Package | Description |
---|---|
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.windowing | |
org.apache.flink.streaming.api.scala.function.util | |
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 |
---|---|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(AllWindowFunction<T,R,W> function)
Applies a window function to the window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(ReduceFunction<T> preAggregator,
AllWindowFunction<T,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
AllWindowFunction<R,R,W> function)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
AllWindowFunction<R,R,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
Modifier and Type | Class and Description |
---|---|
class |
FoldApplyAllWindowFunction<W extends Window,T,ACC> |
class |
PassThroughAllWindowFunction<W extends Window,T> |
class |
ReduceApplyAllWindowFunction<W extends Window,T,R> |
class |
ReduceIterableAllWindowFunction<W extends Window,T> |
class |
RichAllWindowFunction<IN,OUT,W extends Window> |
Constructor and Description |
---|
FoldApplyAllWindowFunction(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
AllWindowFunction<ACC,ACC,W> windowFunction) |
ReduceApplyAllWindowFunction(ReduceFunction<T> reduceFunction,
AllWindowFunction<T,R,W> windowFunction) |
Modifier and Type | Class and Description |
---|---|
class |
ScalaAllWindowFunction<IN,OUT,W extends Window>
A wrapper function that exposes a Scala Function3 as a Java AllWindowFunction.
|
class |
ScalaAllWindowFunctionWrapper<IN,OUT,W extends Window>
A wrapper function that exposes a Scala WindowFunction as a JavaWindow function.
|
Modifier and Type | Class and Description |
---|---|
static class |
IncrementalLearningSkeleton.PartialModelBuilder
Builds up-to-date partial models on new training data.
|
Constructor and Description |
---|
EvictingNonKeyedWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
WindowBufferFactory<? super IN,ACC,? extends EvictingWindowBuffer<IN,ACC>> windowBufferFactory,
AllWindowFunction<ACC,OUT,W> windowFunction,
Trigger<? super IN,? super W> trigger,
Evictor<? super IN,? super W> evictor) |
NonKeyedWindowOperator(WindowAssigner<? super IN,W> windowAssigner,
TypeSerializer<W> windowSerializer,
WindowBufferFactory<? super IN,ACC,? extends WindowBuffer<IN,ACC>> windowBufferFactory,
AllWindowFunction<ACC,OUT,W> windowFunction,
Trigger<? super IN,? super W> trigger)
Creates a new
WindowOperator based on the given policies and user functions. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.