Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.backup.impl | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.protobuf |
Holds classes generated from protobuf
src/main/protobuf definition files. |
org.apache.hadoop.hbase.quotas | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.rest.client | |
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.security.visibility | |
org.apache.hadoop.hbase.test |
Modifier and Type | Method and Description |
---|---|
Result |
HBaseTestCase.Incommon.get(Get get) |
Result |
HBaseTestCase.HRegionIncommon.get(Get get) |
Result |
HBaseTestCase.HTableIncommon.get(Get get) |
static java.util.List<Cell> |
HBaseTestingUtility.getFromStoreFile(HStore store,
Get get)
Do a small get/scan against one store.
|
Modifier and Type | Method and Description |
---|---|
static Get |
BackupSystemTableHelper.createGetForCheckWALFile(java.lang.String file)
Creates Get operation for a given wal file name
TODO: support for backup destination
|
Modifier and Type | Field and Description |
---|---|
protected Get |
RpcRetryingCallerWithReadReplicas.get |
Modifier and Type | Method and Description |
---|---|
Get |
Get.addColumn(byte[] family,
byte[] qualifier)
Get the column from the specific family with the specified qualifier.
|
Get |
Get.addFamily(byte[] family)
Get all columns from the specified family.
|
Get |
Get.setACL(java.util.Map<java.lang.String,Permission> perms) |
Get |
Get.setACL(java.lang.String user,
Permission perms) |
Get |
Get.setAttribute(java.lang.String name,
byte[] value) |
Get |
Get.setAuthorizations(Authorizations authorizations) |
Get |
Get.setCacheBlocks(boolean cacheBlocks)
Set whether blocks should be cached for this Get.
|
Get |
Get.setCheckExistenceOnly(boolean checkExistenceOnly) |
Get |
Get.setClosestRowBefore(boolean closestRowBefore) |
Get |
Get.setConsistency(Consistency consistency) |
Get |
Get.setFilter(Filter filter) |
Get |
Get.setId(java.lang.String id) |
Get |
Get.setIsolationLevel(IsolationLevel level) |
Get |
Get.setMaxResultsPerColumnFamily(int limit)
Set the maximum number of values to return per row per Column Family
|
Get |
Get.setMaxVersions()
Get all available versions.
|
Get |
Get.setMaxVersions(int maxVersions)
Get up to the specified number of versions of each column.
|
Get |
Get.setReplicaId(int Id) |
Get |
Get.setRowOffsetPerColumnFamily(int offset)
Set offset for the row per Column Family.
|
Get |
Get.setTimeRange(long minStamp,
long maxStamp)
Get versions of columns only within the specified timestamp range,
[minStamp, maxStamp).
|
Get |
Get.setTimeStamp(long timestamp)
Get versions of columns with the specified timestamp.
|
Modifier and Type | Method and Description |
---|---|
boolean |
HTable.exists(Get get)
Test for the existence of columns in the table, as specified by the Get.
|
boolean |
Table.exists(Get get)
Test for the existence of columns in the table, as specified by the Get.
|
boolean |
HTableWrapper.exists(Get get) |
Result |
HTable.get(Get get)
Extracts certain cells from a given row.
|
Result |
Table.get(Get get)
Extracts certain cells from a given row.
|
Result |
HTableWrapper.get(Get get) |
void |
TestClientOperationInterrupt.TestCoprocessor.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
TestHCM.SleepAndFailFirstTime.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
TestHCM.SleepCoprocessor.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
TestReplicasClient.SlowMeCopro.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
TestReplicaWithCluster.SlowMeCopro.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
TestReplicaWithCluster.RegionServerHostingPrimayMetaRegionSlowOrStopCopro.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
TestReplicaWithCluster.RegionServerStoppedCopro.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
Modifier and Type | Method and Description |
---|---|
java.lang.Boolean[] |
HTable.exists(java.util.List<Get> gets)
Deprecated.
|
java.lang.Boolean[] |
HTableInterface.exists(java.util.List<Get> gets)
Deprecated.
Use
Table.existsAll(java.util.List) instead. |
java.lang.Boolean[] |
HTableWrapper.exists(java.util.List<Get> gets)
Deprecated.
|
boolean[] |
HTable.existsAll(java.util.List<Get> gets)
Test for the existence of columns in the table, as specified by the Gets.
|
boolean[] |
Table.existsAll(java.util.List<Get> gets)
Test for the existence of columns in the table, as specified by the Gets.
|
boolean[] |
HTableWrapper.existsAll(java.util.List<Get> gets) |
Result[] |
HTable.get(java.util.List<Get> gets)
Extracts certain cells from the given rows, in batch.
|
Result[] |
Table.get(java.util.List<Get> gets)
Extracts certain cells from the given rows, in batch.
|
Result[] |
HTableWrapper.get(java.util.List<Get> gets) |
Constructor and Description |
---|
Get(Get get)
Copy-constructor
|
RpcRetryingCallerWithReadReplicas(RpcControllerFactory rpcControllerFactory,
TableName tableName,
ClusterConnection cConnection,
Get get,
java.util.concurrent.ExecutorService pool,
int retries,
int callTimeout,
int timeBeforeReplicas) |
Scan(Get get)
Builds a scan object with the same specs as get.
|
Modifier and Type | Method and Description |
---|---|
boolean |
BaseRegionObserver.postExists(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
boolean exists) |
boolean |
RegionObserver.postExists(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
boolean exists)
Called after the client tests for existence using a Get.
|
void |
BaseRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
RegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
java.util.List<Cell> result)
Called after the client performs a Get
|
void |
SimpleRegionObserver.postGetOp(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
java.util.List<Cell> results) |
boolean |
BaseRegionObserver.preExists(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
boolean exists) |
boolean |
RegionObserver.preExists(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
boolean exists)
Called before the client tests for existence using a Get.
|
void |
BaseRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
RegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
java.util.List<Cell> result)
Called before the client performs a Get
|
void |
SimpleRegionObserver.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
java.util.List<Cell> results) |
void |
TestCoprocessorInterface.CoprocessorII.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
BaseRegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> e,
Mutation delete,
Cell cell,
byte[] byteNow,
Get get) |
void |
RegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> c,
Mutation mutation,
Cell cell,
byte[] byteNow,
Get get)
Called before the server updates the timestamp for version delete with latest timestamp.
|
void |
SimpleRegionObserver.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> e,
Mutation delete,
Cell cell,
byte[] byteNow,
Get get) |
Modifier and Type | Method and Description |
---|---|
static Get |
ProtobufUtil.toGet(ClientProtos.Get proto)
Convert a protocol buffer Get to a client Get
|
Modifier and Type | Method and Description |
---|---|
static ClientProtos.GetRequest |
RequestConverter.buildGetRequest(byte[] regionName,
Get get)
Create a protocol buffer GetRequest for a client Get
|
static ClientProtos.Get |
ProtobufUtil.toGet(Get get)
Create a protocol buffer Get based on a client Get.
|
Modifier and Type | Method and Description |
---|---|
static Get |
QuotaTableUtil.makeGetForNamespaceQuotas(java.lang.String namespace) |
static Get |
QuotaTableUtil.makeGetForTableQuotas(TableName table) |
static Get |
QuotaTableUtil.makeGetForUserQuotas(java.lang.String user,
java.lang.Iterable<TableName> tables,
java.lang.Iterable<java.lang.String> namespaces) |
Modifier and Type | Method and Description |
---|---|
protected static Result |
QuotaTableUtil.doGet(Connection connection,
Get get) |
Modifier and Type | Method and Description |
---|---|
protected static Result[] |
QuotaTableUtil.doGet(Connection connection,
java.util.List<Get> gets) |
static <K> java.util.Map<K,QuotaState> |
QuotaUtil.fetchGlobalQuotas(java.lang.String type,
Connection connection,
java.util.List<Get> gets,
org.apache.hadoop.hbase.quotas.QuotaUtil.KeyFromRow<K> kfr) |
static java.util.Map<java.lang.String,QuotaState> |
QuotaUtil.fetchNamespaceQuotas(Connection connection,
java.util.List<Get> gets) |
static java.util.Map<TableName,QuotaState> |
QuotaUtil.fetchTableQuotas(Connection connection,
java.util.List<Get> gets) |
static java.util.Map<java.lang.String,UserQuotaState> |
QuotaUtil.fetchUserQuotas(Connection connection,
java.util.List<Get> gets) |
Modifier and Type | Method and Description |
---|---|
Result |
HRegion.get(Get get) |
Result |
Region.get(Get get)
Do a get based on the get parameter.
|
java.util.List<Cell> |
HRegion.get(Get get,
boolean withCoprocessor) |
java.util.List<Cell> |
Region.get(Get get,
boolean withCoprocessor)
Do a get based on the get parameter.
|
boolean |
RegionCoprocessorHost.postExists(Get get,
boolean exists) |
void |
RegionCoprocessorHost.postGet(Get get,
java.util.List<Cell> results) |
java.lang.Boolean |
RegionCoprocessorHost.preExists(Get get) |
boolean |
RegionCoprocessorHost.preGet(Get get,
java.util.List<Cell> results) |
boolean |
RegionCoprocessorHost.prePrepareTimeStampForDeleteVersion(Mutation mutation,
Cell kv,
byte[] byteNow,
Get get) |
Constructor and Description |
---|
InternalScan(Get get) |
Modifier and Type | Method and Description |
---|---|
boolean |
RemoteHTable.exists(Get get) |
Result |
RemoteHTable.get(Get get) |
Modifier and Type | Method and Description |
---|---|
java.lang.Boolean[] |
RemoteHTable.exists(java.util.List<Get> gets)
Deprecated.
|
boolean[] |
RemoteHTable.existsAll(java.util.List<Get> gets)
exists(List) is really a list of get() calls.
|
Result[] |
RemoteHTable.get(java.util.List<Get> gets) |
Modifier and Type | Method and Description |
---|---|
boolean |
AccessController.preExists(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
boolean exists) |
void |
AccessController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> c,
Get get,
java.util.List<Cell> result) |
Modifier and Type | Method and Description |
---|---|
void |
VisibilityController.preGetOp(ObserverContext<RegionCoprocessorEnvironment> e,
Get get,
java.util.List<Cell> results) |
void |
VisibilityController.prePrepareTimeStampForDeleteVersion(ObserverContext<RegionCoprocessorEnvironment> ctx,
Mutation delete,
Cell cell,
byte[] byteNow,
Get get) |
Modifier and Type | Method and Description |
---|---|
protected Get |
IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread.createGet(long keyToRead) |
Modifier and Type | Method and Description |
---|---|
protected void |
IntegrationTestTimeBoundedRequestsWithRegionReplicas.TimeBoundedMultiThreadedReader.TimeBoundedMultiThreadedReaderThread.verifyResultsAndUpdateMetrics(boolean verify,
Get[] gets,
long elapsedNano,
Result[] results,
Table table,
boolean isNullExpected) |