Package org.apache.flink.api.connector.sink

Interface Summary

Interface	Description
Committer<CommT>	The Committer is responsible for committing the data staged by the sink.
GlobalCommitter<CommT,GlobalCommT>	The GlobalCommitter is responsible for creating and committing an aggregated committable, which we call global committable (see GlobalCommitter.combine(java.util.List<CommT>)).
Sink<InputT,CommT,WriterStateT,GlobalCommT>	This interface lets the sink developer build a simple sink topology, which could guarantee the exactly once semantics in both batch and stream execution mode if there is a Committer or GlobalCommitter.
Sink.InitContext	The interface exposes some runtime info for creating a SinkWriter.
Sink.ProcessingTimeService	A service that allows to get the current processing time and register timers that will execute the given Sink.ProcessingTimeService.ProcessingTimeCallback when firing.
Sink.ProcessingTimeService.ProcessingTimeCallback	A callback that can be registered via Sink.ProcessingTimeService.registerProcessingTimer(long, ProcessingTimeCallback).
SinkWriter<InputT,CommT,WriterStateT>	The SinkWriter is responsible for writing data and handling any potential tmp area used to write yet un-staged data, e.g.
SinkWriter.Context	Context that SinkWriter.write(InputT, org.apache.flink.api.connector.sink.SinkWriter.Context) can use for getting additional data about an input record.