Uses of Class
org.apache.hadoop.hbase.security.User

Packages that use User

Package	Description
org.apache.hadoop.hbase
org.apache.hadoop.hbase.backup.master
org.apache.hadoop.hbase.client	Provides HBase Client
org.apache.hadoop.hbase.coprocessor	Table of Contents
org.apache.hadoop.hbase.ipc	Tools to help define network clients and servers.
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.procedure
org.apache.hadoop.hbase.master.snapshot
org.apache.hadoop.hbase.mob
org.apache.hadoop.hbase.procedure
org.apache.hadoop.hbase.procedure.flush
org.apache.hadoop.hbase.procedure2
org.apache.hadoop.hbase.regionserver
org.apache.hadoop.hbase.regionserver.compactions
org.apache.hadoop.hbase.replication.regionserver
org.apache.hadoop.hbase.security
org.apache.hadoop.hbase.security.access
org.apache.hadoop.hbase.security.provider
org.apache.hadoop.hbase.security.provider.example
org.apache.hadoop.hbase.security.token
org.apache.hadoop.hbase.security.visibility
org.apache.hadoop.hbase.snapshot
org.apache.hadoop.hbase.thrift2.client
org.apache.hadoop.hbase.util

Uses of User in org.apache.hadoop.hbase

Fields in org.apache.hadoop.hbase declared as User

Modifier and Type	Field	Description
private User	MiniHBaseCluster.MiniHBaseClusterRegionServer.user

Methods in org.apache.hadoop.hbase that return User

Modifier and Type	Method	Description
static User	HBaseTestingUtility.getDifferentUser(org.apache.hadoop.conf.Configuration c, String differentiatingSuffix)	Deprecated. This method clones the passed c configuration setting a new user into the clone.
static User	AuthUtil.loginClient(org.apache.hadoop.conf.Configuration conf)	Deprecated. For kerberized cluster, return login user (from kinit or from keytab if specified).
private static User	AuthUtil.loginClientAsService(org.apache.hadoop.conf.Configuration conf)	Deprecated. For kerberized cluster, return login user (from kinit or from keytab).
private static User	AuthUtil.loginFromKeytabAndReturnUser(UserProvider provider)	Deprecated.

Methods in org.apache.hadoop.hbase with parameters of type User

Modifier and Type	Method	Description
JVMClusterUtil.MasterThread	LocalHBaseCluster.addMaster(org.apache.hadoop.conf.Configuration c, int index, User user)
JVMClusterUtil.RegionServerThread	LocalHBaseCluster.addRegionServer(org.apache.hadoop.conf.Configuration config, int index, User user)
AsyncClusterConnection	HBaseTestingUtility.getAsyncConnection(User user)	Deprecated. Get a assigned AsyncClusterConnection to the cluster.
Connection	HBaseTestingUtility.getConnection(User user)	Deprecated. Get a assigned Connection to the cluster.
int	HBaseRpcServicesBase.getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user)

Uses of User in org.apache.hadoop.hbase.backup.master

Methods in org.apache.hadoop.hbase.backup.master with parameters of type User

Modifier and Type	Method	Description
void	LogRollMasterProcedureManager.checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user)

Uses of User in org.apache.hadoop.hbase.client

Fields in org.apache.hadoop.hbase.client declared as User

Modifier and Type	Field	Description
protected final User	AsyncConnectionImpl.user
private final User	ClusterIdFetcher.user
private final User	ConnectionRegistryRpcStubHolder.user

Methods in org.apache.hadoop.hbase.client that return User

Modifier and Type	Method	Description
User	AsyncConnectionImpl.getUser()

Methods in org.apache.hadoop.hbase.client with parameters of type User

Modifier and Type	Method	Description
(package private) static ConnectionRegistry	ConnectionRegistryFactory.create(URI uri, org.apache.hadoop.conf.Configuration conf, User user)	Returns the connection registry implementation to use, for the given connection url uri.
(package private) static ConnectionRegistry	ConnectionRegistryFactory.create(org.apache.hadoop.conf.Configuration conf, User user)	Returns the connection registry implementation to use.
ConnectionRegistry	ConnectionRegistryURIFactory.create(URI uri, org.apache.hadoop.conf.Configuration conf, User user)	Instantiate the ConnectionRegistry using the given parameters.
ConnectionRegistry	RpcConnectionRegistryURIFactory.create(URI uri, org.apache.hadoop.conf.Configuration conf, User user)
ConnectionRegistry	ZKConnectionRegistryURIFactory.create(URI uri, org.apache.hadoop.conf.Configuration conf, User user)
static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(URI uri, org.apache.hadoop.conf.Configuration conf, SocketAddress localAddress, User user)	Create a new AsyncClusterConnection instance.
static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(org.apache.hadoop.conf.Configuration conf, SocketAddress localAddress, User user)	Create a new AsyncClusterConnection instance.
private static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, SocketAddress localAddress, User user)
static AsyncClusterConnection	ClusterConnectionFactory.createAsyncClusterConnection(ConnectionRegistryEndpoint endpoint, org.apache.hadoop.conf.Configuration conf, SocketAddress localAddress, User user)	Create a new AsyncClusterConnection instance to be used at server side where we have a ConnectionRegistryEndpoint.
static CompletableFuture<AsyncConnection>	ConnectionFactory.createAsyncConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, User user)	Create a new AsyncConnection instance using the passed connectionUri, conf and user.
static CompletableFuture<AsyncConnection>	ConnectionFactory.createAsyncConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, User user, Map<String,byte[]> connectionAttributes)	Create a new AsyncConnection instance using the passed connectionUri, conf and user.
static CompletableFuture<AsyncConnection>	ConnectionFactory.createAsyncConnection(org.apache.hadoop.conf.Configuration conf, User user)	Create a new AsyncConnection instance using the passed conf and user.
static CompletableFuture<AsyncConnection>	ConnectionFactory.createAsyncConnection(org.apache.hadoop.conf.Configuration conf, User user, Map<String,byte[]> connectionAttributes)	Create a new AsyncConnection instance using the passed conf and user.
static Connection	ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user)	Create a new Connection instance using the passed conf instance.
static Connection	ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, Map<String,byte[]> connectionAttributes)	Create a new Connection instance using the passed conf instance.
static Connection	ConnectionFactory.createConnection(URI connectionUri, org.apache.hadoop.conf.Configuration conf, User user)	Create a new Connection instance using the passed conf instance.
static Connection	ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user)	Create a new Connection instance using the passed conf instance.
static Connection	ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, Map<String,byte[]> connectionAttributes)	Create a new Connection instance using the passed conf instance.
static Connection	ConnectionFactory.createConnection(org.apache.hadoop.conf.Configuration conf, User user)	Create a new Connection instance using the passed conf instance.

Constructors in org.apache.hadoop.hbase.client with parameters of type User

Modifier	Constructor	Description
protected	AbstractRpcBasedConnectionRegistry(org.apache.hadoop.conf.Configuration conf, User user, String hedgedReqsFanoutConfigName, String initialRefreshDelaySecsConfigName, String refreshIntervalSecsConfigName, String minRefreshIntervalSecsConfigName)
	AsyncClusterConnectionImpl(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, String clusterId, SocketAddress localAddress, User user)
	AsyncConnectionImpl(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, String clusterId, SocketAddress localAddress, User user)
	AsyncConnectionImpl(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, String clusterId, SocketAddress localAddress, User user, Map<String,byte[]> connectionAttributes)
(package private)	ClusterIdFetcher(org.apache.hadoop.conf.Configuration conf, User user, RpcControllerFactory rpcControllerFactory, Set<ServerName> bootstrapServers)
(package private)	ConnectionRegistryRpcStubHolder(org.apache.hadoop.conf.Configuration conf, User user, RpcControllerFactory rpcControllerFactory, Set<ServerName> bootstrapNodes)
(package private)	MasterRegistry(org.apache.hadoop.conf.Configuration conf, User user)	Deprecated.
(package private)	RpcConnectionRegistry(org.apache.hadoop.conf.Configuration conf, User user)
(package private)	ZKConnectionRegistry(org.apache.hadoop.conf.Configuration conf, User ignored)	Deprecated.

Uses of User in org.apache.hadoop.hbase.coprocessor

Fields in org.apache.hadoop.hbase.coprocessor declared as User

Modifier and Type	Field	Description
private final User	ObserverContextImpl.caller

Methods in org.apache.hadoop.hbase.coprocessor that return types with arguments of type User

Modifier and Type	Method	Description
Optional<User>	ObserverContext.getCaller()	Returns the active user for the coprocessor call.
Optional<User>	ObserverContextImpl.getCaller()

Constructors in org.apache.hadoop.hbase.coprocessor with parameters of type User

Modifier	Constructor	Description
	ObserverContextImpl(User caller)
	ObserverContextImpl(User caller, boolean bypassable)
(package private)	ObserverOperation(CoprocessorHost.ObserverGetter<C,O> observerGetter, User user)
(package private)	ObserverOperation(CoprocessorHost.ObserverGetter<C,O> observerGetter, User user, boolean bypassable)
	ObserverOperationWithoutResult(CoprocessorHost.ObserverGetter<C,O> observerGetter, User user)
	ObserverOperationWithoutResult(CoprocessorHost.ObserverGetter<C,O> observerGetter, User user, boolean bypassable)
	ObserverOperationWithResult(CoprocessorHost.ObserverGetter<C,O> observerGetter, R result, User user)
private	ObserverOperationWithResult(CoprocessorHost.ObserverGetter<C,O> observerGetter, R result, User user, boolean bypassable)

Uses of User in org.apache.hadoop.hbase.ipc

Fields in org.apache.hadoop.hbase.ipc declared as User

Modifier and Type	Field	Description
protected final User	AbstractRpcClient.AbstractRpcChannel.ticket
(package private) final User	ConnectionId.ticket
protected final User	ServerCall.user
protected User	ServerRpcConnection.user

Methods in org.apache.hadoop.hbase.ipc that return User

Modifier and Type	Method	Description
User	ConnectionId.getTicket()

Methods in org.apache.hadoop.hbase.ipc that return types with arguments of type User

Modifier and Type	Method	Description
Optional<User>	RpcCallContext.getRequestUser()	Returns the user credentials associated with the current RPC request or not present if no credentials were provided.
static Optional<User>	RpcServer.getRequestUser()	Returns the user credentials associated with the current RPC request or not present if no credentials were provided.
Optional<User>	ServerCall.getRequestUser()

Methods in org.apache.hadoop.hbase.ipc with parameters of type User

Modifier and Type	Method	Description
private org.apache.hbase.thirdparty.com.google.protobuf.Message	AbstractRpcClient.callBlockingMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, HBaseRpcController hrc, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType, User ticket, Address isa)	Make a blocking call.
private Call	AbstractRpcClient.callMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, HBaseRpcController hrc, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType, User ticket, Address addr, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hbase.thirdparty.com.google.protobuf.Message> callback)
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel	AbstractRpcClient.createBlockingRpcChannel(ServerName sn, User ticket, int rpcTimeout)
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel	RpcClient.createBlockingRpcChannel(ServerName sn, User user, int rpcTimeout)	Creates a "channel" that can be used by a blocking protobuf service.
org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel	AbstractRpcClient.createRpcChannel(ServerName sn, User user, int rpcTimeout)
org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel	RpcClient.createRpcChannel(ServerName sn, User user, int rpcTimeout)	Creates a "channel" that can be used by a protobuf service.
int	AnnotationReadingPriorityFunction.getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user)	Returns a 'priority' based on the request type.
int	PriorityFunction.getPriority(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user)	Returns the 'priority type' of the specified request.
static int	ConnectionId.hashCode(User ticket, String serviceName, Address address)

Constructors in org.apache.hadoop.hbase.ipc with parameters of type User

Modifier	Constructor	Description
protected	AbstractRpcChannel(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout)
protected	BlockingRpcChannelImplementation(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout)
	ConnectionId(User ticket, String serviceName, Address address)
protected	RpcChannelImplementation(AbstractRpcClient<?> rpcClient, Address addr, User ticket, int rpcTimeout)

Uses of User in org.apache.hadoop.hbase.mapreduce

Methods in org.apache.hadoop.hbase.mapreduce with parameters of type User

Modifier and Type	Method	Description
private static void	TableMapReduceUtil.addTokenForJob(IOExceptionSupplier<Connection> connSupplier, User user, org.apache.hadoop.mapreduce.Job job)

Uses of User in org.apache.hadoop.hbase.master

Methods in org.apache.hadoop.hbase.master with parameters of type User

Modifier and Type	Method	Description
void	MasterCoprocessorHost.postCompletedCreateTableAction(TableDescriptor htd, RegionInfo[] regions, User user)
void	MasterCoprocessorHost.postCompletedDeleteTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.postCompletedDisableTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.postCompletedEnableTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.postCompletedMergeRegionsAction(RegionInfo[] regionsToMerge, RegionInfo mergedRegion, User user)	Invoked after completing merge regions operation
void	MasterCoprocessorHost.postCompletedModifyTableAction(TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor, User user)
void	MasterCoprocessorHost.postCompletedSplitRegionAction(RegionInfo regionInfoA, RegionInfo regionInfoB, User user)	Invoked just after a split
void	MasterCoprocessorHost.postCompletedTruncateTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.postMergeRegionsCommit(RegionInfo[] regionsToMerge, RegionInfo mergedRegion, User user)	Invoked after merge regions operation writes the new region to hbase:meta
void	MasterCoprocessorHost.postRollBackMergeRegionsAction(RegionInfo[] regionsToMerge, User user)	Invoked after rollback merge regions operation
void	MasterCoprocessorHost.postRollBackSplitRegionAction(User user)	Invoked just after the rollback of a failed split
void	MasterCoprocessorHost.postSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor, User user)
void	MasterCoprocessorHost.postTruncateRegionAction(RegionInfo region, User user)	Invoked after calling the truncate region procedure
void	MasterCoprocessorHost.preCreateTableAction(TableDescriptor htd, RegionInfo[] regions, User user)
void	MasterCoprocessorHost.preDeleteTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.preDisableTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.preEnableTableAction(TableName tableName, User user)
void	MasterCoprocessorHost.preMergeRegionsAction(RegionInfo[] regionsToMerge, User user)	Invoked just before a merge
void	MasterCoprocessorHost.preMergeRegionsCommit(RegionInfo[] regionsToMerge, List<Mutation> metaEntries, User user)	Invoked before merge regions operation writes the new region to hbase:meta
void	MasterCoprocessorHost.preModifyTableAction(TableName tableName, TableDescriptor currentDescriptor, TableDescriptor newDescriptor, User user)
void	MasterCoprocessorHost.preSnapshot(SnapshotDescription snapshot, TableDescriptor hTableDescriptor, User user)
void	MasterCoprocessorHost.preSplitAfterMETAAction(User user)	This will be called after update META step as part of split table region procedure.
void	MasterCoprocessorHost.preSplitBeforeMETAAction(byte[] splitKey, List<Mutation> metaEntries, User user)	This will be called before update META step as part of split table region procedure.
void	MasterCoprocessorHost.preSplitRegionAction(TableName tableName, byte[] splitRow, User user)	Invoked just before a split
void	MasterCoprocessorHost.preTruncateRegionAction(RegionInfo region, User user)	Invoked just before calling the truncate region procedure
void	MasterCoprocessorHost.preTruncateTableAction(TableName tableName, User user)

Constructors in org.apache.hadoop.hbase.master with parameters of type User

Modifier	Constructor	Description
	MasterObserverOperation(User user)
	MasterObserverOperation(User user, boolean bypassable)

Uses of User in org.apache.hadoop.hbase.master.procedure

Fields in org.apache.hadoop.hbase.master.procedure declared as User

Modifier and Type	Field	Description
private User	AbstractStateMachineTableProcedure.user

Methods in org.apache.hadoop.hbase.master.procedure that return User

Modifier and Type	Method	Description
User	MasterProcedureEnv.getRequestUser()
protected User	AbstractStateMachineTableProcedure.getUser()
static User	MasterProcedureUtil.toUserInfo(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation userInfoProto)

Methods in org.apache.hadoop.hbase.master.procedure with parameters of type User

Modifier and Type	Method	Description
protected void	AbstractStateMachineTableProcedure.setUser(User user)
static org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	MasterProcedureUtil.toProtoUserInfo(User user)

Uses of User in org.apache.hadoop.hbase.master.snapshot

Methods in org.apache.hadoop.hbase.master.snapshot with parameters of type User

Modifier and Type	Method	Description
void	SnapshotManager.checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user)

Uses of User in org.apache.hadoop.hbase.mob

Methods in org.apache.hadoop.hbase.mob with parameters of type User

Modifier and Type	Method	Description
List<org.apache.hadoop.fs.Path>	DefaultMobStoreCompactor.compact(CompactionRequestImpl request, ThroughputController throughputController, User user)

Uses of User in org.apache.hadoop.hbase.procedure

Methods in org.apache.hadoop.hbase.procedure with parameters of type User

Modifier and Type	Method	Description
abstract void	MasterProcedureManager.checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user)	Check for required permissions before executing the procedure.

Uses of User in org.apache.hadoop.hbase.procedure.flush

Methods in org.apache.hadoop.hbase.procedure.flush with parameters of type User

Modifier and Type	Method	Description
void	MasterFlushTableProcedureManager.checkPermissions(org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.ProcedureDescription desc, AccessChecker accessChecker, User user)

Uses of User in org.apache.hadoop.hbase.procedure2

Methods in org.apache.hadoop.hbase.procedure2 with parameters of type User

Modifier and Type	Method	Description
boolean	ProcedureExecutor.isProcedureOwner(long procId, User user)	Check if the user is this procedure's owner
void	ProcedureExecutor.setFailureResultForNonce(NonceKey nonceKey, String procName, User procOwner, IOException exception)	If the failure failed before submitting it, we may want to give back the same error to the requests with the same nonceKey.
void	Procedure.setOwner(User owner)

Constructors in org.apache.hadoop.hbase.procedure2 with parameters of type User

Modifier	Constructor	Description
	FailedProcedure(long procId, String procName, User owner, NonceKey nonceKey, IOException exception)

Uses of User in org.apache.hadoop.hbase.regionserver

Fields in org.apache.hadoop.hbase.regionserver declared as User

Modifier and Type	Field	Description
private User	CompactSplit.CompactionRunner.user
private final User	SplitRequest.user

Methods in org.apache.hadoop.hbase.regionserver that return User

Modifier and Type	Method	Description
private User	SecureBulkLoadManager.getActiveUser()

Methods in org.apache.hadoop.hbase.regionserver with parameters of type User

Modifier and Type	Method	Description
List<org.apache.hadoop.fs.Path>	DateTieredStoreEngine.DateTieredCompactionContext.compact(ThroughputController throughputController, User user)
List<org.apache.hadoop.fs.Path>	DefaultStoreEngine.DefaultCompactionContext.compact(ThroughputController throughputController, User user)
boolean	HRegion.compact(CompactionContext compaction, HStore store, ThroughputController throughputController, User user)	We are trying to remove / relax the region read lock for compaction.
List<HStoreFile>	HStore.compact(CompactionContext compaction, ThroughputController throughputController, User user)	Compact the StoreFiles.
List<org.apache.hadoop.fs.Path>	StripeStoreEngine.StripeCompaction.compact(ThroughputController throughputController, User user)
private org.apache.hadoop.fs.Path	SecureBulkLoadManager.createStagingDir(org.apache.hadoop.fs.Path baseDir, User user, String randomDir)
private org.apache.hadoop.fs.Path	SecureBulkLoadManager.createStagingDir(org.apache.hadoop.fs.Path baseDir, User user, TableName tableName)
private void	CompactSplit.CompactionRunner.doCompaction(User user)
protected List<HStoreFile>	HStore.doCompaction(CompactionRequestImpl cr, Collection<HStoreFile> filesToCompact, User user, long compactionStartTime, List<org.apache.hadoop.fs.Path> newFiles)
void	RegionCoprocessorHost.postCompact(HStore store, HStoreFile resultFile, CompactionLifeCycleTracker tracker, CompactionRequest request, User user)	Called after the store compaction has completed.
void	RegionCoprocessorHost.postCompactSelection(HStore store, List<HStoreFile> selected, CompactionLifeCycleTracker tracker, CompactionRequest request, User user)	Called after the HStoreFiles to be compacted have been selected from the available candidates.
void	RegionCoprocessorHost.preCleanupBulkLoad(User user)
InternalScanner	RegionCoprocessorHost.preCompact(HStore store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user)	Called prior to rewriting the store files selected for compaction
ScanInfo	RegionCoprocessorHost.preCompactScannerOpen(HStore store, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user)	Called prior to opening store scanner for compaction.
boolean	RegionCoprocessorHost.preCompactSelection(HStore store, List<HStoreFile> candidates, CompactionLifeCycleTracker tracker, User user)	Called prior to selecting the HStoreFiles for compaction from the list of currently available candidates.
void	RegionCoprocessorHost.prePrepareBulkLoad(User user)
void	RegionServerCoprocessorHost.preStop(String message, User user)
void	CompactSplit.requestCompaction(HRegion region, String why, int priority, CompactionLifeCycleTracker tracker, User user)
void	CompactSplit.requestCompaction(HRegion region, HStore store, String why, int priority, CompactionLifeCycleTracker tracker, User user)
Optional<CompactionContext>	HStore.requestCompaction(int priority, CompactionLifeCycleTracker tracker, User user)
private void	CompactSplit.requestCompactionInternal(HRegion region, String why, int priority, boolean selectNow, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, User user)
protected void	CompactSplit.requestCompactionInternal(HRegion region, HStore store, String why, int priority, boolean selectNow, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, User user)
private void	CompactSplit.requestSplit(Region r, byte[] midKey, User user)
private Optional<CompactionContext>	CompactSplit.selectCompaction(HRegion region, HStore store, int priority, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, User user)
void	HRegionServer.stop(String msg, boolean force, User user)	Stops the regionserver.

Constructors in org.apache.hadoop.hbase.regionserver with parameters of type User

Modifier	Constructor	Description
	BulkLoadObserverOperation(User user)
	CompactionRunner(HStore store, HRegion region, CompactionContext compaction, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, ThreadPoolExecutor parent, User user)
	RegionObserverOperationWithoutResult(User user)
	RegionObserverOperationWithoutResult(User user, boolean bypassable)
	RegionServerObserverOperation(User user)
(package private)	SplitRequest(Region region, byte[] midKey, HRegionServer hrs, User user)

Uses of User in org.apache.hadoop.hbase.regionserver.compactions

Methods in org.apache.hadoop.hbase.regionserver.compactions with parameters of type User

Modifier and Type	Method	Description
abstract List<org.apache.hadoop.fs.Path>	CompactionContext.compact(ThroughputController throughputController, User user)
protected final List<org.apache.hadoop.fs.Path>	Compactor.compact(CompactionRequestImpl request, Compactor.InternalScannerFactory scannerFactory, Compactor.CellSinkFactory<T> sinkFactory, ThroughputController throughputController, User user)
List<org.apache.hadoop.fs.Path>	DateTieredCompactor.compact(CompactionRequestImpl request, List<Long> lowerBoundaries, Map<Long,String> lowerBoundariesPolicies, ThroughputController throughputController, User user)
List<org.apache.hadoop.fs.Path>	DefaultCompactor.compact(CompactionRequestImpl request, ThroughputController throughputController, User user)	Do a minor/major compaction on an explicit set of storefiles from a Store.
List<org.apache.hadoop.fs.Path>	StripeCompactor.compact(CompactionRequestImpl request, int targetCount, long targetSize, byte[] left, byte[] right, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user)
List<org.apache.hadoop.fs.Path>	StripeCompactor.compact(CompactionRequestImpl request, List<byte[]> targetBoundaries, byte[] majorRangeFromRow, byte[] majorRangeToRow, ThroughputController throughputController, User user)
List<org.apache.hadoop.fs.Path>	StripeCompactionPolicy.BoundaryStripeCompactionRequest.execute(StripeCompactor compactor, ThroughputController throughputController, User user)
List<org.apache.hadoop.fs.Path>	StripeCompactionPolicy.SplitStripeCompactionRequest.execute(StripeCompactor compactor, ThroughputController throughputController, User user)
abstract List<org.apache.hadoop.fs.Path>	StripeCompactionPolicy.StripeCompactionRequest.execute(StripeCompactor compactor, ThroughputController throughputController, User user)	Executes the request against compactor (essentially, just calls correct overload of compact method), to simulate more dynamic dispatch.
private InternalScanner	Compactor.postCompactScannerOpen(CompactionRequestImpl request, ScanType scanType, InternalScanner scanner, User user)	Calls coprocessor, if any, to create scanners - after normal scanner creation.
private ScanInfo	Compactor.preCompactScannerOpen(CompactionRequestImpl request, ScanType scanType, User user)
void	CompactionRequester.requestCompaction(HRegion region, String why, int priority, CompactionLifeCycleTracker tracker, User user)	Request compaction on all the stores of the given region.
void	CompactionRequester.requestCompaction(HRegion region, HStore store, String why, int priority, CompactionLifeCycleTracker tracker, User user)	Request compaction on the given store.

Uses of User in org.apache.hadoop.hbase.replication.regionserver

Methods in org.apache.hadoop.hbase.replication.regionserver with parameters of type User

Modifier and Type	Method	Description
private org.apache.hadoop.fs.Path	HFileReplicator.createStagingDir(org.apache.hadoop.fs.Path baseDir, User user, String randomDir)
private org.apache.hadoop.fs.Path	HFileReplicator.createStagingDir(org.apache.hadoop.fs.Path baseDir, User user, TableName tableName)

Uses of User in org.apache.hadoop.hbase.security

Subclasses of User in org.apache.hadoop.hbase.security

Modifier and Type	Class	Description
static final class	User.SecureHadoopUser	Bridges User invocations to underlying calls to UserGroupInformation for secure Hadoop 0.20 and versions 0.21 and above.

Fields in org.apache.hadoop.hbase.security declared as User

Modifier and Type	Field	Description
private static User	Superusers.systemUser

Methods in org.apache.hadoop.hbase.security that return User

Modifier and Type	Method	Description
static User	User.create(org.apache.hadoop.security.UserGroupInformation ugi)	Wraps an underlying UserGroupInformation instance.
User	UserProvider.create(org.apache.hadoop.security.UserGroupInformation ugi)	Wraps an underlying UserGroupInformation instance.
static User	User.createUserForTesting(org.apache.hadoop.conf.Configuration conf, String name, String[] groups)	Generates a new User instance specifically for use in test code.
static User	User.SecureHadoopUser.createUserForTesting(org.apache.hadoop.conf.Configuration conf, String name, String[] groups)	Create a user for testing.
static User	User.getCurrent()	Returns the User instance within current execution context.
User	UserProvider.getCurrent()	Return the current user within the current execution context
static User	Superusers.getSystemUser()

Methods in org.apache.hadoop.hbase.security with parameters of type User

Modifier and Type	Method	Description
static boolean	Superusers.isSuperUser(User user)	Check if the current user is a super user

Uses of User in org.apache.hadoop.hbase.security.access

Subclasses of User in org.apache.hadoop.hbase.security.access

Modifier and Type	Class	Description
static class	AccessChecker.InputUser	A temporary user class to instantiate User instance based on the name and groups.

Fields in org.apache.hadoop.hbase.security.access declared as User

Modifier and Type	Field	Description
private User	AccessControlFilter.user
private final User	AuthResult.user

Methods in org.apache.hadoop.hbase.security.access that return User

Modifier and Type	Method	Description
private User	AccessController.getActiveUser(ObserverContext<?> ctx)	Returns the active user to which authorization checks should be applied.
private User	SnapshotScannerHDFSAclController.getActiveUser(ObserverContext<?> ctx)
User	AuthResult.getUser()
User	AccessChecker.validateCallerWithFilterUser(User caller, TablePermission tPerm, String inputUserName)

Methods in org.apache.hadoop.hbase.security.access with parameters of type User

Modifier and Type	Method	Description
boolean	AuthManager.accessUserTable(User user, TableName table, Permission.Action action)	Checks if the user has access to the full table or at least a family/qualifier for the specified action.
static AuthResult	AuthResult.allow(String request, String reason, User user, Permission.Action action, String namespace)
static AuthResult	AuthResult.allow(String request, String reason, User user, Permission.Action action, TableName table, byte[] family, byte[] qualifier)
static AuthResult	AuthResult.allow(String request, String reason, User user, Permission.Action action, TableName table, Map<byte[],? extends Collection<?>> families)
boolean	AuthManager.authorizeCell(User user, TableName table, Cell cell, Permission.Action action)	Check if user has given action privilige in cell scope.
boolean	AuthManager.authorizeUserFamily(User user, TableName table, byte[] family, Permission.Action action)	Check if user has given action privilige in table:family scope.
boolean	AuthManager.authorizeUserGlobal(User user, Permission.Action action)	Check if user has given action privilige in global scope.
boolean	AuthManager.authorizeUserNamespace(User user, String namespace, Permission.Action action)	Check if user has given action privilige in namespace scope.
boolean	AuthManager.authorizeUserTable(User user, TableName table, byte[] family, byte[] qualifier, Permission.Action action)	Check if user has given action privilige in table:family:qualifier scope.
boolean	AuthManager.authorizeUserTable(User user, TableName table, byte[] family, Permission.Action action)	Check if user has given action privilige in table:family scope.
boolean	AuthManager.authorizeUserTable(User user, TableName table, Permission.Action action)	Check if user has given action privilige in table scope.
private boolean	AccessController.checkCoveringPermission(User user, AccessController.OpType request, RegionCoprocessorEnvironment e, byte[] row, Map<byte[],? extends Collection<?>> familyMap, long opTs, Permission.Action... actions)	Determine if cell ACLs covered by the operation grant access.
private void	AccessController.checkForReservedTagPresence(User user, Mutation m)
void	AccessChecker.checkLockPermissions(User user, String namespace, TableName tableName, RegionInfo[] regionInfos, String reason)
void	NoopAccessChecker.checkLockPermissions(User user, String namespace, TableName tableName, RegionInfo[] regionInfos, String reason)
private void	AccessController.checkSystemOrSuperUser(User activeUser)
static AuthResult	AuthResult.deny(String request, String reason, User user, Permission.Action action, String namespace)
static AuthResult	AuthResult.deny(String request, String reason, User user, Permission.Action action, TableName table, byte[] family, byte[] qualifier)
static AuthResult	AuthResult.deny(String request, String reason, User user, Permission.Action action, TableName table, Map<byte[],? extends Collection<?>> families)
static List<Permission>	PermissionStorage.getCellPermissionsForUser(User user, ExtendedCell cell)
private boolean	AccessController.hasFamilyQualifierPermission(User user, Permission.Action perm, RegionCoprocessorEnvironment env, Map<byte[],? extends Collection<byte[]>> familyMap)	Returns true if the current user is allowed the given action over at least one of the column qualifiers in the given column families.
boolean	AccessChecker.hasUserPermission(User user, String request, Permission permission)	Authorizes that if the current user has the given permissions.
boolean	NoopAccessChecker.hasUserPermission(User user, String request, Permission permission)
void	AccessChecker.performOnSuperuser(String request, User caller, String userToBeChecked)	Check if caller is granting or revoking superusers's or supergroups's permissions.
void	NoopAccessChecker.performOnSuperuser(String request, User caller, String userToBeChecked)
private AuthResult	AccessChecker.permissionGranted(String request, User user, Permission.Action permRequest, TableName tableName, byte[] family, byte[] qualifier)
AuthResult	AccessChecker.permissionGranted(String request, User user, Permission.Action permRequest, TableName tableName, Map<byte[],? extends Collection<?>> families)	Check the current user for authorization to perform a specific action against the given set of row data.
private AuthResult	AccessController.permissionGranted(AccessController.OpType opType, User user, RegionCoprocessorEnvironment e, Map<byte[],? extends Collection<?>> families, Permission.Action... actions)	Check the current user for authorization to perform a specific action against the given set of row data.
AuthResult	NoopAccessChecker.permissionGranted(String request, User user, Permission.Action permRequest, TableName tableName, Map<byte[],? extends Collection<?>> families)
private void	AccessController.preGetUserPermissions(User caller, String userName, String namespace, TableName tableName, byte[] family, byte[] qualifier)
private void	AccessController.preGrantOrRevoke(User caller, String request, UserPermission userPermission)
private void	AccessController.preHasUserPermissions(User caller, String userName, List<Permission> permissions)
void	AccessChecker.requireAccess(User user, String request, TableName tableName, Permission.Action... permissions)	Authorizes that the current user has any of the given permissions to access the table.
void	NoopAccessChecker.requireAccess(User user, String request, TableName tableName, Permission.Action... permissions)
void	AccessChecker.requireGlobalPermission(User user, String request, Permission.Action perm, String namespace)	Checks that the user has the given global permission.
void	AccessChecker.requireGlobalPermission(User user, String request, Permission.Action perm, TableName tableName, Map<byte[],? extends Collection<byte[]>> familyMap, String filterUser)	Checks that the user has the given global permission.
void	NoopAccessChecker.requireGlobalPermission(User user, String request, Permission.Action perm, String namespace)
void	NoopAccessChecker.requireGlobalPermission(User user, String request, Permission.Action perm, TableName tableName, Map<byte[],? extends Collection<byte[]>> familyMap, String filterUser)
void	AccessChecker.requireNamespacePermission(User user, String request, String namespace, String filterUser, Permission.Action... permissions)	Checks that the user has the given global or namespace permission.
void	AccessChecker.requireNamespacePermission(User user, String request, String namespace, TableName tableName, Map<byte[],? extends Collection<byte[]>> familyMap, Permission.Action... permissions)	Checks that the user has the given global or namespace permission.
void	NoopAccessChecker.requireNamespacePermission(User user, String request, String namespace, String filterUser, Permission.Action... permissions)
void	NoopAccessChecker.requireNamespacePermission(User user, String request, String namespace, TableName tableName, Map<byte[],? extends Collection<byte[]>> familyMap, Permission.Action... permissions)
void	AccessChecker.requirePermission(User user, String request, String filterUser, Permission.Action perm)	Authorizes that the current user has global privileges for the given action.
void	AccessChecker.requirePermission(User user, String request, TableName tableName, byte[] family, byte[] qualifier, String filterUser, Permission.Action... permissions)	Authorizes that the current user has any of the given permissions for the given table, column family and column qualifier.
void	NoopAccessChecker.requirePermission(User user, String request, String filterUser, Permission.Action perm)
void	NoopAccessChecker.requirePermission(User user, String request, TableName tableName, byte[] family, byte[] qualifier, String filterUser, Permission.Action... permissions)
void	AccessChecker.requireTablePermission(User user, String request, TableName tableName, byte[] family, byte[] qualifier, Permission.Action... permissions)	Authorizes that the current user has any of the given permissions for the given table, column family and column qualifier.
void	NoopAccessChecker.requireTablePermission(User user, String request, TableName tableName, byte[] family, byte[] qualifier, Permission.Action... permissions)
User	AccessChecker.validateCallerWithFilterUser(User caller, TablePermission tPerm, String inputUserName)

Constructors in org.apache.hadoop.hbase.security.access with parameters of type User

Modifier	Constructor	Description
(package private)	AccessControlFilter(AuthManager mgr, User ugi, TableName tableName, AccessControlFilter.Strategy strategy, Map<ByteRange,Integer> cfVsMaxVersions)
	AuthResult(boolean allowed, String request, String reason, User user, Permission.Action action, String namespace)
	AuthResult(boolean allowed, String request, String reason, User user, Permission.Action action, TableName table, byte[] family, byte[] qualifier)
	AuthResult(boolean allowed, String request, String reason, User user, Permission.Action action, TableName table, Map<byte[],? extends Collection<?>> families)

Uses of User in org.apache.hadoop.hbase.security.provider

Methods in org.apache.hadoop.hbase.security.provider with parameters of type User

Modifier and Type	Method	Description
org.apache.hadoop.security.UserGroupInformation	GssSaslClientAuthenticationProvider.getRealUser(User user)
default org.apache.hadoop.security.UserGroupInformation	SaslClientAuthenticationProvider.getRealUser(User ugi)	Returns the "real" user, the user who has the credentials being authenticated by the remote service, in the form of an UserGroupInformation object.
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	DigestSaslClientAuthenticationProvider.getUserInfo(User user)
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	GssSaslClientAuthenticationProvider.getUserInfo(User user)
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	SaslClientAuthenticationProvider.getUserInfo(User user)	Constructs a RPCProtos.UserInformation from the given UserGroupInformation
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	SimpleSaslClientAuthenticationProvider.getUserInfo(User user)
Pair<SaslClientAuthenticationProvider,org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>>	AuthenticationProviderSelector.selectProvider(String clusterId, User user)	Chooses the authentication provider which should be used given the provided client context from the authentication providers passed in via AuthenticationProviderSelector.configure(Configuration, Collection).
Pair<SaslClientAuthenticationProvider,org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>>	BuiltInProviderSelector.selectProvider(String clusterId, User user)
Pair<SaslClientAuthenticationProvider,org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>>	SaslClientAuthenticationProviders.selectProvider(String clusterId, User clientUser)	Chooses the best authentication provider and corresponding token given the HBase cluster identifier and the user.

Uses of User in org.apache.hadoop.hbase.security.provider.example

Methods in org.apache.hadoop.hbase.security.provider.example with parameters of type User

Modifier and Type	Method	Description
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	ShadeSaslClientAuthenticationProvider.getUserInfo(User user)
Pair<SaslClientAuthenticationProvider,org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>>	ShadeProviderSelector.selectProvider(String clusterId, User user)

Uses of User in org.apache.hadoop.hbase.security.token

Methods in org.apache.hadoop.hbase.security.token with parameters of type User

Modifier and Type	Method	Description
static void	TokenUtil.addTokenForJob(Connection conn, User user, org.apache.hadoop.mapreduce.Job job)	Checks for an authentication token for the given user, obtaining a new token if necessary, and adds it to the credentials for the given map reduce job.
static void	TokenUtil.addTokenForJob(Connection conn, org.apache.hadoop.mapred.JobConf job, User user)	Checks for an authentication token for the given user, obtaining a new token if necessary, and adds it to the credentials for the given map reduce job.
static boolean	TokenUtil.addTokenIfMissing(Connection conn, User user)	Checks if an authentication tokens exists for the connected cluster, obtaining one if needed and adding it to the user's credentials.
private static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>	TokenUtil.getAuthToken(Connection conn, User user)	Get the authentication token of the user for the cluster specified in the configuration
static void	ClientTokenUtil.obtainAndCacheToken(Connection conn, User user)	Obtain an authentication token for the given user and add it to the user's credentials.
static void	TokenUtil.obtainAndCacheToken(Connection conn, User user)	See ClientTokenUtil.obtainAndCacheToken(Connection, User).
(package private) static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>	ClientTokenUtil.obtainToken(Connection conn, User user)	Obtain and return an authentication token for the given user.
static org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>	TokenUtil.obtainToken(Connection conn, User user)	Deprecated. External users should not use this method, will be removed in 4.0.0.
static void	TokenUtil.obtainTokenForJob(Connection conn, User user, org.apache.hadoop.mapreduce.Job job)	Obtain an authentication token on behalf of the given user and add it to the credentials for the given map reduce job.
static void	TokenUtil.obtainTokenForJob(Connection conn, org.apache.hadoop.mapred.JobConf job, User user)	Obtain an authentication token on behalf of the given user and add it to the credentials for the given map reduce job.

Uses of User in org.apache.hadoop.hbase.security.visibility

Methods in org.apache.hadoop.hbase.security.visibility that return User

Modifier and Type	Method	Description
static User	VisibilityUtils.getActiveUser()

Methods in org.apache.hadoop.hbase.security.visibility with parameters of type User

Modifier and Type	Method	Description
List<String>	DefinedSetFilterScanLabelGenerator.getLabels(User user, Authorizations authorizations)
List<String>	EnforcingScanLabelGenerator.getLabels(User user, Authorizations authorizations)
List<String>	FeedUserAuthScanLabelGenerator.getLabels(User user, Authorizations authorizations)
List<String>	ScanLabelGenerator.getLabels(User user, Authorizations authorizations)	Helps to get a list of lables associated with an UGI
List<String>	SimpleScanLabelGenerator.getLabels(User user, Authorizations authorizations)
boolean	DefaultVisibilityLabelServiceImpl.havingSystemAuth(User user)
boolean	VisibilityLabelService.havingSystemAuth(User user)	System checks for user auth during admin operations.

Uses of User in org.apache.hadoop.hbase.snapshot

Methods in org.apache.hadoop.hbase.snapshot with parameters of type User

Modifier and Type	Method	Description
static boolean	SnapshotDescriptionUtils.isSnapshotOwner(SnapshotDescription snapshot, User user)	Check if the user is this table snapshot's owner

Uses of User in org.apache.hadoop.hbase.thrift2.client

Fields in org.apache.hadoop.hbase.thrift2.client declared as User

Modifier and Type	Field	Description
private User	ThriftConnection.user

Constructors in org.apache.hadoop.hbase.thrift2.client with parameters of type User

Modifier	Constructor	Description
	ThriftConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, Map<String,byte[]> connectionAttributes)

Uses of User in org.apache.hadoop.hbase.util

Fields in org.apache.hadoop.hbase.util declared as User

Modifier and Type	Field	Description
private User	LoadTestTool.userOwner
private User	MultiThreadedUpdaterWithACL.userOwner
private User	MultiThreadedWriterWithACL.userOwner

Fields in org.apache.hadoop.hbase.util with type parameters of type User

Modifier and Type	Field	Description
private Map<String,User>	MultiThreadedReaderWithACL.users
private Map<String,User>	MultiThreadedUpdaterWithACL.users

Constructors in org.apache.hadoop.hbase.util with parameters of type User

Modifier	Constructor	Description
	MultiThreadedUpdaterWithACL(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, TableName tableName, double updatePercent, User userOwner, String userNames)
	MultiThreadedWriterWithACL(LoadTestDataGenerator dataGen, org.apache.hadoop.conf.Configuration conf, TableName tableName, User userOwner)