Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.coordination | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.handler | |
org.apache.hadoop.hbase.snapshot | |
org.apache.hadoop.hbase.util |
Modifier and Type | Field and Description |
---|---|
protected HRegion |
HBaseTestCase.meta
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
HRegion |
HBaseTestingUtility.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor htd)
Create an HRegion.
|
HRegion |
HBaseTestingUtility.createLocalHRegion(byte[] tableName,
byte[] startKey,
byte[] stopKey,
java.lang.String callingMethod,
Configuration conf,
boolean isReadOnly,
Durability durability,
WAL wal,
byte[]... families) |
HRegion |
HBaseTestingUtility.createLocalHRegion(HRegionInfo info,
HTableDescriptor desc)
Create an HRegion that writes to the local tmp dirs
|
HRegion |
HBaseTestingUtility.createLocalHRegion(HRegionInfo info,
HTableDescriptor desc,
WAL wal)
Create an HRegion that writes to the local tmp dirs with specified wal
|
HRegion |
HBaseTestingUtility.createLocalHRegion(HTableDescriptor desc,
byte[] startKey,
byte[] endKey)
Create an HRegion that writes to the local tmp dirs
|
HRegion |
HBaseTestCase.createNewHRegion(HTableDescriptor desc,
byte[] startKey,
byte[] endKey)
Deprecated.
You must call close on the returned region and then close on the log file
it created.
|
HRegion |
HBaseTestCase.createNewHRegion(HTableDescriptor desc,
byte[] startKey,
byte[] endKey,
Configuration conf)
Deprecated.
|
static HRegion |
HBaseTestingUtility.createRegionAndWAL(HRegionInfo info,
Path rootDir,
Path walRootDir,
Configuration conf,
HTableDescriptor htd)
Create a region with it's own WAL.
|
static HRegion |
HBaseTestingUtility.createRegionAndWAL(HRegionInfo info,
Path rootDir,
Path walRootDir,
Configuration conf,
HTableDescriptor htd,
boolean initialize)
Create a region with it's own WAL.
|
HRegion |
HBaseTestingUtility.createTestRegion(java.lang.String tableName,
HColumnDescriptor hcd) |
HRegion |
HBaseTestingUtility.getSplittableRegion(TableName tableName,
int maxAttempts) |
protected HRegion |
HBaseTestCase.openClosedRegion(HRegion closedRegion)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<HRegion> |
MiniHBaseCluster.findRegionsForTable(TableName tableName) |
java.util.List<HRegion> |
MiniHBaseCluster.getRegions(byte[] tableName) |
java.util.List<HRegion> |
MiniHBaseCluster.getRegions(TableName tableName) |
Modifier and Type | Method and Description |
---|---|
protected void |
HBaseTestCase.assertResultEquals(HRegion region,
byte[] row,
byte[] family,
byte[] qualifier,
long timestamp,
byte[] value)
Deprecated.
|
static void |
HBaseTestingUtility.closeRegionAndWAL(HRegion r)
Close both the HRegion
r and it's underlying WAL. |
static ZooKeeperWatcher |
HBaseTestingUtility.createAndForceNodeToOpenedState(HBaseTestingUtility TEST_UTIL,
HRegion region,
ServerName serverName)
Creates a znode with OPENED state.
|
int |
HBaseTestingUtility.loadRegion(HRegion r,
byte[] f) |
int |
HBaseTestingUtility.loadRegion(HRegion r,
byte[] f,
boolean flush)
Load region with rows from 'aaa' to 'zzz'.
|
protected HRegion |
HBaseTestCase.openClosedRegion(HRegion closedRegion)
Deprecated.
|
void |
HBaseTestingUtility.verifyNumericRows(HRegion region,
byte[] f,
int startRow,
int endRow) |
void |
HBaseTestingUtility.verifyNumericRows(HRegion region,
byte[] f,
int startRow,
int endRow,
boolean present) |
Constructor and Description |
---|
HRegionIncommon(HRegion HRegion) |
Modifier and Type | Method and Description |
---|---|
void |
RegionMergeCoordination.completeRegionMergeTransaction(RegionServerServices services,
HRegionInfo merged,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails rmd,
HRegion mergedRegion)
Finish off merge transaction
|
void |
ZkRegionMergeCoordination.completeRegionMergeTransaction(RegionServerServices services,
HRegionInfo mergedRegionInfo,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails rmd,
HRegion mergedRegion) |
void |
CloseRegionCoordination.setClosedState(HRegion region,
ServerName sn,
CloseRegionCoordination.CloseRegionDetails crd)
Called after region is closed to notify all interesting parties / "register"
region as finally closed.
|
void |
ZkCloseRegionCoordination.setClosedState(HRegion region,
ServerName sn,
CloseRegionCoordination.CloseRegionDetails crd)
In ZK-based version we do some znodes transitioning.
|
void |
SplitTransactionCoordination.startSplitTransaction(HRegion parent,
ServerName serverName,
HRegionInfo hri_a,
HRegionInfo hri_b)
init coordination for split transaction
|
void |
ZKSplitTransactionCoordination.startSplitTransaction(HRegion parent,
ServerName serverName,
HRegionInfo hri_a,
HRegionInfo hri_b)
Creates a new ephemeral node in the PENDING_SPLIT state for the specified region.
|
boolean |
OpenRegionCoordination.transitionToOpened(HRegion r,
OpenRegionCoordination.OpenRegionDetails ord)
Tries to move regions to OPENED state.
|
boolean |
ZkOpenRegionCoordination.transitionToOpened(HRegion r,
OpenRegionCoordination.OpenRegionDetails ord) |
void |
RegionMergeCoordination.waitForRegionMergeTransaction(RegionServerServices services,
HRegionInfo mergedRegionInfo,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails details)
Get everything ready for region merge
|
void |
ZkRegionMergeCoordination.waitForRegionMergeTransaction(RegionServerServices services,
HRegionInfo mergedRegionInfo,
HRegion region_a,
HRegion region_b,
RegionMergeCoordination.RegionMergeDetails details)
Wait for the merging node to be transitioned from pending_merge
to merging by master.
|
Modifier and Type | Class and Description |
---|---|
static class |
TestRegionObserverScannerOpenHook.CompactionCompletionNotifyingRegion |
Modifier and Type | Method and Description |
---|---|
static void |
TestRowProcessorEndpoint.RowProcessorEndpoint.doScan(HRegion region,
Scan scan,
java.util.List<Cell> result) |
void |
TestRowProcessorEndpoint.RowProcessorEndpoint.IncrementCounterProcessor.process(long now,
HRegion region,
java.util.List<Mutation> mutations,
WALEdit walEdit) |
void |
TestRowProcessorEndpoint.RowProcessorEndpoint.FriendsOfFriendsProcessor.process(long now,
HRegion region,
java.util.List<Mutation> mutations,
WALEdit walEdit) |
void |
TestRowProcessorEndpoint.RowProcessorEndpoint.RowSwapProcessor.process(long now,
HRegion region,
java.util.List<Mutation> mutations,
WALEdit walEdit) |
void |
TestRowProcessorEndpoint.RowProcessorEndpoint.TimeoutProcessor.process(long now,
HRegion region,
java.util.List<Mutation> mutations,
WALEdit walEdit) |
Modifier and Type | Class and Description |
---|---|
static class |
TestAtomicOperation.MockHRegion |
Modifier and Type | Field and Description |
---|---|
protected HRegion |
FlushPolicy.region
The region configured for this flush policy.
|
protected HRegion |
HStore.region |
protected HRegion |
RegionSplitPolicy.region
The region configured for this split policy.
|
protected HRegion |
TestAtomicOperation.AtomicOperation.region |
Modifier and Type | Method and Description |
---|---|
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal) |
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
boolean ignoreWAL)
Convenience method creating new HRegions.
|
static HRegion |
HRegion.createHRegion(HRegionInfo info,
Path rootDir,
Path tableDir,
Configuration conf,
HTableDescriptor hTableDescriptor,
WAL wal,
boolean initialize,
boolean ignoreWAL)
Convenience method creating new HRegions.
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services)
Run the transaction.
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services,
User user) |
HRegion |
HStore.getHRegion() |
static HRegion |
TestHRegion.initHRegion(byte[] tableName,
byte[] startKey,
byte[] stopKey,
java.lang.String callingMethod,
Configuration conf,
boolean isReadOnly,
byte[]... families) |
static HRegion |
TestHRegion.initHRegion(byte[] tableName,
byte[] startKey,
byte[] stopKey,
java.lang.String callingMethod,
Configuration conf,
boolean isReadOnly,
Durability durability,
WAL wal,
byte[]... families) |
static HRegion |
TestHRegion.initHRegion(byte[] tableName,
java.lang.String callingMethod,
Configuration conf,
boolean isReadOnly,
byte[]... families) |
static HRegion |
TestHRegion.initHRegion(byte[] tableName,
java.lang.String callingMethod,
Configuration conf,
byte[]... families) |
HRegion |
TestFailedAppendAndSync.initHRegion(TableName tableName,
byte[] startKey,
byte[] stopKey,
WAL wal) |
static HRegion |
TestHRegion.initHRegion(TableName tableName,
java.lang.String callingMethod,
Configuration conf,
byte[]... families) |
static HRegion |
HRegion.merge(HRegion a,
HRegion b)
Merge two regions whether they are adjacent or not.
|
static HRegion |
HRegion.mergeAdjacent(HRegion srcA,
HRegion srcB)
Merge two HRegions.
|
protected HRegion |
HRegion.openHRegion(CancelableProgressable reporter)
Open HRegion.
|
static HRegion |
HRegion.openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Configuration conf,
FileSystem fs,
Path rootDir,
Path tableDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(HRegion other,
CancelableProgressable reporter)
Useful when reopening a closed region (normally for unit tests)
|
static HRegion |
HRegion.openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf)
Open a Region.
|
static HRegion |
HRegion.openHRegion(Path rootDir,
HRegionInfo info,
HTableDescriptor htd,
WAL wal,
Configuration conf,
RegionServerServices rsServices,
CancelableProgressable reporter)
Open a Region.
|
HRegion |
RegionMergeTransactionImpl.stepsBeforePONR(Server server,
RegionServerServices services,
boolean testing) |
Modifier and Type | Method and Description |
---|---|
static void |
HRegion.addRegionToMETA(HRegion meta,
HRegion r)
Inserts a new region's meta information into the passed
meta region. |
static void |
HRegion.closeHRegion(HRegion r)
This will do the necessary cleanup a call to
createHRegion(HRegionInfo, Path, Configuration, HTableDescriptor)
requires. |
protected void |
ConstantSizeRegionSplitPolicy.configureForRegion(HRegion region) |
protected void |
DelimitedKeyPrefixRegionSplitPolicy.configureForRegion(HRegion region) |
protected void |
FlushLargeStoresPolicy.configureForRegion(HRegion region) |
protected void |
FlushPolicy.configureForRegion(HRegion region)
Upon construction, this method will be called with the region to be governed.
|
protected void |
IncreasingToUpperBoundRegionSplitPolicy.configureForRegion(HRegion region) |
protected void |
KeyPrefixRegionSplitPolicy.configureForRegion(HRegion region) |
protected void |
RegionSplitPolicy.configureForRegion(HRegion region)
Upon construction, this method will be called with the region
to be governed.
|
static FlushPolicy |
FlushPolicyFactory.create(HRegion region,
Configuration conf)
Create the FlushPolicy configured for the given table.
|
static RegionSplitPolicy |
RegionSplitPolicy.create(HRegion region,
Configuration conf)
Create the RegionSplitPolicy configured for the given table.
|
static HRegion |
HRegion.merge(HRegion a,
HRegion b)
Merge two regions whether they are adjacent or not.
|
static HRegion |
HRegion.mergeAdjacent(HRegion srcA,
HRegion srcB)
Merge two HRegions.
|
static HRegion |
HRegion.openHRegion(HRegion other,
CancelableProgressable reporter)
Useful when reopening a closed region (normally for unit tests)
|
void |
BaseRowProcessor.postBatchMutate(HRegion region) |
void |
RowProcessor.postBatchMutate(HRegion region)
The hook to be executed after the process() and applying the Mutations to region.
|
void |
RegionServerCoprocessorHost.postMerge(HRegion regionA,
HRegion regionB,
HRegion mergedRegion) |
void |
RegionServerCoprocessorHost.postMergeCommit(HRegion regionA,
HRegion regionB,
HRegion mergedRegion) |
void |
BaseRowProcessor.postProcess(HRegion region,
WALEdit walEdit,
boolean success) |
void |
RowProcessor.postProcess(HRegion region,
WALEdit walEdit,
boolean success)
The hook to be executed after process() and applying the Mutations to region.
|
void |
RegionServerCoprocessorHost.postRollBackMerge(HRegion regionA,
HRegion regionB) |
void |
BaseRowProcessor.preBatchMutate(HRegion region,
WALEdit walEdit) |
void |
RowProcessor.preBatchMutate(HRegion region,
WALEdit walEdit)
The hook to be executed after the process() but before applying the Mutations to region.
|
boolean |
RegionServerCoprocessorHost.preMerge(HRegion regionA,
HRegion regionB) |
boolean |
RegionServerCoprocessorHost.preMergeCommit(HRegion regionA,
HRegion regionB,
java.util.List<Mutation> metaEntries) |
void |
BaseRowProcessor.preProcess(HRegion region,
WALEdit walEdit) |
void |
RowProcessor.preProcess(HRegion region,
WALEdit walEdit)
The hook to be executed before process().
|
void |
RegionServerCoprocessorHost.preRollBackMerge(HRegion regionA,
HRegion regionB) |
void |
RowProcessor.process(long now,
HRegion region,
java.util.List<Mutation> mutations,
WALEdit walEdit)
HRegion handles the locks and MVCC and invokes this method properly.
|
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion)
Deprecated.
|
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion,
User user) |
Constructor and Description |
---|
AtomicOperation(HRegion region,
int numOps,
java.util.concurrent.atomic.AtomicLong timeStamps,
java.util.concurrent.atomic.AtomicInteger failures) |
HMobStore(HRegion region,
HColumnDescriptor family,
Configuration confParam) |
HStore(HRegion region,
HColumnDescriptor family,
Configuration confParam)
Constructor
|
Incrementer(HRegion region,
int threadNumber,
int amount,
int numIncrements) |
MetricsRegionWrapperImpl(HRegion region) |
Putter(HRegion region,
int threadNumber,
int numOps) |
Constructor and Description |
---|
RegionReplicaFlushHandler(Server server,
ClusterConnection connection,
RpcRetryingCallerFactory rpcRetryingCallerFactory,
RpcControllerFactory rpcControllerFactory,
int operationTimeout,
HRegion region) |
Modifier and Type | Method and Description |
---|---|
void |
SnapshotManifest.addRegion(HRegion region)
Creates a 'manifest' for the specified region, by reading directly from the HRegion object.
|
Modifier and Type | Method and Description |
---|---|
static HRegion |
HBaseFsckRepair.createHDFSRegionDir(Configuration conf,
HRegionInfo hri,
HTableDescriptor htd)
Creates, flushes, and closes a new region.
|
HRegion |
MetaUtils.getMetaRegion() |
Modifier and Type | Method and Description |
---|---|
void |
ModifyRegionUtils.RegionFillTask.fillRegion(HRegion region) |
static boolean |
ServerRegionReplicaUtil.isReadOnly(HRegion region)
Returns whether this region replica can accept writes.
|
static boolean |
ServerRegionReplicaUtil.shouldReplayRecoveredEdits(HRegion region)
Returns whether to replay the recovered edits to flush the results.
|