Uses of Class
org.apache.flink.streaming.api.windowing.triggers.Trigger

Packages that use Trigger

Package	Description
org.apache.flink.streaming.api.datastream
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 in org.apache.flink.streaming.api.datastream

Methods in org.apache.flink.streaming.api.datastream with parameters of type Trigger

Modifier and Type	Method	Description
AllWindowedStream<T,W>	AllWindowedStream.trigger(Trigger<? super T,? super W> trigger)	Sets the Trigger that should be used to trigger window emission.
CoGroupedStreams.WithWindow<T1,T2,KEY,W>	CoGroupedStreams.WithWindow.trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger)	Sets the Trigger that should be used to trigger window emission.
JoinedStreams.WithWindow<T1,T2,KEY,W>	JoinedStreams.WithWindow.trigger(Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> newTrigger)	Sets the Trigger that should be used to trigger window emission.
WindowedStream<T,K,W>	WindowedStream.trigger(Trigger<? super T,? super W> trigger)	Sets the Trigger that should be used to trigger window emission.

Constructors in org.apache.flink.streaming.api.datastream with parameters of type Trigger

Constructor	Description
WithWindow(DataStream<T1> input1, DataStream<T2> input2, org.apache.flink.api.java.functions.KeySelector<T1,KEY> keySelector1, org.apache.flink.api.java.functions.KeySelector<T2,KEY> keySelector2, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, java.time.Duration allowedLateness)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, org.apache.flink.api.java.functions.KeySelector<T1,KEY> keySelector1, org.apache.flink.api.java.functions.KeySelector<T2,KEY> keySelector2, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, Time allowedLateness)	Deprecated. Use WithWindow(DataStream, DataStream, KeySelector, KeySelector, TypeInformation, WindowAssigner, Trigger, Evictor, Duration)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, org.apache.flink.api.java.functions.KeySelector<T1,KEY> keySelector1, org.apache.flink.api.java.functions.KeySelector<T2,KEY> keySelector2, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, java.time.Duration allowedLateness)
WithWindow(DataStream<T1> input1, DataStream<T2> input2, org.apache.flink.api.java.functions.KeySelector<T1,KEY> keySelector1, org.apache.flink.api.java.functions.KeySelector<T2,KEY> keySelector2, org.apache.flink.api.common.typeinfo.TypeInformation<KEY> keyType, WindowAssigner<? super CoGroupedStreams.TaggedUnion<T1,T2>,W> windowAssigner, Trigger<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> trigger, Evictor<? super CoGroupedStreams.TaggedUnion<T1,T2>,? super W> evictor, Time allowedLateness)	Deprecated. Use WithWindow(DataStream, DataStream, KeySelector, KeySelector, TypeInformation, WindowAssigner, Trigger, Evictor, Duration).

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

Subclasses of Trigger in org.apache.flink.streaming.api.windowing.assigners

Modifier and Type	Class	Description
static class	GlobalWindows.EndOfStreamTrigger	A trigger that fires iff the input stream reaches EndOfStream.
static class	GlobalWindows.NeverTrigger	A trigger that never fires, as default Trigger for GlobalWindows.

Methods in org.apache.flink.streaming.api.windowing.assigners that return Trigger

Modifier and Type	Method	Description
Trigger<T,TimeWindow>	DynamicEventTimeSessionWindows.getDefaultTrigger()
Trigger<T,TimeWindow>	DynamicEventTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<T,TimeWindow>	DynamicProcessingTimeSessionWindows.getDefaultTrigger()
Trigger<T,TimeWindow>	DynamicProcessingTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	EventTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	EventTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,GlobalWindow>	GlobalWindows.getDefaultTrigger()
Trigger<Object,GlobalWindow>	GlobalWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	ProcessingTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	ProcessingTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	SlidingEventTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	SlidingEventTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	SlidingProcessingTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	SlidingProcessingTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	TumblingEventTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	TumblingEventTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	TumblingProcessingTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	TumblingProcessingTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<T,W>	WindowAssigner.getDefaultTrigger()	Returns the default trigger associated with this WindowAssigner.
abstract Trigger<T,W>	WindowAssigner.getDefaultTrigger(StreamExecutionEnvironment env)	Deprecated. the method is deprecated since Flink 1.19 because StreamExecutionEnvironment is unused.

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

Subclasses of Trigger in org.apache.flink.streaming.api.windowing.triggers

Modifier and Type	Class	Description
class	ContinuousEventTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval.
class	ContinuousProcessingTimeTrigger<W extends Window>	A Trigger that continuously fires based on a given time interval as measured by the clock of the machine on which the job is running.
class	CountTrigger<W extends Window>	A Trigger that fires once the count of elements in a pane reaches the given count.
class	DeltaTrigger<T,W extends Window>	A Trigger that fires based on a DeltaFunction and a threshold.
class	EventTimeTrigger	A Trigger that fires once the watermark passes the end of the window to which a pane belongs.
class	ProcessingTimeoutTrigger<T,W extends Window>	A Trigger that can turn any Trigger into a timeout Trigger.
class	ProcessingTimeTrigger	A Trigger that fires once the current system time passes the end of the window to which a pane belongs.
class	PurgingTrigger<T,W extends Window>	A trigger that can turn any Trigger into a purging Trigger.

Methods in org.apache.flink.streaming.api.windowing.triggers that return Trigger

Modifier and Type	Method	Description
Trigger<T,W>	PurgingTrigger.getNestedTrigger()

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

Modifier and Type	Method	Description
static <T,W extends Window> ProcessingTimeoutTrigger<T,W>	ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger, java.time.Duration timeout)	Creates a new ProcessingTimeoutTrigger that fires when the inner trigger is fired or when the timeout timer fires.
static <T,W extends Window> ProcessingTimeoutTrigger<T,W>	ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger, java.time.Duration timeout, boolean resetTimerOnNewRecord, boolean shouldClearOnTimeout)	Creates a new ProcessingTimeoutTrigger that fires when the inner trigger is fired or when the timeout timer fires.
static <T,W extends Window> PurgingTrigger<T,W>	PurgingTrigger.of(Trigger<T,W> nestedTrigger)	Creates a new purging trigger from the given Trigger.

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

Methods in org.apache.flink.streaming.runtime.operators.windowing that return Trigger

Modifier and Type	Method	Description
Trigger<? super IN,? super W>	WindowOperator.getTrigger()

Methods in org.apache.flink.streaming.runtime.operators.windowing with parameters of type Trigger

Modifier and Type	Method	Description
void	WindowOperatorBuilder.trigger(Trigger<? super T,? super W> trigger)

Constructors in org.apache.flink.streaming.runtime.operators.windowing with parameters of type Trigger

Constructor	Description
EvictingWindowOperator(WindowAssigner<? super IN,W> windowAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, org.apache.flink.api.java.functions.KeySelector<IN,K> keySelector, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.state.StateDescriptor<? extends org.apache.flink.api.common.state.ListState<StreamRecord<IN>>,?> windowStateDescriptor, InternalWindowFunction<Iterable<IN>,OUT,K,W> windowFunction, Trigger<? super IN,? super W> trigger, Evictor<? super IN,? super W> evictor, long allowedLateness, org.apache.flink.util.OutputTag<IN> lateDataOutputTag)
WindowOperator(WindowAssigner<? super IN,W> windowAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, org.apache.flink.api.java.functions.KeySelector<IN,K> keySelector, org.apache.flink.api.common.typeutils.TypeSerializer<K> keySerializer, org.apache.flink.api.common.state.StateDescriptor<? extends org.apache.flink.api.common.state.AppendingState<IN,ACC>,?> windowStateDescriptor, InternalWindowFunction<ACC,OUT,K,W> windowFunction, Trigger<? super IN,? super W> trigger, long allowedLateness, org.apache.flink.util.OutputTag<IN> lateDataOutputTag)	Creates a new WindowOperator based on the given policies and user functions.
WindowOperatorBuilder(WindowAssigner<? super T,W> windowAssigner, Trigger<? super T,? super W> trigger, org.apache.flink.api.common.ExecutionConfig config, org.apache.flink.api.common.typeinfo.TypeInformation<T> inputType, org.apache.flink.api.java.functions.KeySelector<T,K> keySelector, org.apache.flink.api.common.typeinfo.TypeInformation<K> keyType)