Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.example | |
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.mapreduce.replication | |
org.apache.hadoop.hbase.master.assignment | |
org.apache.hadoop.hbase.quotas | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.rest |
HBase REST
|
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.thrift |
Provides an HBase Thrift
service.
|
org.apache.hadoop.hbase.thrift2 |
Provides an HBase Thrift
service.
|
org.apache.hadoop.hbase.thrift2.client | |
org.apache.hadoop.hbase.tool | |
org.apache.hadoop.hbase.util | |
org.apache.hbase.archetypes.exemplars.client |
This package provides fully-functional exemplar Java code demonstrating
simple usage of the hbase-client API, for incorporation into a Maven
archetype with hbase-client dependency.
|
org.apache.hbase.archetypes.exemplars.shaded_client |
This package provides fully-functional exemplar Java code demonstrating
simple usage of the hbase-client API, for incorporation into a Maven
archetype with hbase-shaded-client dependency.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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(TableDescriptor htd,
byte[][] splitRows)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] families,
byte[][] splitKeys,
BloomType type,
int blockSize,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] families,
byte[][] splitKeys,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
Table |
HBaseTestingUtility.createTable(TableDescriptor htd,
byte[][] families,
org.apache.hadoop.conf.Configuration c)
Deprecated.
Create a table.
|
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.
|
Table |
HBaseTestingUtility.deleteTableData(TableName tableName)
Deprecated.
Provide an existing table name to truncate.
|
static Table |
MetaTableAccessor.getMetaHTable(Connection connection)
Callers should call close on the returned
Table instance. |
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.
|
Modifier and Type | Method and Description |
---|---|
String |
HBaseTestingUtility.checksumRows(Table table)
Deprecated.
Return an md5 digest of the entire contents of a table.
|
static int |
HBaseTestingUtility.countRows(Table table)
Deprecated.
Return the number of rows in the given table.
|
int |
HBaseTestingUtility.countRows(Table table,
byte[]... families)
Deprecated.
|
static int |
HBaseTestingUtility.countRows(Table table,
Scan scan)
Deprecated.
|
void |
HBaseTestingUtility.deleteNumericRows(Table t,
byte[] f,
int startRow,
int endRow)
Deprecated.
|
void |
HBaseTestingUtility.loadNumericRows(Table t,
byte[] f,
int startRow,
int endRow)
Deprecated.
|
void |
HBaseTestingUtility.loadRandomRows(Table t,
byte[] f,
int rowSize,
int totalRows)
Deprecated.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[] f)
Deprecated.
Load table with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[][] f)
Deprecated.
Load table of multiple column families with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[][] f,
byte[] value)
Deprecated.
Load table of multiple column families with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[][] f,
byte[] value,
boolean writeToWAL)
Deprecated.
Load table of multiple column families with rows from 'aaa' to 'zzz'.
|
int |
HBaseTestingUtility.loadTable(Table t,
byte[] f,
boolean writeToWAL)
Deprecated.
Load table with rows from 'aaa' to 'zzz'.
|
private static void |
MetaTableAccessor.put(Table t,
Put p) |
void |
HBaseTestingUtility.verifyNumericRows(Table table,
byte[] f,
int startRow,
int endRow,
int replicaId)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
TableOverAsyncTable
The table implementation based on
AsyncTable . |
Modifier and Type | Method and Description |
---|---|
Table |
TableBuilder.build()
Create the
Table instance. |
default Table |
Connection.getTable(TableName tableName)
Retrieve a Table implementation for accessing a table.
|
default Table |
Connection.getTable(TableName tableName,
ExecutorService pool)
Retrieve a Table implementation for accessing a table.
|
Modifier and Type | Method and Description |
---|---|
void |
RefreshHFilesClient.refreshHFiles(Table table) |
Modifier and Type | Field and Description |
---|---|
private Table |
TableRecordReaderImpl.htable |
private Table |
TableInputFormatBase.table |
Modifier and Type | Method and Description |
---|---|
protected Table |
TableInputFormatBase.getTable()
Allows subclasses to get the
Table . |
Modifier and Type | Method and Description |
---|---|
void |
TableRecordReader.setHTable(Table htable) |
void |
TableRecordReaderImpl.setHTable(Table htable) |
Modifier and Type | Field and Description |
---|---|
private Table |
TableRecordReaderImpl.htable |
(package private) Table |
SyncTable.SyncMapper.sourceTable |
private Table |
TableInputFormatBase.table
The
Table to scan. |
(package private) Table |
SyncTable.SyncMapper.targetTable |
Modifier and Type | Method and Description |
---|---|
protected Table |
TableInputFormatBase.getTable()
Allows subclasses to get the
Table . |
private static Table |
SyncTable.SyncMapper.openTable(Connection connection,
org.apache.hadoop.conf.Configuration conf,
String tableNameConfKey) |
Modifier and Type | Method and Description |
---|---|
static void |
HFileOutputFormat2.configureIncrementalLoad(org.apache.hadoop.mapreduce.Job job,
Table table,
RegionLocator regionLocator)
Configure a MapReduce Job to perform an incremental load into the given table.
|
void |
TableRecordReaderImpl.setHTable(Table htable)
Sets the HBase table.
|
void |
TableRecordReader.setTable(Table table) |
Modifier and Type | Field and Description |
---|---|
private Table |
VerifyReplication.Verifier.replicatedTable |
private Table |
VerifyReplicationRecompareRunnable.replicatedTable |
private Table |
VerifyReplication.Verifier.sourceTable |
private Table |
VerifyReplicationRecompareRunnable.sourceTable |
Constructor and Description |
---|
VerifyReplicationRecompareRunnable(org.apache.hadoop.mapreduce.Mapper.Context context,
Result sourceResult,
Result replicatedResult,
VerifyReplication.Verifier.Counters originalCounter,
String delimiter,
Scan tableScan,
Table sourceTable,
Table replicatedTable,
int reCompareTries,
int sleepMsBeforeReCompare,
int reCompareBackoffExponent,
boolean verbose) |
Modifier and Type | Method and Description |
---|---|
private Table |
RegionStateStore.getMetaTable() |
Modifier and Type | Field and Description |
---|---|
private Table |
QuotaRetriever.table |
Modifier and Type | Method and Description |
---|---|
(package private) long |
FileArchiverNotifierImpl.getPreviousNamespaceSnapshotSize(Table quotaTable,
String namespace)
Fetches the current size of all snapshots in the given
namespace . |
(package private) void |
FileArchiverNotifierImpl.persistSnapshotSizes(Table table,
List<FileArchiverNotifierImpl.SnapshotWithSize> snapshotSizes)
Writes the snapshot sizes to the provided
table . |
Modifier and Type | Method and Description |
---|---|
private Map<String,ReplicationGroupOffset> |
TableReplicationQueueStorage.getOffsets0(Table table,
ReplicationQueueId queueId) |
private void |
TableReplicationQueueStorage.listAllQueueIds(Table table,
Scan scan,
List<ReplicationQueueId> queueIds) |
private void |
TableReplicationQueueStorage.listAllQueueIds(Table table,
String peerId,
ServerName serverName,
List<ReplicationQueueId> queueIds) |
Modifier and Type | Method and Description |
---|---|
(package private) Table |
RESTServlet.getTable(String tableName)
Caller closes the table afterwards.
|
Modifier and Type | Method and Description |
---|---|
private static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.addUserEntry(Table t,
String user,
byte[] entry) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.addUserGlobalHdfsAcl(Table aclTable,
String user) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.addUserNamespaceHdfsAcl(Table aclTable,
String user,
String namespace) |
(package private) static void |
PermissionStorage.addUserPermission(org.apache.hadoop.conf.Configuration conf,
UserPermission userPerm,
Table t) |
static void |
PermissionStorage.addUserPermission(org.apache.hadoop.conf.Configuration conf,
UserPermission userPerm,
Table t,
boolean mergeExistingPermissions)
Stores a new user permission grant in the access control lists table.
|
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.addUserTableHdfsAcl(Table aclTable,
String user,
TableName tableName) |
private static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteEntry(Table aclTable,
byte[] entry) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteTableHdfsAcl(Table aclTable,
TableName tableName) |
private static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteUserEntry(Table aclTable,
String user,
byte[] entry) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteUserGlobalHdfsAcl(Table aclTable,
String user) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteUserNamespaceHdfsAcl(Table aclTable,
String user,
String namespace) |
(package private) static void |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.deleteUserTableHdfsAcl(Table aclTable,
String user,
TableName tableName) |
private Set<String> |
SnapshotScannerHDFSAclController.filterUsersToRemoveNsAccessAcl(Table aclTable,
TableName tableName,
Set<String> tablesUsers)
Remove table user access HDFS acl from namespace directory if the user has no permissions of
global, ns of the table or other tables of the ns, eg: Bob has 'ns1:t1' read permission, when
delete 'ns1:t1', if Bob has global read permission, '@ns1' read permission or
'ns1:other_tables' read permission, then skip remove Bob access acl in ns1Dirs, otherwise,
remove Bob access acl.
|
private static Set<String> |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.getEntryUsers(Table aclTable,
byte[] entry) |
(package private) static org.apache.hbase.thirdparty.com.google.common.collect.ListMultimap<String,UserPermission> |
PermissionStorage.getPermissions(org.apache.hadoop.conf.Configuration conf,
byte[] entryName,
Table t,
byte[] cf,
byte[] cq,
String user,
boolean hasFilterUser)
Reads user permission assignments stored in the
l: column family of the first
table row in _acl_ . |
(package private) static Set<String> |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.getTableUsers(Table aclTable,
TableName tableName) |
(package private) static List<byte[]> |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.getUserEntries(Table aclTable,
String userName) |
(package private) static Pair<Set<String>,Set<TableName>> |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.getUserNamespaceAndTable(Table aclTable,
String userName) |
private static boolean |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.hasUserEntry(Table aclTable,
String userName,
byte[] entry) |
(package private) static boolean |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.hasUserGlobalHdfsAcl(Table aclTable,
String user) |
(package private) static boolean |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.hasUserNamespaceHdfsAcl(Table aclTable,
String user,
String namespace) |
(package private) static boolean |
SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage.hasUserTableHdfsAcl(Table aclTable,
String user,
TableName tableName) |
private boolean |
SnapshotScannerHDFSAclController.isHdfsAclSet(Table aclTable,
String userName) |
private boolean |
SnapshotScannerHDFSAclController.isHdfsAclSet(Table aclTable,
String userName,
String namespace) |
private boolean |
SnapshotScannerHDFSAclController.isHdfsAclSet(Table aclTable,
String userName,
String namespace,
TableName tableName)
Check if user global/namespace/table HDFS acls is already set
|
private boolean |
SnapshotScannerHDFSAclController.isHdfsAclSet(Table aclTable,
String userName,
TableName tableName) |
(package private) static void |
PermissionStorage.removeNamespacePermissions(org.apache.hadoop.conf.Configuration conf,
String namespace,
Table t)
Remove specified namespace from the acl table.
|
private static void |
PermissionStorage.removePermissionRecord(org.apache.hadoop.conf.Configuration conf,
UserPermission userPerm,
Table t) |
(package private) static void |
PermissionStorage.removeTablePermissions(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
byte[] column,
Table t)
Remove specified table column from the acl table.
|
(package private) static void |
PermissionStorage.removeTablePermissions(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
Table t)
Remove specified table from the _acl_ table.
|
private static void |
PermissionStorage.removeTablePermissions(TableName tableName,
byte[] column,
Table table,
boolean closeTable) |
private void |
SnapshotScannerHDFSAclController.removeUserGlobalHdfsAcl(Table aclTable,
String userName,
UserPermission userPermission) |
private void |
SnapshotScannerHDFSAclController.removeUserNamespaceHdfsAcl(Table aclTable,
String userName,
String namespace,
UserPermission userPermission) |
static void |
PermissionStorage.removeUserPermission(org.apache.hadoop.conf.Configuration conf,
UserPermission userPerm,
Table t)
Removes a previously granted permission from the stored access control lists.
|
private void |
SnapshotScannerHDFSAclController.removeUserTableHdfsAcl(Table aclTable,
String userName,
TableName tableName,
UserPermission userPermission) |
Modifier and Type | Method and Description |
---|---|
protected Table |
HBaseServiceHandler.getTable(byte[] tableName)
Creates and returns a Table instance from a given table name.
|
protected Table |
HBaseServiceHandler.getTable(ByteBuffer tableName) |
Modifier and Type | Method and Description |
---|---|
private void |
ThriftHBaseServiceHandler.closeTable(Table table) |
(package private) byte[][] |
ThriftHBaseServiceHandler.getAllColumns(Table table)
Returns a list of all the column families for a given Table.
|
Modifier and Type | Method and Description |
---|---|
protected Table |
ThriftHBaseServiceHandler.getTable(ByteBuffer tableName) |
Modifier and Type | Method and Description |
---|---|
private void |
ThriftHBaseServiceHandler.closeTable(Table table) |
Modifier and Type | Class and Description |
---|---|
class |
ThriftTable |
Modifier and Type | Method and Description |
---|---|
private Void |
CanaryTool.RegionTask.readColumnFamily(Table table,
ColumnFamilyDescriptor column) |
Modifier and Type | Field and Description |
---|---|
private Table |
HBaseFsck.meta
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Table |
ConnectionCache.getTable(String tableName)
Caller closes the table afterwards.
|
Modifier and Type | Method and Description |
---|---|
(package private) static void |
HelloHBase.deleteRow(Table table)
Invokes Table#delete to delete test data (i.e.
|
(package private) static void |
HelloHBase.getAndPrintRowContents(Table table)
Invokes Table#get and prints out the contents of the retrieved row.
|
(package private) static void |
HelloHBase.putRowToTable(Table table)
Invokes Table#put to store a row (with two new columns created 'on the fly') into the table.
|
Modifier and Type | Method and Description |
---|---|
(package private) static void |
HelloHBase.deleteRow(Table table)
Invokes Table#delete to delete test data (i.e.
|
(package private) static void |
HelloHBase.getAndPrintRowContents(Table table)
Invokes Table#get and prints out the contents of the retrieved row.
|
(package private) static void |
HelloHBase.putRowToTable(Table table)
Invokes Table#put to store a row (with two new columns created 'on the fly') into the table.
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.