Class AscendingTimestamps
- java.lang.Object
-
- org.apache.flink.table.sources.wmstrategies.WatermarkStrategy
-
- org.apache.flink.table.sources.wmstrategies.PeriodicWatermarkAssigner
-
- org.apache.flink.table.sources.wmstrategies.AscendingTimestamps
-
- All Implemented Interfaces:
Serializable
,Descriptor
@PublicEvolving public final class AscendingTimestamps extends PeriodicWatermarkAssigner
A watermark strategy for ascending rowtime attributes.Emits a watermark of the maximum observed timestamp so far minus 1. Rows that have a timestamp equal to the max timestamp are not late.
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description AscendingTimestamps()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object obj)
Watermark
getWatermark()
Returns the current watermark.int
hashCode()
void
nextTimestamp(long timestamp)
Updates the assigner with the next timestamp.Map<String,String>
toProperties()
This method is a default implementation that uses java serialization and it is discouraged.
-
-
-
Method Detail
-
nextTimestamp
public void nextTimestamp(long timestamp)
Description copied from class:PeriodicWatermarkAssigner
Updates the assigner with the next timestamp.- Specified by:
nextTimestamp
in classPeriodicWatermarkAssigner
- Parameters:
timestamp
- The next timestamp to update the assigner.
-
toProperties
public Map<String,String> toProperties()
Description copied from class:WatermarkStrategy
This method is a default implementation that uses java serialization and it is discouraged. All implementation should provide a more specific set of properties.- Specified by:
toProperties
in interfaceDescriptor
- Overrides:
toProperties
in classWatermarkStrategy
-
getWatermark
public Watermark getWatermark()
Description copied from class:PeriodicWatermarkAssigner
Returns the current watermark.- Specified by:
getWatermark
in classPeriodicWatermarkAssigner
- Returns:
- The current watermark.
-
-