Package org.apache.hadoop.hbase.mapreduce

Class HashTable.TableHash.Reader

java.lang.Object

org.apache.hadoop.hbase.mapreduce.HashTable.TableHash.Reader

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

HashTable.TableHash

public class HashTable.TableHash.Reader
extends Object
implements Closeable

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	cachedNext
private final org.apache.hadoop.conf.Configuration	conf
private ImmutableBytesWritable	hash
private int	hashFileIndex
private ImmutableBytesWritable	key
private org.apache.hadoop.io.MapFile.Reader	mapFileReader

Constructor Summary

Constructors

Constructor	Description
Reader(org.apache.hadoop.conf.Configuration conf, ImmutableBytesWritable startKey)

Method Summary

Modifier and Type	Method	Description
void	close()
ImmutableBytesWritable	getCurrentHash()	Get the current hash
ImmutableBytesWritable	getCurrentKey()	Get the current key
boolean	next()	Read the next key/hash pair.
private void	openHashFile()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

conf

private final org.apache.hadoop.conf.Configuration conf

hashFileIndex

private int hashFileIndex

mapFileReader

private org.apache.hadoop.io.MapFile.Reader mapFileReader

cachedNext

private boolean cachedNext

key

private ImmutableBytesWritable key

hash

private ImmutableBytesWritable hash

Constructor Details

Reader

Reader(org.apache.hadoop.conf.Configuration conf,
 ImmutableBytesWritable startKey)
throws IOException

Throws:

IOException

Method Details

next

public boolean next()
             throws IOException

Read the next key/hash pair. Returns true if such a pair exists and false when at the end of the data.

Throws:

IOException

getCurrentKey

public ImmutableBytesWritable getCurrentKey()

Get the current key

Returns:

the current key or null if there is no current key

getCurrentHash

public ImmutableBytesWritable getCurrentHash()

Get the current hash

Returns:

the current hash or null if there is no current hash

openHashFile

private void openHashFile()
                   throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException