

def _get_configs(self, service, cluster=None, instance=None):

    def get_hadoop_dirs(mount_points, suffix):
        return ','.join([(x + suffix) for x in mount_points])
    all_confs = {
        
    }
    if cluster:
        zk_count = self.validator._get_inst_count(cluster, 'ZOOKEEPER_SERVER')
        core_site_safety_valve = ''
        if self.pu.c_helper.is_swift_enabled(cluster):
            configs = swift_helper.get_swift_configs()
            confs = {c['name']: c['value'] for c in configs}
            core_site_safety_valve = xmlutils.create_elements_xml(confs)
        all_confs = {
            'HDFS': {
                'zookeeper_service': (self.ZOOKEEPER_SERVICE_NAME if zk_count else ''),
                'core_site_safety_valve': core_site_safety_valve,
            },
            'HIVE': {
                'mapreduce_yarn_service': self.YARN_SERVICE_NAME,
                'zookeeper_service': (self.ZOOKEEPER_SERVICE_NAME if zk_count else ''),
            },
            'OOZIE': {
                'mapreduce_yarn_service': self.YARN_SERVICE_NAME,
                'zookeeper_service': (self.ZOOKEEPER_SERVICE_NAME if zk_count else ''),
            },
            'YARN': {
                'hdfs_service': instance_default_confs.HDFS_SERVICE_NAME,
                'zookeeper_service': (self.ZOOKEEPER_SERVICE_NAME if zk_count else ''),
            },
            'HUE': {
                'hive_service': self.HIVE_SERVICE_NAME,
                'oozie_service': self.OOZIE_SERVICE_NAME,
                'zookeeper_service': (self.ZOOKEEPER_SERVICE_NAME if zk_count else ''),
            },
            'SPARK_ON_YARN': {
                'yarn_service': self.YARN_SERVICE_NAME,
            },
            'HBASE': {
                'hdfs_service': self.HDFS_SERVICE_NAME,
                'zookeeper_service': self.ZOOKEEPER_SERVICE_NAME,
            },
        }
        hive_confs = {
            'HIVE': {
                'hive_metastore_database_type': 'postgresql',
                'hive_metastore_database_host': self.pu.get_manager(cluster).internal_ip,
                'hive_metastore_database_port': '7432',
                'hive_metastore_database_password': self.pu.db_helper.get_hive_db_password(cluster),
            },
        }
        hue_confs = {
            'HUE': {
                'hue_webhdfs': self.pu.get_role_name(self.pu.get_namenode(cluster), 'NAMENODE'),
            },
        }
        all_confs = s_cfg.merge_configs(all_confs, hue_confs)
        all_confs = s_cfg.merge_configs(all_confs, hive_confs)
        all_confs = s_cfg.merge_configs(all_confs, cluster.cluster_configs)
    if instance:
        paths = instance.storage_paths()
        instance_default_confs = {
            'NAMENODE': {
                'dfs_name_dir_list': get_hadoop_dirs(paths, '/fs/nn'),
            },
            'SECONDARYNAMENODE': {
                'fs_checkpoint_dir_list': get_hadoop_dirs(paths, '/fs/snn'),
            },
            'DATANODE': {
                'dfs_data_dir_list': get_hadoop_dirs(paths, '/fs/dn'),
                'dfs_datanode_data_dir_perm': 755,
                'dfs_datanode_handler_count': 30,
            },
            'NODEMANAGER': {
                'yarn_nodemanager_local_dirs': get_hadoop_dirs(paths, '/yarn/local'),
            },
            'SERVER': {
                'maxSessionTimeout': 60000,
            },
        }
        ng_user_confs = self.pu.convert_process_configs(instance.node_group.node_configs)
        all_confs = s_cfg.merge_configs(all_confs, ng_user_confs)
        all_confs = s_cfg.merge_configs(all_confs, instance_default_confs)
    return all_confs.get(service, {
        
    })

dataset/ETHPy150Open openstack/sahara/sahara/plugins/cdh/v5/cloudera_utils.py ClouderaUtilsV5._get_configs/VarMisuse@218/365 `self`->`instance_default_confs`