Class WatermarkAlignmentEvent
- java.lang.Object
-
- org.apache.flink.runtime.source.event.WatermarkAlignmentEvent
-
- All Implemented Interfaces:
Serializable
,OperatorEvent
public class WatermarkAlignmentEvent extends Object implements OperatorEvent
Signals source operators the maximum watermark that emitted records can have.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description WatermarkAlignmentEvent(long maxWatermark)
-