@Experimental public interface SupportsPostCommitTopology<CommittableT>
Committer
.
It is recommended to use immutable committables because mutating committables can have unexpected side-effects.
Modifier and Type | Method and Description |
---|---|
void |
addPostCommitTopology(DataStream<CommittableMessage<CommittableT>> committables)
Adds a custom post-commit topology where all committables can be processed.
|
void addPostCommitTopology(DataStream<CommittableMessage<CommittableT>> committables)
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.
committables
- the stream of committables.Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.