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

Packages that use SinkWriter

Package	Description
org.apache.flink.api.common.functions.util
org.apache.flink.api.connector.sink2
org.apache.flink.connector.base.sink.writer
org.apache.flink.connector.file.sink.writer
org.apache.flink.connector.upserttest.sink
org.apache.flink.streaming.api.functions.sink

Uses of SinkWriter in org.apache.flink.api.common.functions.util

Classes in org.apache.flink.api.common.functions.util that implement SinkWriter

Modifier and Type	Class and Description
class	PrintSinkOutputWriter<IN> Print sink output writer for DataStream and DataSet print API.

Uses of SinkWriter in org.apache.flink.api.connector.sink2

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

Modifier and Type	Interface and Description
static interface	StatefulSink.StatefulSinkWriter<InputT,WriterStateT> A SinkWriter whose state needs to be checkpointed.
static interface	TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT> A SinkWriter that performs the first part of a two-phase commit protocol.

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

Modifier and Type	Method and Description
SinkWriter<InputT>	Sink.createWriter(Sink.InitContext context) Creates a SinkWriter.

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

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

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 SinkWriter in org.apache.flink.connector.file.sink.writer

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

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

Uses of SinkWriter in org.apache.flink.connector.upserttest.sink

Methods in org.apache.flink.connector.upserttest.sink that return SinkWriter

Modifier and Type	Method and Description
SinkWriter<IN>	UpsertTestSink.createWriter(Sink.InitContext context)

Uses of SinkWriter in org.apache.flink.streaming.api.functions.sink

Methods in org.apache.flink.streaming.api.functions.sink that return SinkWriter

Modifier and Type	Method and Description
SinkWriter<IN>	PrintSink.createWriter(Sink.InitContext context)