H2OContext

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

val PROP_CLIENT_ICED_DIR: (String, String)

Location of iced directory for the driver instance.

val PROP_CLIENT_LOG_LEVEL: (String, String)

H2O log leve for client running in Spark driver

val PROP_CLIENT_WEB_PORT: (String, Int)

Exact client port to access web UI.

val PROP_CLOUD_NAME: (String, String)

Configuration property - name of H2O cloud

val PROP_CLOUD_TIMEOUT: (String, Int)

Configuration property - timeout for cloud up.

val PROP_CLUSTER_SIZE: (String, Int)

Configuration property - expected number of workers of H2O cloud.

val PROP_DEFAULT_CLUSTER_SIZE: (String, Int)

Starting size of cluster in case that size is not explicitelly passed

val PROP_DISABLE_GA: (String, Boolean)

Disable GA tracking

val PROP_DUMMY_RDD_MUL_FACTOR: (String, Int)

Configuration property - multiplication factor for dummy RDD generation.

val PROP_NETWORK_MASK: (String, String)

Subnet selector for h2o if IP guess fail - useful if 'spark.

val PROP_NODE_ICED_DIR: (String, String)

Location of iced directory for Spark nodes

val PROP_NODE_LOG_LEVEL: (String, String)

val PROP_NTHREADS: (String, Int)

Limit for number of threads used by H2O, default -1 means unlimited

val PROP_PORT_BASE: (String, Int)

Configuration property - base port used for individual H2O nodes configuration.

val PROP_SPREADRDD_RETRIES: (String, Int)

Configuration property - number of retries to create an RDD spreat over all executors

val PROP_USE_FLATFILE: (String, Boolean)

Configuration property - use flatfile for H2O cloud formation.

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

implicit def asH2OFrame(fr: Frame): H2OFrame

Implicit conversion from Frame to DataFrame

implicit def asH2OFrame(primitiveType: PrimitiveType): H2OFrame

Implicit conversion from RDD[Primitive type] ( where primitive type can be String, Double, Float or Int) to appropriate H2OFrame

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

Implicit conversion from typed RDD to H2O's DataFrame

implicit def asH2OFrame(rdd: DataFrame): H2OFrame

Implicit conversion from Spark DataFrame to H2O's DataFrame

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 basePort: Int

def clientIcedDir: 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 h2oClientLogLevel: String

def h2oLocalClient: String

def h2oNodeLogLevel: String

def hashCode(): Int

final def isInstanceOf[T0]: Boolean

def isTraceEnabled(): 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

final def ne(arg0: AnyRef): Boolean

def networkMask: Option[String]

def nodeIcedDir: Option[String]

final def notify(): Unit

final def notifyAll(): Unit

def nthreads: Int

def numH2OWorkers: Int

def numRddRetries: Int

def openFlow(): Unit

Open H2O Flow running in this client.

val sparkConf: SparkConf

val sparkContext: SparkContext

def start(): H2OContext

Initialize Sparkling H2O and start H2O cloud.

def start(h2oWorkers: Int): H2OContext

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

def stop(stopSparkContext: Boolean = false): Unit

Stops H2O context.

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]

Returns a key of given frame

implicit def toH2OFrameKey(primitiveType: PrimitiveType): Key[_]

Implicit conversion from RDD[Primitive type] ( where primitive type can be String, Boolean, Double, Float, Int, Long, Short or Byte ) to appropriate H2O's DataFrame

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

Implicit conversion from typed RDD to H2O's DataFrame

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

Implicit conversion from Spark DataFrame to H2O's DataFrame

def toString(): String

def useFlatFile: Boolean

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