| Modifier and Type | Field and Description |
|---|---|
static TableName |
TableName.BACKUP_TABLE_NAME
The backup table's name.
|
static TableName |
HTestConst.DEFAULT_TABLE |
static TableName |
TableName.META_TABLE_NAME
The hbase:meta table's name.
|
static TableName |
TableName.NAMESPACE_TABLE_NAME
The Namespace table's name.
|
static TableName |
TableName.OLD_META_TABLE_NAME
TableName for old .META.
|
static TableName |
TableName.OLD_ROOT_TABLE_NAME
TableName for old -ROOT- table.
|
protected static TableName |
IntegrationTestManyRegions.TABLE_NAME |
| Modifier and Type | Method and Description |
|---|---|
TableName |
HRegionInfo.getTable()
Get current table name of the region
|
static TableName |
HRegionInfo.getTable(byte[] regionName)
Gets the table name from the specified region name.
|
TableName |
IntegrationTestAcidGuarantees.getTablename() |
abstract TableName |
IntegrationTestBase.getTablename() |
TableName |
IntegrationTestDDLMasterFailover.getTablename() |
TableName |
IntegrationTestIngest.getTablename() |
TableName |
IntegrationTestRegionReplicaPerf.getTablename() |
TableName |
HTableDescriptor.getTableName()
Get the name of the table
|
static TableName |
TableName.valueOf(byte[] fullName) |
static TableName |
TableName.valueOf(byte[] namespace,
byte[] qualifier) |
static TableName |
TableName.valueOf(java.nio.ByteBuffer namespace,
java.nio.ByteBuffer qualifier) |
static TableName |
TableName.valueOf(java.lang.String name) |
static TableName |
TableName.valueOf(java.lang.String namespaceAsString,
java.lang.String qualifierAsString) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Set<TableName> |
MockRegionServerServices.getOnlineTables() |
java.util.Set<TableName> |
TableStateManager.getTablesInStates(ZooKeeperProtos.Table.State... states) |
| Modifier and Type | Method and Description |
|---|---|
void |
TableStateManager.checkAndRemoveTableState(TableName tableName,
ZooKeeperProtos.Table.State states,
boolean deletePermanentState)
If the table is found in the given state the in-memory state is removed.
|
void |
HBaseTestingUtility.compact(TableName tableName,
boolean major)
Compact all of a table's reagion in the mini hbase cluster
|
void |
MiniHBaseCluster.compact(TableName tableName,
boolean major)
Call flushCache on all regions of the specified table.
|
int |
TableName.compareTo(TableName tableName)
For performance reasons, the ordering is not lexicographic.
|
int |
HBaseTestingUtility.countRows(TableName tableName)
Return the number of rows in the given table.
|
HTable |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[] family)
Create a table with multiple regions.
|
HTable |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[][] families)
Create a table with multiple regions.
|
HTable |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[][] families,
int numVersions)
Create a table with multiple regions.
|
HTable |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[] family,
int numRegions)
Create a table with multiple regions.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(Configuration conf,
TableName tableName,
byte[][] columnFamilies,
Compression.Algorithm compression,
DataBlockEncoding dataBlockEncoding,
int numRegionsPerServer,
int regionReplication,
Durability durability)
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(Configuration conf,
TableName tableName,
byte[] columnFamily,
Compression.Algorithm compression,
DataBlockEncoding dataBlockEncoding)
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(Configuration conf,
TableName tableName,
byte[] columnFamily,
Compression.Algorithm compression,
DataBlockEncoding dataBlockEncoding,
int numRegionsPerServer,
int regionReplication,
Durability durability)
Creates a pre-split table for load testing.
|
static byte[] |
HRegionInfo.createRegionName(TableName tableName,
byte[] startKey,
byte[] id,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
HRegionInfo.createRegionName(TableName tableName,
byte[] startKey,
byte[] id,
int replicaId,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
HRegionInfo.createRegionName(TableName tableName,
byte[] startKey,
long regionid,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
HRegionInfo.createRegionName(TableName tableName,
byte[] startKey,
long regionid,
int replicaId,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
HRegionInfo.createRegionName(TableName tableName,
byte[] startKey,
java.lang.String id,
boolean newFormat)
Make a region name of passed parameters.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[] family)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
byte[][] splitKeys)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
byte[][] splitKeys,
Configuration c)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
Configuration c)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
Configuration c,
int numVersions)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions,
byte[][] splitKeys)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions,
byte[] startKey,
byte[] endKey,
int numRegions) |
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[] family,
byte[][] splitRows)
Create a table.
|
HTable |
HBaseTestingUtility.createTable(TableName tableName,
byte[] family,
int numVersions)
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
java.lang.String family)
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
java.lang.String[] families)
Create a table.
|
HTableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName tableName,
byte[] family) |
HTableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName tableName,
byte[][] families,
int maxVersions) |
void |
HBaseTestingUtility.deleteTable(TableName tableName)
Drop an existing table
|
HTable |
HBaseTestingUtility.deleteTableData(TableName tableName)
Provide an existing table name to truncate.
|
void |
HBaseTestingUtility.deleteTableIfAny(TableName tableName)
Drop an existing table
|
java.lang.String |
HBaseTestingUtility.explainTableAvailability(TableName tableName) |
java.lang.String |
HBaseTestingUtility.explainTableState(TableName tableName) |
java.util.List<HRegion> |
MiniHBaseCluster.findRegionsForTable(TableName tableName) |
void |
HBaseTestingUtility.flush(TableName tableName)
Flushes all caches in the mini hbase cluster
|
void |
MiniHBaseCluster.flushcache(TableName tableName)
Call flushCache on all regions of the specified table.
|
HTableDescriptor |
TableDescriptors.get(TableName tableName) |
long |
ClusterStatus.getLastMajorCompactionTsForTable(TableName table) |
java.util.List<byte[]> |
HBaseTestingUtility.getMetaTableRows(TableName tableName)
Returns all rows from the hbase:meta table for a given user table
|
java.util.List<Region> |
MockRegionServerServices.getOnlineRegions(TableName tableName) |
static int |
MetaTableAccessor.getRegionCount(Configuration c,
TableName tableName)
Count regions in
hbase:meta for passed table. |
java.util.List<HRegion> |
MiniHBaseCluster.getRegions(TableName tableName) |
HRegionServer |
HBaseTestingUtility.getRSForFirstRegionInTable(TableName tableName)
Tool to get the reference to the region server object that holds the
region of the specified user table.
|
static Scan |
MetaTableAccessor.getScanForTableName(TableName tableName)
This method creates a Scan object that will only scan catalog rows that
belong to the specified table.
|
ServerName |
DistributedHBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName) |
abstract ServerName |
HBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName)
Get the ServerName of region server serving the specified region
|
ServerName |
MiniHBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName) |
HRegion |
HBaseTestingUtility.getSplittableRegion(TableName tableName,
int maxAttempts) |
HTableInterface |
CoprocessorEnvironment.getTable(TableName tableName) |
HTableInterface |
CoprocessorEnvironment.getTable(TableName tableName,
java.util.concurrent.ExecutorService service) |
static java.util.List<HRegionInfo> |
MetaTableAccessor.getTableRegions(ZooKeeperWatcher zkw,
Connection connection,
TableName tableName)
Gets all of the regions of the specified table.
|
static java.util.List<HRegionInfo> |
MetaTableAccessor.getTableRegions(ZooKeeperWatcher zkw,
Connection connection,
TableName tableName,
boolean excludeOfflinedSplitParents)
Gets all of the regions of the specified table.
|
static java.util.List<Pair<HRegionInfo,ServerName>> |
MetaTableAccessor.getTableRegionsAndLocations(ZooKeeperWatcher zkw,
Connection connection,
TableName tableName) |
static java.util.List<Pair<HRegionInfo,ServerName>> |
MetaTableAccessor.getTableRegionsAndLocations(ZooKeeperWatcher zkw,
Connection connection,
TableName tableName,
boolean excludeOfflinedSplitParents) |
boolean |
TableStateManager.isTablePresent(TableName tableName)
Checks if table is present.
|
boolean |
TableStateManager.isTableState(TableName tableName,
boolean checkSource,
ZooKeeperProtos.Table.State... states) |
boolean |
TableStateManager.isTableState(TableName tableName,
ZooKeeperProtos.Table.State... states) |
Waiter.Predicate<java.io.IOException> |
HBaseTestingUtility.predicateTableAvailable(TableName tableName)
Returns a
Waiter.Predicate for checking that table is enabled |
Waiter.Predicate<java.io.IOException> |
HBaseTestingUtility.predicateTableDisabled(TableName tableName)
Returns a
Waiter.Predicate for checking that table is enabled |
Waiter.Predicate<java.io.IOException> |
HBaseTestingUtility.predicateTableEnabled(TableName tableName)
Returns a
Waiter.Predicate for checking that table is enabled |
HTableDescriptor |
TableDescriptors.remove(TableName tablename) |
void |
TableStateManager.setDeletedTable(TableName tableName)
Mark table as deleted.
|
HTableDescriptor |
HTableDescriptor.setName(TableName name)
Deprecated.
|
static void |
HBaseTestingUtility.setReplicas(Admin admin,
TableName table,
int replicaCount)
Set the number of Region replicas.
|
void |
TableStateManager.setTableState(TableName tableName,
ZooKeeperProtos.Table.State state)
Sets the table into desired state.
|
boolean |
TableStateManager.setTableStateIfInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Sets the specified table into the newState, but only if the table is already in
one of the possibleCurrentStates (otherwise no operation is performed).
|
boolean |
TableStateManager.setTableStateIfNotInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Sets the specified table into the newState, but only if the table is NOT in
one of the possibleCurrentStates (otherwise no operation is performed).
|
static boolean |
MetaTableAccessor.tableExists(Connection connection,
TableName tableName)
Checks if the specified table exists.
|
HTable |
HBaseTestingUtility.truncateTable(TableName tableName)
Truncate a table using the admin command.
|
HTable |
HBaseTestingUtility.truncateTable(TableName tableName,
boolean preserveRegions)
Truncate a table using the admin command.
|
void |
HBaseTestingUtility.waitTableAvailable(TableName table)
Wait until all regions in a table have been assigned.
|
void |
HBaseTestingUtility.waitTableAvailable(TableName table,
long timeoutMillis) |
void |
HBaseTestingUtility.waitTableEnabled(TableName table)
Waits for a table to be 'enabled'.
|
void |
HBaseTestingUtility.waitTableEnabled(TableName table,
long timeoutMillis) |
void |
HBaseTestingUtility.waitUntilAllRegionsAssigned(TableName tableName)
Wait until all regions for a table in hbase:meta have a non-empty
info:server, up to a configuable timeout value (default is 60 seconds)
This means all regions have been deployed,
master has been informed and updated hbase:meta with the regions deployed
server.
|
void |
HBaseTestingUtility.waitUntilAllRegionsAssigned(TableName tableName,
long timeout)
Wait until all regions for a table in hbase:meta have a non-empty
info:server, or until timeout.
|
| Constructor and Description |
|---|
DelayingMultiThreadedUpdater(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
double updatePercent) |
DelayingMultiThreadedWriter(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName) |
HRegionInfo(long regionId,
TableName tableName,
int replicaId) |
HRegionInfo(TableName tableName) |
HRegionInfo(TableName tableName,
byte[] startKey,
byte[] endKey)
Construct HRegionInfo with explicit parameters
|
HRegionInfo(TableName tableName,
byte[] startKey,
byte[] endKey,
boolean split)
Construct HRegionInfo with explicit parameters
|
HRegionInfo(TableName tableName,
byte[] startKey,
byte[] endKey,
boolean split,
long regionid)
Construct HRegionInfo with explicit parameters
|
HRegionInfo(TableName tableName,
byte[] startKey,
byte[] endKey,
boolean split,
long regionid,
int replicaId)
Construct HRegionInfo with explicit parameters
|
HTableDescriptor(TableName name)
Construct a table descriptor specifying a TableName object
|
HTableDescriptor(TableName name,
HColumnDescriptor[] families)
INTERNAL Private constructor used internally creating table descriptors for
catalog tables,
hbase:meta and -ROOT-. |
HTableDescriptor(TableName name,
HColumnDescriptor[] families,
java.util.Map<ImmutableBytesWritable,ImmutableBytesWritable> values)
INTERNAL Private constructor used internally creating table descriptors for
catalog tables,
hbase:meta and -ROOT-. |
TableExistsException(TableName t) |
TableNotDisabledException(TableName tableName) |
TableNotEnabledException(TableName tableName) |
TableNotFoundException(TableName tableName) |
| Modifier and Type | Field and Description |
|---|---|
protected static TableName |
TestBackupBase.table1 |
protected static TableName |
TestBackupBase.table1_restore |
protected static TableName |
TestBackupBase.table2 |
protected static TableName |
TestBackupBase.table2_restore |
protected static TableName |
TestBackupBase.table3 |
protected static TableName |
TestBackupBase.table3_restore |
protected static TableName |
TestBackupBase.table4 |
protected static TableName |
TestBackupBase.table4_restore |
| Modifier and Type | Method and Description |
|---|---|
TableName[] |
RestoreRequest.getFromTables() |
TableName |
BackupStatus.getTable() |
TableName |
BackupInfo.getTableBySnapshot(java.lang.String snapshotName) |
TableName[] |
RestoreRequest.getToTables() |
| Modifier and Type | Method and Description |
|---|---|
java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
BackupInfo.getIncrTimestampMap()
Get new region server log timestamps after distributed log roll
|
java.util.List<TableName> |
BackupRequest.getTableList() |
java.util.List<TableName> |
BackupInfo.getTableNames() |
java.util.Set<TableName> |
BackupInfo.getTables() |
java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
BackupInfo.getTableSetTimestampMap() |
protected java.util.List<TableName> |
TestBackupBase.toList(java.lang.String... args)
Helper method
|
| Modifier and Type | Method and Description |
|---|---|
void |
BackupInfo.addTables(TableName[] tables) |
static void |
HBackupFileSystem.checkImageManifestExist(java.util.HashMap<TableName,BackupManifest> backupManifestMap,
TableName[] tableArray,
Configuration conf,
Path backupRootPath,
java.lang.String backupId)
Check whether the backup image path and there is manifest file in the path.
|
RestoreRequest |
TestBackupBase.createRestoreRequest(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] fromTables,
TableName[] toTables,
boolean isOverwrite)
Get restore request.
|
RestoreRequest |
TestBackupBase.createRestoreRequest(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] fromTables,
TableName[] toTables,
boolean isOverwrite)
Get restore request.
|
BackupStatus |
BackupInfo.getBackupStatus(TableName table) |
static BackupManifest |
HBackupFileSystem.getManifest(TableName tableName,
Configuration conf,
Path backupRootPath,
java.lang.String backupId) |
java.lang.String |
BackupInfo.getSnapshotName(TableName table) |
static java.lang.String |
HBackupFileSystem.getTableBackupDir(java.lang.String backupRootDir,
java.lang.String backupId,
TableName tableName)
Given the backup root dir, backup id and the table name, return the backup image location,
which is also where the backup manifest file is.
|
static Path |
HBackupFileSystem.getTableBackupPath(TableName tableName,
Path backupRootPath,
java.lang.String backupId)
Given the backup root dir, backup id and the table name, return the backup image location,
which is also where the backup manifest file is.
|
void |
RestoreClient.restore(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] sTableArray,
TableName[] tTableArray,
boolean isOverwrite)
Restore operation.
|
void |
RestoreClient.restore(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] sTableArray,
TableName[] tTableArray,
boolean isOverwrite)
Restore operation.
|
void |
IncrementalRestoreService.run(Path[] logDirectoryPaths,
TableName[] fromTables,
TableName[] toTables)
Run restore operation
|
void |
IncrementalRestoreService.run(Path[] logDirectoryPaths,
TableName[] fromTables,
TableName[] toTables)
Run restore operation
|
RestoreRequest |
RestoreRequest.setFromTables(TableName[] fromTables) |
void |
BackupInfo.setSnapshotName(TableName table,
java.lang.String snapshotName) |
void |
BackupStatus.setTable(TableName table) |
RestoreRequest |
RestoreRequest.setToTables(TableName[] toTables) |
| Modifier and Type | Method and Description |
|---|---|
protected java.lang.String |
TestBackupBase.backupTables(BackupType type,
java.util.List<TableName> tables,
java.lang.String path) |
static void |
HBackupFileSystem.checkImageManifestExist(java.util.HashMap<TableName,BackupManifest> backupManifestMap,
TableName[] tableArray,
Configuration conf,
Path backupRootPath,
java.lang.String backupId)
Check whether the backup image path and there is manifest file in the path.
|
protected java.lang.String |
TestBackupBase.fullTableBackup(java.util.List<TableName> tables) |
protected java.lang.String |
TestBackupBase.incrementalTableBackup(java.util.List<TableName> tables) |
void |
BackupInfo.setBackupStatusMap(java.util.Map<TableName,BackupStatus> backupStatusMap) |
void |
BackupInfo.setIncrTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> newTableSetTimestampMap)
Set the new region server log timestamps after distributed log roll
|
BackupRequest |
BackupRequest.setTableList(java.util.List<TableName> tableList) |
void |
BackupInfo.setTableSetTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> tableSetTimestampMap) |
| Constructor and Description |
|---|
BackupInfo(java.lang.String backupId,
BackupType type,
TableName[] tables,
java.lang.String targetRootDir) |
BackupStatus(TableName table,
java.lang.String targetRootDir,
java.lang.String backupId) |
| Modifier and Type | Method and Description |
|---|---|
static TableName |
BackupSystemTable.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<TableName> |
BackupSystemTable.describeBackupSet(java.lang.String name)
Get backup set description (list of tables)
|
java.util.Set<TableName> |
BackupManager.getIncrementalBackupTableSet()
Return the current tables covered by incremental backup.
|
java.util.Set<TableName> |
BackupSystemTable.getIncrementalBackupTableSet(java.lang.String backupRoot)
Return the current tables covered by incremental backup.
|
java.util.Map<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
BackupManifest.getIncrTimestampMap() |
java.util.ArrayList<TableName> |
BackupManifest.getTableList()
Get the table set of this image.
|
java.util.List<TableName> |
BackupManifest.BackupImage.getTableNames() |
java.util.List<TableName> |
BackupSystemTable.getTablesForBackupType(BackupType type) |
java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
BackupManager.readLogTimestampMap()
Read the timestamp for each region server log after the last successful backup.
|
java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> |
BackupSystemTable.readLogTimestampMap(java.lang.String backupRoot)
Read the timestamp for each region server log after the last successful backup.
|
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupSystemTable.readOrigBulkloadRows(java.util.List<TableName> tableList) |
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupManager.readOrigBulkloadRows(java.util.List<TableName> tableList) |
| Modifier and Type | Method and Description |
|---|---|
java.util.ArrayList<BackupManifest.BackupImage> |
BackupManifest.getAllDependentListByTable(TableName table)
Get the full dependent image list in the whole dependency scope for a specific table of this
backup in time order from old to new.
|
java.util.ArrayList<BackupManifest.BackupImage> |
BackupManager.getAncestors(BackupInfo backupContext,
TableName table)
Get the direct ancestors of this backup for one table involved.
|
java.util.ArrayList<BackupManifest.BackupImage> |
BackupManifest.getDependentListByTable(TableName table)
Get the dependent image list for a specific table of this backup in time order from old to new
if want to restore to this backup image level.
|
static int |
BackupSystemTable.getIndex(TableName tbl,
java.util.List<TableName> sTableList) |
boolean |
BackupManifest.BackupImage.hasTable(TableName table) |
void |
RestoreClientImpl.restore(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] sTableArray,
TableName[] tTableArray,
boolean isOverwrite)
Restore operation.
|
void |
RestoreClientImpl.restore(java.lang.String backupRootDir,
java.lang.String backupId,
boolean check,
TableName[] sTableArray,
TableName[] tTableArray,
boolean isOverwrite)
Restore operation.
|
void |
BackupSystemTable.writeOrigBulkLoad(TableName tabName,
byte[] region,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
void |
BackupSystemTable.writeOrigBulkLoad(TableName tabName,
byte[] region,
java.util.Map<byte[],java.util.List<Path>> finalPaths) |
| Modifier and Type | Method and Description |
|---|---|
void |
BackupManager.addIncrementalBackupTableSet(java.util.Set<TableName> tables)
Adds set of tables to overall incremental backup table set
|
void |
BackupSystemTable.addIncrementalBackupTableSet(java.util.Set<TableName> tables,
java.lang.String backupRoot)
Add tables to global incremental backup set
|
BackupInfo |
BackupManager.createBackupInfo(java.lang.String backupId,
BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth)
Create a BackupContext based on input backup request.
|
static java.util.List<Delete> |
BackupSystemTableHelper.createDeleteForOrigBulkLoad(java.util.List<TableName> lst) |
static int |
BackupSystemTable.getIndex(TableName tbl,
java.util.List<TableName> sTableList) |
java.util.Map<byte[],java.util.List<Path>>[] |
BackupSystemTable.readBulkLoadedFiles(java.lang.String backupId,
java.util.List<TableName> sTableList) |
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupSystemTable.readOrigBulkloadRows(java.util.List<TableName> tableList) |
Pair<java.util.Map<TableName,java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.util.List<Pair<java.lang.String,java.lang.Boolean>>>>>,java.util.List<byte[]>> |
BackupManager.readOrigBulkloadRows(java.util.List<TableName> tableList) |
void |
BackupSystemTable.removeOrigBulkLoadedRows(java.util.List<TableName> lst,
java.util.List<byte[]> rows) |
void |
BackupManager.removeOrigBulkLoadedRows(java.util.List<TableName> lst,
java.util.List<byte[]> rows) |
void |
BackupManifest.setIncrTimestampMap(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> incrTimestampMap)
Set the incremental timestamp map directly.
|
void |
BackupManifest.BackupImage.setTableList(java.util.List<TableName> tableList) |
void |
BackupManager.writeBulkLoadedFiles(java.util.List<TableName> sTableList,
java.util.Map<byte[],java.util.List<Path>>[] maps) |
void |
BackupSystemTable.writeBulkLoadedFiles(java.util.List<TableName> sTableList,
java.util.Map<byte[],java.util.List<Path>>[] maps,
java.lang.String backupId) |
void |
BackupManager.writeRegionServerLogTimestamp(java.util.Set<TableName> tables,
java.util.HashMap<java.lang.String,java.lang.Long> newTimestamps)
Write the current timestamps for each regionserver to hbase:backup after a successful full or
incremental backup.
|
void |
BackupSystemTable.writeRegionServerLogTimestamp(java.util.Set<TableName> tables,
java.util.HashMap<java.lang.String,java.lang.Long> newTimestamps,
java.lang.String backupRoot)
Write the current timestamps for each regionserver to hbase:backup
after a successful full or incremental backup.
|
| Constructor and Description |
|---|
BackupManifest(BackupInfo backupCtx,
TableName table)
Construct a table level manifest for a backup of the named table.
|
| Constructor and Description |
|---|
BackupImage(java.lang.String backupId,
BackupType type,
java.lang.String rootDir,
java.util.List<TableName> tableList,
long startTs,
long completeTs) |
| Modifier and Type | Method and Description |
|---|---|
void |
MapReduceRestoreService.run(Path[] fileDirPaths,
TableName[] tableNames,
TableName[] newTableNames) |
void |
MapReduceRestoreService.run(Path[] fileDirPaths,
TableName[] tableNames,
TableName[] newTableNames) |
| Modifier and Type | Method and Description |
|---|---|
TableName |
FullTableBackupProcedure.getTableName() |
TableName |
IncrementalTableBackupProcedure.getTableName() |
| Constructor and Description |
|---|
FullTableBackupProcedure(MasterProcedureEnv env,
java.lang.String backupId,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth) |
IncrementalTableBackupProcedure(MasterProcedureEnv env,
java.lang.String backupId,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth) |
| Modifier and Type | Method and Description |
|---|---|
static TableName[] |
BackupClientUtil.parseTableNames(java.lang.String tables) |
static TableName[] |
BackupServerUtil.parseTableNames(java.lang.String tables) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<TableName> |
BackupSet.getTables() |
| Modifier and Type | Method and Description |
|---|---|
void |
RestoreServerUtil.fullRestoreTable(Path tableBackupPath,
TableName tableName,
TableName newTableName,
boolean converted,
boolean truncateIfExists) |
static java.lang.String |
BackupClientUtil.getTableBackupDir(java.lang.String backupRootDir,
java.lang.String backupId,
TableName tableName)
Given the backup root dir, backup id and the table name, return the backup image location,
which is also where the backup manifest file is.
|
void |
RestoreServerUtil.incrementalRestoreTable(Path[] logDirs,
TableName[] tableNames,
TableName[] newTableNames)
During incremental backup operation.
|
void |
RestoreServerUtil.incrementalRestoreTable(Path[] logDirs,
TableName[] tableNames,
TableName[] newTableNames)
During incremental backup operation.
|
static java.lang.String |
BackupServerUtil.join(TableName[] names) |
| Modifier and Type | Method and Description |
|---|---|
static java.util.HashMap<java.lang.String,java.lang.Long> |
BackupServerUtil.getRSLogTimestampMins(java.util.HashMap<TableName,java.util.HashMap<java.lang.String,java.lang.Long>> rsLogTimestampMap)
Loop through the RS log timestamp map for the tables, for each RS, find the min timestamp
value for the RS among the tables.
|
| Constructor and Description |
|---|
BackupSet(java.lang.String name,
java.util.List<TableName> tables) |
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
MonkeyFactory.tableName |
| Modifier and Type | Method and Description |
|---|---|
MonkeyFactory |
MonkeyFactory.setTableName(TableName tableName) |
| Modifier and Type | Method and Description |
|---|---|
TableName |
ChaosMonkeyRunner.getTablename() |
| Modifier and Type | Field and Description |
|---|---|
protected static TableName |
TestSnapshotFromClient.TABLE_NAME |
protected TableName |
RegionAdminServiceCallable.tableName |
protected TableName |
RegionServerCallable.tableName |
protected TableName |
RpcRetryingCallerWithReadReplicas.tableName |
protected TableName |
TestCloneSnapshotFromClient.tableName |
protected TableName |
TestRestoreSnapshotFromClient.tableName |
TableName |
TestSnapshotWithAcl.TEST_TABLE |
| Modifier and Type | Method and Description |
|---|---|
TableName |
BufferedMutator.getName()
Gets the fully qualified table name instance of the table that this BufferedMutator writes to.
|
TableName |
BufferedMutatorImpl.getName() |
TableName |
HRegionLocator.getName() |
TableName |
HTable.getName() |
TableName |
RegionLocator.getName()
Gets the fully qualified table name instance of this table.
|
TableName |
Table.getName()
Gets the fully qualified table name instance of this table.
|
TableName |
HTableWrapper.getName() |
protected TableName |
ClientScanner.getTable() |
TableName |
BufferedMutatorParams.getTableName() |
protected TableName |
HBaseAdmin.TableFuture.getTableName() |
TableName |
RegionServerCallable.getTableName() |
TableName[] |
Admin.listTableNames()
List all of the names of userspace tables.
|
TableName[] |
HBaseAdmin.listTableNames() |
TableName[] |
HConnection.listTableNames()
Deprecated.
Use
Admin.listTables() instead. |
TableName[] |
Admin.listTableNames(java.util.regex.Pattern pattern)
List all of the names of userspace tables.
|
TableName[] |
HBaseAdmin.listTableNames(java.util.regex.Pattern pattern) |
TableName[] |
Admin.listTableNames(java.util.regex.Pattern pattern,
boolean includeSysTables)
List all of the names of userspace tables.
|
TableName[] |
HBaseAdmin.listTableNames(java.util.regex.Pattern pattern,
boolean includeSysTables) |
TableName[] |
Admin.listTableNames(java.lang.String regex)
List all of the names of userspace tables.
|
TableName[] |
HBaseAdmin.listTableNames(java.lang.String regex) |
TableName[] |
Admin.listTableNames(java.lang.String regex,
boolean includeSysTables)
List all of the names of userspace tables.
|
TableName[] |
HBaseAdmin.listTableNames(java.lang.String regex,
boolean includeSysTables) |
TableName[] |
Admin.listTableNamesByNamespace(java.lang.String name)
Get list of table names by namespace
|
TableName[] |
HBaseAdmin.listTableNamesByNamespace(java.lang.String name)
Get list of table names by namespace
|
| Modifier and Type | Method and Description |
|---|---|
void |
Admin.addColumn(TableName tableName,
HColumnDescriptor column)
Add a column to an existing table.
|
void |
HBaseAdmin.addColumn(TableName tableName,
HColumnDescriptor column)
Add a column to an existing table.
|
void |
BackupAdmin.addToBackupSet(java.lang.String name,
TableName[] tables)
Add tables to backup set command
|
void |
HBaseBackupAdmin.addToBackupSet(java.lang.String name,
TableName[] tables) |
static java.util.NavigableMap<HRegionInfo,ServerName> |
MetaScanner.allTableRegions(Configuration conf,
Connection connection,
TableName tableName,
boolean offlined)
Deprecated.
|
static java.util.NavigableMap<HRegionInfo,ServerName> |
MetaScanner.allTableRegions(Connection connection,
TableName tableName)
Lists all of the table regions currently in META.
|
void |
ClusterConnection.cacheLocation(TableName tableName,
RegionLocations location) |
void |
MetaCache.cacheLocation(TableName tableName,
RegionLocations locations)
Put a newly discovered HRegionLocation into the cache.
|
void |
MetaCache.cacheLocation(TableName tableName,
ServerName source,
HRegionLocation location)
Put a newly discovered HRegionLocation into the cache.
|
void |
MetaCache.clearCache(TableName tableName)
Delete all cached entries of a table.
|
void |
MetaCache.clearCache(TableName tableName,
byte[] row)
Delete a cached location, no matter what it is.
|
void |
MetaCache.clearCache(TableName tableName,
byte[] row,
int replicaId)
Delete a cached location, no matter what it is.
|
void |
MetaCache.clearCache(TableName tableName,
byte[] row,
ServerName serverName)
Delete a cached location for a table, row and server
|
void |
ClusterConnection.clearRegionCache(TableName tableName)
Allows flushing the region cache of all locations that pertain to
tableName |
void |
HConnection.clearRegionCache(TableName tableName)
Deprecated.
internal method, do not use thru HConnection
|
void |
Admin.cloneSnapshot(byte[] snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content.
|
void |
HBaseAdmin.cloneSnapshot(byte[] snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content.
|
void |
Admin.cloneSnapshot(java.lang.String snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content.
|
void |
HBaseAdmin.cloneSnapshot(java.lang.String snapshotName,
TableName tableName) |
void |
Admin.cloneSnapshot(java.lang.String snapshotName,
TableName tableName,
boolean restoreAcl)
Create a new table by cloning the snapshot content.
|
void |
HBaseAdmin.cloneSnapshot(java.lang.String snapshotName,
TableName tableName,
boolean restoreAcl)
Create a new table by cloning the snapshot content.
|
void |
Admin.compact(TableName tableName)
Compact a table.
|
void |
HBaseAdmin.compact(TableName tableName)
Compact a table.
|
void |
Admin.compact(TableName tableName,
Admin.CompactType compactType)
Compact a table.
|
void |
HBaseAdmin.compact(TableName tableName,
Admin.CompactType compactType)
Compact a table.
|
void |
Admin.compact(TableName tableName,
byte[] columnFamily)
Compact a column family within a table.
|
void |
HBaseAdmin.compact(TableName tableName,
byte[] columnFamily)
Compact a column family within a table.
|
void |
Admin.compact(TableName tableName,
byte[] columnFamily,
Admin.CompactType compactType)
Compact a column family within a table.
|
void |
HBaseAdmin.compact(TableName tableName,
byte[] columnFamily,
Admin.CompactType compactType)
Compact a column family within a table.
|
protected Table |
TestSnapshotCloneIndependence.createTable(TableName table,
byte[] family) |
static void |
TestTableSnapshotScanner.createTableAndSnapshot(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
int numRegions) |
static HTableInterface |
HTableWrapper.createWrapper(java.util.List<HTableInterface> openTables,
TableName tableName,
CoprocessorHost.Environment env,
java.util.concurrent.ExecutorService pool) |
void |
Admin.deleteColumn(TableName tableName,
byte[] columnName)
Delete a column from a table.
|
void |
HBaseAdmin.deleteColumn(TableName tableName,
byte[] columnName)
Delete a column from a table.
|
void |
Admin.deleteTable(TableName tableName)
Deletes a table.
|
void |
HBaseAdmin.deleteTable(TableName tableName)
Deletes a table.
|
void |
Admin.disableTable(TableName tableName)
Disable table and wait on completion.
|
void |
HBaseAdmin.disableTable(TableName tableName)
Disable table and wait on completion.
|
void |
Admin.disableTableAsync(TableName tableName)
Starts the disable of a table.
|
void |
HBaseAdmin.disableTableAsync(TableName tableName)
Starts the disable of a table.
|
void |
Admin.enableTable(TableName tableName)
Enable a table.
|
void |
HBaseAdmin.enableTable(TableName tableName)
Enable a table.
|
void |
Admin.enableTableAsync(TableName tableName)
Brings a table on-line (enables it).
|
void |
HBaseAdmin.enableTableAsync(TableName tableName)
Brings a table on-line (enables it).
|
void |
Admin.flush(TableName tableName)
Flush a table.
|
void |
HBaseAdmin.flush(TableName tableName)
Flush a table.
|
Pair<java.lang.Integer,java.lang.Integer> |
Admin.getAlterStatus(TableName tableName)
Get the status of alter command - indicates how many regions have received the updated schema
Asynchronous operation.
|
Pair<java.lang.Integer,java.lang.Integer> |
HBaseAdmin.getAlterStatus(TableName tableName)
Get the status of alter command - indicates how many regions have received
the updated schema Asynchronous operation.
|
BufferedMutator |
Connection.getBufferedMutator(TableName tableName)
Retrieve a
BufferedMutator for performing client-side buffering of writes. |
RegionLocations |
MetaCache.getCachedLocation(TableName tableName,
byte[] row)
Search the cache for a location that fits our table and row key.
|
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas |
ClientSmallScanner.SmallScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
Configuration conf,
RpcRetryingCaller<Result[]> caller) |
org.apache.hadoop.hbase.client.ScannerCallableWithReplicas |
ClientSmallReversedScanner.SmallReversedScannerCallableFactory.getCallable(ClusterConnection connection,
TableName table,
Scan scan,
ScanMetrics scanMetrics,
byte[] localStartKey,
int cacheNum,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout,
int retries,
int scannerTimeout,
Configuration conf,
RpcRetryingCaller<Result[]> caller,
boolean isFirstRegionToLocate) |
AdminProtos.GetRegionInfoResponse.CompactionState |
Admin.getCompactionState(TableName tableName)
Get the current compaction state of a table.
|
AdminProtos.GetRegionInfoResponse.CompactionState |
HBaseAdmin.getCompactionState(TableName tableName) |
AdminProtos.GetRegionInfoResponse.CompactionState |
Admin.getCompactionState(TableName tableName,
Admin.CompactType compactType)
Get the current compaction state of a table.
|
AdminProtos.GetRegionInfoResponse.CompactionState |
HBaseAdmin.getCompactionState(TableName tableName,
Admin.CompactType compactType)
Get the current compaction state of a table.
|
HTableDescriptor |
HConnection.getHTableDescriptor(TableName tableName)
Deprecated.
|
long |
Admin.getLastMajorCompactionTimestamp(TableName tableName)
Get the timestamp of the last major compaction for the passed table
The timestamp of the oldest HFile resulting from a major compaction of that table,
or 0 if no such HFile could be found.
|
long |
HBaseAdmin.getLastMajorCompactionTimestamp(TableName tableName) |
int |
MetaCache.getNumberOfCachedRegionLocations(TableName tableName)
Return the number of cached region for a table.
|
static boolean |
HTable.getRegionCachePrefetch(Configuration conf,
TableName tableName)
Deprecated.
always return false since 0.99
|
boolean |
HConnection.getRegionCachePrefetch(TableName tableName)
Deprecated.
always return false since 0.99
|
static boolean |
HTable.getRegionCachePrefetch(TableName tableName)
Deprecated.
always return false since 0.99
|
HRegionLocation |
ClusterConnection.getRegionLocation(TableName tableName,
byte[] row,
boolean reload)
Find region location hosting passed row
|
HRegionLocation |
HConnection.getRegionLocation(TableName tableName,
byte[] row,
boolean reload)
Deprecated.
internal method, do not use thru HConnection
|
static RegionLocations |
RegionAdminServiceCallable.getRegionLocations(ClusterConnection connection,
TableName tableName,
byte[] row,
boolean useCache,
int replicaId) |
RegionLocator |
Connection.getRegionLocator(TableName tableName)
Retrieve a RegionLocator implementation to inspect region information on a table.
|
RegionLocator |
HConnection.getRegionLocator(TableName tableName)
Deprecated.
Retrieve a RegionLocator implementation to inspect region information on a table.
|
Table |
Connection.getTable(TableName tableName)
Retrieve a Table implementation for accessing a table.
|
HTableInterface |
HConnection.getTable(TableName tableName)
Deprecated.
Retrieve an HTableInterface implementation for access to a table.
|
Table |
Connection.getTable(TableName tableName,
java.util.concurrent.ExecutorService pool)
Retrieve a Table implementation for accessing a table.
|
HTableInterface |
HConnection.getTable(TableName tableName,
java.util.concurrent.ExecutorService pool)
Deprecated.
Retrieve an HTableInterface implementation for access to a table.
|
HTableDescriptor |
Admin.getTableDescriptor(TableName tableName)
Method for getting the tableDescriptor
|
HTableDescriptor |
HBaseAdmin.getTableDescriptor(TableName tableName)
Method for getting the tableDescriptor
|
java.util.List<HRegionInfo> |
Admin.getTableRegions(TableName tableName)
Get the regions of a given table.
|
java.util.List<HRegionInfo> |
HBaseAdmin.getTableRegions(TableName tableName)
get the regions of a given table.
|
boolean |
MetaCache.isRegionCached(TableName tableName,
byte[] row)
Check the region cache to see whether a region is cached yet or not.
|
boolean |
Admin.isTableAvailable(TableName tableName) |
boolean |
HBaseAdmin.isTableAvailable(TableName tableName) |
boolean |
HConnection.isTableAvailable(TableName tableName)
Deprecated.
|
boolean |
Admin.isTableAvailable(TableName tableName,
byte[][] splitKeys)
Use this api to check if the table has been created with the specified number of splitkeys
which was used while creating the given table.
|
boolean |
ClusterConnection.isTableAvailable(TableName tableName,
byte[][] splitKeys)
Use this api to check if the table has been created with the specified number of
splitkeys which was used while creating the given table.
|
boolean |
HBaseAdmin.isTableAvailable(TableName tableName,
byte[][] splitKeys)
Use this api to check if the table has been created with the specified number of
splitkeys which was used while creating the given table.
|
boolean |
HConnection.isTableAvailable(TableName tableName,
byte[][] splitKeys)
Deprecated.
internal method, do not use thru HConnection
|
boolean |
Admin.isTableDisabled(TableName tableName) |
boolean |
HBaseAdmin.isTableDisabled(TableName tableName) |
boolean |
HConnection.isTableDisabled(TableName tableName)
Deprecated.
|
static boolean |
HTable.isTableEnabled(Configuration conf,
TableName tableName)
|
boolean |
Admin.isTableEnabled(TableName tableName) |
boolean |
HBaseAdmin.isTableEnabled(TableName tableName) |
boolean |
HConnection.isTableEnabled(TableName tableName)
Deprecated.
A table that isTableEnabled == false and isTableDisabled == false
is possible.
|
static boolean |
HTable.isTableEnabled(TableName tableName)
Deprecated.
|
static java.util.List<RegionLocations> |
MetaScanner.listTableRegionLocations(Configuration conf,
Connection connection,
TableName tableName)
Lists table regions and locations grouped by region range from META.
|
HRegionLocation |
ClusterConnection.locateRegion(TableName tableName,
byte[] row)
Find the location of the region of tableName that row
lives in.
|
HRegionLocation |
HConnection.locateRegion(TableName tableName,
byte[] row)
Deprecated.
internal method, do not use thru HConnection
|
RegionLocations |
ClusterConnection.locateRegion(TableName tableName,
byte[] row,
boolean useCache,
boolean retry) |
RegionLocations |
ClusterConnection.locateRegion(TableName tableName,
byte[] row,
boolean useCache,
boolean retry,
int replicaId) |
java.util.List<HRegionLocation> |
ClusterConnection.locateRegions(TableName tableName)
Gets the locations of all regions in the specified table, tableName.
|
java.util.List<HRegionLocation> |
HConnection.locateRegions(TableName tableName)
Deprecated.
internal method, do not use thru HConnection
|
java.util.List<HRegionLocation> |
ClusterConnection.locateRegions(TableName tableName,
boolean useCache,
boolean offlined)
Gets the locations of all regions in the specified table, tableName.
|
java.util.List<HRegionLocation> |
HConnection.locateRegions(TableName tableName,
boolean useCache,
boolean offlined)
Deprecated.
internal method, do not use thru HConnection
|
void |
Admin.majorCompact(TableName tableName)
Major compact a table.
|
void |
HBaseAdmin.majorCompact(TableName tableName)
Major compact a table.
|
void |
Admin.majorCompact(TableName tableName,
Admin.CompactType compactType)
Major compact a table.
|
void |
HBaseAdmin.majorCompact(TableName tableName,
Admin.CompactType compactType)
Major compact a table.
|
void |
Admin.majorCompact(TableName tableName,
byte[] columnFamily)
Major compact a column family within a table.
|
void |
HBaseAdmin.majorCompact(TableName tableName,
byte[] columnFamily)
Major compact a column family within a table.
|
void |
Admin.majorCompact(TableName tableName,
byte[] columnFamily,
Admin.CompactType compactType)
Major compact a column family within a table.
|
void |
HBaseAdmin.majorCompact(TableName tableName,
byte[] columnFamily,
Admin.CompactType compactType)
Major compact a column family within a table.
|
static void |
MetaScanner.metaScan(Connection connection,
MetaScanner.MetaScannerVisitor visitor,
TableName userTableName)
Scans the meta table and calls a visitor on each RowResult.
|
static void |
MetaScanner.metaScan(Connection connection,
MetaScanner.MetaScannerVisitor visitor,
TableName userTableName,
byte[] row,
int rowLimit)
Scans the meta table and calls a visitor on each RowResult.
|
void |
Admin.modifyColumn(TableName tableName,
HColumnDescriptor descriptor)
Modify an existing column family on a table.
|
void |
HBaseAdmin.modifyColumn(TableName tableName,
HColumnDescriptor descriptor)
Modify an existing column family on a table.
|
void |
Admin.modifyTable(TableName tableName,
HTableDescriptor htd)
Modify an existing table, more IRB friendly version.
|
void |
HBaseAdmin.modifyTable(TableName tableName,
HTableDescriptor htd)
Modify an existing table, more IRB friendly version.
|
void |
HConnection.processBatch(java.util.List<? extends Row> actions,
TableName tableName,
java.util.concurrent.ExecutorService pool,
java.lang.Object[] results)
Deprecated.
since 0.96 - Use
Table.batch(java.util.List<? extends org.apache.hadoop.hbase.client.Row>, java.lang.Object[]) instead |
<R> void |
HConnection.processBatchCallback(java.util.List<? extends Row> list,
TableName tableName,
java.util.concurrent.ExecutorService pool,
java.lang.Object[] results,
Batch.Callback<R> callback)
|
java.util.List<Put> |
HTableMultiplexer.put(TableName tableName,
java.util.List<Put> puts)
The puts request will be buffered by their corresponding buffer queue.
|
boolean |
HTableMultiplexer.put(TableName tableName,
Put put)
The put request will be buffered by its corresponding buffer queue.
|
boolean |
HTableMultiplexer.put(TableName tableName,
Put put,
int retry)
The put request will be buffered by its corresponding buffer queue.
|
HRegionLocation |
ClusterConnection.relocateRegion(TableName tableName,
byte[] row)
Find the location of the region of tableName that row
lives in, ignoring any value that might be in the cache.
|
HRegionLocation |
HConnection.relocateRegion(TableName tableName,
byte[] row)
Deprecated.
internal method, do not use thru HConnection
|
RegionLocations |
ClusterConnection.relocateRegion(TableName tableName,
byte[] row,
int replicaId)
Find the location of the region of tableName that row
lives in, ignoring any value that might be in the cache.
|
void |
TestRpcControllerFactory.CountingRpcController.setPriority(TableName tn) |
static void |
HTable.setRegionCachePrefetch(Configuration conf,
TableName tableName,
boolean enable)
Deprecated.
does nothing since 0.99
|
void |
HConnection.setRegionCachePrefetch(TableName tableName,
boolean enable)
Deprecated.
does nothing since since 0.99
|
static void |
HTable.setRegionCachePrefetch(TableName tableName,
boolean enable)
Deprecated.
does nothing since 0.99
|
void |
Admin.snapshot(byte[] snapshotName,
TableName tableName)
public void snapshot(final String snapshotName, Create a timestamp consistent snapshot for the
given table.
|
void |
HBaseAdmin.snapshot(byte[] snapshotName,
TableName tableName)
public void snapshot(final String snapshotName,
Create a timestamp consistent snapshot for the given table.
|
void |
Admin.snapshot(java.lang.String snapshotName,
TableName tableName)
Take a snapshot for the given table.
|
void |
HBaseAdmin.snapshot(java.lang.String snapshotName,
TableName tableName)
Take a snapshot for the given table.
|
void |
Admin.snapshot(java.lang.String snapshotName,
TableName tableName,
HBaseProtos.SnapshotDescription.Type type)
Create typed snapshot of the table.
|
void |
HBaseAdmin.snapshot(java.lang.String snapshotName,
TableName tableName,
HBaseProtos.SnapshotDescription.Type type)
Create typed snapshot of the table.
|
void |
Admin.split(TableName tableName)
Split a table.
|
void |
HBaseAdmin.split(TableName tableName)
Split a table.
|
void |
Admin.split(TableName tableName,
byte[] splitPoint)
Split a table.
|
void |
HBaseAdmin.split(TableName tableName,
byte[] splitPoint)
Split a table.
|
boolean |
Admin.tableExists(TableName tableName) |
boolean |
HBaseAdmin.tableExists(TableName tableName) |
void |
Admin.truncateTable(TableName tableName,
boolean preserveSplits)
Truncate a table.
|
void |
HBaseAdmin.truncateTable(TableName tableName,
boolean preserveSplits)
Truncate a table.
|
void |
ClusterConnection.updateCachedLocations(TableName tableName,
byte[] regionName,
byte[] rowkey,
java.lang.Object exception,
ServerName source)
Update the location cache.
|
void |
HConnection.updateCachedLocations(TableName tableName,
byte[] regionName,
byte[] rowkey,
java.lang.Object exception,
ServerName source)
Deprecated.
internal method, do not use thru HConnection
|
void |
HConnection.updateCachedLocations(TableName tableName,
byte[] rowkey,
java.lang.Object exception,
HRegionLocation source)
Deprecated.
|
protected void |
TestCloneSnapshotFromClient.verifyReplicasCameOnline(TableName tableName) |
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) |
| Modifier and Type | Method and Description |
|---|---|
HTableDescriptor[] |
HConnection.getHTableDescriptorsByTableName(java.util.List<TableName> tableNames)
Deprecated.
Use
Admin.getTableDescriptor(TableName) instead. |
HTableDescriptor[] |
Admin.getTableDescriptorsByTableName(java.util.List<TableName> tableNames)
Get tableDescriptors
|
HTableDescriptor[] |
HBaseAdmin.getTableDescriptorsByTableName(java.util.List<TableName> tableNames)
Get tableDescriptors
|
| Constructor and Description |
|---|
BufferedMutatorParams(TableName tableName) |
ClientScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ClientScanner for the specified table Note that the passed
Scan's start
row maybe changed changed. |
ClientSmallReversedScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table.
|
ClientSmallScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ShortClientScanner for the specified table.
|
FlushRegionCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
TableName tableName,
byte[] regionName,
byte[] regionStartKey,
boolean writeFlushWalMarker) |
HRegionLocator(TableName tableName,
ClusterConnection connection) |
HTable(Configuration conf,
TableName tableName)
Deprecated.
Constructing HTable objects manually has been deprecated. Please use
Connection to instantiate a Table instead. |
HTable(Configuration conf,
TableName tableName,
java.util.concurrent.ExecutorService pool)
Deprecated.
Constructing HTable objects manually has been deprecated. Please use
Connection to instantiate a Table instead. |
HTable(TableName tableName,
ClusterConnection connection,
ConnectionConfiguration tableConfig,
RpcRetryingCallerFactory rpcCallerFactory,
RpcControllerFactory rpcControllerFactory,
java.util.concurrent.ExecutorService pool)
Creates an object to access a HBase table.
|
HTable(TableName tableName,
Connection connection)
Deprecated.
Do not use.
|
HTable(TableName tableName,
Connection connection,
java.util.concurrent.ExecutorService pool)
Deprecated.
Do not use, internal ctor.
|
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionLocation location,
TableName tableName,
byte[] row) |
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
HRegionLocation location,
TableName tableName,
byte[] row,
int replicaId) |
RegionAdminServiceCallable(ClusterConnection connection,
RpcControllerFactory rpcControllerFactory,
TableName tableName,
byte[] row) |
RegionServerCallable(Connection connection,
TableName tableName,
byte[] row) |
ReversedClientScanner(Configuration conf,
Scan scan,
TableName tableName,
ClusterConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory,
java.util.concurrent.ExecutorService pool,
int primaryOperationTimeout)
Create a new ReversibleClientScanner for the specified table Note that the
passed
Scan's start row maybe changed. |
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow)
|
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow,
RpcControllerFactory rpcFactory) |
ReversedScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow,
RpcControllerFactory rpcFactory,
int replicaId) |
RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory,
TableName tableName,
ClusterConnection cConnection,
Get get,
java.util.concurrent.ExecutorService pool,
int retries,
int callTimeout,
int timeBeforeReplicas) |
ScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcControllerFactory) |
ScannerCallable(ClusterConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
RpcControllerFactory rpcControllerFactory,
int id) |
TableBackupFuture(HBaseAdmin admin,
TableName tableName,
MasterProtos.BackupTablesResponse response) |
TableFuture(HBaseAdmin admin,
TableName tableName,
java.lang.Long procId) |
TableMetaScannerVisitor(TableName tableName) |
| Modifier and Type | Method and Description |
|---|---|
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.avg(TableName tableName,
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(TableName tableName,
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(TableName tableName,
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(TableName tableName,
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.
|
java.lang.String |
SecureBulkLoadClient.prepareBulkLoad(TableName tableName) |
<R,S,P extends Message,Q extends Message,T extends Message> |
AggregationClient.rowCount(TableName tableName,
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(TableName tableName,
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(TableName tableName,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan)
It sums up the value returned from various regions.
|
| Modifier and Type | Method and Description |
|---|---|
static java.util.Map<TableName,java.util.List<java.lang.String>> |
ReplicationAdmin.parseTableCFsFromConfig(java.lang.String tableCFsConfig) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationAdmin.disableTableRep(TableName tableName)
Disable a table's replication switch.
|
void |
ReplicationAdmin.enableTableRep(TableName tableName)
Enable a table's replication switch.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationAdmin.addPeer(java.lang.String id,
ReplicationPeerConfig peerConfig,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Add a new remote slave cluster for replication.
|
void |
ReplicationAdmin.appendPeerTableCFs(java.lang.String id,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Append the replicable table-cf config of the specified peer
|
void |
ReplicationAdmin.removePeerTableCFs(java.lang.String id,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Remove some table-cfs from config of the specified peer
|
void |
ReplicationAdmin.setPeerTableCFs(java.lang.String id,
java.util.Map<TableName,? extends java.util.Collection<java.lang.String>> tableCfs)
Set the replicable table-cf config of the specified peer
|
| Modifier and Type | Field and Description |
|---|---|
static TableName |
TestRegionObserverInterface.TEST_TABLE |
| Modifier and Type | Method and Description |
|---|---|
void |
BaseMasterAndRegionObserver.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
BaseMasterObserver.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
MasterObserver.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex)
Called after a getTableDescriptors request has been processed.
|
void |
TestMasterObserver.CPMasterObserver.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
BaseMasterAndRegionObserver.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
BaseMasterObserver.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
MasterObserver.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup)
Called after servers are moved to target region server group
|
void |
TestMasterObserver.CPMasterObserver.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
BaseMasterAndRegionObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors) |
void |
BaseMasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors) |
void |
MasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors)
Deprecated.
Use preGetTableDescriptors with regex instead.
|
void |
TestMasterObserver.CPMasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors) |
void |
BaseMasterAndRegionObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
BaseMasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
MasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex)
Called before a getTableDescriptors request has been processed.
|
void |
TestMasterObserver.CPMasterObserver.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
BaseMasterAndRegionObserver.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
BaseMasterObserver.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
MasterObserver.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup)
Called before tables are moved to target region server group
|
void |
TestMasterObserver.CPMasterObserver.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroupGroup) |
| Modifier and Type | Method and Description |
|---|---|
static TableName |
HFileLink.getReferencedTableName(java.lang.String fileName)
Get the Table name of the referenced link
|
| Modifier and Type | Method and Description |
|---|---|
static HFileLink |
HFileLink.build(Configuration conf,
TableName table,
java.lang.String region,
java.lang.String family,
java.lang.String hfile)
Create an HFileLink instance from table/region/family/hfile location
|
static boolean |
HFileLink.create(Configuration conf,
FileSystem fs,
Path dstFamilyPath,
TableName linkedTable,
java.lang.String linkedRegion,
java.lang.String hfileName)
Create a new HFileLink
|
static boolean |
HFileLink.create(Configuration conf,
FileSystem fs,
Path dstFamilyPath,
TableName linkedTable,
java.lang.String linkedRegion,
java.lang.String hfileName,
boolean createBackRef)
Create a new HFileLink
|
static java.lang.String |
HFileLink.createHFileLinkName(TableName tableName,
java.lang.String regionName,
java.lang.String hfileName)
Create a new HFileLink name
|
static Path |
HFileLink.createPath(TableName table,
java.lang.String region,
java.lang.String family,
java.lang.String hfile)
Create an HFileLink relative path for the table/region/family/hfile location
|
| Modifier and Type | Method and Description |
|---|---|
void |
DelegatingPayloadCarryingRpcController.setPriority(TableName tn) |
void |
PayloadCarryingRpcController.setPriority(TableName tn) |
| Constructor and Description |
|---|
RegionCoprocessorRpcChannel(ClusterConnection conn,
TableName table,
byte[] row) |
| Modifier and Type | Method and Description |
|---|---|
TableName |
TableSplit.getTable() |
| Modifier and Type | Method and Description |
|---|---|
static Table |
TestTableMapReduceUtil.createAndFillTable(TableName tableName) |
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 |
TableInputFormatBase.initializeTable(Connection connection,
TableName tableName)
Allows subclasses to initialize the table information.
|
void |
TestTableSnapshotInputFormat.testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName,
java.lang.String snapshotName,
Path tmpTableDir) |
protected void |
TestTableSnapshotInputFormat.testWithMapReduceImpl(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
Path tableDir,
int numRegions,
int expectedNumSplits,
boolean shutdownCluster) |
| Constructor and Description |
|---|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
java.lang.String location)
Constructor
|
| Modifier and Type | Field and Description |
|---|---|
protected static TableName |
TestTableMapReduceBase.MULTI_REGION_TABLE_NAME |
| Modifier and Type | Method and Description |
|---|---|
TableName |
TableSplit.getTable()
Returns the table name.
|
TableName |
IntegrationTestBulkLoad.getTablename() |
TableName |
IntegrationTestTableSnapshotInputFormat.getTablename() |
static TableName |
IntegrationTestBulkLoad.getTableName(Configuration conf) |
| Modifier and Type | Method and Description |
|---|---|
static void |
TableInputFormat.configureSplitTable(Job job,
TableName tableName)
Sets split table in map-reduce job.
|
protected static void |
TableSnapshotInputFormatTestBase.createTableAndSnapshot(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
byte[] startRow,
byte[] endRow,
int numRegions) |
protected void |
IntegrationTestImportTsv.doLoadIncrementalHFiles(Path hfiles,
TableName tableName)
Verify the data described by
simple_tsv matches
simple_expected. |
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 |
TableInputFormatBase.initializeTable(Connection connection,
TableName tableName)
Allows subclasses to initialize the table information.
|
static void |
TableMapReduceUtil.initTableMapperJob(TableName table,
Scan scan,
java.lang.Class<? extends TableMapper> mapper,
java.lang.Class<?> outputKeyClass,
java.lang.Class<?> outputValueClass,
Job job)
Use this before submitting a TableMap job.
|
java.util.Map<LoadIncrementalHFiles.LoadQueueItem,java.nio.ByteBuffer> |
LoadIncrementalHFiles.run(java.lang.String dirPath,
java.util.Map<byte[],java.util.List<Path>> map,
TableName tableName) |
abstract void |
TableSnapshotInputFormatTestBase.testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName,
java.lang.String snapshotName,
Path tmpTableDir) |
void |
TestTableSnapshotInputFormat.testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName,
java.lang.String snapshotName,
Path tmpTableDir) |
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 java.util.List<LoadIncrementalHFiles.LoadQueueItem> |
LoadIncrementalHFiles.tryAtomicRegionLoad(Connection conn,
TableName tableName,
byte[] first,
java.util.Collection<LoadIncrementalHFiles.LoadQueueItem> lqis,
boolean copyFile)
Attempts to do an atomic load of many hfiles into a region.
|
protected void |
TestTableMapReduceBase.verify(TableName tableName) |
| Constructor and Description |
|---|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
java.lang.String location)
Creates a new instance without a scanner.
|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
java.lang.String location,
long length)
Creates a new instance without a scanner.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
java.lang.String location)
Creates a new instance while assigning all variables.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
java.lang.String location,
long length)
Creates a new instance while assigning all variables.
|
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
TestWarmupRegion.TABLENAME |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.Map<TableName,java.util.Map<ServerName,java.util.List<HRegionInfo>>> |
RegionStates.getAssignmentsByTable()
This is an EXPENSIVE clone.
|
java.util.Map<TableName,java.lang.Integer> |
RegionPlacementMaintainer.getRegionsMovement(FavoredNodesPlan newPlan)
Return how many regions will move per table since their primary RS will
change
|
java.util.Set<TableName> |
SnapshotOfRegionAssignmentFromMeta.getTableSet()
Get the table set
|
java.util.Map<TableName,java.util.List<HRegionInfo>> |
SnapshotOfRegionAssignmentFromMeta.getTableToRegionMap()
Get regions for tables
|
java.util.List<TableName> |
HMaster.listTableNames(java.lang.String namespace,
java.lang.String regex,
boolean includeSysTables)
Returns the list of table names that match the specified request
|
java.util.List<TableName> |
HMaster.listTableNamesByNamespace(java.lang.String name) |
java.util.List<TableName> |
MasterServices.listTableNamesByNamespace(java.lang.String name)
Get list of table names by namespace
|
| Modifier and Type | Method and Description |
|---|---|
HTableDescriptor |
MasterFileSystem.addColumn(TableName tableName,
HColumnDescriptor hcd)
Add column to a table
|
void |
HMaster.addColumn(TableName tableName,
HColumnDescriptor columnDescriptor,
long nonceGroup,
long nonce) |
void |
MasterServices.addColumn(TableName tableName,
HColumnDescriptor column,
long nonceGroup,
long nonce)
Add a new column to an existing table
|
java.util.List<RegionPlan> |
LoadBalancer.balanceCluster(TableName tableName,
java.util.Map<ServerName,java.util.List<HRegionInfo>> clusterState)
Perform the major balance operation
|
void |
HMaster.checkTableModifiable(TableName tableName) |
void |
MasterServices.checkTableModifiable(TableName tableName)
Check table is modifiable; i.e.
|
HTableDescriptor |
MasterFileSystem.deleteColumn(TableName tableName,
byte[] familyName)
Delete column of a table
|
void |
HMaster.deleteColumn(TableName tableName,
byte[] columnName,
long nonceGroup,
long nonce) |
void |
MasterServices.deleteColumn(TableName tableName,
byte[] columnName,
long nonceGroup,
long nonce)
Delete a column from an existing table
|
void |
MasterFileSystem.deleteTable(TableName tableName) |
long |
HMaster.deleteTable(TableName tableName,
long nonceGroup,
long nonce) |
long |
MasterServices.deleteTable(TableName tableName,
long nonceGroup,
long nonce)
Delete a table
|
long |
HMaster.disableTable(TableName tableName,
long nonceGroup,
long nonce) |
long |
MasterServices.disableTable(TableName tableName,
long nonceGroup,
long nonce)
Disable an existing table
|
long |
HMaster.enableTable(TableName tableName,
long nonceGroup,
long nonce) |
long |
MasterServices.enableTable(TableName tableName,
long nonceGroup,
long nonce)
Enable an existing table
|
void |
AssignmentVerificationReport.fillUp(TableName tableName,
SnapshotOfRegionAssignmentFromMeta snapshot,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Float>> regionLocalityMap) |
void |
AssignmentVerificationReport.fillUpDispersion(TableName tableName,
SnapshotOfRegionAssignmentFromMeta snapshot,
FavoredNodesPlan newPlan)
Use this to project the dispersion scores
|
long |
HMaster.getLastMajorCompactionTimestamp(TableName table) |
long |
MasterServices.getLastMajorCompactionTimestamp(TableName table) |
AdminProtos.GetRegionInfoResponse.CompactionState |
HMaster.getMobCompactionState(TableName tableName)
Gets the mob file compaction state for a specific table.
|
java.util.Map<RegionState.State,java.util.List<HRegionInfo>> |
RegionStates.getRegionByStateOfTable(TableName tableName)
Gets current state of all regions of the table.
|
java.util.List<HRegionInfo> |
RegionStates.getRegionsOfTable(TableName tableName)
Gets the online regions of the specified table.
|
Pair<java.lang.Integer,java.lang.Integer> |
AssignmentManager.getReopenStatus(TableName tableName)
Used by the client to identify if all regions have the schema updates
|
HTableDescriptor |
MasterFileSystem.modifyColumn(TableName tableName,
HColumnDescriptor hcd)
Modify Column of a table
|
void |
HMaster.modifyColumn(TableName tableName,
HColumnDescriptor descriptor,
long nonceGroup,
long nonce) |
void |
MasterServices.modifyColumn(TableName tableName,
HColumnDescriptor descriptor,
long nonceGroup,
long nonce)
Modify the column descriptor of an existing column in an existing table
|
void |
HMaster.modifyTable(TableName tableName,
HTableDescriptor descriptor,
long nonceGroup,
long nonce) |
void |
MasterServices.modifyTable(TableName tableName,
HTableDescriptor descriptor,
long nonceGroup,
long nonce)
Modify the descriptor of an existing table
|
Path |
MasterFileSystem.moveTableToTemp(TableName tableName)
Move the specified table to the hbase temp directory
|
void |
MasterCoprocessorHost.postAddColumn(TableName tableName,
HColumnDescriptor column) |
void |
TestTableLockManager.TestAlterAndDisableMasterObserver.postAddColumnHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HColumnDescriptor column) |
void |
MasterCoprocessorHost.postAddColumnHandler(TableName tableName,
HColumnDescriptor column) |
void |
MasterCoprocessorHost.postDeleteColumn(TableName tableName,
byte[] c) |
void |
TestTableLockManager.TestLockTimeoutExceptionMasterObserver.postDeleteColumnHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
byte[] c) |
void |
MasterCoprocessorHost.postDeleteColumnHandler(TableName tableName,
byte[] c) |
void |
MasterCoprocessorHost.postDeleteTable(TableName tableName) |
void |
MasterCoprocessorHost.postDeleteTableHandler(TableName tableName) |
void |
MasterCoprocessorHost.postDisableTable(TableName tableName) |
void |
TestTableLockManager.TestAlterAndDisableMasterObserver.postDisableTableHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
MasterCoprocessorHost.postDisableTableHandler(TableName tableName) |
void |
MasterCoprocessorHost.postEnableTable(TableName tableName) |
void |
MasterCoprocessorHost.postEnableTableHandler(TableName tableName) |
void |
MasterCoprocessorHost.postModifyColumn(TableName tableName,
HColumnDescriptor descriptor) |
void |
MasterCoprocessorHost.postModifyColumnHandler(TableName tableName,
HColumnDescriptor descriptor) |
void |
MasterCoprocessorHost.postModifyTable(TableName tableName,
HTableDescriptor htd) |
void |
MasterCoprocessorHost.postModifyTableHandler(TableName tableName,
HTableDescriptor htd) |
void |
MasterCoprocessorHost.postSetTableQuota(TableName table,
QuotaProtos.Quotas quotas) |
void |
MasterCoprocessorHost.postSetUserQuota(java.lang.String user,
TableName table,
QuotaProtos.Quotas quotas) |
void |
MasterCoprocessorHost.postTableFlush(TableName tableName) |
void |
MasterCoprocessorHost.postTruncateTable(TableName tableName) |
void |
MasterCoprocessorHost.postTruncateTableHandler(TableName tableName) |
boolean |
MasterCoprocessorHost.preAddColumn(TableName tableName,
HColumnDescriptor column) |
void |
TestTableLockManager.TestLockTimeoutExceptionMasterObserver.preAddColumnHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HColumnDescriptor column) |
void |
TestTableLockManager.TestAlterAndDisableMasterObserver.preAddColumnHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HColumnDescriptor column) |
boolean |
MasterCoprocessorHost.preAddColumnHandler(TableName tableName,
HColumnDescriptor column) |
boolean |
MasterCoprocessorHost.preDeleteColumn(TableName tableName,
byte[] c) |
void |
TestTableLockManager.TestLockTimeoutExceptionMasterObserver.preDeleteColumnHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
byte[] c) |
boolean |
MasterCoprocessorHost.preDeleteColumnHandler(TableName tableName,
byte[] c) |
void |
MasterCoprocessorHost.preDeleteTable(TableName tableName) |
void |
MasterCoprocessorHost.preDeleteTableHandler(TableName tableName) |
void |
TestTableLockManager.TestAlterAndDisableMasterObserver.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
MasterCoprocessorHost.preDisableTable(TableName tableName) |
void |
MasterCoprocessorHost.preDisableTableHandler(TableName tableName) |
void |
MasterCoprocessorHost.preEnableTable(TableName tableName) |
void |
MasterCoprocessorHost.preEnableTableHandler(TableName tableName) |
boolean |
MasterCoprocessorHost.preModifyColumn(TableName tableName,
HColumnDescriptor descriptor) |
boolean |
MasterCoprocessorHost.preModifyColumnHandler(TableName tableName,
HColumnDescriptor descriptor) |
void |
MasterCoprocessorHost.preModifyTable(TableName tableName,
HTableDescriptor htd) |
void |
MasterCoprocessorHost.preModifyTableHandler(TableName tableName,
HTableDescriptor htd) |
void |
MasterCoprocessorHost.preSetTableQuota(TableName table,
QuotaProtos.Quotas quotas) |
void |
MasterCoprocessorHost.preSetUserQuota(java.lang.String user,
TableName table,
QuotaProtos.Quotas quotas) |
void |
MasterCoprocessorHost.preTableFlush(TableName tableName) |
void |
MasterCoprocessorHost.preTruncateTable(TableName tableName) |
void |
MasterCoprocessorHost.preTruncateTableHandler(TableName tableName) |
void |
RegionPlacementMaintainer.printDispersionScores(TableName table,
SnapshotOfRegionAssignmentFromMeta snapshot,
int numRegions,
FavoredNodesPlan newPlan,
boolean simplePrint) |
abstract TableLockManager.TableLock |
TableLockManager.readLock(TableName tableName,
java.lang.String purpose)
Returns a TableLock for locking the table for shared access among read-lock holders
|
TableLockManager.TableLock |
TableLockManager.NullTableLockManager.readLock(TableName tableName,
java.lang.String purpose) |
void |
HMaster.reportMobCompactionEnd(TableName tableName) |
void |
HMaster.reportMobCompactionStart(TableName tableName) |
void |
MasterMobCompactionThread.requestMobCompaction(Configuration conf,
FileSystem fs,
TableName tableName,
java.util.List<HColumnDescriptor> columns,
TableLockManager tableLockManager,
boolean allFiles)
Requests mob compaction
|
void |
HMaster.requestMobCompaction(TableName tableName,
java.util.List<HColumnDescriptor> columns,
boolean allFiles)
Requests mob compaction.
|
protected void |
AssignmentManager.setEnabledTable(TableName tableName) |
void |
RegionStates.tableDeleted(TableName tableName)
A table is deleted.
|
abstract void |
TableLockManager.tableDeleted(TableName tableName)
Called after a table has been deleted, and after the table lock is released.
|
void |
TableLockManager.NullTableLockManager.tableDeleted(TableName tableName) |
void |
HMaster.truncateTable(TableName tableName,
boolean preserveSplits,
long nonceGroup,
long nonce) |
void |
MasterServices.truncateTable(TableName tableName,
boolean preserveSplits,
long nonceGroup,
long nonce)
Truncate a table
|
abstract TableLockManager.TableLock |
TableLockManager.writeLock(TableName tableName,
java.lang.String purpose)
Returns a TableLock for locking the table for exclusive access
|
TableLockManager.TableLock |
TableLockManager.NullTableLockManager.writeLock(TableName tableName,
java.lang.String purpose) |
| Modifier and Type | Method and Description |
|---|---|
Pair<java.lang.Long,java.lang.String> |
HMaster.backupTables(BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth) |
Pair<java.lang.Long,java.lang.String> |
MasterServices.backupTables(BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth)
Full backup given list of tables
|
void |
RegionPlacementMaintainer.checkDifferencesWithOldPlan(java.util.Map<TableName,java.lang.Integer> movesPerTable,
java.util.Map<java.lang.String,java.util.Map<java.lang.String,java.lang.Float>> regionLocalityMap,
FavoredNodesPlan newPlan)
Compares two plans and check whether the locality dropped or increased
(prints the information as a string) also prints the baseline locality
|
java.util.List<HTableDescriptor> |
HMaster.listTableDescriptors(java.lang.String namespace,
java.lang.String regex,
java.util.List<TableName> tableNameList,
boolean includeSysTables)
Returns the list of table descriptors that match the specified request
|
void |
MasterCoprocessorHost.postGetTableDescriptors(java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
MasterCoprocessorHost.postMoveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup) |
boolean |
MasterCoprocessorHost.preGetTableDescriptors(java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors)
Deprecated.
|
boolean |
MasterCoprocessorHost.preGetTableDescriptors(java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
MasterCoprocessorHost.preMoveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup) |
| Constructor and Description |
|---|
SnapshotOfRegionAssignmentFromMeta(Connection connection,
java.util.Set<TableName> disabledTables,
boolean excludeOfflinedSplitParents) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<RegionPlan> |
FavoredNodeLoadBalancer.balanceCluster(TableName tableName,
java.util.Map<ServerName,java.util.List<HRegionInfo>> clusterState) |
java.util.List<RegionPlan> |
SimpleLoadBalancer.balanceCluster(TableName tableName,
java.util.Map<ServerName,java.util.List<HRegionInfo>> clusterState) |
java.util.List<RegionPlan> |
StochasticLoadBalancer.balanceCluster(TableName tableName,
java.util.Map<ServerName,java.util.List<HRegionInfo>> clusterState) |
java.util.List<RegionPlan> |
TestBaseLoadBalancer.MockBalancer.balanceCluster(TableName tableName,
java.util.Map<ServerName,java.util.List<HRegionInfo>> clusterState) |
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
TableEventHandler.tableName |
| Modifier and Type | Method and Description |
|---|---|
static void |
TestEnableTableHandler.deleteTable(HBaseTestingUtility testUtil,
HBaseAdmin admin,
TableName tableName) |
static void |
TestEnableTableHandler.deleteTable(HBaseTestingUtility testUtil,
TableName tableName) |
protected java.util.List<HRegionInfo> |
CreateTableHandler.handleCreateHdfsRegions(Path tableRootDir,
TableName tableName)
Create the on-disk structure for the table, and returns the regions info.
|
void |
TestEnableTableHandler.MasterSyncObserver.postDeleteTableHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
| Constructor and Description |
|---|
DeleteTableHandler(TableName tableName,
Server server,
MasterServices masterServices) |
DisableTableHandler(Server server,
TableName tableName,
AssignmentManager assignmentManager,
TableLockManager tableLockManager,
boolean skipTableStateCheck) |
EnableTableHandler(MasterServices services,
TableName tableName,
AssignmentManager assignmentManager,
TableLockManager tableLockManager,
boolean skipTableStateCheck) |
EnableTableHandler(Server server,
TableName tableName,
AssignmentManager assignmentManager,
TableLockManager tableLockManager,
boolean skipTableStateCheck) |
ModifyTableHandler(TableName tableName,
HTableDescriptor htd,
Server server,
MasterServices masterServices) |
TableAddFamilyHandler(TableName tableName,
HColumnDescriptor familyDesc,
Server server,
MasterServices masterServices) |
TableDeleteFamilyHandler(TableName tableName,
byte[] familyName,
Server server,
MasterServices masterServices) |
TableEventHandler(EventType eventType,
TableName tableName,
Server server,
MasterServices masterServices) |
TableModifyFamilyHandler(TableName tableName,
HColumnDescriptor familyDesc,
Server server,
MasterServices masterServices) |
TruncateTableHandler(TableName tableName,
Server server,
MasterServices masterServices,
boolean preserveSplits) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<NormalizationPlan> |
RegionNormalizer.computePlanForTable(TableName table)
Computes next optimal normalization plan.
|
java.util.List<NormalizationPlan> |
SimpleRegionNormalizer.computePlanForTable(TableName table)
Computes next most "urgent" normalization action on the table.
|
| Modifier and Type | Method and Description |
|---|---|
TableName |
AddColumnFamilyProcedure.getTableName() |
TableName |
CreateTableProcedure.getTableName() |
TableName |
DeleteColumnFamilyProcedure.getTableName() |
TableName |
DeleteTableProcedure.getTableName() |
TableName |
DisableTableProcedure.getTableName() |
TableName |
EnableTableProcedure.getTableName() |
TableName |
ModifyColumnFamilyProcedure.getTableName() |
TableName |
ModifyTableProcedure.getTableName() |
TableName |
TableProcedureInterface.getTableName() |
TableName |
TruncateTableProcedure.getTableName() |
TableName |
TestMasterProcedureQueue.TestTableProcedure.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
CreateTableProcedure.assignRegions(MasterProcedureEnv env,
TableName tableName,
java.util.List<HRegionInfo> regions) |
static void |
MasterDDLOperationHelper.checkTableModifiable(MasterProcedureEnv env,
TableName tableName)
Check whether a table is modifiable - exists and either offline or online with config set
|
java.util.List<HRegionInfo> |
CreateTableProcedure.CreateHdfsRegions.createHdfsRegions(MasterProcedureEnv env,
Path tableRootDir,
TableName tableName,
java.util.List<HRegionInfo> newRegions) |
static HTableDescriptor |
MasterProcedureTestingUtility.createHTD(TableName tableName,
java.lang.String... family) |
static HRegionInfo[] |
MasterProcedureTestingUtility.createTable(ProcedureExecutor<MasterProcedureEnv> procExec,
TableName tableName,
byte[][] splitKeys,
java.lang.String... family) |
protected static void |
DeleteTableProcedure.deleteAssignmentState(MasterProcedureEnv env,
TableName tableName) |
static void |
MasterDDLOperationHelper.deleteColumnFamilyFromFileSystem(MasterProcedureEnv env,
TableName tableName,
java.util.List<HRegionInfo> regionInfoList,
byte[] familyName,
boolean hasMob)
Remove the column family from the file system
|
protected static void |
DeleteTableProcedure.deleteFromFs(MasterProcedureEnv env,
TableName tableName,
java.util.List<HRegionInfo> regions,
boolean archive) |
protected static void |
DeleteTableProcedure.deleteFromMeta(MasterProcedureEnv env,
TableName tableName,
java.util.List<HRegionInfo> regions) |
protected static void |
DeleteTableProcedure.deleteTableDescriptorCache(MasterProcedureEnv env,
TableName tableName) |
protected static void |
DeleteTableProcedure.deleteTableStates(MasterProcedureEnv env,
TableName tableName) |
protected static java.util.List<HRegionInfo> |
ProcedureSyncWait.getRegionsFromMeta(MasterProcedureEnv env,
TableName tableName) |
static void |
MasterProcedureTestingUtility.loadData(Connection connection,
TableName tableName,
int rows,
byte[][] splitKeys,
java.lang.String... sfamilies) |
protected static org.apache.hadoop.hbase.master.procedure.DisableTableProcedure.MarkRegionOfflineOpResult |
DisableTableProcedure.markRegionsOffline(MasterProcedureEnv env,
TableName tableName,
java.lang.Boolean retryRequired)
Mark regions of the table offline with retries
|
protected static void |
EnableTableProcedure.markRegionsOnline(MasterProcedureEnv env,
TableName tableName,
java.lang.Boolean retryRequired)
Mark offline regions of the table online with retry
|
protected boolean |
MasterProcedureQueue.markTableAsDeleted(TableName table)
Tries to remove the queue and the table-lock of the specified table.
|
void |
MasterProcedureQueue.releaseTableRead(TableName table)
Release the read lock taken with tryAcquireTableRead()
|
void |
MasterProcedureQueue.releaseTableWrite(TableName table)
Release the write lock taken with tryAcquireTableWrite()
|
static boolean |
MasterDDLOperationHelper.reOpenAllRegions(MasterProcedureEnv env,
TableName tableName,
java.util.List<HRegionInfo> regionInfoList)
Reopen all regions from a table after a schema change operation.
|
protected static void |
DisableTableProcedure.setTableStateToDisabled(MasterProcedureEnv env,
TableName tableName)
Mark table state to Disabled
|
protected static void |
DisableTableProcedure.setTableStateToDisabling(MasterProcedureEnv env,
TableName tableName)
Mark table state to Disabling
|
protected static void |
EnableTableProcedure.setTableStateToEnabled(MasterProcedureEnv env,
TableName tableName)
Mark table state to Enabled
|
protected static void |
EnableTableProcedure.setTableStateToEnabling(MasterProcedureEnv env,
TableName tableName)
Mark table state to Enabling
|
boolean |
MasterProcedureQueue.tryAcquireTableRead(TableName table,
java.lang.String purpose)
Try to acquire the read lock on the specified table.
|
boolean |
MasterProcedureQueue.tryAcquireTableWrite(TableName table,
java.lang.String purpose)
Try to acquire the write lock on the specified table.
|
protected static void |
CreateTableProcedure.updateTableDescCache(MasterProcedureEnv env,
TableName tableName) |
static void |
MasterProcedureTestingUtility.validateColumnFamilyAddition(HMaster master,
TableName tableName,
java.lang.String family) |
static void |
MasterProcedureTestingUtility.validateColumnFamilyDeletion(HMaster master,
TableName tableName,
java.lang.String family) |
static void |
MasterProcedureTestingUtility.validateColumnFamilyModification(HMaster master,
TableName tableName,
java.lang.String family,
HColumnDescriptor columnDescriptor) |
static void |
MasterProcedureTestingUtility.validateTableCreation(HMaster master,
TableName tableName,
HRegionInfo[] regions,
boolean hasFamilyDirs,
java.lang.String... family) |
static void |
MasterProcedureTestingUtility.validateTableCreation(HMaster master,
TableName tableName,
HRegionInfo[] regions,
java.lang.String... family) |
static void |
MasterProcedureTestingUtility.validateTableDeletion(HMaster master,
TableName tableName,
HRegionInfo[] regions,
java.lang.String... family) |
static void |
MasterProcedureTestingUtility.validateTableIsDisabled(HMaster master,
TableName tableName) |
static void |
MasterProcedureTestingUtility.validateTableIsEnabled(HMaster master,
TableName tableName) |
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
TakeSnapshotHandler.snapshotTable |
| Modifier and Type | Method and Description |
|---|---|
protected java.util.List<HRegionInfo> |
CloneSnapshotHandler.handleCreateHdfsRegions(Path tableRootDir,
TableName tableName)
Create the on-disk regions, using the tableRootDir provided by the CreateTableHandler.
|
void |
SnapshotManager.setSnapshotHandlerForTesting(TableName tableName,
SnapshotSentinel handler)
Set the handler for the current snapshot
|
| Modifier and Type | Method and Description |
|---|---|
static TableName |
MobUtils.getTableLockName(TableName tn)
Gets the table name used in the table lock.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
MobUtils.cleanExpiredMobFiles(FileSystem fs,
Configuration conf,
TableName tableName,
HColumnDescriptor columnDescriptor,
CacheConfig cacheConfig,
long current)
Cleans the expired mob files.
|
static void |
MobUtils.doMobCompaction(Configuration conf,
FileSystem fs,
TableName tableName,
HColumnDescriptor hcd,
java.util.concurrent.ExecutorService pool,
TableLockManager tableLockManager,
boolean allFiles)
Performs the mob compaction.
|
static Path |
MobUtils.getMobFamilyPath(Configuration conf,
TableName tableName,
java.lang.String familyName)
Gets the family dir of the mob files.
|
static HRegionInfo |
MobUtils.getMobRegionInfo(TableName tableName)
Gets the HRegionInfo of the mob files.
|
static Path |
MobUtils.getMobRegionPath(Configuration conf,
TableName tableName)
Gets the region dir of the mob files.
|
static TableName |
MobUtils.getTableLockName(TableName tn)
Gets the table name used in the table lock.
|
static boolean |
MobUtils.isMobRegionName(TableName tableName,
byte[] regionName)
Gets whether the current region name follows the pattern of a mob region name.
|
static void |
MobUtils.removeMobFiles(Configuration conf,
FileSystem fs,
TableName tableName,
Path tableDir,
byte[] family,
java.util.Collection<StoreFile> storeFiles)
Archives the mob files.
|
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
MobCompactor.tableName |
| Constructor and Description |
|---|
MobCompactor(Configuration conf,
FileSystem fs,
TableName tableName,
HColumnDescriptor column,
java.util.concurrent.ExecutorService pool) |
PartitionedMobCompactor(Configuration conf,
FileSystem fs,
TableName tableName,
HColumnDescriptor column,
java.util.concurrent.ExecutorService pool) |
| Modifier and Type | Method and Description |
|---|---|
int |
SweepJob.sweep(TableName tn,
HColumnDescriptor family)
Runs MapReduce to do the sweeping on the mob files.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NamespaceAuditor.checkQuotaToCreateTable(TableName tName,
int regions)
Check quota to create table.
|
void |
NamespaceAuditor.checkQuotaToUpdateRegion(TableName tName,
int regions)
Check and update region count quota for an existing table.
|
int |
NamespaceAuditor.getRegionCountOfTable(TableName tName)
Get region count for table
|
void |
TestNamespaceAuditor.MasterSyncObserver.postDeleteTableHandler(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
TestNamespaceAuditor.MasterSyncObserver.preDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
NamespaceAuditor.removeFromNamespaceUsage(TableName tableName) |
| Modifier and Type | Method and Description |
|---|---|
static TableName[] |
ProtobufUtil.getTableNameArray(java.util.List<TableProtos.TableName> tableNamesList) |
static TableName |
ProtobufUtil.toTableName(TableProtos.TableName tableNamePB) |
| Modifier and Type | Method and Description |
|---|---|
static MasterProtos.AddColumnRequest |
RequestConverter.buildAddColumnRequest(TableName tableName,
HColumnDescriptor column,
long nonceGroup,
long nonce)
Create a protocol buffer AddColumnRequest
|
static MasterProtos.DeleteColumnRequest |
RequestConverter.buildDeleteColumnRequest(TableName tableName,
byte[] columnName,
long nonceGroup,
long nonce)
Create a protocol buffer DeleteColumnRequest
|
static MasterProtos.DeleteTableRequest |
RequestConverter.buildDeleteTableRequest(TableName tableName,
long nonceGroup,
long nonce)
Creates a protocol buffer DeleteTableRequest
|
static MasterProtos.DisableTableRequest |
RequestConverter.buildDisableTableRequest(TableName tableName,
long nonceGroup,
long nonce)
Creates a protocol buffer DisableTableRequest
|
static MasterProtos.EnableTableRequest |
RequestConverter.buildEnableTableRequest(TableName tableName,
long nonceGroup,
long nonce)
Creates a protocol buffer EnableTableRequest
|
static MasterProtos.GetSchemaAlterStatusRequest |
RequestConverter.buildGetSchemaAlterStatusRequest(TableName tableName)
Creates a protocol buffer GetSchemaAlterStatusRequest
|
static MasterProtos.GetTableDescriptorsRequest |
RequestConverter.buildGetTableDescriptorsRequest(TableName tableName)
Creates a protocol buffer GetTableDescriptorsRequest for a single table
|
static AccessControlProtos.GrantRequest |
RequestConverter.buildGrantRequest(java.lang.String username,
TableName tableName,
byte[] family,
byte[] qualifier,
AccessControlProtos.Permission.Action... actions)
Create a request to grant user permissions.
|
static MasterProtos.ModifyColumnRequest |
RequestConverter.buildModifyColumnRequest(TableName tableName,
HColumnDescriptor column,
long nonceGroup,
long nonce)
Create a protocol buffer ModifyColumnRequest
|
static MasterProtos.ModifyTableRequest |
RequestConverter.buildModifyTableRequest(TableName tableName,
HTableDescriptor hTableDesc,
long nonceGroup,
long nonce)
Creates a protocol buffer ModifyTableRequest
|
static AccessControlProtos.RevokeRequest |
RequestConverter.buildRevokeRequest(java.lang.String username,
TableName tableName,
byte[] family,
byte[] qualifier,
AccessControlProtos.Permission.Action... actions)
Create a request to revoke user permissions.
|
static MasterProtos.TruncateTableRequest |
RequestConverter.buildTruncateTableRequest(TableName tableName,
boolean preserveSplits,
long nonceGroup,
long nonce)
Creates a protocol buffer TruncateTableRequest
|
static java.util.List<UserPermission> |
ProtobufUtil.getUserPermissions(RpcController controller,
AccessControlProtos.AccessControlService.BlockingInterface protocol,
TableName t)
A utility used to get user table permissions.
|
static void |
ProtobufUtil.grant(RpcController controller,
AccessControlProtos.AccessControlService.BlockingInterface protocol,
java.lang.String userShortName,
TableName tableName,
byte[] f,
byte[] q,
Permission.Action... actions)
A utility used to grant a user table permissions.
|
static void |
ProtobufUtil.revoke(RpcController controller,
AccessControlProtos.AccessControlService.BlockingInterface protocol,
java.lang.String userShortName,
TableName tableName,
byte[] f,
byte[] q,
Permission.Action... actions)
A utility used to revoke a user's table permissions.
|
static WALProtos.BulkLoadDescriptor |
ProtobufUtil.toBulkLoadDescriptor(TableName tableName,
ByteString encodedRegionName,
java.util.Map<byte[],java.util.List<Path>> storeFiles,
java.util.Map<java.lang.String,java.lang.Long> storeFilesSize,
long bulkloadSeqId)
Generates a marker for the WAL so that we propagate the notion of a bulk region load
throughout the WAL.
|
static TableProtos.TableName |
ProtobufUtil.toProtoTableName(TableName tableName) |
| Modifier and Type | Method and Description |
|---|---|
static MasterProtos.BackupTablesRequest |
RequestConverter.buildBackupTablesRequest(BackupType type,
java.util.List<TableName> tableList,
java.lang.String targetRootDir,
int workers,
long bandwidth) |
static MasterProtos.GetTableDescriptorsRequest |
RequestConverter.buildGetTableDescriptorsRequest(java.util.List<TableName> tableNames)
Creates a protocol buffer GetTableDescriptorsRequest
|
| Modifier and Type | Field and Description |
|---|---|
static TableName |
QuotaTableUtil.QUOTA_TABLE_NAME
System table for quotas
|
| Modifier and Type | Method and Description |
|---|---|
protected static TableName |
QuotaTableUtil.getTableFromRowKey(byte[] key) |
TableName |
QuotaSettings.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<TableName,SpaceQuotaSnapshot> |
RegionServerSpaceQuotaManager.copyQuotaSnapshots()
Copies the last
SpaceQuotaSnapshots that were recorded. |
java.util.Map<TableName,SpaceQuotaSnapshot> |
SpaceQuotaSnapshotNotifierForTest.copySnapshots() |
java.util.Map<TableName,SpaceQuotaSnapshot> |
SpaceQuotaRefresherChore.fetchSnapshotsFromQuotaTable()
Reads all quota violation policies which are to be enforced from the quota table.
|
static java.util.Map<TableName,QuotaState> |
QuotaUtil.fetchTableQuotas(Connection connection,
java.util.List<Get> gets) |
java.util.Map<TableName,SpaceQuotaSnapshot> |
RegionServerSpaceQuotaManager.getActivePoliciesAsMap()
Converts a map of table to
SpaceViolationPolicyEnforcements into
SpaceViolationPolicys. |
static java.util.Map<TableName,java.lang.Long> |
QuotaTableUtil.getMasterReportedTableSizes(Connection conn)
Fetches the table sizes on the filesystem as tracked by the HBase Master.
|
java.util.Map<TableName,SpaceViolationPolicyEnforcement> |
ActivePolicyEnforcement.getPolicies()
Returns an unmodifiable version of the active
SpaceViolationPolicyEnforcements. |
static java.util.Map<TableName,SpaceQuotaSnapshot> |
QuotaTableUtil.getRegionServerQuotaSnapshots(Connection conn,
ServerName regionServer)
Fetches the observed
SpaceQuotaSnapshots observed by a RegionServer. |
static java.util.Map<TableName,SpaceQuotaSnapshot> |
QuotaTableUtil.getSnapshots(Connection conn)
Fetches all
SpaceQuotaSnapshot objects from the hbase:quota table. |
java.util.Map<TableName,SpaceQuotaSnapshot> |
QuotaObserverChore.getTableQuotaSnapshots()
Returns an unmodifiable view over the current
SpaceQuotaSnapshot objects
for each HBase table with a quota defined. |
| Modifier and Type | Method and Description |
|---|---|
static void |
QuotaUtil.addTableQuota(Connection connection,
TableName table,
QuotaProtos.Quotas data) |
static void |
QuotaUtil.addUserQuota(Connection connection,
java.lang.String user,
TableName table,
QuotaProtos.Quotas data) |
boolean |
RegionServerSpaceQuotaManager.areCompactionsDisabled(TableName tableName)
Returns whether or not compactions should be disabled for the given
tableName per
a space quota violation policy. |
void |
MasterQuotaManager.checkAndUpdateNamespaceRegionQuota(TableName tName,
int regions) |
void |
MasterQuotaManager.checkNamespaceTableAndRegionQuota(TableName tName,
int regions) |
SpaceViolationPolicyEnforcement |
SpaceViolationPolicyEnforcementFactory.create(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot)
Constructs the appropriate
SpaceViolationPolicyEnforcement for tables that are
in violation of their space quota. |
SpaceViolationPolicyEnforcement |
SpaceViolationPolicyEnforcementFactory.createWithoutViolation(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot)
Creates the "default"
SpaceViolationPolicyEnforcement for a table that isn't in
violation. |
static void |
QuotaUtil.deleteTableQuota(Connection connection,
TableName table) |
static void |
QuotaUtil.deleteUserQuota(Connection connection,
java.lang.String user,
TableName table) |
void |
RegionServerSpaceQuotaManager.disableViolationPolicyEnforcement(TableName tableName)
Disables enforcement on any violation policy on the given
tableName. |
void |
RegionServerSpaceQuotaManager.enforceViolationPolicy(TableName tableName,
SpaceQuotaSnapshot snapshot)
Enforces the given violationPolicy on the given table in this RegionServer.
|
java.lang.Iterable<java.util.Map.Entry<HRegionInfo,java.lang.Long>> |
TableQuotaSnapshotStore.filterBySubject(TableName table) |
static SpaceQuotaSnapshot |
QuotaTableUtil.getCurrentSnapshot(Connection conn,
TableName tn)
Returns the Master's view of a quota on the given
tableName or null if the
Master has no quota information on that table. |
SpaceQuotaSnapshot |
TableQuotaSnapshotStore.getCurrentState(TableName table) |
SpaceViolationPolicyEnforcement |
ActivePolicyEnforcement.getPolicyEnforcement(TableName tableName)
Returns the proper
SpaceViolationPolicyEnforcement implementation for the given table. |
OperationQuota |
RegionServerRpcQuotaManager.getQuota(UserGroupInformation ugi,
TableName table)
Returns the quota for an operation.
|
int |
MasterQuotaManager.getRegionCountOfTable(TableName tName) |
protected static byte[] |
QuotaTableUtil.getSettingsQualifierForUserTable(TableName tableName) |
QuotaProtos.SpaceQuota |
TableQuotaSnapshotStore.getSpaceQuota(TableName subject) |
QuotaLimiter |
QuotaCache.getTableLimiter(TableName table)
Returns the limiter associated to the specified table.
|
QuotaLimiter |
UserQuotaState.getTableLimiter(TableName table)
Return the limiter for the specified table associated with this quota.
|
static QuotaProtos.Quotas |
QuotaTableUtil.getTableQuota(Connection connection,
TableName table) |
protected static byte[] |
QuotaTableUtil.getTableRowKey(TableName table) |
SpaceQuotaSnapshot |
TableQuotaSnapshotStore.getTargetState(TableName table,
QuotaProtos.SpaceQuota spaceQuota) |
QuotaLimiter |
QuotaCache.getUserLimiter(UserGroupInformation ugi,
TableName table)
Returns the limiter associated to the specified user/table.
|
static QuotaProtos.Quotas |
QuotaTableUtil.getUserQuota(Connection connection,
java.lang.String user,
TableName table) |
void |
SpaceViolationPolicyEnforcement.initialize(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot)
Initializes this policy instance.
|
static QuotaSettings |
QuotaSettingsFactory.limitTableSpace(TableName tableName,
long sizeLimit,
SpaceViolationPolicy violationPolicy)
Creates a
QuotaSettings object to limit the FileSystem space usage for the given table
to the given size in bytes. |
static Get |
QuotaTableUtil.makeGetForTableQuotas(TableName table) |
protected static void |
QuotaTableUtil.parseTableResult(TableName table,
Result result,
QuotaTableUtil.TableQuotasVisitor visitor) |
void |
MasterSpaceQuotaObserver.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
static Put |
QuotaTableUtil.putSpaceSnapshot(TableName tableName,
SpaceQuotaSnapshot snapshot)
|
void |
MasterQuotaManager.removeTableFromNamespaceQuota(TableName tName)
Remove table from namespace quota.
|
static QuotaSettings |
QuotaSettingsFactory.removeTableSpaceLimit(TableName tableName)
Creates a
QuotaSettings object to remove the FileSystem space quota for the given
table. |
void |
TableQuotaSnapshotStore.setCurrentState(TableName table,
SpaceQuotaSnapshot snapshot) |
void |
UserQuotaState.setQuotas(TableName table,
QuotaProtos.Quotas quotas)
Add the quota information of the specified table.
|
void |
MasterQuotaManager.setTableQuota(TableName table,
MasterProtos.SetQuotaRequest req) |
void |
MasterQuotaManager.setUserQuota(java.lang.String userName,
TableName table,
MasterProtos.SetQuotaRequest req) |
static QuotaSettings |
QuotaSettingsFactory.throttleTable(TableName tableName,
ThrottleType type,
long limit,
java.util.concurrent.TimeUnit timeUnit)
Throttle the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.throttleUser(java.lang.String userName,
TableName tableName,
ThrottleType type,
long limit,
java.util.concurrent.TimeUnit timeUnit)
Throttle the specified user on the specified table.
|
void |
SpaceQuotaSnapshotNotifier.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot)
Instructs the cluster that the given table is in violation of a space quota.
|
void |
TableSpaceQuotaSnapshotNotifier.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot) |
void |
SpaceQuotaSnapshotNotifierForTest.transitionTable(TableName tableName,
SpaceQuotaSnapshot snapshot) |
static QuotaSettings |
QuotaSettingsFactory.unthrottleTable(TableName tableName)
Remove the throttling for the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.unthrottleUser(java.lang.String userName,
TableName tableName)
Remove the throttling for the specified user on the specified table.
|
void |
QuotaTableUtil.TableQuotasVisitor.visitTableQuotas(TableName tableName,
QuotaProtos.Quotas quotas) |
void |
QuotaTableUtil.UserQuotasVisitor.visitUserQuotas(java.lang.String userName,
TableName table,
QuotaProtos.Quotas quotas) |
| Modifier and Type | Method and Description |
|---|---|
static void |
QuotaTableUtil.extractQuotaSnapshot(Result result,
java.util.Map<TableName,SpaceQuotaSnapshot> snapshots)
Extracts the
SpaceViolationPolicy and TableName from the provided
Result and adds them to the given Map. |
static Get |
QuotaTableUtil.makeGetForUserQuotas(java.lang.String user,
java.lang.Iterable<TableName> tables,
java.lang.Iterable<java.lang.String> namespaces) |
void |
RegionServerSpaceQuotaManager.updateQuotaSnapshot(java.util.Map<TableName,SpaceQuotaSnapshot> newSnapshots)
Updates the current
SpaceQuotaSnapshots for the RegionServer. |
| Constructor and Description |
|---|
QuotaSettings(java.lang.String userName,
TableName tableName,
java.lang.String namespace) |
| Constructor and Description |
|---|
ActivePolicyEnforcement(java.util.Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
java.util.Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss) |
ActivePolicyEnforcement(java.util.Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
java.util.Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss) |
ActivePolicyEnforcement(java.util.Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
java.util.Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss,
SpaceViolationPolicyEnforcementFactory factory) |
ActivePolicyEnforcement(java.util.Map<TableName,SpaceViolationPolicyEnforcement> activePolicies,
java.util.Map<TableName,SpaceQuotaSnapshot> snapshots,
RegionServerServices rss,
SpaceViolationPolicyEnforcementFactory factory) |
| Modifier and Type | Method and Description |
|---|---|
TableName |
AbstractViolationPolicyEnforcement.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractViolationPolicyEnforcement.initialize(RegionServerServices rss,
TableName tableName,
SpaceQuotaSnapshot snapshot) |
void |
AbstractViolationPolicyEnforcement.setTableName(TableName tableName) |
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
TestFailedAppendAndSync.tableName |
static TableName |
TestPerColumnFamilyFlush.TABLENAME |
| Modifier and Type | Method and Description |
|---|---|
TableName |
HStore.getTableName() |
TableName |
Store.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
java.util.Set<TableName> |
HRegionServer.getOnlineTables()
Gets the online tables in this RS.
|
java.util.Set<TableName> |
RegionServerServices.getOnlineTables() |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<Region> |
HRegionServer.getOnlineRegions(TableName tableName)
Gets the online regions of the specified table.
|
java.util.List<Region> |
OnlineRegions.getOnlineRegions(TableName tableName)
Get all online regions of a table in this RS.
|
HRegion |
TestFailedAppendAndSync.initHRegion(TableName tableName,
byte[] startKey,
byte[] stopKey,
WAL wal) |
static HRegion |
TestHRegion.initHRegion(TableName tableName,
java.lang.String callingMethod,
Configuration conf,
byte[]... families) |
void |
TestMobStoreScanner.setUp(long threshold,
TableName tn) |
| Constructor and Description |
|---|
AtomicHFileLoader(TableName tableName,
MultithreadedTestUtil.TestContext ctx,
byte[][] targetFamilies) |
AtomicScanReader(TableName TABLE_NAME,
MultithreadedTestUtil.TestContext ctx,
byte[][] targetFamilies) |
| Modifier and Type | Method and Description |
|---|---|
protected WALKey |
FSHLog.makeKey(byte[] encodedRegionName,
TableName tableName,
long seqnum,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce) |
| Constructor and Description |
|---|
HLogKey(byte[] encodedRegionName,
TableName tablename)
Deprecated.
|
HLogKey(byte[] encodedRegionName,
TableName tablename,
long now)
Deprecated.
|
HLogKey(byte[] encodedRegionName,
TableName tablename,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce)
Deprecated.
Create the log key for writing to somewhere.
|
HLogKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce)
Deprecated.
Create the log key for writing to somewhere.
|
HLogKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long nonceGroup,
long nonce)
Deprecated.
Create the log key for writing to somewhere.
|
HLogKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long now,
java.util.UUID clusterId)
Deprecated.
|
ReplayHLogKey(byte[] encodedRegionName,
TableName tablename,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce) |
ReplayHLogKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce) |
WALEditsReplaySink(Configuration conf,
TableName tableName,
HConnection conn)
Create a sink for WAL log entries replay
|
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<TableName,java.util.List<java.lang.String>> |
ReplicationPeer.getTableCFs()
Get replicable (table, cf-list) map of this peer
|
java.util.Map<TableName,java.util.List<java.lang.String>> |
ReplicationPeerZKImpl.getTableCFs()
Get replicable (table, cf-list) map of this peer
|
java.util.Map<TableName,java.util.List<java.lang.String>> |
ReplicationPeers.getTableCFs(java.lang.String peerId)
Get the table and column-family-list map of the peer.
|
java.util.Map<TableName,java.util.List<java.lang.String>> |
ReplicationPeersZKImpl.getTableCFs(java.lang.String id) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationSource.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
void |
ReplicationSourceInterface.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs)
Add hfile names to the queue to be replicated.
|
void |
ReplicationSourceManager.addHFileRefs(TableName tableName,
byte[] family,
java.util.List<Pair<Path,Path>> pairs) |
protected void |
ReplicationSink.batch(TableName tableName,
java.util.Collection<java.util.List<Row>> allRows)
Do the changes and handle the pool
|
| Modifier and Type | Field and Description |
|---|---|
static TableName |
PerformanceEvaluation.TABLE_NAME |
| Modifier and Type | Method and Description |
|---|---|
TableName |
PerformanceEvaluation.PeInputSplit.getTableName() |
| Constructor and Description |
|---|
PeInputSplit(TableName tableName,
int startRow,
int rows,
int totalRows,
int clients,
boolean flushCommits,
boolean writeToWAL,
boolean useTags,
int noOfTags) |
| Modifier and Type | Method and Description |
|---|---|
TableName |
RemoteHTable.getName() |
| Modifier and Type | Field and Description |
|---|---|
static TableName |
RSGroupInfoManager.RSGROUP_TABLE_NAME |
| Modifier and Type | Method and Description |
|---|---|
java.util.Map<TableName,java.util.List<java.lang.String>> |
TestRSGroupsBase.getTableRegionMap() |
java.util.NavigableSet<TableName> |
RSGroupInfo.getTables()
Set of tables that are members of this group
|
java.util.Map<TableName,java.util.Map<ServerName,java.util.List<java.lang.String>>> |
TestRSGroupsBase.getTableServerRegionMap() |
| Modifier and Type | Method and Description |
|---|---|
void |
RSGroupInfo.addAllTables(java.util.Collection<TableName> arg) |
abstract void |
RSGroupAdmin.moveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup)
Move tables to a new group.
|
void |
RSGroupAdminServer.moveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
RSGroupInfoManager.moveTables(java.util.Set<TableName> tableNames,
java.lang.String groupName)
Set the group membership of a set of tables
|
void |
RSGroupInfoManagerImpl.moveTables(java.util.Set<TableName> tableNames,
java.lang.String groupName) |
void |
VerifyingRSGroupAdminClient.moveTables(java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
RSGroupAdminEndpoint.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
RSGroupAdminEndpoint.postMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
void |
RSGroupAdminEndpoint.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors) |
void |
RSGroupAdminEndpoint.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
RSGroupAdminEndpoint.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
| Modifier and Type | Field and Description |
|---|---|
static TableName |
AccessControlClient.ACL_TABLE_NAME |
static TableName |
AccessControlLists.ACL_TABLE_NAME
Internal storage table for access control lists
|
| Modifier and Type | Method and Description |
|---|---|
TableName |
TablePermission.getTableName() |
TableName |
AuthResult.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
static AuthResult |
AuthResult.allow(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
byte[] family,
byte[] qualifier) |
static AuthResult |
AuthResult.allow(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
java.util.Map<byte[],? extends java.util.Collection<?>> families) |
boolean |
TableAuthManager.authorize(User user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action) |
boolean |
TableAuthManager.authorize(User user,
TableName table,
byte[] family,
Permission.Action action) |
boolean |
TableAuthManager.authorize(User user,
TableName table,
Cell cell,
Permission.Action action)
Authorize a user for a given KV.
|
boolean |
TableAuthManager.authorizeGroup(java.lang.String groupName,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action)
Checks authorization to a given table, column family and column for a group, based
on the stored permissions.
|
boolean |
TableAuthManager.authorizeUser(User user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action) |
boolean |
TableAuthManager.authorizeUser(User user,
TableName table,
byte[] family,
Permission.Action action)
Checks authorization to a given table and column family for a user, based on the
stored user permissions.
|
void |
ZKPermissionWatcher.deleteTableACLNode(TableName tableName)
Delete the acl notify node of table
|
static AuthResult |
AuthResult.deny(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
byte[] family,
byte[] qualifier) |
static AuthResult |
AuthResult.deny(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
java.util.Map<byte[],? extends java.util.Collection<?>> families) |
static <any> |
AccessControlLists.getTablePermissions(Configuration conf,
TableName tableName) |
static void |
AccessControlClient.grant(Configuration conf,
TableName tableName,
java.lang.String userName,
byte[] family,
byte[] qual,
Permission.Action... actions)
Deprecated.
|
static void |
AccessControlClient.grant(Connection connection,
TableName tableName,
java.lang.String userName,
byte[] family,
byte[] qual,
Permission.Action... actions)
Grants permission on the specified table for the specified user
|
boolean |
TableAuthManager.groupHasAccess(java.lang.String groupName,
TableName table,
Permission.Action action)
Checks if the user has access to the full table or at least a family/qualifier
for the specified action.
|
boolean |
TableAuthManager.hasAccess(User user,
TableName table,
Permission.Action action) |
boolean |
TablePermission.implies(TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action)
Checks that a given table operation is authorized by this permission
instance.
|
boolean |
TablePermission.implies(TableName table,
KeyValue kv,
Permission.Action action)
Checks if this permission grants access to perform the given action on
the given table and key value.
|
boolean |
TablePermission.matchesFamily(TableName table,
byte[] family,
Permission.Action action)
Returns
true if this permission matches the given column
family at least. |
boolean |
TablePermission.matchesFamilyQualifier(TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action)
Returns if the given permission matches the given qualifier.
|
boolean |
TableAuthManager.matchPermission(User user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action) |
boolean |
TableAuthManager.matchPermission(User user,
TableName table,
byte[] family,
Permission.Action action)
Returns true if the given user has a
TablePermission matching up
to the column family portion of a permission. |
void |
AccessController.postDeleteColumn(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
byte[] col) |
void |
AccessController.postDeleteTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName) |
void |
AccessController.postModifyTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
HTableDescriptor htd) |
void |
AccessController.postTruncateTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
AccessController.preAddColumn(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
HColumnDescriptor column) |
void |
AccessController.preDeleteColumn(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
byte[] col) |
void |
AccessController.preDeleteTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName) |
void |
AccessController.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName) |
void |
AccessController.preEnableTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName) |
void |
AccessController.preModifyColumn(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
HColumnDescriptor descriptor) |
void |
AccessController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName,
HTableDescriptor htd) |
void |
CoprocessorWhitelistMasterObserver.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HTableDescriptor htd) |
void |
AccessController.preSetTableQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
QuotaProtos.Quotas quotas) |
void |
AccessController.preSetUserQuota(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.lang.String userName,
TableName tableName,
QuotaProtos.Quotas quotas) |
void |
AccessController.preTableFlush(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
AccessController.preTruncateTable(ObserverContext<MasterCoprocessorEnvironment> c,
TableName tableName) |
void |
TableAuthManager.refreshTableCacheFromWritable(TableName table,
byte[] data) |
void |
TableAuthManager.removeTable(TableName table) |
void |
AccessController.requireNamespacePermission(java.lang.String request,
java.lang.String namespace,
TableName tableName,
java.util.Map<byte[],? extends java.util.Collection<byte[]>> familyMap,
Permission.Action... permissions)
Checks that the user has the given global or namespace permission.
|
static void |
AccessControlClient.revoke(Configuration conf,
TableName tableName,
java.lang.String username,
byte[] family,
byte[] qualifier,
Permission.Action... actions)
Deprecated.
|
static void |
AccessControlClient.revoke(Connection connection,
TableName tableName,
java.lang.String username,
byte[] family,
byte[] qualifier,
Permission.Action... actions)
Revokes the permission on the table
|
void |
TableAuthManager.setTableGroupPermissions(java.lang.String group,
TableName table,
java.util.List<TablePermission> perms)
Overwrites the existing permission set for a group and triggers an update
for zookeeper synchronization.
|
void |
TablePermission.setTableName(TableName table) |
AuthResult.Params |
AuthResult.Params.setTableName(TableName table) |
void |
TableAuthManager.setTableUserPermissions(java.lang.String username,
TableName table,
java.util.List<TablePermission> perms)
Overwrites the existing permission set for a given user for a table, and
triggers an update for zookeeper synchronization.
|
boolean |
TableAuthManager.userHasAccess(User user,
TableName table,
Permission.Action action)
Checks if the user has access to the full table or at least a family/qualifier
for the specified action.
|
void |
TableAuthManager.writeTableToZooKeeper(TableName table,
org.apache.hadoop.hbase.security.access.TableAuthManager.PermissionCache<TablePermission> tablePerms) |
| Modifier and Type | Method and Description |
|---|---|
void |
AccessController.postGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
AccessController.preGetTableDescriptors(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.List<TableName> tableNamesList,
java.util.List<HTableDescriptor> descriptors,
java.lang.String regex) |
void |
AccessController.preMoveTables(ObserverContext<MasterCoprocessorEnvironment> ctx,
java.util.Set<TableName> tables,
java.lang.String targetGroup) |
| Constructor and Description |
|---|
AuthResult(boolean allowed,
java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
byte[] family,
byte[] qualifier) |
AuthResult(boolean allowed,
java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
java.util.Map<byte[],? extends java.util.Collection<?>> families) |
TablePermission(java.lang.String namespace,
TableName table,
byte[] family,
byte[] qualifier,
byte[] actionCodes)
Creates a new permission for the given namespace or table, family and column qualifier,
allowing the actions matching the provided byte codes to be performed.
|
TablePermission(java.lang.String namespace,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action... assigned)
Creates a new permission for the given namespace or table, restricted to the given
column family and qualifier, allowing the assigned actions to be performed.
|
TablePermission(TableName table,
byte[] family,
byte[] qualifier,
byte[] actionCodes)
Creates a new permission for the given table, family and column qualifier,
allowing the actions matching the provided byte codes to be performed.
|
TablePermission(TableName table,
byte[] family,
byte[] qualifier,
Permission.Action... assigned)
Creates a new permission for the given table, restricted to the given
column family and qualifier, allowing the assigned actions to be performed.
|
TablePermission(TableName table,
byte[] family,
Permission.Action... assigned)
Create a new permission for the given table and (optionally) column family,
allowing the given actions.
|
UserPermission(byte[] user,
TableName table,
byte[] family,
byte[] qualifier,
byte[] actionCodes)
Creates a new instance for the given user, table, column family and
qualifier, matching the actions with the given codes.
|
UserPermission(byte[] user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action... assigned)
Creates a new permission for the given user, table, column family and
column qualifier.
|
UserPermission(byte[] user,
TableName table,
byte[] family,
Permission.Action... assigned)
Creates a new instance for the given user, table and column family.
|
| Modifier and Type | Field and Description |
|---|---|
static TableName |
VisibilityConstants.LABELS_TABLE_NAME
Internal storage table for visibility labels
|
| Modifier and Type | Method and Description |
|---|---|
void |
VisibilityController.preAddColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HColumnDescriptor column) |
void |
VisibilityController.preDeleteColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
byte[] c) |
void |
VisibilityController.preDisableTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName) |
void |
VisibilityController.preModifyColumn(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HColumnDescriptor descriptor) |
void |
VisibilityController.preModifyTable(ObserverContext<MasterCoprocessorEnvironment> ctx,
TableName tableName,
HTableDescriptor htd) |
| Modifier and Type | Method and Description |
|---|---|
static HTableDescriptor |
RestoreSnapshotHelper.cloneTableSchema(HTableDescriptor snapshotTableDescriptor,
TableName tableName)
Create a new table descriptor cloning the snapshot table schema.
|
static void |
RestoreSnapshotHelper.restoreSnapshotACL(HBaseProtos.SnapshotDescription snapshot,
TableName newTableName,
Configuration conf) |
| Constructor and Description |
|---|
TablePartiallyOpenException(TableName tableName) |
| Modifier and Type | Method and Description |
|---|---|
TableName |
IntegrationTestBigLinkedList.getTablename() |
TableName |
IntegrationTestLoadAndVerify.getTablename() |
| Constructor and Description |
|---|
TimeBoundedMultiThreadedReader(LoadTestDataGenerator dataGen,
Configuration conf,
TableName tableName,
double verifyPercent) |
| Modifier and Type | Method and Description |
|---|---|
static void |
Canary.sniff(Admin admin,
TableName tableName)
Canary entry point for specified table.
|
| Modifier and Type | Method and Description |
|---|---|
TableName |
HBaseFsck.TableInfo.getName() |
TableName |
HBaseFsck.HbckInfo.getTableName() |
static TableName |
FSUtils.getTableName(Path tablePath)
Returns the
TableName object representing
the table directory under
path rootdir |
static TableName |
HFileArchiveUtil.getTableName(Path archivePath) |
| Modifier and Type | Method and Description |
|---|---|
void |
FSTableDescriptors.deleteTableDescriptorIfExists(TableName tableName)
Deletes all the table descriptor files from the file system.
|
HTableDescriptor |
FSTableDescriptors.get(TableName tablename)
Get the current table descriptor for the given table, or null if none exists.
|
<any> |
HBaseFsck.getOverlapGroups(TableName table) |
static Path |
HFileArchiveUtil.getRegionArchiveDir(Path rootDir,
TableName tableName,
Path regiondir)
Get the archive directory for a given region under the specified table
|
static Path |
HFileArchiveUtil.getRegionArchiveDir(Path rootDir,
TableName tableName,
java.lang.String encodedRegionName)
Get the archive directory for a given region under the specified table
|
static Path |
HFileArchiveUtil.getStoreArchivePath(Configuration conf,
TableName tableName,
java.lang.String regionName,
java.lang.String familyName)
Get the directory to archive a store directory
|
static Path |
HFileArchiveUtil.getTableArchivePath(Configuration conf,
TableName tableName)
Get the path to the table archive directory based on the configured archive directory.
|
static Path |
HFileArchiveUtil.getTableArchivePath(Path rootdir,
TableName tableName)
Get the path to the table archive directory based on the configured archive directory.
|
static HTableDescriptor |
FSTableDescriptors.getTableDescriptorFromFs(FileSystem fs,
Path hbaseRootDir,
TableName tableName)
Returns the latest table descriptor for the given table directly from the file system
if it exists, bypassing the local cache.
|
static HTableDescriptor |
FSTableDescriptors.getTableDescriptorFromFs(FileSystem fs,
Path hbaseRootDir,
TableName tableName,
boolean rewritePb)
Returns the latest table descriptor for the table located at the given directory
directly from the file system if it exists.
|
static Path |
FSUtils.getTableDir(Path rootdir,
TableName tableName)
Returns the
org.apache.hadoop.fs.Path object representing the table directory under
path rootdir |
static java.util.Map<java.lang.String,Path> |
FSUtils.getTableStoreFilePathMap(java.util.Map<java.lang.String,Path> map,
FileSystem fs,
Path hbaseRootDir,
TableName tableName)
Runs through the HBase rootdir/tablename and creates a reverse lookup map for
table StoreFile names to the full Path.
|
static java.util.Map<java.lang.String,Path> |
FSUtils.getTableStoreFilePathMap(java.util.Map<java.lang.String,Path> resultMap,
FileSystem fs,
Path hbaseRootDir,
TableName tableName,
PathFilter sfFilter,
java.util.concurrent.ExecutorService executor,
HBaseFsck.ErrorReporter errors)
Runs through the HBase rootdir/tablename and creates a reverse lookup map for
table StoreFile names to the full Path.
|
void |
HBaseFsck.includeTable(TableName table) |
boolean |
FSTableDescriptors.isTableInfoExists(TableName tableName)
Checks if a current table info file exists for the given table
|
<R> void |
MultiHConnection.processBatchCallback(java.util.List<? extends Row> actions,
TableName tableName,
java.lang.Object[] results,
Batch.Callback<R> callback)
Randomly pick a connection and process the batch of actions for a given table
|
HTableDescriptor |
FSTableDescriptors.remove(TableName tablename)
Removes the table descriptor from the local cache and returns it.
|
| Modifier and Type | Field and Description |
|---|---|
protected TableName |
WALKey.tablename |
| Modifier and Type | Method and Description |
|---|---|
TableName |
WALKey.getTablename() |
TableName |
WALSplitter.RegionEntryBuffer.getTableName() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
WALKey.init(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce) |
| Constructor and Description |
|---|
WALKey(byte[] encodedRegionName,
TableName tablename) |
WALKey(byte[] encodedRegionName,
TableName tablename,
long now) |
WALKey(byte[] encodedRegionName,
TableName tablename,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce)
Create the log key for writing to somewhere.
|
WALKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long now,
java.util.List<java.util.UUID> clusterIds,
long nonceGroup,
long nonce)
Create the log key for writing to somewhere.
|
WALKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long nonceGroup,
long nonce)
Create the log key for writing to somewhere.
|
WALKey(byte[] encodedRegionName,
TableName tablename,
long logSeqNum,
long now,
java.util.UUID clusterId) |
| Modifier and Type | Method and Description |
|---|---|
static java.util.Set<TableName> |
ZKTableStateClientSideReader.getDisabledOrDisablingTables(ZooKeeperWatcher zkw)
Gets a list of all the tables set as disabled in zookeeper.
|
static java.util.Set<TableName> |
ZKTableStateClientSideReader.getDisabledTables(ZooKeeperWatcher zkw)
Gets a list of all the tables set as disabled in zookeeper.
|
static java.util.Set<TableName> |
ZKTableStateClientSideReader.getEnablingTables(ZooKeeperWatcher zkw)
Gets a list of all the tables set as enabling in zookeeper.
|
java.util.Set<TableName> |
ZKTableStateManager.getTablesInStates(ZooKeeperProtos.Table.State... states)
Gets a list of all the tables set as disabling in zookeeper.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ZKTableStateManager.checkAndRemoveTableState(TableName tableName,
ZooKeeperProtos.Table.State states,
boolean deletePermanentState)
If the table is found in the given state the in-memory state is removed.
|
static boolean |
ZKTableStateClientSideReader.isDisabledTable(ZooKeeperWatcher zkw,
TableName tableName)
Go to zookeeper and see if state of table is
ZooKeeperProtos.Table.State#DISABLED. |
static boolean |
ZKTableStateClientSideReader.isDisablingOrDisabledTable(ZooKeeperWatcher zkw,
TableName tableName)
Go to zookeeper and see if state of table is
ZooKeeperProtos.Table.State#DISABLING
of ZooKeeperProtos.Table.State#DISABLED. |
static boolean |
ZKTableStateClientSideReader.isEnabledTable(ZooKeeperWatcher zkw,
TableName tableName)
Go to zookeeper and see if state of table is
ZooKeeperProtos.Table.State#ENABLED. |
boolean |
ZKTableStateManager.isTablePresent(TableName tableName)
check if table is present.
|
boolean |
ZKTableStateManager.isTableState(TableName tableName,
boolean checkSource,
ZooKeeperProtos.Table.State... states)
Checks if table is marked in specified state in ZK.
|
boolean |
ZKTableStateManager.isTableState(TableName tableName,
ZooKeeperProtos.Table.State... states)
Checks if table is marked in specified state in ZK (using cache only).
|
void |
ZKTableStateManager.setDeletedTable(TableName tableName)
Deletes the table in zookeeper.
|
void |
ZKTableStateManager.setTableState(TableName tableName,
ZooKeeperProtos.Table.State state)
Sets table state in ZK.
|
boolean |
ZKTableStateManager.setTableStateIfInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Checks and sets table state in ZK.
|
boolean |
ZKTableStateManager.setTableStateIfNotInStates(TableName tableName,
ZooKeeperProtos.Table.State newState,
ZooKeeperProtos.Table.State... states)
Checks and sets table state in ZK.
|