public class Task extends Object implements org.apache.thrift.TBase<Task,Task._Fields>, Serializable, Cloneable
Modifier and Type | Class and Description |
---|---|
static class |
Task._Fields
The set of fields this struct contains, along with convenience methods for finding and manipulating them.
|
Modifier and Type | Field and Description |
---|---|
static Map<Task._Fields,org.apache.thrift.meta_data.FieldMetaData> |
metaDataMap |
Constructor and Description |
---|
Task() |
Task(String taskId,
TaskType taskType,
Map<String,String> taskAttributes,
Map<String,Long> taskCounters,
boolean done,
boolean started) |
Task(Task other)
Performs a deep copy on other.
|
Modifier and Type | Method and Description |
---|---|
void |
addToOperatorList(Operator elem) |
void |
clear() |
int |
compareTo(Task other) |
Task |
deepCopy() |
boolean |
equals(Object that) |
boolean |
equals(Task that) |
Task._Fields |
fieldForId(int fieldId) |
Object |
getFieldValue(Task._Fields field) |
Graph |
getOperatorGraph() |
List<Operator> |
getOperatorList() |
Iterator<Operator> |
getOperatorListIterator() |
int |
getOperatorListSize() |
Map<String,String> |
getTaskAttributes() |
int |
getTaskAttributesSize() |
Map<String,Long> |
getTaskCounters() |
int |
getTaskCountersSize() |
String |
getTaskId() |
TaskType |
getTaskType() |
int |
hashCode() |
boolean |
isDone() |
boolean |
isSet(Task._Fields field)
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
|
boolean |
isSetDone()
Returns true if field done is set (has been assigned a value) and false otherwise
|
boolean |
isSetOperatorGraph()
Returns true if field operatorGraph is set (has been assigned a value) and false otherwise
|
boolean |
isSetOperatorList()
Returns true if field operatorList is set (has been assigned a value) and false otherwise
|
boolean |
isSetStarted()
Returns true if field started is set (has been assigned a value) and false otherwise
|
boolean |
isSetTaskAttributes()
Returns true if field taskAttributes is set (has been assigned a value) and false otherwise
|
boolean |
isSetTaskCounters()
Returns true if field taskCounters is set (has been assigned a value) and false otherwise
|
boolean |
isSetTaskId()
Returns true if field taskId is set (has been assigned a value) and false otherwise
|
boolean |
isSetTaskType()
Returns true if field taskType is set (has been assigned a value) and false otherwise
|
boolean |
isStarted() |
void |
putToTaskAttributes(String key,
String val) |
void |
putToTaskCounters(String key,
long val) |
void |
read(org.apache.thrift.protocol.TProtocol iprot) |
void |
setDone(boolean done) |
void |
setDoneIsSet(boolean value) |
void |
setFieldValue(Task._Fields field,
Object value) |
void |
setOperatorGraph(Graph operatorGraph) |
void |
setOperatorGraphIsSet(boolean value) |
void |
setOperatorList(List<Operator> operatorList) |
void |
setOperatorListIsSet(boolean value) |
void |
setStarted(boolean started) |
void |
setStartedIsSet(boolean value) |
void |
setTaskAttributes(Map<String,String> taskAttributes) |
void |
setTaskAttributesIsSet(boolean value) |
void |
setTaskCounters(Map<String,Long> taskCounters) |
void |
setTaskCountersIsSet(boolean value) |
void |
setTaskId(String taskId) |
void |
setTaskIdIsSet(boolean value) |
void |
setTaskType(TaskType taskType) |
void |
setTaskTypeIsSet(boolean value) |
String |
toString() |
void |
unsetDone() |
void |
unsetOperatorGraph() |
void |
unsetOperatorList() |
void |
unsetStarted() |
void |
unsetTaskAttributes() |
void |
unsetTaskCounters() |
void |
unsetTaskId() |
void |
unsetTaskType() |
void |
validate() |
void |
write(org.apache.thrift.protocol.TProtocol oprot) |
public static final Map<Task._Fields,org.apache.thrift.meta_data.FieldMetaData> metaDataMap
public Task()
public Task(String taskId, TaskType taskType, Map<String,String> taskAttributes, Map<String,Long> taskCounters, boolean done, boolean started)
public Task(Task other)
public Task deepCopy()
deepCopy
in interface org.apache.thrift.TBase<Task,Task._Fields>
public void clear()
clear
in interface org.apache.thrift.TBase<Task,Task._Fields>
public String getTaskId()
public void setTaskId(String taskId)
public void unsetTaskId()
public boolean isSetTaskId()
public void setTaskIdIsSet(boolean value)
public void unsetTaskType()
public boolean isSetTaskType()
public void setTaskTypeIsSet(boolean value)
public int getTaskAttributesSize()
public void unsetTaskAttributes()
public boolean isSetTaskAttributes()
public void setTaskAttributesIsSet(boolean value)
public int getTaskCountersSize()
public void putToTaskCounters(String key, long val)
public void unsetTaskCounters()
public boolean isSetTaskCounters()
public void setTaskCountersIsSet(boolean value)
public Graph getOperatorGraph()
public void setOperatorGraph(Graph operatorGraph)
public void unsetOperatorGraph()
public boolean isSetOperatorGraph()
public void setOperatorGraphIsSet(boolean value)
public int getOperatorListSize()
public void addToOperatorList(Operator elem)
public void unsetOperatorList()
public boolean isSetOperatorList()
public void setOperatorListIsSet(boolean value)
public boolean isDone()
public void setDone(boolean done)
public void unsetDone()
public boolean isSetDone()
public void setDoneIsSet(boolean value)
public boolean isStarted()
public void setStarted(boolean started)
public void unsetStarted()
public boolean isSetStarted()
public void setStartedIsSet(boolean value)
public void setFieldValue(Task._Fields field, Object value)
setFieldValue
in interface org.apache.thrift.TBase<Task,Task._Fields>
public Object getFieldValue(Task._Fields field)
getFieldValue
in interface org.apache.thrift.TBase<Task,Task._Fields>
public boolean isSet(Task._Fields field)
isSet
in interface org.apache.thrift.TBase<Task,Task._Fields>
public boolean equals(Task that)
public int compareTo(Task other)
compareTo
in interface Comparable<Task>
public Task._Fields fieldForId(int fieldId)
fieldForId
in interface org.apache.thrift.TBase<Task,Task._Fields>
public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException
read
in interface org.apache.thrift.TBase<Task,Task._Fields>
org.apache.thrift.TException
public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException
write
in interface org.apache.thrift.TBase<Task,Task._Fields>
org.apache.thrift.TException
public void validate() throws org.apache.thrift.TException
org.apache.thrift.TException
Copyright © 2017 The Apache Software Foundation. All rights reserved.