Package org.apache.hadoop.hbase.security.visibility

Class VisibilityReplication

java.lang.Object

org.apache.hadoop.hbase.security.visibility.VisibilityReplication

All Implemented Interfaces:

Coprocessor, RegionServerCoprocessor, RegionServerObserver

@Private
public class VisibilityReplication
extends Object
implements RegionServerCoprocessor, RegionServerObserver

A RegionServerObserver impl that provides the custom VisibilityReplicationEndpoint. This class should be configured as the 'hbase.coprocessor.regionserver.classes' for the visibility tags to be replicated as string. The value for the configuration should be 'org.apache.hadoop.hbase.security.visibility.VisibilityController$VisibilityReplication'.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

Coprocessor.State

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private VisibilityLabelService	visibilityLabelService

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor	Description
VisibilityReplication()

Method Summary

Modifier and Type	Method	Description
Optional<RegionServerObserver>	getRegionServerObserver()
ReplicationEndpoint	postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx, ReplicationEndpoint endpoint)	This will be called after the replication endpoint is instantiated.
void	start(CoprocessorEnvironment env)	Called by the CoprocessorEnvironment during it's own startup to initialize the coprocessor.
void	stop(CoprocessorEnvironment env)	Called by the CoprocessorEnvironment during it's own shutdown to stop the coprocessor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

getServices

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionServerObserver

postClearCompactionQueues, postClearRegionBlockCache, postExecuteProcedures, postReplicateLogEntries, postReplicationSinkBatchMutate, postRollWALWriterRequest, postUpdateRegionServerConfiguration, preClearCompactionQueues, preClearRegionBlockCache, preExecuteProcedures, preReplicateLogEntries, preReplicationSinkBatchMutate, preRollWALWriterRequest, preStopRegionServer, preUpdateRegionServerConfiguration

Field Details

conf

private org.apache.hadoop.conf.Configuration conf

visibilityLabelService

private VisibilityLabelService visibilityLabelService

Constructor Details

VisibilityReplication

public VisibilityReplication()

Method Details

start

public void start(CoprocessorEnvironment env)
           throws IOException

Description copied from interface: Coprocessor

Called by the CoprocessorEnvironment during it's own startup to initialize the coprocessor.

Specified by:

start in interface Coprocessor

Throws:

IOException

stop

public void stop(CoprocessorEnvironment env)
          throws IOException

Description copied from interface: Coprocessor

Called by the CoprocessorEnvironment during it's own shutdown to stop the coprocessor.

Specified by:

stop in interface Coprocessor

Throws:

IOException

getRegionServerObserver

public Optional<RegionServerObserver> getRegionServerObserver()

Specified by:

getRegionServerObserver in interface RegionServerCoprocessor

postCreateReplicationEndPoint

public ReplicationEndpoint postCreateReplicationEndPoint(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
 ReplicationEndpoint endpoint)

Description copied from interface: RegionServerObserver

This will be called after the replication endpoint is instantiated.

Specified by:

postCreateReplicationEndPoint in interface RegionServerObserver

Parameters:

ctx - the environment to interact with the framework and region server.

endpoint - - the base endpoint for replication

Returns:

the endpoint to use during replication.