public class SparkAppInputTaskletProxy
extends java.lang.Object
implements com.google.gwt.user.client.rpc.IsSerializable
ShellScriptCustomizer
Constructor and Description |
---|
SparkAppInputTaskletProxy(SparkAppInput inputJavaBean) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getCodeRepoHome() |
java.lang.String |
getDd_archives() |
java.lang.Integer |
getDd_executor_cores() |
java.lang.String |
getDd_keytab() |
java.lang.Integer |
getDd_num_executors() |
java.lang.String |
getDd_principal() |
java.lang.String |
getDd_py_files() |
java.lang.String |
getDd_queue() |
java.lang.String |
getEnv_hadoop_conf_dir() |
java.lang.String[] |
getInputEnvironmentNames()
Used by app only
|
java.lang.Integer |
getMasterWebUIPort() |
java.lang.String |
getSparkHome() |
java.lang.String |
getWorkingDirectory() |
boolean |
isFailureOnNonZeroExit() |
boolean |
isFailureOnStdError() |
boolean |
isHideArgValues() |
boolean |
isSaveStatusMsgToJobContext() |
boolean |
isSaveStatusMsgToTaskletContext() |
java.lang.Boolean |
isStreamStdOutError() |
public SparkAppInputTaskletProxy(SparkAppInput inputJavaBean)
public java.lang.String[] getInputEnvironmentNames()
public boolean isFailureOnNonZeroExit()
public boolean isFailureOnStdError()
public boolean isHideArgValues()
public boolean isSaveStatusMsgToJobContext()
public boolean isSaveStatusMsgToTaskletContext()
public java.lang.String getWorkingDirectory()
public java.lang.String getSparkHome()
public java.lang.Boolean isStreamStdOutError()
public java.lang.Integer getDd_executor_cores()
public java.lang.String getEnv_hadoop_conf_dir()
public java.lang.String getDd_queue()
public java.lang.Integer getDd_num_executors()
public java.lang.String getDd_archives()
public java.lang.String getDd_principal()
public java.lang.String getDd_keytab()
public java.lang.Integer getMasterWebUIPort()
public java.lang.String getCodeRepoHome()
public java.lang.String getDd_py_files()
Copyright © Grand Logic, Inc. All Rights Reserved.