WatermarkSupplier

All Superinterfaces:

java.io.Serializable, TimeProvider

All Known Subinterfaces:

BatchLogObserver.OnNextContext, CommitLogObserver.OnIdleContext, CommitLogObserver.OnNextContext, GlobalWatermarkTracker, LogObserver.OnNextContext<OffsetT>, PartitionedWatermarkEstimator, WatermarkEstimator

All Known Implementing Classes:

AbstractWatermarkEstimator, BoundedOutOfOrdernessWatermarkEstimator, FlinkGlobalWatermarkTracker, MinimalPartitionWatermarkEstimator, ProcessingTimeWatermarkEstimator, UnboundedOutOfOrdernessWatermarkEstimator, ZKGlobalWatermarkTracker

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
```
@Internal
@FunctionalInterface
public interface WatermarkSupplier
extends TimeProvider
```
Supplies the current watermark to clients.

- Method Summary
  
  All Methods Instance Methods Abstract Methods Default Methods
  Modifier and Type Method Description
  
  default long getCurrentTime()
  
  long getWatermark()
  Retrieve watermark.

- Method Detail
  - getWatermark
```
long getWatermark()
```
    Retrieve watermark.
    
    Returns:
    
    the current watermark.
  - getCurrentTime
```
default long getCurrentTime()
```
    Specified by:
    
    getCurrentTime in interface TimeProvider
    
    Returns:
    
    current epoch milli time according to this timestamp provider