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

Class HadoopProtocolNextTaskIdTask

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, ComputeTask<HadoopProtocolTaskArguments,HadoopJobId>

public class HadoopProtocolNextTaskIdTask
extends HadoopProtocolTaskAdapter<HadoopJobId>

Task to get the next job ID.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopProtocolNextTaskIdTask()

Method Summary

Modifier and Type	Method and Description
HadoopJobId	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

HadoopProtocolNextTaskIdTask

public HadoopProtocolNextTaskIdTask()

Method Detail

run

public HadoopJobId run(ComputeJobContext jobCtx,
                       Hadoop hadoop,
                       HadoopProtocolTaskArguments args)

Run the task.

Specified by:

run in class HadoopProtocolTaskAdapter<HadoopJobId>

Parameters:

jobCtx - Job context.

hadoop - Hadoop facade.

args - Arguments.

Returns:

Job result.