Class ComputeTaskStatus
- java.lang.Object
-
- org.apache.ignite.internal.processors.task.monitor.ComputeTaskStatus
-
- All Implemented Interfaces:
ComputeTaskStatusSnapshot
public class ComputeTaskStatus extends Object implements ComputeTaskStatusSnapshot
Task status container.- See Also:
ComputeTaskStatusSnapshot
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Map<?,?>attributes()@Nullable ObjectcreateBy()longendTime()@Nullable ThrowablefailReason()booleanfullSupport()booleaninternal()List<UUID>jobNodes()static ComputeTaskStatusonFinishTask(GridTaskSessionImpl sessionImp, @Nullable Throwable err)Creates a task status on finishing task.UUIDoriginatingNodeId()IgniteUuidsessionId()static ComputeTaskStatussnapshot(GridTaskSessionImpl sessionImp)Creates the status of a task that is in progress.longstartTime()ComputeTaskStatusEnumstatus()StringtaskName()
-
-
-
Method Detail
-
sessionId
public IgniteUuid sessionId()
- Specified by:
sessionIdin interfaceComputeTaskStatusSnapshot- Returns:
- Session ID of the task being executed.
-
taskName
public String taskName()
- Specified by:
taskNamein interfaceComputeTaskStatusSnapshot- Returns:
- Task name of the task this session belongs to.
-
originatingNodeId
public UUID originatingNodeId()
- Specified by:
originatingNodeIdin interfaceComputeTaskStatusSnapshot- Returns:
- ID of the node on which task execution originated.
-
startTime
public long startTime()
- Specified by:
startTimein interfaceComputeTaskStatusSnapshot- Returns:
- Start of computation time for the task.
-
endTime
public long endTime()
- Specified by:
endTimein interfaceComputeTaskStatusSnapshot- Returns:
- End of computation time for the task.
-
jobNodes
public List<UUID> jobNodes()
- Specified by:
jobNodesin interfaceComputeTaskStatusSnapshot- Returns:
- Nodes IDs on which the task jobs will execute.
-
attributes
public Map<?,?> attributes()
- Specified by:
attributesin interfaceComputeTaskStatusSnapshot- Returns:
- All session attributes.
-
status
public ComputeTaskStatusEnum status()
- Specified by:
statusin interfaceComputeTaskStatusSnapshot- Returns:
- Status of the task.
-
failReason
@Nullable public @Nullable Throwable failReason()
- Specified by:
failReasonin interfaceComputeTaskStatusSnapshot- Returns:
- Reason for the failure of the task.
-
fullSupport
public boolean fullSupport()
- Specified by:
fullSupportin interfaceComputeTaskStatusSnapshot- Returns:
trueif change of task attributes is available.
-
createBy
@Nullable public @Nullable Object createBy()
- Specified by:
createByin interfaceComputeTaskStatusSnapshot- Returns:
- User who created the task,
nullif security is not available.
-
internal
public boolean internal()
- Specified by:
internalin interfaceComputeTaskStatusSnapshot- Returns:
Trueif task is internal.
-
snapshot
public static ComputeTaskStatus snapshot(GridTaskSessionImpl sessionImp)
Creates the status of a task that is in progress.- Parameters:
sessionImp- Task session.- Returns:
- New instance.
-
onFinishTask
public static ComputeTaskStatus onFinishTask(GridTaskSessionImpl sessionImp, @Nullable @Nullable Throwable err)
Creates a task status on finishing task.- Parameters:
sessionImp- Task session.err- – Reason for the failure of the task, null if the task completed successfully.- Returns:
- New instance.
-
-