- decrement() - Method in class org.hbase.async.jsr166e.LongAdder
-
Equivalent to add(-1).
- deDup(byte[], byte[]) - Static method in class org.hbase.async.Bytes
-
De-duplicates two byte arrays.
- DEFAULT_MAX_NUM_KVS - Static variable in class org.hbase.async.Scanner
-
The default maximum number of
KeyValues the server is allowed
to return in a single RPC response to a
Scanner.
- DEFAULT_MAX_NUM_ROWS - Static variable in class org.hbase.async.Scanner
-
The default maximum number of rows to scan per RPC.
- delete(DeleteRequest) - Method in class org.hbase.async.HBaseClient
-
Deletes data from HBase.
- deleteAtTimestampOnly() - Method in class org.hbase.async.DeleteRequest
-
Returns whether to only delete the cell value at the timestamp.
- DeleteRequest - Class in org.hbase.async
-
Deletes some data into HBase.
- DeleteRequest(byte[], byte[]) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete an entire row.
- DeleteRequest(byte[], byte[], long) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete an entire row before a specific timestamp.
- DeleteRequest(byte[], byte[], byte[]) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific family.
- DeleteRequest(byte[], byte[], byte[], long) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific family before a specific timestamp.
- DeleteRequest(byte[], byte[], byte[], byte[]) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell.
- DeleteRequest(byte[], byte[], byte[], byte[], long) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell before a specific timestamp.
- DeleteRequest(byte[], byte[], byte[], byte[][]) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific number of cells in a row.
- DeleteRequest(byte[], byte[], byte[], byte[][], long) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific number of cells in a row.
- DeleteRequest(byte[], byte[], byte[], byte[], RowLock) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell with an explicit row lock.
- DeleteRequest(byte[], byte[], byte[], byte[], long, RowLock) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell with an explicit row lock.
- DeleteRequest(byte[], byte[], byte[], byte[][], RowLock) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific number of cells in a row.
- DeleteRequest(byte[], byte[], byte[], byte[][], long, RowLock) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific number of cells in a row with a row lock.
- DeleteRequest(String, String) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete an entire row.
- DeleteRequest(String, String, String) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific family.
- DeleteRequest(String, String, String, String) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell.
- DeleteRequest(String, String, String, String, RowLock) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell with an explicit row lock.
- DeleteRequest(byte[], KeyValue) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell.
- DeleteRequest(byte[], KeyValue, RowLock) - Constructor for class org.hbase.async.DeleteRequest
-
Constructor to delete a specific cell with an explicit row lock.
- deletes() - Method in class org.hbase.async.ClientStats
-
- DependentColumnFilter - Class in org.hbase.async
-
Filters key values based on the existence of a dependent, or reference,
column.
- DependentColumnFilter(byte[], byte[], boolean, CompareFilter.CompareOp, FilterComparator) - Constructor for class org.hbase.async.DependentColumnFilter
-
Creates a DependentColumnFilter with the provided dependent column,
additional value filter, and specification of whether the dependent
column should be included in the results.
- DependentColumnFilter(byte[], byte[], boolean) - Constructor for class org.hbase.async.DependentColumnFilter
-
Creates a DependentColumnFilter with the provided dependent column, and
specify whether the dependent column should be included in the results.
- DependentColumnFilter(byte[], byte[], CompareFilter.CompareOp, FilterComparator) - Constructor for class org.hbase.async.DependentColumnFilter
-
Creates a DependentColumnFilter with the provided dependent column, and
dependent-column value comparison filter.
- DependentColumnFilter(byte[], byte[]) - Constructor for class org.hbase.async.DependentColumnFilter
-
Creates a DependentColumnFilter with the provided dependent column.
- doubleValue() - Method in class org.hbase.async.jsr166e.LongAdder
-
Returns the
LongAdder.sum() as a
double after a widening
primitive conversion.
- dropDependentColumn() - Method in class org.hbase.async.DependentColumnFilter
-
Returns whether the dependent column will be included in the results.
- get(ByteString) - Static method in class org.hbase.async.Bytes
-
Extracts the byte array from the given ByteString without copy.
- get() - Method in class org.hbase.async.Counter
-
Returns the current value of the counter.
- get(GetRequest) - Method in class org.hbase.async.HBaseClient
-
Retrieves data from HBase.
- getAmount() - Method in class org.hbase.async.AtomicIncrementRequest
-
Returns the amount by which the value is going to be incremented.
- getChannel() - Method in exception org.hbase.async.ConnectionResetException
-
Returns the name of the region that's offline.
- getCurrentKey() - Method in class org.hbase.async.Scanner
-
Returns the row key this scanner is currently at.
- getDeferred() - Method in exception org.hbase.async.PleaseThrottleException
-
Returns a deferred one can wait on before retrying the failed RPC.
- getFailedRpc() - Method in interface org.hbase.async.HasFailedRpcException
-
Returns the RPC that caused this exception.
- getFailedRpc() - Method in exception org.hbase.async.NoSuchColumnFamilyException
-
- getFailedRpc() - Method in exception org.hbase.async.NotServingRegionException
-
- getFailedRpc() - Method in exception org.hbase.async.PleaseThrottleException
-
The RPC that was made to fail with this exception.
- getFailedRpc() - Method in exception org.hbase.async.RegionMovedException
-
- getFailedRpc() - Method in exception org.hbase.async.UnknownRowLockException
-
- getFailedRpc() - Method in exception org.hbase.async.UnknownScannerException
-
- getFailedRpc() - Method in exception org.hbase.async.VersionMismatchException
-
- getFilter() - Method in class org.hbase.async.Scanner
-
Returns the possibly-null filter applied to this scanner.
- getFlushInterval() - Method in class org.hbase.async.HBaseClient
-
Returns the maximum time (in milliseconds) for which edits can be buffered.
- getIncrementBufferSize() - Method in class org.hbase.async.HBaseClient
-
Returns the capacity of the increment buffer.
- getInt(byte[]) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 4-byte integer from the begining of the given array.
- getInt(byte[], int) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 4-byte integer from an offset in the given array.
- getLong(byte[]) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 8-byte long from the begining of the given array.
- getLong(byte[], int) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 8-byte long from an offset in the given array.
- getMaxNumBytes() - Method in class org.hbase.async.Scanner
-
Returns the maximum number of bytes returned at once by the scanner.
- getMaxNumKeyValues() - Method in class org.hbase.async.Scanner
-
Maximum number of
KeyValues the server is allowed to return.
- getMaxTimestamp() - Method in class org.hbase.async.Scanner
-
Returns the maximum timestamp to scan (exclusive).
- getMaxVersions() - Method in class org.hbase.async.Scanner
-
Returns the maximum number of versions to return for each cell scanned.
- getMessage() - Method in exception org.hbase.async.NotServingRegionException
-
- getMessage() - Method in exception org.hbase.async.RegionMovedException
-
- getMinTimestamp() - Method in class org.hbase.async.Scanner
-
Returns the minimum timestamp to scan (inclusive).
- getRegion() - Method in exception org.hbase.async.RegionOfflineException
-
Returns the name of the region that's offline.
- GetRequest - Class in org.hbase.async
-
Reads something from HBase.
- GetRequest(byte[], byte[]) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- GetRequest(String, byte[]) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- GetRequest(String, String) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- GetRequest(byte[], byte[], byte[]) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- GetRequest(String, String, String) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- GetRequest(byte[], byte[], byte[], byte[]) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- GetRequest(String, String, String, String) - Constructor for class org.hbase.async.GetRequest
-
Constructor.
- getResponse() - Method in exception org.hbase.async.InvalidResponseException
-
Returns the possibly null response received from the server.
- gets() - Method in class org.hbase.async.ClientStats
-
- getShort(byte[]) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 2-byte short from the begining of the given array.
- getShort(byte[], int) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 2-byte short from an offset in the given array.
- getTable() - Method in exception org.hbase.async.TableNotFoundException
-
Returns the table that was doesn't exist.
- getTimer() - Method in class org.hbase.async.HBaseClient
-
Returns the timer used by this client.
- getType() - Method in exception org.hbase.async.RemoteException
-
Returns the name of the class of the remote exception.
- getUnsignedInt(byte[]) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 4-byte unsigned integer from the begining of the
given array.
- getUnsignedInt(byte[], int) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 4-byte unsigned integer from an offset in the
given array.
- getUnsignedShort(byte[]) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 2-byte unsigned short from the begining of the
given array.
- getUnsignedShort(byte[], int) - Static method in class org.hbase.async.Bytes
-
Reads a big-endian 2-byte unsigned short from an offset in the
given array.
- HasFailedRpcException - Interface in org.hbase.async
-
Interface implemented by
HBaseExceptions that can tell you which
RPC failed.
- hashCode() - Method in class org.hbase.async.KeyValue
-
- HBaseClient - Class in org.hbase.async
-
A fully asynchronous, thread-safe, modern HBase client.
- HBaseClient(String) - Constructor for class org.hbase.async.HBaseClient
-
Constructor.
- HBaseClient(String, String) - Constructor for class org.hbase.async.HBaseClient
-
Constructor.
- HBaseClient(String, String, Executor) - Constructor for class org.hbase.async.HBaseClient
-
Constructor for advanced users with special needs.
- HBaseClient(String, String, ClientSocketChannelFactory) - Constructor for class org.hbase.async.HBaseClient
-
Constructor for advanced users with special needs.
- HBaseException - Exception in org.hbase.async
-
- HBaseRpc - Class in org.hbase.async
-
Abstract base class for all RPC requests going out to HBase.
- HBaseRpc.HasFamily - Interface in org.hbase.async
-
An RPC from which you can get a family name.
- HBaseRpc.HasKey - Interface in org.hbase.async
-
An RPC from which you can get a row key name.
- HBaseRpc.HasQualifier - Interface in org.hbase.async
-
An RPC from which you can get a column qualifier name.
- HBaseRpc.HasQualifiers - Interface in org.hbase.async
-
An RPC from which you can get multiple column qualifier names.
- HBaseRpc.HasTable - Interface in org.hbase.async
-
An RPC from which you can get a table name.
- HBaseRpc.HasTimestamp - Interface in org.hbase.async
-
An RPC from which you can get a timestamp.
- HBaseRpc.HasValue - Interface in org.hbase.async
-
An RPC from which you can get a value.
- HBaseRpc.HasValues - Interface in org.hbase.async
-
An RPC from which you can get multiple values.
- hex(long) - Static method in class org.hbase.async.Bytes
-
Pretty-prints a long into a fixed-width hexadecimal number.
- holdNanoTime() - Method in class org.hbase.async.RowLock
-
Returns for how long this lock has been held in nanoseconds.
- PleaseThrottleException - Exception in org.hbase.async
-
This exception notifies the application to throttle its use of HBase.
- prefetchMeta(String) - Method in class org.hbase.async.HBaseClient
-
Eagerly prefetches and caches a table's region metadata from HBase.
- prefetchMeta(String, String, String) - Method in class org.hbase.async.HBaseClient
-
Eagerly prefetches and caches part of a table's region metadata from HBase.
- prefetchMeta(byte[]) - Method in class org.hbase.async.HBaseClient
-
Eagerly prefetches and caches a table's region metadata from HBase.
- prefetchMeta(byte[], byte[], byte[]) - Method in class org.hbase.async.HBaseClient
-
Eagerly prefetches and caches part of a table's region metadata from HBase.
- pretty(StringBuilder, byte[]) - Static method in class org.hbase.async.Bytes
-
Pretty-prints a byte array into a human-readable output buffer.
- pretty(StringBuilder, byte[][]) - Static method in class org.hbase.async.Bytes
-
Pretty-prints an array of byte arrays into a human-readable output buffer.
- pretty(byte[]) - Static method in class org.hbase.async.Bytes
-
Pretty-prints a byte array into a human-readable string.
- pretty(ChannelBuffer) - Static method in class org.hbase.async.Bytes
-
Pretty-prints all the bytes of a buffer into a human-readable string.
- put(PutRequest) - Method in class org.hbase.async.HBaseClient
-
Stores data in HBase.
- PutRequest - Class in org.hbase.async
-
Puts some data into HBase.
- PutRequest(byte[], byte[], byte[], byte[], byte[]) - Constructor for class org.hbase.async.PutRequest
-
Constructor using current time.
- PutRequest(byte[], byte[], byte[], byte[][], byte[][]) - Constructor for class org.hbase.async.PutRequest
-
Constructor for multiple columns using current time.
- PutRequest(byte[], byte[], byte[], byte[], byte[], long) - Constructor for class org.hbase.async.PutRequest
-
Constructor for a specific timestamp.
- PutRequest(byte[], byte[], byte[], byte[][], byte[][], long) - Constructor for class org.hbase.async.PutRequest
-
Constructor for multiple columns with a specific timestamp.
- PutRequest(byte[], byte[], byte[], byte[], byte[], RowLock) - Constructor for class org.hbase.async.PutRequest
-
Constructor using an explicit row lock.
- PutRequest(byte[], byte[], byte[], byte[], byte[], long, RowLock) - Constructor for class org.hbase.async.PutRequest
-
Constructor using current time and an explicit row lock.
- PutRequest(byte[], byte[], byte[], byte[][], byte[][], long, RowLock) - Constructor for class org.hbase.async.PutRequest
-
Constructor for multiple columns with current time and explicit row lock.
- PutRequest(String, String, String, String, String) - Constructor for class org.hbase.async.PutRequest
-
Convenience constructor from strings (higher overhead).
- PutRequest(String, String, String, String, String, RowLock) - Constructor for class org.hbase.async.PutRequest
-
Convenience constructor with explicit row lock (higher overhead).
- PutRequest(byte[], KeyValue) - Constructor for class org.hbase.async.PutRequest
-
- PutRequest(byte[], KeyValue, RowLock) - Constructor for class org.hbase.async.PutRequest
-
Constructor from a
KeyValue with an explicit row lock.
- puts() - Method in class org.hbase.async.ClientStats
-
- ScanFilter - Class in org.hbase.async
-
Abstract base class for
Scanner filters.
- Scanner - Class in org.hbase.async
-
Creates a scanner to read data sequentially from HBase.
- scannersOpened() - Method in class org.hbase.async.ClientStats
-
Number of scanners opened.
- scans() - Method in class org.hbase.async.ClientStats
-
Number of times a scanner had to fetch data from HBase.
- setAmount(long) - Method in class org.hbase.async.AtomicIncrementRequest
-
Changes the amount by which the value is going to be incremented.
- setDeleteAtTimestampOnly(boolean) - Method in class org.hbase.async.DeleteRequest
-
Deletes only the cell value with the timestamp specified in the
constructor.
- setFailfast(boolean) - Method in class org.hbase.async.HBaseRpc
-
Set whether or not the RPC not be retried upon encountering a problem.
- setFamilies(byte[][], byte[][][]) - Method in class org.hbase.async.Scanner
-
Specifies multiple column families to scan.
- setFamilies(String...) - Method in class org.hbase.async.Scanner
-
Specifies multiple column families to scan.
- setFamily(byte[]) - Method in class org.hbase.async.Scanner
-
Specifies a particular column family to scan.
- setFamily(String) - Method in class org.hbase.async.Scanner
-
Specifies a particular column family to scan.
- setFilter(ScanFilter) - Method in class org.hbase.async.Scanner
-
Specifies the filter to apply to this scanner.
- setFlushInterval(short) - Method in class org.hbase.async.HBaseClient
-
Sets the maximum time (in milliseconds) for which edits can be buffered.
- setIncrementBufferSize(int) - Method in class org.hbase.async.HBaseClient
-
Changes the size of the increment buffer.
- setInt(byte[], int) - Static method in class org.hbase.async.Bytes
-
Writes a big-endian 4-byte int at the begining of the given array.
- setInt(byte[], int, int) - Static method in class org.hbase.async.Bytes
-
Writes a big-endian 4-byte int at an offset in the given array.
- setKeyRegexp(String) - Method in class org.hbase.async.Scanner
-
Sets a regular expression to filter results based on the row key.
- setKeyRegexp(String, Charset) - Method in class org.hbase.async.Scanner
-
Sets a regular expression to filter results based on the row key.
- setLong(byte[], long) - Static method in class org.hbase.async.Bytes
-
Writes a big-endian 8-byte long at the begining of the given array.
- setLong(byte[], long, int) - Static method in class org.hbase.async.Bytes
-
Writes a big-endian 8-byte long at an offset in the given array.
- setMaxNumBytes(long) - Method in class org.hbase.async.Scanner
-
Sets the maximum number of bytes returned at once by the scanner.
- setMaxNumKeyValues(int) - Method in class org.hbase.async.Scanner
-
Sets the maximum number of
KeyValues the server is allowed to
return in a single RPC response.
- setMaxNumRows(int) - Method in class org.hbase.async.Scanner
-
Sets the maximum number of rows to scan per RPC (for better performance).
- setMaxTimestamp(long) - Method in class org.hbase.async.Scanner
-
Sets the maximum timestamp to scan (exclusive).
- setMaxVersions(int) - Method in class org.hbase.async.Scanner
-
Sets the maximum number of versions to return for each cell scanned.
- setMinTimestamp(long) - Method in class org.hbase.async.Scanner
-
Sets the minimum timestamp to scan (inclusive).
- setQualifier(byte[]) - Method in class org.hbase.async.Scanner
-
Specifies a particular column qualifier to scan.
- setQualifier(String) - Method in class org.hbase.async.Scanner
-
Specifies a particular column qualifier to scan.
- setQualifiers(byte[][]) - Method in class org.hbase.async.Scanner
-
Specifies one or more column qualifiers to scan.
- setServerBlockCache(boolean) - Method in class org.hbase.async.Scanner
-
Sets whether or not the server should populate its block cache.
- setShort(byte[], short) - Static method in class org.hbase.async.Bytes
-
Writes a big-endian 2-byte short at the begining of the given array.
- setShort(byte[], short, int) - Static method in class org.hbase.async.Bytes
-
Writes a big-endian 2-byte short at an offset in the given array.
- setStartKey(byte[]) - Method in class org.hbase.async.Scanner
-
Specifies from which row key to start scanning (inclusive).
- setStartKey(String) - Method in class org.hbase.async.Scanner
-
Specifies from which row key to start scanning (inclusive).
- setStopKey(byte[]) - Method in class org.hbase.async.Scanner
-
Specifies up to which row key to scan (exclusive).
- setStopKey(String) - Method in class org.hbase.async.Scanner
-
Specifies up to which row key to scan (exclusive).
- setTimeRange(long, long) - Method in class org.hbase.async.Scanner
-
Sets the time range to scan.
- shutdown() - Method in class org.hbase.async.HBaseClient
-
Performs a graceful shutdown of this instance.
- stats() - Method in class org.hbase.async.HBaseClient
-
Returns a snapshot of usage statistics for this client.
- substring() - Method in class org.hbase.async.SubstringComparator
-
- SubstringComparator - Class in org.hbase.async
-
A substring comparator used in comparison filters such as RowFilter,
QualifierFilter, and ValueFilter.
- SubstringComparator(String) - Constructor for class org.hbase.async.SubstringComparator
-
- sum() - Method in class org.hbase.async.jsr166e.LongAdder
-
Returns the current sum.
- sumThenReset() - Method in class org.hbase.async.jsr166e.LongAdder
-
- value() - Method in class org.hbase.async.BinaryComparator
-
- value() - Method in class org.hbase.async.BinaryPrefixComparator
-
- value() - Method in class org.hbase.async.BitComparator
-
- value() - Method in interface org.hbase.async.HBaseRpc.HasValue
-
Returns the value contained in this RPC.
- value() - Method in class org.hbase.async.KeyValue
-
Returns the value, the contents of the cell.
- value() - Method in class org.hbase.async.PutRequest
-
Returns the first value of the set of edits in this RPC.
- ValueFilter - Class in org.hbase.async
-
Filter key values based on their value.
- ValueFilter(CompareFilter.CompareOp, FilterComparator) - Constructor for class org.hbase.async.ValueFilter
-
- valueOf(String) - Static method in enum org.hbase.async.BitComparator.BitwiseOp
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hbase.async.CompareFilter.CompareOp
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.hbase.async.FilterList.Operator
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.hbase.async.BitComparator.BitwiseOp
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hbase.async.CompareFilter.CompareOp
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.hbase.async.FilterList.Operator
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Method in interface org.hbase.async.HBaseRpc.HasValues
-
Returns the values contained in this RPC.
- values() - Method in class org.hbase.async.PutRequest
-
Returns the values contained in this RPC.
- VersionMismatchException - Exception in org.hbase.async
-
Indicates that an RPC version mismatch occurred.