@Internal @Deprecated public class FoldApplyAllWindowFunction<W extends Window,T,ACC,R> extends WrappingFunction<AllWindowFunction<ACC,R,W>> implements AllWindowFunction<T,R,W>, OutputTypeConfigurable<R>
AllWindowFunction
that is used for implementing a fold on a window configuration
that only allows AllWindowFunction
and cannot directly execute a FoldFunction
.wrappedFunction
Constructor and Description |
---|
FoldApplyAllWindowFunction(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
AllWindowFunction<ACC,R,W> windowFunction,
TypeInformation<ACC> accTypeInformation)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
apply(W window,
Iterable<T> values,
Collector<R> out)
Deprecated.
Evaluates the window and outputs none or several elements.
|
void |
open(Configuration configuration)
Deprecated.
Initialization method for the function.
|
void |
setOutputType(TypeInformation<R> outTypeInfo,
ExecutionConfig executionConfig)
Deprecated.
Is called by the
org.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer,
String, StreamOperator, TypeInformation, TypeInformation, String) method when the StreamGraph is generated. |
close, getWrappedFunction, setRuntimeContext
getIterationRuntimeContext, getRuntimeContext
public FoldApplyAllWindowFunction(ACC initialValue, FoldFunction<T,ACC> foldFunction, AllWindowFunction<ACC,R,W> windowFunction, TypeInformation<ACC> accTypeInformation)
public void open(Configuration configuration) throws Exception
RichFunction
The configuration object passed to the function can be used for configuration and initialization. The configuration contains all parameters that were configured on the function in the program composition.
public class MyFilter extends RichFilterFunction<String> {
private String searchString;
public void open(Configuration parameters) {
this.searchString = parameters.getString("foo");
}
public boolean filter(String value) {
return value.equals(searchString);
}
}
By default, this method does nothing.
open
in interface RichFunction
open
in class WrappingFunction<AllWindowFunction<ACC,R,W extends Window>>
configuration
- The configuration containing the parameters attached to the contract.Exception
- Implementations may forward exceptions, which are caught by the runtime.
When the runtime catches an exception, it aborts the task and lets the fail-over logic
decide whether to retry the task execution.Configuration
public void apply(W window, Iterable<T> values, Collector<R> out) throws Exception
AllWindowFunction
apply
in interface AllWindowFunction<T,R,W extends Window>
window
- The window that is being evaluated.values
- The elements in the window being evaluated.out
- A collector for emitting elements.Exception
- The function may throw exceptions to fail the program and trigger recovery.public void setOutputType(TypeInformation<R> outTypeInfo, ExecutionConfig executionConfig)
OutputTypeConfigurable
org.apache.flink.streaming.api.graph.StreamGraph#addOperator(Integer,
String, StreamOperator, TypeInformation, TypeInformation, String)
method when the StreamGraph
is generated. The method is called with the
output TypeInformation
which is also used for the StreamTask
output serializer.setOutputType
in interface OutputTypeConfigurable<R>
outTypeInfo
- Output type information of the StreamTask
executionConfig
- Execution configurationCopyright © 2014–2021 The Apache Software Foundation. All rights reserved.