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

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	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	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	Description
SinkWriter<InputT>	Sink.createWriter(Sink.InitContext context)	Deprecated. Please implement Sink.createWriter(WriterInitContext).
default SinkWriter<InputT>	Sink.createWriter(WriterInitContext context)	Creates a SinkWriter.