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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

AvroFileSourceTarget, SeqFileSourceTarget, TextFileSourceTarget

public class ReadableSourcePathTargetImpl<T>
extends SourcePathTargetImpl<T>
implements ReadableSourceTarget<T>

Field Summary

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

source, target

Constructor Summary

ReadableSourcePathTargetImpl(ReadableSource<T> source, PathTarget target)

Method Summary

Iterable<T>

read(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class com.cloudera.crunch.io.impl.SourcePathTargetImpl

configureForMapReduce, 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.Source

configureSource, getSize, getType

Methods inherited from interface com.cloudera.crunch.Target

accept, asSourceTarget

Constructor Detail

ReadableSourcePathTargetImpl

public ReadableSourcePathTargetImpl(ReadableSource<T> source,
                                    PathTarget target)

Method Detail

read

public Iterable<T> read(org.apache.hadoop.conf.Configuration conf)
                 throws IOException

Specified by:

read in interface ReadableSource<T>

Throws:

IOException