Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.scala | |
org.apache.flink.streaming.api.windowing.assigners | |
org.apache.flink.streaming.api.windowing.triggers | |
org.apache.flink.streaming.api.windowing.windows | |
org.apache.flink.streaming.examples.ml | |
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 |
---|---|
WindowedStream<T,KEY,TimeWindow> |
KeyedStream.timeWindow(Time size)
Windows this
KeyedStream into tumbling time windows. |
WindowedStream<T,KEY,TimeWindow> |
KeyedStream.timeWindow(Time size,
Time slide)
Windows this
KeyedStream into sliding time windows. |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size)
Windows this
DataStream into tumbling time windows. |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size,
Time slide)
Windows this
DataStream into sliding time windows. |
Modifier and Type | Method and Description |
---|---|
WindowedStream<T,K,TimeWindow> |
KeyedStream.timeWindow(Time size)
Windows this
KeyedStream into tumbling time windows. |
WindowedStream<T,K,TimeWindow> |
KeyedStream.timeWindow(Time size,
Time slide)
Windows this
KeyedStream into sliding time windows. |
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size)
Windows this DataStream into tumbling time windows.
|
AllWindowedStream<T,TimeWindow> |
DataStream.timeWindowAll(Time size,
Time slide)
Windows this DataStream into sliding time windows.
|
Modifier and Type | Method and Description |
---|---|
void |
ProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
void |
ProcessingTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
void |
EventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
void |
EventTimeSessionWindows.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
Modifier and Type | Method and Description |
---|---|
TimeWindow |
TimeWindow.Serializer.copy(TimeWindow from) |
TimeWindow |
TimeWindow.Serializer.copy(TimeWindow from,
TimeWindow reuse) |
TimeWindow |
TimeWindow.cover(TimeWindow other)
Returns the minimal window covers both this window and the given window.
|
TimeWindow |
TimeWindow.Serializer.createInstance() |
TimeWindow |
TimeWindow.Serializer.deserialize(DataInputView source) |
TimeWindow |
TimeWindow.Serializer.deserialize(TimeWindow reuse,
DataInputView source) |
Modifier and Type | Method and Description |
---|---|
TypeSerializer<TimeWindow> |
TimeWindow.Serializer.duplicate() |
Modifier and Type | Method and Description |
---|---|
TimeWindow |
TimeWindow.Serializer.copy(TimeWindow from) |
TimeWindow |
TimeWindow.Serializer.copy(TimeWindow from,
TimeWindow reuse) |
TimeWindow |
TimeWindow.cover(TimeWindow other)
Returns the minimal window covers both this window and the given window.
|
TimeWindow |
TimeWindow.Serializer.deserialize(TimeWindow reuse,
DataInputView source) |
boolean |
TimeWindow.intersects(TimeWindow other)
Returns
true if this window intersects the given window. |
void |
TimeWindow.Serializer.serialize(TimeWindow record,
DataOutputView target) |
Modifier and Type | Method and Description |
---|---|
static void |
TimeWindow.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
static void |
TimeWindow.mergeWindows(Collection<TimeWindow> windows,
MergingWindowAssigner.MergeCallback<TimeWindow> c)
Merge overlapping
TimeWindow s. |
Modifier and Type | Method and Description |
---|---|
void |
IncrementalLearningSkeleton.PartialModelBuilder.apply(TimeWindow window,
Iterable<Integer> values,
Collector<Double[]> out) |
Modifier and Type | Method and Description |
---|---|
void |
AccumulatingKeyedTimePanes.evaluateWindow(Collector<Result> out,
TimeWindow window,
AbstractStreamOperator<Result> operator) |
abstract void |
AbstractKeyedTimePanes.evaluateWindow(Collector<Result> out,
TimeWindow window,
AbstractStreamOperator<Result> operator) |
void |
AggregatingKeyedTimePanes.evaluateWindow(Collector<Type> out,
TimeWindow window,
AbstractStreamOperator<Type> operator) |
Constructor and Description |
---|
AccumulatingProcessingTimeWindowOperator(WindowFunction<IN,OUT,KEY,TimeWindow> function,
KeySelector<IN,KEY> keySelector,
TypeSerializer<KEY> keySerializer,
TypeSerializer<IN> valueSerializer,
long windowLength,
long windowSlide) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.