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

类 ProcessingTimeSessionWindows

java.lang.Object

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

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

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

所有已实现的接口:

Serializable

@PublicEvolving
public class ProcessingTimeSessionWindows
extends MergingWindowAssigner<Object,TimeWindow>

A WindowAssigner that windows elements into sessions based on the current processing time. Windows cannot overlap.

For example, in order to window into windows of 1 minute, every 10 seconds:

 DataStream<Tuple2<String, Integer>> in = ...;
 KeyedStream<String, Tuple2<String, Integer>> keyed = in.keyBy(...);
 WindowedStream<Tuple2<String, Integer>, String, TimeWindows> windowed =
   keyed.window(ProcessingTimeSessionWindows.withGap(Duration.ofMinutes(1)));
 

另请参阅:

序列化表格

嵌套类概要

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

MergingWindowAssigner.MergeCallback<W>

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

WindowAssigner.WindowAssignerContext

字段概要

字段

限定符和类型	字段和说明
protected long	sessionTimeout

构造器概要

构造器

限定符	构造器和说明
protected	ProcessingTimeSessionWindows(long sessionTimeout)

方法概要

限定符和类型	方法和说明
Collection<TimeWindow>	assignWindows(Object element, long timestamp, WindowAssigner.WindowAssignerContext context) Returns a Collection of windows that should be assigned to the element.
Trigger<Object,TimeWindow>	getDefaultTrigger() Returns the default trigger associated with this WindowAssigner.
Trigger<Object,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> DynamicProcessingTimeSessionWindows<T>	withDynamicGap(SessionWindowTimeGapExtractor<T> sessionWindowTimeGapExtractor) Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.
static ProcessingTimeSessionWindows	withGap(Duration size) Creates a new SessionWindows WindowAssigner that assigns elements to sessions based on the element timestamp.
static ProcessingTimeSessionWindows	withGap(Time size) 已过时。 Use withGap(Duration)

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

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

字段详细资料

sessionTimeout

protected long sessionTimeout

构造器详细资料

ProcessingTimeSessionWindows

protected ProcessingTimeSessionWindows(long sessionTimeout)

方法详细资料

assignWindows

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

从类复制的说明: WindowAssigner

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

指定者:

assignWindows 在类中 WindowAssigner<Object,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<Object,TimeWindow> getDefaultTrigger(StreamExecutionEnvironment env)

从类复制的说明: WindowAssigner

Returns the default trigger associated with this WindowAssigner.

指定者:

getDefaultTrigger 在类中 WindowAssigner<Object,TimeWindow>

另请参阅:

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

getDefaultTrigger

public Trigger<Object,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<Object,TimeWindow>

toString

public String toString()

覆盖:

toString 在类中 Object

withGap

@Deprecated
public static ProcessingTimeSessionWindows withGap(Time size)

已过时。 Use withGap(Duration)

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

参数:

size - The session timeout, i.e. the time gap between sessions

返回:

The policy.

withGap

public static ProcessingTimeSessionWindows withGap(Duration size)

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

参数:

size - The session timeout, i.e. the time gap between sessions

返回:

The policy.

withDynamicGap

@PublicEvolving
public static <T> DynamicProcessingTimeSessionWindows<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<Object,TimeWindow>

isEventTime

public boolean isEventTime()

从类复制的说明: WindowAssigner

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

指定者:

isEventTime 在类中 WindowAssigner<Object,TimeWindow>

mergeWindows

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

Merge overlapping TimeWindows.

指定者:

mergeWindows 在类中 MergingWindowAssigner<Object,TimeWindow>

参数:

windows - The window candidates.

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