Modifier and Type | Method and Description |
---|---|
static User |
HBaseTestingUtility.getDifferentUser(Configuration c,
java.lang.String differentiatingSuffix)
This method clones the passed
c configuration setting a new
user into the clone. |
Modifier and Type | Method and Description |
---|---|
JVMClusterUtil.MasterThread |
LocalHBaseCluster.addMaster(Configuration c,
int index,
User user) |
JVMClusterUtil.RegionServerThread |
LocalHBaseCluster.addRegionServer(Configuration config,
int index,
User user) |
static boolean |
ProcedureInfo.isProcedureOwner(ProcedureInfo procInfo,
User user)
Check if the user is this procedure's owner
|
HTableDescriptor |
HTableDescriptor.setOwner(User owner)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
BlockingRpcChannel |
TestClientTimeouts.RandomTimeoutRpcClient.createBlockingRpcChannel(ServerName sn,
User ticket,
int rpcTimeout) |
static Connection |
ConnectionFactory.createConnection(Configuration conf,
java.util.concurrent.ExecutorService pool,
User user)
Create a new Connection instance using the passed
conf instance. |
static HConnection |
HConnectionManager.createConnection(Configuration conf,
java.util.concurrent.ExecutorService pool,
User user)
Deprecated.
|
static Connection |
ConnectionFactory.createConnection(Configuration conf,
User user)
Create a new Connection instance using the passed
conf instance. |
static HConnection |
HConnectionManager.createConnection(Configuration conf,
User user)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
boolean |
TestRegionObserverScannerOpenHook.CompactionCompletionNotifyingRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController,
User user) |
Modifier and Type | Method and Description |
---|---|
User |
RpcCallContext.getRequestUser()
Returns the user credentials associated with the current RPC request or
null if no credentials were provided. |
static User |
RpcServer.getRequestUser()
Returns the user credentials associated with the current RPC request or
null if no credentials were provided. |
User |
RpcServer.Call.getRequestUser() |
User |
ConnectionId.getTicket() |
Modifier and Type | Method and Description |
---|---|
protected abstract Pair<Message,CellScanner> |
AbstractRpcClient.call(PayloadCarryingRpcController pcrc,
Descriptors.MethodDescriptor md,
Message param,
Message returnType,
User ticket,
java.net.InetSocketAddress isa)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
protected Pair<Message,CellScanner> |
AsyncRpcClient.call(PayloadCarryingRpcController pcrc,
Descriptors.MethodDescriptor md,
Message param,
Message returnType,
User ticket,
java.net.InetSocketAddress addr)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
protected Pair<Message,CellScanner> |
RpcClientImpl.call(PayloadCarryingRpcController pcrc,
MethodDescriptor md,
Message param,
Message returnType,
User ticket,
java.net.InetSocketAddress addr)
Make a call, passing
param , to the IPC server running at
address which is servicing the protocol protocol,
with the ticket credentials, returning the value. |
BlockingRpcChannel |
AbstractRpcClient.createBlockingRpcChannel(ServerName sn,
User ticket,
int defaultOperationTimeout) |
BlockingRpcChannel |
RpcClient.createBlockingRpcChannel(ServerName sn,
User user,
int rpcTimeout)
Creates a "channel" that can be used by a blocking protobuf service.
|
RpcChannel |
AsyncRpcClient.createRpcChannel(ServerName sn,
User user,
int rpcTimeout)
Creates a "channel" that can be used by a protobuf service.
|
protected RpcClientImpl.Connection |
RpcClientImpl.getConnection(User ticket,
Call call,
java.net.InetSocketAddress addr)
Get a connection from the pool, or create a new one and add it to the
pool.
|
static int |
ConnectionId.hashCode(User ticket,
java.lang.String serviceName,
java.net.InetSocketAddress address) |
Constructor and Description |
---|
AsyncRpcChannel(Bootstrap bootstrap,
AsyncRpcClient client,
User ticket,
java.lang.String serviceName,
java.net.InetSocketAddress address)
Constructor for netty RPC channel
|
BlockingRpcChannelImplementation(AbstractRpcClient rpcClient,
ServerName sn,
User ticket,
int channelOperationTimeout) |
ConnectionId(User ticket,
java.lang.String serviceName,
java.net.InetSocketAddress address) |
RpcChannelImplementation(AsyncRpcClient rpcClient,
ServerName sn,
User ticket,
int channelOperationTimeout) |
Modifier and Type | Method and Description |
---|---|
User |
MasterProcedureEnv.getRequestUser() |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
DefaultMobStoreCompactor.compact(CompactionRequest request,
CompactionThroughputController throughputController,
User user) |
Modifier and Type | Method and Description |
---|---|
boolean |
ProcedureExecutor.isProcedureOwner(long procId,
User user)
Check if the user is this procedure's owner
|
void |
ProcedureExecutor.setFailureResultForNonce(NonceKey nonceKey,
java.lang.String procName,
User procOwner,
java.io.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.
|
Modifier and Type | Method and Description |
---|---|
java.util.List<StoreFile> |
HStore.compact(CompactionContext compaction,
CompactionThroughputController throughputController,
User user) |
java.util.List<StoreFile> |
Store.compact(CompactionContext compaction,
CompactionThroughputController throughputController,
User user) |
boolean |
HRegion.compact(CompactionContext compaction,
Store store,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
TestCompaction.BlockingStoreMockMaker.BlockingCompactionContext.compact(CompactionThroughputController throughputController,
User user) |
Region |
RegionMergeTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
HRegion |
RegionMergeTransactionImpl.execute(Server server,
RegionServerServices services,
User user) |
PairOfSameType<Region> |
SplitTransaction.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
PairOfSameType<Region> |
SplitTransactionImpl.execute(Server server,
RegionServerServices services,
User user)
Run the transaction.
|
CompactionContext |
HStore.requestCompaction(int priority,
CompactionRequest baseRequest,
User user) |
CompactionContext |
Store.requestCompaction(int priority,
CompactionRequest baseRequest,
User user) |
CompactionRequest |
CompactionRequestor.requestCompaction(Region r,
Store s,
java.lang.String why,
int pri,
CompactionRequest request,
User user) |
CompactionRequest |
CompactSplitThread.requestCompaction(Region r,
Store s,
java.lang.String why,
int priority,
CompactionRequest request,
User user) |
java.util.List<CompactionRequest> |
CompactionRequestor.requestCompaction(Region r,
java.lang.String why,
int pri,
java.util.List<Pair<CompactionRequest,Store>> requests,
User user) |
java.util.List<CompactionRequest> |
CompactSplitThread.requestCompaction(Region r,
java.lang.String why,
int p,
java.util.List<Pair<CompactionRequest,Store>> requests,
User user) |
void |
CompactSplitThread.requestRegionsMerge(Region a,
Region b,
boolean forcible,
long masterSystemTime,
User user) |
void |
CompactSplitThread.requestSplit(Region r,
byte[] midKey,
User user) |
boolean |
RegionMergeTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
RegionMergeTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
boolean |
SplitTransaction.rollback(Server server,
RegionServerServices services,
User user)
Roll back a failed transaction
|
boolean |
SplitTransactionImpl.rollback(Server server,
RegionServerServices services,
User user) |
void |
RegionMergeTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
HRegion mergedRegion,
User user) |
PairOfSameType<Region> |
SplitTransactionImpl.stepsAfterPONR(Server server,
RegionServerServices services,
PairOfSameType<Region> regions,
User user) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Path> |
DefaultCompactor.compact(CompactionRequest request,
CompactionThroughputController throughputController,
User user)
Do a minor/major compaction on an explicit set of storefiles from a Store.
|
protected java.util.List<Path> |
Compactor.compact(CompactionRequest request,
Compactor.InternalScannerFactory scannerFactory,
Compactor.CellSinkFactory<T> sinkFactory,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactor.compact(CompactionRequest request,
int targetCount,
long targetSize,
byte[] left,
byte[] right,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
StripeCompactor.compact(CompactionRequest request,
java.util.List<byte[]> targetBoundaries,
byte[] majorRangeFromRow,
byte[] majorRangeToRow,
CompactionThroughputController throughputController,
User user) |
java.util.List<Path> |
DateTieredCompactor.compact(CompactionRequest request,
java.util.List<java.lang.Long> lowerBoundaries,
CompactionThroughputController throughputController,
User user) |
abstract java.util.List<Path> |
CompactionContext.compact(CompactionThroughputController throughputController,
User user) |
abstract java.util.List<Path> |
StripeCompactionPolicy.StripeCompactionRequest.execute(StripeCompactor compactor,
CompactionThroughputController throughputController,
User user)
Executes the request against compactor (essentially, just calls correct overload of
compact method), to simulate more dynamic dispatch.
|
protected InternalScanner |
Compactor.postCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
InternalScanner scanner,
User user)
Calls coprocessor, if any, to create scanners - after normal scanner creation.
|
protected InternalScanner |
Compactor.preCreateCoprocScanner(CompactionRequest request,
ScanType scanType,
long earliestPutTs,
java.util.List<StoreFileScanner> scanners,
User user) |
Modifier and Type | Method and Description |
---|---|
static User |
User.create(UserGroupInformation ugi)
Wraps an underlying
UserGroupInformation instance. |
User |
UserProvider.create(UserGroupInformation ugi)
Wraps an underlying
UserGroupInformation instance. |
static User |
User.createUserForTesting(Configuration conf,
java.lang.String name,
java.lang.String[] groups)
Generates a new
User instance specifically for use in test code. |
static User |
User.getCurrent()
Returns the
User instance within current execution context. |
User |
UserProvider.getCurrent() |
Modifier and Type | Method and Description |
---|---|
static boolean |
Superusers.isSuperUser(User user) |
Modifier and Type | Method and Description |
---|---|
User |
AuthResult.getUser() |
Modifier and Type | Method and Description |
---|---|
static AuthResult |
AuthResult.allow(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
java.lang.String namespace) |
static AuthResult |
AuthResult.allow(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
byte[] family,
byte[] qualifier) |
static AuthResult |
AuthResult.allow(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
java.util.Map<byte[],? extends java.util.Collection<?>> families) |
boolean |
TableAuthManager.authorize(User user,
Permission.Action action)
Authorize a global permission based on ACLs for the given user and the
user's groups.
|
boolean |
TableAuthManager.authorize(User user,
java.lang.String namespace,
Permission.Action action) |
boolean |
TableAuthManager.authorize(User user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action) |
boolean |
TableAuthManager.authorize(User user,
TableName table,
byte[] family,
Permission.Action action) |
boolean |
TableAuthManager.authorize(User user,
TableName table,
Cell cell,
Permission.Action action)
Authorize a user for a given KV.
|
boolean |
TableAuthManager.authorizeUser(User user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action) |
boolean |
TableAuthManager.authorizeUser(User user,
TableName table,
byte[] family,
Permission.Action action)
Checks authorization to a given table and column family for a user, based on the
stored user permissions.
|
static AuthResult |
AuthResult.deny(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
java.lang.String namespace) |
static AuthResult |
AuthResult.deny(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
byte[] family,
byte[] qualifier) |
static AuthResult |
AuthResult.deny(java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
java.util.Map<byte[],? extends java.util.Collection<?>> families) |
static java.util.List<Permission> |
AccessControlLists.getCellPermissionsForUser(User user,
Cell cell) |
boolean |
TableAuthManager.hasAccess(User user,
TableName table,
Permission.Action action) |
boolean |
TableAuthManager.matchPermission(User user,
TableName table,
byte[] family,
byte[] qualifier,
Permission.Action action) |
boolean |
TableAuthManager.matchPermission(User user,
TableName table,
byte[] family,
Permission.Action action)
Returns true if the given user has a
TablePermission matching up
to the column family portion of a permission. |
boolean |
TableAuthManager.userHasAccess(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.
|
Constructor and Description |
---|
AuthResult(boolean allowed,
java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
java.lang.String namespace) |
AuthResult(boolean allowed,
java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
byte[] family,
byte[] qualifier) |
AuthResult(boolean allowed,
java.lang.String request,
java.lang.String reason,
User user,
Permission.Action action,
TableName table,
java.util.Map<byte[],? extends java.util.Collection<?>> families) |
Modifier and Type | Method and Description |
---|---|
static void |
TokenUtil.addTokenForJob(Connection conn,
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 void |
TokenUtil.addTokenForJob(Connection conn,
User user,
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 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.
|
static <any> |
TokenUtil.obtainToken(Connection conn,
User user)
Obtain and return an authentication token for the current user.
|
static void |
TokenUtil.obtainTokenForJob(Connection conn,
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.
|
static void |
TokenUtil.obtainTokenForJob(Connection conn,
User user,
Job job)
Obtain an authentication token on behalf of the given user and add it to
the credentials for the given map reduce job.
|
Modifier and Type | Method and Description |
---|---|
static User |
VisibilityUtils.getActiveUser() |
Modifier and Type | Method and Description |
---|---|
java.util.List<java.lang.String> |
DefinedSetFilterScanLabelGenerator.getLabels(User user,
Authorizations authorizations) |
java.util.List<java.lang.String> |
EnforcingScanLabelGenerator.getLabels(User user,
Authorizations authorizations) |
java.util.List<java.lang.String> |
FeedUserAuthScanLabelGenerator.getLabels(User user,
Authorizations authorizations) |
java.util.List<java.lang.String> |
ScanLabelGenerator.getLabels(User user,
Authorizations authorizations)
Helps to get a list of lables associated with an UGI
|
java.util.List<java.lang.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.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
SnapshotDescriptionUtils.isSnapshotOwner(HBaseProtos.SnapshotDescription snapshot,
User user)
Check if the user is this table snapshot's owner
|