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. |
Class | Description |
---|---|
InitContextInitializationContextAdapter |
Adapter between
Sink.InitContext and SerializationSchema.InitializationContext . |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.