@PublicEvolving public class SlidingEventTimeWindows extends WindowAssigner<Object,TimeWindow>
WindowAssigner
that windows elements into sliding windows based on the timestamp of the
elements. Windows can possibly overlap.
For example, in order to window into windows of 1 minute, every 10 seconds:
DataStream<Tuple2<String, Integer>> in = ...;
KeyedStream<Tuple2<String, Integer>, String> keyed = in.keyBy(...);
WindowedStream<Tuple2<String, Integer>, String, TimeWindow> windowed =
keyed.window(SlidingEventTimeWindows.of(Time.minutes(1), Time.seconds(10)));
Modifier | Constructor and Description |
---|---|
protected |
SlidingEventTimeWindows(long size,
long slide) |
Modifier and Type | Method and Description |
---|---|
Collection<TimeWindow> |
assignWindows(Object element,
long timestamp)
Returns a
Collection of windows that should be assigned to the element. |
Trigger<Object,TimeWindow> |
getDefaultTrigger(StreamExecutionEnvironment env)
Returns the default trigger associated with this
WindowAssigner . |
long |
getSize() |
long |
getSlide() |
TypeSerializer<TimeWindow> |
getWindowSerializer(ExecutionConfig executionConfig)
Returns a
TypeSerializer for serializing windows that are assigned by
this WindowAssigner . |
static SlidingEventTimeWindows |
of(Time size,
Time slide)
Creates a new
SlidingEventTimeWindows WindowAssigner that assigns
elements to sliding time windows based on the element timestamp. |
String |
toString() |
public Collection<TimeWindow> assignWindows(Object element, long timestamp)
WindowAssigner
Collection
of windows that should be assigned to the element.assignWindows
in class WindowAssigner<Object,TimeWindow>
element
- The element to which windows should be assigned.timestamp
- The timestamp of the element.public long getSize()
public long getSlide()
public Trigger<Object,TimeWindow> getDefaultTrigger(StreamExecutionEnvironment env)
WindowAssigner
WindowAssigner
.getDefaultTrigger
in class WindowAssigner<Object,TimeWindow>
public static SlidingEventTimeWindows of(Time size, Time slide)
SlidingEventTimeWindows
WindowAssigner
that assigns
elements to sliding time windows based on the element timestamp.size
- The size of the generated windows.slide
- The slide interval of the generated windows.public TypeSerializer<TimeWindow> getWindowSerializer(ExecutionConfig executionConfig)
WindowAssigner
TypeSerializer
for serializing windows that are assigned by
this WindowAssigner
.getWindowSerializer
in class WindowAssigner<Object,TimeWindow>
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.