This project has retired. For details please refer to its
Attic page.
SeqFileTableSource (Apache Crunch 0.9.0 API)
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>>
A TableSource
that uses SequenceFileInputFormat
to read the input
file.
Methods inherited from class org.apache.crunch.io.impl.FileSourceImpl |
configureSource, equals, getBundle, getConverter, getLastModifiedAt, getPath, getPaths, getSize, getType, hashCode, inputConf, pathsAsString, read |
SeqFileTableSource
public SeqFileTableSource(String path,
PTableType<K,V> ptype)
SeqFileTableSource
public SeqFileTableSource(org.apache.hadoop.fs.Path path,
PTableType<K,V> ptype)
SeqFileTableSource
public SeqFileTableSource(List<org.apache.hadoop.fs.Path> paths,
PTableType<K,V> ptype)
read
public Iterable<Pair<K,V>> read(org.apache.hadoop.conf.Configuration conf)
throws IOException
- Description copied from interface:
ReadableSource
- Returns an
Iterable
that contains the contents of this source.
- Specified by:
read
in interface ReadableSource<Pair<K,V>>
- Parameters:
conf
- The current Configuration
instance
- Returns:
- the contents of this
Source
as an Iterable
instance
- Throws:
IOException
asReadable
public ReadableData<Pair<K,V>> asReadable()
- Specified by:
asReadable
in interface ReadableSource<Pair<K,V>>
- Returns:
- a
ReadableData
instance containing the data referenced by this
ReadableSource
.
toString
public String toString()
- Overrides:
toString
in class FileSourceImpl<Pair<K,V>>
Copyright © 2014 The Apache Software Foundation. All Rights Reserved.