This is an automated email from the ASF dual-hosted git repository.
dwysakowicz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c3fedf3 [hotfix] Make Transformation.getTransitivePredecessors()
return a list
add 0c0dbf5 [refactor] Reuse StreamOneInputProcessor in
StreamMultiProcessor
add f87a6ef [refactor] Reuse StreamOneInputProcessor in
StreamTwoInputProcessor
add 4c4f6a7 [refactor] Remove SourceInputProcessor from
StreamMultipleInputProcessor
add b1317fa [refactor] Extract StreamMultipleInputProcessor factory method
add 2aa8345 [refactor] Use BoundedMultiInput instead of OperatorChain in
InputProcessors
add e8f500b [refactor] Call nextSelection after each emitNext
add fa43b75 [FLINK-19473] Implement multi inputs sorting DataInput
add 24708d0 [minor] Minor fixes in javadocs and an exception message in
SortingDataInput
add 4ddf954 [refactor] Extract StreamTwoInputProcessor factory method
add 574edb3 [FLINK-19473] Enable two input sorting in TwoInputStreamTask
add 77e4e3b [FLINK-19473] Enable sorting inputs in MultiInputTasks
No new revisions were added by this update.
Summary of changes:
.../streaming/api/operators/StreamSource.java | 2 +-
.../operators/sort/MultiInputSortingDataInput.java | 463 +++++++++++++++++++++
.../api/operators/sort/SortingDataInput.java | 7 +-
.../streaming/runtime/io/StreamInputProcessor.java | 4 +
.../runtime/io/StreamMultipleInputProcessor.java | 260 +-----------
.../io/StreamMultipleInputProcessorFactory.java | 321 ++++++++++++++
.../runtime/io/StreamOneInputProcessor.java | 10 +-
.../runtime/io/StreamTaskSourceInput.java | 12 +-
.../runtime/io/StreamTwoInputProcessor.java | 235 ++---------
.../runtime/io/StreamTwoInputProcessorFactory.java | 287 +++++++++++++
.../runtime/tasks/AbstractTwoInputStreamTask.java | 14 +-
.../runtime/tasks/MultipleInputStreamTask.java | 25 +-
.../streaming/runtime/tasks/OperatorChain.java | 8 +-
.../runtime/tasks/SourceOperatorStreamTask.java | 2 +-
.../runtime/tasks/TwoInputStreamTask.java | 24 +-
.../{source => sort}/CollectingDataOutput.java | 3 +-
.../api/operators/sort/CollectionDataInput.java | 82 ++++
...TCase.java => LargeSortingDataInputITCase.java} | 84 +++-
.../sort/MultiInputSortingDataInputsTest.java | 211 ++++++++++
.../api/operators/sort/SortingDataInputTest.java | 88 +---
.../runtime/SortingBoundedInputITCase.java | 283 ++++++++++++-
21 files changed, 1801 insertions(+), 624 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/sort/MultiInputSortingDataInput.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamMultipleInputProcessorFactory.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/io/StreamTwoInputProcessorFactory.java
copy
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/{source
=> sort}/CollectingDataOutput.java (97%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/CollectionDataInput.java
rename
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/{SortingDataInputITCase.java
=> LargeSortingDataInputITCase.java} (71%)
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/operators/sort/MultiInputSortingDataInputsTest.java
