This is an automated email from the ASF dual-hosted git repository.
vinoyang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from ecbd389 [HUDI-1478] Introduce HoodieBloomIndex to hudi-java-client
(#2608)
add d415d45 [HUDI-1729] Asynchronous Hive sync and commits cleaning for
Flink writer (#2732)
No new revisions were added by this update.
Summary of changes:
.../apache/hudi/client/HoodieFlinkWriteClient.java | 91 +++++++++++++---
hudi-flink/pom.xml | 10 ++
.../apache/hudi/configuration/FlinkOptions.java | 117 ++++++++++++++++++++-
.../java/org/apache/hudi/sink/CleanFunction.java | 89 ++++++++++++++++
.../hudi/sink/StreamWriteOperatorCoordinator.java | 47 ++++++++-
.../hudi/sink/compact/CompactionCommitSink.java | 8 +-
.../sink/partitioner/BucketAssignFunction.java | 17 ++-
.../apache/hudi/sink/utils/HiveSyncContext.java | 89 ++++++++++++++++
.../apache/hudi/sink/utils/NonThrownExecutor.java | 78 ++++++++++++++
.../hudi/streamer/HoodieFlinkStreamerV2.java | 12 ++-
.../org/apache/hudi/table/HoodieTableSink.java | 9 +-
.../java/org/apache/hudi/util/StreamerUtil.java | 22 ++++
.../org/apache/hudi/sink/StreamWriteITCase.java | 15 ++-
.../sink/TestStreamWriteOperatorCoordinator.java | 32 +++++-
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 4 +-
.../apache/hudi/table/HoodieDataSourceITCase.java | 35 +++++-
.../org/apache/hudi/utils/TestConfigurations.java | 11 +-
.../test/java/org/apache/hudi/utils/TestData.java | 2 +-
.../utils/factory/ContinuousFileSourceFactory.java | 11 +-
.../hudi/utils/source/ContinuousFileSource.java | 4 +-
.../{test_source2.data => test_source_2.data} | 0
hudi-flink/src/test/resources/test_source_3.data | 8 ++
packaging/hudi-flink-bundle/pom.xml | 34 ++++++
23 files changed, 704 insertions(+), 41 deletions(-)
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/CleanFunction.java
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java
create mode 100644
hudi-flink/src/main/java/org/apache/hudi/sink/utils/NonThrownExecutor.java
rename hudi-flink/src/test/resources/{test_source2.data => test_source_2.data}
(100%)
create mode 100644 hudi-flink/src/test/resources/test_source_3.data
