Packages

class H2OContext extends H2OContextExtensions

Create new H2OContext based on provided H2O configuration

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

Value Members

  1. def asH2OFrame(s: String): H2OFrame

    Create a new H2OFrame based on existing Frame referenced by its id.

  2. def asH2OFrame(ds: SupportedDataset, frameName: Option[String]): H2OFrame
  3. def asH2OFrame(ds: SupportedDataset, frameName: String): H2OFrame
  4. def asH2OFrame(ds: SupportedDataset): H2OFrame

    Transforms Dataset[Supported type] to H2OFrame

  5. def asH2OFrame(df: DataFrame, frameName: Option[String] = None, featureColumns: Option[Seq[String]] = None): H2OFrame
  6. def asH2OFrame(df: DataFrame, frameName: String): H2OFrame
  7. def asH2OFrame(df: DataFrame, featureColumns: Seq[String]): H2OFrame
  8. def asH2OFrame(df: DataFrame): H2OFrame

    Transform DataFrame to H2OFrame

  9. def asH2OFrame(rdd: SupportedRDD, frameName: Option[String]): H2OFrame
  10. def asH2OFrame(rdd: SupportedRDD, frameName: String): H2OFrame
  11. def asH2OFrame(rdd: SupportedRDD): H2OFrame

    Transforms RDD[Supported type] to H2OFrame

  12. def asRDD[A <: Product](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): AnyRef { def apply(fr: ai.h2o.sparkling.H2OFrame): org.apache.spark.rdd.RDD[A] }

    A generic convert of Frame into Product RDD type

    A generic convert of Frame into Product RDD type

    Consider using asH2OFrame since asRDD has several limitations such as that asRDD can't be used in Spark REPL in case we are RDD[T] where T is class defined in REPL. This is because class T is created as inner class and we are not able to create instance of class T without outer scope - which is impossible to get.

    This code: hc.asRDD[PUBDEV458Type](rdd) will need to be call as hc.asRDD[PUBDEV458Type].apply(rdd)

  13. def asRDD[A <: Product](fr: H2OFrame)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): RDD[A]

    Convert given H2O frame into a Product RDD type

    Convert given H2O frame into a Product RDD type

    Consider using asH2OFrame since asRDD has several limitations such as that asRDD can't be used in Spark REPL in case we are RDD[T] where T is class defined in REPL. This is because class T is created as inner class and we are not able to create instance of class T without outer scope - which is impossible to get.

  14. def asSparkFrame(s: String): DataFrame
  15. def asSparkFrame(s: String, copyMetadata: Boolean): DataFrame
  16. def asSparkFrame(fr: H2OFrame, copyMetadata: Boolean = true): DataFrame
  17. def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit
    Definition Classes
    RestCommunication
  18. 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
  19. def downloadH2OLogs(destinationDir: String, logContainer: String): String
    Definition Classes
    H2OContextExtensions
  20. def flowURL(): String
  21. def getClusterEndpoint(conf: H2OConf): URI
    Definition Classes
    RestApiUtils
  22. def getClusterInfo(conf: H2OConf): CloudV3
    Definition Classes
    RestApiUtils
  23. def getConf: H2OConf

    Return a copy of this H2OContext's configuration.

    Return a copy of this H2OContext's configuration. The configuration cannot be changed at runtime.

  24. def getH2OLogLevel(): String
  25. def getH2ONodes(): Array[NodeDesc]
  26. def getLogLevel(conf: H2OConf): String
    Definition Classes
    RestApiUtils
  27. def getNodes(cloudV3: CloudV3): Array[NodeDesc]
    Definition Classes
    RestApiUtils
  28. def getNodes(conf: H2OConf): Array[NodeDesc]
    Definition Classes
    RestApiUtils
  29. def getPingInfo(conf: H2OConf): PingV3
    Definition Classes
    RestApiUtils
  30. def getTimeZone(conf: H2OConf): String
    Definition Classes
    RestApiUtils
  31. def h2oLocalClient: String

    Returns location of REST API of H2O client

  32. def h2oLocalClientIp: String

    Returns IP of H2O client

  33. def h2oLocalClientPort: Int

    Returns port where H2O REST API is exposed

  34. def importHiveTable(database: String = HiveTableImporter.DEFAULT_DATABASE, table: String, partitions: Array[Array[String]] = null, allowMultiFormat: Boolean = false): H2OFrame
    Definition Classes
    H2OContextExtensions
  35. 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
  36. def isStopped(): Boolean
  37. def openFlow(): Unit

    Open H2O Flow running in this client.

  38. 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
  39. 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
  40. def resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI
    Definition Classes
    RestApiUtils
  41. def setH2OLogLevel(level: String): Unit
  42. def setLogLevel(conf: H2OConf, logLevel: String): Unit
    Definition Classes
    RestApiUtils
  43. def setTimeZone(conf: H2OConf, timezone: String): Unit
    Definition Classes
    RestApiUtils
  44. def shutdownCluster(conf: H2OConf): Unit
    Definition Classes
    RestApiUtils
  45. val sparkContext: SparkContext
  46. def stop(stopSparkContext: Boolean = false): Unit

    Stops H2O context.

    Stops H2O context.

    stopSparkContext

    stop also spark context

  47. def toString(): String
    Definition Classes
    H2OContext → AnyRef → Any
  48. 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
  49. def visibleFlowURL(): String
  50. object implicits extends H2OContextImplicits with Serializable

    Define implicits available via h2oContext.implicits._

  51. object LoggingLevel extends Enumeration
    Definition Classes
    RestCommunication