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/flink-table-store.git
from 1c446d3b [hotfix] Minor code refactor in BinaryInMemorySortBuffer
new 9cf4f76b [FLINK-28256] Move the write and prepareCommit logic of
AbstractTableWrite to FileStoreWrite
new 2d056232 [FLINK-28256] Rename WriteRecordConverter to RecordExtractor
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:
.../file/operation/AbstractFileStoreWrite.java | 100 +++++++++++++
.../table/store/file/operation/FileStoreWrite.java | 39 ++++-
.../file/operation/KeyValueFileStoreWrite.java | 4 +-
.../operation/MemoryFileStoreWrite.java} | 19 +--
.../store/table/AppendOnlyFileStoreTable.java | 25 ++--
.../table/ChangelogValueCountFileStoreTable.java | 55 +++----
.../table/ChangelogWithKeyFileStoreTable.java | 60 +++++---
.../table/store/table/sink/AbstractTableWrite.java | 166 ---------------------
.../table/store/table/sink/TableWriteImpl.java | 86 +++++++++++
9 files changed, 313 insertions(+), 241 deletions(-)
rename
flink-table-store-core/src/main/java/org/apache/flink/table/store/{table/sink/MemoryTableWrite.java
=> file/operation/MemoryFileStoreWrite.java} (83%)
delete mode 100644
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/AbstractTableWrite.java
create mode 100644
flink-table-store-core/src/main/java/org/apache/flink/table/store/table/sink/TableWriteImpl.java
