This is an automated email from the ASF dual-hosted git repository.
godfrey pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c954070 [FLINK-8357] Use rolling logs as default
add e464c80 [FLINK-19627][table-runtime] Introduce OneInput,
FirstInputOfTwoInput, SecondInputOfTwoInput, InputSelectionHandler for multiple
input operator
add 3720b92 [FLINK-19627][table-runtime] Introduce different Output
sub-classes for multiple input operator
add 649328a [FLINK-19627][table-runtime] Introduce multiple input
operator for batch
No new revisions were added by this update.
Summary of changes:
.../batch/BatchExecMultipleInputNode.scala | 2 +-
.../BatchMultipleInputStreamOperator.java | 83 +++++
.../BatchMultipleInputStreamOperatorFactory.java | 15 +-
.../MultipleInputStreamOperatorBase.java | 329 ++++++++++++++++++
.../TableOperatorWrapperGenerator.java | 15 +-
.../multipleinput/UnionStreamOperator.java | 3 +-
.../multipleinput/input/FirstInputOfTwoInput.java} | 38 +--
.../InputBase.java} | 22 +-
.../multipleinput/input/InputSelectionHandler.java | 96 ++++++
.../operators/multipleinput/input/InputSpec.java | 4 +-
.../operators/multipleinput/input/OneInput.java} | 36 +-
.../input/SecondInputOfTwoInput.java} | 38 +--
.../multipleinput/output/BroadcastingOutput.java | 84 +++++
.../output/CopyingBroadcastingOutput.java | 64 ++++
...ngFirstInputOfTwoInputStreamOperatorOutput.java | 57 ++++
.../CopyingOneInputStreamOperatorOutput.java | 56 +++
...gSecondInputOfTwoInputStreamOperatorOutput.java | 88 +++++
...ExceptionInMultipleInputOperatorException.java} | 29 +-
.../FirstInputOfTwoInputStreamOperatorOutput.java | 83 +++++
.../output/OneInputStreamOperatorOutput.java | 82 +++++
.../OutputBase.java} | 29 +-
.../SecondInputOfTwoInputStreamOperatorOutput.java | 83 +++++
.../BatchMultipleInputStreamOperatorTest.java | 379 +++++++++++++++++++++
.../multipleinput/MultipleInputTestBase.java | 179 ++++++++++
.../TableOperatorWrapperGeneratorTest.java | 38 +--
.../multipleinput/TableOperatorWrapperTest.java | 46 +--
.../TestingOneInputStreamOperator.java | 75 ++++
.../TestingTwoInputStreamOperator.java | 107 +++++-
.../input/InputSelectionHandlerTest.java | 92 +++++
.../operators/multipleinput/input/InputTest.java | 105 ++++++
.../BlackHoleOutput.java} | 38 +--
.../operators/multipleinput/output/OutputTest.java | 226 ++++++++++++
32 files changed, 2394 insertions(+), 227 deletions(-)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/BatchMultipleInputStreamOperator.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/MultipleInputStreamOperatorBase.java
copy
flink-table/flink-table-runtime-blink/src/{test/java/org/apache/flink/table/runtime/operators/multipleinput/TestingOneInputStreamOperator.java
=>
main/java/org/apache/flink/table/runtime/operators/multipleinput/input/FirstInputOfTwoInput.java}
(54%)
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/{UnionStreamOperator.java
=> input/InputBase.java} (53%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/input/InputSelectionHandler.java
copy
flink-table/flink-table-runtime-blink/src/{test/java/org/apache/flink/table/runtime/operators/multipleinput/TestingOneInputStreamOperator.java
=>
main/java/org/apache/flink/table/runtime/operators/multipleinput/input/OneInput.java}
(59%)
copy
flink-table/flink-table-runtime-blink/src/{test/java/org/apache/flink/table/runtime/operators/multipleinput/TestingOneInputStreamOperator.java
=>
main/java/org/apache/flink/table/runtime/operators/multipleinput/input/SecondInputOfTwoInput.java}
(54%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/BroadcastingOutput.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/CopyingBroadcastingOutput.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/CopyingFirstInputOfTwoInputStreamOperatorOutput.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/CopyingOneInputStreamOperatorOutput.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/CopyingSecondInputOfTwoInputStreamOperatorOutput.java
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/{UnionStreamOperator.java
=> output/ExceptionInMultipleInputOperatorException.java} (52%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/FirstInputOfTwoInputStreamOperatorOutput.java
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/OneInputStreamOperatorOutput.java
copy
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/{UnionStreamOperator.java
=> output/OutputBase.java} (52%)
create mode 100644
flink-table/flink-table-runtime-blink/src/main/java/org/apache/flink/table/runtime/operators/multipleinput/output/SecondInputOfTwoInputStreamOperatorOutput.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/multipleinput/BatchMultipleInputStreamOperatorTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/multipleinput/MultipleInputTestBase.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/multipleinput/input/InputSelectionHandlerTest.java
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/multipleinput/input/InputTest.java
copy
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/multipleinput/{TestingOneInputStreamOperator.java
=> output/BlackHoleOutput.java} (54%)
create mode 100644
flink-table/flink-table-runtime-blink/src/test/java/org/apache/flink/table/runtime/operators/multipleinput/output/OutputTest.java
