Utility methods for helping with security tasks.

The unit of storage in HBase consisting of the following fields:

Utility methods helpful slinging Cell instances.

Coprocessor interface.

All hbase specific IOExceptions should be subclasses of HBaseIOException

Information about a region.

HTableDescriptor contains the details about an HBase table such as the descriptors of all the column families, is the table a catalog table, -ROOT- or hbase:meta , if the table is read only, the maximum size of the memstore, when the region split should occur, coprocessors associated with it etc...

Ways to keep cells marked for delete around.

Exception thrown when the result needs to be chunked on the server side.

Encapsulates per-region load metrics.

This class is used for exporting current state of load on a RegionServer.

Implementers are Stoppable.

Immutable POJO class for representing a table name.

Annotation to inform users of how much to rely on a particular package, class or method not changing over time.

Used to communicate with a single HBase table similar to Table but meant for batched, asynchronous puts.

Used to communicate with a single HBase table similar to HTable but meant for batched, potentially asynchronous puts.

A cluster connection encapsulating lower level individual connections to actual servers and a connection to zookeeper.

Consistency defines the expected consistency level for an operation.

Enum describing the durability guarantees for tables and Mutations Note that the items must be sorted in order of increasing durability

Future that waits on a procedure result.

HTableMultiplexer provides a thread-safe non blocking PUT API across all the tables.

Used to view region location information for a single HBase table.

Performs multiple mutations atomically on a single row.

A Scanner which performs a scan over snapshot files.

Read-only table descriptor.

Convenience class that is used to make RowProcessorEndpoint invocations.

Provides server side metrics related to scan operations.

Every class that wants to observe changes in Configuration properties, must implement interface (and also, register itself with the ConfigurationManager object.

An abstract class that implements RegionServerObserver.

An abstract class that implements WALObserver.

Thrown if a coprocessor encounters any exception.

Coprocessor endpoints providing protobuf services should implement this interface and return the Service instance via CoprocessorService.getService().

This class demonstrates how to implement atomic multi row transactions using HRegion.mutateRowsWithLocks(java.util.Collection, java.util.Collection) and Coprocessor endpoints.

Coprocessor endpoints registered once per server and providing protobuf services should implement this interface and return the Service instance via SingletonCoprocessorService.getService().

It's provided to have a way for coprocessors to observe, rewrite, or skip WALEdits as they are being written to the WAL.

The ForeignExceptionListener is an interface for objects that can receive a ForeignException.

Thrown when the client believes that we are trying to communicate to has been repeatedly unresponsive for a while.

Thrown when the client believes that we are trying to communicate to has been repeatedly unresponsive for a while.

Subclass if the server knows the region is now on another server.

An error requesting an RPC protocol that the server is not serving.

Filter to support scan multiple row key ranges.

Create a Jetty embedded server to answer http requests.

Accepts a stream of Cells.

An CipherProvider contributes support for various cryptographic Ciphers.

Decryptors apply a cipher to an InputStream to recover plaintext.

A facade for encryption algorithms and related support.

Encryptors apply a cipher to an OutputStream to produce ciphertext.

A basic KeyProvider that can resolve keys from a protected KeyStore file on the local filesystem.

An RpcExecutor that will balance requests evenly across all its queues, but still remains efficient with a single queue via an inlinable queue balancing mechanism.

The request processing logic, which is usually executed in thread pools provided by an RpcScheduler.

Base class which provides clients with an RPC connection to call coprocessor endpoint Services.

Thrown when server finds fatal issue w/ connection setup: e.g.

A RemoteException with some extra information.

An interface for RPC request scheduling algorithm.

Datastructure that holds all necessary to a method invocation and then afterward, carries the result.

RPC Executor that uses different queues for reads and writes.

A scheduler that maintains isolated handler pools for general, high-priority, and replication requests.

TableSnapshotInputFormat allows a MapReduce job to run over a table snapshot.

Writes HFiles.

Convert HBase tabular data from multiple scanners into a format that is consumable by Map/Reduce.

MultiTableSnapshotInputFormat generalizes TableSnapshotInputFormat allowing a MapReduce job to run over one or more table snapshots, with one or more scans configured for each.

Combine Puts.

Hadoop MR API-agnostic implementation for mapreduce over table snapshots.

Emits Sorted KeyValues.

Interface to convert visibility expressions into Tags for storing along with Cells in HFiles.

Stores the plan for the move of an individual region.

ProcedureRunnableSet for the Master Procedures.

Latch used by the Master to have the prepare() sync behaviour for old clients, that can only get exceptions in a synchronous way.

Procedures that handle servers -- e.g.

Intelligently keep track of all the files for all the snapshots.

Implementation of a log cleaner that checks if a log is still used by snapshots of HBase tables.

A life-cycle management interface for globally barriered procedures on region servers.

Base Procedure class responsible to handle the Procedure Metadata e.g.

Keep track of the runnable procedures

A RemoteProcedureException is an exception from another thread or process.

A SequentialProcedure describes one step in a procedure chain.

Keeps track of live procedures.

Helper class that contains the WAL serialization utils.

ProcedureWALPrettyPrinter prints the contents of a given ProcedureWAL file

Master Quota Manager.

Noop quota limiter returned when no limiter is associated to the user/table

Cache that keeps track of the quota settings for the users and tables that are interacting with it.

Filter to use to filter the QuotaRetriever results.

Describe the Scope of the quota rules.

Helper class to interact with the quota table.

Helper class to interact with the quota table

Region Server Quota Manager.

Describe the Throttle Type.

In-Memory state of the user quotas

Makes the decision regarding proper sizing of the heap memory.

This class is for maintaining the various regionserver statistics and publishing them through the metrics interfaces.

Thrown if request for nonexistent column family.

Regions store data for a certain region of a table.

Executes region merge as a "transaction".

RegionScanner describes iterators over rows in an HRegion.

Services provided by HRegionServer

Defines the procedure to atomically perform multiple scans and mutations on a HRegion.

ScannerContext instances encapsulate limit tracking AND progress towards those limits during invocations of InternalScanner.next(java.util.List) and InternalScanner.next(java.util.List).

Constructs a SimpleRpcScheduler.

A factory for creating SplitTransactions, which execute region split as a "transaction".

Thrown when we fail close of the write-ahead-log file.

Some static utility methods for encryption uses in hbase-client.

Utility methods for obtaining authentication tokens.

This contains a visibility expression which can be associated with a cell.

Utility client for doing visibility labels admin operations.

During the read (ie.

Export the specified snapshot to a given FileSystem.

Thrown when a snapshot could not be restored due to a server-side error when restoring it.

Thrown when the server is looking for a snapshot but can't find the snapshot on the filesystem

Tool for dumping snapshot information.

Exception thrown when we get a request for a snapshot we don't recognize.

Wraps an existing DataType implementation as a fixed-length version of itself.

An alternative to OrderedBlob for use by Struct fields that do not terminate the fields list.

A float of 32-bits using a fixed-length encoding.

A short of 16-bits using a fixed-length encoding.

A long of 64-bits using a fixed-length encoding.

An Number of arbitrary precision and variable-length encoding.

A base-class for DataType implementations backed by protobuf.

An DataType for interacting with variable-length values encoded using Bytes.putBytes(byte[], int, byte[], int, int).

An DataType that encodes variable-length values encoded using Bytes.putBytes(byte[], int, byte[], int, int).

An DataType for interacting with values encoded using Bytes.putFloat(byte[], int, float).

An DataType for interacting with values encoded using Bytes.putLong(byte[], int, long).

An DataType for interacting with values encoded using Bytes.toBytes(String).

An DataType that encodes variable-length values encoded using Bytes.toBytes(String).

A helper for building Struct instances.

Wraps an existing DataType implementation as a terminated version of itself.

The Union family of DataTypes encode one of a fixed collection of Objects.

Extends the basic SimpleByteRange implementation with position support.

Lightweight, reusable class for specifying ranges of byte[]'s.

Compression validation test.

Utilities for storing more complex collection types in Configuration instances.

Utilities for interacting with and monitoring DirectByteBuffer allocations.

Thrown when the file system needs to be upgraded

Implementation for hdfs

Utility class for converting objects to JSON

Utility class that handles ordered byte arrays.

Exception thrown when a read only byte range is modified

A read only version of the ByteRange.

Extends the basic SimpleMutableByteRange implementation with position support and it is a readonly version.

A Write Ahead Log (WAL) provides service for reading, writing waledits.

TODO: Most of the code in this class is ripped from ZooKeeper tests.