com.cloudera.crunch.io
Class PathTargetImpl

java.lang.Object
  com.cloudera.crunch.io.PathTargetImpl

All Implemented Interfaces:

MapReduceTarget, PathTarget, Target

public abstract class PathTargetImpl
extends Object
implements PathTarget

Constructor Summary

PathTargetImpl(org.apache.hadoop.fs.Path path, Class<org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass, Class keyClass, Class valueClass)

PathTargetImpl(String path, Class<org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass, Class keyClass, Class valueClass)

Method Summary

void	configureForMapReduce(org.apache.hadoop.mapreduce.Job job, PType<?> ptype, org.apache.hadoop.fs.Path outputPath, String name)
org.apache.hadoop.fs.Path	getPath()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.cloudera.crunch.Target

accept, asSourceTarget

Constructor Detail

PathTargetImpl

public PathTargetImpl(String path,
                      Class<org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass,
                      Class keyClass,
                      Class valueClass)

PathTargetImpl

public PathTargetImpl(org.apache.hadoop.fs.Path path,
                      Class<org.apache.hadoop.mapreduce.OutputFormat> outputFormatClass,
                      Class keyClass,
                      Class valueClass)

Method Detail

configureForMapReduce

public void configureForMapReduce(org.apache.hadoop.mapreduce.Job job,
                                  PType<?> ptype,
                                  org.apache.hadoop.fs.Path outputPath,
                                  String name)

Specified by:

configureForMapReduce in interface MapReduceTarget

getPath

public org.apache.hadoop.fs.Path getPath()

Specified by:

getPath in interface PathTarget