Package | Description |
---|---|
org.apache.flink.state.api | |
org.apache.flink.state.api.runtime | |
org.apache.flink.state.api.runtime.metadata |
Modifier and Type | Method and Description |
---|---|
<ACC,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,R> function)
Applies the given aggregation function to each window.
|
<ACC,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,R> function,
TypeInformation<ACC> accumulatorType)
Applies the given aggregation function to each window.
|
<ACC,V,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,V> aggFunction,
ProcessWindowFunction<V,R,K,W> windowFunction)
Applies the given window function to each window.
|
<ACC,V,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
ProcessWindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType)
Applies the given window function to each window.
|
<ACC,V,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,V> aggFunction,
WindowFunction<V,R,K,W> windowFunction)
Applies the given window function to each window.
|
<ACC,V,R> StateBootstrapTransformation<T> |
WindowedStateTransformation.aggregate(AggregateFunction<T,ACC,V> aggregateFunction,
WindowFunction<V,R,K,W> windowFunction,
TypeInformation<ACC> accumulatorType)
Applies the given window function to each window.
|
<R> StateBootstrapTransformation<T> |
WindowedStateTransformation.apply(WindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
<R> StateBootstrapTransformation<T> |
WindowedStateTransformation.apply(WindowFunction<T,R,K,W> function,
TypeInformation<R> resultType)
Applies the given window function to each window.
|
<R> StateBootstrapTransformation<T> |
WindowedStateTransformation.process(ProcessWindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
StateBootstrapTransformation<T> |
WindowedStateTransformation.reduce(ReduceFunction<T> function)
Applies a reduce function to the window.
|
<R> StateBootstrapTransformation<T> |
WindowedStateTransformation.reduce(ReduceFunction<T> reduceFunction,
ProcessWindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
<R> StateBootstrapTransformation<T> |
WindowedStateTransformation.reduce(ReduceFunction<T> reduceFunction,
WindowFunction<T,R,K,W> function)
Applies the given window function to each window.
|
StateBootstrapTransformation<T> |
OneInputStateTransformation.transform(BroadcastStateBootstrapFunction<T> processFunction)
Applies the given
BroadcastStateBootstrapFunction on the non-keyed input. |
StateBootstrapTransformation<T> |
KeyedStateTransformation.transform(KeyedStateBootstrapFunction<K,T> processFunction)
Applies the given
KeyedStateBootstrapFunction on the keyed input. |
StateBootstrapTransformation<T> |
KeyedStateTransformation.transform(SavepointWriterOperatorFactory factory)
Method for passing user defined operators along with the type information that will transform
the OperatorTransformation.
|
StateBootstrapTransformation<T> |
OneInputStateTransformation.transform(SavepointWriterOperatorFactory factory)
Method for passing user defined operators along with the type information that will transform
the OperatorTransformation.
|
StateBootstrapTransformation<T> |
OneInputStateTransformation.transform(StateBootstrapFunction<T> processFunction)
Applies the given
StateBootstrapFunction on the non-keyed input. |
Modifier and Type | Method and Description |
---|---|
<T> SavepointWriter |
SavepointWriter.withOperator(String uid,
StateBootstrapTransformation<T> transformation)
Adds a new operator to the savepoint.
|
Modifier and Type | Method and Description |
---|---|
StateBootstrapTransformation<T> |
StateBootstrapTransformationWithID.getBootstrapTransformation() |
Constructor and Description |
---|
StateBootstrapTransformationWithID(OperatorID operatorID,
StateBootstrapTransformation<T> bootstrapTransformation) |
Modifier and Type | Method and Description |
---|---|
void |
SavepointMetadataV2.addOperator(String uid,
StateBootstrapTransformation<?> transformation) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.