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 |
---|---|
int |
getAppType() |
java.lang.String |
getCodeRepoHome() |
java.lang.String |
getDd_archives() |
java.lang.String |
getDd_class() |
java.lang.String |
getDd_conf() |
java.lang.String |
getDd_deploy_mode() |
java.lang.String |
getDd_driver_class_path() |
java.lang.String |
getDd_driver_java_options() |
java.lang.String |
getDd_driver_library_path() |
java.lang.String |
getDd_driver_memory() |
java.lang.String |
getDd_exclude_packages() |
java.lang.Integer |
getDd_executor_cores() |
java.lang.String |
getDd_executor_memory() |
java.lang.String |
getDd_files() |
java.lang.String |
getDd_jars() |
java.lang.String |
getDd_keytab() |
java.lang.String |
getDd_master() |
java.lang.String |
getDd_name() |
java.lang.Integer |
getDd_num_executors() |
java.lang.String |
getDd_packages() |
java.lang.String |
getDd_principal() |
java.lang.String |
getDd_properties() |
java.lang.String |
getDd_proxy_user() |
java.lang.String |
getDd_py_files() |
java.lang.String |
getDd_queue() |
java.lang.String |
getDd_repositories() |
java.lang.Integer |
getDd_total_executor_cores() |
java.lang.String[] |
getInputEnvironmentNames()
Used by app only
|
int |
getLog4jLevel() |
java.lang.Integer |
getMasterWebUIPort() |
java.lang.String |
getSparkAppJarPath() |
java.lang.String |
getSparkHome() |
java.lang.String |
getSparkScriptPath() |
java.lang.String |
getWorkingDirectory() |
boolean |
isDd_verbose() |
boolean |
isFailureOnNonZeroExit() |
boolean |
isFailureOnStdError() |
boolean |
isHideArgValues() |
boolean |
isMasterWebHTTPSecure() |
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 int getAppType()
public java.lang.String getSparkScriptPath()
public java.lang.String getSparkAppJarPath()
public java.lang.String getDd_master()
public java.lang.String getDd_deploy_mode()
public java.lang.String getDd_class()
public java.lang.String getDd_name()
public java.lang.String getDd_jars()
public java.lang.String getDd_packages()
public java.lang.String getDd_exclude_packages()
public java.lang.String getDd_repositories()
public java.lang.String getDd_files()
public java.lang.String getDd_conf()
public java.lang.String getDd_properties()
public java.lang.String getDd_driver_memory()
public java.lang.String getDd_driver_java_options()
public java.lang.String getDd_driver_library_path()
public java.lang.String getDd_driver_class_path()
public java.lang.String getDd_executor_memory()
public java.lang.String getDd_proxy_user()
public java.lang.Integer getDd_total_executor_cores()
public java.lang.Integer getDd_executor_cores()
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()
public boolean isMasterWebHTTPSecure()
public boolean isDd_verbose()
public int getLog4jLevel()
Copyright © Grand Logic, Inc. All Rights Reserved.