An input split provider can be successively queried to provide a series of
This interface must be implemented by any invokable that has recoverable state and participates in checkpointing.
Implemented by tasks that can receive STOP signal.
This is the abstract base class for every task that can be executed by a TaskManager.
Grouped settings for externalized checkpoints.
The JobCheckpointingSettings are attached to a JobGraph and describe the settings for the asynchronous checkpoints of the JobGraph, such as interval, and which vertices need to participate.
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.