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

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

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v2_3_0/versionhandler.py   sahara(Download)
            run.start_historyserver(hs)
 
        oo = vu.get_oozie(cluster)
        if oo:
            run.start_oozie_process(oo)
    def _set_cluster_info(self, cluster):
        nn = vu.get_namenode(cluster)
        rm = vu.get_resourcemanager(cluster)
        hs = vu.get_historyserver(cluster)
        oo = vu.get_oozie(cluster)
    def get_oozie_server(self, cluster):
        return vu.get_oozie(cluster)
 
    def get_resource_manager_uri(self, cluster):
        return cluster['info']['YARN']['ResourceManager']

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v1_2_1/versionhandler.py   sahara(Download)
    def get_oozie_server(self, cluster):
        return vu.get_oozie(cluster)
 
    def validate(self, cluster):
        nn_count = sum([ng.count for ng
                 cluster.name)
 
        oozie = vu.get_oozie(cluster)
        if oozie:
            with remote.get_remote(oozie) as r:
    def _extract_configs_to_extra(self, cluster):
        oozie = vu.get_oozie(cluster)
        hive = vu.get_hiveserver(cluster)
 
        extra = dict()
    def _set_cluster_info(self, cluster):
        nn = vu.get_namenode(cluster)
        jt = vu.get_jobtracker(cluster)
        oozie = vu.get_oozie(cluster)
        info = {}

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

src/s/a/sahara-HEAD/sahara/plugins/vanilla/v2_3_0/config.py   sahara(Download)
    }
 
    oozie = vu.get_oozie(cluster)
    if oozie:
        hadoop_cfg = {