Package

org.apache.spark.h2o.backends

internal

Permalink

package internal

Visibility
  1. Public
  2. All

Type Members

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

    Permalink
  2. class H2ORpcEndpoint extends ThreadSafeRpcEndpoint

    Permalink

    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

    Permalink

    Internal backend configuration

  4. class InternalH2OBackend extends SparklingBackend with InternalBackendUtils with Logging

    Permalink
  5. class InternalReadConverterCtx extends ReadConverterCtx

    Permalink
  6. class InternalWriteConverterCtx extends WriteConverterCtx

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

    Permalink
  8. case class StopEndpointMsg() extends Product with Serializable

    Permalink

Value Members

  1. object InternalBackendConf

    Permalink
  2. object InternalBackendUtils extends InternalBackendUtils

    Permalink
  3. object InternalH2OBackend extends Logging with Serializable

    Permalink
  4. object InternalWriteConverterCtx

    Permalink
  5. object RpcReferenceCache

    Permalink

Ungrouped