Class BoolWatermark
- java.lang.Object
-
- org.apache.flink.api.common.watermark.BoolWatermark
-
- All Implemented Interfaces:
Serializable,Watermark
@Experimental public class BoolWatermark extends Object implements Watermark
TheBoolWatermarkrepresents a watermark with a boolean value and an associated identifier.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BoolWatermark(boolean 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.booleangetValue()inthashCode()StringtoString()
-
-
-
Constructor Detail
-
BoolWatermark
public BoolWatermark(boolean value, String identifier)
-
-
Method Detail
-
getValue
public boolean 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
-
-