Class BoolWatermarkDeclaration
- java.lang.Object
-
- org.apache.flink.api.common.watermark.BoolWatermarkDeclaration
-
- All Implemented Interfaces:
Serializable,WatermarkDeclaration
@Experimental public class BoolWatermarkDeclaration extends Object implements WatermarkDeclaration
TheBoolWatermarkDeclarationclass implements theWatermarkDeclarationinterface and provides additional functionality specific to boolean-type watermarks. It includes methods for obtaining combination semantics and creating new bool watermarks.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description BoolWatermarkDeclaration(String identifier, WatermarkCombinationPolicy combinationPolicy, WatermarkHandlingStrategy defaultHandlingStrategy)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanequals(Object o)WatermarkCombinationPolicygetCombinationPolicy()WatermarkHandlingStrategygetDefaultHandlingStrategy()StringgetIdentifier()Returns the unique identifier for this watermark.inthashCode()BoolWatermarknewWatermark(boolean val)Creates a newBoolWatermarkwith the specified boolean value.StringtoString()
-
-
-
Constructor Detail
-
BoolWatermarkDeclaration
public BoolWatermarkDeclaration(String identifier, WatermarkCombinationPolicy combinationPolicy, WatermarkHandlingStrategy defaultHandlingStrategy)
-
-
Method Detail
-
getIdentifier
public String getIdentifier()
Description copied from interface:WatermarkDeclarationReturns the unique identifier for this watermark.- Specified by:
getIdentifierin interfaceWatermarkDeclaration- Returns:
- a
Stringrepresenting the unique identifier of the watermark
-
newWatermark
public BoolWatermark newWatermark(boolean val)
Creates a newBoolWatermarkwith the specified boolean value.
-
getCombinationPolicy
public WatermarkCombinationPolicy getCombinationPolicy()
-
getDefaultHandlingStrategy
public WatermarkHandlingStrategy getDefaultHandlingStrategy()
-
-