Merged the two channels

deephaven · Dec 18, 2023 · 093567f · 093567f
1 parent adc7d67
commit 093567f
Show file tree

Hide file tree

Showing 3 changed files with 142 additions and 232 deletions.
diff --git a/.../table/src/main/java/io/deephaven/parquet/table/util/S3BackedSeekableChannelProvider.java b/.../table/src/main/java/io/deephaven/parquet/table/util/S3BackedSeekableChannelProvider.java
@@ -65,5 +65,7 @@ public SeekableByteChannel getWriteChannel(@NotNull final Path path, final boole
 
     public void close() throws IOException {
         s3AsyncClient.close();
+        readAheadBuffersCache.invalidateAll();
+        readAheadBuffersCache.cleanUp();
     }
 }
diff --git a/...s/parquet/table/src/main/java/io/deephaven/parquet/table/util/S3ReadAheadByteChannel.java b/...s/parquet/table/src/main/java/io/deephaven/parquet/table/util/S3ReadAheadByteChannel.java