类的使用
org.apache.flink.streaming.api.windowing.triggers.Trigger

使用Trigger的程序包

程序包	说明
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.

org.apache.flink.streaming.api.datastream中Trigger的使用

参数类型为Trigger的org.apache.flink.streaming.api.datastream中的方法

限定符和类型	方法和说明
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.
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.
AllWindowedStream<T,W>	AllWindowedStream.trigger(Trigger<? super T,? super W> trigger) 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.

参数类型为Trigger的org.apache.flink.streaming.api.datastream中的构造器

构造器和说明
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, 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, 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) 已过时。 Use WithWindow#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, Time allowedLateness) 已过时。 Use WithWindow#WithWindow(DataStream, DataStream, KeySelector, KeySelector, TypeInformation, WindowAssigner, Trigger, Evictor, Duration)

org.apache.flink.streaming.api.windowing.assigners中Trigger的使用

org.apache.flink.streaming.api.windowing.assigners中Trigger的子类

限定符和类型	类和说明
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.

返回Trigger的org.apache.flink.streaming.api.windowing.assigners中的方法

限定符和类型	方法和说明
Trigger<Object,TimeWindow>	ProcessingTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	SlidingProcessingTimeWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	EventTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	TumblingProcessingTimeWindows.getDefaultTrigger()
Trigger<T,TimeWindow>	DynamicEventTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	SlidingEventTimeWindows.getDefaultTrigger()
Trigger<T,TimeWindow>	DynamicProcessingTimeSessionWindows.getDefaultTrigger()
Trigger<Object,TimeWindow>	TumblingEventTimeWindows.getDefaultTrigger()
Trigger<Object,GlobalWindow>	GlobalWindows.getDefaultTrigger()
Trigger<T,W>	WindowAssigner.getDefaultTrigger() Returns the default trigger associated with this WindowAssigner.
Trigger<Object,TimeWindow>	ProcessingTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	SlidingProcessingTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	EventTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	TumblingProcessingTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<T,TimeWindow>	DynamicEventTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	SlidingEventTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<T,TimeWindow>	DynamicProcessingTimeSessionWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,TimeWindow>	TumblingEventTimeWindows.getDefaultTrigger(StreamExecutionEnvironment env)
Trigger<Object,GlobalWindow>	GlobalWindows.getDefaultTrigger(StreamExecutionEnvironment env)
abstract Trigger<T,W>	WindowAssigner.getDefaultTrigger(StreamExecutionEnvironment env) 已过时。 the method is deprecated since Flink 1.19 because StreamExecutionEnvironment is unused. Please use getDefaultTrigger and override this method with an empty body instead. 1. If you override getDefaultTrigger(), the getDefaultTrigger() will be invoked and the getDefaultTrigger(StreamExecutionEnvironment env) won't be invoked. 2. If you don't override getDefaultTrigger(), the getDefaultTrigger(StreamExecutionEnvironment env) will be invoked in the default implementation of the getDefaultTrigger().

org.apache.flink.streaming.api.windowing.triggers中Trigger的使用

org.apache.flink.streaming.api.windowing.triggers中Trigger的子类

限定符和类型	类和说明
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.

返回Trigger的org.apache.flink.streaming.api.windowing.triggers中的方法

限定符和类型	方法和说明
Trigger<T,W>	PurgingTrigger.getNestedTrigger()

参数类型为Trigger的org.apache.flink.streaming.api.windowing.triggers中的方法

限定符和类型	方法和说明
static <T,W extends Window> PurgingTrigger<T,W>	PurgingTrigger.of(Trigger<T,W> nestedTrigger) Creates a new purging trigger from the given Trigger.
static <T,W extends Window> ProcessingTimeoutTrigger<T,W>	ProcessingTimeoutTrigger.of(Trigger<T,W> nestedTrigger, 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, Duration timeout, boolean resetTimerOnNewRecord, boolean shouldClearOnTimeout) Creates a new ProcessingTimeoutTrigger that fires when the inner trigger is fired or when the timeout timer fires.

org.apache.flink.streaming.runtime.operators.windowing中Trigger的使用

返回Trigger的org.apache.flink.streaming.runtime.operators.windowing中的方法

限定符和类型	方法和说明
Trigger<? super IN,? super W>	WindowOperator.getTrigger()

参数类型为Trigger的org.apache.flink.streaming.runtime.operators.windowing中的方法

限定符和类型	方法和说明
void	WindowOperatorBuilder.trigger(Trigger<? super T,? super W> trigger)

参数类型为Trigger的org.apache.flink.streaming.runtime.operators.windowing中的构造器

构造器和说明
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)