| Committer |
The Committer is responsible for committing the data staged by the CommittingSinkWriter in the second step of a two-phase commit protocol.
|
| Committer.CommitRequest |
A request to commit a specific committable.
|
| CommitterInitContext |
The interface exposes some runtime info for creating a Committer.
|
| CommittingSinkWriter |
A SinkWriter that performs the first part of a two-phase commit protocol.
|
| InitContext |
|
| Sink |
Base interface for developing a sink.
|
| Sink.InitContext |
Deprecated.
|
| SinkWriter |
The SinkWriter is responsible for writing data.
|
| SinkWriter.Context |
|
| StatefulSink.StatefulSinkWriter |
Deprecated.
A SinkWriter whose state needs to be checkpointed.
|
| StatefulSinkWriter |
A SinkWriter whose state needs to be checkpointed.
|
| SupportsCommitter |
A mixin interface for a Sink which supports exactly-once semantics using a two-phase
commit protocol.
|
| SupportsWriterState |
|
| SupportsWriterState.WithCompatibleState |
A mix-in for SupportsWriterState that allows users to migrate from a sink with a
compatible state to this sink.
|
| WriterInitContext |
The interface exposes some runtime info for creating a SinkWriter.
|