

@cpo.event_wrapper(True, step=_('Configure services'), param=('cluster', 1))
def configure_services(self, cluster):
    cm_cluster = self.get_cloudera_cluster(cluster)
    if (len(self.pu.get_zookeepers(cluster)) > 0):
        zookeeper = cm_cluster.get_service(self.ZOOKEEPER_SERVICE_NAME)
        zookeeper.update_config(self._get_configs(ZOOKEEPER_SERVICE_TYPE, cluster=cluster))
    hdfs = cm_cluster.get_service(self.HDFS_SERVICE_NAME)
    hdfs.update_config(self._get_configs(HDFS_SERVICE_TYPE, cluster=cluster))
    yarn = cm_cluster.get_service(self.YARN_SERVICE_NAME)
    yarn.update_config(self._get_configs(YARN_SERVICE_TYPE, cluster=cluster))
    oozie = cm_cluster.get_service(self.OOZIE_SERVICE_NAME)
    oozie.update_config(self._get_configs(OOZIE_SERVICE_TYPE, cluster=cluster))
    if self.pu.get_hive_metastore(cluster):
        hive = cm_cluster.get_service(self.HIVE_SERVICE_NAME)
        hive.update_config(self._get_configs(HIVE_SERVICE_TYPE, cluster=cluster))
    if self.pu.get_hue(cluster):
        hue = cm_cluster.get_service(self.HUE_SERVICE_NAME)
        hue.update_config(self._get_configs(HUE_SERVICE_TYPE, cluster=cluster))
    if self.pu.get_spark_historyserver(cluster):
        spark = cm_cluster.get_service(self.SPARK_SERVICE_NAME)
        spark.update_config(self._get_configs(SPARK_SERVICE_TYPE, cluster=cluster))
    if self.pu.get_hbase_master(cluster):
        hbase = cm_cluster.get_service(self.HBASE_SERVICE_NAME)
        hbase.update_config(self._get_configs(HBASE_SERVICE_TYPE, cluster=cluster))

dataset/ETHPy150Open openstack/sahara/sahara/plugins/cdh/v5/cloudera_utils.py ClouderaUtilsV5.configure_services/original