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