org.apache.flink.cep.time

Interface TimeContext

All Known Subinterfaces:

IterativeCondition.Context<T>, PatternProcessFunction.Context

@PublicEvolving
public interface TimeContext

Enables access to time related characteristics such as current processing time or timestamp of currently processed element. Used in PatternProcessFunction and IterativeCondition

Method Summary

Modifier and Type	Method and Description
long	currentProcessingTime() Returns the current processing time.
long	timestamp() Timestamp of the element currently being processed.

Method Detail

timestamp

long timestamp()

Timestamp of the element currently being processed.

In case of org.apache.flink.cep.time.TimeBehaviour#ProcessingTime this means the time when the event entered the cep operator.

currentProcessingTime

long currentProcessingTime()

Returns the current processing time.