public class Job extends Object
Modifier and Type | Class and Description |
---|---|
static class |
Job.JobStatus |
Modifier and Type | Field and Description |
---|---|
long |
endTime |
int |
id |
int |
partitionError |
Map<org.apache.kafka.common.TopicPartition,PartitionRestoreContext> |
partitionRestoreContextMap |
long |
startTime |
Job.JobStatus |
status |
int |
version |
Constructor and Description |
---|
Job() |
Modifier and Type | Method and Description |
---|---|
void |
addPartitionRestoreContext(PartitionRestoreContext partitionRestoreContext) |
int |
getPartitionCount() |
boolean |
isDone() |
Map<PartitionRestoreContext.RestoreStatus,Integer> |
partitionRestoreStatusMap() |
public int id
public long startTime
public long endTime
public int version
public Job.JobStatus status
public int partitionError
public Map<org.apache.kafka.common.TopicPartition,PartitionRestoreContext> partitionRestoreContextMap
public void addPartitionRestoreContext(PartitionRestoreContext partitionRestoreContext)
public int getPartitionCount()
public Map<PartitionRestoreContext.RestoreStatus,Integer> partitionRestoreStatusMap()
public boolean isDone()