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 UNSUPPORTED_SPARK_OPTIONS: Seq[(String, String)]

final def asInstanceOf[T0]: T0

def clone(): AnyRef

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

def get(): Option[H2OContext]

Tries to get existing H2O Context.

final def getClass(): Class[_]

def getOrCreate(sc: JavaSparkContext): H2OContext

Supports call from java environments.

def getOrCreate(sc: SparkContext): H2OContext

Get existing H2O Context or initialize Sparkling H2O and start H2O cloud with default number of workers

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

final def notify(): Unit

final def notifyAll(): Unit

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

def toH2OFrame(sc: SparkContext, rdd: SupportedRDD, frameKeyName: Option[String]): H2OFrame

Transform supported type for conversion to H2OFrame

def toH2OFrame[A <: Product](sc: SparkContext, rdd: RDD[A], frameKeyName: Option[String])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): H2OFrame

Transform typed RDD into H2O Frame

def toH2OFrame(sc: SparkContext, dataFrame: DataFrame, frameKeyName: Option[String]): H2OFrame

Transform SchemaRDD into H2O Frame

def toH2OFrameFromPureProduct(sc: SparkContext, rdd: RDD[Product], frameKeyName: Option[String]): H2OFrame

def toH2OFrameFromRDDBool(sc: SparkContext, rdd: RDD[Boolean], frameKeyName: Option[String]): H2OFrame

Transform RDD[Double] to appropriate H2OFrame

def toH2OFrameFromRDDByte(sc: SparkContext, rdd: RDD[Byte], frameKeyName: Option[String]): H2OFrame

Transform RDD[Byte] to appropriate H2OFrame

def toH2OFrameFromRDDDouble(sc: SparkContext, rdd: RDD[Double], frameKeyName: Option[String]): H2OFrame

Transform RDD[Double] to appropriate H2OFrame

def toH2OFrameFromRDDFloat(sc: SparkContext, rdd: RDD[Float], frameKeyName: Option[String]): H2OFrame

Transform RDD[Float] to appropriate H2OFrame

def toH2OFrameFromRDDInt(sc: SparkContext, rdd: RDD[Int], frameKeyName: Option[String]): H2OFrame

Transform RDD[Int] to appropriate H2OFrame

def toH2OFrameFromRDDLabeledPoint(sc: SparkContext, rdd: RDD[LabeledPoint], frameKeyName: Option[String]): H2OFrame

Transform RDD[LabeledPoint] to appropriate H2OFrame

def toH2OFrameFromRDDLong(sc: SparkContext, rdd: RDD[Long], frameKeyName: Option[String]): H2OFrame

Transform RDD[Long] to appropriate H2OFrame

def toH2OFrameFromRDDShort(sc: SparkContext, rdd: RDD[Short], frameKeyName: Option[String]): H2OFrame

Transform RDD[Short] to appropriate H2OFrame

def toH2OFrameFromRDDString(sc: SparkContext, rdd: RDD[String], frameKeyName: Option[String]): H2OFrame

Transform RDD[String] to appropriate H2OFrame

def toH2OFrameFromRDDTimeStamp(sc: SparkContext, rdd: RDD[Timestamp], frameKeyName: Option[String]): H2OFrame

Transform RDD[Byte] to appropriate H2OFrame

def toString(): String

final def wait(): Unit

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

final def wait(arg0: Long): Unit

def getOrCreate(sc: JavaSparkContext, h2oWorkers: Int): H2OContext

Supports call from java environments.

def getOrCreate(sc: SparkContext, h2oWorkers: Int): H2OContext

Get existing H2O Context or initialize Sparkling H2O and start H2O cloud with specified number of workers