org.apache.ignite.internal.processors.hadoop.impl.v1

Class HadoopV1ReduceTask

java.lang.Object

org.apache.ignite.internal.processors.hadoop.HadoopTask

org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task

org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1ReduceTask

public class HadoopV1ReduceTask
extends HadoopV1Task

Hadoop reduce task implementation for v1 API.

Constructor Summary

Constructors

Constructor and Description
HadoopV1ReduceTask(HadoopTaskInfo taskInfo, boolean reduce) Constructor.

Method Summary

Modifier and Type	Method and Description
void	run(HadoopTaskContext taskCtx)

Methods inherited from class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task

cancel, collector, fileName, isCancelled

Methods inherited from class org.apache.ignite.internal.processors.hadoop.HadoopTask

info

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopV1ReduceTask

public HadoopV1ReduceTask(HadoopTaskInfo taskInfo,
                          boolean reduce)

Constructor.

Parameters:

taskInfo - Task info.

reduce - True if reduce, false if combine.

Method Detail

run

public void run(HadoopTaskContext taskCtx)
         throws IgniteCheckedException

Specified by:

run in class HadoopTask

Throws:

IgniteCheckedException