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

Class HadoopV2MapTask

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.HadoopV2MapTask

public class HadoopV2MapTask
extends HadoopV2Task

Hadoop map task implementation for v2 API.

Constructor Summary

Constructors

Constructor and Description
HadoopV2MapTask(HadoopTaskInfo taskInfo)

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

HadoopV2MapTask

public HadoopV2MapTask(HadoopTaskInfo taskInfo)

Parameters:

taskInfo - Task info.

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