Uses of Interface
org.apache.flink.api.common.eventtime.WatermarkOutputMultiplexer.WatermarkUpdateListener
-
Packages that use WatermarkOutputMultiplexer.WatermarkUpdateListener Package Description org.apache.flink.api.common.eventtime -
-
Uses of WatermarkOutputMultiplexer.WatermarkUpdateListener in org.apache.flink.api.common.eventtime
Methods in org.apache.flink.api.common.eventtime with parameters of type WatermarkOutputMultiplexer.WatermarkUpdateListener Modifier and Type Method Description voidWatermarkOutputMultiplexer. registerNewOutput(String id, WatermarkOutputMultiplexer.WatermarkUpdateListener onWatermarkUpdate)Registers a new multiplexed output, which creates internal states for that output and returns an output ID that can be used to get a deferred or immediateWatermarkOutputfor that output.
-