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