OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
result = currentChannel.getNextBuffer()result = Optional.empty()currentChannel.getNextBuffer()Optional.empty()flink5b1e127f7b3acd8f82893dda394fbcb7fe93d20dorg.apache.flink.runtime.io.network.partition.consumer.SingleInputGate
_1531
_2512
_1result
_2result
xyzcurrentChannel.getNextBuffer()
  • java.util.Optional
xyzOptional.empty()
AssignedToFalse