This is an automated email from the ASF dual-hosted git repository.
huaxingao pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git
The following commit(s) were added to refs/heads/main by this push:
new 5a5ba0d473 Parquet: Fix UnnecessaryParentheses warning (#14361)
5a5ba0d473 is described below
commit 5a5ba0d473086266fde00f3cbb1e2415ebe8cc6a
Author: Yuya Ebihara <[email protected]>
AuthorDate: Sat Oct 18 09:04:49 2025 +0900
Parquet: Fix UnnecessaryParentheses warning (#14361)
---
parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java
b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java
index e042504ca1..7e0c7f5f3f 100644
--- a/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java
+++ b/parquet/src/main/java/org/apache/iceberg/parquet/ParquetIO.java
@@ -25,7 +25,6 @@ import java.io.OutputStream;
import java.nio.ByteBuffer;
import java.util.List;
import java.util.concurrent.CompletableFuture;
-import java.util.function.IntFunction;
import java.util.stream.Collectors;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
@@ -178,9 +177,8 @@ class ParquetIO {
@Override
public void readVectored(List<ParquetFileRange> ranges,
ByteBufferAllocator allocate)
throws IOException {
- IntFunction<ByteBuffer> delegateAllocate = (allocate::allocate);
List<FileRange> delegateRange = convertRanges(ranges);
- delegate.readVectored(delegateRange, delegateAllocate);
+ delegate.readVectored(delegateRange, allocate::allocate);
}
private static List<FileRange> convertRanges(List<ParquetFileRange>
ranges) {