Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.replication | |
org.apache.hadoop.hbase.mapred |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.quotas | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.rsgroup | |
org.apache.hadoop.hbase.snapshot |
Modifier and Type | Field and Description |
---|---|
static TableName |
HConstants.ENSEMBLE_TABLE_NAME
The name of the ensemble table
|
static TableName |
TableName.META_TABLE_NAME
The hbase:meta table's name.
|
static TableName |
TableName.NAMESPACE_TABLE_NAME
Deprecated.
since 3.0.0 and will be removed in 4.0.0. We have folded the data in namespace
table into meta table, so do not use it any more.
|
static TableName |
TableName.OLD_META_TABLE_NAME
TableName for old .META.
|
static TableName |
TableName.OLD_ROOT_TABLE_NAME
TableName for old -ROOT- table.
|
Modifier and Type | Method and Description |
---|---|
static TableName |
TableName.valueOf(byte[] fullName)
Construct a TableName
|
static TableName |
TableName.valueOf(byte[] namespace,
byte[] qualifier) |
static TableName |
TableName.valueOf(byte[] fullName,
int offset,
int length)
Construct a TableName
|
static TableName |
TableName.valueOf(ByteBuffer fullname)
Construct a TableName
|
static TableName |
TableName.valueOf(ByteBuffer namespace,
ByteBuffer qualifier) |
static TableName |
TableName.valueOf(String name)
Construct a TableName
|
static TableName |
TableName.valueOf(String namespaceAsString,
String qualifierAsString) |
Modifier and Type | Method and Description |
---|---|
Map<TableName,org.apache.hadoop.hbase.client.RegionStatesCount> |
ClusterMetrics.getTableRegionStatesCount()
Provide region states count for given table.
|
Modifier and Type | Method and Description |
---|---|
void |
HBaseTestingUtility.compact(TableName tableName,
boolean major)
Deprecated.
Compact all of a table's reagion in the mini hbase cluster
|
void |
MiniHBaseCluster.compact(TableName tableName,
boolean major)
Deprecated.
Call flushCache on all regions of the specified table.
|
int |
TableName.compareTo(TableName tableName) |
int |
HBaseTestingUtility.countRows(TableName tableName)
Deprecated.
Return the number of rows in the given table.
|
org.apache.hadoop.hbase.regionserver.HRegion |
HBaseTestingUtility.createLocalHRegion(TableName tableName,
byte[] startKey,
byte[] stopKey,
org.apache.hadoop.conf.Configuration conf,
boolean isReadOnly,
Durability durability,
org.apache.hadoop.hbase.wal.WAL wal,
byte[]... families)
Deprecated.
Return a region on which you must call
HBaseTestingUtility.closeRegionAndWAL(HRegion)
when done. |
org.apache.hadoop.hbase.regionserver.HRegion |
HBaseTestingUtility.createLocalHRegionWithInMemoryFlags(TableName tableName,
byte[] startKey,
byte[] stopKey,
org.apache.hadoop.conf.Configuration conf,
boolean isReadOnly,
Durability durability,
org.apache.hadoop.hbase.wal.WAL wal,
boolean[] compactedMemStore,
byte[]... families)
Deprecated.
|
TableDescriptorBuilder |
HBaseTestingUtility.createModifyableTableDescriptor(TableName name,
int minVersions,
int versions,
int ttl,
KeepDeletedCells keepDeleted)
Deprecated.
|
Table |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[] family)
Deprecated.
Create a table with multiple regions.
|
Table |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[][] families)
Deprecated.
Create a table with multiple regions.
|
Table |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[][] families,
int numVersions)
Deprecated.
Create a table with multiple regions.
|
Table |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
byte[] family,
int numRegions)
Deprecated.
Create a table with multiple regions.
|
Table |
HBaseTestingUtility.createMultiRegionTable(TableName tableName,
int replicaCount,
byte[][] families)
Deprecated.
Create a table with multiple regions.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
byte[][] columnFamilies,
Compression.Algorithm compression,
DataBlockEncoding dataBlockEncoding,
int numRegionsPerServer,
int regionReplication,
Durability durability)
Deprecated.
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
byte[] columnFamily,
Compression.Algorithm compression,
DataBlockEncoding dataBlockEncoding)
Deprecated.
Creates a pre-split table for load testing.
|
static int |
HBaseTestingUtility.createPreSplitLoadTestTable(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
byte[] columnFamily,
Compression.Algorithm compression,
DataBlockEncoding dataBlockEncoding,
int numRegionsPerServer,
int regionReplication,
Durability durability)
Deprecated.
Creates a pre-split table for load testing.
|
Table |
HBaseTestingUtility.createRandomTable(TableName tableName,
Collection<String> families,
int maxVersions,
int numColsPerRow,
int numFlushes,
int numRegions,
int numRowsPerFlush)
Deprecated.
Creates a random table with the given parameters
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[] family)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
byte[][] splitKeys)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
byte[][] splitKeys,
int replicaCount)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
byte[][] splitKeys,
int replicaCount,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int[] numVersions)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions,
byte[][] splitKeys)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions,
byte[] startKey,
byte[] endKey,
int numRegions)
Deprecated.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions,
int blockSize)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[][] families,
int numVersions,
int blockSize,
String cpName)
Deprecated.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[] family,
byte[][] splitRows)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
byte[] family,
int numVersions)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
String family)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableName tableName,
String[] families)
Deprecated.
Create a table.
|
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName name)
Deprecated.
Create a table of name
name . |
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName tableName,
byte[] family)
Deprecated.
|
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName tableName,
byte[][] families,
int maxVersions)
Deprecated.
|
TableDescriptor |
HBaseTestingUtility.createTableDescriptor(TableName name,
int minVersions,
int versions,
int ttl,
KeepDeletedCells keepDeleted)
Deprecated.
|
void |
HBaseTestingUtility.deleteTable(TableName tableName)
Deprecated.
Drop an existing table
|
Table |
HBaseTestingUtility.deleteTableData(TableName tableName)
Deprecated.
Provide an existing table name to truncate.
|
void |
HBaseTestingUtility.deleteTableIfAny(TableName tableName)
Deprecated.
Drop an existing table
|
String |
HBaseTestingUtility.explainTableAvailability(TableName tableName)
Deprecated.
|
String |
HBaseTestingUtility.explainTableState(TableName table,
org.apache.hadoop.hbase.client.TableState.State state)
Deprecated.
|
org.apache.hadoop.hbase.client.TableState |
HBaseTestingUtility.findLastTableState(TableName table)
Deprecated.
|
List<org.apache.hadoop.hbase.regionserver.HRegion> |
MiniHBaseCluster.findRegionsForTable(TableName tableName)
Deprecated.
|
void |
HBaseTestingUtility.flush(TableName tableName)
Deprecated.
Flushes all caches in the mini hbase cluster
|
void |
MiniHBaseCluster.flushcache(TableName tableName)
Deprecated.
Call flushCache on all regions of the specified table.
|
default long |
ClusterMetrics.getLastMajorCompactionTimestamp(TableName table) |
List<byte[]> |
HBaseTestingUtility.getMetaTableRows(TableName tableName)
Deprecated.
Returns all rows from the hbase:meta table for a given user table
|
int |
HBaseTestingUtility.getNumHFiles(TableName tableName,
byte[] family)
Deprecated.
|
int |
HBaseTestingUtility.getNumHFilesForRS(org.apache.hadoop.hbase.regionserver.HRegionServer rs,
TableName tableName,
byte[] family)
Deprecated.
|
List<org.apache.hadoop.hbase.regionserver.HRegion> |
MiniHBaseCluster.getRegions(TableName tableName)
Deprecated.
|
org.apache.hadoop.hbase.regionserver.HRegionServer |
HBaseTestingUtility.getRSForFirstRegionInTable(TableName tableName)
Deprecated.
Tool to get the reference to the region server object that holds the region of the specified
user table.
|
abstract ServerName |
HBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName)
Deprecated.
Get the ServerName of region server serving the specified region
|
ServerName |
MiniHBaseCluster.getServerHoldingRegion(TableName tn,
byte[] regionName)
Deprecated.
|
org.apache.hadoop.hbase.regionserver.HRegion |
HBaseTestingUtility.getSplittableRegion(TableName tableName,
int maxAttempts)
Deprecated.
Retrieves a splittable region randomly from tableName
|
static boolean |
TableName.isMetaTableName(TableName tn)
Returns True if
tn is the hbase:meta table name. |
<any> |
HBaseTestingUtility.predicateTableAvailable(TableName tableName)
Deprecated.
Returns a
Predicate for checking that table is enabled |
<any> |
HBaseTestingUtility.predicateTableDisabled(TableName tableName)
Deprecated.
Returns a
Predicate for checking that table is enabled |
<any> |
HBaseTestingUtility.predicateTableEnabled(TableName tableName)
Deprecated.
Returns a
Predicate for checking that table is enabled |
static void |
HBaseTestingUtility.setReplicas(Admin admin,
TableName table,
int replicaCount)
Deprecated.
Set the number of Region replicas.
|
Table |
HBaseTestingUtility.truncateTable(TableName tableName)
Deprecated.
Truncate a table using the admin command.
|
Table |
HBaseTestingUtility.truncateTable(TableName tableName,
boolean preserveRegions)
Deprecated.
Truncate a table using the admin command.
|
void |
HBaseTestingUtility.waitTableAvailable(TableName table)
Deprecated.
Wait until all regions in a table have been assigned.
|
void |
HBaseTestingUtility.waitTableAvailable(TableName table,
long timeoutMillis)
Deprecated.
|
void |
HBaseTestingUtility.waitTableDisabled(TableName table,
long millisTimeout)
Deprecated.
|
void |
HBaseTestingUtility.waitTableEnabled(TableName table)
Deprecated.
Waits for a table to be 'enabled'.
|
void |
HBaseTestingUtility.waitTableEnabled(TableName table,
long timeoutMillis)
Deprecated.
|
void |
HBaseTestingUtility.waitUntilAllRegionsAssigned(TableName tableName)
Deprecated.
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)
Deprecated.
Wait until all regions for a table in hbase:meta have a non-empty info:server, or until
timeout.
|
Constructor and Description |
---|
ConcurrentTableModificationException(TableName tableName) |
TableExistsException(TableName tableName) |
TableNotDisabledException(TableName tableName) |
TableNotEnabledException(TableName tableName) |
TableNotFoundException(TableName tableName) |
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 |
AsyncTable.getName()
Gets the fully qualified table name instance of this table.
|
TableName |
AsyncBufferedMutator.getName()
Gets the fully qualified table name instance of the table that this
AsyncBufferedMutator writes to. |
TableName |
AsyncTableRegionLocator.getName()
Gets the fully qualified table name instance of the table whose region we want to locate.
|
TableName |
Table.getName()
Gets the fully qualified table name instance of this table.
|
TableName |
RegionLocator.getName()
Gets the fully qualified table name instance of this table.
|
TableName |
RegionInfo.getTable()
Returns current table name of the region
|
static TableName |
RegionInfo.getTable(byte[] regionName)
Gets the table name from the specified region name.
|
TableName |
SnapshotDescription.getTableName() |
TableName |
TableDescriptor.getTableName()
Get the name of the table
|
TableName |
BufferedMutatorParams.getTableName() |
TableName[] |
Admin.listTableNames()
List all of the names of userspace tables.
|
default TableName[] |
Admin.listTableNames(Pattern pattern)
List all of the names of userspace tables.
|
TableName[] |
Admin.listTableNames(Pattern pattern,
boolean includeSysTables)
List all of the names of userspace tables.
|
TableName[] |
Admin.listTableNamesByNamespace(String name)
Get list of table names by namespace.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Pair<List<String>,List<TableName>>> |
AsyncAdmin.getConfiguredNamespacesAndTablesInRSGroup(String groupName)
Get the namespaces and tables which have this RegionServer group in descriptor.
|
Pair<List<String>,List<TableName>> |
Admin.getConfiguredNamespacesAndTablesInRSGroup(String groupName)
Get the namespaces and tables which have this RegionServer group in descriptor.
|
CompletableFuture<? extends Map<TableName,? extends SpaceQuotaSnapshotView>> |
AsyncAdmin.getRegionServerSpaceQuotaSnapshots(ServerName serverName)
Fetches the observed
SpaceQuotaSnapshotView s observed by a RegionServer. |
Map<TableName,? extends SpaceQuotaSnapshotView> |
Admin.getRegionServerSpaceQuotaSnapshots(ServerName serverName)
Fetches the observed
SpaceQuotaSnapshotView s observed by a RegionServer. |
CompletableFuture<Map<TableName,Long>> |
AsyncAdmin.getSpaceQuotaTableSizes()
Fetches the table sizes on the filesystem as tracked by the HBase Master.
|
Map<TableName,Long> |
Admin.getSpaceQuotaTableSizes()
Fetches the table sizes on the filesystem as tracked by the HBase Master.
|
List<TableName> |
NormalizeTableFilterParams.getTableNames() |
default CompletableFuture<List<TableName>> |
AsyncAdmin.listTableNames()
List all of the names of userspace tables.
|
CompletableFuture<List<TableName>> |
AsyncAdmin.listTableNames(boolean includeSysTables)
List all of the names of tables.
|
CompletableFuture<List<TableName>> |
AsyncAdmin.listTableNames(Pattern pattern,
boolean includeSysTables)
List all of the names of userspace tables.
|
CompletableFuture<List<TableName>> |
AsyncAdmin.listTableNamesByNamespace(String name)
Get list of table names by namespace.
|
CompletableFuture<List<TableName>> |
AsyncAdmin.listTableNamesByState(boolean isEnabled)
List all enabled or disabled table names
|
List<TableName> |
Admin.listTableNamesByState(boolean isEnabled)
List all enabled or disabled table names
|
CompletableFuture<List<TableName>> |
AsyncAdmin.listTablesInRSGroup(String groupName)
Get all tables in this RegionServer group.
|
List<TableName> |
Admin.listTablesInRSGroup(String groupName)
Get all tables in this RegionServer group.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
AsyncAdmin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
default void |
Admin.addColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
Future<Void> |
Admin.addColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Add a column family to an existing table.
|
CompletableFuture<CacheEvictionStats> |
AsyncAdmin.clearBlockCache(TableName tableName)
Clear all the blocks corresponding to this table from BlockCache.
|
CacheEvictionStats |
Admin.clearBlockCache(TableName tableName)
Clear all the blocks corresponding to this table from BlockCache.
|
default CompletableFuture<Void> |
AsyncAdmin.cloneSnapshot(String snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content.
|
default void |
Admin.cloneSnapshot(String snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content.
|
default CompletableFuture<Void> |
AsyncAdmin.cloneSnapshot(String snapshotName,
TableName tableName,
boolean restoreAcl)
Create a new table by cloning the snapshot content.
|
default void |
Admin.cloneSnapshot(String snapshotName,
TableName tableName,
boolean restoreAcl)
Create a new table by cloning the snapshot content.
|
CompletableFuture<Void> |
AsyncAdmin.cloneSnapshot(String snapshotName,
TableName tableName,
boolean restoreAcl,
String customSFT)
Create a new table by cloning the snapshot content.
|
default void |
Admin.cloneSnapshot(String snapshotName,
TableName tableName,
boolean restoreAcl,
String customSFT)
Create a new table by cloning the snapshot content.
|
default Future<Void> |
Admin.cloneSnapshotAsync(String snapshotName,
TableName tableName)
Create a new table by cloning the snapshot content, but does not block and wait for it to be
completely cloned.
|
default Future<Void> |
Admin.cloneSnapshotAsync(String snapshotName,
TableName tableName,
boolean restoreAcl)
Create a new table by cloning the snapshot content.
|
Future<Void> |
Admin.cloneSnapshotAsync(String snapshotName,
TableName tableName,
boolean restoreAcl,
String customSFT)
Create a new table by cloning the snapshot content.
|
CompletableFuture<Void> |
AsyncAdmin.cloneTableSchema(TableName tableName,
TableName newTableName,
boolean preserveSplits)
Create a new table by cloning the existent table schema.
|
void |
Admin.cloneTableSchema(TableName tableName,
TableName newTableName,
boolean preserveSplits)
Create a new table by cloning the existent table schema.
|
default CompletableFuture<Void> |
AsyncAdmin.compact(TableName tableName)
Compact a table.
|
void |
Admin.compact(TableName tableName)
Compact a table.
|
default CompletableFuture<Void> |
AsyncAdmin.compact(TableName tableName,
byte[] columnFamily)
Compact a column family within a table.
|
void |
Admin.compact(TableName tableName,
byte[] columnFamily)
Compact a column family within a table.
|
CompletableFuture<Void> |
AsyncAdmin.compact(TableName tableName,
byte[] columnFamily,
CompactType compactType)
Compact a column family within a table.
|
void |
Admin.compact(TableName tableName,
byte[] columnFamily,
CompactType compactType)
Compact a column family within a table.
|
CompletableFuture<Void> |
AsyncAdmin.compact(TableName tableName,
CompactType compactType)
Compact a table.
|
void |
Admin.compact(TableName tableName,
CompactType compactType)
Compact a table.
|
static TableDescriptor |
TableDescriptorBuilder.copy(TableName name,
TableDescriptor desc) |
static RegionInfo |
RegionInfo.createMobRegionInfo(TableName tableName)
Creates a RegionInfo object for MOB data.
|
static byte[] |
RegionInfo.createRegionName(TableName tableName,
byte[] startKey,
byte[] id,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
RegionInfo.createRegionName(TableName tableName,
byte[] startKey,
byte[] id,
int replicaId,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
RegionInfo.createRegionName(TableName tableName,
byte[] startKey,
long regionid,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
RegionInfo.createRegionName(TableName tableName,
byte[] startKey,
long regionid,
int replicaId,
boolean newFormat)
Make a region name of passed parameters.
|
static byte[] |
RegionInfo.createRegionName(TableName tableName,
byte[] startKey,
String id,
boolean newFormat)
Make a region name of passed parameters.
|
CompletableFuture<Void> |
AsyncAdmin.deleteColumnFamily(TableName tableName,
byte[] columnFamily)
Delete a column family from a table.
|
default void |
Admin.deleteColumnFamily(TableName tableName,
byte[] columnFamily)
Delete a column family from a table.
|
Future<Void> |
Admin.deleteColumnFamilyAsync(TableName tableName,
byte[] columnFamily)
Delete a column family from a table.
|
CompletableFuture<Void> |
AsyncAdmin.deleteTable(TableName tableName)
Deletes a table.
|
default void |
Admin.deleteTable(TableName tableName)
Deletes a table.
|
Future<Void> |
Admin.deleteTableAsync(TableName tableName)
Deletes the table but does not block and wait for it to be completely removed.
|
CompletableFuture<Void> |
AsyncAdmin.disableTable(TableName tableName)
Disable a table.
|
default void |
Admin.disableTable(TableName tableName)
Disable table and wait on completion.
|
Future<Void> |
Admin.disableTableAsync(TableName tableName)
Disable the table but does not block and wait for it to be completely disabled.
|
CompletableFuture<Void> |
AsyncAdmin.disableTableReplication(TableName tableName)
Disable a table's replication switch.
|
void |
Admin.disableTableReplication(TableName tableName)
Disable a table's replication switch.
|
CompletableFuture<Void> |
AsyncAdmin.enableTable(TableName tableName)
Enable a table.
|
default void |
Admin.enableTable(TableName tableName)
Enable a table.
|
Future<Void> |
Admin.enableTableAsync(TableName tableName)
Enable the table but does not block and wait for it to be completely enabled.
|
CompletableFuture<Void> |
AsyncAdmin.enableTableReplication(TableName tableName)
Enable a table's replication switch.
|
void |
Admin.enableTableReplication(TableName tableName)
Enable a table's replication switch.
|
CompletableFuture<Void> |
AsyncAdmin.flush(TableName tableName)
Flush a table.
|
void |
Admin.flush(TableName tableName)
Flush a table.
|
CompletableFuture<Void> |
AsyncAdmin.flush(TableName tableName,
byte[] columnFamily)
Flush the specified column family stores on all regions of the passed table.
|
void |
Admin.flush(TableName tableName,
byte[] columnFamily)
Flush the specified column family stores on all regions of the passed table.
|
CompletableFuture<Void> |
AsyncAdmin.flush(TableName tableName,
List<byte[]> columnFamilies)
Flush the specified column family stores on all regions of the passed table.
|
void |
Admin.flush(TableName tableName,
List<byte[]> columnFamilies)
Flush the specified column family stores on all regions of the passed table.
|
default AsyncBufferedMutator |
AsyncConnection.getBufferedMutator(TableName tableName)
Retrieve an
AsyncBufferedMutator for performing client-side buffering of writes. |
default BufferedMutator |
Connection.getBufferedMutator(TableName tableName)
Retrieve a
BufferedMutator for performing client-side buffering of writes. |
default AsyncBufferedMutator |
AsyncConnection.getBufferedMutator(TableName tableName,
ExecutorService pool)
Retrieve an
AsyncBufferedMutator for performing client-side buffering of writes. |
AsyncBufferedMutatorBuilder |
AsyncConnection.getBufferedMutatorBuilder(TableName tableName)
Returns an
AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator . |
AsyncBufferedMutatorBuilder |
AsyncConnection.getBufferedMutatorBuilder(TableName tableName,
ExecutorService pool)
Returns an
AsyncBufferedMutatorBuilder for creating AsyncBufferedMutator . |
default CompletableFuture<CompactionState> |
AsyncAdmin.getCompactionState(TableName tableName)
Get the current compaction state of a table.
|
CompactionState |
Admin.getCompactionState(TableName tableName)
Get the current compaction state of a table.
|
CompletableFuture<CompactionState> |
AsyncAdmin.getCompactionState(TableName tableName,
CompactType compactType)
Get the current compaction state of a table.
|
CompactionState |
Admin.getCompactionState(TableName tableName,
CompactType compactType)
Get the current compaction state of a table.
|
CompletableFuture<? extends SpaceQuotaSnapshotView> |
AsyncAdmin.getCurrentSpaceQuotaSnapshot(TableName tableName)
Returns the Master's view of a quota on the given
tableName or null if the Master has
no quota information on that table. |
SpaceQuotaSnapshotView |
Admin.getCurrentSpaceQuotaSnapshot(TableName tableName)
Returns the Master's view of a quota on the given
tableName or null if the Master has
no quota information on that table. |
CompletableFuture<TableDescriptor> |
AsyncAdmin.getDescriptor(TableName tableName)
Method for getting the tableDescriptor
|
TableDescriptor |
Admin.getDescriptor(TableName tableName)
Get a table descriptor.
|
CompletableFuture<Optional<Long>> |
AsyncAdmin.getLastMajorCompactionTimestamp(TableName tableName)
Get the timestamp of the last major compaction for the passed table.
|
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.
|
AsyncTableRegionLocator |
AsyncConnection.getRegionLocator(TableName tableName)
Retrieve a AsyncRegionLocator implementation to inspect region information on a table.
|
RegionLocator |
Connection.getRegionLocator(TableName tableName)
Retrieve a RegionLocator implementation to inspect region information on a table.
|
CompletableFuture<List<RegionMetrics>> |
AsyncAdmin.getRegionMetrics(ServerName serverName,
TableName tableName)
Get a list of
RegionMetrics of all regions hosted on a region server for a table. |
List<RegionMetrics> |
Admin.getRegionMetrics(ServerName serverName,
TableName tableName)
Get
RegionMetrics of all regions hosted on a regionserver for a table. |
CompletableFuture<List<RegionInfo>> |
AsyncAdmin.getRegions(TableName tableName)
Get the regions of a given table.
|
List<RegionInfo> |
Admin.getRegions(TableName tableName)
Get the regions of a given table.
|
CompletableFuture<RSGroupInfo> |
AsyncAdmin.getRSGroup(TableName tableName)
Get group info for the given table
|
RSGroupInfo |
Admin.getRSGroup(TableName tableName)
Get group info for the given table
|
default AsyncTable<AdvancedScanResultConsumer> |
AsyncConnection.getTable(TableName tableName)
Retrieve an
AsyncTable implementation for accessing a table. |
default Table |
Connection.getTable(TableName tableName)
Retrieve a Table implementation for accessing a table.
|
default AsyncTable<ScanResultConsumer> |
AsyncConnection.getTable(TableName tableName,
ExecutorService pool)
Retrieve an
AsyncTable implementation for accessing a table. |
default Table |
Connection.getTable(TableName tableName,
ExecutorService pool)
Retrieve a Table implementation for accessing a table.
|
AsyncTableBuilder<AdvancedScanResultConsumer> |
AsyncConnection.getTableBuilder(TableName tableName)
Returns an
AsyncTableBuilder for creating AsyncTable . |
AsyncTableBuilder<ScanResultConsumer> |
AsyncConnection.getTableBuilder(TableName tableName,
ExecutorService pool)
Returns an
AsyncTableBuilder for creating AsyncTable . |
TableBuilder |
Connection.getTableBuilder(TableName tableName,
ExecutorService pool)
Returns an
TableBuilder for creating Table . |
CompletableFuture<Boolean> |
AsyncAdmin.isTableAvailable(TableName tableName)
Check if a table is available.
|
boolean |
Admin.isTableAvailable(TableName tableName)
Check if a table is available.
|
CompletableFuture<Boolean> |
AsyncAdmin.isTableDisabled(TableName tableName)
Check if a table is disabled.
|
boolean |
Admin.isTableDisabled(TableName tableName)
Check if a table is disabled.
|
CompletableFuture<Boolean> |
AsyncAdmin.isTableEnabled(TableName tableName)
Check if a table is enabled.
|
boolean |
Admin.isTableEnabled(TableName tableName)
Check if a table is enabled.
|
default CompletableFuture<Void> |
AsyncAdmin.majorCompact(TableName tableName)
Major compact a table.
|
void |
Admin.majorCompact(TableName tableName)
Major compact a table.
|
default CompletableFuture<Void> |
AsyncAdmin.majorCompact(TableName tableName,
byte[] columnFamily)
Major compact a column family within a table.
|
void |
Admin.majorCompact(TableName tableName,
byte[] columnFamily)
Major compact a column family within a table.
|
CompletableFuture<Void> |
AsyncAdmin.majorCompact(TableName tableName,
byte[] columnFamily,
CompactType compactType)
Major compact a column family within a table.
|
void |
Admin.majorCompact(TableName tableName,
byte[] columnFamily,
CompactType compactType)
Major compact a column family within a table.
|
CompletableFuture<Void> |
AsyncAdmin.majorCompact(TableName tableName,
CompactType compactType)
Major compact a table.
|
void |
Admin.majorCompact(TableName tableName,
CompactType compactType)
Major compact a table.
|
CompletableFuture<Void> |
AsyncAdmin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
default void |
Admin.modifyColumnFamily(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
Future<Void> |
Admin.modifyColumnFamilyAsync(TableName tableName,
ColumnFamilyDescriptor columnFamily)
Modify an existing column family on a table.
|
CompletableFuture<Void> |
AsyncAdmin.modifyColumnFamilyStoreFileTracker(TableName tableName,
byte[] family,
String dstSFT)
Change the store file tracker of the given table's given family.
|
default void |
Admin.modifyColumnFamilyStoreFileTracker(TableName tableName,
byte[] family,
String dstSFT)
Change the store file tracker of the given table's given family.
|
Future<Void> |
Admin.modifyColumnFamilyStoreFileTrackerAsync(TableName tableName,
byte[] family,
String dstSFT)
Change the store file tracker of the given table's given family.
|
CompletableFuture<Void> |
AsyncAdmin.modifyTableStoreFileTracker(TableName tableName,
String dstSFT)
Change the store file tracker of the given table.
|
default void |
Admin.modifyTableStoreFileTracker(TableName tableName,
String dstSFT)
Change the store file tracker of the given table.
|
Future<Void> |
Admin.modifyTableStoreFileTrackerAsync(TableName tableName,
String dstSFT)
Change the store file tracker of the given table.
|
static TableDescriptorBuilder |
TableDescriptorBuilder.newBuilder(TableName name) |
default CompletableFuture<Void> |
AsyncAdmin.snapshot(String snapshotName,
TableName tableName)
Take a snapshot for the given table.
|
default void |
Admin.snapshot(String snapshotName,
TableName tableName)
Take a snapshot for the given table.
|
default void |
Admin.snapshot(String snapshotName,
TableName tableName,
Map<String,Object> snapshotProps)
Create typed snapshot of the table.
|
default CompletableFuture<Void> |
AsyncAdmin.snapshot(String snapshotName,
TableName tableName,
SnapshotType type)
Create typed snapshot of the table.
|
default void |
Admin.snapshot(String snapshotName,
TableName tableName,
SnapshotType type)
Create typed snapshot of the table.
|
default void |
Admin.snapshot(String snapshotName,
TableName tableName,
SnapshotType type,
Map<String,Object> snapshotProps)
Create typed snapshot of the table.
|
CompletableFuture<Void> |
AsyncAdmin.split(TableName tableName)
Split a table.
|
void |
Admin.split(TableName tableName)
Split a table.
|
CompletableFuture<Void> |
AsyncAdmin.split(TableName tableName,
byte[] splitPoint)
Split a table.
|
void |
Admin.split(TableName tableName,
byte[] splitPoint)
Split a table.
|
CompletableFuture<Boolean> |
AsyncAdmin.tableExists(TableName tableName)
Check if a table exists.
|
boolean |
Admin.tableExists(TableName tableName)
Check if a table exists.
|
CompletableFuture<Void> |
AsyncAdmin.truncateTable(TableName tableName,
boolean preserveSplits)
Truncate a table.
|
default void |
Admin.truncateTable(TableName tableName,
boolean preserveSplits)
Truncate a table.
|
Future<Void> |
Admin.truncateTableAsync(TableName tableName,
boolean preserveSplits)
Truncate the table but does not block and wait for it to be completely enabled.
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
AsyncAdmin.appendReplicationPeerTableCFs(String peerId,
Map<TableName,List<String>> tableCfs)
Append the replicable table-cf config of the specified peer
|
default void |
Admin.appendReplicationPeerTableCFs(String id,
Map<TableName,List<String>> tableCfs)
Append the replicable table column family config from the specified peer.
|
CompletableFuture<List<TableDescriptor>> |
AsyncAdmin.listTableDescriptors(List<TableName> tableNames)
List specific tables including system tables.
|
List<TableDescriptor> |
Admin.listTableDescriptors(List<TableName> tableNames)
Get tableDescriptors.
|
CompletableFuture<Void> |
AsyncAdmin.removeReplicationPeerTableCFs(String peerId,
Map<TableName,List<String>> tableCfs)
Remove some table-cfs from config of the specified peer
|
default void |
Admin.removeReplicationPeerTableCFs(String id,
Map<TableName,List<String>> tableCfs)
Remove some table-cfs from config of the specified peer.
|
CompletableFuture<Void> |
AsyncAdmin.setRSGroup(Set<TableName> tables,
String groupName)
Set the RegionServer group for tables
|
void |
Admin.setRSGroup(Set<TableName> tables,
String groupName)
Set the RegionServer group for tables
|
Constructor and Description |
---|
BufferedMutatorParams(TableName tableName) |
SnapshotDescription(String name,
TableName table) |
SnapshotDescription(String name,
TableName table,
SnapshotType type) |
SnapshotDescription(String snapshotName,
TableName tableName,
SnapshotType type,
Map<String,Object> snapshotProps)
SnapshotDescription Parameterized Constructor
|
SnapshotDescription(String name,
TableName table,
SnapshotType type,
String owner) |
SnapshotDescription(String name,
TableName table,
SnapshotType type,
String owner,
long creationTime,
int version)
Deprecated.
since 2.3.0 and will be removed in 4.0.0. Use
SnapshotDescription(String, TableName, SnapshotType, String, long, int, Map) |
SnapshotDescription(String name,
TableName table,
SnapshotType type,
String owner,
long creationTime,
int version,
Map<String,Object> snapshotProps)
SnapshotDescription Parameterized Constructor
|
Modifier and Type | Method and Description |
---|---|
TableName |
TableCFs.getTable() |
Constructor and Description |
---|
TableCFs(TableName table,
Map<String,Integer> cfs) |
Modifier and Type | Method and Description |
---|---|
TableName |
TableSplit.getTable()
Returns table name
|
Modifier and Type | Method and Description |
---|---|
protected void |
TableInputFormatBase.initializeTable(Connection connection,
TableName tableName)
Allows subclasses to initialize the table information.
|
Constructor and Description |
---|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
String location)
Constructor
|
Modifier and Type | Method and Description |
---|---|
TableName |
TableSplit.getTable()
Returns the table name.
|
Modifier and Type | Method and Description |
---|---|
static void |
TableInputFormat.configureSplitTable(org.apache.hadoop.mapreduce.Job job,
TableName tableName)
Sets split table in map-reduce job.
|
protected void |
TableInputFormatBase.initializeTable(Connection connection,
TableName tableName)
Allows subclasses to initialize the table information.
|
static void |
TableMapReduceUtil.initTableMapperJob(TableName table,
Scan scan,
Class<? extends TableMapper> mapper,
Class<?> outputKeyClass,
Class<?> outputValueClass,
org.apache.hadoop.mapreduce.Job job)
Use this before submitting a TableMap job.
|
Constructor and Description |
---|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
String location)
Creates a new instance without a scanner.
|
TableSplit(TableName tableName,
byte[] startRow,
byte[] endRow,
String location,
long length)
Creates a new instance without a scanner.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
String location)
Creates a new instance while assigning all variables.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
String location,
long length)
Creates a new instance while assigning all variables.
|
TableSplit(TableName tableName,
Scan scan,
byte[] startRow,
byte[] endRow,
String location,
String encodedRegionName,
long length)
Creates a new instance while assigning all variables.
|
Modifier and Type | Method and Description |
---|---|
TableName |
QuotaSettings.getTableName() |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.hbase.quotas.ThrottleSettings> |
QuotaSettingsFactory.fromTableThrottles(TableName tableName,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Throttle throttle) |
protected static List<org.apache.hadoop.hbase.quotas.ThrottleSettings> |
QuotaSettingsFactory.fromThrottle(String userName,
TableName tableName,
String namespace,
String regionServer,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Throttle throttle) |
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 QuotaSettings |
QuotaSettingsFactory.removeTableSpaceLimit(TableName tableName)
Creates a
QuotaSettings object to remove the FileSystem space quota for the given
table. |
static QuotaSettings |
QuotaSettingsFactory.throttleTable(TableName tableName,
ThrottleType type,
long limit,
TimeUnit timeUnit)
Throttle the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.throttleTable(TableName tableName,
ThrottleType type,
long limit,
TimeUnit timeUnit,
QuotaScope scope)
Throttle the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.throttleUser(String userName,
TableName tableName,
ThrottleType type,
long limit,
TimeUnit timeUnit)
Throttle the specified user on the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.throttleUser(String userName,
TableName tableName,
ThrottleType type,
long limit,
TimeUnit timeUnit,
QuotaScope scope)
Throttle the specified user on the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.unthrottleTable(TableName tableName)
Remove the throttling for the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.unthrottleTableByThrottleType(TableName tableName,
ThrottleType type)
Remove the throttling for the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.unthrottleUser(String userName,
TableName tableName)
Remove the throttling for the specified user on the specified table.
|
static QuotaSettings |
QuotaSettingsFactory.unthrottleUserByThrottleType(String userName,
TableName tableName,
ThrottleType type)
Remove the throttling for the specified user on the specified table.
|
Constructor and Description |
---|
QuotaSettings(String userName,
TableName tableName,
String namespace,
String regionServer) |
Modifier and Type | Method and Description |
---|---|
Map<TableName,List<String>> |
ReplicationPeerConfig.getExcludeTableCFsMap() |
Map<TableName,List<String>> |
ReplicationPeerConfig.getTableCFsMap() |
Modifier and Type | Method and Description |
---|---|
boolean |
ReplicationPeerConfig.needToReplicate(TableName table)
Decide whether the table need replicate to the peer cluster
|
boolean |
ReplicationPeerConfig.needToReplicate(TableName table,
byte[] family)
Decide whether the passed family of the table need replicate to the peer cluster according to
this peer config.
|
Modifier and Type | Method and Description |
---|---|
ReplicationPeerConfigBuilder |
ReplicationPeerConfigBuilder.setExcludeTableCFsMap(Map<TableName,List<String>> tableCFsMap)
Sets the mapping of table name to column families which should not be replicated.
|
ReplicationPeerConfigBuilder |
ReplicationPeerConfigBuilder.setTableCFsMap(Map<TableName,List<String>> tableCFsMap)
Sets an explicit map of tables and column families in those tables that should be replicated to
the given peer.
|
Modifier and Type | Method and Description |
---|---|
SortedSet<TableName> |
RSGroupInfo.getTables()
Deprecated.
Since 3.0.0, will be removed in 4.0.0. The rsgroup information will be stored in
the configuration of a table so this will be removed.
|
Modifier and Type | Method and Description |
---|---|
void |
RSGroupInfo.addTable(TableName table)
Deprecated.
Since 3.0.0, will be removed in 4.0.0. The rsgroup information will be stored in
the configuration of a table so this will be removed.
|
boolean |
RSGroupInfo.containsTable(TableName table)
Deprecated.
Since 3.0.0, will be removed in 4.0.0. The rsgroup information will be stored in
the configuration of a table so this will be removed.
|
boolean |
RSGroupInfo.removeTable(TableName table)
Deprecated.
Since 3.0.0, will be removed in 4.0.0. The rsgroup information will be stored in
the configuration of a table so this will be removed.
|
Modifier and Type | Method and Description |
---|---|
void |
RSGroupInfo.addAllTables(Collection<TableName> arg)
Deprecated.
Since 3.0.0, will be removed in 4.0.0. The rsgroup information will be stored in
the configuration of a table so this will be removed.
|
Constructor and Description |
---|
TablePartiallyOpenException(TableName tableName) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.