public class JavaStandaloneExecutableInitializer extends Object
Modifier and Type | Field and Description |
---|---|
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 and Description |
---|
JavaStandaloneExecutableInitializer() |
Modifier and Type | Method and Description |
---|---|
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 |
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) |
protected Map<String,byte[]> propagatedVariables
protected TaskId taskId
public Map<String,Serializable> getArguments(ClassLoader cl) throws IOException, ClassNotFoundException
IOException
- if the deserialization of the value cannot be performed.ClassNotFoundException
- if the value's class cannot be loaded.public void setSerializedArguments(Map<String,byte[]> serializedArguments)
serializedArguments
- the arguments to setpublic void setPropagatedVariables(Map<String,byte[]> propagatedVariables)
propagatedVariables
- a map of propagated variablespublic Map<String,byte[]> getPropagatedVariables()
public void setThirdPartyCredentials(Map<String,String> thirdPartyCredentials)
public TaskId getTaskId()
public void setTaskId(TaskId taskId)
public PrintStream getOutputSink()
public void setOutputSink(PrintStream redirectedStdout)
public PrintStream getErrorSink()
public void setErrorSink(PrintStream errorSink)