[jira] [Updated] (SAMZA-2731) Add readAllCheckpoints to CheckpointManager and implement for KafkaCheckpointManager

["Lakshmi Manasa Gaduputi (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/SAMZA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Lakshmi Manasa Gaduputi updated SAMZA-2731:
-------------------------------------------
    Summary: Add readAllCheckpoints to CheckpointManager and implement for KafkaCheckpointManager  (was: Add readAllCheckpoints to CheckpointManager)

> Add readAllCheckpoints to CheckpointManager and implement for KafkaCheckpointManager
> ------------------------------------------------------------------------------------
>
>                 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
>            Priority: Major
>
> 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)