[
https://issues.apache.org/jira/browse/SAMZA-2731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lakshmi Manasa Gaduputi updated SAMZA-2731:
-------------------------------------------
Description:
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.
Provide implementation for KafkaCheckpointManager
was:
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.
> 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.
> Provide implementation for KafkaCheckpointManager
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
