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

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

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

All Implemented Interfaces:

OutputHandler

public class MSCROutputHandler
extends Object
implements OutputHandler

Constructor Summary

MSCROutputHandler(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path outputPath, boolean mapOnlyJob)

Method Summary

boolean	configure(Target target, PType<?> ptype)
void	configureNode(DoNode node, Target target)
Map<Integer,PathTarget>	getMultiPaths()
boolean	isMapOnlyJob()

Methods inherited from class java.lang.Object

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

Constructor Detail

MSCROutputHandler

public MSCROutputHandler(org.apache.hadoop.mapreduce.Job job,
                         org.apache.hadoop.fs.Path outputPath,
                         boolean mapOnlyJob)

Method Detail

configureNode

public void configureNode(DoNode node,
                          Target target)

configure

public boolean configure(Target target,
                         PType<?> ptype)

Specified by:

configure in interface OutputHandler

isMapOnlyJob

public boolean isMapOnlyJob()

getMultiPaths

public Map<Integer,PathTarget> getMultiPaths()