You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by lz...@apache.org on 2022/01/14 08:09:00 UTC
[flink-table-store] branch master updated (f62e233 -> 1c47a99)

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 f62e233  [hotfix] Move FileStorePathFactory to main from test
     add b2c0a6e  [FLINK-25630] Introduce manifest entry and maniefst file meta
     add 318fe5f  [FLINK-25630] Add tests for FileStorePathFactory
     add 8a05932  [FLINK-25630] Introduce ManifestFile and ManifestList
     add 1c47a99  [hotfix] Add serialVersionUID to all ObjectSerializer

No new revisions were added by this update.

Summary of changes:
 .../flink/table/store/file/KeyValueSerializer.java |   2 +
 .../table/store/file/manifest/ManifestEntry.java   | 148 +++++++++++++++++
 .../file/manifest/ManifestEntrySerializer.java     |  65 ++++++++
 .../table/store/file/manifest/ManifestFile.java    | 127 +++++++++++++++
 .../store/file/manifest/ManifestFileMeta.java      | 121 ++++++++++++++
 .../ManifestFileMetaSerializer.java}               |  49 +++---
 .../table/store/file/manifest/ManifestList.java    | 101 ++++++++++++
 .../file/mergetree/sst/SstFileMetaSerializer.java  |   2 +
 .../store/file/mergetree/sst/SstPathFactory.java   |  10 +-
 .../file/stats/FieldStatsArraySerializer.java      |   2 +
 .../store/file/utils/FileStorePathFactory.java     |  39 ++---
 .../ManifestEntrySerializerTest.java}              |  23 +--
 .../ManifestFileMetaSerializerTest.java}           |  27 ++--
 .../store/file/manifest/ManifestFileTest.java      | 107 +++++++++++++
 .../store/file/manifest/ManifestListTest.java      |  98 ++++++++++++
 .../file/manifest/ManifestTestDataGenerator.java   | 177 +++++++++++++++++++++
 .../store/file/mergetree/sst/SstFileTest.java      |   8 +-
 .../file/mergetree/sst/SstPathFactoryTest.java     |   2 +-
 .../file/mergetree/sst/SstTestDataGenerator.java   |  17 +-
 .../store/file/utils/FileStorePathFactoryTest.java | 121 ++++++++++++++
 20 files changed, 1153 insertions(+), 93 deletions(-)
 create mode 100644 flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestEntry.java
 create mode 100644 flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestEntrySerializer.java
 create mode 100644 flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestFile.java
 create mode 100644 flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestFileMeta.java
 copy flink-table-store-core/src/main/java/org/apache/flink/table/store/file/{mergetree/sst/SstFileMetaSerializer.java => manifest/ManifestFileMetaSerializer.java} (50%)
 create mode 100644 flink-table-store-core/src/main/java/org/apache/flink/table/store/file/manifest/ManifestList.java
 copy flink-table-store-core/src/test/java/org/apache/flink/table/store/file/{mergetree/sst/SstFileMetaSerializerTest.java => manifest/ManifestEntrySerializerTest.java} (56%)
 copy flink-table-store-core/src/test/java/org/apache/flink/table/store/file/{mergetree/sst/SstFileMetaSerializerTest.java => manifest/ManifestFileMetaSerializerTest.java} (53%)
 create mode 100644 flink-table-store-core/src/test/java/org/apache/flink/table/store/file/manifest/ManifestFileTest.java
 create mode 100644 flink-table-store-core/src/test/java/org/apache/flink/table/store/file/manifest/ManifestListTest.java
 create mode 100644 flink-table-store-core/src/test/java/org/apache/flink/table/store/file/manifest/ManifestTestDataGenerator.java
 create mode 100644 flink-table-store-core/src/test/java/org/apache/flink/table/store/file/utils/FileStorePathFactoryTest.java