Class LongWatermark
- java.lang.Object
-
- org.apache.flink.api.common.watermark.LongWatermark
-
- All Implemented Interfaces:
Serializable,Watermark
@Experimental public class LongWatermark extends Object implements Watermark
TheLongWatermarkrepresents a watermark with a long value and an associated identifier.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description LongWatermark(long value, String identifier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)StringgetIdentifier()Returns the unique identifier for this watermark.longgetValue()inthashCode()StringtoString()
-
-
-
Constructor Detail
-
LongWatermark
public LongWatermark(long value, String identifier)
-
-
Method Detail
-
getValue
public long getValue()
-
getIdentifier
public String getIdentifier()
Description copied from interface:WatermarkReturns the unique identifier for this watermark.- Specified by:
getIdentifierin interfaceWatermark- Returns:
- a
Stringrepresenting the unique identifier of the watermark
-
-