diff --git a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBaseBloomIndexCheckFunction.java b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBaseBloomIndexCheckFunction.java index 95a225547..2ca563aa3 100644 --- a/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBaseBloomIndexCheckFunction.java +++ b/hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBaseBloomIndexCheckFunction.java @@ -36,8 +36,7 @@ import java.util.List; /** * Function performing actual checking of list containing (fileId, hoodieKeys) against the actual files. */ -//TODO we can move this class into the hudi-client-common and reuse it for spark client -public class HoodieBaseBloomIndexCheckFunction +public class HoodieBaseBloomIndexCheckFunction implements Function>, Iterator>> { private final HoodieTable hoodieTable; @@ -54,16 +53,6 @@ public class HoodieBaseBloomIndexCheckFunction return new LazyKeyCheckIterator(fileParitionRecordKeyTripletItr); } - @Override - public Function>> compose(Function>> before) { - return null; - } - - @Override - public Function>, V> andThen(Function>, ? extends V> after) { - return null; - } - class LazyKeyCheckIterator extends LazyIterableIterator, List> { private HoodieKeyLookupHandle keyLookupHandle;