Package org.apache.hadoop.hbase.security.access

Class BulkLoadReadOnlyController

java.lang.Object

org.apache.hadoop.hbase.security.access.AbstractReadOnlyController

org.apache.hadoop.hbase.security.access.BulkLoadReadOnlyController

All Implemented Interfaces:

Coprocessor, BulkLoadObserver, RegionCoprocessor

@LimitedPrivate("Configuration")
public class BulkLoadReadOnlyController
extends AbstractReadOnlyController
implements BulkLoadObserver, RegionCoprocessor

Nested Class Summary

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

Coprocessor.State

Field Summary

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

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor	Description
BulkLoadReadOnlyController()

Method Summary

Modifier and Type	Method	Description
Optional<BulkLoadObserver>	getBulkLoadObserver()
void	preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx)	Called as part of the SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call.
void	prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx)	Called as part of the SecureBulkLoadEndpoint.prepareBulkLoad() RPC call.

Methods inherited from class org.apache.hadoop.hbase.security.access.AbstractReadOnlyController

internalReadOnlyGuard, isWritableInReadOnlyMode, isWritableInReadOnlyMode, manageActiveClusterIdFile, start, stop

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, start, stop

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

getEndpointObserver, getRegionObserver

Constructor Details

BulkLoadReadOnlyController

public BulkLoadReadOnlyController()

Method Details

getBulkLoadObserver

public Optional<BulkLoadObserver> getBulkLoadObserver()

Specified by:

getBulkLoadObserver in interface RegionCoprocessor

prePrepareBulkLoad

public void prePrepareBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx)
                        throws IOException

Description copied from interface: BulkLoadObserver

Called as part of the SecureBulkLoadEndpoint.prepareBulkLoad() RPC call. It can't bypass the default action, e.g., ctx.bypass() won't have any effect. If you need to get the region or table name, get it from the ctx as follows: ctx.getEnvironment().getRegion(). Use getRegionInfo to fetch the encodedName and use getDescriptor() to get the tableName.

Specified by:

prePrepareBulkLoad in interface BulkLoadObserver

Parameters:

ctx - the environment to interact with the framework and master

Throws:

IOException

preCleanupBulkLoad

public void preCleanupBulkLoad(ObserverContext<RegionCoprocessorEnvironment> ctx)
                        throws IOException

Description copied from interface: BulkLoadObserver

Called as part of the SecureBulkLoadEndpoint.cleanupBulkLoad() RPC call. It can't bypass the default action, e.g., ctx.bypass() won't have any effect. If you need to get the region or table name, get it from the ctx as follows: ctx.getEnvironment().getRegion(). Use getRegionInfo to fetch the encodedName and use getDescriptor() to get the tableName.

Specified by:

preCleanupBulkLoad in interface BulkLoadObserver

Parameters:

ctx - the environment to interact with the framework and master

Throws:

IOException