Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
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.
|
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.addImmutable(byte[] family,
byte[] qualifier,
byte[] value)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0. Use
add(Cell)
and CellBuilder instead |
Put |
Put.addImmutable(byte[] family,
byte[] qualifier,
long ts,
byte[] value)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0. Use
add(Cell)
and CellBuilder instead |
Put |
Put.addImmutable(byte[] family,
ByteBuffer qualifier,
long ts,
ByteBuffer value)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0. Use
add(Cell)
and CellBuilder instead |
Put |
Put.setACL(Map<String,org.apache.hadoop.hbase.security.access.Permission> perms) |
Put |
Put.setACL(String user,
org.apache.hadoop.hbase.security.access.Permission perms) |
Put |
Put.setAttribute(String name,
byte[] value) |
Put |
Put.setCellVisibility(org.apache.hadoop.hbase.security.visibility.CellVisibility expression) |
Put |
Put.setClusterIds(List<UUID> clusterIds) |
Put |
Put.setDurability(Durability d) |
Put |
Put.setFamilyCellMap(NavigableMap<byte[],List<Cell>> map)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0. Use
Put(byte[], long, NavigableMap) instead |
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 |
---|---|
List<Put> |
HTableMultiplexer.put(byte[] tableName,
List<Put> puts)
Deprecated.
Use
HTableMultiplexer.put(TableName, List) instead. |
List<Put> |
HTableMultiplexer.put(TableName tableName,
List<Put> puts)
Deprecated.
The puts request will be buffered by their corresponding buffer queue.
|
Modifier and Type | Method and Description |
---|---|
void |
RowMutations.add(Put p)
Deprecated.
since 2.0 version and will be removed in 3.0 version. use
RowMutations.add(Mutation) |
CheckAndMutate |
CheckAndMutate.Builder.build(Put put)
Build the CheckAndMutate object
|
default boolean |
Table.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
byte[] value,
Put put)
Deprecated.
Since 2.0.0. Will be removed in 3.0.0. Use
Table.checkAndMutate(byte[], byte[]) |
default boolean |
Table.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareFilter.CompareOp compareOp,
byte[] value,
Put put)
Deprecated.
Since 2.0.0. Will be removed in 3.0.0. Use
Table.checkAndMutate(byte[], byte[]) |
default boolean |
Table.checkAndPut(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
byte[] value,
Put put)
Deprecated.
Since 2.0.0. Will be removed in 3.0.0. Use
Table.checkAndMutate(byte[], byte[]) |
boolean |
HTableMultiplexer.put(byte[] tableName,
Put put)
Deprecated.
Use
HTableMultiplexer.put(TableName, Put) instead. |
boolean |
HTableMultiplexer.put(byte[] tableName,
Put put,
int retry)
Deprecated.
Use
HTableMultiplexer.put(TableName, Put) instead. |
CompletableFuture<Void> |
AsyncTable.put(Put put)
Puts some data to the table.
|
default void |
Table.put(Put put)
Puts some data in the table.
|
boolean |
HTableMultiplexer.put(TableName tableName,
Put put)
Deprecated.
The put request will be buffered by its corresponding buffer queue.
|
boolean |
HTableMultiplexer.put(TableName tableName,
Put put,
int maxAttempts)
Deprecated.
The put request will be buffered by its corresponding buffer queue.
|
Modifier and Type | Method and Description |
---|---|
List<Put> |
HTableMultiplexer.put(byte[] tableName,
List<Put> puts)
Deprecated.
Use
HTableMultiplexer.put(TableName, List) instead. |
List<CompletableFuture<Void>> |
AsyncTable.put(List<Put> puts)
Puts some data in the table, in batch.
|
default void |
Table.put(List<Put> puts)
Batch puts the specified data into the table.
|
List<Put> |
HTableMultiplexer.put(TableName tableName,
List<Put> puts)
Deprecated.
The puts request will be buffered by their corresponding buffer queue.
|
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 |
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) nnnnn
|
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) nnnnn
|
Modifier and Type | Method and Description |
---|---|
protected void |
TsvImporterMapper.populatePut(byte[] lineBytes,
org.apache.hadoop.hbase.mapreduce.ImportTsv.TsvParser.ParsedLine parsed,
Put put,
int i) |
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) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.