NotProgressingWatermarkIdlePolicy

java.lang.Object
- cz.o2.proxima.direct.core.time.NotProgressingWatermarkIdlePolicy

All Implemented Interfaces:

WatermarkIdlePolicy, java.io.Serializable
```
public class NotProgressingWatermarkIdlePolicy
extends java.lang.Object
implements WatermarkIdlePolicy
```
Idle policy doesn't progress watermark on idle.

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type Class Description

static class NotProgressingWatermarkIdlePolicy.Factory

Constructor Summary

Constructors
Constructor Description

NotProgressingWatermarkIdlePolicy()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`long`	`getIdleWatermark()`	Returns watermark for idle source.
`void`	`idle(long currentWatermark)`	Signals that a source is idle.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cz.o2.proxima.core.time.WatermarkIdlePolicy
update

- Constructor Detail
  - NotProgressingWatermarkIdlePolicy
```
public NotProgressingWatermarkIdlePolicy()
```
- Method Detail
  - idle
```
public void idle(long currentWatermark)
```
    Description copied from interface: WatermarkIdlePolicy
    
    Signals that a source is idle.
    
    Specified by:
    
    idle in interface WatermarkIdlePolicy
    
    Parameters:
    
    currentWatermark - the most recent watermark estimated by watermark estimator WatermarkEstimator.
  - getIdleWatermark
```
public long getIdleWatermark()
```
    Description copied from interface: WatermarkIdlePolicy
    
    Returns watermark for idle source.
    
    Specified by:
    
    getIdleWatermark in interface WatermarkIdlePolicy
    
    Returns:
    
    the watermark.