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

Class HadoopV1Task

java.lang.Object

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

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

Direct Known Subclasses:

HadoopV1CleanupTask, HadoopV1MapTask, HadoopV1ReduceTask, HadoopV1SetupTask

public abstract class HadoopV1Task
extends HadoopTask

Extended Hadoop v1 task.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HadoopV1Task(HadoopTaskInfo taskInfo) Constructor.

Method Summary

Modifier and Type	Method and Description
void	cancel()
protected HadoopV1OutputCollector	collector(JobConf jobConf, HadoopV2TaskContext taskCtx, boolean directWrite, String fileName, TaskAttemptID attempt)
String	fileName() Gets file name for that task result.
boolean	isCancelled() Returns true if task is cancelled.

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

info, run

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopV1Task

protected HadoopV1Task(HadoopTaskInfo taskInfo)

Constructor.

Parameters:

taskInfo - Task info.

Method Detail

fileName

public String fileName()

Gets file name for that task result.

Returns:

File name.

collector

protected HadoopV1OutputCollector collector(JobConf jobConf,
                                            HadoopV2TaskContext taskCtx,
                                            boolean directWrite,
                                            @Nullable
                                            String fileName,
                                            TaskAttemptID attempt)
                                     throws IOException

Parameters:

jobConf - Job configuration.

taskCtx - Task context.

directWrite - Direct write flag.

fileName - File name.

attempt - Attempt of task.

Returns:

Collector.

Throws:

IOException - In case of IO exception.

cancel

public void cancel()

Specified by:

cancel in class HadoopTask

isCancelled

public boolean isCancelled()

Returns true if task is cancelled.