Modifier and Type | Method and Description |
---|---|
Admin |
SharedConnection.getAdmin() |
Modifier and Type | Class and Description |
---|---|
class |
HBaseAdmin
HBaseAdmin is no longer a client API.
|
Modifier and Type | Method and Description |
---|---|
Admin |
ConnectionImplementation.getAdmin() |
Admin |
Connection.getAdmin()
Retrieve an Admin implementation to administer an HBase cluster.
|
Modifier and Type | Field and Description |
---|---|
private Admin |
ReplicationAdmin.admin
Deprecated.
|
Modifier and Type | Field and Description |
---|---|
private Admin |
TableInputFormatBase.admin
The
Admin . |
Modifier and Type | Method and Description |
---|---|
protected Admin |
TableInputFormatBase.getAdmin()
Allows subclasses to get the
Admin . |
Modifier and Type | Method and Description |
---|---|
private static void |
ImportTsv.createTable(Admin admin,
TableName tableName,
String[] columns) |
private void |
RegionSizeCalculator.init(RegionLocator regionLocator,
Admin admin) |
Constructor and Description |
---|
RegionSizeCalculator(RegionLocator regionLocator,
Admin admin)
Computes size of each region for table and given column families.
|
Modifier and Type | Method and Description |
---|---|
void |
NormalizationPlan.execute(Admin admin)
Executes normalization plan on cluster (does actual splitting/merging work).
|
void |
EmptyNormalizationPlan.execute(Admin admin)
No-op for empty plan.
|
void |
MergeNormalizationPlan.execute(Admin admin)
Executes normalization plan on cluster (does actual splitting/merging work).
|
void |
SplitNormalizationPlan.execute(Admin admin)
Executes normalization plan on cluster (does actual splitting/merging work).
|
Modifier and Type | Method and Description |
---|---|
(package private) org.apache.hbase.thirdparty.com.google.common.collect.Multimap<TableName,String> |
SnapshotQuotaObserverChore.getSnapshotsFromTables(Admin admin,
Set<TableName> tablesToFetchSnapshotsFrom)
Computes a mapping of originating
TableName to snapshots, when the TableName
exists in the provided Set . |
Modifier and Type | Field and Description |
---|---|
private Admin |
ReplicationTableBase.CreateReplicationTableWorker.admin |
Modifier and Type | Method and Description |
---|---|
(package private) Admin |
RESTServlet.getAdmin() |
Modifier and Type | Method and Description |
---|---|
private javax.ws.rs.core.Response |
NamespacesInstanceResource.createOrUpdate(NamespacesInstanceModel model,
javax.ws.rs.core.UriInfo uriInfo,
Admin admin,
boolean updateExisting) |
private boolean |
NamespacesInstanceResource.doesNamespaceExist(Admin admin,
String namespaceName) |
private javax.ws.rs.core.Response |
SchemaResource.replace(TableName name,
TableSchemaModel model,
javax.ws.rs.core.UriInfo uriInfo,
Admin admin) |
private javax.ws.rs.core.Response |
SchemaResource.update(TableName name,
TableSchemaModel model,
javax.ws.rs.core.UriInfo uriInfo,
Admin admin) |
Constructor and Description |
---|
NamespacesInstanceModel(Admin admin,
String namespaceName)
Constructor
|
NamespacesModel(Admin admin)
Constructor
|
Modifier and Type | Field and Description |
---|---|
private Admin |
RSGroupAdminClient.admin |
Modifier and Type | Method and Description |
---|---|
private static void |
AccessController.createACLTable(Admin admin)
Create the ACL table
|
Modifier and Type | Method and Description |
---|---|
private Admin |
ThriftServerRunner.HBaseHandler.getAdmin()
Obtain HBaseAdmin.
|
Modifier and Type | Field and Description |
---|---|
protected Admin |
Canary.Monitor.admin |
Modifier and Type | Method and Description |
---|---|
private void |
LoadIncrementalHFiles.cleanup(Admin admin,
Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
ExecutorService pool,
SecureBulkLoadClient secureClient) |
private void |
LoadIncrementalHFiles.createTable(TableName tableName,
String dirPath,
Admin admin)
If the table is created for the first time, then "completebulkload" reads the files twice.
|
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> |
LoadIncrementalHFiles.doBulkLoad(Map<byte[],List<org.apache.hadoop.fs.Path>> map,
Admin admin,
Table table,
RegionLocator regionLocator,
boolean silence,
boolean copyFile)
Perform a bulk load of the given directory into the given pre-existing table.
|
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> |
LoadIncrementalHFiles.doBulkLoad(org.apache.hadoop.fs.Path hfofDir,
Admin admin,
Table table,
RegionLocator regionLocator)
Perform a bulk load of the given directory into the given pre-existing table.
|
Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> |
LoadIncrementalHFiles.doBulkLoad(org.apache.hadoop.fs.Path hfofDir,
Admin admin,
Table table,
RegionLocator regionLocator,
boolean silence,
boolean copyFile)
Perform a bulk load of the given directory into the given pre-existing table.
|
private Map<LoadIncrementalHFiles.LoadQueueItem,ByteBuffer> |
LoadIncrementalHFiles.performBulkLoad(Admin admin,
Table table,
RegionLocator regionLocator,
Deque<LoadIncrementalHFiles.LoadQueueItem> queue,
ExecutorService pool,
SecureBulkLoadClient secureClient,
boolean copyFile) |
private static List<Future<Void>> |
Canary.sniff(Admin admin,
Canary.Sink sink,
String tableName,
ExecutorService executor,
Canary.RegionTask.TaskType taskType,
boolean rawScanEnabled,
LongAdder readLatency)
Canary entry point for specified table.
|
private static List<Future<Void>> |
Canary.sniff(Admin admin,
Canary.Sink sink,
TableDescriptor tableDesc,
ExecutorService executor,
Canary.RegionTask.TaskType taskType,
boolean rawScanEnabled,
LongAdder rwLatency) |
Modifier and Type | Method and Description |
---|---|
protected void |
CoprocessorValidator.validateTables(ClassLoader classLoader,
Admin admin,
Pattern pattern,
List<CoprocessorViolation> violations) |
Modifier and Type | Field and Description |
---|---|
(package private) Admin |
ConnectionCache.ConnectionInfo.admin |
private Admin |
HBaseFsck.admin |
private Admin |
RegionMover.admin |
Modifier and Type | Method and Description |
---|---|
Admin |
ConnectionCache.getAdmin()
Caller doesn't close the admin afterwards.
|
Modifier and Type | Method and Description |
---|---|
static void |
HBaseFsckRepair.fixUnassigned(Admin admin,
RegionInfo region)
Fix unassigned by creating/transition the unassigned ZK node for this
region to OFFLINE state with a special flag to tell the master that this is
a forced operation by HBCK.
|
private static void |
HBaseFsckRepair.forceOfflineInZK(Admin admin,
RegionInfo region)
In 0.90, this forces an HRI offline by setting the RegionTransitionData
in ZK to have HBCK_CODE_NAME as the server.
|
static void |
HBaseFsckRepair.waitUntilAssigned(Admin admin,
RegionInfo region) |
Modifier and Type | Method and Description |
---|---|
(package private) static void |
HelloHBase.createNamespaceAndTable(Admin admin)
Invokes Admin#createNamespace and Admin#createTable to create a namespace
with a table that has one column-family.
|
(package private) static void |
HelloHBase.deleteNamespaceAndTable(Admin admin)
Invokes Admin#disableTable, Admin#deleteTable, and Admin#deleteNamespace to
disable/delete Table and delete Namespace.
|
(package private) static boolean |
HelloHBase.namespaceExists(Admin admin,
String namespaceName)
Checks to see whether a namespace exists.
|
Modifier and Type | Method and Description |
---|---|
(package private) static void |
HelloHBase.createNamespaceAndTable(Admin admin)
Invokes Admin#createNamespace and Admin#createTable to create a namespace
with a table that has one column-family.
|
(package private) static void |
HelloHBase.deleteNamespaceAndTable(Admin admin)
Invokes Admin#disableTable, Admin#deleteTable, and Admin#deleteNamespace to
disable/delete Table and delete Namespace.
|
(package private) static boolean |
HelloHBase.namespaceExists(Admin admin,
String namespaceName)
Checks to see whether a namespace exists.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.