This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch release-0.5
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git
from a4d7ad054 [doc] Update stable 0.5
new f03a5bee1 [doc] Document more hadoop-conf-dir
new b974661db [doc] Update confused documentation
new 23280843f [doc] Update trino doc to trino 422 (#1884)
new e6a98ba95 [doc] Fix minor SQL error in trino.md (#1882)
new 461096ef6 [doc] Document Spark truncate table
new 4345fa60c [doc] Document performance for dynamic bucket
new 10d933cfb [doc] Document warehouse dir for FlinkGenericCatalog
new cb4dbc28a [doc] Correct the errors in the document (#1928)
new 52be707ed [flink] Fix global dynamic bucket mode (#1914)
new d7b8107ed [doc] Add presto sql 332 to download
new 6f5fa5727 [doc] Document Cross Partitions Update Dynamic Bucket Mode
not work in 0.5.0
The 11 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/content/api/java-api.md | 1 +
docs/content/concepts/primary-key-table.md | 19 +-
docs/content/engines/flink.md | 5 +
docs/content/engines/hive.md | 1 +
docs/content/engines/overview.md | 2 +-
docs/content/engines/presto.md | 2 +
docs/content/engines/trino.md | 36 +-
docs/content/how-to/cdc-ingestion.md | 9 +-
docs/content/how-to/creating-catalogs.md | 5 +-
docs/content/how-to/writing-tables.md | 17 +-
docs/content/project/download.md | 2 +
.../data/serializer/InternalRowSerializer.java | 2 +-
.../paimon/disk/BufferFileReaderInputView.java | 99 ++++++
.../org/apache/paimon/disk/ExternalBuffer.java | 383 +++++++++++++++++++++
.../org/apache/paimon/disk/ExternalBufferTest.java | 209 +++++++++++
.../paimon/flink/sink/cdc/CdcSinkBuilder.java | 4 -
.../sink/cdc/FlinkCdcSyncDatabaseSinkBuilder.java | 3 -
.../flink/sink/index/GlobalDynamicBucketSink.java | 16 +-
.../sink/index/GlobalDynamicCdcBucketSink.java | 133 -------
.../flink/sink/index/GlobalIndexAssigner.java | 29 +-
.../sink/index/GlobalIndexAssignerOperator.java | 107 ++++--
.../paimon/flink/sink/index/IndexBootstrap.java | 48 ++-
.../sink/index/KeyPartRowChannelComputer.java | 6 +-
.../flink/GlobalDynamicBucketTableITCase.java | 19 +
.../sink/cdc/FlinkCdcSyncTableSinkITCase.java | 2 +
.../flink/sink/index/IndexBootstrapTest.java | 17 +-
26 files changed, 942 insertions(+), 234 deletions(-)
create mode 100644
paimon-core/src/main/java/org/apache/paimon/disk/BufferFileReaderInputView.java
create mode 100644
paimon-core/src/main/java/org/apache/paimon/disk/ExternalBuffer.java
create mode 100644
paimon-core/src/test/java/org/apache/paimon/disk/ExternalBufferTest.java
delete mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/sink/index/GlobalDynamicCdcBucketSink.java