Java 类org.apache.hadoop.mapreduce.ContextFactory 实例源码

项目:spork-streaming    文件:HadoopShims.java   
static public JobContext cloneJobContext(JobContext original) throws IOException, InterruptedException {
    JobContext newContext = ContextFactory.cloneContext(original,
            new JobConf(original.getConfiguration()));
    return newContext;
}
项目:spork    文件:HadoopShims.java   
static public JobContext cloneJobContext(JobContext original) throws IOException, InterruptedException {
    JobContext newContext = ContextFactory.cloneContext(original,
            new JobConf(original.getConfiguration()));
    return newContext;
}
项目:PonIC    文件:HadoopShims.java   
static public JobContext cloneJobContext(JobContext original) throws IOException, InterruptedException {
    JobContext newContext = ContextFactory.cloneContext(original, original.getConfiguration());
    return newContext;
}
项目:sedge    文件:HadoopShims.java   
static public JobContext cloneJobContext(JobContext original) throws IOException, InterruptedException {
    JobContext newContext = ContextFactory.cloneContext(original, original.getConfiguration());
    return newContext;
}