<OUT1,OUT2> GlobalStream.TwoGlobalStreams<OUT1,OUT2> |
GlobalStream.process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction) |
|
<OUT1,OUT2> NonKeyedPartitionStream.TwoNonKeyedPartitionStreams<OUT1,OUT2> |
KeyedPartitionStream.process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction) |
|
<OUT1,OUT2> KeyedPartitionStream.TwoKeyedPartitionStreams<K,OUT1,OUT2> |
KeyedPartitionStream.process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction,
org.apache.flink.api.java.functions.KeySelector<OUT1,K> keySelector1,
org.apache.flink.api.java.functions.KeySelector<OUT2,K> keySelector2) |
|
<OUT1,OUT2> NonKeyedPartitionStream.TwoNonKeyedPartitionStreams<OUT1,OUT2> |
NonKeyedPartitionStream.process(TwoOutputStreamProcessFunction<T,OUT1,OUT2> processFunction) |
|