com.cloudera.crunch.io.text
Class TextFileSource<T>

java.lang.Object
  com.cloudera.crunch.io.impl.FileSourceImpl<T>
      com.cloudera.crunch.io.text.TextFileSource<T>

All Implemented Interfaces:

ReadableSource<T>, Source<T>

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

Field Summary

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

inputFormatClass, path, ptype

Constructor Summary

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

Method Summary

long	getSize(org.apache.hadoop.conf.Configuration conf) Returns the number of bytes in this Source.
Iterable<T>	read(org.apache.hadoop.conf.Configuration conf)

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

configureSource, equals, 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, getType

Constructor Detail

TextFileSource

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

Method Detail

getSize

public long getSize(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: Source

Returns the number of bytes in this Source.

Specified by:

getSize in interface Source<T>

Overrides:

getSize in class FileSourceImpl<T>

read

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

Specified by:

read in interface ReadableSource<T>

Throws:

IOException