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 44dfecd [FLINK-25876] Implement overwrite in FlinkStoreCommitImpl
add b9e3055 [FLINK-26066] Introduce FileStoreRead
No new revisions were added by this update.
Summary of changes:
.../source/FileStoreSourceReaderTest.java | 3 +-
.../source/FileStoreSourceSplitReaderTest.java | 61 +++++----
...stFileStoreRead.java => TestDataReadWrite.java} | 93 ++++++--------
.../table/store/file/mergetree/MergeTree.java | 112 -----------------
.../store/file/mergetree/MergeTreeReader.java | 16 +--
.../store/file/mergetree/MergeTreeWriter.java | 14 +--
.../store/file/mergetree/sst/SstFileReader.java | 138 +++++++++++++++++++++
.../sst/{SstFile.java => SstFileWriter.java} | 90 ++------------
.../FileStoreReadImpl.java} | 57 +++++----
.../store/file/operation/FileStoreWriteImpl.java | 106 ++++++++++++++--
.../table/store/file/mergetree/MergeTreeTest.java | 109 +++++++++++-----
.../store/file/mergetree/sst/SstFileTest.java | 33 +++--
.../store/file/operation/OperationTestUtils.java | 77 +++++++-----
.../table/store/file/utils/FlushingAvroFormat.java | 70 +++++++++++
14 files changed, 583 insertions(+), 396 deletions(-)
rename
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/{TestFileStoreRead.java
=> TestDataReadWrite.java} (52%)
delete mode 100644
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/MergeTree.java
create mode 100644
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/sst/SstFileReader.java
rename
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/mergetree/sst/{SstFile.java
=> SstFileWriter.java} (74%)
rename
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/{mergetree/MergeTreeFactory.java
=> operation/FileStoreReadImpl.java} (50%)
create mode 100644
flink-table-store-core/src/test/java/org/apache/flink/table/store/file/utils/FlushingAvroFormat.java
