org.apache.flink.api.connector.sink2

Interface StatefulSink.WithCompatibleState

All Superinterfaces:

SupportsWriterState.WithCompatibleState

Enclosing interface:

StatefulSink<InputT,WriterStateT>

@PublicEvolving
public static interface StatefulSink.WithCompatibleState
extends SupportsWriterState.WithCompatibleState

A mix-in for StatefulSink that allows users to migrate from a sink with a compatible state to this sink.

Method Summary

Methods inherited from interface org.apache.flink.api.connector.sink2.SupportsWriterState.WithCompatibleState

getCompatibleWriterStateNames