org.apache.flink.table.sources.wmstrategies

Class WatermarkStrategy

java.lang.Object

org.apache.flink.table.sources.wmstrategies.WatermarkStrategy

All Implemented Interfaces:

Serializable, Descriptor

Direct Known Subclasses:

PeriodicWatermarkAssigner, PreserveWatermarks, PunctuatedWatermarkAssigner

@PublicEvolving
public abstract class WatermarkStrategy
extends Object
implements Serializable, Descriptor

Provides a strategy to generate watermarks for a rowtime attribute.

A watermark strategy is either a PeriodicWatermarkAssigner or PunctuatedWatermarkAssigner.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WatermarkStrategy()

Method Summary

Modifier and Type	Method and Description
Map<String,String>	toProperties() This method is a default implementation that uses java serialization and it is discouraged.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WatermarkStrategy

public WatermarkStrategy()

Method Detail

toProperties

public Map<String,String> toProperties()

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 interface Descriptor