Instance Constructors
-
new
H2OConf(sparkSession: SparkSession)
-
new
H2OConf(sc: SparkContext)
-
new
H2OConf(jsc: JavaSparkContext)
-
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
backendClusterMode: String
-
def
clientBasePort: Int
-
def
clientCheckRetryTimeout: Int
-
def
clientConnectionTimeout: Int
-
def
clientIcedDir: 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
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
externalConfString: String
-
def
externalReadConfirmationTimeout: Int
-
def
externalWriteConfirmationTimeout: Int
-
def
finalize(): Unit
-
def
flowDir: Option[String]
-
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
h2oClientLogDir: Option[String]
-
def
h2oClientLogLevel: String
-
def
h2oCluster: Option[String]
-
def
h2oClusterHost: Option[String]
-
def
h2oClusterPort: Option[Int]
-
def
h2oDriverIf: Option[String]
-
def
h2oDriverPath: Option[String]
-
def
h2oNodeLogDir: Option[String]
-
def
h2oNodeLogLevel: String
-
def
h2oNodeWebEnabled: Boolean
-
def
hashCode(): Int
-
def
hashLogin: Boolean
-
def
healthCheckInterval: Int
-
def
initializeLogIfNecessary(isInterpreter: Boolean): Unit
-
def
internalConfString: String
-
def
isAutoClusterStartUsed: Boolean
-
def
isClusterTopologyListenerEnabled: Boolean
-
def
isFailOnUnsupportedSparkParamEnabled: Boolean
-
def
isH2OReplEnabled: Boolean
-
final
def
isInstanceOf[T0]: Boolean
-
def
isInternalSecureConnectionsEnabled: Boolean
-
def
isKillOnUnhealthyClusterEnabled: Boolean
-
def
isManualClusterStartUsed: Boolean
-
def
isSparkVersionCheckEnabled: Boolean
-
def
isTraceEnabled(): Boolean
-
def
jks: Option[String]
-
def
jksPass: Option[String]
-
def
kerberosLogin: Boolean
-
def
killOnUnhealthyClusterInterval: Int
-
def
ldapLogin: Boolean
-
def
log: Logger
-
def
logDebug(msg: ⇒ String, throwable: Throwable): Unit
-
def
logDebug(msg: ⇒ String): Unit
-
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
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
mapperXmx: String
-
def
maxParallelScalaCellJobs: Int
-
final
def
ne(arg0: AnyRef): Boolean
-
def
nodeBasePort: Int
-
def
nodeIcedDir: Option[String]
-
def
nodeNetworkMask: Option[String]
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
nthreads: Int
-
def
numH2OWorkers: Option[Int]
-
def
numOfExternalH2ONodes: Option[String]
-
def
numRddRetries: Int
-
def
remove(key: String): H2OConf
-
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
setClientCheckRetryTimeout(timeout: Int): H2OConf
-
def
setClientConnectionTimeout(timeout: Int): H2OConf
-
def
setClientIcedDir(icedDir: String): H2OConf
-
def
setClientIp(ip: String): H2OConf
-
def
setClientNetworkMask(mask: String): H2OConf
-
def
setClientPortBase(basePort: Int): H2OConf
-
def
setClientVerboseDisabled(): H2OConf
-
def
setClientVerboseEnabled(): H2OConf
-
def
setCloudName(cloudName: String): H2OConf
-
def
setCloudTimeout(timeout: Int): H2OConf
-
def
setClusterConfigFile(path: String): 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
setDrddMulFactor(factor: Int): H2OConf
-
def
setExternalClusterMode(): H2OConf
-
def
setExternalReadConfirmationTimeout(timeout: Int): H2OConf
-
def
setExternalWriteConfirmationTimeout(timeout: Int): H2OConf
-
def
setFailOnUnsupportedSparkParamDisabled(): H2OConf
-
def
setFailOnUnsupportedSparkParamEnabled(): H2OConf
-
def
setFlatFileDisabled(): H2OConf
-
def
setFlatFileEnabled(): H2OConf
-
def
setFlowDir(dir: String): H2OConf
-
def
setFlowScalaCellAsyncDisabled(): H2OConf
-
def
setFlowScalaCellAsyncEnabled(): H2OConf
-
def
setH2OClientLogDir(dir: String): H2OConf
-
def
setH2OClientLogLevel(level: String): H2OConf
-
def
setH2OCluster(hostPort: String): H2OConf
-
def
setH2OCluster(host: String, port: Int): H2OConf
-
def
setH2ODriverIf(ip: String): H2OConf
-
def
setH2ODriverPath(path: String): H2OConf
-
def
setH2ONodeLogDir(dir: String): H2OConf
-
def
setH2ONodeLogLevel(level: String): H2OConf
-
def
setH2ONodeWebDisabled(): H2OConf
-
def
setH2ONodeWebEnabled(): H2OConf
-
def
setHDFSOutputDir(dir: String): H2OConf
-
def
setHashLoginDisabled(): H2OConf
-
def
setHashLoginEnabled(): H2OConf
-
def
setHealthCheckInterval(interval: Int): H2OConf
-
def
setInternalClusterMode(): H2OConf
-
def
setInternalSecureConnectionsDisabled(): H2OConf
-
def
setInternalSecureConnectionsEnabled(): H2OConf
-
def
setJks(path: String): H2OConf
-
def
setJksPass(password: String): H2OConf
-
def
setKerberosLoginDisabled(): H2OConf
-
def
setKerberosLoginEnabled(): H2OConf
-
def
setKillOnUnhealthyClusterDisabled(): H2OConf
-
def
setKillOnUnhealthyClusterEnabled(): H2OConf
-
def
setKillOnUnhealthyClusterInterval(interval: Int): H2OConf
-
def
setLdapLoginDisabled(): H2OConf
-
def
setLdapLoginEnabled(): H2OConf
-
def
setLoginConf(file: String): H2OConf
-
def
setMapperXmx(mem: String): H2OConf
-
def
setMaxParallelScalaCellJobs(limit: Int): H2OConf
-
def
setNodeBasePort(port: Int): H2OConf
-
def
setNodeIcedDir(dir: String): H2OConf
-
def
setNodeNetworkMask(mask: String): H2OConf
-
def
setNthreads(numThreads: Int): H2OConf
-
def
setNumH2OWorkers(numWorkers: Int): H2OConf
-
def
setNumOfExternalH2ONodes(numOfExternalH2ONodes: Int): H2OConf
-
def
setNumRddRetries(retries: Int): H2OConf
-
def
setReplDisabled(): H2OConf
-
def
setReplEnabled(): H2OConf
-
def
setSparkVersionCheckDisabled(): H2OConf
-
def
setSparkVersionCheckEnable(): H2OConf
-
def
setSslConf(path: String): H2OConf
-
def
setStacktraceCollectorInterval(interval: Int): H2OConf
-
def
setSubseqTries(subseqTriesNum: Int): H2OConf
-
def
setUiUpdateInterval(interval: Int): H2OConf
-
def
setUserName(username: String): H2OConf
-
def
setYARNQueue(queueName: String): H2OConf
-
val
sparkConf: SparkConf
-
def
sslConf: Option[String]
-
def
stacktraceCollectorInterval: Int
-
def
subseqTries: Int
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toString(): String
-
def
uiUpdateInterval: Int
-
def
useAutoClusterStart(): H2OConf
-
def
useFlatFile: Boolean
-
def
useManualClusterStart(): H2OConf
-
def
userName: Option[String]
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from Logging
Inherited from AnyRef
Inherited from Any
Configuration holder which is representing properties passed from user to Sparkling Water.