Package org.apache.flink.state.api.output

Class StatePathExtractor

java.lang.Object

org.apache.flink.state.api.output.StatePathExtractor

All Implemented Interfaces:

Serializable, FlatMapFunction<OperatorState,Path>, Function

@Internal
public class StatePathExtractor
extends Object
implements FlatMapFunction<OperatorState,Path>

Extracts all file paths that are part of the provided OperatorState.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
StatePathExtractor()

Method Summary

Modifier and Type	Method	Description
void	flatMap(OperatorState operatorState, Collector<Path> out)	The core method of the FlatMapFunction.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StatePathExtractor

public StatePathExtractor()

Method Detail

flatMap

public void flatMap(OperatorState operatorState,
                    Collector<Path> out)
             throws Exception

Description copied from interface: FlatMapFunction

The core method of the FlatMapFunction. Takes an element from the input data set and transforms it into zero, one, or more elements.

Specified by:

flatMap in interface FlatMapFunction<OperatorState,Path>

Parameters:

operatorState - The input value.

out - The collector for returning result values.

Throws:

Exception - This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.