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