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

Class HadoopV2Task

java.lang.Object

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

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

Direct Known Subclasses:

HadoopV2CleanupTask, HadoopV2MapTask, HadoopV2ReduceTask, HadoopV2SetupTask

public abstract class HadoopV2Task
extends HadoopTask

Extended Hadoop v2 task.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected void	abort(OutputFormat outputFormat) Abort task.
void	cancel()
protected void	closeWriter() Closes writer.
protected void	commit(OutputFormat outputFormat) Commit task.
protected OutputFormat	getOutputFormat(JobContext jobCtx) Create and configure an OutputFormat instance.
protected HadoopV2Context	hadoopContext()
protected OutputFormat	prepareWriter(JobContext jobCtx) Put write into Hadoop context and return associated output format instance.
void	run(HadoopTaskContext taskCtx)
protected abstract void	run0(HadoopV2TaskContext taskCtx) Internal task routine.
protected void	setup(OutputFormat outputFormat) Setup task.

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

HadoopV2Task

protected HadoopV2Task(HadoopTaskInfo taskInfo)

Constructor.

Parameters:

taskInfo - Task info.

Method Detail

run

public void run(HadoopTaskContext taskCtx)
         throws IgniteCheckedException

Specified by:

run in class HadoopTask

Throws:

IgniteCheckedException

run0

protected abstract void run0(HadoopV2TaskContext taskCtx)
                      throws IgniteCheckedException

Internal task routine.

Parameters:

taskCtx - Task context.

Throws:

IgniteCheckedException

hadoopContext

protected HadoopV2Context hadoopContext()

Returns:

hadoop context.

getOutputFormat

protected OutputFormat getOutputFormat(JobContext jobCtx)
                                throws ClassNotFoundException

Create and configure an OutputFormat instance.

Parameters:

jobCtx - Job context.

Returns:

Instance of OutputFormat is specified in job configuration.

Throws:

ClassNotFoundException - If specified class not found.

prepareWriter

protected OutputFormat prepareWriter(JobContext jobCtx)
                              throws IgniteCheckedException,
                                     InterruptedException

Put write into Hadoop context and return associated output format instance.

Parameters:

jobCtx - Job context.

Returns:

Output format.

Throws:

IgniteCheckedException - In case of Grid exception.

InterruptedException - In case of interrupt.

closeWriter

protected void closeWriter()
                    throws Exception

Closes writer.

Throws:

Exception - If fails and logger hasn't been specified.

setup

protected void setup(@Nullable
                     OutputFormat outputFormat)
              throws IOException,
                     InterruptedException

Setup task.

Parameters:

outputFormat - Output format.

Throws:

IOException - In case of IO exception.

InterruptedException - In case of interrupt.

commit

protected void commit(@Nullable
                      OutputFormat outputFormat)
               throws IgniteCheckedException,
                      IOException,
                      InterruptedException

Commit task.

Parameters:

outputFormat - Output format.

Throws:

IgniteCheckedException - In case of Grid exception.

IOException - In case of IO exception.

InterruptedException - In case of interrupt.

abort

protected void abort(@Nullable
                     OutputFormat outputFormat)

Abort task.

Parameters:

outputFormat - Output format.

cancel

public void cancel()

Specified by:

cancel in class HadoopTask