com.cloudera.crunch.io.impl
Class FileTableSourceImpl<K,V>

java.lang.Object
  com.cloudera.crunch.io.impl.FileSourceImpl<Pair<K,V>>
      com.cloudera.crunch.io.impl.FileTableSourceImpl<K,V>

All Implemented Interfaces:

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

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

Field Summary

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

inputFormatClass, path, ptype

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 com.cloudera.crunch.io.impl.FileSourceImpl

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

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>