org.apache.crunch.io

Class PathTargetImpl

java.lang.Object

org.apache.crunch.io.PathTargetImpl

All Implemented Interfaces:

MapReduceTarget, PathTarget, Target

public abstract class PathTargetImpl
extends Object
implements PathTarget

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.crunch.Target

Target.WriteMode

Constructor Summary

Constructors

Constructor and Description
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

Methods

Modifier and Type	Method and Description
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, handleExisting

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