org.apache.ignite.internal.processors.hadoop.proto

Class HadoopProtocolJobStatusTask

java.lang.Object

org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter<HadoopJobStatus>

org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolJobStatusTask

All Implemented Interfaces:

Serializable, ComputeTask<HadoopProtocolTaskArguments,HadoopJobStatus>

public class HadoopProtocolJobStatusTask
extends HadoopProtocolTaskAdapter<HadoopJobStatus>

Job status task.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopProtocolJobStatusTask()

Method Summary

Modifier and Type	Method and Description
HadoopJobStatus	run(ComputeJobContext jobCtx, Hadoop hadoop, HadoopProtocolTaskArguments args) Run the task.

Methods inherited from class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter

map, reduce, result

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopProtocolJobStatusTask

public HadoopProtocolJobStatusTask()

Method Detail

run

public HadoopJobStatus run(ComputeJobContext jobCtx,
                           Hadoop hadoop,
                           HadoopProtocolTaskArguments args)
                    throws IgniteCheckedException

Run the task.

Specified by:

run in class HadoopProtocolTaskAdapter<HadoopJobStatus>

Parameters:

jobCtx - Job context.

hadoop - Hadoop facade.

args - Arguments.

Returns:

Job result.

Throws:

IgniteCheckedException - If failed.