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

org.apache.crunch.io.impl
Class SourcePathTargetImpl<T>

java.lang.Object
  org.apache.crunch.io.impl.SourceTargetImpl<T>
      org.apache.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

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 org.apache.crunch.io.impl.SourceTargetImpl

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

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.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