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 b647508 [FLINK-25803] Implement partition and bucket filter in
FileStoreScanImpl
add e718d80 [FLINK-25820] Introduce list serialization to ObjectSerializer
add 5fd4529 [FLINK-25820] Introduce FileStoreRead to FileStore
add 9fad056 [FLINK-25820] Introduce FileStoreSourceSplit
add 59139a7 [FLINK-25820] Introduce FileStoreSourceSplitState
add cb18cfb [FLINK-25820] Introduce PendingSplitsCheckpoint
new 166b066 [FLINK-25820] Introduce FileStoreSourceSplitGenerator
new 4cf7ef9 [FLINK-25820] Introduce StaticFileStoreSplitEnumerator
new a7819f7 [FLINK-25820] Introduce FileStoreSourceSplitReader
new 1601a3a [FLINK-25820] Introduce FileStoreSourceReader
new 4089be2 [FLINK-25820] Introduce FileStoreSource
The 5 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:
flink-table-store-connector/pom.xml | 28 ++
.../connector/sink/LocalCommittableSerializer.java | 30 +--
.../store/connector/source/FileStoreSource.java | 130 ++++++++++
.../connector/source/FileStoreSourceReader.java | 73 ++++++
.../connector/source/FileStoreSourceSplit.java | 105 ++++++++
.../source/FileStoreSourceSplitGenerator.java | 79 ++++++
.../source/FileStoreSourceSplitReader.java | 203 +++++++++++++++
.../FileStoreSourceSplitSerializer.java} | 51 ++--
.../source/FileStoreSourceSplitState.java | 55 ++++
.../connector/source/PendingSplitsCheckpoint.java | 55 ++++
.../source/PendingSplitsCheckpointSerializer.java | 73 ++++++
.../source/StaticFileStoreSplitEnumerator.java | 93 +++++++
.../table/store/connector/sink/TestFileStore.java | 6 +
.../source/FileStoreSourceReaderTest.java | 68 +++++
.../source/FileStoreSourceSplitGeneratorTest.java | 119 +++++++++
.../source/FileStoreSourceSplitReaderTest.java | 284 +++++++++++++++++++++
.../source/FileStoreSourceSplitSerializerTest.java | 104 ++++++++
.../source/FileStoreSourceSplitStateTest.java | 72 ++++++
.../PendingSplitsCheckpointSerializerTest.java | 117 +++++++++
.../source/StaticFileStoreSplitEnumeratorTest.java | 108 ++++++++
.../store/connector/source/TestFileStoreRead.java | 117 +++++++++
.../apache/flink/table/store/file/FileStore.java | 3 +
.../{FileStoreWrite.java => FileStoreRead.java} | 23 +-
.../table/store/file/operation/FileStoreScan.java | 20 ++
.../table/store/file/utils/ObjectSerializer.java | 20 ++
25 files changed, 1968 insertions(+), 68 deletions(-)
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSource.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceReader.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplit.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitGenerator.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReader.java
copy
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/{sink/LocalCommittableSerializer.java
=> source/FileStoreSourceSplitSerializer.java} (53%)
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitState.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/PendingSplitsCheckpoint.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/PendingSplitsCheckpointSerializer.java
create mode 100644
flink-table-store-connector/src/main/java/org/apache/flink/table/store/connector/source/StaticFileStoreSplitEnumerator.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceReaderTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitGeneratorTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitReaderTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitSerializerTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/FileStoreSourceSplitStateTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/PendingSplitsCheckpointSerializerTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/StaticFileStoreSplitEnumeratorTest.java
create mode 100644
flink-table-store-connector/src/test/java/org/apache/flink/table/store/connector/source/TestFileStoreRead.java
copy
flink-table-store-core/src/main/java/org/apache/flink/table/store/file/operation/{FileStoreWrite.java
=> FileStoreRead.java} (58%)
