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
void	fetchUrlsIfNeeded()
String	getCatalogRestPublicUrl()
String	getCatalogRestUrl()
String	getCloudAutomationRestPublicUrl()
String	getCloudAutomationRestUrl()
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()
com.google.common.collect.ImmutableMap<String,String>	getGlobalGenericInformation()
com.google.common.collect.ImmutableMap<String,JobVariable>	getGlobalVariables()
int	getIterationIndex()
String	getJobOwner()
String	getJobPlannerRestPublicUrl()
String	getJobPlannerRestUrl()
com.google.common.collect.ImmutableMap<String,JobVariable>	getJobVariables()
org.objectweb.proactive.extensions.dataspaces.core.naming.NamingService	getNamingService() Get the namingService Stub
String	getNotificationServiceRestPublicUrl()
String	getNotificationServiceRestUrl()
int	getPingAttempts()
int	getPingPeriod()
TaskScript	getPostScript() Get the post-script
Script<?>	getPreScript() Get the pre-script
int	getReplicationIndex()
String	getSchedulerRestPublicUrl()
String	getSchedulerRestUrl()
SignalApi	getSignalAPI()
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	setCatalogRestPublicUrl(String catalogRestPublicUrl)
void	setCatalogRestUrl(String catalogRestUrl)
void	setCloudAutomationRestPublicUrl(String cloudAutomationRestPublicUrl)
void	setCloudAutomationRestUrl(String cloudAutomationRestUrl)
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	setGlobalGenericInformation(Map<String,String> globalGenericInformation)
void	setGlobalVariables(Map<String,JobVariable> globalVariables)
void	setIterationIndex(int id)
void	setJobOwner(String jobOwner)
void	setJobPlannerRestPublicUrl(String jobPlannerRestPublicUrl)
void	setJobPlannerRestUrl(String jobPlannerRestUrl)
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	setNotificationServiceRestPublicUrl(String notificationServiceRestPublicUrl)
void	setNotificationServiceRestUrl(String notificationServiceRestUrl)
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	setSchedulerRestPublicUrl(String schedulerRestPublicUrl)
void	setSchedulerRestUrl(String schedulerRestUrl)
void	setSignalAPI(SignalApi signalAPI)
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 TaskScript getPostScript()

Get the post-script

Returns:

the post-script

fetchUrlsIfNeeded

public void fetchUrlsIfNeeded()
                       throws IOException

Throws:

IOException

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

getGlobalGenericInformation

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

setGlobalGenericInformation

public void setGlobalGenericInformation(Map<String,String> globalGenericInformation)

isPreciousLogs

public boolean isPreciousLogs()

Returns:

the preciousLogs

setJobOwner

public void setJobOwner(String jobOwner)

setSchedulerRestUrl

public void setSchedulerRestUrl(String schedulerRestUrl)

getSchedulerRestUrl

public String getSchedulerRestUrl()

setSchedulerRestPublicUrl

public void setSchedulerRestPublicUrl(String schedulerRestPublicUrl)

getSchedulerRestPublicUrl

public String getSchedulerRestPublicUrl()

setCatalogRestUrl

public void setCatalogRestUrl(String catalogRestUrl)

getCatalogRestUrl

public String getCatalogRestUrl()

setCatalogRestPublicUrl

public void setCatalogRestPublicUrl(String catalogRestPublicUrl)

getCatalogRestPublicUrl

public String getCatalogRestPublicUrl()

getCloudAutomationRestUrl

public String getCloudAutomationRestUrl()

setCloudAutomationRestUrl

public void setCloudAutomationRestUrl(String cloudAutomationRestUrl)

getCloudAutomationRestPublicUrl

public String getCloudAutomationRestPublicUrl()

setCloudAutomationRestPublicUrl

public void setCloudAutomationRestPublicUrl(String cloudAutomationRestPublicUrl)

getJobPlannerRestUrl

public String getJobPlannerRestUrl()

setJobPlannerRestUrl

public void setJobPlannerRestUrl(String jobPlannerRestUrl)

getJobPlannerRestPublicUrl

public String getJobPlannerRestPublicUrl()

setJobPlannerRestPublicUrl

public void setJobPlannerRestPublicUrl(String jobPlannerRestPublicUrl)

getNotificationServiceRestUrl

public String getNotificationServiceRestUrl()

setNotificationServiceRestUrl

public void setNotificationServiceRestUrl(String notificationServiceRestUrl)

getNotificationServiceRestPublicUrl

public String getNotificationServiceRestPublicUrl()

setNotificationServiceRestPublicUrl

public void setNotificationServiceRestPublicUrl(String notificationServiceRestPublicUrl)

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()

getGlobalVariables

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

setGlobalVariables

public void setGlobalVariables(Map<String,JobVariable> globalVariables)

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)

getSignalAPI

public SignalApi getSignalAPI()

setSignalAPI

public void setSignalAPI(SignalApi signalAPI)