Package | Description |
---|---|
org.apache.flink.api.common.eventtime |
Modifier and Type | Method and Description |
---|---|
void |
WatermarkOutputMultiplexer.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 immediate
WatermarkOutput for that
output. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.