This is an automated email from the ASF dual-hosted git repository.
zhangyue19921010 pushed a change to branch stream-binary-copy
in repository https://gitbox.apache.org/repos/asf/hudi.git
from b8e88905c1e fix ut
add 6b3e7e8dcd3 code review
No new revisions were added by this update.
Summary of changes:
.../org/apache/hudi/io/HoodieBinaryCopyHandle.java | 153 ++++++++++
.../org/apache/hudi/io/HoodieCreateHandle.java | 14 +-
.../apache/hudi/io/HoodieCreateRewriteHandle.java | 114 -------
.../hudi/io/HoodieUnboundedCreateHandle.java | 2 +-
.../hudi/io/SingleFileHandleRewriteFactory.java | 15 +-
...parkBinaryCopyClusteringExecutionStrategy.java} | 62 +---
.../TestHoodieClientOnCopyOnWriteStorage.java | 2 +-
.../bloom/HoodieDynamicBoundedBloomFilter.java | 6 +-
.../common/bloom/InternalDynamicBloomFilter.java | 16 +
.../apache/hudi/common/config/TypedProperties.java | 2 +-
.../io/storage/rewrite/HoodieFileRewriter.java | 14 +-
.../storage/rewrite/HoodieFileRewriterFactory.java | 18 +-
.../io/storage/TestHoodieFileMetadataMerger.java | 6 +-
.../hudi/parquet/io/HoodieParquetFileRewriter.java | 43 ++-
.../hudi/parquet/io/HoodieParquetRewriterBase.java | 47 ++-
.../parquet/io/HoodieParquetRewriterFactory.java | 26 +-
.../parquet/io/TestHoodieParquetFileRewriter.java | 37 ++-
.../apache/hudi/spark/internal/DefaultSource.java | 2 +-
.../TestClusteringBinaryCopyStrategy.scala | 330 +++++++++++++++++++++
19 files changed, 652 insertions(+), 257 deletions(-)
create mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieBinaryCopyHandle.java
delete mode 100644
hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCreateRewriteHandle.java
rename
hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/{SparkStreamCopyClusteringExecutionStrategy.java
=> SparkBinaryCopyClusteringExecutionStrategy.java} (56%)
create mode 100644
hudi-spark-datasource/hudi-spark/src/test/scala/org/apache/spark/sql/hudi/procedure/TestClusteringBinaryCopyStrategy.scala
