Package fr.ens.biologie.genomique.eoulsan.core.schedulers

Class HadoopCompatibleTaskScheduler

java.lang.Object

fr.ens.biologie.genomique.eoulsan.core.schedulers.AbstractTaskScheduler

fr.ens.biologie.genomique.eoulsan.core.schedulers.HadoopCompatibleTaskScheduler

All Implemented Interfaces:

TaskScheduler

public class HadoopCompatibleTaskScheduler
extends AbstractTaskScheduler

This class is a scheduler for tasks from step with the @HadoopComptible annotation in Hadoop mode.

Since:

2.0

Author:

Laurent Jourdren

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	HadoopCompatibleTaskScheduler.HadoopCompatibleMapper

Method Summary

Modifier and Type	Method	Description
void	stop()	Stop the scheduler.
void	submit(Step step, TaskContextImpl context)	Submit a context to execute.

Methods inherited from class fr.ens.biologie.genomique.eoulsan.core.schedulers.AbstractTaskScheduler

afterExecuteTask, beforeExecuteTask, executeTask, getResult, getStatus, getStep, getStep, getTaskDoneCount, getTaskRunningCount, getTaskSubmittedCount, getTotalTaskDoneCount, getTotalTaskRunningCount, getTotalTaskSubmittedCount, isStarted, isStopped, start, submit, waitEndOfTasks

Methods inherited from class java.lang.Object

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

Method Detail

submit

public void submit(Step step,
                   TaskContextImpl context)

Description copied from interface: TaskScheduler

Submit a context to execute.

Specified by:

submit in interface TaskScheduler

Overrides:

submit in class AbstractTaskScheduler

Parameters:

step - step related to the context

context - context to execute

stop

public void stop()

Description copied from interface: TaskScheduler

Stop the scheduler.

Specified by:

stop in interface TaskScheduler

Overrides:

stop in class AbstractTaskScheduler