This interface adds checkpoint meta information to the committable.
Internal wrapper to handle the committing of committables.
Internal implementation to commit a specific committable and handle the response.
This class is responsible to book-keep the committing progress across checkpoints and subtasks.
The serializer for the
This class offers the possibility to deserialize committables that have been written with older Flink releases (i.e.
Internal state of a committable.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.