Class/Object

ai.h2o.sparkling

H2OContext

Related Docs: object H2OContext | package sparkling

Permalink

class H2OContext extends H2OContextExtensions

Create new H2OContext based on provided H2O configuration

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

Value Members

  1. final def !=(arg0: Any): Boolean

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

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

    Permalink
    Definition Classes
    AnyRef → Any
  4. object LoggingLevel extends Enumeration

    Permalink
    Definition Classes
    RestCommunication
  5. def asH2OFrame(s: String): H2OFrame

    Permalink

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

  6. def asH2OFrame(ds: SupportedDataset, frameName: Option[String]): H2OFrame

    Permalink
  7. def asH2OFrame(ds: SupportedDataset, frameName: String): H2OFrame

    Permalink
  8. def asH2OFrame(ds: SupportedDataset): H2OFrame

    Permalink

    Transforms Dataset[Supported type] to H2OFrame

  9. def asH2OFrame(df: DataFrame, frameName: Option[String]): H2OFrame

    Permalink
  10. def asH2OFrame(df: DataFrame, frameName: String): H2OFrame

    Permalink
  11. def asH2OFrame(df: DataFrame): H2OFrame

    Permalink

    Transform DataFrame to H2OFrame

  12. def asH2OFrame(rdd: SupportedRDD, frameName: Option[String]): H2OFrame

    Permalink
  13. def asH2OFrame(rdd: SupportedRDD, frameName: String): H2OFrame

    Permalink
  14. def asH2OFrame(rdd: SupportedRDD): H2OFrame

    Permalink

    Transforms RDD[Supported type] to H2OFrame

  15. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  16. 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] }

    Permalink

    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)

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

    Permalink

    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.

  18. def asSparkFrame(s: String): DataFrame

    Permalink
  19. def asSparkFrame(s: String, copyMetadata: Boolean): DataFrame

    Permalink
  20. def asSparkFrame(fr: H2OFrame, copyMetadata: Boolean = true): DataFrame

    Permalink
  21. val backend: SparklingBackend

    Permalink

    Used backend

    Used backend

    Attributes
    protected
  22. def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit

    Permalink
    Definition Classes
    RestCommunication
  23. def clone(): AnyRef

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

    Permalink
    Attributes
    protected
    Definition Classes
    H2OContextExtensions
  25. def convertLabel(label: String): String

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

    Permalink

    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
  27. 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

    Permalink

    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
  28. def deleteH2OHeadlessService(client: KubernetesClient, conf: H2OConf): Unit

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

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

    Permalink
    Attributes
    protected
    Definition Classes
    RestCommunication
  31. def downloadH2OLogs(destinationDir: String, logContainer: String): String

    Permalink
    Definition Classes
    H2OContextExtensions
  32. def downloadStringURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

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

    Permalink
    Definition Classes
    AnyRef
  34. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  35. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  36. def flowURL(): String

    Permalink
  37. def getAndVerifyWorkerNodes(conf: H2OConf): Array[NodeDesc]

    Permalink
    Attributes
    protected
    Definition Classes
    H2OContextExtensions
  38. final def getClass(): Class[_]

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

    Permalink
    Definition Classes
    RestApiUtils
  40. def getClusterInfo(conf: H2OConf): CloudV3

    Permalink
    Definition Classes
    RestApiUtils
  41. def getConf: H2OConf

    Permalink

    Return a copy of this H2OContext's configuration.

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

  42. def getH2OHeadlessServiceURL(conf: H2OConf): String

    Permalink
    Attributes
    protected
    Definition Classes
    K8sHeadlessService
  43. def getH2OLogLevel(): String

    Permalink
  44. def getH2ONodes(): Array[NodeDesc]

    Permalink
  45. def getLogLevel(conf: H2OConf): String

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

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

    Permalink
    Definition Classes
    RestApiUtils
  48. def getPingInfo(conf: H2OConf): PingV3

    Permalink
    Definition Classes
    RestApiUtils
  49. def getTimeZone(conf: H2OConf): String

    Permalink
    Definition Classes
    RestApiUtils
  50. def h2oLocalClient: String

    Permalink

    Returns location of REST API of H2O client

  51. def h2oLocalClientIp: String

    Permalink

    Returns IP of H2O client

  52. def h2oLocalClientPort: Int

    Permalink

    Returns port where H2O REST API is exposed

  53. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  54. object implicits extends H2OContextImplicits with Serializable

    Permalink

    Define implicits available via h2oContext.implicits._

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

    Permalink
    Definition Classes
    H2OContextExtensions
  56. def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  57. def initializeLogIfNecessary(isInterpreter: Boolean): Unit

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

    Permalink

    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
  59. def insertToNode(node: NodeDesc, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty): OutputStream

    Permalink

    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
  60. def installH2OHeadlessService(client: KubernetesClient, conf: H2OConf): Unit

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

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

    Permalink
    Definition Classes
    Any
  63. def isPrimitiveType(value: Any): Boolean

    Permalink
    Attributes
    protected
    Definition Classes
    RestEncodingUtils
  64. def isStopped(): Boolean

    Permalink
  65. def isTraceEnabled(): Boolean

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

    Permalink
    Attributes
    protected
    Definition Classes
    ShellUtils
  67. def log: Logger

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

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

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

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

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

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

    Permalink
    Attributes
    protected
    Definition Classes
    Logging
  74. def logName: String

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

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

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

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

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

    Permalink
    Definition Classes
    AnyRef
  80. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  81. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  82. def openFlow(): Unit

    Permalink

    Open H2O Flow running in this client.

  83. def openURI(uri: String): Unit

    Permalink

    Open browser for given address.

    Open browser for given address.

    uri

    address to open in browser, e.g., http://example.com

    Attributes
    protected
    Definition Classes
    H2OContextExtensions
  84. 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

    Permalink

    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
  85. 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

    Permalink
    Attributes
    protected
    Definition Classes
    RestCommunication
  86. 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

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

    Permalink
    Definition Classes
    RestApiUtils
  88. def setH2OLogLevel(level: String): Unit

    Permalink
  89. def setLogLevel(conf: H2OConf, logLevel: String): Unit

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

    Permalink
    Definition Classes
    RestApiUtils
  91. def shutdownCluster(conf: H2OConf): Unit

    Permalink
    Definition Classes
    RestApiUtils
  92. val sparkContext: SparkContext

    Permalink
  93. def startExternalH2OOnKubernetes(conf: H2OConf): Unit

    Permalink
    Definition Classes
    K8sExternalBackendClient
  94. def stop(stopSparkContext: Boolean = false): Unit

    Permalink

    Stops H2O context.

    Stops H2O context.

    stopSparkContext

    stop also spark context

  95. def stopExternalH2OOnKubernetes(conf: H2OConf): Unit

    Permalink
    Definition Classes
    K8sExternalBackendClient
  96. def stringify(value: Any): String

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

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

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

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

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

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

    Permalink
    Definition Classes
    AnyRef
  103. def toString(): String

    Permalink
    Definition Classes
    H2OContext → AnyRef → Any
  104. 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

    Permalink

    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
  105. def visibleFlowURL(): String

    Permalink
  106. final def wait(): Unit

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

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

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

    Permalink
    Attributes
    protected
    Definition Classes
    H2OContextExtensions

Inherited from H2OContextExtensions

Inherited from K8sExternalBackendClient

Inherited from K8sH2OStatefulSet

Inherited from K8sHeadlessService

Inherited from K8sUtils

Inherited from ShellUtils

Inherited from RestApiUtils

Inherited from RestCommunication

Inherited from RestEncodingUtils

Inherited from Logging

Inherited from Serializable

Inherited from Serializable

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped