WatermarkIdlePolicy

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

NotProgressingWatermarkIdlePolicy, ProcessingTimeShiftingWatermarkIdlePolicy, SkewedProcessingTimeIdlePolicy
```
public interface WatermarkIdlePolicy
extends java.io.Serializable
```
Policy defines behaviour how watermark should behave when streaming source is idle

Method Summary

All Methods Instance Methods Abstract Methods Default Methods
Modifier and Type	Method	Description
`long`	`getIdleWatermark()`	Returns watermark for idle source.
`default void`	`idle(long currentWatermark)`	Signals that a source is idle.
`default void`	`update(StreamElement element)`	Updates policy state when a new element is received from streaming source.

- Method Detail
  - getIdleWatermark
```
long getIdleWatermark()
```
    Returns watermark for idle source.
    
    Returns:
    
    the watermark.
  - update
```
default void update(StreamElement element)
```
    Updates policy state when a new element is received from streaming source.
    
    Parameters:
    
    element - a stream element.
  - idle
```
default void idle(long currentWatermark)
```
    Signals that a source is idle.
    
    Parameters:
    
    currentWatermark - the most recent watermark estimated by watermark estimator WatermarkEstimator.