Interface StatefulSink.WithCompatibleState

  • Enclosing interface:
    StatefulSink<InputT,​WriterStateT>

    @PublicEvolving
    public static interface StatefulSink.WithCompatibleState
    A mix-in for StatefulSink that allows users to migrate from a sink with a compatible state to this sink.
    • Method Detail

      • getCompatibleWriterStateNames

        Collection<String> getCompatibleWriterStateNames()
        A list of state names of sinks from which the state can be restored. For example, the new FileSink can resume from the state of an old StreamingFileSink as a drop-in replacement when resuming from a checkpoint/savepoint.