Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(11)  |  Call(11)  |  Derive(0)  |  Import(0)

src/s/a/sahara-2014.1/sahara/plugins/intel/v2_5_1/installer.py   sahara(Download)
    snn_host = snn[0].fqdn() if snn else None
    jt_host = u.get_jobtracker(cluster).fqdn() if u.get_jobtracker(
        cluster) else None
    dn_hosts = [dn.fqdn() for dn in u.get_datanodes(cluster)]
    tt_hosts = [tt.fqdn() for tt in u.get_tasktrackers(cluster)]
        services += ['hdfs']
 
    if u.get_jobtracker(cluster):
        services += ['mapred']
 
    client.services.hdfs.start()
 
    if u.get_jobtracker(cluster):
        client.services.mapred.start()
 

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
            run.start_processes(remote.get_remote(snn), "secondarynamenode")
 
        jt_instance = utils.get_jobtracker(cluster)
        if jt_instance:
            run.start_processes(remote.get_remote(jt_instance), "jobtracker")
 
        nn = utils.get_namenode(cluster)
        jt = utils.get_jobtracker(cluster)
 
        if decommission_tts:
        run.refresh_nodes(remote.get_remote(
            utils.get_namenode(cluster)), "dfsadmin")
        jt = utils.get_jobtracker(cluster)
        if jt:
            run.refresh_nodes(remote.get_remote(jt), "mradmin")
    def _set_cluster_info(self, cluster):
        nn = utils.get_namenode(cluster)
        jt = utils.get_jobtracker(cluster)
        oozie = utils.get_oozie(cluster)
        info = {}
    def _validate_additional_ng_scaling(self, cluster, additional):
        jt = utils.get_jobtracker(cluster)
        scalable_processes = self._get_scalable_processes()
 
        for ng_id in additional:

src/s/a/sahara-2014.1/sahara/plugins/intel/v2_5_1/versionhandler.py   sahara(Download)
    def _validate_additional_ng_scaling(self, cluster, additional):
        jt = u.get_jobtracker(cluster)
        scalable_processes = self._get_scalable_processes()
 
        for ng_id in additional:
    def _set_cluster_info(self, cluster):
        mng = u.get_instances(cluster, 'manager')[0]
        nn = u.get_namenode(cluster)
        jt = u.get_jobtracker(cluster)
        oozie = u.get_oozie(cluster)

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v1_2_1/config_helper.py   sahara(Download)
def generate_sahara_configs(cluster, node_group=None):
    nn_hostname = _get_hostname(utils.get_namenode(cluster))
    jt_hostname = _get_hostname(utils.get_jobtracker(cluster))
    oozie_hostname = _get_hostname(utils.get_oozie(cluster))
    hive_hostname = _get_hostname(utils.get_hiveserver(cluster))