Package org.apache.flink.state.api
Interface SavepointWriterOperatorFactory
-
- Functional Interface:
- This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@PublicEvolving @FunctionalInterface public interface SavepointWriterOperatorFactory
Creates a savepoint writing operator from a savepoint path.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.flink.streaming.api.operators.StreamOperator<TaggedOperatorSubtaskState>createOperator(long savepointTimestamp, org.apache.flink.core.fs.Path savepointPath)Creates aStreamOperatorto be used for generating and snapshotting state.
-
-
-
Method Detail
-
createOperator
org.apache.flink.streaming.api.operators.StreamOperator<TaggedOperatorSubtaskState> createOperator(long savepointTimestamp, org.apache.flink.core.fs.Path savepointPath)
Creates aStreamOperatorto be used for generating and snapshotting state.- Parameters:
savepointTimestamp- the timestamp to associate with the generated savepoint.savepointPath- the path to write the savepoint to.- Returns:
- a stream operator for writing the savepoint.
-
-