This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
from 1d3e335d8e [Feature][Catalog] Doris Catalog (#5175)
add 5aabb14a94 [Feature][Core] Upgrade flink source translation (#5100)
No new revisions were added by this update.
Summary of changes:
.../source/AmazonDynamoDBSourceReader.java | 31 ++--
.../AmazonDynamoDBSourceSplitEnumerator.java | 5 +-
.../clickhouse/source/ClickhouseSourceReader.java | 1 +
.../common/source/AbstractSingleSplitReader.java | 18 ++
.../source/split/FileSourceSplitEnumerator.java | 23 ++-
.../seatunnel/http/source/HttpSourceReader.java | 2 +-
.../seatunnel/neo4j/source/Neo4jSourceReader.java | 2 +-
.../seatunnel/redis/source/RedisSourceReader.java | 2 +-
.../flink/execution/SourceExecuteProcessor.java | 58 +-----
.../seatunnel-flink-connector-v2-example/pom.xml | 41 +++--
.../main/resources/examples/fake_to_console.conf | 4 +-
.../translation/serialization/RowConverter.java | 4 +-
.../seatunnel-translation-flink-common/pom.xml | 7 +
.../flink/serialization/FlinkRowConverter.java | 2 +-
.../flink/serialization/KryoTypeInfo.java | 41 -----
.../flink/serialization/WrappedRow.java | 54 ------
.../flink/source/BaseSeaTunnelSourceFunction.java | 198 ---------------------
.../flink/source/FlinkRowCollector.java | 60 +++++++
.../translation/flink/source/FlinkSource.java | 111 ++++++++++++
.../flink/source/FlinkSourceEnumerator.java | 135 ++++++++++++++
.../flink/source/FlinkSourceReader.java | 135 ++++++++++++++
.../flink/source/FlinkSourceReaderContext.java | 93 ++++++++++
.../source/FlinkSourceSplitEnumeratorContext.java} | 36 ++--
.../flink/source/NoMoreElementEvent.java | 46 +++++
.../translation/flink/source/RowCollector.java | 84 ---------
.../flink/source/SeaTunnelCoordinatedSource.java | 48 -----
.../flink/source/SeaTunnelParallelSource.java | 54 ------
.../SourceEventWrapper.java} | 23 +--
.../translation/flink/source/SplitWrapper.java | 34 ++--
.../SplitWrapperSerializer.java} | 29 ++-
30 files changed, 744 insertions(+), 637 deletions(-)
delete mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/serialization/KryoTypeInfo.java
delete mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/serialization/WrappedRow.java
delete mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/BaseSeaTunnelSourceFunction.java
create mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/FlinkRowCollector.java
create mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/FlinkSource.java
create mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/FlinkSourceEnumerator.java
create mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/FlinkSourceReader.java
create mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/FlinkSourceReaderContext.java
copy
seatunnel-translation/{seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/CoordinatedEnumeratorContext.java
=>
seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/FlinkSourceSplitEnumeratorContext.java}
(61%)
create mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/NoMoreElementEvent.java
delete mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/RowCollector.java
delete mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelCoordinatedSource.java
delete mode 100644
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/SeaTunnelParallelSource.java
copy
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/{sink/CommitWrapper.java
=> source/SourceEventWrapper.java} (56%)
copy
seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/source/HudiSourceSplit.java
=>
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/source/SplitWrapper.java
(60%)
copy
seatunnel-translation/seatunnel-translation-flink/seatunnel-translation-flink-common/src/main/java/org/apache/seatunnel/translation/flink/{serialization/CommitWrapperSerializer.java
=> source/SplitWrapperSerializer.java} (65%)
