Lakshmi Manasa Gaduputi created SAMZA-2731:
----------------------------------------------
Summary: Add readAllCheckpoints to CheckpointManager
Key: SAMZA-2731
URL: https://issues.apache.org/jira/browse/SAMZA-2731
Project: Samza
Issue Type: Improvement
Reporter: Lakshmi Manasa Gaduputi
Assignee: Lakshmi Manasa Gaduputi
currently, CheckpointManager exposes functionality to read checkpoints as
{code:java}
readCheckpoint(TaskName taskName){code}
which returns the last recorded checkpoint for the given task name.
This ticket is to introduce an additional functionality to read all checkpoints
present for the job as follows.
{code:java}
Map<TaskName, Checkpoint> readAllCheckpoints(){code}
Returns the last recorded checkpoint for all tasks present in the
implementation-specific location.
* All tasks contains all the tasks within the current job model.
* All tasks also includes tasks which may have been part of the job model
during a previous deploy.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
