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

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

src/s/a/sahara-2014.1/sahara/plugins/intel/v3_0_2/versionhandler.py   sahara(Download)
    def _set_cluster_info(self, cluster):
        mng = u.get_instances(cluster, 'manager')[0]
        nn = u.get_namenode(cluster)
        jt = u.get_resourcemanager(cluster)
        oozie = u.get_oozie(cluster)

src/s/a/sahara-2014.1/sahara/plugins/intel/v2_5_1/versionhandler.py   sahara(Download)
    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/versionhandler.py   sahara(Download)
    def configure_cluster(self, cluster):
        instances = utils.get_instances(cluster)
 
        self._setup_instances(cluster, instances)
 
            run.start_processes(remote.get_remote(jt_instance), "jobtracker")
 
        self._start_tt_dn_processes(utils.get_instances(cluster))
 
        self._await_datanodes(cluster)
    def _push_configs_to_nodes(self, cluster, extra, new_instances):
        all_instances = utils.get_instances(cluster)
        with context.ThreadGroup() as tg:
            for instance in all_instances:
                if instance in new_instances:

src/s/a/sahara-HEAD/sahara/plugins/vanilla/utils.py   sahara(Download)
def get_nodemanagers(cluster):
    return u.get_instances(cluster, 'nodemanager')
 
 
def get_oozie(cluster):
def get_datanodes(cluster):
    return u.get_instances(cluster, 'datanode')
 
 
def get_tasktrackers(cluster):
    return u.get_instances(cluster, 'tasktracker')
 
 
def get_secondarynamenodes(cluster):
    return u.get_instances(cluster, 'secondarynamenode')

src/s/a/sahara-2014.1/sahara/plugins/vanilla/v2_3_0/scaling.py   sahara(Download)
def _update_include_files(cluster):
    instances = u.get_instances(cluster)
 
    datanodes = u.get_datanodes(cluster)
    nodemanagers = u.get_nodemanagers(cluster)
    dn_hosts = u.generate_fqdn_host_names(datanodes)
    nm_hosts = u.generate_fqdn_host_names(nodemanagers)
    for instance in u.get_instances(cluster):
        with instance.remote() as r:
            r.execute_command(
def _clear_exclude_files(cluster):
    for instance in u.get_instances(cluster):
        with instance.remote() as r:
            r.execute_command(
                'sudo su - -c "echo > %s/dn-exclude" hadoop' % HADOOP_CONF_DIR)

src/s/a/sahara-2014.1/sahara/plugins/intel/v3_0_2/installer.py   sahara(Download)
def configure_os(cluster):
    instances = u.get_instances(cluster)
    configure_os_from_instances(cluster, instances)
 
 
def install_cluster(cluster):
    mng_instance = u.get_instance(cluster, 'manager')
 
    all_hosts = list(set([i.fqdn() for i in u.get_instances(cluster)]))
 

src/s/a/sahara-2014.1/sahara/plugins/intel/v2_5_1/installer.py   sahara(Download)
def configure_os(cluster):
    instances = u.get_instances(cluster)
    configure_os_from_instances(cluster, instances)
 
 
def install_cluster(cluster):
    mng_instance = u.get_instance(cluster, 'manager')
 
    all_hosts = list(set([i.fqdn() for i in u.get_instances(cluster)]))
 

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
    def configure_cluster(self, cluster):
        instances = utils.get_instances(cluster)
 
        self._setup_instances(cluster, instances)
 
            run.start_processes(remote.get_remote(jt_instance), "jobtracker")
 
        self._start_tt_dn_processes(utils.get_instances(cluster))
 
        self._await_datanodes(cluster)
    def _push_configs_to_nodes(self, cluster, extra, new_instances):
        all_instances = utils.get_instances(cluster)
        with context.ThreadGroup() as tg:
            for instance in all_instances:
                if instance in new_instances:

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v2_3_0/scaling.py   sahara(Download)
def _update_include_files(cluster):
    instances = u.get_instances(cluster)
 
    datanodes = vu.get_datanodes(cluster)
    nodemanagers = vu.get_nodemanagers(cluster)
    dn_hosts = u.generate_fqdn_host_names(datanodes)
    nm_hosts = u.generate_fqdn_host_names(nodemanagers)
    for instance in u.get_instances(cluster):
        with instance.remote() as r:
            r.execute_command(
def _clear_exclude_files(cluster):
    for instance in u.get_instances(cluster):
        with instance.remote() as r:
            r.execute_command(
                'sudo su - -c "echo > %s/dn-exclude" hadoop' % HADOOP_CONF_DIR)

src/s/a/sahara-2014.1/sahara/service/edp/hdfs_helper.py   sahara(Download)
            continue
 
        for i in u.get_instances(c):
            if i.instance_name == host:
                return g.generate_etc_hosts(c)
    copy_etc_host = 'sudo "cat /tmp/etc-hosts > /etc/hosts"'
 
    for inst in u.get_instances(cluster):
        with inst.remote as r:
            r.write_file_to('/tmp/etc-hosts-update', etc_hosts_information)

  1 | 2  Next