Package org.apache.flink.state.api

Class WritableSavepoint<F extends WritableSavepoint>

  • Type Parameters:
    F - The implementation type.
    Direct Known Subclasses:
    ExistingSavepoint, NewSavepoint
    @PublicEvolving
@Deprecated
public abstract class WritableSavepoint<F extends WritableSavepoint>
extends Object
    Deprecated.
    A WritableSavepoint is any savepoint that can be written to from a batch context. Internally, a SavepointMetadata object is maintained that keeps track of the set of existing operator states in the savepoint, as well as newly added operator states defined by their BootstrapTransformation.

    • Field Detail

      • metadata

        protected final SavepointMetadata metadata
        Deprecated.
        The savepoint metadata, which maintains the current set of existing / newly added operator states.

      • stateBackend

        @Nullable
protected final org.apache.flink.runtime.state.StateBackend stateBackend
        Deprecated.
        The state backend to use when writing this savepoint.

    • Method Detail

      • removeOperator

        public F removeOperator​(String uid)
        Deprecated.
        Drop an existing operator from the savepoint.
        Parameters:
        uid - The uid of the operator.
        Returns:
        A modified savepoint.

      • withOperator

        public <T> F withOperator​(String uid,
                          BootstrapTransformation<T> transformation)
        Deprecated.
        Adds a new operator to the savepoint.
        Parameters:
        uid - The uid of the operator.
        transformation - The operator to be included.
        Returns:
        The modified savepoint.

      • withConfiguration

        public <T> F withConfiguration​(org.apache.flink.configuration.ConfigOption<T> option,
                               T value)
        Deprecated.
        Sets a configuration that will be applied to the stream operators used to bootstrap a new savepoint.
        Type Parameters:
        T - type of the value to be stored
        Parameters:
        option - metadata information
        value - value to be stored
        Returns:
        The modified savepoint.

      • write

        public final void write​(String path)
        Deprecated.
        Write out a new or updated savepoint.
        Parameters:
        path - The path to where the savepoint should be written.