Package org.apache.hadoop.applications.mawo.server.common

Class MawoConfiguration

java.lang.Object
org.apache.hadoop.applications.mawo.server.common.MawoConfiguration
public final class MawoConfiguration extends Object
MaWo configuration class.

  • Field Details

    • CONFIG_FILE

      public static final String CONFIG_FILE
      MaWo config file name.
      See Also:

    • JOB_BUILDER_CLASS

      public static final String JOB_BUILDER_CLASS
      Property for setting job builder class.
      See Also:

    • CLUSTER_MANAGER_URL

      public static final String CLUSTER_MANAGER_URL
      Property for resource manager url.
      See Also:

    • AUTO_SHUTDOWN_WORKERS

      public static final String AUTO_SHUTDOWN_WORKERS
      Property for setting auto shutdown for worker.
      See Also:

    • MASTER_TASKS_STATUS_LOG_PATH

      public static final String MASTER_TASKS_STATUS_LOG_PATH
      Property for task status log path in master node.
      See Also:

  • Constructor Details

    • MawoConfiguration

      public MawoConfiguration()
      Mowo configuration initializer.

  • Method Details

    • getConfigsMap

      public Map<String,String> getConfigsMap()
      Get MaWo config map.
      Returns:
      the config map for MaWo properties

    • getRpcServerPort

      public int getRpcServerPort()
      Get MaWo RPC server Port.
      Returns:
      value of rpc.server.port

    • getRpcHostName

      public String getRpcHostName()
      Get RPC Host map.
      Returns:
      value of rpc.server.hostname

    • getJobQueueStorageEnabled

      public boolean getJobQueueStorageEnabled()
      Check if Job Queue Storage is Enabled.
      Returns:
      True if Job queue storage is enabled otherwise False

    • getZKAddress

      public String getZKAddress()
      Get ZooKeeper Address.
      Returns:
      value of ZooKeeper.address

    • getZKParentPath

      public String getZKParentPath()
      Get ZooKeeper parent Path.
      Returns:
      value of ZooKeeper.parent.path

    • getZKRetryIntervalMS

      public int getZKRetryIntervalMS()
      Get ZooKeeper retry interval value in milli seconds.
      Returns:
      value of ZooKeeper.retry.interval.ms

    • getZKSessionTimeoutMS

      public int getZKSessionTimeoutMS()
      Get ZooKeeper session timeout in milli seconds.
      Returns:
      value of ZooKeeper.session.timeout.ms

    • getZKRetriesNum

      public int getZKRetriesNum()
      Get ZooKeeper retries number.
      Returns:
      value of ZooKeeper.retries.num

    • getZKAcl

      public String getZKAcl()
      Get ZooKeeper Acls.
      Returns:
      value of ZooKeeper.acl

    • getWorkerConcurrentTasksLimit

      public int getWorkerConcurrentTasksLimit()
      Get number of tasks a worker can run in parallel.
      Returns:
      value of worker.num.tasks

    • getJobBuilderClass

      public String getJobBuilderClass()
      Get job builder class.
      Returns:
      value of mawo.job-builder.class

    • getWorkerWorkSpace

      public String getWorkerWorkSpace()
      Get worker work space.
      Returns:
      value of worker.workspace

    • getClusterManagerURL

      public String getClusterManagerURL()
      Get cluster manager URL.
      Returns:
      value of ycloud.url

    • getAutoShutdownWorkers

      public boolean getAutoShutdownWorkers()
      Check if worker auto shutdown feature is enabled.
      Returns:
      value of mawo.master.auto-shutdown-workers

    • getMasterTasksStatusLogPath

      public String getMasterTasksStatusLogPath()
      Get Task status log file path on master host.
      Returns:
      value of master.tasks-status.log.path

    • getMasterDrainEventsTimeout

      public long getMasterDrainEventsTimeout()
      Get Master drain event timeout.
      Returns:
      value of master.drain-events.timeout

    • getWorkerWhiteListEnv

      public List<String> getWorkerWhiteListEnv()
      Get Worker whitelist env params. These params will be set in all tasks.
      Returns:
      list of white list environment

    • getTeardownWorkerValidityInterval

      public long getTeardownWorkerValidityInterval()
      Get Teardown worker validity interval.
      Returns:
      value of master.teardown-worker.validity-interval.ms