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/incubator-paimon.git
from 500f86cd2 [flink] Supports watermark transmitting for consumer-id mode
(#1373)
add 93e3dd5ba [flink] Remove per record RecordsWithSplitIds (#1370)
No new revisions were added by this update.
Summary of changes:
.../generated/flink_connector_configuration.html | 6 -
.../paimon/flink/ContinuousFileStoreITCase.java | 15 ---
.../paimon/flink/ContinuousFileStoreITCase.java | 15 ---
.../apache/paimon/flink/FlinkConnectorOptions.java | 17 ---
.../flink/source/ContinuousFileStoreSource.java | 22 +---
.../paimon/flink/source/FileStoreSourceReader.java | 26 +---
.../flink/source/FileStoreSourceSplitReader.java | 46 ++++---
...rRecords.java => FlinkRecordsWithSplitIds.java} | 40 +++++--
.../apache/paimon/flink/source/FlinkSource.java | 8 +-
.../apache/paimon/flink/source/RecordLimiter.java | 7 ++
.../paimon/flink/source/RecordsFunction.java | 132 ---------------------
.../paimon/flink/ContinuousFileStoreITCase.java | 7 --
.../flink/source/FileStoreSourceReaderTest.java | 11 +-
.../source/FileStoreSourceSplitReaderTest.java | 75 ++++++------
...Test.java => FlinkRecordsWithSplitIdsTest.java} | 83 +++++++++----
.../paimon/flink/source/RecordsFunctionTest.java | 89 --------------
16 files changed, 174 insertions(+), 425 deletions(-)
rename
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/{SingleIteratorRecords.java
=> FlinkRecordsWithSplitIds.java} (62%)
delete mode 100644
paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/source/RecordsFunction.java
rename
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/source/{SingleIteratorRecordsTest.java
=> FlinkRecordsWithSplitIdsTest.java} (50%)
delete mode 100644
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink/source/RecordsFunctionTest.java
