This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch release-0.8
in repository https://gitbox.apache.org/repos/asf/paimon.git
from c2c72e3be [core] Fix that cannot read UPDATE_BEFORE of ignore-delete
table (#3467)
new 46d9f3d5c [core] Fisrt row merge engine supports none changelog
producer (#3452)
new de5474782 [doc] Delete redundant symbols in compaction doc (#3453)
new 3b6f9ea6f [core] Optimize snapshots table when specific snapshot id
(#3339)
new 1c677142b [core] Fix FilesTable splits too big to distribute (#3454)
new 9e60f8eb4 [core] added greater and less than query optimization to
snapshots table queries (#3396)
new d92091c57 [core] Fix should ignore the Long.MIN value when create TAG
based on the watermark. (#3457)
new 432d7e23e [spark] Spark 3.2 insert overwrite test support (#3458)
new 3119130f1 [core] Fix snapshot EARLIEST first write value (#3398)
new a0a76e6fd [doc] Fix changelog producer doc to better desc (#3469)
new 66074c28f [minor] Document specify hugo version (#3471)
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/README.md | 4 +-
docs/content/engines/overview.md | 6 +-
docs/content/maintenance/dedicated-compaction.md | 2 +-
.../primary-key-table/changelog-producer.md | 2 +-
docs/content/primary-key-table/merge-engine.md | 5 +-
.../main/java/org/apache/paimon/CoreOptions.java | 3 +-
.../org/apache/paimon/lookup/LookupStrategy.java | 31 ++---
.../LeafPredicateExtractor.java} | 24 ++--
.../paimon/operation/KeyValueFileStoreWrite.java | 7 +-
.../org/apache/paimon/schema/SchemaValidation.java | 5 +-
.../apache/paimon/table/ExpireSnapshotsImpl.java | 2 +-
.../table/source/InnerStreamTableScanImpl.java | 3 +-
.../apache/paimon/table/source/SingletonSplit.java | 11 +-
.../table/system/AggregationFieldsTable.java | 18 +--
.../paimon/table/system/AllTableOptionsTable.java | 23 +---
.../apache/paimon/table/system/BranchesTable.java | 16 +--
.../paimon/table/system/CatalogOptionsTable.java | 11 +-
.../apache/paimon/table/system/ConsumersTable.java | 18 +--
.../org/apache/paimon/table/system/FilesTable.java | 132 +++++++++------------
.../apache/paimon/table/system/ManifestsTable.java | 34 ++----
.../apache/paimon/table/system/OptionsTable.java | 16 +--
.../paimon/table/system/PartitionsTable.java | 8 +-
.../apache/paimon/table/system/SchemasTable.java | 22 +---
.../apache/paimon/table/system/SnapshotsTable.java | 76 ++++++++----
.../apache/paimon/table/system/StatisticTable.java | 23 +---
.../org/apache/paimon/table/system/TagsTable.java | 16 +--
.../org/apache/paimon/tag/TagTimeExtractor.java | 2 +-
.../org/apache/paimon/utils/SnapshotManager.java | 27 +++++
.../LookupChangelogMergeFunctionWrapperTest.java | 6 +-
.../org/apache/paimon/tag/TagAutoManagerTest.java | 4 +
.../apache/paimon/flink/CatalogTableITCase.java | 30 ++++-
.../org/apache/paimon/flink/FirstRowITCase.java | 24 ++--
...DLTest.scala => InsertOverwriteTableTest.scala} | 2 +-
.../spark/sql/InsertOverwriteTableTest.scala} | 2 +-
.../spark/sql/InsertOverwriteTableTest.scala} | 2 +-
.../spark/sql/InsertOverwriteTableTest.scala} | 2 +-
...teTest.scala => InsertOverwriteTableTest.scala} | 2 +-
37 files changed, 290 insertions(+), 331 deletions(-)
copy paimon-common/src/main/java/org/apache/paimon/{utils/MapBuilder.java =>
predicate/LeafPredicateExtractor.java} (52%)
copy paimon-common/src/test/java/org/apache/paimon/factories/DummyFactory.java
=> paimon-core/src/main/java/org/apache/paimon/table/source/SingletonSplit.java
(77%)
copy
paimon-spark/paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/{DDLTest.scala
=> InsertOverwriteTableTest.scala} (92%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-3.3/src/test/scala/org/apache/paimon/spark/sql/InsertOverwriteTableTest.scala}
(92%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-3.4/src/test/scala/org/apache/paimon/spark/sql/InsertOverwriteTableTest.scala}
(92%)
copy
paimon-spark/{paimon-spark-3.2/src/test/scala/org/apache/paimon/spark/sql/DDLTest.scala
=>
paimon-spark-3.5/src/test/scala/org/apache/paimon/spark/sql/InsertOverwriteTableTest.scala}
(92%)
rename
paimon-spark/paimon-spark-common/src/test/scala/org/apache/paimon/spark/sql/{InsertOverwriteTest.scala
=> InsertOverwriteTableTest.scala} (99%)
