@Internal @Deprecated public class FoldApplyProcessWindowFunction<K,W extends Window,T,ACC,R> extends ProcessWindowFunction<T,R,K,W> implements OutputTypeConfigurable<R>
ProcessWindowFunction
that is used for implementing a fold on a window
configuration that only allows ProcessWindowFunction
and cannot directly execute a
FoldFunction
.ProcessWindowFunction.Context
Constructor and Description |
---|
FoldApplyProcessWindowFunction(ACC initialValue,
FoldFunction<T,ACC> foldFunction,
ProcessWindowFunction<ACC,R,K,W> windowFunction,
TypeInformation<ACC> accTypeInformation)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
clear(ProcessWindowFunction.Context context)
Deprecated.
Deletes any state in the
Context when the Window is purged. |
void |
close()
Deprecated.
Tear-down method for the user code.
|
void |
open(Configuration configuration)
Deprecated.
Initialization method for the function.
|
void |
process(K key,
ProcessWindowFunction.Context context,
Iterable<T> values,
Collector<R> out)
Deprecated.
Evaluates the window and outputs none or several elements.
|
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. |
void |
setRuntimeContext(RuntimeContext t)
Deprecated.
Sets the function's runtime context.
|
getIterationRuntimeContext, getRuntimeContext
public FoldApplyProcessWindowFunction(ACC initialValue, FoldFunction<T,ACC> foldFunction, ProcessWindowFunction<ACC,R,K,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 MyMapper extends FilterFunction<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 AbstractRichFunction
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 close() throws Exception
RichFunction
This method can be used for clean up work.
close
in interface RichFunction
close
in class AbstractRichFunction
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.public void setRuntimeContext(RuntimeContext t)
RichFunction
setRuntimeContext
in interface RichFunction
setRuntimeContext
in class AbstractRichFunction
t
- The runtime context.public void process(K key, ProcessWindowFunction.Context context, Iterable<T> values, Collector<R> out) throws Exception
ProcessWindowFunction
process
in class ProcessWindowFunction<T,R,K,W extends Window>
key
- The key for which this window is evaluated.context
- The context in which the window 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 clear(ProcessWindowFunction.Context context) throws Exception
ProcessWindowFunction
Context
when the Window is purged.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–2020 The Apache Software Foundation. All rights reserved.