Uses of Interface
org.apache.flink.api.connector.sink2.Sink.InitContext

Packages that use Sink.InitContext

Package	Description
org.apache.flink.api.connector.sink2

Uses of Sink.InitContext in org.apache.flink.api.connector.sink2

Methods in org.apache.flink.api.connector.sink2 with parameters of type Sink.InitContext

Modifier and Type	Method	Description
SinkWriter<InputT>	Sink.createWriter(Sink.InitContext context)	Creates a SinkWriter.
StatefulSink.StatefulSinkWriter<InputT,WriterStateT>	StatefulSink.createWriter(Sink.InitContext context)	Create a StatefulSink.StatefulSinkWriter.
TwoPhaseCommittingSink.PrecommittingSinkWriter<InputT,CommT>	TwoPhaseCommittingSink.createWriter(Sink.InitContext context)	Creates a TwoPhaseCommittingSink.PrecommittingSinkWriter that creates committables on checkpoint or end of input.
StatefulSink.StatefulSinkWriter<InputT,WriterStateT>	StatefulSink.restoreWriter(Sink.InitContext context, Collection<WriterStateT> recoveredState)	Create a StatefulSink.StatefulSinkWriter from a recovered state.