org.apache.ignite.internal.processors.hadoop.taskexecutor.external

Class HadoopExternalTaskExecutor

java.lang.Object

org.apache.ignite.internal.processors.hadoop.HadoopComponent

org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskExecutorAdapter

org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor

public class HadoopExternalTaskExecutor
extends HadoopTaskExecutorAdapter

External process registry. Handles external process lifecycle.

Constructor Summary

Constructors

Constructor and Description
HadoopExternalTaskExecutor()

Method Summary

Modifier and Type	Method and Description
void	cancelTasks(HadoopJobId jobId) Cancels all currently running tasks for given job ID and cancels scheduled execution of tasks for this job ID.
void	onJobStateChanged(HadoopJobMetadata meta) On job state change callback;
void	run(HadoopJobEx job, Collection<HadoopTaskInfo> tasks) Runs tasks.
void	start(HadoopContext ctx)
void	stop(boolean cancel) Stops manager.

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

onKernalStart, onKernalStop

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopExternalTaskExecutor

public HadoopExternalTaskExecutor()

Method Detail

start

public void start(HadoopContext ctx)
           throws IgniteCheckedException

Overrides:

start in class HadoopComponent

Parameters:

ctx - Hadoop context.

Throws:

IgniteCheckedException

stop

public void stop(boolean cancel)

Stops manager.

Overrides:

stop in class HadoopComponent

onJobStateChanged

public void onJobStateChanged(HadoopJobMetadata meta)

On job state change callback;

Specified by:

onJobStateChanged in class HadoopTaskExecutorAdapter

Parameters:

meta - Job metadata.

run

public void run(HadoopJobEx job,
                Collection<HadoopTaskInfo> tasks)
         throws IgniteCheckedException

Runs tasks.

Specified by:

run in class HadoopTaskExecutorAdapter

Parameters:

job - Job.

tasks - Tasks.

Throws:

IgniteCheckedException - If failed.

cancelTasks

public void cancelTasks(HadoopJobId jobId)

Cancels all currently running tasks for given job ID and cancels scheduled execution of tasks for this job ID.

It is guaranteed that this method will not be called concurrently with HadoopTaskExecutorAdapter.run(HadoopJobEx, Collection) method. No more job submissions will be performed via HadoopTaskExecutorAdapter.run(HadoopJobEx, Collection) method for given job ID after this method is called.

Specified by:

cancelTasks in class HadoopTaskExecutorAdapter

Parameters:

jobId - Job ID to cancel.