Uses of Interface
org.apache.flink.streaming.api.windowing.triggers.Trigger.TriggerContext

Packages that use Trigger.TriggerContext

Package	Description
org.apache.flink.streaming.api.windowing.assigners
org.apache.flink.streaming.api.windowing.triggers
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.

Uses of Trigger.TriggerContext in org.apache.flink.streaming.api.windowing.assigners

Methods in org.apache.flink.streaming.api.windowing.assigners with parameters of type Trigger.TriggerContext

Modifier and Type	Method and Description
void	GlobalWindows.NeverTrigger.clear(GlobalWindow window, Trigger.TriggerContext ctx)
TriggerResult	GlobalWindows.NeverTrigger.onElement(Object element, long timestamp, GlobalWindow window, Trigger.TriggerContext ctx)
TriggerResult	GlobalWindows.NeverTrigger.onEventTime(long time, GlobalWindow window, Trigger.TriggerContext ctx)
TriggerResult	GlobalWindows.NeverTrigger.onProcessingTime(long time, GlobalWindow window, Trigger.TriggerContext ctx)

Uses of Trigger.TriggerContext in org.apache.flink.streaming.api.windowing.triggers

Subinterfaces of Trigger.TriggerContext in org.apache.flink.streaming.api.windowing.triggers

Modifier and Type	Interface and Description
static interface	Trigger.OnMergeContext Extension of Trigger.TriggerContext that is given to Trigger.onMerge(Window, OnMergeContext).

Methods in org.apache.flink.streaming.api.windowing.triggers with parameters of type Trigger.TriggerContext

Modifier and Type	Method and Description
void	EventTimeTrigger.clear(TimeWindow window, Trigger.TriggerContext ctx)
void	ProcessingTimeTrigger.clear(TimeWindow window, Trigger.TriggerContext ctx)
void	PurgingTrigger.clear(W window, Trigger.TriggerContext ctx)
void	ContinuousEventTimeTrigger.clear(W window, Trigger.TriggerContext ctx)
void	ContinuousProcessingTimeTrigger.clear(W window, Trigger.TriggerContext ctx)
abstract void	Trigger.clear(W window, Trigger.TriggerContext ctx) Clears any state that the trigger might still hold for the given window.
void	DeltaTrigger.clear(W window, Trigger.TriggerContext ctx)
void	CountTrigger.clear(W window, Trigger.TriggerContext ctx)
TriggerResult	EventTimeTrigger.onElement(Object element, long timestamp, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	ProcessingTimeTrigger.onElement(Object element, long timestamp, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	ContinuousEventTimeTrigger.onElement(Object element, long timestamp, W window, Trigger.TriggerContext ctx)
TriggerResult	ContinuousProcessingTimeTrigger.onElement(Object element, long timestamp, W window, Trigger.TriggerContext ctx)
TriggerResult	CountTrigger.onElement(Object element, long timestamp, W window, Trigger.TriggerContext ctx)
TriggerResult	PurgingTrigger.onElement(T element, long timestamp, W window, Trigger.TriggerContext ctx)
abstract TriggerResult	Trigger.onElement(T element, long timestamp, W window, Trigger.TriggerContext ctx) Called for every element that gets added to a pane.
TriggerResult	DeltaTrigger.onElement(T element, long timestamp, W window, Trigger.TriggerContext ctx)
TriggerResult	EventTimeTrigger.onEventTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	ProcessingTimeTrigger.onEventTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	PurgingTrigger.onEventTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	ContinuousEventTimeTrigger.onEventTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	ContinuousProcessingTimeTrigger.onEventTime(long time, W window, Trigger.TriggerContext ctx)
abstract TriggerResult	Trigger.onEventTime(long time, W window, Trigger.TriggerContext ctx) Called when an event-time timer that was set using the trigger context fires.
TriggerResult	DeltaTrigger.onEventTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	CountTrigger.onEventTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	EventTimeTrigger.onProcessingTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	ProcessingTimeTrigger.onProcessingTime(long time, TimeWindow window, Trigger.TriggerContext ctx)
TriggerResult	PurgingTrigger.onProcessingTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	ContinuousEventTimeTrigger.onProcessingTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	ContinuousProcessingTimeTrigger.onProcessingTime(long time, W window, Trigger.TriggerContext ctx)
abstract TriggerResult	Trigger.onProcessingTime(long time, W window, Trigger.TriggerContext ctx) Called when a processing-time timer that was set using the trigger context fires.
TriggerResult	DeltaTrigger.onProcessingTime(long time, W window, Trigger.TriggerContext ctx)
TriggerResult	CountTrigger.onProcessingTime(long time, W window, Trigger.TriggerContext ctx)

Uses of Trigger.TriggerContext in org.apache.flink.streaming.runtime.operators.windowing

Classes in org.apache.flink.streaming.runtime.operators.windowing that implement Trigger.TriggerContext

Modifier and Type	Class and Description
class	WindowOperator.Context Context is a utility for handling Trigger invocations.