Value Members

1.  final def !=(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def asH2OFrame(s: String): H2OFrame

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

5.  def asH2OFrame(ds: SupportedDataset, frameName: Option[String]): H2OFrame
6.  def asH2OFrame(ds: SupportedDataset, frameName: String): H2OFrame
7.  def asH2OFrame(ds: SupportedDataset): H2OFrame

   Transforms Dataset[Supported type] to H2OFrame

8.  def asH2OFrame(df: DataFrame, frameName: Option[String]): H2OFrame
9.  def asH2OFrame(df: DataFrame, frameName: String): H2OFrame
10.  def asH2OFrame(df: DataFrame): H2OFrame

    Transform DataFrame to H2OFrame

11.  def asH2OFrame(rdd: SupportedRDD, frameName: Option[String]): H2OFrame
12.  def asH2OFrame(rdd: SupportedRDD, frameName: String): H2OFrame
13.  def asH2OFrame(rdd: SupportedRDD): H2OFrame

    Transforms RDD[Supported type] to H2OFrame

14.  final def asInstanceOf[T0]: T0

    Definition Classes

    Any

15.  def asRDD[A <: Product](implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A], arg1: ClassTag[A]): AnyRef { def apply(fr: ai.h2o.sparkling.H2OFrame): org.apache.spark.rdd.RDD[A] }

    A generic convert of Frame into Product RDD type

    A generic convert of Frame into Product RDD type

    Consider using asH2OFrame since asRDD has several limitations such as that asRDD can't be used in Spark REPL in case we are RDD[T] where T is class defined in REPL. This is because class T is created as inner class and we are not able to create instance of class T without outer scope - which is impossible to get.

    This code: hc.asRDD[PUBDEV458Type](rdd) will need to be call as hc.asRDD[PUBDEV458Type].apply(rdd)

16.  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

    Convert given H2O frame into a Product RDD type

    Consider using asH2OFrame since asRDD has several limitations such as that asRDD can't be used in Spark REPL in case we are RDD[T] where T is class defined in REPL. This is because class T is created as inner class and we are not able to create instance of class T without outer scope - which is impossible to get.

17.  def asSparkFrame(s: String): DataFrame
18.  def asSparkFrame(s: String, copyMetadata: Boolean): DataFrame
19.  def asSparkFrame(fr: H2OFrame, copyMetadata: Boolean = true): DataFrame
20.  val backend: SparklingBackend

    Used backend

    Used backend

    Attributes

    protected

21.  def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit

    Definition Classes

    RestCommunication

22.  def clone(): AnyRef

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

23.  def collectPropertiesDoc(): Map[String, String]

    Attributes

    protected

    Definition Classes

    H2OContextExtensions

24.  def delete(endpoint: URI, suffix: String, conf: H2OConf): Unit
    endpoint

    An address of H2O node with exposed REST endpoint

    suffix

    REST relative path representing a specific call

    conf

    H2O conf object

    Attributes

    protected

    Definition Classes

    RestCommunication

25.  def delete[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false)(implicit arg0: ClassTag[ResultType]): ResultType
    ResultType

    A type that the result will be deserialized to

    endpoint

    An address of H2O node with exposed REST endpoint

    suffix

    REST relative path representing a specific call

    conf

    H2O conf object

    params

    Query parameters

    skippedFields

    The list of field specifications that are skipped during deserialization. The specification consists of the class containing the field and the field name.

    returns

    A deserialized object

    Definition Classes

    RestCommunication

26.  def downloadBinaryURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

    Attributes

    protected

    Definition Classes

    RestCommunication

27.  def downloadH2OLogs(destinationDir: String, logContainer: String): String

    Definition Classes

    H2OContextExtensions

28.  def downloadStringURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit

    Attributes

    protected

    Definition Classes

    RestCommunication

29.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

30.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

31.  def finalize(): Unit

    Attributes

    protected[lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

32.  def flowURL(): String
33.  def getAndVerifyWorkerNodes(conf: H2OConf): Array[NodeDesc]

    Attributes

    protected

    Definition Classes

    H2OContextExtensions

34.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

35.  def getClusterEndpoint(conf: H2OConf): URI

    Definition Classes

    RestApiUtils

36.  def getClusterInfo(conf: H2OConf): CloudV3

    Definition Classes

    RestApiUtils

37.  def getConf: H2OConf

    Return a copy of this H2OContext's configuration.

    Return a copy of this H2OContext's configuration. The configuration cannot be changed at runtime.

38.  def getH2OLogLevel(): String
39.  def getH2ONodes(): Array[NodeDesc]
40.  def getLogLevel(conf: H2OConf): String

    Definition Classes

    RestApiUtils

41.  def getNodes(cloudV3: CloudV3): Array[NodeDesc]

    Definition Classes

    RestApiUtils

42.  def getNodes(conf: H2OConf): Array[NodeDesc]

    Definition Classes

    RestApiUtils

43.  def getPingInfo(conf: H2OConf): PingV3

    Definition Classes

    RestApiUtils

44.  def getTimeZone(conf: H2OConf): String

    Definition Classes

    RestApiUtils

45.  def h2oLocalClient: String

    Returns location of REST API of H2O client

46.  def h2oLocalClientIp: String

    Returns IP of H2O client

47.  def h2oLocalClientPort: Int

    Returns port where H2O REST API is exposed

48.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

49.  def importHiveTable(database: String = HiveTableImporter.DEFAULT_DATABASE, table: String, partitions: Array[Array[String]] = null, allowMultiFormat: Boolean = false): H2OFrame

    Definition Classes

    H2OContextExtensions

50.  def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean

    Attributes

    protected

    Definition Classes

    Logging

51.  def initializeLogIfNecessary(isInterpreter: Boolean): Unit

    Attributes

    protected

    Definition Classes

    Logging

52.  def insert(endpoint: URI, suffix: String, conf: H2OConf, streamWrapper: (OutputStream) ⇒ OutputStream = identity, params: Map[String, Any] = Map.empty): OutputStream
    endpoint

    An address of H2O node with exposed REST endpoint

    suffix

    REST relative path representing a specific call

    conf

    H2O conf object

    params

    Query parameters

    returns

    HttpUrlConnection facilitating the insertion and holding the outputStream

    Attributes

    protected

    Definition Classes

    RestCommunication

53.  def insertToNode(node: NodeDesc, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty): OutputStream
    node

    H2O node descriptor

    suffix

    REST relative path representing a specific call

    conf

    H2O conf object

    params

    Query parameters

    returns

    HttpUrlConnection facilitating the insertion and holding the outputStream

    Definition Classes

    RestCommunication

54.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

55.  def isPrimitiveType(value: Any): Boolean

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

56.  def isStopped(): Boolean
57.  def isTraceEnabled(): Boolean

    Attributes

    protected

    Definition Classes

    Logging

58.  def launchShellCommand(cmdToLaunch: Seq[String]): Int

    Attributes

    protected

    Definition Classes

    ShellUtils

59.  def log: Logger

    Attributes

    protected

    Definition Classes

    Logging

60.  def logDebug(msg: ⇒ String, throwable: Throwable): Unit

    Attributes

    protected

    Definition Classes

    Logging

61.  def logDebug(msg: ⇒ String): Unit

    Attributes

    protected

    Definition Classes

    Logging

62.  def logError(msg: ⇒ String, throwable: Throwable): Unit

    Attributes

    protected

    Definition Classes

    Logging

63.  def logError(msg: ⇒ String): Unit

    Attributes

    protected

    Definition Classes

    Logging

64.  def logInfo(msg: ⇒ String, throwable: Throwable): Unit

    Attributes

    protected

    Definition Classes

    Logging

65.  def logInfo(msg: ⇒ String): Unit

    Attributes

    protected

    Definition Classes

    Logging

66.  def logName: String

    Attributes

    protected

    Definition Classes

    Logging

67.  def logTrace(msg: ⇒ String, throwable: Throwable): Unit

    Attributes

    protected

    Definition Classes

    Logging

68.  def logTrace(msg: ⇒ String): Unit

    Attributes

    protected

    Definition Classes

    Logging

69.  def logWarning(msg: ⇒ String, throwable: Throwable): Unit

    Attributes

    protected

    Definition Classes

    Logging

70.  def logWarning(msg: ⇒ String): Unit

    Attributes

    protected

    Definition Classes

    Logging

71.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

72.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

73.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

74.  def openFlow(): Unit

    Open H2O Flow running in this client.

75.  def openURI(uri: String): Unit

    Open browser for given address.

    Open browser for given address.

    uri

    address to open in browser, e.g., http://example.com

    Attributes

    protected

    Definition Classes

    H2OContextExtensions

76.  def query[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, confirmationLoggingLevel: LoggingLevel = Info)(implicit arg0: ClassTag[ResultType]): ResultType
    ResultType

    A type that the result will be deserialized to

    endpoint

    An address of H2O node with exposed REST endpoint

    suffix

    REST relative path representing a specific call

    conf

    H2O conf object

    params

    Query parameters

    skippedFields

    The list of field specifications that are skipped during deserialization. The specification consists of the class containing the field and the field name.

    returns

    A deserialized object

    Definition Classes

    RestCommunication

77.  def readURLContent(endpoint: URI, requestType: String, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false, file: Option[String] = None, confirmationLoggingLevel: LoggingLevel = Info): InputStream

    Attributes

    protected

    Definition Classes

    RestCommunication

78.  def request[ResultType](endpoint: URI, requestType: String, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false, confirmationLoggingLevel: LoggingLevel = Info)(implicit arg0: ClassTag[ResultType]): ResultType

    Definition Classes

    RestCommunication

79.  def resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI

    Definition Classes

    RestApiUtils

80.  def setH2OLogLevel(level: String): Unit
81.  def setLogLevel(conf: H2OConf, logLevel: String): Unit

    Definition Classes

    RestApiUtils

82.  def setTimeZone(conf: H2OConf, timezone: String): Unit

    Definition Classes

    RestApiUtils

83.  def shutdownCluster(conf: H2OConf): Unit

    Definition Classes

    RestApiUtils

84.  val sparkContext: SparkContext
85.  def stop(stopSparkContext: Boolean = false): Unit

    Stops H2O context.

    Stops H2O context.

    stopSparkContext

    stop also spark context

86.  def stringify(value: Any): String

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

87.  def stringifyArray(arr: Array[_]): String

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

88.  def stringifyMap(map: Map[_, _]): String

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

89.  def stringifyPair(pair: Tuple2[_, _]): String

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

90.  def stringifyParams(params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false): String

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

91.  def stringifyPrimitiveParam(value: Any): String

    Attributes

    protected

    Definition Classes

    RestEncodingUtils

92.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

93.  def toString(): String

    Definition Classes

    H2OContext → AnyRef → Any

94.  def update[ResultType](endpoint: URI, suffix: String, conf: H2OConf, params: Map[String, Any] = Map.empty, skippedFields: Seq[(Class[_], String)] = Seq.empty, encodeParamsAsJson: Boolean = false)(implicit arg0: ClassTag[ResultType]): ResultType
    ResultType

    A type that the result will be deserialized to

    endpoint

    An address of H2O node with exposed REST endpoint

    suffix

    REST relative path representing a specific call

    conf

    H2O conf object

    params

    Query parameters

    skippedFields

    The list of field specifications that are skipped during deserialization. The specification consists of the class containing the field and the field name.

    returns

    A deserialized object

    Definition Classes

    RestCommunication

95.  def visibleFlowURL(): String
96.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

98.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... ) @native()

99.  def withConversionDebugPrints(sc: SparkContext, conversionName: String, block: ⇒ H2OFrame): H2OFrame

    Attributes

    protected

    Definition Classes

    H2OContextExtensions

100.  object implicits extends H2OContextImplicits with Serializable

     Define implicits available via h2oContext.implicits._

101.  object LoggingLevel extends Enumeration

     Definition Classes

     RestCommunication