@InterfaceAudience.Private public static class SplitLogManager.Task extends Object
Modifier and Type | Field and Description |
---|---|
SplitLogManager.TaskBatch |
batch |
ServerName |
cur_worker_name |
int |
incarnation |
long |
last_update |
int |
last_version |
boolean |
resubmitThresholdReached |
SplitLogManager.TerminationStatus |
status |
AtomicInteger |
unforcedResubmits |
Constructor and Description |
---|
Task() |
Modifier and Type | Method and Description |
---|---|
void |
heartbeat(long time,
int version,
ServerName worker) |
void |
heartbeatNoDetails(long time) |
boolean |
isOrphan() |
boolean |
isUnassigned() |
void |
setUnassigned() |
String |
toString() |
public volatile long last_update
public volatile int last_version
public volatile ServerName cur_worker_name
public volatile SplitLogManager.TaskBatch batch
public volatile SplitLogManager.TerminationStatus status
public volatile int incarnation
public final AtomicInteger unforcedResubmits
public volatile boolean resubmitThresholdReached
public boolean isOrphan()
public boolean isUnassigned()
public void heartbeatNoDetails(long time)
public void heartbeat(long time, int version, ServerName worker)
public void setUnassigned()