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

Class HadoopV2ReduceTask

java.lang.Object

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

org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task

org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2ReduceTask

public class HadoopV2ReduceTask
extends HadoopV2Task

Hadoop reduce task implementation for v2 API.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	run0(HadoopV2TaskContext taskCtx) Internal task routine.

Methods inherited from class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task

abort, cancel, closeWriter, commit, getOutputFormat, hadoopContext, prepareWriter, run, setup

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

HadoopV2ReduceTask

public HadoopV2ReduceTask(HadoopTaskInfo taskInfo,
                          boolean reduce)

Constructor.

Parameters:

taskInfo - Task info.

reduce - True if reduce, false if combine.

Method Detail

run0

public void run0(HadoopV2TaskContext taskCtx)
          throws IgniteCheckedException

Internal task routine.

Specified by:

run0 in class HadoopV2Task

Parameters:

taskCtx - Task context.

Throws:

IgniteCheckedException