THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Process Function | number of inputs | number of outputs |
OneInputStreamProcessFunction | 1 | 1 |
TwoInputStreamProcessFunction | 2 | 1 |
TwoOutputStreamProcessFunction | 1 | 2 |
Logically,
...
process functions that support more inputs and outputs can be achieved by combining them, but this implementation might be inefficient. If the call for this becomes louder, we will consider supporting as many output edges as we want through a mechanism like OutputTag. But this loses the explicit generic type information that comes with using ProcessFunction.
Advantages of ProcessFunction
...