org.apache.flink.api.connector.sink2

Interface StatefulSink.WithCompatibleState

All Known Implementing Classes:

FileSink

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 Summary

Modifier and Type	Method and Description
Collection<String>	getCompatibleWriterStateNames() A list of state names of sinks from which the state can be restored.

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.