This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from af9f09047d [HUDI-3509] Add call procedure for HoodieLogFileCommand
(#5949)
add 6456bd3a51 [HUDI-4273] Support inline schedule clustering for Flink
stream (#5890)
No new revisions were added by this update.
Summary of changes:
.../cluster/strategy/ClusteringPlanStrategy.java | 13 +-
.../compact/ScheduleCompactionActionExecutor.java | 2 +-
.../FlinkRecentDaysClusteringPlanStrategy.java | 65 ----
...nkSelectedPartitionsClusteringPlanStrategy.java | 67 ----
.../apache/hudi/configuration/FlinkOptions.java | 28 +-
.../apache/hudi/configuration/OptionsResolver.java | 51 ++-
.../hudi/sink/StreamWriteOperatorCoordinator.java | 10 +-
.../sink/clustering/ClusteringCommitEvent.java | 10 +-
.../hudi/sink/clustering/ClusteringCommitSink.java | 28 +-
.../hudi/sink/clustering/ClusteringOperator.java | 165 ++++++----
.../sink/clustering/ClusteringPlanOperator.java | 139 +++++++++
.../clustering/ClusteringPlanSourceFunction.java | 13 +-
.../sink/clustering/FlinkClusteringConfig.java | 30 +-
.../sink/clustering/HoodieFlinkClusteringJob.java | 347 +++++++++++++++------
.../apache/hudi/sink/compact/CompactFunction.java | 3 +-
.../hudi/sink/compact/CompactionCommitSink.java | 2 +-
.../java/org/apache/hudi/sink/utils/Pipelines.java | 63 +++-
.../apache/hudi/streamer/HoodieFlinkStreamer.java | 3 +-
.../org/apache/hudi/table/HoodieTableSink.java | 10 +-
.../java/org/apache/hudi/util/ClusteringUtil.java | 80 +++++
.../java/org/apache/hudi/util/StreamerUtil.java | 23 +-
.../apache/hudi/sink/ITTestDataStreamWrite.java | 74 +++++
.../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 29 +-
.../sink/cluster/ITTestHoodieFlinkClustering.java | 45 ++-
.../hudi/sink/utils/ClusteringFunctionWrapper.java | 121 +++++++
.../hudi/sink/utils/InsertFunctionWrapper.java | 34 +-
.../sink/utils/StreamWriteFunctionWrapper.java | 5 +-
.../org/apache/hudi/sink/utils/TestWriteBase.java | 7 +-
.../test/java/org/apache/hudi/utils/TestUtils.java | 10 +
29 files changed, 1104 insertions(+), 373 deletions(-)
delete mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkRecentDaysClusteringPlanStrategy.java
delete mode 100644
hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkSelectedPartitionsClusteringPlanStrategy.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClusteringUtil.java
create mode 100644
hudi-flink-datasource/hudi-flink/src/test/java/org/apache/hudi/sink/utils/ClusteringFunctionWrapper.java
