Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.backup | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
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.master | |
org.apache.hadoop.hbase.master.handler | |
org.apache.hadoop.hbase.master.procedure | |
org.apache.hadoop.hbase.namespace | |
org.apache.hadoop.hbase.quotas | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.rest | |
org.apache.hadoop.hbase.rsgroup |
Modifier and Type | Class and Description |
---|---|
class |
IntegrationTestingUtility
Facility for integration/system tests.
|
Modifier and Type | Field and Description |
---|---|
protected HBaseTestingUtility |
HBaseTestCase.testUtil
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static HBaseTestingUtility |
HBaseTestingUtility.createLocalHTU()
Create an HBaseTestingUtility where all tmp files are written to the local test data dir.
|
static HBaseTestingUtility |
HBaseTestingUtility.createLocalHTU(Configuration c)
Create an HBaseTestingUtility where all tmp files are written to the local test data dir.
|
Modifier and Type | Method and Description |
---|---|
static ZooKeeperWatcher |
HBaseTestingUtility.createAndForceNodeToOpenedState(HBaseTestingUtility TEST_UTIL,
HRegion region,
ServerName serverName)
Creates a znode with OPENED state.
|
static ZooKeeperWatcher |
HBaseTestingUtility.createAndForceNodeToOpenedState(HBaseTestingUtility TEST_UTIL,
Region region,
ServerName serverName)
Creates a znode with OPENED state.
|
static ZooKeeperWatcher |
HBaseTestingUtility.getZooKeeperWatcher(HBaseTestingUtility TEST_UTIL)
Gets a ZooKeeperWatcher.
|
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestBackupBase.TEST_UTIL |
protected static HBaseTestingUtility |
TestBackupBase.TEST_UTIL2 |
Modifier and Type | Method and Description |
---|---|
static void |
TestBackupBase.waitForSystemTable(HBaseTestingUtility TEST_UTIL) |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestCloneSnapshotFromClient.TEST_UTIL |
protected static HBaseTestingUtility |
TestFromClientSide.TEST_UTIL |
protected static HBaseTestingUtility |
TestFromClientSideNoCodec.TEST_UTIL |
protected static HBaseTestingUtility |
TestIncrementsFromClientSide.TEST_UTIL |
protected static HBaseTestingUtility |
TestRestoreSnapshotFromClient.TEST_UTIL |
protected static HBaseTestingUtility |
TestSizeFailures.TEST_UTIL |
protected static HBaseTestingUtility |
TestSnapshotCloneIndependence.UTIL |
protected static HBaseTestingUtility |
TestSnapshotFromClient.UTIL |
Modifier and Type | Method and Description |
---|---|
static void |
TestTableSnapshotScanner.createTableAndSnapshot(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
int numRegions) |
static void |
TestMetaWithReplicas.shutdownMetaAndDoValidations(HBaseTestingUtility util) |
protected void |
TestCloneSnapshotFromClient.verifyRowCount(HBaseTestingUtility util,
TableName tableName,
long expectedRows) |
protected void |
TestMobCloneSnapshotFromClient.verifyRowCount(HBaseTestingUtility util,
TableName tableName,
long expectedRows) |
protected void |
TestMobRestoreSnapshotFromClient.verifyRowCount(HBaseTestingUtility util,
TableName tableName,
long expectedRows) |
protected void |
TestRestoreSnapshotFromClient.verifyRowCount(HBaseTestingUtility util,
TableName tableName,
long expectedRows) |
Constructor and Description |
---|
CreateTableThread(HBaseTestingUtility UTIL) |
Modifier and Type | Method and Description |
---|---|
static void |
TestTableSnapshotInputFormat.doTestWithMapReduce(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
byte[] startRow,
byte[] endRow,
Path tableDir,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
protected void |
TestTableSnapshotInputFormat.testWithMapReduceImpl(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
Path tableDir,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
protected void |
TestTableSnapshotInputFormat.testWithMockedMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int expectedNumSplits) |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestSimpleTotalOrderPartitioner.TEST_UTIL |
protected static HBaseTestingUtility |
TestImportTsv.util |
protected static HBaseTestingUtility |
TestImportTSVWithOperationAttributes.util |
protected static HBaseTestingUtility |
TestImportTSVWithTTLs.util |
protected static HBaseTestingUtility |
TestImportTSVWithVisibilityLabels.util |
protected HBaseTestingUtility |
TableSnapshotInputFormatTestBase.UTIL |
protected static HBaseTestingUtility |
TestTableMapReduceBase.UTIL |
Modifier and Type | Method and Description |
---|---|
protected static void |
TableSnapshotInputFormatTestBase.createTableAndSnapshot(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
byte[] startRow,
byte[] endRow,
int numRegions) |
protected static Tool |
TestImportTsv.doMROnTableTest(HBaseTestingUtility util,
java.lang.String family,
java.lang.String data,
java.lang.String[] args) |
protected static Tool |
TestImportTsv.doMROnTableTest(HBaseTestingUtility util,
java.lang.String family,
java.lang.String data,
java.lang.String[] args,
int valueMultiplier) |
protected static Tool |
TestImportTSVWithTTLs.doMROnTableTest(HBaseTestingUtility util,
java.lang.String family,
java.lang.String data,
java.lang.String[] args,
int valueMultiplier) |
protected static Tool |
TestImportTSVWithVisibilityLabels.doMROnTableTest(HBaseTestingUtility util,
java.lang.String family,
java.lang.String data,
java.lang.String[] args,
int valueMultiplier)
Run an ImportTsv job and perform basic validation on the results.
|
protected static Tool |
TestImportTsv.doMROnTableTest(HBaseTestingUtility util,
java.lang.String family,
java.lang.String data,
java.lang.String[] args,
int valueMultiplier,
int expectedKVCount)
Run an ImportTsv job and perform basic validation on the results.
|
static void |
TestTableSnapshotInputFormat.doTestWithMapReduce(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
byte[] startRow,
byte[] endRow,
Path tableDir,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
static int |
TestLoadIncrementalHFiles.loadHFiles(java.lang.String testName,
HTableDescriptor htd,
HBaseTestingUtility util,
byte[] fam,
byte[] qual,
boolean preCreateTable,
byte[][] tableSplitKeys,
byte[][][] hfileRanges,
boolean useMap,
boolean deleteFile,
boolean copyFiles,
int initRowCount,
int factor,
boolean managed) |
protected void |
TableSnapshotInputFormatTestBase.testWithMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
protected abstract void |
TableSnapshotInputFormatTestBase.testWithMapReduceImpl(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
Path tableDir,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
protected void |
TestTableSnapshotInputFormat.testWithMapReduceImpl(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
Path tableDir,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
protected abstract void |
TableSnapshotInputFormatTestBase.testWithMockedMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int expectedNumSplits) |
void |
TestTableSnapshotInputFormat.testWithMockedMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int expectedNumSplits) |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestWarmupRegion.TEST_UTIL |
Modifier and Type | Method and Description |
---|---|
static void |
TestEnableTableHandler.createTable(HBaseTestingUtility testUtil,
HBaseAdmin admin,
HTableDescriptor htd,
byte[][] splitKeys) |
static void |
TestEnableTableHandler.createTable(HBaseTestingUtility testUtil,
HTableDescriptor htd,
byte[][] splitKeys) |
static void |
TestEnableTableHandler.deleteTable(HBaseTestingUtility testUtil,
HBaseAdmin admin,
TableName tableName) |
static void |
TestEnableTableHandler.deleteTable(HBaseTestingUtility testUtil,
TableName tableName) |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestAddColumnFamilyProcedure.UTIL |
protected static HBaseTestingUtility |
TestCreateTableProcedure.UTIL |
protected static HBaseTestingUtility |
TestDeleteColumnFamilyProcedure.UTIL |
protected static HBaseTestingUtility |
TestDeleteTableProcedure.UTIL |
protected static HBaseTestingUtility |
TestDisableTableProcedure.UTIL |
protected static HBaseTestingUtility |
TestEnableTableProcedure.UTIL |
protected static HBaseTestingUtility |
TestMasterFailoverWithProcedures.UTIL |
protected static HBaseTestingUtility |
TestModifyColumnFamilyProcedure.UTIL |
protected static HBaseTestingUtility |
TestModifyTableProcedure.UTIL |
protected static HBaseTestingUtility |
TestProcedureAdmin.UTIL |
protected static HBaseTestingUtility |
TestSafemodeBringsDownMaster.UTIL |
protected static HBaseTestingUtility |
TestTruncateTableProcedure.UTIL |
protected static HBaseTestingUtility |
TestWALProcedureStoreOnHDFS.UTIL |
Modifier and Type | Method and Description |
---|---|
static void |
TestMasterFailoverWithProcedures.masterFailover(HBaseTestingUtility testUtil) |
static <TState> void |
TestMasterFailoverWithProcedures.testRecoveryAndDoubleExecution(HBaseTestingUtility testUtil,
long procId,
int lastStepBeforeFailover,
TState[] states) |
static void |
TestMasterFailoverWithProcedures.waitBackupMaster(HBaseTestingUtility testUtil,
HMaster oldMaster) |
Modifier and Type | Method and Description |
---|---|
static void |
TestNamespaceAuditor.waitForQuotaInitialize(HBaseTestingUtility util) |
Constructor and Description |
---|
SpaceQuotaHelperForTests(HBaseTestingUtility testUtil,
TestName testName,
java.util.concurrent.atomic.AtomicLong counter) |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestCompactionPolicy.TEST_UTIL |
Modifier and Type | Method and Description |
---|---|
static void |
TestRegionServerNoMaster.checkRegionIsClosed(HBaseTestingUtility HTU,
HRegionServer rs,
HRegionInfo hri) |
static void |
TestRegionServerNoMaster.checkRegionIsOpened(HBaseTestingUtility HTU,
HRegionServer rs,
HRegionInfo hri) |
static void |
TestRegionServerNoMaster.closeRegion(HBaseTestingUtility HTU,
HRegionServer rs,
HRegionInfo hri) |
static void |
TestRegionServerNoMaster.flushRegion(HBaseTestingUtility HTU,
HRegionInfo regionInfo)
Flush the given region in the mini cluster.
|
static void |
TestRegionServerNoMaster.openRegion(HBaseTestingUtility HTU,
HRegionServer rs,
HRegionInfo hri) |
static void |
TestRegionServerNoMaster.stopMasterAndAssignMeta(HBaseTestingUtility HTU) |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
RowResourceBase.TEST_UTIL |
Modifier and Type | Field and Description |
---|---|
protected static HBaseTestingUtility |
TestRSGroupsBase.TEST_UTIL |