org.ow2.proactive.scheduler.task

Class TaskLauncherInitializer

java.lang.Object

org.ow2.proactive.scheduler.task.TaskLauncherInitializer

All Implemented Interfaces:

Serializable

public class TaskLauncherInitializer
extends Object
implements Serializable

TaskLauncherInitializer is used to initialize the task launcher.
It contains every information that can be used by the launcher. It's a kind of contract so that each launcher must use its required information coming from this class.

Since:

ProActive Scheduling 1.0

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TaskLauncherInitializer()

Method Summary

Modifier and Type	Method and Description
String	getCatalogRestUrl()
FlowScript	getControlFlowScript() Get the control flow script
List<InputSelector>	getFilteredInputFiles(Map<String,Serializable> variables)
List<OutputSelector>	getFilteredOutputFiles(Map<String,Serializable> variables)
ForkEnvironment	getForkEnvironment()
com.google.common.collect.ImmutableMap<String,String>	getGenericInformation()
int	getIterationIndex()
String	getJobOwner()
com.google.common.collect.ImmutableMap<String,JobVariable>	getJobVariables()
org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService	getNamingService() Get the namingService Stub
int	getPingAttempts()
int	getPingPeriod()
Script<?>	getPostScript() Get the post-script
Script<?>	getPreScript() Get the pre-script
int	getReplicationIndex()
String	getSchedulerRestUrl()
Synchronization	getSynchronizationAPI()
TaskId	getTaskId() Get the taskId
List<InputSelector>	getTaskInputFiles() Get the taskInputFiles
List<OutputSelector>	getTaskOutputFiles() Get the taskOutputFiles
com.google.common.collect.ImmutableMap<String,TaskVariable>	getTaskVariables()
long	getWalltime() Get the walltime of the task
boolean	isAuthorizedForkEnvironmentScript()
boolean	isPreciousLogs()
void	setAuthorizedForkEnvironmentScript(boolean authorizedForkEnvironmentScript)
void	setCatalogRestUrl(String catalogRestUrl)
void	setControlFlowScript(FlowScript flow) Set the control flow script value to the given flow value
void	setForkEnvironment(ForkEnvironment forkEnvironment)
void	setGenericInformation(Map<String,String> genericInformation)
void	setIterationIndex(int id)
void	setJobOwner(String jobOwner)
void	setJobVariables(Map<String,JobVariable> variables)
void	setNamingService(org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService namingService) Set the namingService Stub to the given namingService value
void	setPingAttempts(int pingAttempts)
void	setPingPeriod(int pingPeriod)
void	setPostScript(Script<?> post) Set the post-script value to the given post value
void	setPreciousLogs(boolean preciousLogs)
void	setPreScript(Script<?> pre) Set the pre-script value to the given pre value
void	setReplicationIndex(int id)
void	setSchedulerRestUrl(String schedulerRestUrl)
void	setSynchronizationAPI(Synchronization synchronizationAPI)
void	setTaskId(TaskId taskId) Set the taskId value to the given taskId value
void	setTaskInputFiles(List<InputSelector> taskInputFiles) Set the taskInputFiles value to the given taskInputFiles value
void	setTaskOutputFiles(List<OutputSelector> taskOutputFiles) Set the taskOutputFiles value to the given taskOutputFiles value
void	setTaskVariables(Map<String,TaskVariable> taskVariables)
void	setWalltime(long walltime) Set the walltime value to the given walltime value

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskLauncherInitializer

public TaskLauncherInitializer()

Method Detail

getTaskId

public TaskId getTaskId()

Get the taskId

Returns:

the taskId

setTaskId

public void setTaskId(TaskId taskId)

Set the taskId value to the given taskId value

Parameters:

taskId - the taskId to set

getPreScript

public Script<?> getPreScript()

Get the pre-script

Returns:

the pre-script

setPreScript

public void setPreScript(Script<?> pre)

Set the pre-script value to the given pre value

Parameters:

pre - the pre-script to set

getPostScript

public Script<?> getPostScript()

Get the post-script

Returns:

the post-script

setControlFlowScript

public void setControlFlowScript(FlowScript flow)

Set the control flow script value to the given flow value

Parameters:

flow - the control flow script to set

getControlFlowScript

public FlowScript getControlFlowScript()

Get the control flow script

Returns:

the post-script

setPostScript

public void setPostScript(Script<?> post)

Set the post-script value to the given post value

Parameters:

post - the post-script to set

setWalltime

public void setWalltime(long walltime)

Set the walltime value to the given walltime value

Parameters:

walltime - the walltime to set

getWalltime

public long getWalltime()

Get the walltime of the task

Returns:

the walltime of the task

getNamingService

public org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService getNamingService()

Get the namingService Stub

Returns:

the namingService

setNamingService

public void setNamingService(org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService namingService)

Set the namingService Stub to the given namingService value

Parameters:

namingService - the namingService to set

getTaskInputFiles

public List<InputSelector> getTaskInputFiles()

Get the taskInputFiles

Returns:

the taskInputFiles

setTaskInputFiles

public void setTaskInputFiles(List<InputSelector> taskInputFiles)

Set the taskInputFiles value to the given taskInputFiles value

Parameters:

taskInputFiles - the taskInputFiles to set

getTaskOutputFiles

public List<OutputSelector> getTaskOutputFiles()

Get the taskOutputFiles

Returns:

the taskOutputFiles

setTaskOutputFiles

public void setTaskOutputFiles(List<OutputSelector> taskOutputFiles)

Set the taskOutputFiles value to the given taskOutputFiles value

Parameters:

taskOutputFiles - the taskOutputFiles to set

setIterationIndex

public void setIterationIndex(int id)

Parameters:

id - the replication index: task was replicated in parallel

getIterationIndex

public int getIterationIndex()

Returns:

the replication index: task was replicated in parallel

getJobOwner

public String getJobOwner()

Returns:

the job owner

setReplicationIndex

public void setReplicationIndex(int id)

Parameters:

id - the iteration index: task was replicated sequentially

getReplicationIndex

public int getReplicationIndex()

Returns:

the iteration index: task was replicated sequentially

setGenericInformation

public void setGenericInformation(Map<String,String> genericInformation)

Parameters:

genericInformation - the generic information of this task

getGenericInformation

public com.google.common.collect.ImmutableMap<String,String> getGenericInformation()

Returns:

the generic information of this task

isPreciousLogs

public boolean isPreciousLogs()

Returns:

the preciousLogs

setJobOwner

public void setJobOwner(String jobOwner)

setSchedulerRestUrl

public void setSchedulerRestUrl(String schedulerRestUrl)

getSchedulerRestUrl

public String getSchedulerRestUrl()

setCatalogRestUrl

public void setCatalogRestUrl(String catalogRestUrl)

getCatalogRestUrl

public String getCatalogRestUrl()

setPreciousLogs

public void setPreciousLogs(boolean preciousLogs)

Parameters:

preciousLogs - the preciousLogs to set

setJobVariables

public void setJobVariables(Map<String,JobVariable> variables)

getJobVariables

public com.google.common.collect.ImmutableMap<String,JobVariable> getJobVariables()

setTaskVariables

public void setTaskVariables(Map<String,TaskVariable> taskVariables)

getTaskVariables

public com.google.common.collect.ImmutableMap<String,TaskVariable> getTaskVariables()

setPingPeriod

public void setPingPeriod(int pingPeriod)

getPingPeriod

public int getPingPeriod()

setPingAttempts

public void setPingAttempts(int pingAttempts)

getPingAttempts

public int getPingAttempts()

getFilteredInputFiles

public List<InputSelector> getFilteredInputFiles(Map<String,Serializable> variables)

getFilteredOutputFiles

public List<OutputSelector> getFilteredOutputFiles(Map<String,Serializable> variables)

getForkEnvironment

public ForkEnvironment getForkEnvironment()

setForkEnvironment

public void setForkEnvironment(ForkEnvironment forkEnvironment)

isAuthorizedForkEnvironmentScript

public boolean isAuthorizedForkEnvironmentScript()

setAuthorizedForkEnvironmentScript

public void setAuthorizedForkEnvironmentScript(boolean authorizedForkEnvironmentScript)

getSynchronizationAPI

public Synchronization getSynchronizationAPI()

setSynchronizationAPI

public void setSynchronizationAPI(Synchronization synchronizationAPI)