org.apache.hadoop.hbase.mapreduce

Class HashTable.TableHash

java.lang.Object

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

Enclosing class:

HashTable

public static class HashTable.TableHash
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	HashTable.TableHash.Reader

Field Summary

Fields

Modifier and Type	Field and Description
(package private) long	batchSize
(package private) long	endTime
(package private) String	families
(package private) org.apache.hadoop.fs.Path	hashDir
(package private) boolean	ignoreTimestamps
(package private) int	numHashFiles
(package private) List<ImmutableBytesWritable>	partitions
(package private) int	scanBatch
(package private) byte[]	startRow
(package private) long	startTime
(package private) byte[]	stopRow
(package private) String	tableName
(package private) int	versions

Constructor Summary

Constructors

Constructor and Description
TableHash()

Method Summary

Modifier and Type	Method and Description
(package private) static String	getDataFileName(int hashFileIndex)
(package private) Scan	initScan()
HashTable.TableHash.Reader	newReader(org.apache.hadoop.conf.Configuration conf, ImmutableBytesWritable startKey) Open a TableHash.Reader starting at the first hash at or after the given key.
static HashTable.TableHash	read(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path hashDir)
private void	readPartitionFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path)
(package private) void	readPropertiesFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)
(package private) void	selectPartitions(Pair<byte[][],byte[][]> regionStartEndKeys) Choose partitions between row ranges to hash to a single output file Selects region boundaries that fall within the scan range, and groups them into the desired number of partitions.
String	toString()
(package private) void	writePartitionFile(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path)
(package private) void	writePropertiesFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)

Methods inherited from class java.lang.Object

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

Field Detail

hashDir

org.apache.hadoop.fs.Path hashDir

tableName

String tableName

families

String families

batchSize

long batchSize

numHashFiles

int numHashFiles

startRow

byte[] startRow

stopRow

byte[] stopRow

scanBatch

int scanBatch

versions

int versions

startTime

long startTime

endTime

long endTime

ignoreTimestamps

boolean ignoreTimestamps

partitions

List<ImmutableBytesWritable> partitions

Constructor Detail

TableHash

public TableHash()

Method Detail

read

public static HashTable.TableHash read(org.apache.hadoop.conf.Configuration conf,
                                       org.apache.hadoop.fs.Path hashDir)
                                throws IOException

Throws:

IOException

writePropertiesFile

void writePropertiesFile(org.apache.hadoop.fs.FileSystem fs,
                         org.apache.hadoop.fs.Path path)
                  throws IOException

Throws:

IOException

readPropertiesFile

void readPropertiesFile(org.apache.hadoop.fs.FileSystem fs,
                        org.apache.hadoop.fs.Path path)
                 throws IOException

Throws:

IOException

initScan

Scan initScan()
       throws IOException

Throws:

IOException

selectPartitions

void selectPartitions(Pair<byte[][],byte[][]> regionStartEndKeys)

Choose partitions between row ranges to hash to a single output file Selects region boundaries that fall within the scan range, and groups them into the desired number of partitions.

writePartitionFile

void writePartitionFile(org.apache.hadoop.conf.Configuration conf,
                        org.apache.hadoop.fs.Path path)
                 throws IOException

Throws:

IOException

readPartitionFile

private void readPartitionFile(org.apache.hadoop.fs.FileSystem fs,
                               org.apache.hadoop.conf.Configuration conf,
                               org.apache.hadoop.fs.Path path)
                        throws IOException

Throws:

IOException

toString

public String toString()

Overrides:

toString in class Object

getDataFileName

static String getDataFileName(int hashFileIndex)

newReader

public HashTable.TableHash.Reader newReader(org.apache.hadoop.conf.Configuration conf,
                                            ImmutableBytesWritable startKey)
                                     throws IOException

Open a TableHash.Reader starting at the first hash at or after the given key.

Throws:

IOException