Modifier and Type | Method and Description |
---|---|
static Put |
MetaTableAccessor.addDaughtersToPut(Put put,
RegionInfo splitA,
RegionInfo 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,
int replicaId) |
static Put |
MetaTableAccessor.addRegionInfo(Put p,
RegionInfo hri) |
static Put |
MetaTableAccessor.addRegionStateToPut(Put put,
int replicaId,
RegionState.State state)
|
static Put |
MetaTableAccessor.makePutFromRegionInfo(RegionInfo regionInfo)
Generates and returns a
Put containing the RegionInfo for the catalog table. |
static Put |
MetaTableAccessor.makePutFromRegionInfo(RegionInfo regionInfo,
long ts)
Generates and returns a
Put containing the RegionInfo for the catalog table. |
static Put |
MetaTableAccessor.makePutFromTableState(TableState state,
long ts)
Construct PUT for given state
|
Modifier and Type | Method and Description |
---|---|
static Put |
MetaTableAccessor.addDaughtersToPut(Put put,
RegionInfo splitA,
RegionInfo 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,
int replicaId) |
static Put |
MetaTableAccessor.addRegionInfo(Put p,
RegionInfo hri) |
static Put |
MetaTableAccessor.addRegionStateToPut(Put put,
int replicaId,
RegionState.State state)
|
private static void |
MetaTableAccessor.put(Table t,
Put p) |
private static void |
MetaTableAccessor.putToMetaTable(Connection connection,
Put p)
Put the passed
p to the hbase:meta table. |
Modifier and Type | Method and Description |
---|---|
static void |
MetaTableAccessor.putsToMetaTable(Connection connection,
List<Put> ps)
Put the passed
ps to the hbase:meta table. |
Modifier and Type | Method and Description |
---|---|
private Put |
BackupSystemTable.createPutForBackupInfo(BackupInfo context)
Creates Put operation for a given backup info object
|
private Put |
BackupSystemTable.createPutForBackupSet(String name,
String[] tables)
Creates Put operation to update backup set content
|
(package private) static Put |
BackupSystemTable.createPutForBulkLoadedFile(TableName tn,
byte[] fam,
String p,
String backupId,
long ts,
int idx) |
private Put |
BackupSystemTable.createPutForDeleteOperation(String[] backupIdList) |
private Put |
BackupSystemTable.createPutForIncrBackupTableSet(Set<TableName> tables,
String backupRoot)
Creates Put to store incremental backup table set
|
private Put |
BackupSystemTable.createPutForMergeOperation(String[] backupIdList) |
private Put |
BackupSystemTable.createPutForRegionServerLastLogRollResult(String server,
Long timestamp,
String backupRoot)
Creates Put to store RS last log result
|
private Put |
BackupSystemTable.createPutForStartBackupSession() |
private Put |
BackupSystemTable.createPutForStartCode(String startCode,
String rootPath)
Creates Put operation to store start code to backup system table
|
private Put |
BackupSystemTable.createPutForStopBackupSession() |
private Put |
BackupSystemTable.createPutForUpdateTablesForMerge(List<TableName> tables) |
private Put |
BackupSystemTable.createPutForWriteRegionServerLogTimestamp(TableName table,
byte[] smap,
String backupRoot)
Creates Put to write RS last roll log timestamp map
|
Modifier and Type | Method and Description |
---|---|
(package private) static List<Put> |
BackupSystemTable.createPutForCommittedBulkload(TableName table,
byte[] region,
Map<byte[],List<org.apache.hadoop.fs.Path>> finalPaths) |
(package private) static List<Put> |
BackupSystemTable.createPutForPreparedBulkload(TableName table,
byte[] region,
byte[] family,
List<Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> pairs) |
Modifier and Type | Method and Description |
---|---|
Put |
Put.add(Cell cell)
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,
ByteBuffer qualifier,
long ts,
ByteBuffer value)
Add the specified column and value, with the specified timestamp as its version to this Put
operation.
|
Put |
Put.setACL(Map<String,Permission> perms) |
Put |
Put.setACL(String user,
Permission perms) |
Put |
Put.setAttribute(String name,
byte[] value) |
Put |
Put.setCellVisibility(CellVisibility expression) |
Put |
Put.setClusterIds(List<UUID> clusterIds) |
Put |
Put.setDurability(Durability d) |
Put |
Put.setId(String id) |
Put |
Put.setPriority(int priority) |
Put |
Put.setTimestamp(long timestamp) |
Put |
Put.setTTL(long ttl) |
Modifier and Type | Method and Description |
---|---|
CheckAndMutate |
CheckAndMutate.Builder.build(Put put)
Build the CheckAndMutate object
|
default void |
Table.put(Put put)
Puts some data in the table.
|
CompletableFuture<Void> |
AsyncTableImpl.put(Put put) |
CompletableFuture<Void> |
AsyncTable.put(Put put)
Puts some data to the table.
|
CompletableFuture<Void> |
RawAsyncTableImpl.put(Put put) |
void |
TableOverAsyncTable.put(Put put) |
boolean |
Table.CheckAndMutateBuilder.thenPut(Put put)
Deprecated.
Specify a Put to commit if the check succeeds.
|
boolean |
Table.CheckAndMutateWithFilterBuilder.thenPut(Put put)
Deprecated.
Specify a Put to commit if the check succeeds.
|
CompletableFuture<Boolean> |
AsyncTable.CheckAndMutateBuilder.thenPut(Put put)
Deprecated.
Specify a Put to commit if the check succeeds.
|
CompletableFuture<Boolean> |
AsyncTable.CheckAndMutateWithFilterBuilder.thenPut(Put put)
Deprecated.
Specify a Put to commit if the check succeeds.
|
CompletableFuture<Boolean> |
RawAsyncTableImpl.CheckAndMutateBuilderImpl.thenPut(Put put) |
CompletableFuture<Boolean> |
RawAsyncTableImpl.CheckAndMutateWithFilterBuilderImpl.thenPut(Put put) |
(package private) static void |
ConnectionUtils.validatePut(Put put,
int maxKeyValueSize) |
Modifier and Type | Method and Description |
---|---|
default void |
Table.put(List<Put> puts)
Batch puts the specified data into the table.
|
List<CompletableFuture<Void>> |
AsyncTableImpl.put(List<Put> puts) |
List<CompletableFuture<Void>> |
AsyncTable.put(List<Put> puts)
Puts some data in the table, in batch.
|
List<CompletableFuture<Void>> |
RawAsyncTableImpl.put(List<Put> puts) |
void |
TableOverAsyncTable.put(List<Put> puts) |
default CompletableFuture<Void> |
AsyncTable.putAll(List<Put> puts)
A simple version of batch put.
|
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 |
ConstraintProcessor.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
Modifier and Type | Method and Description |
---|---|
default boolean |
RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.postCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Put put,
boolean result)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.postCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default void |
RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit)
Called after the client stores a value.
|
default void |
RegionObserver.postPut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.postPut(ObserverContext, Put, WALEdit) instead. |
default boolean |
RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndPut(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Put put,
boolean result)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutate(ObserverContext, CheckAndMutate, CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)
instead. |
default boolean |
RegionObserver.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
Filter filter,
Put put,
boolean result)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.preCheckAndMutateAfterRowLock(ObserverContext, CheckAndMutate,CheckAndMutateResult)
instead. |
default void |
RegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit)
Called before the client stores a value.
|
default void |
RegionObserver.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability)
Deprecated.
since 3.0.0 and will be removed in 4.0.0. Use
RegionObserver.prePut(ObserverContext, Put, WALEdit) instead. |
void |
MetaTableMetrics.ExampleRegionObserverMeta.prePut(ObserverContext<RegionCoprocessorEnvironment> e,
Put put,
WALEdit edit,
Durability durability) |
Modifier and Type | Method and Description |
---|---|
private static Put |
FavoredNodeAssignmentHelper.makePut(RegionInfo regionInfo,
List<ServerName> favoredNodeList) |
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,
Iterator<Put> values,
org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,Put> output,
org.apache.hadoop.mapred.Reporter reporter)
No aggregation, output pairs of (key, record)
|
void |
IdentityTableReduce.reduce(ImmutableBytesWritable key,
Iterator<Put> values,
org.apache.hadoop.mapred.OutputCollector<ImmutableBytesWritable,Put> output,
org.apache.hadoop.mapred.Reporter reporter)
No aggregation, output pairs of (key, record)
|
Modifier and Type | Method and Description |
---|---|
protected void |
Import.Importer.addPutToKv(Put put,
Cell kv) |
protected void |
TsvImporterMapper.populatePut(byte[] lineBytes,
ImportTsv.TsvParser.ParsedLine parsed,
Put put,
int i) |
protected void |
Import.Importer.processKV(ImmutableBytesWritable key,
Result result,
org.apache.hadoop.mapreduce.Mapper.Context context,
Put put,
Delete delete) |
Modifier and Type | Method and Description |
---|---|
protected void |
PutSortReducer.reduce(ImmutableBytesWritable row,
Iterable<Put> puts,
org.apache.hadoop.mapreduce.Reducer.Context context) |
protected void |
PutCombiner.reduce(K row,
Iterable<Put> vals,
org.apache.hadoop.mapreduce.Reducer.Context context) |
Modifier and Type | Method and Description |
---|---|
(package private) static Put |
RegionStateStore.addMergeRegions(Put put,
Collection<RegionInfo> mergeRegions) |
private static Put |
RegionStateStore.addSequenceNum(Put p,
long openSeqNum,
int replicaId) |
private Put |
RegionStateStore.generateUpdateRegionLocationPut(RegionStateNode regionStateNode) |
Modifier and Type | Method and Description |
---|---|
(package private) static Put |
RegionStateStore.addMergeRegions(Put put,
Collection<RegionInfo> mergeRegions) |
private static Put |
RegionStateStore.addSequenceNum(Put p,
long openSeqNum,
int replicaId) |
private CompletableFuture<Void> |
RegionStateStore.updateRegionLocation(RegionInfo regionInfo,
RegionState.State state,
Put put) |
Modifier and Type | Method and Description |
---|---|
private static void |
WALEventTrackerTableAccessor.doPut(Connection connection,
List<Put> puts) |
Modifier and Type | Method and Description |
---|---|
(package private) static Put |
QuotaTableUtil.createPutForNamespaceSnapshotSize(String namespace,
long size)
Creates a
Put for the namespace's total snapshot size. |
(package private) static Put |
QuotaTableUtil.createPutForSnapshotSize(TableName tableName,
String snapshot,
long size)
|
(package private) static Put |
QuotaTableUtil.createPutForSpaceSnapshot(TableName tableName,
SpaceQuotaSnapshot snapshot)
|
Modifier and Type | Method and Description |
---|---|
private static void |
QuotaUtil.doPut(Connection connection,
Put put) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
HRegion.BatchOperation.checkAndPreparePut(Put p)
Implement any Put request specific check and prepare logic here.
|
void |
HRegion.MutationBatchOperation.checkAndPreparePut(Put p) |
protected void |
HRegion.ReplayBatchOperation.checkAndPreparePut(Put p)
Deprecated.
During replay, there could exist column families which are removed between region server
failure and replay
|
void |
RegionCoprocessorHost.postPut(Put put,
WALEdit edit) |
boolean |
RegionCoprocessorHost.prePut(Put put,
WALEdit edit)
Supports Coprocessor 'bypass'.
|
void |
HRegion.put(Put put) |
void |
Region.put(Put put)
Puts some data in the table.
|
Modifier and Type | Method and Description |
---|---|
static Put |
ReplicationBarrierFamilyFormat.makePutForReplicationBarrier(RegionInfo regionInfo,
long openSeqNum,
long ts) |
Modifier and Type | Method and Description |
---|---|
static void |
ReplicationBarrierFamilyFormat.addReplicationBarrier(Put put,
long openSeqNum) |
static void |
ReplicationBarrierFamilyFormat.addReplicationParent(Put put,
List<RegionInfo> parents) |
Modifier and Type | Method and Description |
---|---|
private Put |
ReplicationSink.processReplicationMarkerEntry(Cell cell) |
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,
CompareOperator op,
ByteArrayComparable comparator,
Put put,
boolean result) |
boolean |
AccessController.preCheckAndPutAfterRowLock(ObserverContext<RegionCoprocessorEnvironment> c,
byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator opp,
ByteArrayComparable comparator,
Put put,
boolean result) |
void |
AccessController.prePut(ObserverContext<RegionCoprocessorEnvironment> c,
Put put,
WALEdit edit,
Durability durability) |
Modifier and Type | Method and Description |
---|---|
private static void |
SlowLogTableAccessor.doPut(Connection connection,
List<Put> puts) |
Modifier and Type | Method and Description |
---|---|
static Put |
ThriftUtilities.putFromThrift(org.apache.hadoop.hbase.thrift2.generated.TPut in)
Creates a
Put (HBase) from a TPut (Thrift) |
Modifier and Type | Method and Description |
---|---|
static List<Put> |
ThriftUtilities.putsFromThrift(List<org.apache.hadoop.hbase.thrift2.generated.TPut> in)
Converts multiple
TPut s (Thrift) into a list of Put s (HBase). |
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.thrift2.generated.TPut |
ThriftUtilities.putFromHBase(Put in) |
Modifier and Type | Method and Description |
---|---|
static List<org.apache.hadoop.hbase.thrift2.generated.TPut> |
ThriftUtilities.putsFromHBase(List<Put> in) |
Modifier and Type | Method and Description |
---|---|
void |
ThriftTable.put(Put put) |
boolean |
ThriftTable.CheckAndMutateBuilderImpl.thenPut(Put put) |
Modifier and Type | Method and Description |
---|---|
void |
ThriftTable.put(List<Put> puts) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.