bufferOrEvent = inputGate.getNextBufferOrEvent() | bufferOrEvent = inputGate.pollNextBufferOrEvent() | inputGate.getNextBufferOrEvent() | inputGate.pollNextBufferOrEvent() | flink | 98bd689a2565ec5cf344541f37cd0b0db691c08f | org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate | | _1 | bufferOrEvent |
---|
_2 | bufferOrEvent |
---|
| | | | AssignedTo | True |