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 55f2102ed [core] Use TimeTravelUtil to stats read and manifests table
add 6f033f0a9 [core] Introduce expire_tags action and procedure with
olderThan user custom time (#4138)
No new revisions were added by this update.
Summary of changes:
docs/content/flink/procedures.md | 14 ++
docs/content/spark/procedures.md | 11 ++
.../java/org/apache/paimon/tag/TagAutoManager.java | 6 +-
.../java/org/apache/paimon/tag/TagTimeExpire.java | 45 ++++++-
...ckToProcedure.java => ExpireTagsProcedure.java} | 51 ++++----
.../ProcedurePositionalArgumentsITCase.java | 27 ++++
.../{RepairAction.java => ExpireTagsAction.java} | 21 +--
...onFactory.java => ExpireTagsActionFactory.java} | 24 ++--
...eTagProcedure.java => ExpireTagsProcedure.java} | 65 ++++------
.../services/org.apache.paimon.factories.Factory | 2 +
.../paimon/flink/action/ExpireTagsActionTest.java | 108 ++++++++++++++++
.../flink/procedure/ExpireTagsProcedureITCase.java | 141 +++++++++++++++++++++
.../org/apache/paimon/spark/SparkProcedures.java | 2 +
...umerProcedure.java => ExpireTagsProcedure.java} | 71 +++++------
.../spark/procedure/ExpireTagsProcedureTest.scala | 132 +++++++++++++++++++
15 files changed, 591 insertions(+), 129 deletions(-)
copy
paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/{RollbackToProcedure.java
=> ExpireTagsProcedure.java} (52%)
copy
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/{RepairAction.java
=> ExpireTagsAction.java} (62%)
copy
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/{RewriteFileIndexActionFactory.java
=> ExpireTagsActionFactory.java} (65%)
copy
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/{CreateTagProcedure.java
=> ExpireTagsProcedure.java} (52%)
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/action/ExpireTagsActionTest.java
create mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/procedure/ExpireTagsProcedureITCase.java
copy
paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/{ResetConsumerProcedure.java
=> ExpireTagsProcedure.java} (55%)
create mode 100644
paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/procedure/ExpireTagsProcedureTest.scala
