Interface | Description |
---|---|
CheckpointCommittableManager<CommT> |
This interface adds checkpoint meta information to the committable.
|
CommittableManager<CommT> |
Internal wrapper to handle the committing of committables.
|
Class | Description |
---|---|
CommitRequestImpl<CommT> |
Internal implementation to commit a specific committable and handle the response.
|
CommittableCollector<CommT> |
This class is responsible to book-keep the committing progress across checkpoints and subtasks.
|
CommittableCollectorSerializer<CommT> |
The serializer for the
CommittableCollector . |
SinkV1CommittableDeserializer |
This class offers the possibility to deserialize committables that have been written with older
Flink releases (i.e.
|
Enum | Description |
---|---|
CommitRequestState |
Internal state of a committable.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.