Package | Description |
---|---|
org.apache.flink.streaming.runtime.operators.sink.committables |
Class and Description |
---|
CheckpointCommittableManager
This interface adds checkpoint meta information to the committable.
|
CommitRequestState
Internal state of a committable.
|
CommittableCollector
This class is responsible to book-keep the committing progress across checkpoints and subtasks.
|
CommittableManager
Internal wrapper to handle the committing of committables.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.