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

Class HadoopV2CleanupTask

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

public class HadoopV2CleanupTask
extends HadoopV2Task

Hadoop cleanup task (commits or aborts job).

Constructor Summary

Constructors

Constructor and Description
HadoopV2CleanupTask(HadoopTaskInfo taskInfo, boolean abort)

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

HadoopV2CleanupTask

public HadoopV2CleanupTask(HadoopTaskInfo taskInfo,
                           boolean abort)

Parameters:

taskInfo - Task info.

abort - Abort flag.

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