Modifier and Type | Method and Description |
---|---|
Connection |
Server.createConnection(org.apache.hadoop.conf.Configuration conf) |
Connection |
HBaseServerBase.createConnection(org.apache.hadoop.conf.Configuration conf) |
default Connection |
Server.getConnection()
Returns a reference to the servers' connection.
|
Connection |
HBaseTestingUtility.getConnection()
Deprecated.
Get a shared Connection to the cluster.
|
Connection |
HBaseTestingUtility.getConnection(User user)
Deprecated.
Get a assigned Connection to the cluster.
|
Modifier and Type | Method and Description |
---|---|
static void |
MetaTableAccessor.addRegionsToMeta(Connection connection,
List<RegionInfo> regionInfos,
int regionReplication)
Adds a hbase:meta row for each of the specified new regions.
|
static void |
MetaTableAccessor.addRegionsToMeta(Connection connection,
List<RegionInfo> regionInfos,
int regionReplication,
long ts)
Adds a hbase:meta row for each of the specified new regions.
|
static void |
MetaTableAccessor.addSplitsToParent(Connection connection,
RegionInfo regionInfo,
RegionInfo splitA,
RegionInfo splitB)
Adds daughter region infos to hbase:meta row for the specified region.
|
private static void |
MetaTableAccessor.deleteFromMetaTable(Connection connection,
Delete d)
Delete the passed
d from the hbase:meta table. |
private static void |
MetaTableAccessor.deleteFromMetaTable(Connection connection,
List<Delete> deletes)
Delete the passed
deletes from the hbase:meta table. |
static void |
MetaTableAccessor.deleteTableState(Connection connection,
TableName table)
Remove state for table from meta
|
private static List<Result> |
MetaTableAccessor.fullScan(Connection connection,
ClientMetaTableAccessor.QueryType type)
Performs a full scan of
hbase:meta . |
static void |
MetaTableAccessor.fullScanMetaAndPrint(Connection connection) |
static List<Result> |
MetaTableAccessor.fullScanRegions(Connection connection)
Performs a full scan of
hbase:meta for regions. |
static void |
MetaTableAccessor.fullScanRegions(Connection connection,
ClientMetaTableAccessor.Visitor visitor)
Performs a full scan of
hbase:meta for regions. |
static void |
MetaTableAccessor.fullScanTables(Connection connection,
ClientMetaTableAccessor.Visitor visitor)
Performs a full scan of
hbase:meta for tables. |
static List<RegionInfo> |
MetaTableAccessor.getAllRegions(Connection connection,
boolean excludeOfflinedSplitParents)
Lists all of the regions currently in META.
|
static Result |
MetaTableAccessor.getCatalogFamilyRow(Connection connection,
RegionInfo ri)
Returns Return the
HConstants.CATALOG_FAMILY row from hbase:meta. |
private static RegionInfo |
MetaTableAccessor.getClosestRegionInfo(Connection connection,
TableName tableName,
byte[] row)
Returns Get closest metatable region row to passed
row |
static Table |
MetaTableAccessor.getMetaHTable(Connection connection)
Callers should call close on the returned
Table instance. |
static int |
HBaseTestingUtility.getMetaRSPort(Connection connection)
Deprecated.
|
static Pair<RegionInfo,ServerName> |
MetaTableAccessor.getRegion(Connection connection,
byte[] regionName)
Deprecated.
|
static HRegionLocation |
MetaTableAccessor.getRegionLocation(Connection connection,
byte[] regionName)
Returns the HRegionLocation from meta for the given region
|
static HRegionLocation |
MetaTableAccessor.getRegionLocation(Connection connection,
RegionInfo regionInfo)
Returns the HRegionLocation from meta for the given region
|
static Result |
MetaTableAccessor.getRegionResult(Connection connection,
RegionInfo regionInfo)
Gets the result in hbase:meta for the specified region.
|
static List<RegionInfo> |
MetaTableAccessor.getTableRegions(Connection connection,
TableName tableName)
Gets all of the regions of the specified table.
|
static List<RegionInfo> |
MetaTableAccessor.getTableRegions(Connection connection,
TableName tableName,
boolean excludeOfflinedSplitParents)
Gets all of the regions of the specified table.
|
static List<Pair<RegionInfo,ServerName>> |
MetaTableAccessor.getTableRegionsAndLocations(Connection connection,
TableName tableName)
Do not use this method to get meta table regions, use methods in MetaTableLocator instead.
|
static List<Pair<RegionInfo,ServerName>> |
MetaTableAccessor.getTableRegionsAndLocations(Connection connection,
TableName tableName,
boolean excludeOfflinedSplitParents)
Do not use this method to get meta table regions, use methods in MetaTableLocator instead.
|
static TableState |
MetaTableAccessor.getTableState(Connection conn,
TableName tableName)
Fetch table state for given table from META table
|
static Map<TableName,TableState> |
MetaTableAccessor.getTableStates(Connection conn)
Fetch table states from META table
|
static void |
MetaTableAccessor.putsToMetaTable(Connection connection,
List<Put> ps)
Put the passed
ps to the hbase:meta table. |
private static void |
MetaTableAccessor.putToMetaTable(Connection connection,
Put p)
Put the passed
p to the hbase:meta table. |
static Result |
MetaTableAccessor.scanByRegionEncodedName(Connection connection,
String regionEncodedName)
Scans META table for a row whose key contains the specified regionEncodedName, returning
a single related
Result instance if any row is found, null otherwise. |
static void |
MetaTableAccessor.scanMeta(Connection connection,
byte[] startRow,
byte[] stopRow,
ClientMetaTableAccessor.QueryType type,
ClientMetaTableAccessor.Visitor visitor) |
static void |
MetaTableAccessor.scanMeta(Connection connection,
byte[] startRow,
byte[] stopRow,
ClientMetaTableAccessor.QueryType type,
Filter filter,
int maxRows,
ClientMetaTableAccessor.Visitor visitor) |
static void |
MetaTableAccessor.scanMeta(Connection connection,
byte[] startRow,
byte[] stopRow,
ClientMetaTableAccessor.QueryType type,
int maxRows,
ClientMetaTableAccessor.Visitor visitor)
Performs a scan of META table.
|
static void |
MetaTableAccessor.scanMeta(Connection connection,
ClientMetaTableAccessor.Visitor visitor,
TableName tableName,
byte[] row,
int rowLimit)
Performs a scan of META table for given table starting from given row.
|
private static void |
MetaTableAccessor.scanMeta(Connection connection,
TableName table,
ClientMetaTableAccessor.QueryType type,
int maxRows,
ClientMetaTableAccessor.Visitor visitor) |
static void |
MetaTableAccessor.scanMetaForTableRegions(Connection connection,
ClientMetaTableAccessor.Visitor visitor,
TableName tableName) |
private static void |
MetaTableAccessor.updateLocation(Connection connection,
RegionInfo regionInfo,
ServerName sn,
long openSeqNum,
long masterSystemTime)
Updates the location of the specified region to be the specified server.
|
static void |
MetaTableAccessor.updateRegionLocation(Connection connection,
RegionInfo regionInfo,
ServerName sn,
long openSeqNum,
long masterSystemTime)
Updates the location of the specified region in hbase:meta to be the specified server hostname
and startcode.
|
static void |
MetaTableAccessor.updateRegionState(Connection connection,
RegionInfo ri,
RegionState.State state)
Update state column in hbase:meta.
|
static void |
MetaTableAccessor.updateTableState(Connection conn,
TableName tableName,
TableState.State actual)
Updates state in META Do not use.
|
private static void |
MetaTableAccessor.updateTableState(Connection connection,
TableState state)
Update state of the table in meta.
|
Modifier and Type | Field and Description |
---|---|
private Connection |
BackupHFileCleaner.connection |
Modifier and Type | Method and Description |
---|---|
static TableBackupClient |
BackupClientFactory.create(Connection conn,
String backupId,
BackupRequest request) |
private String |
RestoreDriver.getTablesForSet(Connection conn,
String name) |
Modifier and Type | Field and Description |
---|---|
private Connection |
ZKTableArchiveClient.connection |
Constructor and Description |
---|
HFileArchiveManager(Connection connection,
org.apache.hadoop.conf.Configuration conf) |
ZKTableArchiveClient(org.apache.hadoop.conf.Configuration conf,
Connection connection) |
Modifier and Type | Field and Description |
---|---|
private Connection |
RestoreTablesClient.conn |
private Connection |
BackupAdminImpl.conn |
protected Connection |
TableBackupClient.conn |
(package private) Connection |
BackupCommands.Command.conn |
protected Connection |
BackupManager.conn |
private Connection |
BackupSystemTable.connection
Connection to HBase cluster, shared among all instances
|
Modifier and Type | Method and Description |
---|---|
Connection |
BackupManager.getConnection() |
Modifier and Type | Method and Description |
---|---|
static void |
TableBackupClient.cleanupAndRestoreBackupSystem(Connection conn,
BackupInfo backupInfo,
org.apache.hadoop.conf.Configuration conf) |
protected void |
TableBackupClient.completeBackup(Connection conn,
BackupInfo backupInfo,
BackupManager backupManager,
BackupType type,
org.apache.hadoop.conf.Configuration conf)
Complete the overall backup.
|
static void |
BackupSystemTable.deleteSnapshot(Connection conn) |
protected static void |
TableBackupClient.deleteSnapshots(Connection conn,
BackupInfo backupInfo,
org.apache.hadoop.conf.Configuration conf)
Delete HBase snapshot for backup.
|
protected void |
TableBackupClient.failBackup(Connection conn,
BackupInfo backupInfo,
BackupManager backupManager,
Exception e,
String msg,
BackupType type,
org.apache.hadoop.conf.Configuration conf)
Fail the overall backup.
|
void |
TableBackupClient.init(Connection conn,
String backupId,
BackupRequest request) |
private void |
BackupCommands.RepairCommand.repairFailedBackupDeletionIfAny(Connection conn,
BackupSystemTable sysTable) |
static void |
BackupCommands.RepairCommand.repairFailedBackupMergeIfAny(Connection conn,
BackupSystemTable sysTable) |
static void |
BackupSystemTable.restoreFromSnapshot(Connection conn) |
static void |
BackupSystemTable.snapshot(Connection conn) |
static boolean |
BackupSystemTable.snapshotExists(Connection conn) |
protected boolean |
IncrementalTableBackupClient.tableExists(TableName table,
Connection conn) |
Constructor and Description |
---|
BackupAdminImpl(Connection conn) |
BackupManager(Connection conn,
org.apache.hadoop.conf.Configuration conf)
Backup manager constructor.
|
BackupSystemTable(Connection conn) |
FullTableBackupClient(Connection conn,
String backupId,
BackupRequest request) |
IncrementalBackupManager(Connection conn,
org.apache.hadoop.conf.Configuration conf) |
IncrementalTableBackupClient(Connection conn,
String backupId,
BackupRequest request) |
RestoreTablesClient(Connection conn,
RestoreRequest request) |
TableBackupClient(Connection conn,
String backupId,
BackupRequest request) |
Modifier and Type | Method and Description |
---|---|
protected void |
MapReduceBackupMergeJob.deleteBackupImages(List<String> backupIds,
Connection conn,
org.apache.hadoop.fs.FileSystem fs,
String backupRoot) |
Modifier and Type | Field and Description |
---|---|
private Connection |
BackupLogCleaner.conn |
Modifier and Type | Method and Description |
---|---|
private void |
RestoreTool.checkAndCreateTable(Connection conn,
TableName targetTableName,
ArrayList<org.apache.hadoop.fs.Path> regionDirList,
TableDescriptor htd,
boolean truncateIfExists)
Prepare the table for bulkload, most codes copied from
createTable method in
BulkLoadHFilesTool . |
static void |
BackupUtils.copyTableRegionInfo(Connection conn,
BackupInfo backupInfo,
org.apache.hadoop.conf.Configuration conf)
copy out Table RegionInfo into incremental backup image need to consider move this logic into
HBackupFileSystem
|
private void |
RestoreTool.createAndRestoreTable(Connection conn,
TableName tableName,
TableName newTableName,
org.apache.hadoop.fs.Path tableBackupPath,
boolean truncateIfExists,
String lastIncrBackupId) |
void |
RestoreTool.fullRestoreTable(Connection conn,
org.apache.hadoop.fs.Path tableBackupPath,
TableName tableName,
TableName newTableName,
boolean truncateIfExists,
String lastIncrBackupId) |
void |
RestoreTool.incrementalRestoreTable(Connection conn,
org.apache.hadoop.fs.Path tableBackupPath,
org.apache.hadoop.fs.Path[] logDirs,
TableName[] tableNames,
TableName[] newTableNames,
String incrBackupId)
During incremental backup operation.
|
(package private) void |
RestoreTool.modifyTableSync(Connection conn,
TableDescriptor desc) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
ConnectionOverAsyncConnection
The connection implementation based on
AsyncConnection . |
class |
SharedConnection
Wraps a
Connection to make it can't be closed or aborted. |
Modifier and Type | Field and Description |
---|---|
private Connection |
SharedConnection.conn |
private Connection |
AdminOverAsyncAdmin.conn |
Modifier and Type | Method and Description |
---|---|
static Connection |
ConnectionFactory.createConnection()
Create a new Connection instance using default HBaseConfiguration.
|
static Connection |
ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf)
Create a new Connection instance using the passed
conf instance. |
static Connection |
ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf,
ExecutorService pool)
Create a new Connection instance using the passed
conf instance. |
static Connection |
ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf,
ExecutorService pool,
User user)
Create a new Connection instance using the passed
conf instance. |
static Connection |
ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf,
ExecutorService pool,
User user,
Map<String,byte[]> connectionAttributes)
Create a new Connection instance using the passed
conf instance. |
static Connection |
ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf,
User user)
Create a new Connection instance using the passed
conf instance. |
Connection |
AdminOverAsyncAdmin.getConnection() |
Connection |
Admin.getConnection()
Returns Connection used by this object.
|
Connection |
SharedAsyncConnection.toConnection() |
Connection |
AsyncConnectionImpl.toConnection() |
Connection |
AsyncConnection.toConnection()
Convert this connection to a
Connection . |
Constructor and Description |
---|
AdminOverAsyncAdmin(Connection conn,
RawAsyncHBaseAdmin admin) |
SharedConnection(Connection conn) |
Modifier and Type | Field and Description |
---|---|
private Connection |
MultiThreadedClientExample.WriteExampleCallable.connection |
private Connection |
MultiThreadedClientExample.SingleWriteExampleCallable.connection |
private Connection |
MultiThreadedClientExample.ReadExampleCallable.connection |
private Connection |
RefreshHFilesClient.connection |
Modifier and Type | Method and Description |
---|---|
private void |
MultiThreadedClientExample.warmUpConnectionCache(Connection connection,
TableName tn) |
Constructor and Description |
---|
ReadExampleCallable(Connection connection,
TableName tableName) |
SingleWriteExampleCallable(Connection connection,
TableName tableName) |
WriteExampleCallable(Connection connection,
TableName tableName) |
Modifier and Type | Method and Description |
---|---|
Connection |
RegionServerCoprocessorEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf)
Creates a cluster connection using the passed Configuration.
|
Connection |
MasterCoprocessorEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf)
Creates a cluster connection using the passed Configuration.
|
Connection |
RegionCoprocessorEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf)
Creates a cluster connection using the passed Configuration.
|
Connection |
RegionServerCoprocessorEnvironment.getConnection()
Returns the hosts' Connection to the Cluster.
|
Connection |
MasterCoprocessorEnvironment.getConnection()
Returns the hosts' Connection to the Cluster.
|
Connection |
RegionCoprocessorEnvironment.getConnection()
Returns the hosts' Connection to the Cluster.
|
Modifier and Type | Method and Description |
---|---|
static void |
FavoredNodeAssignmentHelper.updateMetaWithFavoredNodesInfo(Map<RegionInfo,List<ServerName>> regionToFavoredNodes,
Connection connection)
Update meta table with favored nodes info
|
Modifier and Type | Field and Description |
---|---|
private Connection |
Screen.connection |
Modifier and Type | Field and Description |
---|---|
private Connection |
TableOutputFormat.TableRecordWriter.conn |
private Connection |
HRegionPartitioner.connection |
private Connection |
TableInputFormatBase.connection |
Modifier and Type | Method and Description |
---|---|
protected void |
TableInputFormatBase.initializeTable(Connection connection,
TableName tableName)
Allows subclasses to initialize the table information.
|
Modifier and Type | Field and Description |
---|---|
private Connection |
HRegionPartitioner.connection |
private Connection |
TableOutputFormat.TableRecordWriter.connection |
private Connection |
TableInputFormatBase.connection
The underlying
Connection of the table. |
(package private) Connection |
MultiTableOutputFormat.MultiTableRecordWriter.connection |
(package private) Connection |
SyncTable.SyncMapper.sourceConnection |
(package private) Connection |
SyncTable.SyncMapper.targetConnection |
Modifier and Type | Method and Description |
---|---|
private static Connection |
SyncTable.SyncMapper.openConnection(org.apache.hadoop.conf.Configuration conf,
String zkClusterConfKey,
String configPrefix) |
Modifier and Type | Method and Description |
---|---|
protected void |
TableInputFormatBase.initializeTable(Connection connection,
TableName tableName)
Allows subclasses to initialize the table information.
|
private static Table |
SyncTable.SyncMapper.openTable(Connection connection,
org.apache.hadoop.conf.Configuration conf,
String tableNameConfKey) |
Modifier and Type | Field and Description |
---|---|
private Connection |
VerifyReplication.Verifier.replicatedConnection |
private Connection |
VerifyReplication.Verifier.sourceConnection |
Modifier and Type | Field and Description |
---|---|
private Connection |
SnapshotOfRegionAssignmentFromMeta.connection |
Modifier and Type | Method and Description |
---|---|
Connection |
MasterCoprocessorHost.MasterEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf) |
Connection |
MasterCoprocessorHost.MasterEnvironment.getConnection() |
Modifier and Type | Method and Description |
---|---|
static void |
TableNamespaceManager.insertNamespaceToMeta(Connection conn,
NamespaceDescriptor ns) |
Constructor and Description |
---|
SnapshotOfRegionAssignmentFromMeta(Connection connection) |
SnapshotOfRegionAssignmentFromMeta(Connection connection,
Set<TableName> disabledTables,
boolean excludeOfflinedSplitParents) |
Modifier and Type | Method and Description |
---|---|
Connection |
ClusterInfoProvider.getConnection()
Returns a reference to the cluster's connection.
|
Connection |
MasterClusterInfoProvider.getConnection() |
Modifier and Type | Field and Description |
---|---|
private Connection |
ReplicationBarrierCleaner.conn |
Constructor and Description |
---|
ReplicationBarrierCleaner(org.apache.hadoop.conf.Configuration conf,
Stoppable stopper,
Connection conn,
ReplicationPeerManager peerManager) |
Modifier and Type | Field and Description |
---|---|
private Connection |
HBCKServerCrashProcedure.UnknownServerVisitor.connection |
Constructor and Description |
---|
UnknownServerVisitor(Connection connection,
ServerName unknownServerName) |
Modifier and Type | Field and Description |
---|---|
private Connection |
NamedQueueServiceChore.connection |
Modifier and Type | Method and Description |
---|---|
void |
SlowLogPersistentService.addAllLogsToSysTable(Connection connection)
Poll from queueForSysTable and insert 100 records in hbase:slowlog table in single batch
|
static void |
WALEventTrackerTableAccessor.addWalEventTrackerRows(Queue<WALEventTrackerPayload> walEventPayloads,
Connection connection)
Add wal event tracker rows to hbase:waleventtracker table
|
private static void |
WALEventTrackerTableAccessor.doPut(Connection connection,
List<Put> puts) |
void |
NamedQueueService.persistAll(Connection connection)
Add all in memory queue records to system table.
|
void |
WALEventTrackerQueueService.persistAll(Connection connection) |
(package private) void |
LogEventHandler.persistAll(NamedQueuePayload.NamedQueueEvent namedQueueEvent,
Connection connection)
Add all in memory queue records to system table.
|
void |
NamedQueueRecorder.persistAll(NamedQueuePayload.NamedQueueEvent namedQueueEvent,
Connection connection)
Add all in memory queue records to system table.
|
Constructor and Description |
---|
NamedQueueServiceChore(Stoppable stopper,
int period,
NamedQueueRecorder namedQueueRecorder,
Connection connection)
Chore Constructor
|
Modifier and Type | Method and Description |
---|---|
void |
BalancerRejectionQueueService.persistAll(Connection connection) |
void |
SlowLogQueueService.persistAll(Connection connection)
Add all slowLog events to system table.
|
void |
BalancerDecisionQueueService.persistAll(Connection connection) |
Modifier and Type | Field and Description |
---|---|
private Connection |
QuotaObserverChore.conn |
private Connection |
QuotaObserverChore.TablesWithQuotas.conn |
private Connection |
TableSpaceQuotaSnapshotNotifier.conn |
private Connection |
FileArchiverNotifierImpl.conn |
(package private) Connection |
FileArchiverNotifierFactoryImpl.CacheKey.conn |
private Connection |
NamespaceQuotaSnapshotStore.conn |
private Connection |
TableQuotaSnapshotStore.conn |
private Connection |
SnapshotQuotaObserverChore.conn |
private Connection |
SpaceQuotaRefresherChore.conn |
private Connection |
QuotaRetriever.connection
Connection to use.
|
Modifier and Type | Method and Description |
---|---|
(package private) Connection |
RegionServerSpaceQuotaManager.getConnection() |
(package private) Connection |
SpaceQuotaRefresherChore.getConnection() |
Modifier and Type | Method and Description |
---|---|
static void |
QuotaUtil.addNamespaceQuota(Connection connection,
String namespace,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
private static void |
QuotaUtil.addQuotas(Connection connection,
byte[] rowKey,
byte[] qualifier,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
private static void |
QuotaUtil.addQuotas(Connection connection,
byte[] rowKey,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
static void |
QuotaUtil.addRegionServerQuota(Connection connection,
String regionServer,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
static void |
QuotaUtil.addTableQuota(Connection connection,
TableName table,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
static void |
QuotaUtil.addUserQuota(Connection connection,
String user,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
static void |
QuotaUtil.addUserQuota(Connection connection,
String user,
String namespace,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
static void |
QuotaUtil.addUserQuota(Connection connection,
String user,
TableName table,
org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas data) |
(package private) static List<Delete> |
QuotaTableUtil.createDeletesForExistingNamespaceSnapshotSizes(Connection connection)
Returns a list of
Delete to remove all namespace snapshot entries from quota table. |
(package private) static List<Delete> |
QuotaTableUtil.createDeletesForExistingSnapshotsFromScan(Connection connection,
Scan scan)
Returns a list of
Delete to remove all entries returned by the passed scanner. |
(package private) static List<Delete> |
QuotaTableUtil.createDeletesForExistingTableSnapshotSizes(Connection connection)
Returns a list of
Delete to remove all table snapshot entries from quota table. |
static void |
QuotaUtil.deleteNamespaceQuota(Connection connection,
String namespace) |
private static void |
QuotaUtil.deleteQuotas(Connection connection,
byte[] rowKey) |
private static void |
QuotaUtil.deleteQuotas(Connection connection,
byte[] rowKey,
byte[] qualifier) |
static void |
QuotaUtil.deleteRegionServerQuota(Connection connection,
String regionServer) |
static void |
QuotaUtil.deleteTableQuota(Connection connection,
TableName table) |
(package private) static void |
QuotaTableUtil.deleteTableUsageSnapshotsForNamespace(Connection connection,
String namespace)
Remove table usage snapshots (u:p columns) for the namespace passed
|
static void |
QuotaUtil.deleteUserQuota(Connection connection,
String user) |
static void |
QuotaUtil.deleteUserQuota(Connection connection,
String user,
String namespace) |
static void |
QuotaUtil.deleteUserQuota(Connection connection,
String user,
TableName table) |
static void |
QuotaUtil.disableTableIfNotDisabled(Connection conn,
TableName tableName)
Method to disable a table, if not already disabled.
|
private static void |
QuotaUtil.doDelete(Connection connection,
Delete delete) |
protected static Result |
QuotaTableUtil.doGet(Connection connection,
Get get) |
protected static Result[] |
QuotaTableUtil.doGet(Connection connection,
List<Get> gets) |
private static void |
QuotaUtil.doPut(Connection connection,
Put put) |
static void |
QuotaUtil.enableTableIfNotEnabled(Connection conn,
TableName tableName)
Method to enable a table, if not already enabled.
|
static <K> Map<K,QuotaState> |
QuotaUtil.fetchGlobalQuotas(String type,
Connection connection,
List<Get> gets,
QuotaUtil.KeyFromRow<K> kfr) |
static Map<String,QuotaState> |
QuotaUtil.fetchNamespaceQuotas(Connection connection,
List<Get> gets,
double factor) |
static Map<String,QuotaState> |
QuotaUtil.fetchRegionServerQuotas(Connection connection,
List<Get> gets) |
static Map<TableName,QuotaState> |
QuotaUtil.fetchTableQuotas(Connection connection,
List<Get> gets,
Map<TableName,Double> tableMachineFactors) |
static Map<String,UserQuotaState> |
QuotaUtil.fetchUserQuotas(Connection connection,
List<Get> gets,
Map<TableName,Double> tableMachineQuotaFactors,
double factor) |
FileArchiverNotifier |
FileArchiverNotifierFactoryImpl.get(Connection conn,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
TableName tn)
Returns the
FileArchiverNotifier instance for the given TableName . |
FileArchiverNotifier |
FileArchiverNotifierFactory.get(Connection conn,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
TableName tn)
Creates or obtains a
FileArchiverNotifier instance for the given args. |
static SpaceQuotaSnapshot |
QuotaTableUtil.getCurrentSnapshotFromQuotaTable(Connection conn,
TableName tableName)
Returns the current space quota snapshot of the given
tableName from
QuotaTableUtil.QUOTA_TABLE_NAME or null if the no quota information is available for
that tableName. |
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getNamespaceQuota(Connection connection,
String namespace) |
static Set<String> |
QuotaTableUtil.getNamespaceSnapshots(Connection conn)
Returns a set of the names of all namespaces containing snapshot entries.
|
(package private) static long |
QuotaTableUtil.getNamespaceSnapshotSize(Connection conn,
String namespace)
Fetches the computed size of all snapshots against tables in a namespace for space quotas.
|
static Map<String,Long> |
QuotaTableUtil.getObservedSnapshotSizes(Connection conn)
Fetches any persisted HBase snapshot sizes stored in the quota table.
|
private static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getQuotas(Connection connection,
byte[] rowKey) |
private static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getQuotas(Connection connection,
byte[] rowKey,
byte[] qualifier) |
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getRegionServerQuota(Connection connection,
String regionServer) |
static Map<TableName,SpaceQuotaSnapshot> |
QuotaTableUtil.getSnapshots(Connection conn)
Fetches all
SpaceQuotaSnapshot objects from the hbase:quota table. |
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getTableQuota(Connection connection,
TableName table) |
static org.apache.hbase.thirdparty.com.google.common.collect.Multimap<TableName,String> |
QuotaTableUtil.getTableSnapshots(Connection conn)
Returns a multimap for all existing table snapshot entries.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getUserQuota(Connection connection,
String user) |
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getUserQuota(Connection connection,
String user,
String namespace) |
static org.apache.hadoop.hbase.shaded.protobuf.generated.QuotaProtos.Quotas |
QuotaTableUtil.getUserQuota(Connection connection,
String user,
TableName table) |
(package private) void |
QuotaRetriever.init(Connection conn,
Scan scan) |
void |
TableSpaceQuotaSnapshotNotifier.initialize(Connection conn) |
void |
SpaceQuotaSnapshotNotifier.initialize(Connection conn)
Initializes the notifier.
|
protected static boolean |
QuotaUtil.isExceedThrottleQuotaEnabled(Connection connection) |
void |
MasterQuotaManager.processFileArchivals(org.apache.hadoop.hbase.shaded.protobuf.generated.RegionServerStatusProtos.FileArchiveNotificationRequest request,
Connection conn,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs) |
protected static void |
QuotaUtil.switchExceedThrottleQuota(Connection connection,
boolean exceedThrottleQuotaEnabled) |
Constructor and Description |
---|
CacheKey(Connection conn,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
TableName tn) |
FileArchiverNotifierImpl(Connection conn,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
TableName tn) |
NamespaceQuotaSnapshotStore(Connection conn,
QuotaObserverChore chore,
Map<RegionInfo,Long> regionUsage) |
QuotaObserverChore(Connection conn,
org.apache.hadoop.conf.Configuration conf,
SpaceQuotaSnapshotNotifier snapshotNotifier,
MasterQuotaManager quotaManager,
Stoppable stopper,
MetricsMaster metrics) |
SnapshotQuotaObserverChore(Connection conn,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.FileSystem fs,
Stoppable stopper,
MetricsMaster metrics) |
SpaceQuotaRefresherChore(RegionServerSpaceQuotaManager manager,
Connection conn) |
TableQuotaSnapshotStore(Connection conn,
QuotaObserverChore chore,
Map<RegionInfo,Long> regionUsage) |
TablesWithQuotas(Connection conn,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Connection |
RegionCoprocessorHost.RegionEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf) |
Connection |
RegionServerCoprocessorHost.RegionServerEnvironment.createConnection(org.apache.hadoop.conf.Configuration conf) |
Connection |
RegionCoprocessorHost.RegionEnvironment.getConnection() |
Connection |
RegionServerCoprocessorHost.RegionServerEnvironment.getConnection() |
Modifier and Type | Field and Description |
---|---|
private Connection |
TableReplicationQueueStorage.conn |
Modifier and Type | Method and Description |
---|---|
static ReplicationBarrierFamilyFormat.ReplicationBarrierResult |
ReplicationBarrierFamilyFormat.getReplicationBarrierResult(Connection conn,
TableName tableName,
byte[] row,
byte[] encodedRegionName) |
static long[] |
ReplicationBarrierFamilyFormat.getReplicationBarriers(Connection conn,
byte[] regionName) |
static ReplicationQueueStorage |
ReplicationStorageFactory.getReplicationQueueStorage(Connection conn,
org.apache.hadoop.conf.Configuration conf)
Create a new
ReplicationQueueStorage . |
static ReplicationQueueStorage |
ReplicationStorageFactory.getReplicationQueueStorage(Connection conn,
org.apache.hadoop.conf.Configuration conf,
TableName tableName)
Create a new
ReplicationQueueStorage . |
static List<Pair<String,Long>> |
ReplicationBarrierFamilyFormat.getTableEncodedRegionNameAndLastBarrier(Connection conn,
TableName tableName) |
static List<String> |
ReplicationBarrierFamilyFormat.getTableEncodedRegionNamesForSerialReplication(Connection conn,
TableName tableName) |
Constructor and Description |
---|
TableReplicationQueueStorage(Connection conn,
TableName tableName) |
Modifier and Type | Field and Description |
---|---|
private Connection |
ReplicationHFileCleaner.conn |
Modifier and Type | Field and Description |
---|---|
private Connection |
SerialReplicationChecker.conn |
Modifier and Type | Method and Description |
---|---|
Connection |
ReplicationSyncUp.DummyServer.createConnection(org.apache.hadoop.conf.Configuration conf) |
Connection |
ReplicationSyncUp.DummyServer.getConnection() |
Modifier and Type | Method and Description |
---|---|
String |
DumpReplicationQueues.dumpQueues(Connection connection,
Set<String> peerIds,
boolean hdfs,
org.apache.hadoop.conf.Configuration conf) |
String |
DumpReplicationQueues.dumpReplicationViaTable(Connection connection,
org.apache.hadoop.conf.Configuration conf) |
Constructor and Description |
---|
RSGroupAdminClient(Connection conn)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.addUserTableHdfsAcl(Connection connection,
Set<String> users,
TableName tableName) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.addUserTableHdfsAcl(Connection connection,
String user,
TableName tableName) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteNamespaceHdfsAcl(Connection connection,
String namespace) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteUserTableHdfsAcl(Connection connection,
Set<String> users,
TableName tableName) |
static List<UserPermission> |
AccessControlClient.getUserPermissions(Connection connection,
String tableRegex)
List all the userPermissions matching the given pattern.
|
static List<UserPermission> |
AccessControlClient.getUserPermissions(Connection connection,
String tableRegex,
byte[] columnFamily)
List all the userPermissions matching the given table pattern and column family.
|
static List<UserPermission> |
AccessControlClient.getUserPermissions(Connection connection,
String tableRegex,
byte[] columnFamily,
byte[] columnQualifier)
List all the userPermissions matching the given table pattern, column family and column
qualifier.
|
static List<UserPermission> |
AccessControlClient.getUserPermissions(Connection connection,
String tableRegex,
byte[] columnFamily,
byte[] columnQualifier,
String userName)
List all the userPermissions matching the given table pattern, column family and column
qualifier.
|
static List<UserPermission> |
AccessControlClient.getUserPermissions(Connection connection,
String tableRegex,
byte[] columnFamily,
String userName)
List all the userPermissions matching the given table pattern, column family and user name.
|
static List<UserPermission> |
AccessControlClient.getUserPermissions(Connection connection,
String tableRegex,
String userName)
List all the userPermissions matching the given table pattern and user name.
|
private static void |
AccessControlClient.grant(Connection connection,
String userName,
boolean mergeExistingPermissions,
Permission.Action... actions)
Grant global permissions for the specified user.
|
static void |
AccessControlClient.grant(Connection connection,
String userName,
Permission.Action... actions)
Grant global permissions for the specified user.
|
private static void |
AccessControlClient.grant(Connection connection,
String namespace,
String userName,
boolean mergeExistingPermissions,
Permission.Action... actions)
Grants permission on the specified namespace for the specified user.
|
static void |
AccessControlClient.grant(Connection connection,
String namespace,
String userName,
Permission.Action... actions)
Grants permission on the specified namespace for the specified user.
|
private static void |
AccessControlClient.grant(Connection connection,
TableName tableName,
String userName,
byte[] family,
byte[] qual,
boolean mergeExistingPermissions,
Permission.Action... actions)
Grants permission on the specified table for the specified user
|
static void |
AccessControlClient.grant(Connection connection,
TableName tableName,
String userName,
byte[] family,
byte[] qual,
Permission.Action... actions)
Grants permission on the specified table for the specified user.
|
static boolean |
AccessControlClient.hasPermission(Connection connection,
String tableName,
byte[] columnFamily,
byte[] columnQualifier,
String userName,
Permission.Action... actions)
Validates whether specified user has permission to perform actions on the mentioned table,
column family or column qualifier.
|
static boolean |
AccessControlClient.hasPermission(Connection connection,
String tableName,
String columnFamily,
String columnQualifier,
String userName,
Permission.Action... actions)
Validates whether specified user has permission to perform actions on the mentioned table,
column family or column qualifier.
|
static boolean |
AccessControlClient.isAccessControllerRunning(Connection connection) |
static boolean |
AccessControlClient.isAuthorizationEnabled(Connection connection)
Return true if authorization is supported and enabled
|
static boolean |
AccessControlClient.isCellAuthorizationEnabled(Connection connection)
Return true if cell authorization is supported and enabled
|
static void |
AccessControlClient.revoke(Connection connection,
String userName,
Permission.Action... actions)
Revoke global permissions for the specified user.
|
static void |
AccessControlClient.revoke(Connection connection,
String namespace,
String userName,
Permission.Action... actions)
Revokes the permission on the namespace for the specified user.
|
static void |
AccessControlClient.revoke(Connection connection,
TableName tableName,
String username,
byte[] family,
byte[] qualifier,
Permission.Action... actions)
Revokes the permission on the table
|
Constructor and Description |
---|
SnapshotScannerHDFSAclHelper(org.apache.hadoop.conf.Configuration configuration,
Connection connection) |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> |
ShadeClientTokenUtil.obtainToken(Connection conn,
String username,
char[] password) |
Modifier and Type | Method and Description |
---|---|
static void |
TokenUtil.addTokenForJob(Connection conn,
org.apache.hadoop.mapred.JobConf job,
User user)
Checks for an authentication token for the given user, obtaining a new token if necessary, and
adds it to the credentials for the given map reduce job.
|
static void |
TokenUtil.addTokenForJob(Connection conn,
User user,
org.apache.hadoop.mapreduce.Job job)
Checks for an authentication token for the given user, obtaining a new token if necessary, and
adds it to the credentials for the given map reduce job.
|
static boolean |
TokenUtil.addTokenIfMissing(Connection conn,
User user)
Checks if an authentication tokens exists for the connected cluster, obtaining one if needed
and adding it to the user's credentials.
|
private static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier> |
TokenUtil.getAuthToken(Connection conn,
User user)
Get the authentication token of the user for the cluster specified in the configuration
|
static void |
TokenUtil.obtainAndCacheToken(Connection conn,
User user)
|
static void |
ClientTokenUtil.obtainAndCacheToken(Connection conn,
User user)
Obtain an authentication token for the given user and add it to the user's credentials.
|
static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier> |
TokenUtil.obtainToken(Connection conn)
Deprecated.
External users should not use this method. Please post on the HBase dev mailing
list if you need this method. Internal HBase code should use
ClientTokenUtil instead. |
(package private) static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier> |
ClientTokenUtil.obtainToken(Connection conn)
Obtain and return an authentication token for the current user.
|
static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier> |
TokenUtil.obtainToken(Connection conn,
User user)
Deprecated.
External users should not use this method. Please post on the HBase dev mailing
list if you need this method. Internal HBase code should use
ClientTokenUtil instead. |
(package private) static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier> |
ClientTokenUtil.obtainToken(Connection conn,
User user)
Obtain and return an authentication token for the given user.
|
static void |
TokenUtil.obtainTokenForJob(Connection conn,
org.apache.hadoop.mapred.JobConf job,
User user)
Obtain an authentication token on behalf of the given user and add it to the credentials for
the given map reduce job.
|
static void |
TokenUtil.obtainTokenForJob(Connection conn,
User user,
org.apache.hadoop.mapreduce.Job job)
Obtain an authentication token on behalf of the given user and add it to the credentials for
the given map reduce job.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsResponse |
VisibilityClient.addLabel(Connection connection,
String label)
Utility method for adding label to the system.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsResponse |
VisibilityClient.addLabels(Connection connection,
String[] labels)
Utility method for adding labels to the system.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsResponse |
VisibilityClient.clearAuths(Connection connection,
String[] auths,
String user)
Removes given labels from user's globally authorized list of labels.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.GetAuthsResponse |
VisibilityClient.getAuths(Connection connection,
String user)
Get the authorization for a given user
|
static boolean |
VisibilityClient.isCellVisibilityEnabled(Connection connection)
Return true if cell visibility features are supported and enabled
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.ListLabelsResponse |
VisibilityClient.listLabels(Connection connection,
String regex)
Retrieve the list of visibility labels defined in the system.
|
static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsResponse |
VisibilityClient.setAuths(Connection connection,
String[] auths,
String user)
Sets given labels globally authorized for the user.
|
private static org.apache.hadoop.hbase.shaded.protobuf.generated.VisibilityLabelsProtos.VisibilityLabelsResponse |
VisibilityClient.setOrClearAuths(Connection connection,
String[] auths,
String user,
boolean setOrClear) |
Modifier and Type | Method and Description |
---|---|
static void |
SlowLogTableAccessor.addSlowLogRecords(List<org.apache.hadoop.hbase.shaded.protobuf.generated.TooSlowLog.SlowLogPayload> slowLogPayloads,
Connection connection)
Add slow/large log records to hbase:slowlog table
|
private static void |
SlowLogTableAccessor.doPut(Connection connection,
List<Put> puts) |
Modifier and Type | Method and Description |
---|---|
void |
RestoreSnapshotHelper.RestoreMetaChanges.updateMetaParentRegions(Connection connection,
List<RegionInfo> regionInfos) |
Modifier and Type | Class and Description |
---|---|
class |
ThriftConnection |
Modifier and Type | Method and Description |
---|---|
Connection |
ThriftAdmin.getConnection() |
Modifier and Type | Field and Description |
---|---|
private Connection |
CanaryTool.ZookeeperTask.connection |
private Connection |
CanaryTool.RegionTask.connection |
private Connection |
CanaryTool.RegionServerTask.connection |
protected Connection |
CanaryTool.Monitor.connection |
Modifier and Type | Method and Description |
---|---|
private CanaryTool.Monitor |
CanaryTool.newMonitor(Connection connection,
String[] monitorTargets)
A Factory method for
CanaryTool.Monitor . |
Constructor and Description |
---|
Monitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
CanaryTool.Sink sink,
ExecutorService executor,
boolean treatFailureAsError,
long allowedFailures) |
RegionMonitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
CanaryTool.Sink sink,
ExecutorService executor,
boolean writeSniffing,
TableName writeTableName,
boolean treatFailureAsError,
HashMap<String,Long> configuredReadTableTimeouts,
long configuredWriteTableTimeout,
long allowedFailures) |
RegionServerMonitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
CanaryTool.Sink sink,
ExecutorService executor,
boolean allRegions,
boolean treatFailureAsError,
long allowedFailures) |
RegionServerTask(Connection connection,
String serverName,
RegionInfo region,
CanaryTool.RegionServerStdOutSink sink,
Boolean rawScanEnabled,
AtomicLong successes) |
RegionTask(Connection connection,
RegionInfo region,
ServerName serverName,
CanaryTool.RegionStdOutSink sink,
CanaryTool.RegionTask.TaskType taskType,
boolean rawScanEnabled,
LongAdder rwLatency,
boolean readAllCF) |
ZookeeperMonitor(Connection connection,
String[] monitorTargets,
boolean useRegExp,
CanaryTool.Sink sink,
ExecutorService executor,
boolean treatFailureAsError,
long allowedFailures) |
ZookeeperTask(Connection connection,
String host,
String znode,
int timeout,
CanaryTool.ZookeeperStdOutSink sink) |
Modifier and Type | Field and Description |
---|---|
private Connection |
MoveWithAck.conn |
private Connection |
RegionMover.conn |
(package private) Connection |
ConnectionCache.ConnectionInfo.connection |
private Connection |
HBaseFsck.connection
Deprecated.
|
private Connection |
HBaseFsck.WorkItemRegion.connection |
Modifier and Type | Method and Description |
---|---|
static void |
HBaseFsckRepair.closeRegionSilentlyAndWait(Connection connection,
ServerName server,
RegionInfo region)
Contacts a region server and waits up to hbase.hbck.close.timeout ms (default 120s) to close
the region.
|
static void |
HBaseFsckRepair.fixMultiAssignment(Connection connection,
RegionInfo region,
List<ServerName> servers)
Fix multiple assignment by doing silent closes on each RS hosting the region and then force ZK
unassigned node to OFFLINE to trigger assignment by master.
|
private static int |
RegionSplitter.getRegionServerCount(Connection connection)
Alternative getCurrentNrHRS which is no longer available.
|
(package private) static ServerName |
MoveWithAck.getServerNameForRegion(RegionInfo region,
Admin admin,
Connection conn)
Get servername that is up in hbase:meta hosting the given region.
|
(package private) static LinkedList<Pair<byte[],byte[]>> |
RegionSplitter.getSplits(Connection connection,
TableName tableName,
RegionSplitter.SplitAlgorithm splitAlgo) |
(package private) static LinkedList<Pair<byte[],byte[]>> |
RegionSplitter.splitScan(LinkedList<Pair<byte[],byte[]>> regionList,
Connection connection,
TableName tableName,
RegionSplitter.SplitAlgorithm splitAlgo) |
Constructor and Description |
---|
ConnectionInfo(Connection conn,
String user) |
MoveWithAck(Connection conn,
RegionInfo regionInfo,
ServerName sourceServer,
ServerName targetServer,
List<RegionInfo> movedRegions) |
WorkItemRegion(HBaseFsck hbck,
ServerName info,
HbckErrorReporter errors,
Connection connection) |
Modifier and Type | Field and Description |
---|---|
protected Connection |
MajorCompactionRequest.connection |
protected Connection |
MajorCompactor.connection |
Modifier and Type | Method and Description |
---|---|
(package private) Optional<MajorCompactionRequest> |
MajorCompactionRequest.createRequest(Connection connection,
Set<String> stores,
long timestamp) |
private Optional<MajorCompactionRequest> |
MajorCompactionTTLRequest.createRequest(Connection connection,
TableDescriptor htd) |
(package private) static Optional<MajorCompactionRequest> |
MajorCompactionRequest.newRequest(Connection connection,
RegionInfo info,
Set<String> stores,
long timestamp) |
(package private) static Optional<MajorCompactionRequest> |
MajorCompactionTTLRequest.newRequest(Connection connection,
RegionInfo info,
TableDescriptor htd) |
Constructor and Description |
---|
MajorCompactionRequest(Connection connection,
RegionInfo region) |
MajorCompactionRequest(Connection connection,
RegionInfo region,
Set<String> stores) |
MajorCompactionTTLRequest(Connection connection,
RegionInfo region) |
Constructor and Description |
---|
ReplicationChecker(org.apache.hadoop.conf.Configuration conf,
ZKWatcher zkw,
Connection conn,
HbckErrorReporter errorReporter) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.