Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.io | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.querymatcher | |
org.apache.hadoop.hbase.rest.client | |
org.apache.hadoop.hbase.thrift2.client |
Modifier and Type | Field and Description |
---|---|
private TimeRange |
HTable.CheckAndMutateBuilderImpl.timeRange |
private TimeRange |
RawAsyncTableImpl.CheckAndMutateBuilderImpl.timeRange |
private TimeRange |
Scan.tr |
private TimeRange |
Append.tr |
private TimeRange |
Increment.tr |
private TimeRange |
Get.tr |
Modifier and Type | Field and Description |
---|---|
protected Map<byte[],TimeRange> |
Query.colFamTimeRangeMap |
Modifier and Type | Method and Description |
---|---|
TimeRange |
Scan.getTimeRange() |
TimeRange |
Append.getTimeRange()
Gets the TimeRange used for this append.
|
TimeRange |
Increment.getTimeRange()
Gets the TimeRange used for this increment.
|
TimeRange |
Get.getTimeRange()
Method for retrieving the get's TimeRange
|
Modifier and Type | Method and Description |
---|---|
Map<byte[],TimeRange> |
Query.getColumnFamilyTimeRange() |
Modifier and Type | Method and Description |
---|---|
private boolean |
HTable.doCheckAndDelete(byte[] row,
byte[] family,
byte[] qualifier,
String opName,
byte[] value,
TimeRange timeRange,
Delete delete) |
private boolean |
HTable.doCheckAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
String opName,
byte[] value,
TimeRange timeRange,
RowMutations rm) |
private boolean |
HTable.doCheckAndPut(byte[] row,
byte[] family,
byte[] qualifier,
String opName,
byte[] value,
TimeRange timeRange,
Put put) |
Table.CheckAndMutateBuilder |
HTable.CheckAndMutateBuilderImpl.timeRange(TimeRange timeRange) |
AsyncTable.CheckAndMutateBuilder |
AsyncTable.CheckAndMutateBuilder.timeRange(TimeRange timeRange) |
Table.CheckAndMutateBuilder |
Table.CheckAndMutateBuilder.timeRange(TimeRange timeRange) |
AsyncTable.CheckAndMutateBuilder |
RawAsyncTableImpl.CheckAndMutateBuilderImpl.timeRange(TimeRange timeRange) |
Modifier and Type | Field and Description |
---|---|
private static TimeRange |
TimeRange.ALL_TIME |
Modifier and Type | Method and Description |
---|---|
static TimeRange |
TimeRange.allTime() |
static TimeRange |
TimeRange.at(long ts) |
static TimeRange |
TimeRange.between(long minStamp,
long maxStamp)
Represents the time interval [minStamp, maxStamp)
|
static TimeRange |
TimeRange.from(long minStamp)
Represents the time interval [minStamp, Long.MAX_VALUE)
|
static TimeRange |
TimeRange.until(long maxStamp)
Represents the time interval [0, maxStamp)
|
Modifier and Type | Method and Description |
---|---|
boolean |
TimeRange.includesTimeRange(TimeRange tr)
Check if the range has any overlap with TimeRange
|
Modifier and Type | Field and Description |
---|---|
protected TimeRange |
StoreFileReader.timeRange |
Modifier and Type | Method and Description |
---|---|
(package private) TimeRange |
TimeRangeTracker.toTimeRange() |
Modifier and Type | Method and Description |
---|---|
boolean |
Region.checkAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
TimeRange timeRange,
Mutation mutation)
Atomically checks if a row/family/qualifier value matches the expected value and if it does,
it performs the mutation.
|
boolean |
HRegion.checkAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
TimeRange timeRange,
Mutation mutation) |
boolean |
Region.checkAndRowMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
TimeRange timeRange,
RowMutations mutations)
Atomically checks if a row/family/qualifier value matches the expected values and if it does,
it performs the row mutations.
|
boolean |
HRegion.checkAndRowMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
TimeRange timeRange,
RowMutations rm) |
private boolean |
RSRpcServices.checkAndRowMutate(HRegion region,
List<org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Action> actions,
CellScanner cellScanner,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
TimeRange timeRange,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.RegionActionResult.Builder builder,
ActivePolicyEnforcement spaceQuotaEnforcement)
Mutate a list of rows atomically.
|
private boolean |
HRegion.doCheckAndRowMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
TimeRange timeRange,
RowMutations rowMutations,
Mutation mutation)
checkAndMutate and checkAndRowMutate are 90% the same.
|
private List<Cell> |
HRegion.get(Mutation mutation,
HStore store,
List<Cell> coordinates,
IsolationLevel isolation,
TimeRange tr)
Do a specific Get on passed
columnFamily and column qualifiers. |
boolean |
TimeRangeTracker.includesTimeRange(TimeRange tr)
Check if the range has ANY overlap with TimeRange
|
(package private) boolean |
StoreFileReader.passesTimerangeFilter(TimeRange tr,
long oldestUnexpiredTS)
Check if this storeFile may contain keys within the TimeRange that
have not expired (i.e.
|
boolean |
Segment.shouldSeek(TimeRange tr,
long oldestUnexpiredTS) |
boolean |
CompositeImmutableSegment.shouldSeek(TimeRange tr,
long oldestUnexpiredTS) |
Modifier and Type | Field and Description |
---|---|
protected TimeRange |
UserScanQueryMatcher.tr |
Modifier and Type | Method and Description |
---|---|
Table.CheckAndMutateBuilder |
RemoteHTable.CheckAndMutateBuilderImpl.timeRange(TimeRange timeRange) |
Modifier and Type | Method and Description |
---|---|
Table.CheckAndMutateBuilder |
ThriftTable.CheckAndMutateBuilderImpl.timeRange(TimeRange timeRange) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.