[MINOR] fixed building IndexFileFilter with a wrong condition in HoodieGlobalBloomIndex class (#1537)
This commit is contained in:
@@ -86,7 +86,7 @@ public class HoodieGlobalBloomIndex<T extends HoodieRecordPayload> extends Hoodi
|
|||||||
JavaPairRDD<String, String> partitionRecordKeyPairRDD) {
|
JavaPairRDD<String, String> partitionRecordKeyPairRDD) {
|
||||||
|
|
||||||
IndexFileFilter indexFileFilter =
|
IndexFileFilter indexFileFilter =
|
||||||
config.getBloomIndexPruneByRanges() ? new IntervalTreeBasedGlobalIndexFileFilter(partitionToFileIndexInfo)
|
config.useBloomIndexTreebasedFilter() ? new IntervalTreeBasedGlobalIndexFileFilter(partitionToFileIndexInfo)
|
||||||
: new ListBasedGlobalIndexFileFilter(partitionToFileIndexInfo);
|
: new ListBasedGlobalIndexFileFilter(partitionToFileIndexInfo);
|
||||||
|
|
||||||
return partitionRecordKeyPairRDD.map(partitionRecordKeyPair -> {
|
return partitionRecordKeyPairRDD.map(partitionRecordKeyPair -> {
|
||||||
|
|||||||
Reference in New Issue
Block a user