feat: moving to read vector and sync client

Author: stubz151

aws/src/main/java/org/apache/iceberg/aws/s3/AnalyticsAcceleratorInputStreamWrapper.java

@@ -77,6 +77,7 @@ public void close() throws IOException {
   @Override
   public void readVectored(List<ParquetObjectRange> ranges, IntFunction<ByteBuffer> allocate)
       throws IOException {
+    LOG.info("Read vectored ranges: {}", ranges);
     this.delegate.readVectored(convertRanges(ranges), allocate, LOG_BYTE_BUFFER_RELEASED);
   }
 

gradle/libs.versions.toml

@@ -22,7 +22,7 @@
 [versions]
 activation = "1.1.1"
 aliyun-sdk-oss = "3.10.2"
-analyticsaccelerator = "1.2.2"
+analyticsaccelerator = "SNAPSHOT"
 antlr = "4.9.3"
 antlr413 = "4.13.1" # For Spark 4.0 support
 aircompressor = "0.27"

parquet/src/main/java/org/apache/iceberg/parquet/Parquet.java

@@ -1339,7 +1339,6 @@ public <D> CloseableIterable<D> build() {
         if (fileDecryptionProperties != null) {
           optionsBuilder.withDecryption(fileDecryptionProperties);
         }
-        optionsBuilder.withUseHadoopVectoredIo(true);
         ParquetReadOptions options = optionsBuilder.build();
 
         NameMapping mapping;

parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java

@@ -141,7 +141,6 @@ public void readVectored(List<ParquetFileRange> ranges, ByteBufferAllocator allo
         throws IOException {
       IntFunction<ByteBuffer> delegateAllocate = (allocate::allocate);
       List<ParquetObjectRange> delegateRange = convertRanges(ranges);
-
       delegate.readVectored(delegateRange, delegateAllocate);
     }