This is an automated email from the ASF dual-hosted git repository.
czweng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink-table-store.git
from 3e476570 [FLINK-30373] Flink-table-runtime free for
flink-table-store-codegen
new 2073bd66 [FLINK-30210] Refactor StoreWriteOperator so periodic full
compaction writer can be reused in compactor sink
new 333bb8da [FLINK-30210] Refactor StoreCompactOperator to accept records
containing partitions and buckets in Table Store
The 2 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:
.../store/connector/TableStoreManagedFactory.java | 11 +-
.../store/connector/FlinkConnectorOptions.java | 18 --
.../store/connector/sink/FlinkSinkBuilder.java | 24 +-
...rator.java => FullChangelogStoreSinkWrite.java} | 108 ++++---
.../store/connector/sink/StoreCompactOperator.java | 114 +++----
.../table/store/connector/sink/StoreSink.java | 37 +--
.../table/store/connector/sink/StoreSinkWrite.java | 32 +-
.../store/connector/sink/StoreSinkWriteImpl.java | 116 ++++++++
.../store/connector/sink/StoreWriteOperator.java | 80 ++---
.../table/store/connector/sink/TableStoreSink.java | 4 +-
.../connector/source/FileStoreEmptySource.java | 99 -------
.../store/connector/source/FlinkSourceBuilder.java | 6 +-
.../store/connector/AlterTableCompactITCase.java | 329 ---------------------
.../connector/TableStoreManagedFactoryTest.java | 24 --
.../file/append/AppendOnlyCompactManager.java | 2 +-
15 files changed, 278 insertions(+), 726 deletions(-)
rename
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/{FullChangelogStoreWriteOperator.java
=> FullChangelogStoreSinkWrite.java} (84%)
copy
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableWrite.java
=>
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWrite.java
(58%)
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/sink/StoreSinkWriteImpl.java
delete mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreEmptySource.java
delete mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/AlterTableCompactITCase.java
