Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.constraint |
Restrict the domain of a data attribute, often times to fulfill business rules/requirements.
|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.coprocessor.example | |
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility methods.
|
org.apache.hadoop.hbase.master | |
org.apache.hadoop.hbase.master.handler | |
org.apache.hadoop.hbase.namespace | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.replication | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.security.token | |
org.apache.hadoop.hbase.security.visibility | |
org.apache.hadoop.hbase.snapshot | |
org.apache.hadoop.hbase.tool | |
org.apache.hadoop.hbase.util |
Modifier and Type | Class and Description |
---|---|
class |
JMXListener
Pluggable JMX Agent for HBase(to fix the 2 random TCP ports issue
of the out-of-the-box JMX Agent):
1)connector port can share with the registry port if SSL is OFF
2)support password authentication
3)support subset of SSL (with default configuration)
|
Modifier and Type | Method and Description |
---|---|
Coprocessor |
CoprocessorEnvironment.getInstance() |
Modifier and Type | Class and Description |
---|---|
static class |
TestClientOperationInterrupt.TestCoprocessor |
static class |
TestHCM.SleepAndFailFirstTime
This copro sleeps 20 second.
|
static class |
TestReplicasClient.SlowMeCopro
This copro is used to synchronize the tests.
|
static class |
TestReplicaWithCluster.SlowMeCopro
This copro is used to synchronize the tests.
|
Modifier and Type | Class and Description |
---|---|
class |
ConstraintProcessor
Processes multiple
Constraints on a given table. |
Modifier and Type | Interface and Description |
---|---|
interface |
BulkLoadObserver
Coprocessors implement this interface to observe and mediate bulk load operations.
|
interface |
EndpointObserver
Coprocessors implement this interface to observe and mediate endpoint invocations
on a region.
|
interface |
MasterObserver
Defines coprocessor hooks for interacting with operations on the
HMaster process. |
interface |
RegionObserver
Coprocessors implement this interface to observe and mediate client actions
on the region.
|
interface |
RegionServerObserver |
interface |
WALObserver
It's provided to have a way for coprocessors to observe, rewrite,
or skip WALEdits as they are being written to the WAL.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregateImplementation<T,S,P extends Message,Q extends Message,R extends Message>
A concrete AggregateProtocol implementation.
|
class |
BaseMasterAndRegionObserver |
class |
BaseMasterObserver |
class |
BaseRegionObserver
An abstract class that implements RegionObserver.
|
class |
BaseRegionServerObserver
An abstract class that implements RegionServerObserver.
|
class |
BaseRowProcessorEndpoint<S extends Message,T extends Message>
This class demonstrates how to implement atomic read-modify-writes
using
Region.processRowsWithLocks(org.apache.hadoop.hbase.regionserver.RowProcessor<?, ?>) and Coprocessor endpoints. |
class |
BaseWALObserver
An abstract class that implements WALObserver.
|
class |
ColumnAggregationEndpoint
The aggregation implementation at a region.
|
class |
ColumnAggregationEndpointNullResponse
Test coprocessor endpoint that always returns
null for requests to the last region
in the table. |
class |
ColumnAggregationEndpointWithErrors
Test coprocessor endpoint that always throws a
DoNotRetryIOException for requests on
the last region in the table. |
class |
MultiRowMutationEndpoint
This class demonstrates how to implement atomic multi row transactions using
HRegion.mutateRowsWithLocks(java.util.Collection, java.util.Collection)
and Coprocessor endpoints. |
class |
ProtobufCoprocessorService
Test implementation of a coprocessor endpoint exposing the
TestRpcServiceProtos.TestProtobufRpcProto service methods. |
class |
SampleRegionWALObserver
Class for testing WALObserver coprocessor.
|
class |
SimpleRegionObserver
A sample region observer that tests the RegionObserver interface.
|
static class |
SimpleRegionObserver.Legacy
This implementation should trigger our legacy support because it does not directly
implement the newer API calls.
|
static class |
TestCoprocessorConfiguration.SystemCoprocessor |
static class |
TestCoprocessorConfiguration.TableCoprocessor |
static class |
TestCoprocessorInterface.CoprocessorII |
static class |
TestCoprocessorInterface.CoprocessorImpl |
static class |
TestCoprocessorStop.FooCoprocessor |
static class |
TestMasterCoprocessorExceptionWithAbort.BuggyMasterObserver |
static class |
TestMasterCoprocessorExceptionWithRemove.BuggyMasterObserver |
static class |
TestMasterObserver.CPMasterObserver |
static class |
TestOpenTableInCoprocessor.CustomThreadPoolCoprocessor
Coprocessor that creates an HTable with a pool to write to another table
|
static class |
TestOpenTableInCoprocessor.SendToOtherTableCoprocessor
Custom coprocessor that just copies the write to another table.
|
static class |
TestRegionObserverBypass.TestCoprocessor |
static class |
TestRegionObserverInterface.EvenOnlyCompactor |
static class |
TestRegionObserverScannerOpenHook.EmptyRegionObsever
Do the same logic as the
BaseRegionObserver . |
static class |
TestRegionObserverScannerOpenHook.NoDataFromCompaction
Don't allow any data to be written out in the compaction by creating a custom
StoreScanner . |
static class |
TestRegionObserverScannerOpenHook.NoDataFromFlush
Don't allow any data in a flush by creating a custom
StoreScanner . |
static class |
TestRegionObserverScannerOpenHook.NoDataFromScan
Don't return any data from a scan by creating a custom
StoreScanner . |
static class |
TestRegionObserverStacking.ObserverA |
static class |
TestRegionObserverStacking.ObserverB |
static class |
TestRegionObserverStacking.ObserverC |
static class |
TestRegionServerCoprocessorExceptionWithAbort.BuggyRegionObserver |
static class |
TestRegionServerCoprocessorExceptionWithAbort.FailedInitializationObserver |
static class |
TestRegionServerCoprocessorExceptionWithRemove.BuggyRegionObserver |
static class |
TestRegionServerObserver.CPRegionServerObserver |
static class |
TestRowProcessorEndpoint.RowProcessorEndpoint<S extends Message,T extends Message>
This class defines two RowProcessors:
IncrementCounterProcessor and FriendsOfFriendsProcessor.
|
Modifier and Type | Field and Description |
---|---|
Coprocessor |
CoprocessorHost.Environment.impl
The coprocessor
|
Modifier and Type | Method and Description |
---|---|
<T extends Coprocessor> |
CoprocessorHost.findCoprocessors(Class<T> cls)
Find list of coprocessors that extend/implement the given class/interface
|
Modifier and Type | Method and Description |
---|---|
Coprocessor |
CoprocessorHost.findCoprocessor(String className)
Find a coprocessor implementation by class name
|
Coprocessor |
CoprocessorHost.Environment.getInstance() |
Modifier and Type | Method and Description |
---|---|
abstract E |
CoprocessorHost.createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int sequence,
Configuration conf)
Called when a new Coprocessor class is loaded
|
Modifier and Type | Method and Description |
---|---|
protected void |
CoprocessorHost.legacyWarning(Class<? extends Coprocessor> clazz,
String message)
limits the amount of logging to once per coprocessor class.
|
protected static boolean |
CoprocessorHost.useLegacyMethod(Class<? extends Coprocessor> clazz,
String methodName,
Class<?>... parameterTypes)
Used to gracefully handle fallback to deprecated methods when we
evolve coprocessor APIs.
|
Constructor and Description |
---|
Environment(Coprocessor impl,
int priority,
int seq,
Configuration conf)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
BulkDeleteEndpoint
Defines a protocol to delete data in bulk based on a scan.
|
class |
RowCountEndpoint
Sample coprocessor endpoint exposing a Service interface for counting rows and key values.
|
class |
ZooKeeperScanPolicyObserver
This is an example showing how a RegionObserver could configured
via ZooKeeper in order to control a Region compaction, flush, and scan policy.
|
Modifier and Type | Class and Description |
---|---|
static class |
IntegrationTestBulkLoad.SlowMeCoproScanOperations |
static class |
TestImportTSVWithOperationAttributes.OperationAttributesTestController |
static class |
TestImportTSVWithTTLs.TTLCheckingObserver |
Modifier and Type | Class and Description |
---|---|
static class |
TestAssignmentManagerOnCluster.MyRegionObserver |
static class |
TestTableLockManager.TestAlterAndDisableMasterObserver |
static class |
TestTableLockManager.TestLockTimeoutExceptionMasterObserver |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.master.MasterCoprocessorHost.MasterEnvironment |
MasterCoprocessorHost.createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
Configuration conf) |
Modifier and Type | Class and Description |
---|---|
static class |
TestEnableTableHandler.MasterSyncObserver |
Modifier and Type | Class and Description |
---|---|
static class |
TestNamespaceAuditor.CPRegionServerObserver |
static class |
TestNamespaceAuditor.CustomObserver |
static class |
TestNamespaceAuditor.MasterSyncObserver |
Modifier and Type | Class and Description |
---|---|
class |
NoOpScanPolicyObserver
RegionObserver that just reimplements the default behavior,
in order to validate that all the necessary APIs for this are public
This observer is also used in
TestFromClientSideWithCoprocessor and
TestCompactionWithCoprocessor to make sure that a wide range
of functionality still behaves as expected. |
static class |
TestHRegionServerBulkLoad.MyObserver |
static class |
TestScannerRetriableFailure.FaultyScannerObserver |
static class |
TestServerCustomProtocol.PingHandler |
static class |
TestSplitTransaction.CustomObserver |
static class |
TestSplitTransactionOnCluster.FailingSplitRegionObserver |
static class |
TestSplitTransactionOnCluster.MockedRegionObserver |
static class |
TestTags.TestCoprocessorForTags |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost.RegionEnvironment |
RegionCoprocessorHost.createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
Configuration conf) |
org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment |
RegionServerCoprocessorHost.createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int sequence,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.regionserver.wal.WALCoprocessorHost.WALEnvironment |
WALCoprocessorHost.createEnvironment(Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
Configuration conf) |
Modifier and Type | Class and Description |
---|---|
static class |
TestMasterReplication.CoprocessorCounter
Use a coprocessor to count puts and deletes.
|
static class |
TestReplicationWithTags.TestCoprocessorForTagsAtSink |
static class |
TestReplicationWithTags.TestCoprocessorForTagsAtSource |
Modifier and Type | Class and Description |
---|---|
static class |
TestRegionReplicaReplicationEndpointNoMaster.WALEditCopro |
Modifier and Type | Class and Description |
---|---|
class |
AccessController
Provides basic authorization checks for data access and administrative
operations.
|
class |
SecureBulkLoadEndpoint
Coprocessor service for bulk loads in secure mode.
|
static class |
SecureTestUtil.MasterSyncObserver |
static class |
TestAccessController.PingCoprocessor |
static class |
TestAccessController2.MyAccessController |
Modifier and Type | Class and Description |
---|---|
class |
TokenProvider
Provides a service for obtaining authentication tokens via the
AuthenticationProtos AuthenticationService coprocessor service. |
Modifier and Type | Class and Description |
---|---|
static class |
TestVisibilityLabelsReplication.SimpleCP |
static class |
TestVisibilityLabelsReplication.TestCoprocessorForTagsAtSink |
class |
VisibilityController
Coprocessor that has both the MasterObserver and RegionObserver implemented that supports in
visibility labels
|
static class |
VisibilityController.VisibilityReplication
A RegionServerObserver impl that provides the custom
VisibilityReplicationEndpoint.
|
Modifier and Type | Class and Description |
---|---|
static class |
TestSnapshotClientRetries.MasterSyncObserver |
Modifier and Type | Class and Description |
---|---|
class |
WriteSinkCoprocessor
This coprocessor 'shallows' all the writes.
|
Modifier and Type | Class and Description |
---|---|
static class |
TestCoprocessorScanPolicy.ScanObserver |
static class |
TestHBaseFsck.MasterSyncObserver |