Package org.apache.hadoop.hbase.regionserver

Implementing classes of this interface will be used for the tracking and enforcement of columns and numbers of versions and timeToLive during the course of a Get or Scan operation.

This interface is used for the tracking and enforcement of Deletes during the course of a Get or Scan operation.

Request a flush.

Makes the decision regarding proper sizing of the heap memory.

Scanner that returns the next KeyValue.

LeaseListener is an interface meant to be implemented by users of the Leases class.

This interface will be implemented by a MetricsSource that will export metrics from multiple regions into the hadoop metrics system.

Interface of a factory to create Metrics Sources used inside of regionservers.

This interface will be implemented to allow single regions to push metrics into MetricsRegionAggregateSource that will in turn push data to the Hadoop metrics system.

Interface to Map of online regions.

Listener class to enable callers of bulkLoadHFile() to perform any necessary pre/post processing of a given bulkload call

Row lock held by a given thread.

Split transaction journal entry

RegionScanner describes iterators over rows in an HRegion.

Gateway to Cluster Replication.

A source for a replication stream has to expose this service.

A factory class that constructs an RpcScheduler.

Objects implementing this interface actually do the task that has been acquired by a SplitLogWorker.

Split transaction journal entry

Interface for objects that hold a column family in a Region.

Manages the store files and basic metadata about that that determines the logical structure (e.g.

Base class for RowProcessor with some default implementations.

Simple wrapper for a byte buffer and a counter.

Input format that uses store files block location as input split locality.

Class responsible to execute the Compaction on the specified path.

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

The MemStore holds in-memory modifications to the Store.

Default implementation of StoreFlusher.

A RegionSplitPolicy that disables region splits.

A FlushPolicy that always flushes all stores for a given region.

A flush policy determines the stores that need to be flushed when flushing a region.

State and utility processing HRegion.getClosestRowBefore(byte[], byte[]).

POJO which holds the result of memory tuning done by HeapMemoryTuner implementation.

A chunk of memory out of which allocations are sliced.

Struct-like class that tracks the progress of a batch operation, accumulating status codes and tracking the index at which processing is proceeding.

HRegionServer makes a set of HRegions available to clients.

A Store holds a column family in a Region.

Split size is the number of regions that are on this server that all are of the same table, cubed, times 2x the region flush size OR the maximum region split size, whichever is smaller.

A custom RegionSplitPolicy implementing a SplitPolicy that groups rows by a prefix of the row-key This ensures that a region is not split "inside" a prefix of a row key.

This class tracks a single Lease.

The LruHashMap is a memory-aware HashMap with a configurable maximum memory footprint.

A pool of HeapMemStoreLAB.Chunk instances.

Thread that flushes cache on request NOTE: This class extends Thread rather than Chore because the sleep time can be interrupted when there is something to do, rather than the Chore sleep time which is invariant.

Datastructure used in the flush queue.

Holds details of the snapshot taken on a MemStore.

Factory to create MetricsRegionServerSource when given a MetricsRegionServerWrapper

Impl for exposing HRegionServer Information through Hadoop's metrics 2 system.

A MultiRowProcessor that performs multiple puts and deletes.

Write number and whether write has completed given out at start of a write transaction.

A "non-lazy" scanner which always does a real seek operation.

An implementation of HeapMemoryTuner which is not doing any tuning activity but just allows to continue with old style fixed proportions.

Implements the coprocessor environment and runtime support for coprocessors loaded within a Region.

Encapsulation of the environment of each coprocessor

Handles processing region merges.

RegionServerAccounting keeps record of some basic real time information about the Region Server.

Environment priority comparator.

Context for postOpenDeployTasks().

A split policy determines when a region should be split.

In ReversedKVScannerComparator, we compare the row of scanners' peek values first, sort bigger one before the smaller one.

ReversedStoreScanner extends from StoreScanner, and is used to support reversed scanning.

Implements the regionserver RPC services.

This class is responsible for the tracking and enforcement of Deletes during the course of a Scan operation.

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

The different fields that can be used as limits in calls to InternalScanner.next(java.util.List) and InternalScanner.next(java.util.List)

A query matcher that is specifically designed for the scan case.

Implementation of nonce manager that stores nonces in a hash map and cleans them up after some time; if nonce group/client ID is supplied, nonces are stored by client ID.

Manage regionserver shutdown hooks.

Constructs a SimpleRpcScheduler.

Handles processing region splits.

StoreEngine is a factory that can create the objects necessary for HStore to operate.

Useful comparators for comparing StoreFiles.

A StoreFile writer.

Describe a StoreFile (hfile, reference, link)

KeyValueScanner adaptor over the Reader.

Scanner scans both the memstore and the Store.

Base class for cell sink that separates the provided cells into multiple files.

MultiWriter that separates the cells based on target cell number per file and file count.

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

Stripe implementation of StoreFileManager.

An extension of ConcatenatedLists that has several peculiar properties.

The state class.

Stripe flush request wrapper based on boundaries.

Stripe flush request wrapper that writes a non-striped file.

Returns codes for delete result.

Operation enum is used in Region.startRegionOperation() to provide context for various checks before any region operation begins.

The possible states a scanner may be in following a call to InternalScanner.next(List)

Enum to distinguish general scan types.

Each enum is a step in the split transaction.

Thrown if we are asked to create a lease but lease on passed name already exists.

This exception is thrown when a region server is asked to open or close a region but it's already processing it

Thrown if the region server log directory exists (which indicates another region server is running at the same address)

Gets or Scans throw this exception if running without in-row scan flag set and row size appears to exceed max configured size (configurable via hbase.table.max.rowsize).

Thrown when a request contains a key which is not part of this region