From 9c0b934b14c7badeaad58ccaa893391dcd7da482 Mon Sep 17 00:00:00 2001 From: xiaoxingstack Date: Tue, 16 Aug 2022 16:15:59 +0800 Subject: [PATCH] =?UTF-8?q?[HUDI-4628]=20hudi-flink=20support=20GLOBAL=5FB?= =?UTF-8?q?LOOM=EF=BC=8CGLOBAL=5FSIMPLE=EF=BC=8CBUCKET=20index=20type?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../org/apache/hudi/index/FlinkHoodieIndexFactory.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndexFactory.java b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndexFactory.java index 54110d93506d..b10014b9183b 100644 --- a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndexFactory.java +++ b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndexFactory.java @@ -25,7 +25,10 @@ import org.apache.hudi.config.HoodieWriteConfig; import org.apache.hudi.exception.HoodieIndexException; import org.apache.hudi.index.bloom.HoodieBloomIndex; +import org.apache.hudi.index.bloom.HoodieGlobalBloomIndex; import org.apache.hudi.index.bloom.ListBasedHoodieBloomIndexHelper; +import org.apache.hudi.index.bucket.HoodieSimpleBucketIndex; +import org.apache.hudi.index.simple.HoodieGlobalSimpleIndex; import org.apache.hudi.index.simple.HoodieSimpleIndex; import org.apache.hudi.index.state.FlinkInMemoryStateIndex; @@ -49,8 +52,14 @@ public static HoodieIndex createIndex(HoodieFlinkEngineContext context, HoodieWr return new FlinkInMemoryStateIndex(context, config); case BLOOM: return new HoodieBloomIndex(config, ListBasedHoodieBloomIndexHelper.getInstance()); + case GLOBAL_BLOOM: + return new HoodieGlobalBloomIndex(config, ListBasedHoodieBloomIndexHelper.getInstance()); case SIMPLE: return new HoodieSimpleIndex(config, Option.empty()); + case GLOBAL_SIMPLE: + return new HoodieGlobalSimpleIndex(config, Option.empty()); + case BUCKET: + return new HoodieSimpleBucketIndex(config); default: throw new HoodieIndexException("Unsupported index type " + config.getIndexType()); }