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

Class HadoopProtocolJobCountersTask

java.lang.Object

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

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

All Implemented Interfaces:

Serializable, ComputeTask<HadoopProtocolTaskArguments,HadoopCounters>

public class HadoopProtocolJobCountersTask
extends HadoopProtocolTaskAdapter<HadoopCounters>

Task to get job counters.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
HadoopProtocolJobCountersTask()

Method Summary

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

HadoopProtocolJobCountersTask

public HadoopProtocolJobCountersTask()

Method Detail

run

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

Run the task.

Specified by:

run in class HadoopProtocolTaskAdapter<HadoopCounters>

Parameters:

jobCtx - Job context.

hadoop - Hadoop facade.

args - Arguments.

Returns:

Job result.

Throws:

IgniteCheckedException - If failed.