ScalaInterpreterRestApi

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
object LoggingLevel extends Enumeration

Definition Classes
RestCommunication
final def asInstanceOf[T0]: T0

Definition Classes
Any
def checkResponseCode(connection: HttpURLConnection, confirmationLoggingLevel: LoggingLevel = Info): Unit

Definition Classes
RestCommunication
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
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 destroySession(sessionId: Int): Unit

Attributes
protected
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[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
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 getScalaCodeResult(resultKey: String): ScalaCodeResult

Attributes
protected
def getSessions(): ScalaSessions

Attributes
protected
def getTimeZone(conf: H2OConf): String

Definition Classes
RestApiUtils
def hashCode(): Int

Definition Classes
AnyRef → Any
def initSession(): ScalaSessionId

Attributes
protected
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
def interpret(sessionId: Int, code: String): ScalaCode

Attributes
protected
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 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
final def notifyAll(): Unit

Definition Classes
AnyRef
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( ... )

Related Doc: package scalainterpreter

trait ScalaInterpreterRestApi extends RestApiUtils

Value Members

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: Any): Boolean

object LoggingLevel extends Enumeration

final def asInstanceOf[T0]: T0

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

def clone(): AnyRef

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

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

def destroySession(sessionId: Int): Unit

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

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

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def getClusterEndpoint(conf: H2OConf): URI

def getClusterInfo(conf: H2OConf): CloudV3

def getLogLevel(conf: H2OConf): String

def getNodes(cloudV3: CloudV3): Array[NodeDesc]

def getNodes(conf: H2OConf): Array[NodeDesc]

def getPingInfo(conf: H2OConf): PingV3

def getScalaCodeResult(resultKey: String): ScalaCodeResult

def getSessions(): ScalaSessions

def getTimeZone(conf: H2OConf): String

def hashCode(): Int

def initSession(): ScalaSessionId

def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean

def initializeLogIfNecessary(isInterpreter: Boolean): Unit

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

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

def interpret(sessionId: Int, code: String): ScalaCode

final def isInstanceOf[T0]: Boolean

def isPrimitiveType(value: Any): 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

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

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

def resolveNodeEndpoint(node: NodeDesc, conf: H2OConf): URI

def setLogLevel(conf: H2OConf, logLevel: String): Unit

def setTimeZone(conf: H2OConf, timezone: String): Unit

def shutdownCluster(conf: H2OConf): Unit

def stringify(value: Any): String

def stringifyArray(arr: Array[_]): String

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

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

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

def stringifyPrimitiveParam(value: Any): String

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

def toString(): String

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

final def wait(): Unit

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

final def wait(arg0: Long): Unit

Inherited from RestApiUtils

Inherited from RestCommunication

Inherited from RestEncodingUtils

Inherited from Logging

Inherited from Serializable

Inherited from Serializable

Inherited from Logging

Inherited from AnyRef