This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 233e5d4 [hotfix][streaming] Removed useless calculateThroughput in
the test
add 23b048b [FLINK-22670][FLIP-150][connector/common] Hybrid source
baseline
No new revisions were added by this update.
Summary of changes:
.../connector/base/source/hybrid/HybridSource.java | 257 ++++++++++++++
.../source/hybrid/HybridSourceEnumeratorState.java | 38 ++
.../HybridSourceEnumeratorStateSerializer.java | 106 ++++++
.../base/source/hybrid/HybridSourceReader.java | 254 ++++++++++++++
.../base/source/hybrid/HybridSourceSplit.java | 94 +++++
.../source/hybrid/HybridSourceSplitEnumerator.java | 390 +++++++++++++++++++++
.../source/hybrid/HybridSourceSplitSerializer.java | 98 ++++++
.../source/hybrid/SourceReaderFinishedEvent.java | 49 +++
.../base/source/hybrid/SwitchSourceEvent.java | 62 ++++
.../base/source/hybrid/HybridSourceITCase.java | 246 +++++++++++++
.../base/source/hybrid/HybridSourceReaderTest.java | 181 ++++++++++
.../hybrid/HybridSourceSplitEnumeratorTest.java | 252 +++++++++++++
.../hybrid/HybridSourceSplitSerializerTest.java | 52 +++
.../base/source/hybrid/HybridSourceTest.java | 115 ++++++
14 files changed, 2194 insertions(+)
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumeratorState.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceEnumeratorStateSerializer.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReader.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplit.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitSerializer.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SourceReaderFinishedEvent.java
create mode 100644
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/SwitchSourceEvent.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceITCase.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceReaderTest.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumeratorTest.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitSerializerTest.java
create mode 100644
flink-connectors/flink-connector-base/src/test/java/org/apache/flink/connector/base/source/hybrid/HybridSourceTest.java
