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

org.apache.crunch.io.seq
Class SeqFileTableSource<K,V>

java.lang.Object
  org.apache.crunch.io.impl.FileSourceImpl<Pair<K,V>>
      org.apache.crunch.io.impl.FileTableSourceImpl<K,V>
          org.apache.crunch.io.seq.SeqFileTableSource<K,V>

All Implemented Interfaces:

ReadableSource<Pair<K,V>>, Source<Pair<K,V>>, TableSource<K,V>

public class SeqFileTableSource<K,V>
extends FileTableSourceImpl<K,V>
implements ReadableSource<Pair<K,V>>

Constructor Summary

SeqFileTableSource(org.apache.hadoop.fs.Path path, PTableType<K,V> ptype)

SeqFileTableSource(String path, PTableType<K,V> ptype)

Method Summary

Iterable<Pair<K,V>>	read(org.apache.hadoop.conf.Configuration conf)
String	toString()

Methods inherited from class org.apache.crunch.io.impl.FileTableSourceImpl

getTableType

Methods inherited from class org.apache.crunch.io.impl.FileSourceImpl

configureSource, equals, getSize, getType, hashCode

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.crunch.Source

configureSource, getSize, getType

Constructor Detail

SeqFileTableSource

public SeqFileTableSource(String path,
                          PTableType<K,V> ptype)

SeqFileTableSource

public SeqFileTableSource(org.apache.hadoop.fs.Path path,
                          PTableType<K,V> ptype)

Method Detail

read

public Iterable<Pair<K,V>> read(org.apache.hadoop.conf.Configuration conf)
                         throws IOException

Specified by:

read in interface ReadableSource<Pair<K,V>>

Throws:

IOException

toString

public String toString()

Overrides:

toString in class FileSourceImpl<Pair<K,V>>