H2OContext

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

def asDataFrame(s: String)(implicit sqlContext: SQLContext): DataFrame

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

def asH2OFrame(s: String): H2OFrame

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

implicit def asH2OFrame(fr: Frame): H2OFrame

Implicit conversion from Frame to DataFrame

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

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

implicit def asH2OFrame(df: DataFrame): H2OFrame

Implicit conversion from Spark DataFrame to H2O's DataFrame

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

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

def asH2OFrame(rdd: SupportedRDD): H2OFrame

Transforms RDD[Supported type] to H2OFrame

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

Conversion from RDD[Boolean] to H2O's DataFrame

implicit def asH2OFrameFromRDDBool(rdd: RDD[Boolean]): H2OFrame

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

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

implicit def asH2OFrameFromRDDByte(rdd: RDD[Byte]): H2OFrame

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

Conversion from RDD[Double] to H2O's DataFrame

implicit def asH2OFrameFromRDDDouble(rdd: RDD[Double]): H2OFrame

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

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

implicit def asH2OFrameFromRDDLabeledPoint(rdd: RDD[LabeledPoint]): H2OFrame

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

Conversion from RDD[Long] to H2O's DataFrame

implicit def asH2OFrameFromRDDLong(rdd: RDD[Long]): H2OFrame

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

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

implicit def asH2OFrameFromRDDProduct[A <: Product](rdd: RDD[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): H2OFrame

Implicit conversion from RDD[Supported type] to H2OFrame

implicit def asH2OFrameFromRDDShort(rdd: RDD[Short]): H2OFrame

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

Conversion from RDD[String] to H2O's DataFrame

implicit def asH2OFrameFromRDDString(rdd: RDD[String]): H2OFrame

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

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

implicit def asH2OFrameFromRDDTimeStamp(rdd: RDD[Timestamp]): H2OFrame

final def asInstanceOf[T0]: T0

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

def clientBasePort: Int

def clientIcedDir: Option[String]

def clientIp: Option[String]

def clientWebPort: Int

def clone(): AnyRef

def cloudName: String

def cloudTimeout: Int

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

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

def defaultCloudSize: Int

def disableGA: Boolean

def drddMulFactor: Int

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def getH2OClientArgs: Array[String]

Get arguments for H2O client.

def getH2ONodeArgs: Array[String]

Produce arguments for H2O node based on this config.

def h2oClientLogDir: String

def h2oClientLogLevel: String

def h2oLocalClient: String

def h2oLocalClientIp: String

def h2oLocalClientPort: Int

def h2oNodeLogDir: String

def h2oNodeLogLevel: String

def hashCode(): Int

def hashLogin: Boolean

final def isInstanceOf[T0]: Boolean

def isTraceEnabled(): Boolean

def jks: Option[String]

def jksPass: Option[String]

def ldapLogin: Boolean

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

def loginConf: Option[String]

final def ne(arg0: AnyRef): Boolean

def networkMask: Option[String]

def nodeBasePort: Int

def nodeIcedDir: Option[String]

final def notify(): Unit

final def notifyAll(): Unit

def nthreads: Int

def numH2OWorkers: Option[Int]

def numRddRetries: Int

def openFlow(): Unit

Open H2O Flow running in this client.

def scalaIntDefaultNum: Int

val sparkConf: SparkConf

val sparkContext: SparkContext

def start(): H2OContext

Initialize Sparkling H2O and start H2O cloud.

def stop(stopSparkContext: Boolean = false): Unit

Stops H2O context.

def subseqTries: Int

implicit def symbolToString(sy: Symbol): String

Transform given Scala symbol to String

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

implicit def toH2OFrameKey(fr: Frame): Key[Frame]

def toH2OFrameKey(rdd: DataFrame, frameName: String): Key[Frame]

def toH2OFrameKey(rdd: DataFrame, frameName: Option[String]): Key[Frame]

implicit def toH2OFrameKey(rdd: DataFrame): Key[Frame]

Implicit conversion from Spark DataFrame to H2O's DataFrame

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

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

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

Transforms RDD[Supported type] to H2OFrame key

implicit def toH2OFrameKeyFromRDDBool(rdd: RDD[Boolean]): Key[_]

implicit def toH2OFrameKeyFromRDDByte(rdd: RDD[Byte]): Key[_]

implicit def toH2OFrameKeyFromRDDDouble(rdd: RDD[Double]): Key[_]

implicit def toH2OFrameKeyFromRDDLabeledPoint(rdd: RDD[LabeledPoint]): Key[_]

implicit def toH2OFrameKeyFromRDDLong(rdd: RDD[Long]): Key[_]

implicit def toH2OFrameKeyFromRDDProduct[A <: Product](rdd: RDD[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): Key[_]

Implicit conversion from RDD[Supported type] to H2OFrame key

implicit def toH2OFrameKeyFromRDDShort(rdd: RDD[Short]): Key[_]

implicit def toH2OFrameKeyFromRDDString(rdd: RDD[String]): Key[_]

implicit def toH2OFrameKeyFromRDDTimeStamp(rdd: RDD[Timestamp]): Key[_]

def toString(): String

def useFlatFile: Boolean

def userName: Option[String]

final def wait(): Unit

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

final def wait(arg0: Long): Unit

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

Convert given H2O frame into DataFrame type

def start(h2oWorkers: Int): H2OContext

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

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