Object/Trait

org.apache.spark.h2o.backends.external

ExternalBackendConf

Related Docs: trait ExternalBackendConf | package external

Permalink

object ExternalBackendConf

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ExternalBackendConf
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. val EXTERNAL_BACKEND_AUTO_MODE: String

    Permalink
  5. val EXTERNAL_BACKEND_MANUAL_MODE: String

    Permalink
  6. val PROP_EXTERNAL_BACKEND_STOP_TIMEOUT: (String, Int)

    Permalink

    Timeout for confirmation from worker nodes when stopping the external backend.

    Timeout for confirmation from worker nodes when stopping the external backend. It is also possible to pass -1 to ensure the indefinite timeout. The unit is milliseconds.

  7. val PROP_EXTERNAL_CLUSTER_DRIVER_PATH: (String, None.type)

    Permalink

    Path to h2o driver

  8. val PROP_EXTERNAL_CLUSTER_HDFS_DIR: (String, None.type)

    Permalink

    HDFS dir for external h2o nodes when starting in auto mode

  9. val PROP_EXTERNAL_CLUSTER_INFO_FILE: (String, None.type)

    Permalink

    Path to a file used as cluster notification file

  10. val PROP_EXTERNAL_CLUSTER_KILL_ON_UNHEALTHY: (String, Boolean)

    Permalink

    If true, the client will try to kill the cluster and then itself in case some nodes in the cluster report unhealthy status

  11. val PROP_EXTERNAL_CLUSTER_REPRESENTATIVE: (String, None.type)

    Permalink

    ip:port of arbitrary h2o node to identify external h2o cluster

  12. val PROP_EXTERNAL_CLUSTER_SIZE: (String, None.type)

    Permalink

    Number of nodes to wait for when connecting to external H2O cluster in manual mode.

    Number of nodes to wait for when connecting to external H2O cluster in manual mode. In auto mode, number of nodes to be started. This option does not have any effect in manual cluster start in case spark.ext.h2o.rest.api.based.client is set to true

  13. val PROP_EXTERNAL_CLUSTER_START_MODE: (String, String)

    Permalink

    If this option is set to "auto" then h2o external cluster will be automatically started using the provided h2o driver on yarn, otherwise it is expected that the cluster will be started by the user

  14. val PROP_EXTERNAL_CLUSTER_START_TIMEOUT: (String, Int)

    Permalink

    Timeout in seconds for starting h2o external cluster

  15. val PROP_EXTERNAL_CLUSTER_YARN_QUEUE: (String, None.type)

    Permalink

    Yarn queue on which external cluster should be started

  16. val PROP_EXTERNAL_COMMUNICATION_BLOCK_SIZE: (String, String)

    Permalink

    The size of blocks representing data traffic from Spark nodes to H2O-3 nodes.

  17. val PROP_EXTERNAL_DISABLE_VERSION_CHECK: (String, Boolean)

    Permalink

    Disable version check of external H2O backend

  18. val PROP_EXTERNAL_DRIVER_IF: (String, None.type)

    Permalink
  19. val PROP_EXTERNAL_DRIVER_PORT: (String, None.type)

    Permalink
  20. val PROP_EXTERNAL_DRIVER_PORT_RANGE: (String, None.type)

    Permalink
  21. val PROP_EXTERNAL_EXTRA_MEMORY_PERCENT: (String, Int)

    Permalink
  22. val PROP_EXTERNAL_H2O_MEMORY: (String, String)

    Permalink

    Number of memory assigned to each external h2o node when starting in auto mode

  23. val PROP_EXTERNAL_HADOOP_EXECUTABLE: (String, String)

    Permalink

    Hadoop executable used to start external H2O cluster on Hadoop

  24. val PROP_EXTERNAL_KERBEROS_KEYTAB: (String, None.type)

    Permalink

    Path to Kerberos key tab

  25. val PROP_EXTERNAL_KERBEROS_PRINCIPAL: (String, None.type)

    Permalink

    Kerberos principal

  26. val PROP_EXTERNAL_RUN_AS_USER: (String, None.type)

    Permalink

    Impersonated Hadoop user

  27. val PROP_EXTERNAL_WRITE_TIMEOUT: (String, Int)

    Permalink

    Timeout in seconds for confirmation of write operation ( spark frame => h2o frame) on external cluster.

  28. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  29. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  31. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  32. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  33. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  34. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  35. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  36. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  37. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  38. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  39. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  40. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  41. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped