Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.filter |
Provides row-level filters applied to HRegion scan results during calls to
ResultScanner.next() . |
org.apache.hadoop.hbase.protobuf |
Holds classes generated from protobuf
src/main/protobuf definition files. |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.security.access |
Modifier and Type | Method and Description |
---|---|
boolean |
BaseRegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result) |
boolean |
RegionObserver.postCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result)
Called after checkAndDelete
|
boolean |
BaseRegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
boolean |
RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result)
Called after checkAndPut
|
boolean |
BaseRegionObserver.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result) |
boolean |
RegionObserver.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result)
Called before checkAndDelete.
|
boolean |
BaseRegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result) |
boolean |
RegionObserver.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result)
Called before checkAndDelete but after acquiring rowock.
|
boolean |
BaseRegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
boolean |
RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result)
Called before checkAndPut.
|
boolean |
BaseRegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
boolean |
RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result)
Called before checkAndPut but after acquiring rowlock.
|
Modifier and Type | Class and Description |
---|---|
class |
BinaryComparator
A binary comparator which lexicographically compares against the specified
byte array using
Bytes.compareTo(byte[], byte[]) . |
class |
BinaryPrefixComparator
A comparator which compares against a specified byte array, but only compares
up to the length of this byte array.
|
class |
BitComparator
A bit comparator which performs the specified bitwise operation on each of the bytes
with the specified byte array.
|
class |
LongComparator
A long comparator which numerical compares against the specified byte array
|
class |
NullComparator
A binary comparator which lexicographically compares against the specified
byte array using
Bytes.compareTo(byte[], byte[]) . |
class |
RegexStringComparator
This comparator is for use with
CompareFilter implementations, such
as RowFilter , QualifierFilter , and ValueFilter , for
filtering based on the value of a given column. |
class |
SubstringComparator
This comparator is for use with SingleColumnValueFilter, for filtering based on
the value of a given column.
|
Modifier and Type | Field and Description |
---|---|
protected ByteArrayComparable |
SingleColumnValueFilter.comparator |
protected ByteArrayComparable |
CompareFilter.comparator |
Modifier and Type | Method and Description |
---|---|
static ByteArrayComparable |
ParseFilter.createComparator(byte[] comparator)
Parses a comparator of the form comparatorType:comparatorValue form and returns a comparator
|
ByteArrayComparable |
SingleColumnValueFilter.getComparator() |
ByteArrayComparable |
CompareFilter.getComparator() |
static ByteArrayComparable |
ByteArrayComparable.parseFrom(byte[] pbBytes) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
CompareFilter.doCompare(CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
byte[] data,
int offset,
int length) |
Constructor and Description |
---|
CompareFilter(CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator)
Constructor.
|
DependentColumnFilter(byte[] family,
byte[] qualifier,
boolean dropDependentColumn,
CompareFilter.CompareOp valueCompareOp,
ByteArrayComparable valueComparator)
Build a dependent column filter with value checking
dependent column varies will be compared using the supplied
compareOp and comparator, for usage of which
refer to
CompareFilter |
FamilyFilter(CompareFilter.CompareOp familyCompareOp,
ByteArrayComparable familyComparator)
Constructor.
|
QualifierFilter(CompareFilter.CompareOp op,
ByteArrayComparable qualifierComparator)
Constructor.
|
RowFilter(CompareFilter.CompareOp rowCompareOp,
ByteArrayComparable rowComparator)
Constructor.
|
SingleColumnValueExcludeFilter(byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator)
Constructor for binary compare of the value of a single column.
|
SingleColumnValueExcludeFilter(byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
boolean filterIfMissing,
boolean latestVersionOnly)
Constructor for protobuf deserialization only.
|
SingleColumnValueFilter(byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator)
Constructor for binary compare of the value of a single column.
|
SingleColumnValueFilter(byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
boolean filterIfMissing,
boolean latestVersionOnly)
Constructor for protobuf deserialization only.
|
ValueFilter(CompareFilter.CompareOp valueCompareOp,
ByteArrayComparable valueComparator)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
static ByteArrayComparable |
ProtobufUtil.toComparator(org.apache.hadoop.hbase.protobuf.generated.ComparatorProtos.Comparator proto)
Convert a protocol buffer Comparator to a ByteArrayComparable
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.Condition |
RequestConverter.buildCondition(byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType)
Create a protocol buffer Condition
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
RequestConverter.buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType,
Delete delete)
Create a protocol buffer MutateRequest for a conditioned delete
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MutateRequest |
RequestConverter.buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType,
Put put)
Create a protocol buffer MutateRequest for a conditioned put
|
static org.apache.hadoop.hbase.protobuf.generated.ClientProtos.MultiRequest |
RequestConverter.buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
org.apache.hadoop.hbase.protobuf.generated.HBaseProtos.CompareType compareType,
RowMutations rowMutations)
Create a protocol buffer MutateRequest for conditioned row mutations
|
static org.apache.hadoop.hbase.protobuf.generated.ComparatorProtos.Comparator |
ProtobufUtil.toComparator(ByteArrayComparable comparator)
Convert a ByteArrayComparable to a protocol buffer Comparator
|
Modifier and Type | Method and Description |
---|---|
boolean |
HRegion.checkAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Mutation w,
boolean writeToWAL) |
boolean |
Region.checkAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Mutation mutation,
boolean writeToWAL)
Atomically checks if a row/family/qualifier value matches the expected val
If it does, it performs the row mutations.
|
boolean |
HRegion.checkAndRowMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
RowMutations rm,
boolean writeToWAL) |
boolean |
Region.checkAndRowMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
RowMutations mutations,
boolean writeToWAL)
Atomically checks if a row/family/qualifier value matches the expected val
If it does, it performs the row mutations.
|
boolean |
RegionCoprocessorHost.postCheckAndDelete(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result) |
boolean |
RegionCoprocessorHost.postCheckAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
Boolean |
RegionCoprocessorHost.preCheckAndDelete(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete) |
Boolean |
RegionCoprocessorHost.preCheckAndDeleteAfterRowLock(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete) |
Boolean |
RegionCoprocessorHost.preCheckAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put) |
Boolean |
RegionCoprocessorHost.preCheckAndPutAfterRowLock(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put) |
Modifier and Type | Method and Description |
---|---|
boolean |
AccessController.preCheckAndDelete(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result) |
boolean |
AccessController.preCheckAndDeleteAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Delete delete,
boolean result) |
boolean |
AccessController.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
boolean |
AccessController.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.