internal

Type Members

1. case class FlatFileMsg(nodes: Array[NodeDesc], portOffset: Int) extends Product with Serializable

   

2. class H2ORpcEndpoint extends ThreadSafeRpcEndpoint

   

   An RpcEndpoint used for communication between H2O client and H2O worker nodes on remote executors.

   An RpcEndpoint used for communication between H2O client and H2O worker nodes on remote executors. This endpoint is started on each Spark executor where H2O worker will be running.

3. trait InternalBackendConf extends SharedBackendConf

   

   Internal backend configuration

4. class InternalH2OBackend extends SparklingBackend with Logging

   

5. class InternalReadConverterCtx extends ReadConverterCtx

   

6. class InternalWriteConverterCtx extends WriteConverterCtx

   

7. case class StartH2OWorkersMsg(conf: H2OConf) extends Product with Serializable

   

8. case class StopEndpointMsg() extends Product with Serializable