Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.backup.impl | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.constraint |
Restrict the domain of a data attribute, often times to fulfill business rules/requirements.
|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
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.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 |
Modifier and Type | Method and Description |
---|---|
static Put |
MetaTableAccessor.addDaughtersToPut(Put put,
HRegionInfo splitA,
HRegionInfo splitB)
Adds split daughters to the Put
|
static Put |
MetaTableAccessor.addEmptyLocation(Put p,
int replicaId) |
static Put |
MetaTableAccessor.addLocation(Put p,
ServerName sn,
long openSeqNum,
long time,
int replicaId) |
static Put |
MetaTableAccessor.makePutFromRegionInfo(HRegionInfo regionInfo)
Generates and returns a Put containing the region into for the catalog table
|
static Put |
MetaTableAccessor.makePutFromRegionInfo(HRegionInfo regionInfo,
long ts)
Generates and returns a Put containing the region into for the catalog table
|
Modifier and Type | Method and Description |
---|---|
static Put |
MetaTableAccessor.addDaughtersToPut(Put put,
HRegionInfo splitA,
HRegionInfo splitB)
Adds split daughters to the Put
|
static Put |
MetaTableAccessor.addEmptyLocation(Put p,
int replicaId) |
static Put |
MetaTableAccessor.addLocation(Put p,
ServerName sn,
long openSeqNum,
long time,
int replicaId) |
void |
HBaseTestCase.Incommon.put(Put put) |
void |
HBaseTestCase.HRegionIncommon.put(Put put) |
void |
HBaseTestCase.HTableIncommon.put(Put put) |
Modifier and Type | Method and Description |
---|---|
static void |
MetaTableAccessor.putsToMetaTable(Connection connection,
java.util.List<Put> ps)
Put the passed
ps to the hbase:meta table. |
Modifier and Type | Method and Description |
---|---|
static java.util.List<Put> |
BackupSystemTableHelper.createPutsForAddWALFiles(java.util.List<java.lang.String> files,
java.lang.String backupId,
java.lang.String backupRoot)
Creates put list for list of WAL files
|
Modifier and Type | Field and Description |
---|---|
Put |
TestPutDotHas.put |
Modifier and Type | Method and Description |
---|---|
Put |
Put.add(byte[] family,
byte[] qualifier,
byte[] value)
Deprecated.
Since 1.0.0. Use
addColumn(byte[], byte[], byte[]) |
Put |
Put.add(byte[] family,
byte[] qualifier,
long ts,
byte[] value)
Deprecated.
Since 1.0.0. Use
addColumn(byte[], byte[], long, byte[]) |
Put |
Put.add(byte[] family,
java.nio.ByteBuffer qualifier,
long ts,
java.nio.ByteBuffer value)
Deprecated.
Since 1.0.0. Use
addColumn(byte[], ByteBuffer, long, ByteBuffer) |
Put |
Put.add(Cell kv)
Add the specified KeyValue to this Put operation.
|
Put |
Put.addColumn(byte[] family,
byte[] qualifier,
byte[] value)
Add the specified column and value to this Put operation.
|
Put |
Put.addColumn(byte[] family,
byte[] qualifier,
long ts,
byte[] value)
Add the specified column and value, with the specified timestamp as
its version to this Put operation.
|
Put |
Put.addColumn(byte[] family,
java.nio.ByteBuffer qualifier,
long ts,
java.nio.ByteBuffer value)
Add the specified column and value, with the specified timestamp as
its version to this Put operation.
|
Put |
Put.addImmutable(byte[] family,
byte[] qualifier,
byte[] value)
|
Put |
Put.addImmutable(byte[] family,
byte[] qualifier,
byte[] value,
Tag[] tag)
This expects that the underlying arrays won't change.
|
Put |
Put.addImmutable(byte[] family,
byte[] qualifier,
long ts,
byte[] value)
|
Put |
Put.addImmutable(byte[] family,
byte[] qualifier,
long ts,
byte[] value,
Tag[] tag)
This expects that the underlying arrays won't change.
|
Put |
Put.addImmutable(byte[] family,
java.nio.ByteBuffer qualifier,
long ts,
java.nio.ByteBuffer value)
|
Put |
Put.addImmutable(byte[] family,
java.nio.ByteBuffer qualifier,
long ts,
java.nio.ByteBuffer value,
Tag[] tag)
This expects that the underlying arrays won't change.
|
Put |
Put.setACL(java.util.Map<java.lang.String,Permission> perms) |
Put |
Put.setACL(java.lang.String user,
Permission perms) |
Put |
Put.setAttribute(java.lang.String name,
byte[] value) |
Put |
Put.setCellVisibility(CellVisibility expression) |
Put |
Put.setClusterIds(java.util.List<java.util.UUID> clusterIds) |
Put |
Put.setDurability(Durability d) |
Put |
Put.setFamilyCellMap(java.util.NavigableMap<byte[],java.util.List<Cell>> map) |
Put |
Put.setFamilyMap(java.util.NavigableMap<byte[],java.util.List<KeyValue>> map)
Deprecated.
|
Put |
Put.setId(java.lang.String id) |
Put |
Put.setTTL(long ttl) |
Put |
Put.setWriteToWAL(boolean write)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<Put> |
HTableMultiplexer.put(byte[] tableName,
java.util.List<Put> puts)
Deprecated.
|
java.util.List<Put> |
HTableMultiplexer.put(TableName tableName,
java.util.List<Put> puts)
The puts request will be buffered by their corresponding buffer queue.
|
Modifier and Type | Method and Description |
---|---|
void |
RowMutations.add(Put p)
Add a
Put operation to the list of mutations |
boolean |
HTable.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
byte[] value,
Put put)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
Table.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
byte[] value,
Put put)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
HTableWrapper.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
byte[] value,
Put put) |
boolean |
HTable.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
byte[] value,
Put put)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
Table.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
byte[] value,
Put put)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
HTableWrapper.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
byte[] value,
Put put) |
boolean |
HTableMultiplexer.put(byte[] tableName,
Put put)
Deprecated.
|
boolean |
HTableMultiplexer.put(byte[] tableName,
Put put,
int retry)
Deprecated.
|
void |
HTable.put(Put put)
Puts some data in the table.
|
void |
Table.put(Put put)
Puts some data in the table.
|
void |
HTableWrapper.put(Put put) |
boolean |
HTableMultiplexer.put(TableName tableName,
Put put)
The put request will be buffered by its corresponding buffer queue.
|
boolean |
HTableMultiplexer.put(TableName tableName,
Put put,
int retry)
The put request will be buffered by its corresponding buffer queue.
|
void |
BufferedMutatorImpl.validatePut(Put put) |
void |
HTable.validatePut(Put put) |
static void |
HTable.validatePut(Put put,
int maxKeyValueSize) |
Modifier and Type | Method and Description |
---|---|
static void |
HTableUtil.bucketRsPut(HTable htable,
java.util.List<Put> puts)
Deprecated.
Processes a List of Puts and writes them to an HTable instance in RegionServer buckets via the htable.put method.
|
java.util.List<Put> |
HTableMultiplexer.put(byte[] tableName,
java.util.List<Put> puts)
Deprecated.
|
void |
HTable.put(java.util.List<Put> puts)
Puts some data in the table, in batch.
|
void |
Table.put(java.util.List<Put> puts)
Puts some data in the table, in batch.
|
void |
HTableWrapper.put(java.util.List<Put> puts) |
java.util.List<Put> |
HTableMultiplexer.put(TableName tableName,
java.util.List<Put> puts)
The puts request will be buffered by their corresponding buffer queue.
|
Constructor and Description |
---|
Put(Put putToCopy)
Copy constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
Constraint.check(Put p)
Check a
Put to ensure it is valid for the table. |
void |
AllFailConstraint.check(Put p) |
void |
AllPassConstraint.check(Put p) |
void |
CheckConfigurationConstraint.check(Put p) |
void |
RuntimeFailConstraint.check(Put p) |
void |
TestConstraint.CheckWasRunConstraint.check(Put p) |
void |
TestConstraints.AlsoWorks.check(Put p) |
void |
WorksConstraint.check(Put p) |
void |
ConstraintProcessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
Modifier and Type | Method and Description |
---|---|
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 |
SimpleRegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
void |
BaseRegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
void |
RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability)
Called after the client stores a value.
|
void |
SimpleRegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
void |
TestNegativeMemstoreSizeWithSlowCoprocessor.FlushingRegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
void |
TestRegionObserverStacking.ObserverA.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
void |
TestRegionObserverStacking.ObserverB.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
void |
TestRegionObserverStacking.ObserverC.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
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 |
SimpleRegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
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.
|
boolean |
SimpleRegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> e,
byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
void |
BaseRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
void |
RegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability)
Called before the client stores a value.
|
void |
SimpleRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
void |
TestOpenTableInCoprocessor.SendToOtherTableCoprocessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
void |
TestOpenTableInCoprocessor.CustomThreadPoolCoprocessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
void |
TestRegionObserverBypass.TestCoprocessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
void |
TestRegionServerCoprocessorExceptionWithAbort.BuggyRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
void |
TestRegionServerCoprocessorExceptionWithRemove.BuggyRegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
Modifier and Type | Method and Description |
---|---|
void |
TableOutputFormat.TableRecordWriter.write(ImmutableBytesWritable key,
Put value) |
Modifier and Type | Method and Description |
---|---|
void |
IdentityTableReduce.reduce(ImmutableBytesWritable key,
java.util.Iterator<Put> values,
<any> output,
Reporter reporter)
No aggregation, output pairs of (key, record)
|
Modifier and Type | Method and Description |
---|---|
protected static Put |
TestTableMapReduceBase.map(ImmutableBytesWritable key,
Result value)
Implements mapper logic for use across APIs.
|
Modifier and Type | Method and Description |
---|---|
protected void |
Import.Importer.addPutToKv(Put put,
Cell kv) |
protected void |
TsvImporterMapper.populatePut(byte[] lineBytes,
org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed,
Put put,
int i) |
protected void |
TsvImporterCustomTestMapperForOprAttr.populatePut(byte[] lineBytes,
org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed,
Put put,
int i) |
void |
TestImportTSVWithOperationAttributes.OperationAttributesTestController.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
void |
TestImportTSVWithTTLs.TTLCheckingObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
protected void |
Import.Importer.processKV(ImmutableBytesWritable key,
Result result,
Context context,
Put put,
Delete delete) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutSortReducer.reduce(ImmutableBytesWritable row,
java.lang.Iterable<Put> puts,
<any>.Context context) |
protected void |
PutCombiner.reduce(K row,
java.lang.Iterable<Put> vals,
Context context) |
Modifier and Type | Method and Description |
---|---|
static Put |
ProtobufUtil.toPut(ClientProtos.MutationProto proto)
Convert a protocol buffer Mutate to a Put.
|
static Put |
ProtobufUtil.toPut(ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to a Put.
|
Modifier and Type | Method and Description |
---|---|
static ClientProtos.MutateRequest |
RequestConverter.buildMutateRequest(byte[] regionName,
byte[] row,
byte[] family,
byte[] qualifier,
ByteArrayComparable comparator,
HBaseProtos.CompareType compareType,
Put put)
Create a protocol buffer MutateRequest for a conditioned put
|
static ClientProtos.MutateRequest |
RequestConverter.buildMutateRequest(byte[] regionName,
Put put)
Create a protocol buffer MutateRequest for a put
|
Modifier and Type | Method and Description |
---|---|
static Put |
QuotaTableUtil.putSpaceSnapshot(TableName tableName,
SpaceQuotaSnapshot snapshot)
|
Modifier and Type | Method and Description |
---|---|
Put |
RegionMergeTransactionImpl.addLocation(Put p,
ServerName sn,
long openSeqNum) |
Put |
SplitTransactionImpl.addLocation(Put p,
ServerName sn,
long openSeqNum) |
Modifier and Type | Method and Description |
---|---|
Put |
RegionMergeTransactionImpl.addLocation(Put p,
ServerName sn,
long openSeqNum) |
Put |
SplitTransactionImpl.addLocation(Put p,
ServerName sn,
long openSeqNum) |
boolean |
RegionCoprocessorHost.postCheckAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put,
boolean result) |
void |
RegionCoprocessorHost.postPut(Put put,
WALEdit edit,
Durability durability) |
java.lang.Boolean |
RegionCoprocessorHost.preCheckAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put) |
java.lang.Boolean |
RegionCoprocessorHost.preCheckAndPutAfterRowLock(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
ByteArrayComparable comparator,
Put put) |
boolean |
RegionCoprocessorHost.prePut(Put put,
WALEdit edit,
Durability durability) |
void |
OOMERegionServer.put(byte[] regionName,
Put put) |
void |
HRegion.put(Put put) |
void |
Region.put(Put put)
Puts some data in the table.
|
Modifier and Type | Method and Description |
---|---|
protected CellSetModel |
RemoteHTable.buildModelFromPut(Put put) |
boolean |
RemoteHTable.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
byte[] value,
Put put) |
boolean |
RemoteHTable.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
byte[] value,
Put put) |
void |
RemoteHTable.put(Put put) |
Modifier and Type | Method and Description |
---|---|
void |
RemoteHTable.put(java.util.List<Put> puts) |
Modifier and Type | Method and Description |
---|---|
void |
AccessController.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
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) |
void |
AccessController.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |