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

Class HadoopEmbeddedTaskExecutor

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

public class HadoopEmbeddedTaskExecutor
extends HadoopTaskExecutorAdapter

Task executor.

Field Summary

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

ctx, log

Constructor Summary

Constructors

Constructor and Description
HadoopEmbeddedTaskExecutor()

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	onKernalStart() Callback invoked when all grid components are started.
void	onKernalStop(boolean cancel) Callback invoked before all grid components are stopped.
void	run(HadoopJobEx job, Collection<HadoopTaskInfo> tasks) Runs tasks.
void	stop(boolean cancel) Stops manager.

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

start

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopEmbeddedTaskExecutor

public HadoopEmbeddedTaskExecutor()

Method Detail

onKernalStart

public void onKernalStart()
                   throws IgniteCheckedException

Callback invoked when all grid components are started.

Overrides:

onKernalStart in class HadoopComponent

Throws:

IgniteCheckedException

onKernalStop

public void onKernalStop(boolean cancel)

Callback invoked before all grid components are stopped.

Overrides:

onKernalStop in class HadoopComponent

stop

public void stop(boolean cancel)

Stops manager.

Overrides:

stop in class HadoopComponent

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 run(HadoopJobEx, Collection) method. No more job submissions will be performed via 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.

onJobStateChanged

public void onJobStateChanged(HadoopJobMetadata meta)
                       throws IgniteCheckedException

On job state change callback;

Specified by:

onJobStateChanged in class HadoopTaskExecutorAdapter

Parameters:

meta - Job metadata.

Throws:

IgniteCheckedException