bufferOrEvent = barrierHandler.getNextNonBlocked() | bufferOrEvent = barrierHandler.pollNext() | barrierHandler.getNextNonBlocked() | barrierHandler.pollNext() | flink | 8d281f8b2b3d170385f38e8f88ec1df09d0d0efe | org.apache.flink.streaming.runtime.io.StreamTwoInputProcessor | | _1 | bufferOrEvent |
---|
_2 | bufferOrEvent |
---|
| | | | AssignedTo | True |
bufferOrEvent = barrierHandler.getNextNonBlocked() | bufferOrEvent = barrierHandler.pollNext() | barrierHandler.getNextNonBlocked() | barrierHandler.pollNext() | flink | 8d281f8b2b3d170385f38e8f88ec1df09d0d0efe | org.apache.flink.streaming.runtime.io.StreamInputProcessor | | _1 | bufferOrEvent |
---|
_2 | bufferOrEvent |
---|
| | | | AssignedTo | True |