Package | Description |
---|---|
org.apache.flink.cep.pattern | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.timestamps | |
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.api.windowing.evictors | |
org.apache.flink.streaming.api.windowing.time | |
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.
|
Modifier and Type | Method and Description |
---|---|
Time |
Pattern.getWindowTime() |
Modifier and Type | Method and Description |
---|---|
Pattern<T,F> |
Pattern.within(Time windowTime)
Defines the maximum time interval in which a matching pattern has to be completed in order to
be considered valid.
|
Modifier and Type | Method and Description |
---|---|
CoGroupedStreams.WithWindow<T1,T2,KEY,W> |
CoGroupedStreams.WithWindow.allowedLateness(Time newLateness)
Sets the time by which elements are allowed to be late.
|
JoinedStreams.WithWindow<T1,T2,KEY,W> |
JoinedStreams.WithWindow.allowedLateness(Time newLateness)
Sets the time by which elements are allowed to be late.
|
WindowedStream<T,K,W> |
WindowedStream.allowedLateness(Time lateness)
Sets the time by which elements are allowed to be late.
|
AllWindowedStream<T,W> |
AllWindowedStream.allowedLateness(Time lateness)
Sets the time by which elements are allowed to be late.
|
KeyedStream.IntervalJoined<T1,T2,KEY> |
KeyedStream.IntervalJoin.between(Time lowerBound,
Time upperBound)
Specifies the time boundaries over which the join operation works, so that
|
WindowedStream<T,KEY,TimeWindow> |
KeyedStream.timeWindow(Time size)
Deprecated.
Please use
KeyedStream.window(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows . For more information,
see the deprecation notice on TimeCharacteristic |
WindowedStream<T,KEY,TimeWindow> |
KeyedStream.timeWindow(Time size,
Time slide)
Deprecated.
Please use
KeyedStream.window(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows . For more information,
see the deprecation notice on TimeCharacteristic |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size)
Deprecated.
Please use
DataStream.windowAll(WindowAssigner) with either TumblingEventTimeWindows or TumblingProcessingTimeWindows . For more information,
see the deprecation notice on TimeCharacteristic |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size,
Time slide)
Deprecated.
Please use
DataStream.windowAll(WindowAssigner) with either SlidingEventTimeWindows or SlidingProcessingTimeWindows . For more information,
see the deprecation notice on TimeCharacteristic |
Constructor and Description |
---|
WithWindow(DataStream<T1> input1,
DataStream<T2> input2,
KeySelector<T1,KEY> keySelector1,
KeySelector<T2,KEY> keySelector2,
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) |
WithWindow(DataStream<T1> input1,
DataStream<T2> input2,
KeySelector<T1,KEY> keySelector1,
KeySelector<T2,KEY> keySelector2,
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) |
Constructor and Description |
---|
BoundedOutOfOrdernessTimestampExtractor(Time maxOutOfOrderness) |
Modifier and Type | Method and Description |
---|---|
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size)
Creates a new
TumblingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp. |
static TumblingEventTimeWindows |
TumblingEventTimeWindows.of(Time size)
Creates a new
TumblingEventTimeWindows WindowAssigner that assigns elements
to time windows based on the element timestamp. |
static TumblingTimeWindows |
TumblingTimeWindows.of(Time size)
Deprecated.
Please use
TumblingEventTimeWindows.of(Time) . |
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size,
Time offset)
Creates a new
TumblingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp and offset. |
static TumblingEventTimeWindows |
TumblingEventTimeWindows.of(Time size,
Time offset)
Creates a new
TumblingEventTimeWindows WindowAssigner that assigns elements
to time windows based on the element timestamp and offset. |
static SlidingProcessingTimeWindows |
SlidingProcessingTimeWindows.of(Time size,
Time slide)
Creates a new
SlidingProcessingTimeWindows WindowAssigner that assigns
elements to sliding time windows based on the element timestamp. |
static SlidingEventTimeWindows |
SlidingEventTimeWindows.of(Time size,
Time slide)
Creates a new
SlidingEventTimeWindows WindowAssigner that assigns elements to
sliding time windows based on the element timestamp. |
static SlidingTimeWindows |
SlidingTimeWindows.of(Time size,
Time slide)
Deprecated.
Please use
SlidingEventTimeWindows.of(Time, Time) . |
static SlidingProcessingTimeWindows |
SlidingProcessingTimeWindows.of(Time size,
Time slide,
Time offset)
Creates a new
SlidingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp and offset. |
static SlidingEventTimeWindows |
SlidingEventTimeWindows.of(Time size,
Time slide,
Time offset)
Creates a new
SlidingEventTimeWindows WindowAssigner that assigns elements to
time windows based on the element timestamp and offset. |
static TumblingProcessingTimeWindows |
TumblingProcessingTimeWindows.of(Time size,
Time offset,
WindowStagger windowStagger)
Creates a new
TumblingProcessingTimeWindows WindowAssigner that assigns
elements to time windows based on the element timestamp, offset and a staggering offset,
depending on the staggering policy. |
static TumblingEventTimeWindows |
TumblingEventTimeWindows.of(Time size,
Time offset,
WindowStagger windowStagger)
Creates a new
TumblingEventTimeWindows WindowAssigner that assigns elements
to time windows based on the element timestamp, offset and a staggering offset, depending on
the staggering policy. |
static ProcessingTimeSessionWindows |
ProcessingTimeSessionWindows.withGap(Time size)
Creates a new
SessionWindows WindowAssigner that assigns elements to sessions
based on the element timestamp. |
static EventTimeSessionWindows |
EventTimeSessionWindows.withGap(Time size)
Creates a new
SessionWindows WindowAssigner that assigns elements to sessions
based on the element timestamp. |
Modifier and Type | Method and Description |
---|---|
static <W extends Window> |
TimeEvictor.of(Time windowSize)
Creates a
TimeEvictor that keeps the given number of elements. |
static <W extends Window> |
TimeEvictor.of(Time windowSize,
boolean doEvictAfter)
Creates a
TimeEvictor that keeps the given number of elements. |
Modifier and Type | Method and Description |
---|---|
static Time |
Time.days(long days)
Creates a new
Time that represents the given number of days. |
static Time |
Time.hours(long hours)
Creates a new
Time that represents the given number of hours. |
static Time |
Time.milliseconds(long milliseconds)
Creates a new
Time that represents the given number of milliseconds. |
static Time |
Time.minutes(long minutes)
Creates a new
Time that represents the given number of minutes. |
static Time |
Time.of(long size,
TimeUnit unit)
|
static Time |
Time.seconds(long seconds)
Creates a new
Time that represents the given number of seconds. |
Modifier and Type | Method and Description |
---|---|
static <W extends Window> |
ContinuousEventTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
static <W extends Window> |
ContinuousProcessingTimeTrigger.of(Time interval)
Creates a trigger that continuously fires based on the given interval.
|
Modifier and Type | Method and Description |
---|---|
void |
WindowOperatorBuilder.allowedLateness(Time lateness) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.