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 |
---|---|
class |
BackupObserver
An Observer to facilitate backup operations
|
Modifier and Type | Class and Description |
---|---|
class |
BackupController
The current implementation checks if the backup system table
(hbase:backup) exists on HBasae Master startup and if it does not -
it creates it.
|
Modifier and Type | Class and Description |
---|---|
static class |
TestClientOperationInterrupt.TestCoprocessor |
static class |
TestFromClientSide.ExceptionInReseekRegionObserver
This is a coprocessor to inject a test failure so that a store scanner.reseek() call will
fail with an IOException() on the first call.
|
static class |
TestHCM.SleepAndFailFirstTime
This copro sleeps 20 second.
|
static class |
TestHCM.SleepCoprocessor |
static class |
TestMobCloneSnapshotFromClient.DelayFlushCoprocessor
This coprocessor is used to delay the flush.
|
static class |
TestReplicasClient.SlowMeCopro
This copro is used to synchronize the tests.
|
static class |
TestReplicaWithCluster.RegionServerHostingPrimayMetaRegionSlowCopro
This copro is used to slow down the primary meta region scan a bit
|
static class |
TestReplicaWithCluster.RegionServerHostingPrimayMetaRegionSlowOrStopCopro
This copro is used to slow down the primary meta region scan a bit
|
static class |
TestReplicaWithCluster.RegionServerStoppedCopro
This copro is used to simulate region server down exception for Get and Scan
|
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 | Field and Description |
---|---|
Coprocessor |
CoprocessorHost.Environment.impl
The coprocessor
|
Modifier and Type | Method and Description |
---|---|
<T extends Coprocessor> |
CoprocessorHost.findCoprocessors(java.lang.Class<T> cls)
Find list of coprocessors that extend/implement the given class/interface
|
Modifier and Type | Method and Description |
---|---|
Coprocessor |
CoprocessorHost.findCoprocessor(java.lang.String className)
Find a coprocessor implementation by class name
|
Coprocessor |
CoprocessorHost.Environment.getInstance() |
Modifier and Type | Method and Description |
---|---|
abstract E |
CoprocessorHost.createEnvironment(java.lang.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(java.lang.Class<? extends Coprocessor> clazz,
java.lang.String message)
limits the amount of logging to once per coprocessor class.
|
protected static boolean |
CoprocessorHost.useLegacyMethod(java.lang.Class<? extends Coprocessor> clazz,
java.lang.String methodName,
java.lang.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(java.lang.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 |
TestMobCompactor.CompactTwoLatestHfilesCopro
This copro overwrites the default compaction policy.
|
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 |
MasterSpaceQuotaObserver
An observer to automatically delete space quotas when a table/namespace
are deleted.
|
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 |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.hbase.regionserver.RegionCoprocessorHost.RegionEnvironment |
RegionCoprocessorHost.createEnvironment(java.lang.Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
Configuration conf) |
org.apache.hadoop.hbase.regionserver.RegionServerCoprocessorHost.RegionServerEnvironment |
RegionServerCoprocessorHost.createEnvironment(java.lang.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(java.lang.Class<?> implClass,
Coprocessor instance,
int priority,
int seq,
Configuration conf) |
Modifier and Type | Class and Description |
---|---|
class |
ReplicationObserver
An Observer to facilitate replication operations
|
Modifier and Type | Class and Description |
---|---|
class |
RSGroupAdminEndpoint |
Modifier and Type | Class and Description |
---|---|
class |
AccessController
Provides basic authorization checks for data access and administrative
operations.
|
class |
CoprocessorWhitelistMasterObserver
Master observer for restricting coprocessor assignments.
|
class |
SecureBulkLoadEndpoint
Coprocessor service for bulk loads in secure mode.
|
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 |
---|---|
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 |
---|---|
class |
WriteSinkCoprocessor
This coprocessor 'shallows' all the writes.
|