Uses of Interface
org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter
-
Packages that use StatefulSink.StatefulSinkWriter Package Description org.apache.flink.api.connector.sink2 -
-
Uses of StatefulSink.StatefulSinkWriter in org.apache.flink.api.connector.sink2
Methods in org.apache.flink.api.connector.sink2 that return StatefulSink.StatefulSinkWriter Modifier and Type Method Description StatefulSink.StatefulSinkWriter<InputT,WriterStateT>StatefulSink. createWriter(Sink.InitContext context)Create aStatefulSink.StatefulSinkWriter.StatefulSink.StatefulSinkWriter<InputT,WriterStateT>StatefulSink. restoreWriter(Sink.InitContext context, Collection<WriterStateT> recoveredState)Create aStatefulSink.StatefulSinkWriterfrom a recovered state.
-