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

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


    from ee68fbb0fc [hive] Fix hive catalog create partitions using table 
location. (#5029)
     add ecdf46fdc3 [flink] refactor the clone action as we introduced external 
path (#4844)

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/paimon/io/DataFileMeta.java    |  22 ++
 .../org/apache/paimon/manifest/ManifestFile.java   |   7 +-
 .../apache/paimon/flink/action/CloneAction.java    |  48 ++-
 .../apache/paimon/flink/clone/CloneFileInfo.java   |  15 +-
 .../apache/paimon/flink/clone/CloneFilesUtil.java  | 318 ++++++++++++++++++++
 ...FileOperator.java => CopyDataFileOperator.java} | 104 +++----
 .../flink/clone/CopyManifestFileOperator.java      | 221 ++++++++++++++
 .../flink/clone/CopyMetaFilesForCloneOperator.java | 263 ++++++++++++++++
 .../flink/clone/PickFilesForCloneOperator.java     | 174 -----------
 .../apache/paimon/flink/clone/PickFilesUtil.java   | 201 -------------
 .../paimon/flink/action/CloneActionITCase.java     | 329 +++++++++++++++++++--
 11 files changed, 1219 insertions(+), 483 deletions(-)
 create mode 100644 
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CloneFilesUtil.java
 rename 
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/{CopyFileOperator.java
 => CopyDataFileOperator.java} (53%)
 create mode 100644 
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CopyManifestFileOperator.java
 create mode 100644 
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/CopyMetaFilesForCloneOperator.java
 delete mode 100644 
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/PickFilesForCloneOperator.java
 delete mode 100644 
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/clone/PickFilesUtil.java

Reply via email to