Packages

t

ai.h2o.sparkling.backend.utils

H2OContextExtensions

trait H2OContextExtensions extends RestCommunication with RestApiUtils with ShellUtils

Self Type
H2OContext
Linear Supertypes
ShellUtils, RestApiUtils, RestCommunication, RestEncodingUtils, Logging, Serializable, Serializable, Logging, AnyRef, Any
Known Subclasses
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. H2OContextExtensions
  2. ShellUtils
  3. RestApiUtils
  4. RestCommunication
  5. RestEncodingUtils
  6. Logging
  7. Serializable
  8. Serializable
  9. Logging
  10. AnyRef
  11. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit
    Definition Classes
    RestCommunication
  2. 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
  3. def downloadH2OLogs(destinationDir: String, logContainer: String): String
  4. def getClusterEndpoint(conf: H2OConf): URI
    Definition Classes
    RestApiUtils
  5. def getClusterInfo(conf: H2OConf): CloudV3
    Definition Classes
    RestApiUtils
  6. def getLogLevel(conf: H2OConf): String
    Definition Classes
    RestApiUtils
  7. def getNodes(cloudV3: CloudV3): Array[NodeDesc]
    Definition Classes
    RestApiUtils
  8. def getNodes(conf: H2OConf): Array[NodeDesc]
    Definition Classes
    RestApiUtils
  9. def getPingInfo(conf: H2OConf): PingV3
    Definition Classes
    RestApiUtils
  10. def getTimeZone(conf: H2OConf): String
    Definition Classes
    RestApiUtils
  11. def importHiveTable(database: String = HiveTableImporter.DEFAULT_DATABASE, table: String, partitions: Array[Array[String]] = null, allowMultiFormat: Boolean = false): H2OFrame
  12. 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
  13. 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
  14. 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
  15. def resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI
    Definition Classes
    RestApiUtils
  16. def setLogLevel(conf: H2OConf, logLevel: String): Unit
    Definition Classes
    RestApiUtils
  17. def setTimeZone(conf: H2OConf, timezone: String): Unit
    Definition Classes
    RestApiUtils
  18. def shutdownCluster(conf: H2OConf): Unit
    Definition Classes
    RestApiUtils
  19. 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
  20. object LoggingLevel extends Enumeration
    Definition Classes
    RestCommunication