Interface StatefulSink.WithCompatibleState
-
- Enclosing interface:
- StatefulSink<InputT,WriterStateT>
@PublicEvolving public static interface StatefulSink.WithCompatibleStateA mix-in forStatefulSinkthat allows users to migrate from a sink with a compatible state to this sink.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method 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 newFileSinkcan resume from the state of an oldStreamingFileSinkas a drop-in replacement when resuming from a checkpoint/savepoint.
-
-