org.apache.beam.runners.apex

Class ApexYarnLauncher.LaunchParams

java.lang.Object

org.apache.beam.runners.apex.ApexYarnLauncher.LaunchParams

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

ApexYarnLauncher

protected static class ApexYarnLauncher.LaunchParams
extends java.lang.Object
implements java.io.Serializable

Launch parameters that will be serialized and passed to the child process.

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	LaunchParams(com.datatorrent.api.DAG dag, com.datatorrent.api.Attribute.AttributeMap launchAttributes, java.util.Properties configProperties)

Method Summary

Modifier and Type	Method and Description
protected org.apache.apex.api.Launcher<?>	getApexLauncher()
protected java.lang.String	getCmd()
protected java.util.Map<java.lang.String,java.lang.String>	getEnv()

Methods inherited from class java.lang.Object

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

Constructor Detail

LaunchParams

protected LaunchParams(com.datatorrent.api.DAG dag,
                       com.datatorrent.api.Attribute.AttributeMap launchAttributes,
                       java.util.Properties configProperties)

Method Detail

getApexLauncher

protected org.apache.apex.api.Launcher<?> getApexLauncher()

getCmd

protected java.lang.String getCmd()

getEnv

protected java.util.Map<java.lang.String,java.lang.String> getEnv()