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

Posted to commits@hudi.apache.org by da...@apache.org on 2021/08/04 09:53:34 UTC

[hudi] branch master updated (02331fc -> b8b9d6d)

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 02331fc  [HUDI-2258] Metadata table for flink (#3381)
     add b8b9d6d  [HUDI-2087] Support Append only in Flink stream (#3390)

No new revisions were added by this update.

Summary of changes:
 .../apache/hudi/client/HoodieFlinkWriteClient.java |  6 ++
 .../apache/hudi/configuration/FlinkOptions.java    |  6 ++
 .../sink/partitioner/BucketAssignFunction.java     | 12 ++--
 .../hudi/sink/partitioner/BucketAssigners.java     | 18 ++---
 ...iteWriteProfile.java => EmptyWriteProfile.java} | 13 ++--
 .../sink/partitioner/profile/WriteProfiles.java    | 12 ++--
 .../apache/hudi/streamer/FlinkStreamerConfig.java  |  4 ++
 .../org/apache/hudi/table/HoodieTableFactory.java  | 14 ++--
 .../java/org/apache/hudi/util/StreamerUtil.java    |  7 ++
 .../org/apache/hudi/sink/TestWriteCopyOnWrite.java | 76 ++++++++++++++++++++++
 .../org/apache/hudi/sink/TestWriteMergeOnRead.java |  6 ++
 .../hudi/sink/TestWriteMergeOnReadWithCompact.java | 11 ++--
 .../apache/hudi/table/TestHoodieTableFactory.java  | 18 +++++
 .../test/java/org/apache/hudi/utils/TestData.java  | 42 ++++++++++++
 14 files changed, 213 insertions(+), 32 deletions(-)
 rename hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/profile/{OverwriteWriteProfile.java => EmptyWriteProfile.java} (74%)