HashTable.TableHash (Apache HBase 1.2.12 API)

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

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) 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

HashTable.TableHash()

Constructors
Constructor and Description
`HashTable.TableHash()`

Method Summary

Methods
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
```

partitions
```
List<ImmutableBytesWritable> partitions
```

Constructor Detail
- HashTable.TableHash
```
public HashTable.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

Class HashTable.TableHash

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

hashDir

tableName

families

batchSize

numHashFiles

startRow

stopRow

scanBatch

versions

startTime

endTime

partitions

Constructor Detail

HashTable.TableHash

Method Detail

read

writePropertiesFile

readPropertiesFile

initScan

selectPartitions

writePartitionFile

readPartitionFile

toString

getDataFileName

newReader