Versions Compared

Old Version 2

changes.mady.by.user Piotr Nowojski

Saved on

compared with

New Version 3

changes.mady.by.user Piotr Nowojski

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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)

Jira
serverASF JIRA
serverId5aa69414-a9e9-3523-82ec-879b028fb15b
keyFLINK-15688

Released: <Flink Version>

...

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);

...