This project has retired. For details please refer to its Attic page.
PathTargetImpl (Apache Crunch 0.4.0-incubating API)

org.apache.crunch.io
Class PathTargetImpl

java.lang.Object
  extended by org.apache.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
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface org.apache.crunch.io.PathTarget
getFileNamingScheme
 
Methods inherited from interface org.apache.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


Copyright © 2012 The Apache Software Foundation. All Rights Reserved.