com.cloudera.crunch.io.seq
Class SeqFileSource<T>

java.lang.Object
  com.cloudera.crunch.io.impl.FileSourceImpl<T>
      com.cloudera.crunch.io.seq.SeqFileSource<T>

All Implemented Interfaces:

ReadableSource<T>, Source<T>

public class SeqFileSource<T>
extends FileSourceImpl<T>
implements ReadableSource<T>

Field Summary

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

inputFormatClass, path, ptype

Constructor Summary

SeqFileSource(org.apache.hadoop.fs.Path path, PType<T> ptype)

Method Summary

Iterable<T>	read(org.apache.hadoop.conf.Configuration conf)
String	toString()

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

configureSource, equals, getSize, getType, hashCode

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

Constructor Detail

SeqFileSource

public SeqFileSource(org.apache.hadoop.fs.Path path,
                     PType<T> ptype)

Method Detail

read

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

Specified by:

read in interface ReadableSource<T>

Throws:

IOException

toString

public String toString()

Overrides:

toString in class FileSourceImpl<T>