public class Job extends Object
Modifier and Type | Method and Description |
---|---|
void |
addTask(AnalystClusterRequest task)
Adds a task to this Job, assigning it a task ID number.
|
boolean |
containsTask(int taskId) |
int |
getCompletedTaskCount() |
int |
getTotalTaskCount() |
boolean |
isComplete() |
void |
markTaskCompleted(int taskId) |
void |
markTasksDelivered(List<AnalystClusterRequest> tasks) |
int |
redeliver()
Find all tasks that are currently invisible but have passed their invisibility timeout without being marked
completed, and make all these tasks visible again for delivery.
|
public final String jobId
public Job(String jobId)
public void addTask(AnalystClusterRequest task)
public void markTasksDelivered(List<AnalystClusterRequest> tasks)
public int redeliver()
public void markTaskCompleted(int taskId)
public int getTotalTaskCount()
public int getCompletedTaskCount()
public boolean isComplete()
public boolean containsTask(int taskId)
Copyright © 2019. All rights reserved.