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

Class HadoopTaskExecutorAdapter

java.lang.Object

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

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

Direct Known Subclasses:

HadoopEmbeddedTaskExecutor, HadoopExternalTaskExecutor

public abstract class HadoopTaskExecutorAdapter
extends HadoopComponent

Common superclass for task executor.

Field Summary

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

ctx, log

Constructor Summary

Constructors

Constructor and Description
HadoopTaskExecutorAdapter()

Method Summary

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

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

onKernalStart, onKernalStop, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

HadoopTaskExecutorAdapter

public HadoopTaskExecutorAdapter()

Method Detail

run

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

Runs tasks.

Parameters:

job - Job.

tasks - Tasks.

Throws:

IgniteCheckedException - If failed.

cancelTasks

public abstract void cancelTasks(HadoopJobId jobId)
                          throws IgniteCheckedException

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.

Parameters:

jobId - Job ID to cancel.

Throws:

IgniteCheckedException

onJobStateChanged

public abstract void onJobStateChanged(HadoopJobMetadata meta)
                                throws IgniteCheckedException

On job state change callback;

Parameters:

meta - Job metadata.

Throws:

IgniteCheckedException