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

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

src/s/a/sahara-2014.1/sahara/service/edp/job_manager.py   sahara(Download)
    for data_source in [input_source, output_source]:
        if data_source and data_source.type == 'hdfs':
            h.configure_cluster_for_hdfs(cluster, data_source)
 
    hdfs_user = _get_hdfs_user(cluster)

src/s/a/sahara-HEAD/sahara/service/edp/job_manager.py   sahara(Download)
    for data_source in [input_source, output_source]:
        if data_source and data_source.type == 'hdfs':
            h.configure_cluster_for_hdfs(cluster, data_source)
 
    hdfs_user = _get_hdfs_user(cluster)