This is an automated email from the ASF dual-hosted git repository.
jqin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 2160c32 [FLINK-17252][table] Add Table#execute api and support SELECT
statement in TableEnvironment#executeSql
add aa1ede9 [FLINK-16845] Adds implmentation of SourceOperator. This
patch does the following: 1. Add CoordinatedOperatorFactory interface. 2.
Rename SourceReaderOpertor to SourceOperator, add implementation and connect it
to OperatorEventGateway. 3. Rename SourceReaderStreamTask to
SourceOperatorStreamTask 4. Fix some bugs in StreamTaskMailboxTestHarness.
No new revisions were added by this update.
Summary of changes:
.../api/connector/source/mocks/MockSource.java | 14 +-
.../connector/source/mocks/MockSourceReader.java | 130 ++++++++++++
.../connector/source/mocks/MockSourceSplit.java | 4 +
.../flink/state/api/output/BoundedStreamTask.java | 3 +-
.../coordination/MockOperatorEventGateway.java | 24 ++-
.../api/operators/CoordinatedOperatorFactory.java | 57 ++++++
.../streaming/api/operators/SourceOperator.java | 220 +++++++++++++++++++++
.../api/operators/SourceOperatorFactory.java | 80 ++++++++
.../api/operators/SourceReaderOperator.java | 34 ----
.../api/operators/StreamOperatorFactoryUtil.java | 13 +-
.../runtime/io/StreamTaskSourceInput.java | 8 +-
.../streaming/runtime/tasks/OperatorChain.java | 6 +-
...reamTask.java => SourceOperatorStreamTask.java} | 36 +++-
.../runtime/tasks/mailbox/MailboxProcessor.java | 5 +
.../api/operators/SourceOperatorTest.java | 203 +++++++++++++++++++
.../tasks/SourceOperatorStreamTaskTest.java | 176 +++++++++++++++++
.../runtime/tasks/SourceReaderStreamTaskTest.java | 209 --------------------
.../tasks/StreamTaskMailboxTestHarness.java | 14 +-
.../tasks/StreamTaskMailboxTestHarnessBuilder.java | 32 ++-
.../util/AbstractStreamOperatorTestHarness.java | 4 +-
20 files changed, 982 insertions(+), 290 deletions(-)
create mode 100644
flink-core/src/test/java/org/apache/flink/api/connector/source/mocks/MockSourceReader.java
copy
flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/reader/splitreader/SplitsChange.java
=>
flink-runtime/src/test/java/org/apache/flink/runtime/operators/coordination/MockOperatorEventGateway.java
(62%)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/CoordinatedOperatorFactory.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperator.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceOperatorFactory.java
delete mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/SourceReaderOperator.java
rename
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/{SourceReaderStreamTask.java
=> SourceOperatorStreamTask.java} (73%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/SourceOperatorTest.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceOperatorStreamTaskTest.java
delete mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceReaderStreamTaskTest.java
