WatermarkIdlePolicyFactory

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

NotProgressingWatermarkIdlePolicy.Factory, ProcessingTimeShiftingWatermarkIdlePolicy.Factory, SkewedProcessingTimeIdlePolicy.Factory
```
public interface WatermarkIdlePolicyFactory
extends java.io.Serializable
```
Factory creates watermark idle policy instance.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`WatermarkIdlePolicy`	`create()`
`void`	`setup(java.util.Map<java.lang.String,java.lang.Object> cfg)`	Configure the factory based on the provided configuration.

Method Detail

setup

void setup(java.util.Map<java.lang.String,java.lang.Object> cfg)

Configure the factory based on the provided configuration.

create
```
WatermarkIdlePolicy create()
```