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

org.apache.crunch.io.hbase
Class HFileSource

java.lang.Object
  org.apache.crunch.io.impl.FileSourceImpl<org.apache.hadoop.hbase.KeyValue>
      org.apache.crunch.io.hbase.HFileSource

All Implemented Interfaces:

ReadableSource<org.apache.hadoop.hbase.KeyValue>, Source<org.apache.hadoop.hbase.KeyValue>

public class HFileSource
extends FileSourceImpl<org.apache.hadoop.hbase.KeyValue>
implements ReadableSource<org.apache.hadoop.hbase.KeyValue>

Field Summary

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

inputBundle, path, paths, ptype

Constructor Summary

HFileSource(List<org.apache.hadoop.fs.Path> paths)

HFileSource(org.apache.hadoop.fs.Path path)

Method Summary

ReadableData<org.apache.hadoop.hbase.KeyValue>	asReadable()
long	getSize(org.apache.hadoop.conf.Configuration conf) Returns the number of bytes in this Source.
Iterable<org.apache.hadoop.hbase.KeyValue>	read(org.apache.hadoop.conf.Configuration conf) Returns an Iterable that contains the contents of this source.
String	toString()

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

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

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, getType, inputConf

Constructor Detail

HFileSource

public HFileSource(org.apache.hadoop.fs.Path path)

HFileSource

public HFileSource(List<org.apache.hadoop.fs.Path> paths)

Method Detail

read

public Iterable<org.apache.hadoop.hbase.KeyValue> 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<org.apache.hadoop.hbase.KeyValue>

Parameters:

conf - The current Configuration instance

Returns:

the contents of this Source as an Iterable instance

Throws:

IOException

asReadable

public ReadableData<org.apache.hadoop.hbase.KeyValue> asReadable()

Specified by:

asReadable in interface ReadableSource<org.apache.hadoop.hbase.KeyValue>

Returns:

a ReadableData instance containing the data referenced by this ReadableSource.

toString

public String toString()

Overrides:

toString in class FileSourceImpl<org.apache.hadoop.hbase.KeyValue>

getSize

public long getSize(org.apache.hadoop.conf.Configuration conf)

Description copied from interface: Source

Returns the number of bytes in this Source.

Specified by:

getSize in interface Source<org.apache.hadoop.hbase.KeyValue>

Overrides:

getSize in class FileSourceImpl<org.apache.hadoop.hbase.KeyValue>