org.apache.ignite.internal.processors.hadoop.taskexecutor

Class HadoopRunnableTask

java.lang.Object

org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask

All Implemented Interfaces:

Callable<Void>

public abstract class HadoopRunnableTask
extends Object
implements Callable<Void>

Runnable task.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HadoopRunnableTask(IgniteLogger log, HadoopJobEx job, GridUnsafeMemory mem, HadoopTaskInfo info, UUID nodeId)

Method Summary

Modifier and Type	Method and Description
Void	call()
void	cancel() Cancel the executed task.
protected abstract HadoopTaskInput	createInput(HadoopTaskContext ctx)
protected abstract HadoopTaskOutput	createOutput(HadoopTaskContext ctx)
long	executionTime()
protected abstract void	onTaskFinished(HadoopTaskStatus status)
HadoopTaskInfo	taskInfo()
long	waitTime()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopRunnableTask

protected HadoopRunnableTask(IgniteLogger log,
                             HadoopJobEx job,
                             GridUnsafeMemory mem,
                             HadoopTaskInfo info,
                             UUID nodeId)

Parameters:

log - Log.

job - Job.

mem - Memory.

info - Task info.

nodeId - Node id.

Method Detail

waitTime

public long waitTime()

Returns:

Wait time.

executionTime

public long executionTime()

Returns:

Execution time.

call

public Void call()
          throws IgniteCheckedException

Specified by:

call in interface Callable<Void>

Throws:

IgniteCheckedException

cancel

public void cancel()

Cancel the executed task.

onTaskFinished

protected abstract void onTaskFinished(HadoopTaskStatus status)

Parameters:

status - Task status.

createInput

protected abstract HadoopTaskInput createInput(HadoopTaskContext ctx)
                                        throws IgniteCheckedException

Parameters:

ctx - Task context.

Returns:

Input.

Throws:

IgniteCheckedException - If failed.

createOutput

protected abstract HadoopTaskOutput createOutput(HadoopTaskContext ctx)
                                          throws IgniteCheckedException

Parameters:

ctx - Task info.

Returns:

Output.

Throws:

IgniteCheckedException - If failed.

taskInfo

public HadoopTaskInfo taskInfo()

Returns:

Task info.