org.ow2.proactive.scheduler.task.executors.forked.env

Class ForkedTaskVariablesManager

java.lang.Object

org.ow2.proactive.scheduler.task.executors.forked.env.ForkedTaskVariablesManager

All Implemented Interfaces:

Serializable

public class ForkedTaskVariablesManager
extends Object
implements Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CREDENTIALS_KEY_PREFIX Will be replaced by the matching third-party credential Example: if one of the third-party credentials' key-value pairs is 'foo:bar', then '$credentials_foo' will be replaced by 'bar' in the arguments of the tasks.

Constructor Summary

Constructors

Constructor and Description
ForkedTaskVariablesManager()

Method Summary

Modifier and Type	Method and Description
void	addBindingsToScriptHandler(ScriptHandler scriptHandler, TaskContext taskContext, VariablesMap variables, Map<String,Serializable> resultMap, Map<String,String> thirdPartyCredentials, SchedulerNodeClient client, RMNodeClient rmNodeClient, RemoteSpace userSpaceClient, RemoteSpace globalSpaceClient, Map<String,String> resultMetadata, PrintStream outputSink, PrintStream errorSink)
RemoteSpace	createDataSpaceNodeClient(TaskContext container, SchedulerNodeClient schedulerNodeClient, IDataSpaceClient.Dataspace space)
RMNodeClient	createRMNodeClient(TaskContext container)
SchedulerNodeClient	createSchedulerNodeClient(TaskContext container)
Map<String,String>	extractThirdPartyCredentials(TaskContext container)
void	replaceScriptParameters(Script<?> script, Map<String,String> thirdPartyCredentials, VariablesMap variables, PrintStream errorStream)

Methods inherited from class java.lang.Object

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

Field Detail

CREDENTIALS_KEY_PREFIX

public static final String CREDENTIALS_KEY_PREFIX

Will be replaced by the matching third-party credential Example: if one of the third-party credentials' key-value pairs is 'foo:bar', then '$credentials_foo' will be replaced by 'bar' in the arguments of the tasks.

See Also:

Constant Field Values

Constructor Detail

ForkedTaskVariablesManager

public ForkedTaskVariablesManager()

Method Detail

addBindingsToScriptHandler

public void addBindingsToScriptHandler(ScriptHandler scriptHandler,
                                       TaskContext taskContext,
                                       VariablesMap variables,
                                       Map<String,Serializable> resultMap,
                                       Map<String,String> thirdPartyCredentials,
                                       SchedulerNodeClient client,
                                       RMNodeClient rmNodeClient,
                                       RemoteSpace userSpaceClient,
                                       RemoteSpace globalSpaceClient,
                                       Map<String,String> resultMetadata,
                                       PrintStream outputSink,
                                       PrintStream errorSink)

extractThirdPartyCredentials

public Map<String,String> extractThirdPartyCredentials(TaskContext container)

createSchedulerNodeClient

public SchedulerNodeClient createSchedulerNodeClient(TaskContext container)

createRMNodeClient

public RMNodeClient createRMNodeClient(TaskContext container)

Returns:

craeted RMNodeClient if possible (there should be decrypter and url), otherwise null

createDataSpaceNodeClient

public RemoteSpace createDataSpaceNodeClient(TaskContext container,
                                             SchedulerNodeClient schedulerNodeClient,
                                             IDataSpaceClient.Dataspace space)

replaceScriptParameters

public void replaceScriptParameters(Script<?> script,
                                    Map<String,String> thirdPartyCredentials,
                                    VariablesMap variables,
                                    PrintStream errorStream)