org.apache.flink.streaming.api.windowing.evictors

Interface Evictor.EvictorContext

Enclosing interface:

Evictor<T,W extends Window>

public static interface Evictor.EvictorContext

A context object that is given to Evictor methods.

Method Summary

Modifier and Type	Method and Description
long	getCurrentProcessingTime() Returns the current processing time.
long	getCurrentWatermark() Returns the current watermark time.
MetricGroup	getMetricGroup() Returns the metric group for this Evictor.

Method Detail

getCurrentProcessingTime

long getCurrentProcessingTime()

Returns the current processing time.

getMetricGroup

MetricGroup getMetricGroup()

Returns the metric group for this Evictor. This is the same metric group that would be returned from RuntimeContext.getMetricGroup() in a user function.

You must not call methods that create metric objects (such as MetricGroup.counter(int) multiple times but instead call once and store the metric object in a field.

getCurrentWatermark

long getCurrentWatermark()

Returns the current watermark time.