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

Packages that use 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 StatefulSinkWriter in org.apache.flink.api.connector.sink2

Subinterfaces of StatefulSinkWriter in org.apache.flink.api.connector.sink2

Modifier and Type	Interface and Description
static interface	StatefulSink.StatefulSinkWriter<InputT,WriterStateT> Deprecated. A SinkWriter whose state needs to be checkpointed.

Methods in org.apache.flink.api.connector.sink2 that return StatefulSinkWriter

Modifier and Type	Method and Description
StatefulSinkWriter<InputT,WriterStateT>	SupportsWriterState.restoreWriter(WriterInitContext context, Collection<WriterStateT> recoveredState) Create a StatefulSinkWriter from a recovered state.

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

Classes in org.apache.flink.connector.base.sink.writer that implement 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 StatefulSinkWriter in org.apache.flink.connector.file.sink.writer

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

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