Uses of Interface
org.apache.flink.api.connector.sink2.StatefulSink.StatefulSinkWriter

Packages that use StatefulSink.StatefulSinkWriter

Package	Description
org.apache.flink.api.connector.sink2
org.apache.flink.connector.base.sink.writer
org.apache.flink.connector.file.sink.writer

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 and Description
StatefulSink.StatefulSinkWriter<InputT,WriterStateT>	StatefulSink.createWriter(Sink.InitContext context) Create a StatefulSink.StatefulSinkWriter.
StatefulSink.StatefulSinkWriter<InputT,WriterStateT>	StatefulSink.restoreWriter(Sink.InitContext context, Collection<WriterStateT> recoveredState) Create a StatefulSink.StatefulSinkWriter from a recovered state.

Uses of StatefulSink.StatefulSinkWriter in org.apache.flink.connector.base.sink.writer

Classes in org.apache.flink.connector.base.sink.writer that implement StatefulSink.StatefulSinkWriter

Modifier and Type	Class and Description
class	AsyncSinkWriter<InputT,RequestEntryT extends Serializable> A generic sink writer that handles the general behaviour of a sink such as batching and flushing, and allows extenders to implement the logic for persisting individual request elements, with allowance for retries.

Uses of StatefulSink.StatefulSinkWriter in org.apache.flink.connector.file.sink.writer

Classes in org.apache.flink.connector.file.sink.writer that implement StatefulSink.StatefulSinkWriter

Modifier and Type	Class and Description
class	FileWriter<IN> A SinkWriter implementation for FileSink.