TimeProvider

All Superinterfaces:

java.io.Serializable

All Known Subinterfaces:

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

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 TimeProvider
extends java.io.Serializable
```
Provider of timestamp. Timestamp can be provided according to different timestamp policies (e.g. processing time, watermark, test timestamps, etc.).

- Method Summary
  
  All Methods Static Methods Instance Methods Abstract Methods
  Modifier and Type Method Description
  
  long getCurrentTime()
  
  static TimeProvider processingTime()

- Method Detail
  - processingTime
```
static TimeProvider processingTime()
```
    Returns:
    
    TimeProvider using System.currentTimeMillis().
  - getCurrentTime
```
long getCurrentTime()
```
    Returns:
    
    current epoch milli time according to this timestamp provider