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