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

Packages that use org.apache.flink.api.connector.sink

Package	Description
org.apache.flink.api.connector.sink
org.apache.flink.connector.file.sink
org.apache.flink.connector.file.sink.committer
org.apache.flink.connector.file.sink.writer
org.apache.flink.streaming.api.datastream
org.apache.flink.streaming.api.transformations
org.apache.flink.streaming.runtime.operators.sink

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.api.connector.sink

Class and Description
Committer The Committer is responsible for committing the data staged by the sink.
GlobalCommitter The GlobalCommitter is responsible for creating and committing an aggregated committable, which we call global committable (see GlobalCommitter.combine(java.util.List<CommT>)).
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 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.

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.connector.file.sink

Class and Description
Committer The Committer is responsible for committing the data staged by the sink.
GlobalCommitter The GlobalCommitter is responsible for creating and committing an aggregated committable, which we call global committable (see GlobalCommitter.combine(java.util.List<CommT>)).
Sink 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.
SinkWriter The SinkWriter is responsible for writing data and handling any potential tmp area used to write yet un-staged data, e.g.

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.connector.file.sink.committer

Class and Description
Committer The Committer is responsible for committing the data staged by the sink.

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.connector.file.sink.writer

Class and Description
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 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.

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.streaming.api.datastream

Class and Description
Sink 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.

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.streaming.api.transformations

Class and Description
Sink 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.

Classes in org.apache.flink.api.connector.sink used by org.apache.flink.streaming.runtime.operators.sink

Class and Description
Sink 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.