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
org.apache.flink.connector.file.sink.writer
org.apache.flink.connector.upserttest.sink
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.sink.v2
org.apache.flink.streaming.api.transformations

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
interface	CommittingSinkWriter<InputT,CommittableT> A SinkWriter that performs the first part of a two-phase commit protocol.
static interface	StatefulSink.StatefulSinkWriter<InputT,WriterStateT> Deprecated. A SinkWriter whose state needs to be checkpointed.
interface	StatefulSinkWriter<InputT,WriterStateT> A SinkWriter whose state needs to be checkpointed.
static interface	TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT> Deprecated.

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

Modifier and Type	Method and Description
SinkWriter<InputT>	Sink.createWriter(Sink.InitContext context) Deprecated. Please implement Sink.createWriter(WriterInitContext). For backward compatibility reasons - to keep Sink a functional interface - Flink did not provide a default implementation. New Sink implementations should implement this method, but it will not be used, and it will be removed in 1.20.0 release. Do not use Override annotation when implementing this method, to prevent compilation errors when migrating to 1.20.x release.
default SinkWriter<InputT>	Sink.createWriter(WriterInitContext 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

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

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

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)

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

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

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

Uses of SinkWriter in org.apache.flink.streaming.api.transformations

Methods in org.apache.flink.streaming.api.transformations that return SinkWriter

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