class
H2OContext extends AnyRef
Value Members
-
final
def
!=(arg0: Any): Boolean
-
final
def
##(): Int
-
final
def
==(arg0: Any): Boolean
-
-
def
asH2OFrame(s: String): H2OFrame
-
def
asH2OFrame(ds: SupportedDataset, frameName: Option[String]): H2OFrame
-
-
-
def
asH2OFrame(df: DataFrame, frameName: Option[String]): H2OFrame
-
def
asH2OFrame(df: DataFrame, frameName: String): H2OFrame
-
def
asH2OFrame(df: DataFrame): H2OFrame
-
def
asH2OFrame(rdd: SupportedRDD, frameName: Option[String]): H2OFrame
-
def
asH2OFrame(rdd: SupportedRDD, frameName: String): H2OFrame
-
-
def
asH2OFrameKeyString(ds: SupportedDataset, frameName: Option[String]): String
-
def
asH2OFrameKeyString(ds: SupportedDataset, frameName: String): String
-
def
asH2OFrameKeyString(ds: SupportedDataset): String
-
def
asH2OFrameKeyString(df: DataFrame, frameName: Option[String]): String
-
def
asH2OFrameKeyString(df: DataFrame, frameName: String): String
-
def
asH2OFrameKeyString(df: DataFrame): String
-
def
asH2OFrameKeyString(rdd: SupportedRDD, frameName: Option[String]): String
-
def
asH2OFrameKeyString(rdd: SupportedRDD, frameName: String): String
-
def
asH2OFrameKeyString(rdd: SupportedRDD): String
-
final
def
asInstanceOf[T0]: T0
-
def
asRDD[A <: Product](fr: ai.h2o.sparkling.H2OFrame)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): rdd.RDD[A]
-
def
asRDD[A <: Product](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): AnyRef { def apply[T <: org.apache.spark.h2o.Frame](fr: T): org.apache.spark.h2o.RDD[A] }
-
def
asRDD[A <: Product](fr: H2OFrame)(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): RDD[A]
-
def
asSparkFrame(s: String): DataFrame
-
def
asSparkFrame(s: String, copyMetadata: Boolean): DataFrame
-
-
def
asSparkFrame[T <: Frame](fr: T, copyMetadata: Boolean = true): DataFrame
-
def
clone(): AnyRef
-
def
downloadH2OLogs(destinationDir: String, logContainer: String): String
-
final
def
eq(arg0: AnyRef): Boolean
-
def
equals(arg0: Any): Boolean
-
def
finalize(): Unit
-
def
flowURL(): String
-
final
def
getClass(): Class[_]
-
-
def
getH2OLogLevel(): String
-
def
getH2ONodes(): Array[NodeDesc]
-
def
h2oLocalClient: String
-
def
h2oLocalClientIp: String
-
def
h2oLocalClientPort: Int
-
def
hashCode(): Int
-
-
-
def
importHiveTable(database: String = HiveTableImporter.DEFAULT_DATABASE, table: String, partitions: Array[Array[String]] = null, allowMultiFormat: Boolean = false): H2OFrame
-
final
def
isInstanceOf[T0]: Boolean
-
final
def
ne(arg0: AnyRef): Boolean
-
final
def
notify(): Unit
-
final
def
notifyAll(): Unit
-
def
openFlow(): Unit
-
def
setH2OLogLevel(level: String): Unit
-
val
sparkContext: SparkContext
-
val
sparkSession: SparkSession
-
def
stop(stopSparkContext: Boolean = false): Unit
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
-
def
toH2OFrameKey(ds: SupportedDataset, frameName: String): Key[Frame]
-
def
toH2OFrameKey(ds: SupportedDataset, frameName: Option[String]): Key[Frame]
-
-
def
toH2OFrameKey(df: DataFrame, frameName: Option[String]): Key[Frame]
-
def
toH2OFrameKey(df: DataFrame, frameName: String): Key[Frame]
-
def
toH2OFrameKey(df: DataFrame): Key[Frame]
-
def
toH2OFrameKey(rdd: SupportedRDD, frameName: Option[String]): Key[_]
-
def
toH2OFrameKey(rdd: SupportedRDD, frameName: String): Key[_]
-
def
toH2OFrameKey(rdd: SupportedRDD): Key[_]
-
def
toString(): String
-
final
def
wait(): Unit
-
final
def
wait(arg0: Long, arg1: Int): Unit
-
final
def
wait(arg0: Long): Unit
Inherited from AnyRef
Inherited from Any