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 Detail

      • createOperator

        org.apache.flink.streaming.api.operators.StreamOperator<TaggedOperatorSubtaskState> createOperator​(long savepointTimestamp,
                                                                                                           org.apache.flink.core.fs.Path savepointPath)
        Creates a StreamOperator to 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.