package internal
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- case class FlatFileMsg(nodes: Array[NodeDesc], portOffset: Int) extends Product with Serializable
-
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.
- class InternalH2OBackend extends SparklingBackend with Logging
- case class StartH2OWorkersMsg(conf: ai.h2o.sparkling.H2OConf) extends Product with Serializable
Value Members
- object CheckClusterSizeMsg extends Product with Serializable
- object GetLeaderNodeMsg extends Product with Serializable
- object InternalH2OBackend extends InternalBackendUtils
- object LockClusterMsg extends Product with Serializable
- object RpcReferenceCache extends SharedBackendUtils
- object StopEndpointMsg extends Product with Serializable