Uses of Class
org.apache.hadoop.hbase.security.User
Package
Description
Provides HBase Client
Table of Contents
Tools to help define network clients and servers.
-
Uses of User in org.apache.hadoop.hbase
Modifier and TypeMethodDescriptionstatic 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.Modifier and TypeMethodDescriptionLocalHBaseCluster.addRegionServer
(org.apache.hadoop.conf.Configuration config, int index, User user) Deprecated.since 0.94.1 -
Uses of User in org.apache.hadoop.hbase.backup.master
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeFieldDescriptionprivate final User
AsyncConnectionImpl.user
private final User
ClusterIdFetcher.user
protected User
ConnectionImplementation.user
private final User
ConnectionRegistryRpcStubHolder.user
Modifier and TypeMethodDescriptionAsyncConnectionImpl.getUser()
ClusterConnection.getUser()
Get theUser
associated with this connection.ConnectionImplementation.getUser()
Modifier and TypeMethodDescriptionstatic CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(org.apache.hadoop.conf.Configuration conf, User user) Create a new AsyncConnection instance using the passedconf
anduser
.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(org.apache.hadoop.conf.Configuration conf, User user, Map<String, byte[]> connectionAttributes) Create a new AsyncConnection instance using the passedconf
anduser
.static Connection
ConnectionFactory.createConnection
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user) Create a new Connection instance using the passedconf
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 passedconf
instance.static Connection
ConnectionFactory.createConnection
(org.apache.hadoop.conf.Configuration conf, User user) Create a new Connection instance using the passedconf
instance.static ClusterConnection
ServerConnectionUtils.createShortCircuitConnection
(org.apache.hadoop.conf.Configuration conf, User user, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client, ConnectionRegistry registry) Creates a short-circuit connection that can bypass the RPC layer (serialization, deserialization, networking, etc..) when talking to a local server.(package private) static ConnectionRegistry
ConnectionRegistryFactory.getRegistry
(org.apache.hadoop.conf.Configuration conf, User user) Returns The connection registry implementation to use.Deprecated.since 2.0.0 and will be removed in 3.0.0.Deprecated.since 2.0.0 and will be removed in 3.0.0.ModifierConstructorDescriptionprotected
AbstractRpcBasedConnectionRegistry
(org.apache.hadoop.conf.Configuration conf, User user, String hedgedReqsFanoutConfigName, String initialRefreshDelaySecsConfigName, String refreshIntervalSecsConfigName, String minRefreshIntervalSecsConfigName) AsyncConnectionImpl
(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, String clusterId, User user) AsyncConnectionImpl
(org.apache.hadoop.conf.Configuration conf, ConnectionRegistry registry, String clusterId, User user, Map<String, byte[]> connectionAttributes) (package private)
ClusterIdFetcher
(org.apache.hadoop.conf.Configuration conf, User user, RpcControllerFactory rpcControllerFactory, Set<ServerName> bootstrapServers) (package private)
ConnectionImplementation
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user) constructor(package private)
ConnectionImplementation
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, Map<String, byte[]> connectionAttributes) constructor(package private)
ConnectionImplementation
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, ConnectionRegistry registry) Constructor, for creating cluster connection with provided ConnectionRegistry.(package private)
ConnectionImplementation
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, ConnectionRegistry registry, Map<String, byte[]> connectionAttributes) Constructor, for creating cluster connection with provided ConnectionRegistry.(package private)
ConnectionRegistryRpcStubHolder
(org.apache.hadoop.conf.Configuration conf, User user, RpcControllerFactory rpcControllerFactory, Set<ServerName> bootstrapNodes) (package private)
MasterlessConnection
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, Map<String, byte[]> requestAttributes) (package private)
MasterRegistry
(org.apache.hadoop.conf.Configuration conf, User user) Deprecated.(package private)
RpcConnectionRegistry
(org.apache.hadoop.conf.Configuration conf, User user) private
ShortCircuitingClusterConnection
(org.apache.hadoop.conf.Configuration conf, User user, ServerName serverName, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client, ConnectionRegistry registry) (package private)
ZKConnectionRegistry
(org.apache.hadoop.conf.Configuration conf, User ignored) Deprecated. -
Uses of User in org.apache.hadoop.hbase.coprocessor
Modifier and TypeMethodDescriptionObserverContext.getCaller()
Returns the active user for the coprocessor call.ObserverContextImpl.getCaller()
ModifierConstructorDescriptionObserverContextImpl
(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
Modifier and TypeFieldDescriptionprotected final User
AbstractRpcClient.AbstractRpcChannel.ticket
(package private) final User
ConnectionId.ticket
protected final User
ServerCall.user
protected User
ServerRpcConnection.user
Modifier and TypeMethodDescriptionRpcCallContext.getRequestUser()
Returns the user credentials associated with the current RPC request or not present if no credentials were provided.RpcServer.getRequestUser()
Returns the user credentials associated with the current RPC request or not present if no credentials were provided.ServerCall.getRequestUser()
Modifier and TypeMethodDescriptionprivate 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
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
ModifierConstructorDescriptionprotected
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.master
Modifier and TypeMethodDescriptionint
MasterAnnotationReadingPriorityFunction.getPriority
(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user) 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 operationvoid
MasterCoprocessorHost.postCompletedModifyTableAction
(TableName tableName, TableDescriptor oldDescriptor, TableDescriptor currentDescriptor, User user) void
MasterCoprocessorHost.postCompletedSplitRegionAction
(RegionInfo regionInfoA, RegionInfo regionInfoB, User user) Invoked just after a splitvoid
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:metavoid
MasterCoprocessorHost.postRollBackMergeRegionsAction
(RegionInfo[] regionsToMerge, User user) Invoked after rollback merge regions operationvoid
MasterCoprocessorHost.postRollBackSplitRegionAction
(User user) Invoked just after the rollback of a failed splitvoid
MasterCoprocessorHost.postSnapshot
(SnapshotDescription snapshot, TableDescriptor hTableDescriptor, User user) void
MasterCoprocessorHost.postTruncateRegionAction
(RegionInfo region, User user) Invoked after calling the truncate region procedurevoid
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 mergevoid
MasterCoprocessorHost.preMergeRegionsCommit
(RegionInfo[] regionsToMerge, List<Mutation> metaEntries, User user) Invoked before merge regions operation writes the new region to hbase:metavoid
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 splitvoid
MasterCoprocessorHost.preTruncateRegionAction
(RegionInfo region, User user) Invoked just before calling the truncate region procedurevoid
MasterCoprocessorHost.preTruncateTableAction
(TableName tableName, User user) ModifierConstructorDescriptionMasterObserverOperation
(User user) MasterObserverOperation
(User user, boolean bypassable) -
Uses of User in org.apache.hadoop.hbase.master.procedure
Modifier and TypeMethodDescriptionMasterProcedureEnv.getRequestUser()
protected User
AbstractStateMachineTableProcedure.getUser()
static User
MasterProcedureUtil.toUserInfo
(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation userInfoProto) Modifier and TypeMethodDescriptionprotected void
static org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation
MasterProcedureUtil.toProtoUserInfo
(User user) -
Uses of User in org.apache.hadoop.hbase.master.snapshot
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionList<org.apache.hadoop.fs.Path>
DefaultMobStoreCompactor.compact
(CompactionRequestImpl request, ThroughputController throughputController, User user) -
Uses of User in org.apache.hadoop.hbase.procedure
Modifier and TypeMethodDescriptionabstract 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
Modifier and TypeMethodDescriptionvoid
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
Modifier and TypeMethodDescriptionboolean
ProcedureExecutor.isProcedureOwner
(long procId, User user) Check if the user is this procedure's ownervoid
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
ModifierConstructorDescriptionFailedProcedure
(long procId, String procName, User owner, NonceKey nonceKey, IOException exception) -
Uses of User in org.apache.hadoop.hbase.regionserver
Modifier and TypeFieldDescriptionprivate User
CompactSplit.CompactionRunner.user
private final User
SplitRequest.user
Modifier and TypeMethodDescriptionList<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) 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) 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
RSRpcServices.getPriority
(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, User user) 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 theHStoreFile
s to be compacted have been selected from the available candidates.void
RegionCoprocessorHost.preCleanupBulkLoad
(User user) RegionCoprocessorHost.preCompact
(HStore store, InternalScanner scanner, ScanType scanType, CompactionLifeCycleTracker tracker, CompactionRequest request, User user) Called prior to rewriting the store files selected for compactionRegionCoprocessorHost.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 theHStoreFile
s for compaction from the list of currently available candidates.void
RegionCoprocessorHost.prePrepareBulkLoad
(User user) void
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) 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
Stops the regionserver.ModifierConstructorDescriptionCompactionRunner
(HStore store, HRegion region, CompactionContext compaction, CompactionLifeCycleTracker tracker, CompactSplit.CompactionCompleteTracker completeTracker, ThreadPoolExecutor parent, User user) RegionObserverOperationWithoutResult
(User user, boolean bypassable) (package private)
SplitRequest
(Region region, byte[] midKey, HRegionServer hrs, User user) -
Uses of User in org.apache.hadoop.hbase.regionserver.compactions
Modifier and TypeMethodDescriptionabstract 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
Modifier and TypeMethodDescriptionprivate 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.rsgroup
Modifier and TypeMethodDescriptionprivate User
RSGroupAdminEndpoint.getActiveUser()
Returns the active user to which authorization checks should be applied. -
Uses of User in org.apache.hadoop.hbase.security
Modifier and TypeClassDescriptionstatic final class
BridgesUser
invocations to underlying calls toUserGroupInformation
for secure Hadoop 0.20 and versions 0.21 and above.Modifier and TypeMethodDescriptionstatic User
User.create
(org.apache.hadoop.security.UserGroupInformation ugi) Wraps an underlyingUserGroupInformation
instance.UserProvider.create
(org.apache.hadoop.security.UserGroupInformation ugi) Wraps an underlyingUserGroupInformation
instance.static User
User.createUserForTesting
(org.apache.hadoop.conf.Configuration conf, String name, String[] groups) Generates a newUser
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 theUser
instance within current execution context.UserProvider.getCurrent()
Return the current user within the current execution contextstatic User
Superusers.getSystemUser()
Modifier and TypeMethodDescriptionstatic boolean
Superusers.isSuperUser
(User user) Check if the current user is a super user -
Uses of User in org.apache.hadoop.hbase.security.access
Modifier and TypeClassDescriptionstatic class
A temporary user class to instantiate User instance based on the name and groups.Modifier and TypeFieldDescriptionprivate User
AccessControlFilter.user
private final User
AuthResult.user
Modifier and TypeMethodDescriptionprivate User
AccessController.getActiveUser
(ObserverContext<?> ctx) Returns the active user to which authorization checks should be applied.private User
SnapshotScannerHDFSAclController.getActiveUser
(ObserverContext<?> ctx) AuthResult.getUser()
AccessChecker.validateCallerWithFilterUser
(User caller, TablePermission tPerm, String inputUserName) Modifier and TypeMethodDescriptionboolean
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, Cell cell) private boolean
AccessController.hasFamilyQualifierPermission
(User user, Permission.Action perm, RegionCoprocessorEnvironment env, Map<byte[], ? extends Collection<byte[]>> familyMap) Returnstrue
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) 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.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) AccessChecker.validateCallerWithFilterUser
(User caller, TablePermission tPerm, String inputUserName) ModifierConstructorDescription(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
Modifier and TypeMethodDescriptionorg.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 anUserGroupInformation
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 aRPCProtos.UserInformation
from the givenUserGroupInformation
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 viaAuthenticationProviderSelector.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
Modifier and TypeMethodDescriptionorg.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
Modifier and TypeMethodDescriptionstatic 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 configurationstatic 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) (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.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
Modifier and TypeMethodDescriptionDefinedSetFilterScanLabelGenerator.getLabels
(User user, Authorizations authorizations) EnforcingScanLabelGenerator.getLabels
(User user, Authorizations authorizations) FeedUserAuthScanLabelGenerator.getLabels
(User user, Authorizations authorizations) ScanLabelGenerator.getLabels
(User user, Authorizations authorizations) Helps to get a list of lables associated with an UGISimpleScanLabelGenerator.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
Modifier and TypeMethodDescriptionstatic 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
ModifierConstructorDescriptionThriftConnection
(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, User user, Map<String, byte[]> connectionAttributes)