trait RDDsRestApi extends RestApiUtils
- Alphabetic
 - By Inheritance
 
- RDDsRestApi
 - RestApiUtils
 - RestCommunication
 - RestEncodingUtils
 - Logging
 - Serializable
 - Serializable
 - Logging
 - AnyRef
 - Any
 
- Hide All
 - Show All
 
- Public
 - All
 
Value Members
- 
      
      
      
        
      
    
      
        final 
        def
      
      
        !=(arg0: Any): Boolean
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        ##(): Int
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        ==(arg0: Any): Boolean
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        asInstanceOf[T0]: T0
      
      
      
- Definition Classes
 - Any
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit
      
      
      
- Definition Classes
 - RestCommunication
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        clone(): AnyRef
      
      
      
- Attributes
 - protected[lang]
 - Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... ) @native()
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        convertToH2OFrame(rddId: Int, h2oFrameId: String): RDDToH2OFrame
      
      
      
- Attributes
 - protected
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        downloadBinaryURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestCommunication
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        downloadStringURLContent(endpoint: URI, suffix: String, conf: H2OConf, file: File): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestCommunication
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        eq(arg0: AnyRef): Boolean
      
      
      
- Definition Classes
 - AnyRef
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        equals(arg0: Any): Boolean
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        finalize(): Unit
      
      
      
- Attributes
 - protected[lang]
 - Definition Classes
 - AnyRef
 - Annotations
 - @throws( classOf[java.lang.Throwable] )
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        getClass(): Class[_]
      
      
      
- Definition Classes
 - AnyRef → Any
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getClusterEndpoint(conf: H2OConf): URI
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getClusterInfo(conf: H2OConf): CloudV3
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getLogLevel(conf: H2OConf): String
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getNodes(cloudV3: CloudV3): Array[NodeDesc]
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getNodes(conf: H2OConf): Array[NodeDesc]
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getPingInfo(conf: H2OConf): PingV3
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getRDD(rddId: Int): RDDInfo
      
      
      
- Attributes
 - protected
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        getTimeZone(conf: H2OConf): String
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        hashCode(): Int
      
      
      
- Definition Classes
 - AnyRef → Any
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        initializeLogIfNecessary(isInterpreter: Boolean): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        isInstanceOf[T0]: Boolean
      
      
      
- Definition Classes
 - Any
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        isPrimitiveType(value: Any): Boolean
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        isTraceEnabled(): Boolean
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        listRDDs(): RDDs
      
      
      
- Attributes
 - protected
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        log: Logger
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logDebug(msg: ⇒ String, throwable: Throwable): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logDebug(msg: ⇒ String): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logError(msg: ⇒ String, throwable: Throwable): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logError(msg: ⇒ String): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logInfo(msg: ⇒ String, throwable: Throwable): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logInfo(msg: ⇒ String): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logName: String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logTrace(msg: ⇒ String, throwable: Throwable): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logTrace(msg: ⇒ String): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logWarning(msg: ⇒ String, throwable: Throwable): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        logWarning(msg: ⇒ String): Unit
      
      
      
- Attributes
 - protected
 - Definition Classes
 - Logging
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        ne(arg0: AnyRef): Boolean
      
      
      
- Definition Classes
 - AnyRef
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        notify(): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        notifyAll(): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @native()
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        setLogLevel(conf: H2OConf, logLevel: String): Unit
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        setTimeZone(conf: H2OConf, timezone: String): Unit
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        shutdownCluster(conf: H2OConf): Unit
      
      
      
- Definition Classes
 - RestApiUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        stringify(value: Any): String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        stringifyArray(arr: Array[_]): String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        stringifyMap(map: Map[_, _]): String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        stringifyPair(pair: Tuple2[_, _]): String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        stringifyParams(params: Map[String, Any] = Map.empty, encodeParamsAsJson: Boolean = false): String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        stringifyPrimitiveParam(value: Any): String
      
      
      
- Attributes
 - protected
 - Definition Classes
 - RestEncodingUtils
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        synchronized[T0](arg0: ⇒ T0): T0
      
      
      
- Definition Classes
 - AnyRef
 
 - 
      
      
      
        
      
    
      
        
        def
      
      
        toString(): String
      
      
      
- Definition Classes
 - AnyRef → Any
 
 - 
      
      
      
        
      
    
      
        
        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
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... )
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long, arg1: Int): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... )
 
 - 
      
      
      
        
      
    
      
        final 
        def
      
      
        wait(arg0: Long): Unit
      
      
      
- Definition Classes
 - AnyRef
 - Annotations
 - @throws( ... ) @native()
 
 - 
      
      
      
        
      
    
      
        
        object
      
      
        LoggingLevel extends Enumeration
      
      
      
- Definition Classes
 - RestCommunication