This project has retired. For details please refer to its Attic page.

org.apache.crunch.impl.mr.plan
Class MSCRPlanner

java.lang.Object
  org.apache.crunch.impl.mr.plan.MSCRPlanner

public class MSCRPlanner
extends Object

Constructor Summary

MSCRPlanner(MRPipeline pipeline, Map<PCollectionImpl<?>,Set<Target>> outputs, Map<PCollectionImpl<?>,MaterializableIterable> toMaterialize)

Method Summary

MRExecutor

plan(Class<?> jarClass, org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MSCRPlanner

public MSCRPlanner(MRPipeline pipeline,
                   Map<PCollectionImpl<?>,Set<Target>> outputs,
                   Map<PCollectionImpl<?>,MaterializableIterable> toMaterialize)

Method Detail

plan

public MRExecutor plan(Class<?> jarClass,
                       org.apache.hadoop.conf.Configuration conf)
                throws IOException

Throws:

IOException