org.apache.ignite.internal.processors.hadoop

Interface GridHadoopJob

public interface GridHadoopJob

Hadoop job.

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanupStagingDirectory() Cleans up the job staging directory.
void	cleanupTaskEnvironment(GridHadoopTaskInfo info) Cleans up local environment of the task.
void	dispose(boolean external) Release all the resources.
GridHadoopTaskContext	getTaskContext(GridHadoopTaskInfo info) Returns context for task execution.
GridHadoopJobId	id() Gets job ID.
GridHadoopJobInfo	info() Gets job information.
void	initialize(boolean external, UUID locNodeId) Does all the needed initialization for the job.
Collection<GridHadoopInputSplit>	input() Gets collection of input splits for this job.
void	prepareTaskEnvironment(GridHadoopTaskInfo info) Prepare local environment for the task.

Method Detail

id

GridHadoopJobId id()

Gets job ID.

Returns:

Job ID.

info

GridHadoopJobInfo info()

Gets job information.

Returns:

Job information.

input

Collection<GridHadoopInputSplit> input()
                                       throws IgniteCheckedException

Gets collection of input splits for this job.

Returns:

Input splits.

Throws:

IgniteCheckedException

getTaskContext

GridHadoopTaskContext getTaskContext(GridHadoopTaskInfo info)
                                     throws IgniteCheckedException

Returns context for task execution.

Parameters:

info - Task info.

Returns:

Task Context.

Throws:

IgniteCheckedException - If failed.

initialize

void initialize(boolean external,
              UUID locNodeId)
                throws IgniteCheckedException

Does all the needed initialization for the job. Will be called on each node where tasks for this job must be executed.

If job is running in external mode this method will be called on instance in Ignite node with parameter false and on instance in external process with parameter true.

Parameters:

external - If true then this job instance resides in external process.

locNodeId - Local node ID.

Throws:

IgniteCheckedException - If failed.

dispose

void dispose(boolean external)
             throws IgniteCheckedException

Release all the resources.

If job is running in external mode this method will be called on instance in Ignite node with parameter false and on instance in external process with parameter true.

Parameters:

external - If true then this job instance resides in external process.

Throws:

IgniteCheckedException - If failed.

prepareTaskEnvironment

void prepareTaskEnvironment(GridHadoopTaskInfo info)
                            throws IgniteCheckedException

Prepare local environment for the task.

Parameters:

info - Task info.

Throws:

IgniteCheckedException - If failed.

cleanupTaskEnvironment

void cleanupTaskEnvironment(GridHadoopTaskInfo info)
                            throws IgniteCheckedException

Cleans up local environment of the task.

Parameters:

info - Task info.

Throws:

IgniteCheckedException - If failed.

cleanupStagingDirectory

void cleanupStagingDirectory()

Cleans up the job staging directory.