You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@hudi.apache.org by ga...@apache.org on 2021/01/22 02:36:42 UTC

[hudi] branch master updated (b64d22e -> 641abe8)

This is an automated email from the ASF dual-hosted git repository.

garyli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.


    from b64d22e  [HUDI-1511] InstantGenerateOperator support multiple parallelism (#2434)
     add 641abe8  [HUDI-1332] Introduce FlinkHoodieBloomIndex to hudi-flink-client (#2375)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/hudi/index/FlinkHoodieIndex.java    |   3 +
 .../hudi/index/bloom/FlinkHoodieBloomIndex.java    | 267 +++++++++++++++++++++
 .../bloom/HoodieFlinkBloomIndexCheckFunction.java} |  31 ++-
 .../src/main}/resources/log4j-surefire.properties  |   0
 .../index/bloom/TestFlinkHoodieBloomIndex.java}    | 203 ++++++++--------
 .../testutils/HoodieFlinkClientTestHarness.java    |  94 ++++++++
 .../testutils/HoodieFlinkWriteableTestTable.java   | 136 +++++++++++
 7 files changed, 626 insertions(+), 108 deletions(-)
 create mode 100644 hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/bloom/FlinkHoodieBloomIndex.java
 copy hudi-client/{hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/HoodieBloomIndexCheckFunction.java => hudi-flink-client/src/main/java/org/apache/hudi/index/bloom/HoodieFlinkBloomIndexCheckFunction.java} (77%)
 copy {hudi-spark-datasource/hudi-spark/src/test => hudi-client/hudi-flink-client/src/main}/resources/log4j-surefire.properties (100%)
 copy hudi-client/{hudi-spark-client/src/test/java/org/apache/hudi/index/bloom/TestHoodieBloomIndex.java => hudi-flink-client/src/test/java/org/apache/hudi/index/bloom/TestFlinkHoodieBloomIndex.java} (72%)
 create mode 100644 hudi-client/hudi-flink-client/src/test/java/org/apache/hudi/testutils/HoodieFlinkWriteableTestTable.java