Interface SupportsPostCommitTopology<CommittableT>
-
@Experimental public interface SupportsPostCommitTopology<CommittableT>
Allows expert users to implement a custom topology afterCommitter
.It is recommended to use immutable committables because mutating committables can have unexpected side-effects.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addPostCommitTopology(DataStream<CommittableMessage<CommittableT>> committables)
Adds a custom post-commit topology where all committables can be processed.
-
-
-
Method Detail
-
addPostCommitTopology
void addPostCommitTopology(DataStream<CommittableMessage<CommittableT>> committables)
Adds a custom post-commit topology where all committables can be processed.It is strongly recommended to keep this pipeline stateless such that batch and streaming modes do not require special cases.
All operations need to be idempotent: on recovery, any number of committables may be replayed that have already been committed. It's mandatory that these committables have no effect on the external system.
- Parameters:
committables
- the stream of committables.
-
-