org.apache.flink.streaming.api.windowing.assigners

类 DynamicEventTimeSessionWindows<T>

java.lang.Object

org.apache.flink.streaming.api.windowing.assigners.WindowAssigner<T,W>

org.apache.flink.streaming.api.windowing.assigners.MergingWindowAssigner<T,TimeWindow>

org.apache.flink.streaming.api.windowing.assigners.DynamicEventTimeSessionWindows<T>

类型参数:

T - The type of the input elements

所有已实现的接口:

Serializable

@PublicEvolving
public class DynamicEventTimeSessionWindows<T>
extends MergingWindowAssigner<T,TimeWindow>

A WindowAssigner that windows elements into sessions based on the timestamp of the elements. Windows cannot overlap.

For example, in order to window into windows with a dynamic time gap:

 DataStream<Tuple2<String, Integer>> in = ...;
 KeyedStream<String, Tuple2<String, Integer>> keyed = in.keyBy(...);
 WindowedStream<Tuple2<String, Integer>, String, TimeWindows> windowed =
   keyed.window(DynamicEventTimeSessionWindows.withDynamicGap({@link SessionWindowTimeGapExtractor }));
 

另请参阅:

序列化表格

嵌套类概要

从类继承的嵌套类/接口 org.apache.flink.streaming.api.windowing.assigners.MergingWindowAssigner

MergingWindowAssigner.MergeCallback<W>

从类继承的嵌套类/接口 org.apache.flink.streaming.api.windowing.assigners.WindowAssigner

WindowAssigner.WindowAssignerContext

字段概要

字段

限定符和类型	字段和说明
protected SessionWindowTimeGapExtractor<T>	sessionWindowTimeGapExtractor

构造器概要

构造器

限定符	构造器和说明
protected	DynamicEventTimeSessionWindows(SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor)

方法概要

限定符和类型	方法和说明
Collection<TimeWindow>	assignWindows(T element, long timestamp, WindowAssigner.WindowAssignerContext context) Returns a Collection of windows that should be assigned to the element.
Trigger<T,TimeWindow>	getDefaultTrigger() Returns the default trigger associated with this WindowAssigner.
Trigger<T,TimeWindow>	getDefaultTrigger(StreamExecutionEnvironment env) Returns the default trigger associated with this WindowAssigner.
org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow>	getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig) Returns a TypeSerializer for serializing windows that are assigned by this WindowAssigner.
boolean	isEventTime() Returns true if elements are assigned to windows based on event time, false otherwise.
void	mergeWindows(Collection<TimeWindow> windows, MergingWindowAssigner.MergeCallback<TimeWindow> c) Merge overlapping TimeWindows.
String	toString()
static <T> DynamicEventTimeSessionWindows<T>	withDynamicGap(SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor) Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

字段详细资料

sessionWindowTimeGapExtractor

protected SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor

构造器详细资料

DynamicEventTimeSessionWindows

protected DynamicEventTimeSessionWindows(SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor)

方法详细资料

assignWindows

public Collection<TimeWindow> assignWindows(T element,
                                            long timestamp,
                                            WindowAssigner.WindowAssignerContext context)

从类复制的说明: WindowAssigner

Returns a Collection of windows that should be assigned to the element.

指定者:

assignWindows 在类中 WindowAssigner<T,TimeWindow>

参数:

element - The element to which windows should be assigned.

timestamp - The timestamp of the element.

context - The WindowAssigner.WindowAssignerContext in which the assigner operates.

getDefaultTrigger

public Trigger<T,TimeWindow> getDefaultTrigger(StreamExecutionEnvironment env)

从类复制的说明: WindowAssigner

Returns the default trigger associated with this WindowAssigner.

指定者:

getDefaultTrigger 在类中 WindowAssigner<T,TimeWindow>

另请参阅:

FLIP-343: Remove parameter in WindowAssigner#getDefaultTrigger()

getDefaultTrigger

public Trigger<T,TimeWindow> getDefaultTrigger()

从类复制的说明: WindowAssigner

Returns the default trigger associated with this WindowAssigner.

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().

覆盖:

getDefaultTrigger 在类中 WindowAssigner<T,TimeWindow>

toString

public String toString()

覆盖:

toString 在类中 Object

withDynamicGap

public static <T> DynamicEventTimeSessionWindows<T> withDynamicGap(SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor)

Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.

参数:

sessionWindowTimeGapExtractor - The extractor to use to extract the time gap from the input elements

返回:

The policy.

getWindowSerializer

public org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow> getWindowSerializer(org.apache.flink.api.common.ExecutionConfig executionConfig)

从类复制的说明: WindowAssigner

Returns a TypeSerializer for serializing windows that are assigned by this WindowAssigner.

指定者:

getWindowSerializer 在类中 WindowAssigner<T,TimeWindow>

isEventTime

public boolean isEventTime()

从类复制的说明: WindowAssigner

Returns true if elements are assigned to windows based on event time, false otherwise.

指定者:

isEventTime 在类中 WindowAssigner<T,TimeWindow>

mergeWindows

public void mergeWindows(Collection<TimeWindow> windows,
                         MergingWindowAssigner.MergeCallback<TimeWindow> c)

Merge overlapping TimeWindows.

指定者:

mergeWindows 在类中 MergingWindowAssigner<T,TimeWindow>

参数:

windows - The window candidates.

c - A callback that can be invoked to signal which windows should be merged.