This is an automated email from the ASF dual-hosted git repository. czy006 pushed a commit to branch jira/JSPT-2568 in repository https://gitbox.apache.org/repos/asf/amoro.git
commit 43b0ea699a1343a1c9d666c5cfc3d0954558cb90 Merge: e215c8b4a 0a686b738 Author: jinyaqia1 <[email protected]> AuthorDate: Wed Jul 1 11:58:18 2026 +0800 Merge branch 'jira/JSPT-2570' into 'dev' [JSPT-2570] Stp-Iceberg的 Producer入口统一迁移至amoro-producer模块并做统一优化 See merge request shopline/datacenter/dp/dpops/amoro!24 amoro-producer/README.md | 801 ++++++++++++++------- amoro-producer/pom.xml | 2 +- .../apache/amoro/producer/LakehouseProducer.scala | 32 + .../amoro/producer/PaimonExpireSnapshots.scala | 491 ------------- .../amoro/producer/PaimonRemoveOrphanFiles.scala | 478 ------------ .../apache/amoro/producer/core/ActionResult.scala | 40 + .../apache/amoro/producer/core/ProducerApp.scala | 307 ++++++++ .../amoro/producer/core/ProducerCliParser.scala | 243 +++++++ .../amoro/producer/core/ProducerConfig.scala | 29 + .../amoro/producer/core/ProducerContext.scala | 28 + .../amoro/producer/core/ProducerOptions.scala | 51 ++ .../amoro/producer/core/ProducerSummary.scala | 76 ++ .../org/apache/amoro/producer/core/RetryMode.scala | 26 + .../amoro/producer/core/TableActionJsonLog.scala | 125 ++++ .../apache/amoro/producer/core/TableFilter.scala | 53 ++ .../apache/amoro/producer/core/TableResolver.scala | 109 +++ .../apache/amoro/producer/core/TargetTable.scala | 21 + .../producer/paimon/PaimonCompactAction.scala | 373 ++++++++++ .../paimon/PaimonCompactManifestAction.scala | 125 ++++ .../paimon/PaimonExpireSnapshotsAction.scala | 260 +++++++ .../producer/paimon/PaimonFormatAdapter.scala | 79 ++ .../paimon/PaimonRemoveOrphanFilesAction.scala | 159 ++++ .../amoro/producer/paimon/PaimonSqlRunner.scala | 33 + .../amoro/producer/paimon/PaimonSqlUtils.scala | 63 ++ .../amoro/producer/spi/LakeFormatAdapter.scala | 35 + .../apache/amoro/producer/spi/ProducerAction.scala | 41 ++ .../amoro/producer/LakehouseProducerTest.scala | 398 ++++++++++ .../amoro/producer/core/ActionResultTest.scala | 129 ++++ .../amoro/producer/core/ProducerAppTest.scala | 584 +++++++++++++++ .../producer/core/ProducerCliParserTest.scala | 246 +++++++ .../amoro/producer/core/TableFilterTest.scala | 52 ++ .../amoro/producer/core/TableResolverTest.scala | 200 +++++ .../producer/paimon/PaimonCompactActionTest.scala | 395 ++++++++++ .../paimon/PaimonCompactManifestActionTest.scala | 167 +++++ .../paimon/PaimonExpireSnapshotsActionTest.scala | 320 ++++++++ .../producer/paimon/PaimonFormatAdapterTest.scala | 174 +++++ .../paimon/PaimonRemoveOrphanFilesActionTest.scala | 175 +++++ 37 files changed, 5679 insertions(+), 1241 deletions(-)
