Modifier and Type | Class and Description |
---|---|
class |
RichFoldFunction<O,T>
Rich variant of the
FoldFunction . |
Modifier and Type | Method and Description |
---|---|
FoldFunction<T,ACC> |
FoldingStateDescriptor.getFoldFunction()
Returns the fold function to be used for the folding state.
|
Constructor and Description |
---|
FoldingStateDescriptor(String name,
ACC initialValue,
FoldFunction<T,ACC> foldFunction,
Class<ACC> typeClass)
Creates a new
FoldingStateDescriptor with the given name, type, and initial value. |
FoldingStateDescriptor(String name,
ACC initialValue,
FoldFunction<T,ACC> foldFunction,
TypeInformation<ACC> typeInfo)
Creates a new
FoldingStateDescriptor with the given name and default value. |
FoldingStateDescriptor(String name,
ACC initialValue,
FoldFunction<T,ACC> foldFunction,
TypeSerializer<ACC> typeSerializer)
Creates a new
ValueStateDescriptor with the given name and default value. |
Modifier and Type | Method and Description |
---|---|
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFoldReturnTypes(FoldFunction<IN,OUT> foldInterface,
TypeInformation<IN> inType) |
static <IN,OUT> TypeInformation<OUT> |
TypeExtractor.getFoldReturnTypes(FoldFunction<IN,OUT> foldInterface,
TypeInformation<IN> inType,
String functionName,
boolean allowMissing) |
Constructor and Description |
---|
GenericFoldingState(ValueState<ACC> wrappedState,
FoldFunction<T,ACC> foldFunction)
Creates a new
FoldingState that wraps the given ValueState . |
Modifier and Type | Method and Description |
---|---|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
AllWindowFunction<R,R,W> function)
Deprecated.
Use
#fold(R, FoldFunction, AllWindowFunction) instead. |
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
AllWindowFunction<R,R,W> function,
TypeInformation<R> resultType)
Deprecated.
Use
#fold(R, FoldFunction, AllWindowFunction, TypeInformation, TypeInformation) instead. |
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
WindowFunction<R,R,K,W> function)
Deprecated.
Use
#fold(R, FoldFunction, WindowFunction) instead. |
<R> SingleOutputStreamOperator<R> |
WindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
WindowFunction<R,R,K,W> function,
TypeInformation<R> resultType)
Deprecated.
Use
#fold(R, FoldFunction, WindowFunction, TypeInformation, TypeInformation) instead. |
<ACC,R> SingleOutputStreamOperator<R> |
AllWindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
AllWindowFunction<ACC,R,W> function)
Applies the given window function to each window.
|
<ACC,R> SingleOutputStreamOperator<R> |
AllWindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
AllWindowFunction<ACC,R,W> function,
TypeInformation<ACC> foldAccumulatorType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<ACC,R> SingleOutputStreamOperator<R> |
WindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
WindowFunction<ACC,R,K,W> function)
Applies the given window function to each window.
|
<ACC,R> SingleOutputStreamOperator<R> |
WindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
WindowFunction<ACC,R,K,W> function,
TypeInformation<ACC> foldAccumulatorType,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.fold(R initialValue,
FoldFunction<T,R> function)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
KeyedStream.fold(R initialValue,
FoldFunction<T,R> folder)
Applies a fold transformation on the grouped data stream grouped on by
the given key position.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.fold(R initialValue,
FoldFunction<T,R> function)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
WindowedStream.fold(R initialValue,
FoldFunction<T,R> function,
TypeInformation<R> resultType)
Applies the given fold function to each window.
|
<R> SingleOutputStreamOperator<R> |
AllWindowedStream.fold(R initialValue,
FoldFunction<T,R> function,
TypeInformation<R> resultType)
Applies the given fold function to each window.
|
Constructor and Description |
---|
FoldApplyAllWindowFunction(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
AllWindowFunction<ACC,R,W> windowFunction,
TypeInformation<ACC> accTypeInformation) |
FoldApplyWindowFunction(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
WindowFunction<ACC,R,K,W> windowFunction,
TypeInformation<ACC> accTypeInformation) |
Constructor and Description |
---|
StreamGroupedFold(FoldFunction<IN,OUT> folder,
OUT initialValue) |
Modifier and Type | Method and Description |
---|---|
<R> DataStream<R> |
AllWindowedStream.apply(R initialValue,
FoldFunction<T,R> preAggregator,
AllWindowFunction<R,R,W> windowFunction,
TypeInformation<R> evidence$13)
Deprecated.
Use
fold(R, FoldFunction, AllWindowFunction) instead. |
<R> DataStream<R> |
WindowedStream.apply(R initialValue,
FoldFunction<T,R> foldFunction,
WindowFunction<R,R,K,W> function,
TypeInformation<R> evidence$13)
Deprecated.
Use
fold(R, FoldFunction, WindowFunction) instead. |
<ACC,R> DataStream<R> |
AllWindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> preAggregator,
AllWindowFunction<ACC,R,W> windowFunction,
TypeInformation<ACC> evidence$5,
TypeInformation<R> evidence$6)
Applies the given window function to each window.
|
<ACC,R> DataStream<R> |
WindowedStream.fold(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
WindowFunction<ACC,R,K,W> function,
TypeInformation<ACC> evidence$5,
TypeInformation<R> evidence$6)
Applies the given window function to each window.
|
<R> DataStream<R> |
KeyedStream.fold(R initialValue,
FoldFunction<T,R> folder,
TypeInformation<R> evidence$2)
Creates a new
DataStream by folding the elements of this DataStream
using an associative fold function and an initial value. |
<R> DataStream<R> |
AllWindowedStream.fold(R initialValue,
FoldFunction<T,R> function,
TypeInformation<R> evidence$3)
Applies the given fold function to each window.
|
<R> DataStream<R> |
WindowedStream.fold(R initialValue,
FoldFunction<T,R> function,
TypeInformation<R> evidence$3)
Applies the given fold function to each window.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaFoldFunction<T,R>
A wrapper function that exposes a Scala Function2 as a
FoldFunction . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.