Instance Constructors
-
new
H2OConf()
-
new
H2OConf(sparkConf: SparkConf)
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
def
HDFSOutputDir: Option[String]
-
def
YARNQueue: Option[String]
-
final
def
asInstanceOf[T0]: T0
-
def
autoFlowSsl: Boolean
-
def
backendClusterMode: String
-
def
backendHeartbeatInterval: Int
-
def
basePort: Int
-
def
clientCheckRetryTimeout: Int
-
def
clientFlowBaseurlOverride: Option[String]
-
def
clientIp: Option[String]
-
def
clientNetworkMask: Option[String]
-
def
clientVerboseOutput: Boolean
-
def
clientWebPort: Int
-
-
def
cloudName: Option[String]
-
def
cloudTimeout: Int
-
def
clusterInfoFile: Option[String]
-
def
clusterSize: Option[String]
-
def
clusterStartMode: String
-
def
clusterStartTimeout: Int
-
def
contains(key: String): Boolean
-
def
contextPath: Option[String]
-
def
defaultCloudSize: Int
-
def
drddMulFactor: Int
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
externalAutoStartBackend: String
-
def
externalBackendStopTimeout: Int
-
def
externalCommunicationCompression: String
-
def
externalConfString: String
-
def
externalExtraJars: Option[String]
-
def
externalExtraMemoryPercent: Int
-
def
externalH2ODriverIf: Option[String]
-
def
externalH2ODriverPort: Option[String]
-
def
externalH2ODriverPortRange: Option[String]
-
def
externalHadoopExecutable: String
-
def
externalK8sDockerImage: String
-
def
externalK8sDomain: String
-
def
externalK8sH2OApiPort: Int
-
def
externalK8sH2OLabel: String
-
def
externalK8sH2OServiceName: String
-
def
externalK8sH2OStatefulsetName: String
-
def
externalK8sNamespace: String
-
def
externalK8sServiceTimeout: Int
-
def
externalMemory: String
-
def
extraClusterNodes: Boolean
-
def
extraProperties: Option[String]
-
def
finalize(): Unit
-
def
flowDir: Option[String]
-
def
flowExtraHttpHeaders: Option[String]
-
def
flowProxyRequestMaxSize(): Int
-
def
flowProxyResponseMaxSize(): Int
-
def
flowScalaCellAsync: Boolean
-
def
get(key: String, defaultValue: String): String
-
def
get(key: String): String
-
def
getAll: Array[(String, String)]
-
def
getBoolean(key: String, defaultValue: Boolean): Boolean
-
final
def
getClass(): Class[_]
-
def
getDouble(key: String, defaultValue: Double): Double
-
def
getInt(key: String, defaultValue: Int): Int
-
def
getLong(key: String, defaultValue: Long): Long
-
def
getOption(key: String): Option[String]
-
def
getScheme(): String
-
def
h2oCluster: Option[String]
-
def
h2oClusterHost: Option[String]
-
def
h2oClusterPort: Option[Int]
-
def
h2oDriverPath: Option[String]
-
def
hashCode(): Int
-
def
hashLogin: Boolean
-
def
hdfsConf: Option[String]
-
def
hiveHost: Option[String]
-
def
hiveJdbcUrlPattern: Option[String]
-
def
hivePrincipal: Option[String]
-
def
hiveToken: Option[String]
-
def
icedDir: Option[String]
-
def
initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
-
def
initializeLogIfNecessary(isInterpreter: Boolean): Unit
-
def
internalConfString: String
-
def
internalPortOffset: Int
-
def
isAutoClusterStartUsed: Boolean
-
def
isClusterTopologyListenerEnabled: Boolean
-
def
isDirectIpConfigurationEnabled: Boolean
-
def
isFailOnUnsupportedSparkParamEnabled: Boolean
-
def
isH2OReplEnabled: Boolean
-
def
isInsecureXGBoostAllowed: Boolean
-
final
def
isInstanceOf[T0]: Boolean
-
def
isInternalSecureConnectionsEnabled: Boolean
-
def
isKerberizedHiveEnabled: Boolean
-
def
isKillOnUnhealthyClusterEnabled: Boolean
-
def
isManualClusterStartUsed: Boolean
-
def
isProgressBarEnabled: Boolean
-
def
isSparkVersionCheckEnabled: Boolean
-
def
isSslCertificateVerificationInInternalRestConnectionsEnabled: Boolean
-
def
isSslHostnameVerificationInInternalRestConnectionsEnabled: Boolean
-
def
isTraceEnabled(): Boolean
-
def
jks: Option[String]
-
def
jksAlias: Option[String]
-
def
jksPass: Option[String]
-
def
kerberosKeytab: Option[String]
-
def
kerberosLogin: Boolean
-
def
kerberosPrincipal: Option[String]
-
def
ldapLogin: Boolean
-
def
log: Logger
-
def
logDebug(msg: ⇒ String, throwable: Throwable): Unit
-
def
logDebug(msg: ⇒ String): Unit
-
def
logDir: Option[String]
-
def
logError(msg: ⇒ String, throwable: Throwable): Unit
-
def
logError(msg: ⇒ String): Unit
-
def
logInfo(msg: ⇒ String, throwable: Throwable): Unit
-
def
logInfo(msg: ⇒ String): Unit
-
def
logLevel: String
-
def
logName: String
-
def
logTrace(msg: ⇒ String, throwable: Throwable): Unit
-
def
logTrace(msg: ⇒ String): Unit
-
def
logWarning(msg: ⇒ String, throwable: Throwable): Unit
-
def
logWarning(msg: ⇒ String): Unit
-
def
loginConf: Option[String]
-
def
maxParallelScalaCellJobs: Int
-
def
mojoDestroyTimeout: Int
-
final
def
ne(arg0: AnyRef): Boolean
-
def
nodeNetworkMask: Option[String]
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
nthreads: Int
-
def
numH2OWorkers: Option[Int]
-
def
numRddRetries: Int
-
def
password: Option[String]
-
def
remove(key: String): H2OConf
-
def
restApiTimeout: Int
-
def
runAsUser: Option[String]
-
def
runsInExternalClusterMode: Boolean
-
def
runsInInternalClusterMode: Boolean
-
def
scalaIntDefaultNum: Int
-
def
set(key: String, value: Boolean): H2OConf
-
def
set(key: String, value: String): H2OConf
-
def
setAll(settings: Traversable[(String, String)]): H2OConf
-
def
setAutoFlowSslDisabled(): H2OConf
-
def
setAutoFlowSslEnabled(): H2OConf
-
def
setBackendClusterMode(backendClusterMode: String): H2OConf
-
def
setBackendHeartbeatInterval(interval: Int): H2OConf
-
def
setBasePort(port: Int): H2OConf
-
def
setClientCheckRetryTimeout(timeout: Int): H2OConf
-
def
setClientFlowBaseurlOverride(baseUrl: String): H2OConf
-
def
setClientIp(ip: String): H2OConf
-
def
setClientNetworkMask(mask: String): H2OConf
-
def
setClientVerboseDisabled(): H2OConf
-
def
setClientVerboseEnabled(): H2OConf
-
def
setClientWebPort(port: Int): H2OConf
-
def
setCloudName(cloudName: String): H2OConf
-
def
setCloudTimeout(timeout: Int): H2OConf
-
def
setClusterInfoFile(path: String): H2OConf
-
def
setClusterSize(clusterSize: Int): H2OConf
-
def
setClusterStartTimeout(clusterStartTimeout: Int): H2OConf
-
def
setClusterTopologyListenerDisabled(): H2OConf
-
def
setClusterTopologyListenerEnabled(): H2OConf
-
def
setContextPath(contextPath: String): H2OConf
-
def
setDefaultCloudSize(defaultClusterSize: Int): H2OConf
-
def
setDefaultNumReplSessions(numSessions: Int): H2OConf
-
def
setDirectIpConfigurationDisabled(): H2OConf
-
def
setDirectIpConfigurationEnabled(): H2OConf
-
def
setDrddMulFactor(factor: Int): H2OConf
-
def
setExternalAutoStartBackend(backend: String): H2OConf
-
def
setExternalBackendStopTimeout(timeout: Int): H2OConf
-
def
setExternalClusterMode(): H2OConf
-
def
setExternalCommunicationCompression(compressionType: String): H2OConf
-
def
setExternalExtraJars(paths: Seq[String]): H2OConf
-
def
setExternalExtraJars(paths: ArrayList[String]): H2OConf
-
def
setExternalExtraJars(commaSeparatedPaths: String): H2OConf
-
def
setExternalExtraMemoryPercent(memoryPercent: Int): H2OConf
-
def
setExternalH2ODriverIf(iface: String): H2OConf
-
def
setExternalH2ODriverPort(port: Int): H2OConf
-
def
setExternalH2ODriverPortRange(portRange: String): H2OConf
-
def
setExternalHadoopExecutable(executable: String): H2OConf
-
def
setExternalK8sDockerImage(name: String): H2OConf
-
def
setExternalK8sDomain(domain: String): H2OConf
-
def
setExternalK8sH2OApiPort(port: Int): H2OConf
-
def
setExternalK8sH2OLabel(label: String): H2OConf
-
def
setExternalK8sH2OServiceName(serviceName: String): H2OConf
-
def
setExternalK8sH2OStatefulsetName(statefulsetName: String): H2OConf
-
def
setExternalK8sNamespace(namespace: String): H2OConf
-
def
setExternalK8sServiceTimeout(timeout: Int): H2OConf
-
def
setExternalMemory(memory: String): H2OConf
-
def
setExtraClusterNodesDisabled(): H2OConf
-
def
setExtraClusterNodesEnabled(): H2OConf
-
def
setExtraProperties(extraProperties: String): H2OConf
-
def
setFailOnUnsupportedSparkParamDisabled(): H2OConf
-
def
setFailOnUnsupportedSparkParamEnabled(): H2OConf
-
def
setFlowDir(dir: String): H2OConf
-
def
setFlowExtraHttpHeaders(headers: Map[String, String]): H2OConf
-
def
setFlowExtraHttpHeaders(headers: HashMap[String, String]): H2OConf
-
def
setFlowExtraHttpHeaders(headers: String): H2OConf
-
def
setFlowProxyRequestMaxSize(value: Int): H2OConf
-
def
setFlowProxyResponseMaxSize(value: Int): H2OConf
-
def
setFlowScalaCellAsyncDisabled(): H2OConf
-
def
setFlowScalaCellAsyncEnabled(): H2OConf
-
def
setH2OCluster(hostPort: String): H2OConf
-
def
setH2OCluster(host: String, port: Int): H2OConf
-
def
setH2ODriverPath(path: String): H2OConf
-
def
setHDFSOutputDir(dir: String): H2OConf
-
def
setHashLoginDisabled(): H2OConf
-
def
setHashLoginEnabled(): H2OConf
-
def
setHdfsConf(conf: Configuration): H2OConf
-
def
setHdfsConf(path: String): H2OConf
-
def
setHiveHost(host: String): H2OConf
-
def
setHiveJdbcUrlPattern(pattern: String): H2OConf
-
def
setHivePrincipal(principal: String): H2OConf
-
def
setHiveToken(token: String): H2OConf
-
def
setIcedDir(dir: String): H2OConf
-
def
setInsecureXGBoostAllowed(): H2OConf
-
def
setInsecureXGBoostDenied(): H2OConf
-
def
setInternalClusterMode(): H2OConf
-
def
setInternalPortOffset(offset: Int): H2OConf
-
def
setInternalSecureConnectionsDisabled(): H2OConf
-
def
setInternalSecureConnectionsEnabled(): H2OConf
-
def
setJks(path: String): H2OConf
-
def
setJksAlias(alias: String): H2OConf
-
def
setJksPass(password: String): H2OConf
-
def
setKerberizedHiveDisabled(): H2OConf
-
def
setKerberizedHiveEnabled(): H2OConf
-
def
setKerberosKeytab(path: String): H2OConf
-
def
setKerberosLoginDisabled(): H2OConf
-
def
setKerberosLoginEnabled(): H2OConf
-
def
setKerberosPrincipal(principal: String): H2OConf
-
def
setKillOnUnhealthyClusterDisabled(): H2OConf
-
def
setKillOnUnhealthyClusterEnabled(): H2OConf
-
def
setLdapLoginDisabled(): H2OConf
-
def
setLdapLoginEnabled(): H2OConf
-
def
setLogDir(dir: String): H2OConf
-
def
setLogLevel(level: String): H2OConf
-
def
setLoginConf(filePath: String): H2OConf
-
def
setMaxParallelScalaCellJobs(limit: Int): H2OConf
-
def
setMojoDestroyTimeout(timeoutInMilliseconds: Int): H2OConf
-
def
setNodeNetworkMask(mask: String): H2OConf
-
def
setNthreads(numThreads: Int): H2OConf
-
def
setNumH2OWorkers(numWorkers: Int): H2OConf
-
def
setNumRddRetries(retries: Int): H2OConf
-
def
setPassword(password: String): H2OConf
-
def
setProgressBarDisabled(): H2OConf
-
def
setProgressBarEnabled(): H2OConf
-
def
setReplDisabled(): H2OConf
-
def
setReplEnabled(): H2OConf
-
def
setRestApiTimeout(timeout: Int): H2OConf
-
def
setRunAsUser(user: String): H2OConf
-
def
setSparkVersionCheckDisabled(): H2OConf
-
def
setSparkVersionCheckEnabled(): H2OConf
-
def
setSpreadRddRetriesTimeout(timeout: Int): H2OConf
-
def
setSslCACert(path: String): H2OConf
-
def
setSslCertificateVerificationInInternalRestConnectionsDisabled(): H2OConf
-
def
setSslCertificateVerificationInInternalRestConnectionsEnabled(): H2OConf
-
def
setSslConf(path: String): H2OConf
-
def
setSslHostnameVerificationInInternalRestConnectionsDisabled(): H2OConf
-
def
setSslHostnameVerificationInInternalRestConnectionsEnabled(): H2OConf
-
def
setStacktraceCollectorInterval(interval: Int): H2OConf
-
def
setSubseqTries(subseqTriesNum: Int): H2OConf
-
def
setUserName(username: String): H2OConf
-
def
setVerifySslCertificates(verify: Boolean): H2OConf
-
def
setYARNQueue(queueName: String): H2OConf
-
val
sparkConf: SparkConf
-
def
spreadRddRetriesTimeout: Int
-
def
sslCACert: Option[String]
-
def
sslConf: Option[String]
-
def
stacktraceCollectorInterval: Int
-
def
subseqTries: Int
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
useAutoClusterStart(): H2OConf
-
def
useManualClusterStart(): H2OConf
-
def
userName: Option[String]
-
def
verifySslCertificates: Boolean
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Logging
Inherited from Serializable
Inherited from Serializable
Inherited from Logging
Inherited from AnyRef
Inherited from Any
Configuration holder which is representing properties passed from user to Sparkling Water.