Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.coprocessor |
Provides client classes for invoking Coprocessor RPC protocols
|
org.apache.hadoop.hbase.filter |
Provides row-level filters applied to HRegion scan results during calls to
ResultScanner.next() . |
org.apache.hadoop.hbase.mapred |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.rest.client | |
org.apache.hadoop.hbase.rsgroup | |
org.apache.hadoop.hbase.test | |
org.apache.hadoop.hbase.util |
Modifier and Type | Method and Description |
---|---|
Table |
HBaseTestingUtility.createTable(TableName tableName,
java.lang.String family)
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
java.lang.String[] families)
Create a table.
|
Modifier and Type | Method and Description |
---|---|
static void |
MetaTableAccessor.addRegionToMeta(Table meta,
HRegionInfo regionInfo)
Adds a hbase:meta row for the specified new region to the given catalog table.
|
static void |
MetaTableAccessor.addRegionToMeta(Table meta,
HRegionInfo regionInfo,
HRegionInfo splitA,
HRegionInfo splitB)
Adds a (single) hbase:meta row for the specified new region and its daughters.
|
java.lang.String |
HBaseTestingUtility.checksumRows(Table table)
Return an md5 digest of the entire contents of a table.
|
int |
HBaseTestingUtility.countRows(Table table)
Return the number of rows in the given table.
|
int |
HBaseTestingUtility.countRows(Table table,
byte[]... families) |
int |
HBaseTestingUtility.countRows(Table table,
Scan scan) |
void |
HBaseTestingUtility.loadNumericRows(Table t,
byte[] f,
int startRow,
int endRow) |
int |
HBaseTestingUtility.loadTable(Table t,
byte[] f)
Load table with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[][] f)
Load table of multiple column families with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[][] f,
byte[] value)
Load table of multiple column families with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[][] f,
byte[] value,
boolean writeToWAL)
Load table of multiple column families with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[] f,
boolean writeToWAL)
Load table with rows from 'aaa' to 'zzz'.
|
void |
HBaseTestingUtility.verifyNumericRows(Table table,
byte[] f,
int startRow,
int endRow,
int replicaId) |
Constructor and Description |
---|
HTableIncommon(Table table) |
Modifier and Type | Interface and Description |
---|---|
interface |
HTableInterface
Deprecated.
use
Table instead |
Modifier and Type | Class and Description |
---|---|
class |
HTable
An implementation of
Table . |
class |
HTableWrapper
A wrapper for HTable.
|
Modifier and Type | Method and Description |
---|---|
protected Table |
TestSnapshotCloneIndependence.createTable(TableName table,
byte[] family) |
Table |
Connection.getTable(TableName tableName)
Retrieve a Table implementation for accessing a table.
|
Table |
Connection.getTable(TableName tableName,
java.util.concurrent.ExecutorService pool)
Retrieve a Table implementation for accessing a table.
|
Modifier and Type | Method and Description |
---|---|
protected int |
TestMobRestoreSnapshotFromClient.countRows(Table table,
byte[]... families) |
protected int |
TestRestoreSnapshotFromClient.countRows(Table table,
byte[]... families) |
protected int |
TestSnapshotCloneIndependence.countRows(Table table,
byte[]... families) |
protected void |
TestSnapshotCloneIndependence.loadData(Table table,
byte[]... families) |
void |
TestScannersFromClientSide.testSmallScan(Table table,
boolean reversed,
int rows,
int columns)
Run through a variety of test configurations with a small scan
|
Modifier and Type | Method and Description |
---|---|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.avg(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
This is the client side interface/handle for calling the average method for
a given cf-cq combination.
|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.max(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
It gives the maximum value of a column for a given column family for the
given range.
|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.median(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
This is the client side interface/handler for calling the median method for a
given cf-cq combination.
|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.min(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
It gives the minimum value of a column for a given column family for the
given range.
|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.rowCount(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
It gives the row count, by summing up the individual results obtained from
regions.
|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.std(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
This is the client side interface/handle for calling the std method for a
given cf-cq combination.
|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.sum(Table table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
It sums up the value returned from various regions.
|
Constructor and Description |
---|
SecureBulkLoadClient(Table table) |
Modifier and Type | Method and Description |
---|---|
protected static Table |
FilterTestingCluster.openTable(java.lang.String tableName) |
Modifier and Type | Method and Description |
---|---|
static Table |
TestTableMapReduceUtil.createAndFillTable(TableName tableName) |
static Table |
TestTableInputFormat.createTable(byte[] tableName)
Setup a table with two rows and values.
|
static Table |
TestTableInputFormat.createTable(byte[] tableName,
byte[][] families)
Setup a table with two rows and values per column family.
|
protected Table |
TableInputFormatBase.getTable()
Allows subclasses to get the
Table . |
Modifier and Type | Method and Description |
---|---|
void |
TableRecordReader.setHTable(Table htable) |
void |
TableRecordReaderImpl.setHTable(Table htable) |
Modifier and Type | Method and Description |
---|---|
static Table |
TestTableInputFormat.createTable(byte[] tableName)
Setup a table with two rows and values.
|
static Table |
TestTableInputFormat.createTable(byte[] tableName,
byte[][] families)
Setup a table with two rows and values per column family.
|
protected Table |
TableInputFormatBase.getTable()
Allows subclasses to get the
Table . |
Modifier and Type | Method and Description |
---|---|
protected void |
LoadIncrementalHFiles.bulkLoadPhase(Table table,
Connection conn,
java.util.concurrent.ExecutorService pool,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
<any> regionGroups,
boolean copyFile,
java.util.Map<LoadIncrementalHFiles.LoadQueueItem,java.nio.ByteBuffer> item2RegionMap)
This takes the LQI's grouped by likely regions and attempts to bulk load
them.
|
static void |
HFileOutputFormat2.configureIncrementalLoad(Job job,
Table table,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given
table.
|
static void |
HFileOutputFormat2.configureIncrementalLoadMap(Job job,
Table table) |
void |
LoadIncrementalHFiles.doBulkLoad(java.util.Map<byte[],java.util.List<Path>> map,
Admin admin,
Table table,
RegionLocator regionLocator,
boolean silence,
boolean copyFile)
Perform a bulk load of the given directory into the given
pre-existing table.
|
void |
LoadIncrementalHFiles.doBulkLoad(Path hfofDir,
Admin admin,
Table table,
RegionLocator regionLocator)
Perform a bulk load of the given directory into the given
pre-existing table.
|
void |
LoadIncrementalHFiles.doBulkLoad(Path hfofDir,
Admin admin,
Table table,
RegionLocator regionLocator,
boolean silence,
boolean copyFile)
Perform a bulk load of the given directory into the given
pre-existing table.
|
protected Pair<java.util.List<LoadIncrementalHFiles.LoadQueueItem>,java.lang.String> |
LoadIncrementalHFiles.groupOrSplit(<any> regionGroups,
LoadIncrementalHFiles.LoadQueueItem item,
Table table,
Pair<byte[][],byte[][]> startEndKeys)
Attempt to assign the given load queue item into its target region group.
|
void |
LoadIncrementalHFiles.loadHFileQueue(Table table,
Connection conn,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
Pair<byte[][],byte[][]> startEndKeys)
Used by the replication sink to load the hfiles from the source cluster.
|
void |
LoadIncrementalHFiles.loadHFileQueue(Table table,
Connection conn,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
Pair<byte[][],byte[][]> startEndKeys,
boolean copyFile)
Used by the replication sink to load the hfiles from the source cluster.
|
void |
LoadIncrementalHFiles.prepareHFileQueue(java.util.Map<byte[],java.util.List<Path>> map,
Table table,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
boolean silence)
Prepare a collection of
LoadIncrementalHFiles.LoadQueueItem from list of source hfiles contained in the
passed directory and validates whether the prepared queue has all the valid table column
families in it. |
void |
LoadIncrementalHFiles.prepareHFileQueue(Path hfofDir,
Table table,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
boolean validateHFile)
Prepare a collection of
LoadIncrementalHFiles.LoadQueueItem from list of source hfiles contained in the
passed directory and validates whether the prepared queue has all the valid table column
families in it. |
void |
LoadIncrementalHFiles.prepareHFileQueue(Path hfilesDir,
Table table,
java.util.Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
boolean validateHFile,
boolean silence)
Prepare a collection of
LoadIncrementalHFiles.LoadQueueItem from list of source hfiles contained in the
passed directory and validates whether the prepared queue has all the valid table column
families in it. |
void |
TableRecordReader.setHTable(Table htable)
Deprecated.
Use setTable() instead.
|
void |
TableRecordReaderImpl.setHTable(Table htable)
Sets the HBase table.
|
void |
TableRecordReader.setTable(Table table) |
protected java.util.List<LoadIncrementalHFiles.LoadQueueItem> |
LoadIncrementalHFiles.splitStoreFile(LoadIncrementalHFiles.LoadQueueItem item,
Table table,
byte[] startKey,
byte[] splitKey) |
Modifier and Type | Method and Description |
---|---|
void |
TestScannerRetriableFailure.loadTable(Table table,
int numRows) |
Modifier and Type | Class and Description |
---|---|
class |
RemoteHTable
HTable interface to remote tables accessed via REST gateway
|
Modifier and Type | Method and Description |
---|---|
java.util.List<RSGroupInfo> |
RSGroupSerDe.retrieveGroupList(Table groupTable) |
Modifier and Type | Method and Description |
---|---|
protected void |
IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread.verifyResultsAndUpdateMetrics(boolean verify,
Get[] gets,
long elapsedNano,
Result[] results,
Table table,
boolean isNullExpected) |
Modifier and Type | Method and Description |
---|---|
Table |
ConnectionCache.getTable(java.lang.String tableName)
Caller closes the table afterwards.
|