org.apache.hadoop.hbase.security.access

Class SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage

java.lang.Object

org.apache.hadoop.hbase.security.access.SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage

Enclosing class:

SnapshotScannerHDFSAclController

static final class SnapshotScannerHDFSAclController.SnapshotScannerHDFSAclStorage
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static byte[]	HDFS_ACL_FAMILY Add a new CF in HBase acl table to record if the HBase read permission is synchronized to related hfiles.
private static byte[]	HDFS_ACL_VALUE

Constructor Summary

Constructors

Constructor and Description
SnapshotScannerHDFSAclStorage()

Method Summary

Modifier and Type	Method and Description
private static void	addUserEntry(Table t, String user, byte[] entry)
(package private) static void	addUserGlobalHdfsAcl(Table aclTable, String user)
(package private) static void	addUserNamespaceHdfsAcl(Table aclTable, String user, String namespace)
(package private) static void	addUserTableHdfsAcl(Connection connection, Set<String> users, TableName tableName)
(package private) static void	addUserTableHdfsAcl(Connection connection, String user, TableName tableName)
(package private) static void	addUserTableHdfsAcl(Table aclTable, String user, TableName tableName)
private static void	deleteEntry(Table aclTable, byte[] entry)
(package private) static void	deleteNamespaceHdfsAcl(Connection connection, String namespace)
(package private) static void	deleteTableHdfsAcl(Table aclTable, TableName tableName)
private static void	deleteUserEntry(Table aclTable, String user, byte[] entry)
(package private) static void	deleteUserGlobalHdfsAcl(Table aclTable, String user)
(package private) static void	deleteUserNamespaceHdfsAcl(Table aclTable, String user, String namespace)
(package private) static void	deleteUserTableHdfsAcl(Connection connection, Set<String> users, TableName tableName)
(package private) static void	deleteUserTableHdfsAcl(Table aclTable, String user, TableName tableName)
private static Set<String>	getEntryUsers(Table aclTable, byte[] entry)
(package private) static Set<String>	getTableUsers(Table aclTable, TableName tableName)
(package private) static List<byte[]>	getUserEntries(Table aclTable, String userName)
(package private) static Pair<Set<String>,Set<TableName>>	getUserNamespaceAndTable(Table aclTable, String userName)
private static boolean	hasUserEntry(Table aclTable, String userName, byte[] entry)
(package private) static boolean	hasUserGlobalHdfsAcl(Table aclTable, String user)
(package private) static boolean	hasUserNamespaceHdfsAcl(Table aclTable, String user, String namespace)
(package private) static boolean	hasUserTableHdfsAcl(Table aclTable, String user, TableName tableName)

Methods inherited from class java.lang.Object

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

Field Detail

HDFS_ACL_FAMILY

static final byte[] HDFS_ACL_FAMILY

Add a new CF in HBase acl table to record if the HBase read permission is synchronized to related hfiles. The record has two usages: 1. check if we need to remove HDFS acls for a grant without READ permission(eg: grant user table read permission and then grant user table write permission without merging the existing permissions, in this case, need to remove HDFS acls); 2. skip some HDFS acl sync because it may be already set(eg: grant user table read permission and then grant user ns read permission; grant user table read permission and then grant user table write permission with merging the existing permissions).

HDFS_ACL_VALUE

private static final byte[] HDFS_ACL_VALUE

Constructor Detail

SnapshotScannerHDFSAclStorage

SnapshotScannerHDFSAclStorage()

Method Detail

addUserGlobalHdfsAcl

static void addUserGlobalHdfsAcl(Table aclTable,
                                 String user)
                          throws IOException

Throws:

IOException

addUserNamespaceHdfsAcl

static void addUserNamespaceHdfsAcl(Table aclTable,
                                    String user,
                                    String namespace)
                             throws IOException

Throws:

IOException

addUserTableHdfsAcl

static void addUserTableHdfsAcl(Connection connection,
                                Set<String> users,
                                TableName tableName)
                         throws IOException

Throws:

IOException

addUserTableHdfsAcl

static void addUserTableHdfsAcl(Connection connection,
                                String user,
                                TableName tableName)
                         throws IOException

Throws:

IOException

addUserTableHdfsAcl

static void addUserTableHdfsAcl(Table aclTable,
                                String user,
                                TableName tableName)
                         throws IOException

Throws:

IOException

addUserEntry

private static void addUserEntry(Table t,
                                 String user,
                                 byte[] entry)
                          throws IOException

Throws:

IOException

deleteUserGlobalHdfsAcl

static void deleteUserGlobalHdfsAcl(Table aclTable,
                                    String user)
                             throws IOException

Throws:

IOException

deleteUserNamespaceHdfsAcl

static void deleteUserNamespaceHdfsAcl(Table aclTable,
                                       String user,
                                       String namespace)
                                throws IOException

Throws:

IOException

deleteUserTableHdfsAcl

static void deleteUserTableHdfsAcl(Table aclTable,
                                   String user,
                                   TableName tableName)
                            throws IOException

Throws:

IOException

deleteUserTableHdfsAcl

static void deleteUserTableHdfsAcl(Connection connection,
                                   Set<String> users,
                                   TableName tableName)
                            throws IOException

Throws:

IOException

deleteUserEntry

private static void deleteUserEntry(Table aclTable,
                                    String user,
                                    byte[] entry)
                             throws IOException

Throws:

IOException

deleteNamespaceHdfsAcl

static void deleteNamespaceHdfsAcl(Connection connection,
                                   String namespace)
                            throws IOException

Throws:

IOException

deleteTableHdfsAcl

static void deleteTableHdfsAcl(Table aclTable,
                               TableName tableName)
                        throws IOException

Throws:

IOException

deleteEntry

private static void deleteEntry(Table aclTable,
                                byte[] entry)
                         throws IOException

Throws:

IOException

getTableUsers

static Set<String> getTableUsers(Table aclTable,
                                 TableName tableName)
                          throws IOException

Throws:

IOException

getEntryUsers

private static Set<String> getEntryUsers(Table aclTable,
                                         byte[] entry)
                                  throws IOException

Throws:

IOException

getUserNamespaceAndTable

static Pair<Set<String>,Set<TableName>> getUserNamespaceAndTable(Table aclTable,
                                                                 String userName)
                                                          throws IOException

Throws:

IOException

getUserEntries

static List<byte[]> getUserEntries(Table aclTable,
                                   String userName)
                            throws IOException

Throws:

IOException

hasUserGlobalHdfsAcl

static boolean hasUserGlobalHdfsAcl(Table aclTable,
                                    String user)
                             throws IOException

Throws:

IOException

hasUserNamespaceHdfsAcl

static boolean hasUserNamespaceHdfsAcl(Table aclTable,
                                       String user,
                                       String namespace)
                                throws IOException

Throws:

IOException

hasUserTableHdfsAcl

static boolean hasUserTableHdfsAcl(Table aclTable,
                                   String user,
                                   TableName tableName)
                            throws IOException

Throws:

IOException

hasUserEntry

private static boolean hasUserEntry(Table aclTable,
                                    String userName,
                                    byte[] entry)
                             throws IOException

Throws:

IOException