public static class HashTable.TableHash extends Object
Modifier and Type | Class and Description |
---|---|
class |
HashTable.TableHash.Reader |
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) boolean |
rawScan |
(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 and Description |
---|
TableHash() |
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) |
org.apache.hadoop.fs.Path hashDir
long batchSize
int numHashFiles
byte[] startRow
byte[] stopRow
int scanBatch
int versions
long startTime
long endTime
boolean ignoreTimestamps
boolean rawScan
List<ImmutableBytesWritable> partitions
public TableHash()
public static HashTable.TableHash read(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path hashDir) throws IOException
IOException
void writePropertiesFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
IOException
void readPropertiesFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path) throws IOException
IOException
Scan initScan() throws IOException
IOException
void selectPartitions(Pair<byte[][],byte[][]> regionStartEndKeys)
void writePartitionFile(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path) throws IOException
IOException
private void readPartitionFile(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.Path path) throws IOException
IOException
static String getDataFileName(int hashFileIndex)
public HashTable.TableHash.Reader newReader(org.apache.hadoop.conf.Configuration conf, ImmutableBytesWritable startKey) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.