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, TextFileTableSource

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

Field Summary

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

inputBundle, path, paths, ptype

Constructor Summary

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

FileTableSourceImpl(List<org.apache.hadoop.fs.Path> paths, PTableType<K,V> tableType, FormatBundle bundle)

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

FileTableSourceImpl(org.apache.hadoop.fs.Path path, PTableType<K,V> tableType, FormatBundle bundle)

Method Summary

PTableType<K,V>

getTableType()

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

configureSource, equals, getBundle, getConverter, getLastModifiedAt, getPath, getPaths, getSize, getType, hashCode, inputConf, pathsAsString, read, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.crunch.Source

configureSource, getConverter, getLastModifiedAt, getSize, getType, inputConf

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)

FileTableSourceImpl

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

FileTableSourceImpl

public FileTableSourceImpl(org.apache.hadoop.fs.Path path,
                           PTableType<K,V> tableType,
                           FormatBundle bundle)

FileTableSourceImpl

public FileTableSourceImpl(List<org.apache.hadoop.fs.Path> paths,
                           PTableType<K,V> tableType,
                           FormatBundle bundle)

Method Detail

getTableType

public PTableType<K,V> getTableType()

Specified by:

getTableType in interface TableSource<K,V>