THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Page properties |
|---|
...
|
Discussion thread: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/DISCUSS-Add-N-Ary-Stream-Operator-td11341.html
JIRA: https://issues.apache.org/jira/browse/FLINK-XXXX)
...
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
| Code Block |
|---|
DataStream<String> source1 = ...;
DataStream<String> source2 = ...;
DataStream<String> source3 = ...;
MyOperator myOperator = new MyOperator();
OperatorTransformation<String> transform = new OperatorTransformation<>(
"My Operator",
myOperator,
BasicTypeInfo.STRING_TYPE_INFO,
env.getParallelism());
transform.setInput(myOperator.input1, source1.getTransformation());
transform.setInput(myOperator.input2, source2.getTransformation());
transform.setInput(myOperator.input3, source3.getTransformation());
env.addOperator(transform); |
...