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 925e8ce [FLINK-27546] Add append only writer which implements the
RecordWriter interface
add d28856e [FLINK-27372] Make DataFileMeta and ManifestFileMeta
schemaless
No new revisions were added by this update.
Summary of changes:
.../connector/sink/FileCommittableSerializer.java | 15 ++-
.../table/store/connector/sink/StoreSink.java | 6 +-
.../store/connector/source/FileStoreSource.java | 3 +-
.../source/FileStoreSourceSplitSerializer.java | 16 ++-
.../connector/sink/CommittableSerializerTest.java | 8 +-
.../sink/FileCommittableSerializerTest.java | 8 +-
.../table/store/connector/sink/TestFileStore.java | 13 +--
.../source/FileStoreSourceSplitGeneratorTest.java | 6 +-
.../source/FileStoreSourceSplitSerializerTest.java | 14 +--
.../connector/source/FileStoreSourceTest.java | 33 +++---
.../PendingSplitsCheckpointSerializerTest.java | 8 +-
.../flink/table/store/file/FileStoreImpl.java | 4 +-
.../flink/table/store/file/data/DataFileMeta.java | 52 +++++-----
.../store/file/data/DataFileMetaSerializer.java | 36 +++----
.../table/store/file/data/DataFileWriter.java | 17 +++-
.../manifest/ManifestCommittableSerializer.java | 16 ++-
.../table/store/file/manifest/ManifestEntry.java | 8 +-
.../file/manifest/ManifestEntrySerializer.java | 29 +++---
.../table/store/file/manifest/ManifestFile.java | 12 +--
.../store/file/manifest/ManifestFileMeta.java | 32 ++----
.../file/manifest/ManifestFileMetaSerializer.java | 24 +++--
.../table/store/file/manifest/ManifestList.java | 5 +-
.../store/file/operation/FileStoreScanImpl.java | 19 +++-
.../table/store/file/stats/BinaryTableStats.java | 111 +++++++++++++++++++++
.../file/stats/FieldStatsArraySerializer.java | 46 ++++-----
.../store/file/stats/FieldStatsCollector.java | 12 ++-
.../store/file/utils/PartitionedManifestMeta.java | 48 +++------
.../table/store/file/utils/SerializationUtils.java | 103 +++++++++++++++++++
.../table/store/file/writer/AppendOnlyWriter.java | 6 +-
.../file/data/DataFileMetaSerializerTest.java | 4 +-
.../flink/table/store/file/data/DataFileTest.java | 41 +++++---
.../ManifestCommittableSerializerTest.java | 19 ++--
.../file/manifest/ManifestEntrySerializerTest.java | 6 +-
.../manifest/ManifestFileMetaSerializerTest.java | 3 +-
.../store/file/manifest/ManifestFileMetaTest.java | 10 +-
.../store/file/manifest/ManifestFileTest.java | 13 +--
.../mergetree/compact/IntervalPartitionTest.java | 7 +-
.../store/file/operation/FileStoreCommitTest.java | 2 -
.../store/file/operation/FileStoreExpireTest.java | 2 -
.../store/file/operation/FileStoreReadTest.java | 9 --
.../store/file/operation/FileStoreScanTest.java | 3 -
.../file/stats/FieldStatsArraySerializerTest.java | 62 ------------
.../store/file/stats/FieldStatsCollectorTest.java | 8 +-
.../file/stats/FileStatsExtractorTestBase.java | 2 +-
.../table/store/file/stats/StatsTestUtils.java | 23 +++++
.../store/file/stats/TestFileStatsExtractor.java | 2 +-
.../store/file/writer/AppendOnlyWriterTest.java | 9 +-
47 files changed, 528 insertions(+), 407 deletions(-)
create mode 100644
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/stats/BinaryTableStats.java
create mode 100644
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/utils/SerializationUtils.java
delete mode 100644
flink-table-store-core/src/test/java/org/apache/flink/table/store/file/stats/FieldStatsArraySerializerTest.java
