org.apache.spark.h2o

H2OContext

class H2OContext extends Logging with H2OConf with Serializable

Simple H2O context motivated by SQLContext.

It provides implicit conversion from RDD -> H2OLikeRDD and back.

Self Type
H2OContext
Linear Supertypes
Serializable, Serializable, H2OConf, Logging, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. H2OContext
  2. Serializable
  3. Serializable
  4. H2OConf
  5. Logging
  6. AnyRef
  7. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Instance Constructors

  1. new H2OContext(sparkContext: JavaSparkContext)

    Supports call from java environments.

  2. new H2OContext(sparkContext: SparkContext)

Value Members

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

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

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

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

    Definition Classes
    Any
  6. def asDataFrame(s: String)(implicit sqlContext: SQLContext): DataFrame

  7. def asDataFrame(fr: H2OFrame)(implicit sqlContext: SQLContext): DataFrame

  8. def asH2OFrame(fr: Frame): H2OFrame

    Create a new H2OFrame based on existing Frame

  9. def asH2OFrame(s: String): H2OFrame

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

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

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

  12. def asH2OFrame(df: DataFrame): H2OFrame

    Transform DataFrame to H2OFrame

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

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

  15. def asH2OFrame(rdd: SupportedRDD): H2OFrame

    Transforms RDD[Supported type] to H2OFrame

  16. def asH2OFrameFromRDDBool(rdd: JavaRDD[Boolean], frameName: String): H2OFrame

    Conversion from RDD[Boolean] to H2O's DataFrame

  17. def asH2OFrameFromRDDBoolKey(rdd: JavaRDD[Boolean], frameName: String): Key[Frame]

    Returns key of the H2O's DataFrame conversed from RDD[Boolean]

  18. def asH2OFrameFromRDDDouble(rdd: JavaRDD[Double], frameName: String): H2OFrame

    Conversion from RDD[Double] to H2O's DataFrame

  19. def asH2OFrameFromRDDDoubleKey(rdd: JavaRDD[Double], frameName: String): Key[Frame]

    Returns key of the H2O's DataFrame conversed from RDD[Double]

  20. def asH2OFrameFromRDDLong(rdd: JavaRDD[Long], frameName: String): H2OFrame

    Conversion from RDD[Long] to H2O's DataFrame

  21. def asH2OFrameFromRDDLongKey(rdd: JavaRDD[Long], frameName: String): Key[Frame]

    Returns key of the H2O's DataFrame conversed from RDD[Long]

  22. def asH2OFrameFromRDDString(rdd: JavaRDD[String], frameName: String): H2OFrame

    Conversion from RDD[String] to H2O's DataFrame

  23. def asH2OFrameFromRDDStringKey(rdd: JavaRDD[String], frameName: String): Key[Frame]

    Returns key of the H2O's DataFrame conversed from RDD[String]

  24. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  25. 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

  26. def buildSparkMajorVersion: String

    Returns Major Spark version for which is this version of Sparkling Water designated.

    Returns Major Spark version for which is this version of Sparkling Water designated.

    For example, for 1.6.1 returns 1.6

    Definition Classes
    H2OConf
  27. def clientBasePort: Int

    Definition Classes
    H2OConf
  28. def clientIcedDir: Option[String]

    Definition Classes
    H2OConf
  29. def clientIp: Option[String]

    Definition Classes
    H2OConf
  30. def clientWebPort: Int

    Definition Classes
    H2OConf
  31. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  32. def cloudName: String

    Definition Classes
    H2OConf
  33. def cloudTimeout: Int

    Definition Classes
    H2OConf
  34. def createH2ORDD[A <: Product](fr: H2OFrame)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): RDD[A]

  35. def createH2OSchemaRDD(fr: H2OFrame)(implicit sqlContext: SQLContext): DataFrame

  36. def defaultCloudSize: Int

    Definition Classes
    H2OConf
  37. def disableGA: Boolean

    Definition Classes
    H2OConf
  38. def drddMulFactor: Int

    Definition Classes
    H2OConf
  39. final def eq(arg0: AnyRef): Boolean

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

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

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  42. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  43. def getH2OClientArgs: Array[String]

    Get arguments for H2O client.

    Get arguments for H2O client.

    returns

    array of H2O client arguments.

    Definition Classes
    H2OConf
  44. def getH2ONodeArgs: Array[String]

    Produce arguments for H2O node based on this config.

    Produce arguments for H2O node based on this config.

    returns

    array of H2O launcher command line arguments

    Definition Classes
    H2OConf
  45. def h2oClientLogDir: String

    Definition Classes
    H2OConf
  46. def h2oClientLogLevel: String

    Definition Classes
    H2OConf
  47. def h2oLocalClient: String

  48. def h2oLocalClientIp: String

  49. def h2oLocalClientPort: Int

  50. def h2oNodeLogDir: String

    Definition Classes
    H2OConf
  51. def h2oNodeLogLevel: String

    Definition Classes
    H2OConf
  52. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  53. def hashLogin: Boolean

    Definition Classes
    H2OConf
  54. object implicits extends H2OContextImplicits with Serializable

    Define implicits available via h2oContext.

  55. def isClusterTopologyListenerEnabled: Boolean

    Definition Classes
    H2OConf
  56. def isH2OReplEnabled: Boolean

    Definition Classes
    H2OConf
  57. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  58. def isSparkVersionCheckEnabled: Boolean

    Definition Classes
    H2OConf
  59. def isTraceEnabled(): Boolean

    Attributes
    protected
    Definition Classes
    Logging
  60. def jks: Option[String]

    Definition Classes
    H2OConf
  61. def jksPass: Option[String]

    Definition Classes
    H2OConf
  62. def ldapLogin: Boolean

    Definition Classes
    H2OConf
  63. def log: Logger

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

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

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

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

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

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

    Attributes
    protected
    Definition Classes
    Logging
  70. def logName: String

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

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

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

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

    Attributes
    protected
    Definition Classes
    Logging
  75. def loginConf: Option[String]

    Definition Classes
    H2OConf
  76. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  77. def networkMask: Option[String]

    Definition Classes
    H2OConf
  78. def nodeBasePort: Int

    Definition Classes
    H2OConf
  79. def nodeIcedDir: Option[String]

    Definition Classes
    H2OConf
  80. final def notify(): Unit

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

    Definition Classes
    AnyRef
  82. def nthreads: Int

    Definition Classes
    H2OConf
  83. def numH2OWorkers: Option[Int]

    Definition Classes
    H2OConf
  84. def numRddRetries: Int

    Definition Classes
    H2OConf
  85. def openFlow(): Unit

    Open H2O Flow running in this client.

  86. def scalaIntDefaultNum: Int

    Definition Classes
    H2OConf
  87. val sparkConf: SparkConf

    Definition Classes
    H2OContextH2OConf
  88. val sparkContext: SparkContext

  89. def start(): H2OContext

    Initialize Sparkling H2O and start H2O cloud.

  90. def stop(stopSparkContext: Boolean = false): Unit

    Stops H2O context.

    Stops H2O context.

    Calls System.exit() which kills executor JVM.

  91. def subseqTries: Int

    Definition Classes
    H2OConf
  92. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  93. def toH2OFrameKey(df: DataFrame, frameName: String): Key[Frame]

  94. def toH2OFrameKey(df: DataFrame, frameName: Option[String]): Key[Frame]

  95. def toH2OFrameKey(df: DataFrame): Key[Frame]

    Transform DataFrame to H2OFrame key

  96. def toH2OFrameKey(rdd: SupportedRDD, frameName: String): Key[_]

  97. def toH2OFrameKey(rdd: SupportedRDD, frameName: Option[String]): Key[_]

  98. def toH2OFrameKey(rdd: SupportedRDD): Key[_]

    Transforms RDD[Supported type] to H2OFrame key

  99. def toString(): String

    Definition Classes
    H2OContextH2OConf → AnyRef → Any
  100. def useFlatFile: Boolean

    Definition Classes
    H2OConf
  101. def userName: Option[String]

    Definition Classes
    H2OConf
  102. final def wait(): Unit

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

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

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def asSchemaRDD(fr: H2OFrame)(implicit sqlContext: SQLContext): DataFrame

    Convert given H2O frame into DataFrame type

    Convert given H2O frame into DataFrame type

    Annotations
    @deprecated
    Deprecated

    (Since version Use asDataFrame) 1.3

  2. def start(h2oWorkers: Int): H2OContext

    Initialize Sparkling H2O and start H2O cloud with specified number of workers.

    Initialize Sparkling H2O and start H2O cloud with specified number of workers.

    Annotations
    @deprecated
    Deprecated

    (Since version 1.5.11) Use start() method.

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

    Convert given H2O frame into a RDD type

    Convert given H2O frame into a RDD type

    Annotations
    @deprecated
    Deprecated

    (Since version 0.2.3) Use asRDD instead

Inherited from Serializable

Inherited from Serializable

Inherited from H2OConf

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped