org.ow2.proactive.scheduler.common.task.executable.internal

Class JavaStandaloneExecutableInitializer

java.lang.Object

org.ow2.proactive.scheduler.common.task.executable.internal.JavaStandaloneExecutableInitializer

public class JavaStandaloneExecutableInitializer
extends Object

JavaStandaloneExecutableInitializer is the class used to store context of java standalone executable initialization

Since:

ProActive Scheduling 1.0

Field Summary

Fields

Modifier and Type	Field and Description
protected Set<String>	allNodes
protected List<String>	nodes
protected Map<String,byte[]>	propagatedVariables Propagated variables from parent tasks
protected Map<String,byte[]>	serializedArguments Arguments of the java task
protected TaskId	taskId

Constructor Summary

Constructors

Constructor and Description
JavaStandaloneExecutableInitializer()

Method Summary

Modifier and Type	Method and Description
Set<String>	getAllNodesURL()
Map<String,Serializable>	getArguments(ClassLoader cl)
PrintStream	getErrorSink()
List<String>	getNodesURL()
PrintStream	getOutputSink()
Map<String,byte[]>	getPropagatedVariables() Returns the propagated variables map of the current Java task.
TaskId	getTaskId()
Map<String,String>	getThirdPartyCredentials()
void	setAllNodesURL(Set<String> allNodes)
void	setErrorSink(PrintStream errorSink)
void	setNodesURL(List<String> nodes)
void	setOutputSink(PrintStream redirectedStdout)
void	setPropagatedVariables(Map<String,byte[]> propagatedVariables) Sets the propagated variable map for the current Java task.
void	setSerializedArguments(Map<String,byte[]> serializedArguments) Set the arguments value to the given arguments value
void	setTaskId(TaskId taskId)
void	setThirdPartyCredentials(Map<String,String> thirdPartyCredentials)

Methods inherited from class java.lang.Object

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

Field Detail

serializedArguments

protected Map<String,byte[]> serializedArguments

Arguments of the java task

propagatedVariables

protected Map<String,byte[]> propagatedVariables

Propagated variables from parent tasks

nodes

protected List<String> nodes

allNodes

protected Set<String> allNodes

taskId

protected TaskId taskId

Constructor Detail

JavaStandaloneExecutableInitializer

public JavaStandaloneExecutableInitializer()

Method Detail

getArguments

public Map<String,Serializable> getArguments(ClassLoader cl)
                                      throws IOException,
                                             ClassNotFoundException

Throws:

IOException - if the deserialization of the value cannot be performed.

ClassNotFoundException - if the value's class cannot be loaded.

setSerializedArguments

public void setSerializedArguments(Map<String,byte[]> serializedArguments)

Set the arguments value to the given arguments value

Parameters:

serializedArguments - the arguments to set

setPropagatedVariables

public void setPropagatedVariables(Map<String,byte[]> propagatedVariables)

Sets the propagated variable map for the current Java task.

Parameters:

propagatedVariables - a map of propagated variables

getPropagatedVariables

public Map<String,byte[]> getPropagatedVariables()

Returns the propagated variables map of the current Java task. g

Returns:

a map of variables

getThirdPartyCredentials

public Map<String,String> getThirdPartyCredentials()

setThirdPartyCredentials

public void setThirdPartyCredentials(Map<String,String> thirdPartyCredentials)

getNodesURL

public List<String> getNodesURL()

setNodesURL

public void setNodesURL(List<String> nodes)

getAllNodesURL

public Set<String> getAllNodesURL()

setAllNodesURL

public void setAllNodesURL(Set<String> allNodes)

getTaskId

public TaskId getTaskId()

setTaskId

public void setTaskId(TaskId taskId)

getOutputSink

public PrintStream getOutputSink()

setOutputSink

public void setOutputSink(PrintStream redirectedStdout)

getErrorSink

public PrintStream getErrorSink()

setErrorSink

public void setErrorSink(PrintStream errorSink)