H2OContextExtensions

Value Members

final def !=(arg0: Any): Boolean

Definition Classes
AnyRef → Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: Any): Boolean

Definition Classes
AnyRef → Any
object LoggingLevel extends Enumeration

Definition Classes
RestCommunication
final def asInstanceOf[T0]: T0

Definition Classes
Any
def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit

Definition Classes
RestCommunication
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
def collectPropertiesDoc(): Map[String, String]

Attributes
protected
def convertLabel(label: String): String

Attributes
protected
Definition Classes
K8sUtils
def delete(endpoint: URI, suffix: String, conf: H2OConf): Unit

endpoint
An address of H2O node with exposed REST endpoint
suffix
REST relative path representing a specific call
conf
H2O conf object

Attributes
protected
Definition Classes
RestCommunication
def delete[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false)(implicit arg0: ClassTag[ResultType]): ResultType

ResultType
A type that the result will be deserialized to
endpoint
An address of H2O node with exposed REST endpoint
suffix
REST relative path representing a specific call
conf
H2O conf object
params
Query parameters
skippedFields
The list of field specifications that are skipped during deserialization. The specification consists of the class containing the field and the field name.
returns
A deserialized object

Definition Classes
RestCommunication
def deleteH2OHeadlessService(client: KubernetesClient, conf: H2OConf): Unit

Attributes
protected
Definition Classes
K8sHeadlessService
def deleteH2OStatefulSet(client: KubernetesClient, conf: H2OConf): Unit

Attributes
protected
Definition Classes
K8sH2OStatefulSet
def downloadBinaryURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

Attributes
protected
Definition Classes
RestCommunication
def downloadH2OLogs(destinationDir: String, logContainer: String): String
def downloadStringURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

Attributes
protected
Definition Classes
RestCommunication
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
def getAndVerifyWorkerNodes(conf: H2OConf): Array[NodeDesc]

Attributes
protected
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def getClusterEndpoint(conf: H2OConf): URI

Definition Classes
RestApiUtils
def getClusterInfo(conf: H2OConf): CloudV3

Definition Classes
RestApiUtils
def getH2OHeadlessServiceURL(conf: H2OConf): String

Attributes
protected
Definition Classes
K8sHeadlessService
def getLogLevel(conf: H2OConf): String

Definition Classes
RestApiUtils
def getNodes(cloudV3: CloudV3): Array[NodeDesc]

Definition Classes
RestApiUtils
def getNodes(conf: H2OConf): Array[NodeDesc]

Definition Classes
RestApiUtils
def getPingInfo(conf: H2OConf): PingV3

Definition Classes
RestApiUtils
def getTimeZone(conf: H2OConf): String

Definition Classes
RestApiUtils
def hashCode(): Int

Definition Classes
AnyRef → Any
def importHiveTable(database: String = HiveTableImporter.DEFAULT_DATABASE, table: String, partitions: Array[Array[String]] = null, allowMultiFormat: Boolean = false): H2OFrame
def initializeLogIfNecessary(isInterpreter: Boolean): Unit

Attributes
protected
Definition Classes
Logging
def insert(endpoint: URI, suffix: String, conf: H2OConf, streamWrapper: (OutputStream) ⇒ OutputStream = identity, params: Map[String, Any] = Map.empty): OutputStream

endpoint
An address of H2O node with exposed REST endpoint
suffix
REST relative path representing a specific call
conf
H2O conf object
params
Query parameters
returns
HttpUrlConnection facilitating the insertion and holding the outputStream

Attributes
protected
Definition Classes
RestCommunication
def insertToNode(node: NodeDesc, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty): OutputStream

node
H2O node descriptor
suffix
REST relative path representing a specific call
conf
H2O conf object
params
Query parameters
returns
HttpUrlConnection facilitating the insertion and holding the outputStream

Definition Classes
RestCommunication
def installH2OHeadlessService(client: KubernetesClient, conf: H2OConf): Unit

Attributes
protected
Definition Classes
K8sHeadlessService
def installH2OStatefulSet(client: KubernetesClient, conf: H2OConf, headlessServiceURL: String): String

Attributes
protected
Definition Classes
K8sH2OStatefulSet
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
def isPrimitiveType(value: Any): Boolean

Attributes
protected
Definition Classes
RestEncodingUtils
def isTraceEnabled(): Boolean

Attributes
protected
Definition Classes
Logging
def launchShellCommand(cmdToLaunch: Seq[String]): Int

Attributes
protected
Definition Classes
ShellUtils
def log: Logger

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logDebug(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logError(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logInfo(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logName: String

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logTrace(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String, throwable: Throwable): Unit

Attributes
protected
Definition Classes
Logging
def logWarning(msg: ⇒ String): Unit

Attributes
protected
Definition Classes
Logging
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def openURI(uri: String): Unit

Open browser for given address.
Open browser for given address.
uri
address to open in browser, e.g., http://example.com

Attributes
protected
def query[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, confirmationLoggingLevel: LoggingLevel = Info)(implicit arg0: ClassTag[ResultType]): ResultType

ResultType
A type that the result will be deserialized to
endpoint
An address of H2O node with exposed REST endpoint
suffix
REST relative path representing a specific call
conf
H2O conf object
params
Query parameters
skippedFields
The list of field specifications that are skipped during deserialization. The specification consists of the class containing the field and the field name.
returns
A deserialized object

Definition Classes
RestCommunication
def readURLContent(endpoint: URI, requestType: String, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false, file: Option[String], confirmationLoggingLevel: LoggingLevel = Info): InputStream

Attributes
protected
Definition Classes
RestCommunication
def request[ResultType](endpoint: URI, requestType: String, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false, confirmationLoggingLevel: LoggingLevel = Info)(implicit arg0: ClassTag[ResultType]): ResultType

Definition Classes
RestCommunication
def resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI

Definition Classes
RestApiUtils
def setLogLevel(conf: H2OConf, logLevel: String): Unit

Definition Classes
RestApiUtils
def setTimeZone(conf: H2OConf, timezone: String): Unit

Definition Classes
RestApiUtils
def shutdownCluster(conf: H2OConf): Unit

Definition Classes
RestApiUtils
def startExternalH2OOnKubernetes(conf: H2OConf): Unit

Definition Classes
K8sExternalBackendClient
def stopExternalH2OOnKubernetes(conf: H2OConf): Unit

Definition Classes
K8sExternalBackendClient
def stringify(value: Any): String

Attributes
protected
Definition Classes
RestEncodingUtils
def stringifyArray(arr: Array[_]): String

Attributes
protected
Definition Classes
RestEncodingUtils
def stringifyMap(map: Map[_, _]): String

Attributes
protected
Definition Classes
RestEncodingUtils
def stringifyPair(pair: Tuple2[_, _]): String

Attributes
protected
Definition Classes
RestEncodingUtils
def stringifyParams(params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false): String

Attributes
protected
Definition Classes
RestEncodingUtils
def stringifyPrimitiveParam(value: Any): String

Attributes
protected
Definition Classes
RestEncodingUtils
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
def toString(): String

Definition Classes
AnyRef → Any
def update[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false)(implicit arg0: ClassTag[ResultType]): ResultType

ResultType
A type that the result will be deserialized to
endpoint
An address of H2O node with exposed REST endpoint
suffix
REST relative path representing a specific call
conf
H2O conf object
params
Query parameters
skippedFields
The list of field specifications that are skipped during deserialization. The specification consists of the class containing the field and the field name.
returns
A deserialized object

Definition Classes
RestCommunication
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def withConversionDebugPrints(sc: SparkContext, conversionName: String, block: ⇒ H2OFrame): H2OFrame

Attributes
protected

Related Doc: package utils

trait H2OContextExtensions extends RestCommunication with RestApiUtils with ShellUtils with K8sExternalBackendClient

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

object LoggingLevel extends Enumeration

final def asInstanceOf[T0]: T0

def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit

def clone(): AnyRef

def collectPropertiesDoc(): Map[String, String]

def convertLabel(label: String): String

def delete(endpoint: URI, suffix: String, conf: H2OConf): Unit

def delete[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false)(implicit arg0: ClassTag[ResultType]): ResultType

def deleteH2OHeadlessService(client: KubernetesClient, conf: H2OConf): Unit

def deleteH2OStatefulSet(client: KubernetesClient, conf: H2OConf): Unit

def downloadBinaryURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

def downloadH2OLogs(destinationDir: String, logContainer: String): String

def downloadStringURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

def getAndVerifyWorkerNodes(conf: H2OConf): Array[NodeDesc]

final def getClass(): Class[_]

def getClusterEndpoint(conf: H2OConf): URI

def getClusterInfo(conf: H2OConf): CloudV3

def getH2OHeadlessServiceURL(conf: H2OConf): String

def getLogLevel(conf: H2OConf): String

def getNodes(cloudV3: CloudV3): Array[NodeDesc]

def getNodes(conf: H2OConf): Array[NodeDesc]

def getPingInfo(conf: H2OConf): PingV3

def getTimeZone(conf: H2OConf): String

def hashCode(): Int

def importHiveTable(database: String = HiveTableImporter.DEFAULT_DATABASE, table: String, partitions: Array[Array[String]] = null, allowMultiFormat: Boolean = false): H2OFrame

def initializeLogIfNecessary(isInterpreter: Boolean): Unit

def insert(endpoint: URI, suffix: String, conf: H2OConf, streamWrapper: (OutputStream) ⇒ OutputStream = identity, params: Map[String, Any] = Map.empty): OutputStream

def insertToNode(node: NodeDesc, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty): OutputStream

def installH2OHeadlessService(client: KubernetesClient, conf: H2OConf): Unit

def installH2OStatefulSet(client: KubernetesClient, conf: H2OConf, headlessServiceURL: String): String

final def isInstanceOf[T0]: Boolean

def isPrimitiveType(value: Any): Boolean

def isTraceEnabled(): Boolean

def launchShellCommand(cmdToLaunch: Seq[String]): Int

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

final def ne(arg0: AnyRef): Boolean

final def notify(): Unit

final def notifyAll(): Unit

def openURI(uri: String): Unit

def query[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, confirmationLoggingLevel: LoggingLevel = Info)(implicit arg0: ClassTag[ResultType]): ResultType

def readURLContent(endpoint: URI, requestType: String, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false, file: Option[String], confirmationLoggingLevel: LoggingLevel = Info): InputStream

def resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI

def setLogLevel(conf: H2OConf, logLevel: String): Unit

def setTimeZone(conf: H2OConf, timezone: String): Unit

def shutdownCluster(conf: H2OConf): Unit

def startExternalH2OOnKubernetes(conf: H2OConf): Unit

def stopExternalH2OOnKubernetes(conf: H2OConf): Unit

def stringify(value: Any): String

def stringifyArray(arr: Array[_]): String

def stringifyMap(map: Map[_, _]): String

def stringifyPair(pair: Tuple2[_, _]): String

def stringifyParams(params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false): String

def stringifyPrimitiveParam(value: Any): String

final def synchronized[T0](arg0: ⇒ T0): T0

def toString(): String

def update[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false)(implicit arg0: ClassTag[ResultType]): ResultType

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit