public class BlockingIncrementingMapFunction extends RichMapFunction<Long,Long>
Processing of elements is held until a latch file is created.
Constructor and Description |
---|
BlockingIncrementingMapFunction(String latchFilePath) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Tear-down method for the user code.
|
Long |
map(Long value)
The mapping method.
|
void |
open(OpenContext openContext)
Initialization method for the function.
|
getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
public BlockingIncrementingMapFunction(String latchFilePath)
public void open(OpenContext openContext)
RichFunction
The openContext object passed to the function can be used for configuration and initialization. The openContext contains some necessary information that were configured on the function in the program composition.
public class MyFilter extends RichFilterFunction<String> {
private String searchString;
public void open(OpenContext openContext) {
// initialize the value of searchString
}
public boolean filter(String value) {
return value.equals(searchString);
}
}
By default, this method does nothing.
1. If you implement open(OpenContext openContext)
, the open(OpenContext
openContext)
will be invoked and the open(Configuration parameters)
won't be
invoked. 2. If you don't implement open(OpenContext openContext)
, the open(Configuration parameters)
will be invoked in the default implementation of the open(OpenContext openContext)
.
openContext
- The context containing information about the context in which the function
is opened.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 Long map(Long value) throws InterruptedException
MapFunction
map
in interface MapFunction<Long,Long>
map
in class RichMapFunction<Long,Long>
value
- The input value.InterruptedException
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.