Interface to support the aborting of a given server or client.

Defines the set of shared functions implemented by HBase servers (Masters and RegionServers).

Using this Interface one can mark a Cell as timestamp changeable.

BaseHFileCleanerDelegate that only cleans HFiles that don't belong to a table that is currently being archived.

An implementation using a multicast message between the master & the client.

Convenience class that is used to make RowProcessorEndpoint invocations.

TODO javadoc

Basic Cell codec that just writes out all the individual elements of a Cell.

Encoder/Decoder for Cell.

Codec that does KeyValue version 1 serialization with serializing tags also.

ZooKeeper-based implementation of CoordinatedStateManager.

An abstract class that implements RegionObserver.

This class demonstrates how to implement atomic read-modify-writes using Region.processRowsWithLocks(org.apache.hadoop.hbase.regionserver.RowProcessor<?, ?>) and Coprocessor endpoints.

Coprocessors implement this interface to observe and mediate bulk load operations.

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.

A servlet to print out the running configuration data.

Provides a servlet filter that pretends to authenticate a fake user (Dr.Who) so that the web UI is usable for a secure cluster without authentication.

A servlet implementation

Implements pretty-printing functionality for HFiles.

Netty client for the requests and responses

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

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.

Driver for hbase mapreduce jobs.

Driver for hbase mapreduce jobs.

Stores the plan for the move of an individual region.

An implementation of the LoadBalancer that assigns favored nodes for each region.

This is a best effort load balancer.

HFileLink cleaner that determines if a hfile should be deleted.

Log cleaner that uses the timestamp of the wal to determine if it should be deleted.

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

This class manages the procedure of taking and restoring snapshots.

ProcedureWALPrettyPrinter prints the contents of a given ProcedureWAL file

Base class for RowProcessor with some default implementations.

A RegionSplitPolicy implementation which splits a region as soon as any of its store files exceeds a maximum configurable size.

A RegionSplitPolicy that disables region splits.

A FlushPolicy that only flushes store larger a given threshold.

HRegionServer makes a set of HRegions available to clients.

This is a special ScannerContext subclass that is designed to be used globally when limits should not be enforced during invocations of InternalScanner.next(java.util.List) or InternalScanner.next(java.util.List).

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".

A Store data file.

The storage engine that implements the stripe-based store/compaction scheme.

This class holds all logical details necessary to run a compaction.

A throughput controller which uses the follow schema to limit throughput If compaction pressure is greater than 1.0, no limitation. In off peak hours, use a fixed throughput limitation "hbase.hstore.compaction.throughput.offpeak" In normal hours, the max throughput is tune between "hbase.hstore.compaction.throughput.lower.bound" and "hbase.hstore.compaction.throughput.higher.bound", using the formula "lower + (higer - lower) * compactionPressure", where compactionPressure is in range [0.0, 1.0]

This manager class handles the work dealing with snapshots for a HRegionServer.

Context that holds the various dictionaries for compression in WAL.

Deprecated. 

Writer for protobuf-based WAL.

WALEdit: Used in HBase's transaction log (WAL) to represent the collection of edits (KeyValue objects) corresponding to a single transaction.

A Base implementation for ReplicationEndpoints.

A WALEntryFilter which contains multiple filters and applies them in chain order

ReplicationPeer manages enabled / disabled state for the peer.

A Filter for WAL entries before being sent over to replication.

Implementation of a log cleaner that checks if a log is still scheduled for replication before deleting it when its TTL is over.

This class is for maintaining the various replication statistics for a source and publishing them through the metrics interfaces.

Main class for launching REST gateway as a servlet hosted by Jetty.

Provides basic authorization checks for data access and administrative operations.

Coprocessor that has both the MasterObserver and RegionObserver implemented that supports in visibility labels

ThriftServer- this class starts up a Thrift server which implements the Hbase API specified in the Hbase.thrift IDL file.

ThriftServer - this class starts up a Thrift server which implements the HBase API specified in the HbaseClient.thrift IDL file.

Compression validation test.

Generate a classpath string containing any jars required by mapreduce jobs.

This code is used to rebuild meta off line from file system data.

A Key for an entry in the change log.

HBase's version of ZooKeeper's QuorumPeer.

Tool for running ZookeeperMain from HBase by reading a ZooKeeper server from HBase XML configuration.