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

org.apache.crunch.io.impl
Class FileTableSourceImpl<K,V>

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

All Implemented Interfaces:

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

Direct Known Subclasses:

SeqFileTableSource

public class FileTableSourceImpl<K,V>
extends FileSourceImpl<Pair<K,V>>
implements TableSource<K,V>

Constructor Summary

FileTableSourceImpl(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass)

Method Summary

PTableType<K,V>

getTableType()

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

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

configureSource, getSize, getType

Constructor Detail

FileTableSourceImpl

public FileTableSourceImpl(org.apache.hadoop.fs.Path path,
                           PTableType<K,V> tableType,
                           Class<? extends org.apache.hadoop.mapreduce.lib.input.FileInputFormat> formatClass)

Method Detail

getTableType

public PTableType<K,V> getTableType()

Specified by:

getTableType in interface TableSource<K,V>