This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 7e7dbc2 [FLINK-20235][hive][parquet] Parquet lack additional
dependencies after bumping
add fc1bf51 [hotfix][runtime] Replace dangling inline JavaDoc comment by
regular comment
add 0de189c [FLINK-20270][refactor] Initialize reader in SourceOperator
at an earlier point.
add 4c5fd59 [FLINK-20270][runtime] Add support for
ExternallyInducedSource based on FLIP-27 to SourceOperatorStreamTask.
add 7161b18 [hotfix][core] Extend JavaDocs for
ExternallyInducedSourceReader.
No new revisions were added by this update.
Summary of changes:
.../source/ExternallyInducedSourceReader.java | 64 ++++++++++
.../streaming/api/operators/SourceOperator.java | 37 ++++--
.../io/StreamTaskExternallyInducedSourceInput.java | 53 +++++++++
.../runtime/io/StreamTaskSourceInput.java | 2 +-
.../runtime/tasks/SourceOperatorStreamTask.java | 73 +++++++++++-
.../api/operators/SourceOperatorTest.java | 4 +-
.../operators/source/TestingSourceOperator.java | 18 +--
.../tasks/SourceOperatorStreamTaskTest.java | 130 ++++++++++++++++++++-
8 files changed, 348 insertions(+), 33 deletions(-)
create mode 100644
flink-core/src/main/java/org/apache/flink/api/connector/source/ExternallyInducedSourceReader.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTaskExternallyInducedSourceInput.java
