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 6bc9646337 [flink] fix the issue where AlignedSourceReader might hang, 
and add detailed comments. (#5155)
     add 68d0cbf29a [core] Introduce SupportsBranches to put branch management 
to Catalog (#5157)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/paimon/catalog/AbstractCatalog.java |   8 +-
 .../paimon/catalog/CatalogSnapshotCommit.java      |  67 ++++++
 .../org/apache/paimon/catalog/CatalogUtils.java    |  11 +-
 .../java/org/apache/paimon/catalog/Identifier.java |   4 +-
 .../apache/paimon/catalog/SupportsBranches.java    |  73 +++++++
 .../apache/paimon/catalog/SupportsSnapshots.java   |  18 +-
 .../apache/paimon/operation/OrphanFilesClean.java  |   4 +-
 .../java/org/apache/paimon/rest/RESTCatalog.java   |  28 ++-
 .../paimon/rest/RESTSnapshotCommitFactory.java     |  58 ------
 .../paimon/table/AbstractFileStoreTable.java       |  10 +-
 .../apache/paimon/table/CatalogEnvironment.java    |  58 ++++--
 .../apache/paimon/table/system/BranchesTable.java  |  20 +-
 .../org/apache/paimon/utils/BranchManager.java     | 228 ++-------------------
 .../apache/paimon/utils/CatalogBranchManager.java  |  82 ++++++++
 ...chManager.java => FileSystemBranchManager.java} |  51 ++---
 .../test/java/org/apache/paimon/SnapshotTest.java  |   2 +-
 .../apache/paimon/operation/FileDeletionTest.java  |   2 +-
 .../paimon/operation/PartitionExpireTest.java      |   2 +-
 .../paimon/table/FileStoreTableTestBase.java       |   8 +-
 .../table/system/AggregationFieldsTableTest.java   |   4 +-
 .../paimon/table/system/OptionsTableTest.java      |   4 +-
 .../apache/paimon/utils/SnapshotManagerTest.java   |   2 +-
 .../org/apache/paimon/flink/FileStoreITCase.java   |   4 +-
 .../paimon/flink/action/BranchActionITCase.java    |   8 +-
 .../java/org/apache/paimon/hive/HiveCatalog.java   |   2 +-
 .../apache/paimon/hive/HiveCatalogITCaseBase.java  |   8 +-
 .../spark/procedure/AlterBranchProcedureTest.scala |   3 +-
 .../spark/procedure/BranchProcedureTest.scala      |   3 +-
 28 files changed, 388 insertions(+), 384 deletions(-)
 create mode 100644 
paimon-core/src/main/java/org/apache/paimon/catalog/CatalogSnapshotCommit.java
 create mode 100644 
paimon-core/src/main/java/org/apache/paimon/catalog/SupportsBranches.java
 delete mode 100644 
paimon-core/src/main/java/org/apache/paimon/rest/RESTSnapshotCommitFactory.java
 create mode 100644 
paimon-core/src/main/java/org/apache/paimon/utils/CatalogBranchManager.java
 copy paimon-core/src/main/java/org/apache/paimon/utils/{BranchManager.java => 
FileSystemBranchManager.java} (85%)

Reply via email to