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() |
Time |
Quantifier.Times.getWindowTime() |
Time |
Pattern.getWindowTime(WithinType withinType) |
Modifier and Type | Method and Description |
---|---|
static Quantifier.Times |
Quantifier.Times.of(int from,
int to,
Time windowTime) |
static Quantifier.Times |
Quantifier.Times.of(int times,
Time windowTime) |
Pattern<T,F> |
Pattern.oneOrMore(Time windowTime)
Specifies that this pattern can occur
one or more times and time interval corresponds
to the maximum time gap between previous and current event for each times. |
Pattern<T,F> |
Pattern.times(int from,
int to,
Time windowTime)
Specifies that the pattern can occur between from and to times with time interval corresponds
to the maximum time gap between previous and current event for each times.
|
Pattern<T,F> |
Pattern.times(int times,
Time windowTime)
Specifies exact number of times that this pattern should be matched and time interval
corresponds to the maximum time gap between previous and current event for each times.
|
Pattern<T,F> |
Pattern.timesOrMore(int times,
Time windowTime)
Specifies that this pattern can occur the specified times at least with interval corresponds
to the maximum time gap between previous and current event for each times.
|
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.
|
Pattern<T,F> |
Pattern.within(Time windowTime,
WithinType withinType)
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 |
---|---|
JoinedStreams.WithWindow<T1,T2,KEY,W> |
JoinedStreams.WithWindow.allowedLateness(Time newLateness)
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.
|
CoGroupedStreams.WithWindow<T1,T2,KEY,W> |
CoGroupedStreams.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.
|
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 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 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 EventTimeSessionWindows |
EventTimeSessionWindows.withGap(Time size)
Creates a new
SessionWindows WindowAssigner that assigns elements to sessions
based on the element timestamp. |
static ProcessingTimeSessionWindows |
ProcessingTimeSessionWindows.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–2023 The Apache Software Foundation. All rights reserved.