com.cloudera.crunch.io.impl
Class SourcePathTargetImpl<T>

java.lang.Object
  com.cloudera.crunch.io.impl.SourceTargetImpl<T>
      com.cloudera.crunch.io.impl.SourcePathTargetImpl<T>

All Implemented Interfaces:

MapReduceTarget, PathTarget, Source<T>, SourceTarget<T>, Target

Direct Known Subclasses:

ReadableSourcePathTargetImpl, TableSourcePathTargetImpl

public class SourcePathTargetImpl<T>
extends SourceTargetImpl<T>
implements PathTarget

Field Summary

Fields inherited from class com.cloudera.crunch.io.impl.SourceTargetImpl

source, target

Constructor Summary

SourcePathTargetImpl(Source<T> source, PathTarget target)

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 com.cloudera.crunch.io.impl.SourceTargetImpl

accept, asSourceTarget, configureSource, equals, getSize, getType, hashCode, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.cloudera.crunch.Target

accept, asSourceTarget

Constructor Detail

SourcePathTargetImpl

public SourcePathTargetImpl(Source<T> source,
                            PathTarget target)

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