OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
outputId = multiplexer.registerNewOutput()id = UUID.randomUUID().toString()multiplexer.registerNewOutput()UUID.randomUUID().toString()flink8e01f5284b2a9b1d41ef49507598e2912b839206org.apache.flink.api.common.eventtime.WatermarkOutputMultiplexerTest
_1311
_2391
_1outputId
_2id
xyzmultiplexer.registerNewOutput()
  • java.util.UUID
xyzUUID.randomUUID().toString()
AssignedToFalse
outputId = multiplexer.registerNewOutput()id = UUID.randomUUID().toString()multiplexer.registerNewOutput()UUID.randomUUID().toString()flink8e01f5284b2a9b1d41ef49507598e2912b839206org.apache.flink.api.common.eventtime.WatermarkOutputMultiplexerTest
_1302
_2381
_1outputId
_2id
xyzmultiplexer.registerNewOutput()
  • java.util.UUID
xyzUUID.randomUUID().toString()
AssignedToFalse