danny0405 commented on code in PR #13060:
URL: https://github.com/apache/hudi/pull/13060#discussion_r2026501136
##########
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/FileIndex.java:
##########
@@ -69,7 +70,7 @@ public class FileIndex implements Serializable {
private final org.apache.hadoop.conf.Configuration hadoopConf;
private final PartitionPruners.PartitionPruner partitionPruner; // for
partition pruning
private final ColumnStatsProbe colStatsProbe; // for
probing column stats
- private final int dataBucketHashing; //
for bucket pruning
+ private final Option<Functions.Function1<Integer, Integer>> dataBucket;
// for bucket pruning
Review Comment:
dataBucket -> dataBucketFunc
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@hudi.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
