本文整理了Java中org.apache.hadoop.hbase.security.access.ZKPermissionWatcher.writeToZookeeper()方法的一些代码示例，展示了ZKPermissionWatcher.writeToZookeeper()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZKPermissionWatcher.writeToZookeeper()方法的具体详情如下：
包路径：org.apache.hadoop.hbase.security.access.ZKPermissionWatcher
类名称：ZKPermissionWatcher
方法名：writeToZookeeper

ZKPermissionWatcher.writeToZookeeper介绍

[英]Write a table's access controls to the permissions mirror in zookeeper
[中]将表的访问控件写入zookeeper中的权限镜像

代码示例

代码示例来源：origin: apache/hbase

private void initialize(RegionCoprocessorEnvironment e) throws IOException {
 final Region region = e.getRegion();
 Configuration conf = e.getConfiguration();
 Map<byte[], ListMultimap<String, UserPermission>> tables = AccessControlLists.loadAll(region);
 // For each table, write out the table's permissions to the respective
 // znode for that table.
 for (Map.Entry<byte[], ListMultimap<String, UserPermission>> t:
  tables.entrySet()) {
  byte[] entry = t.getKey();
  ListMultimap<String, UserPermission> perms = t.getValue();
  byte[] serialized = AccessControlLists.writePermissionsAsBytes(perms, conf);
  getAuthManager().getZKPermissionWatcher().writeToZookeeper(entry, serialized);
 }
 initialized = true;
}

代码示例来源：origin: apache/hbase

AccessControlLists.getPermissions(conf, entry, t, null, null, null, false);
byte[] serialized = AccessControlLists.writePermissionsAsBytes(perms, conf);
zkw.writeToZookeeper(entry, serialized);

代码示例来源：origin: apache/hbase

multimap.putAll(george.getShortName(), acl);
byte[] serialized = AccessControlLists.writePermissionsAsBytes(multimap, conf);
AUTH_A.getZKPermissionWatcher().writeToZookeeper(TEST_TABLE.getName(), serialized);
final long mtimeB = AUTH_B.getMTime();
multimap.putAll(hubert.getShortName(), acl2);
byte[] serialized2 = AccessControlLists.writePermissionsAsBytes(multimap, conf);
AUTH_B.getZKPermissionWatcher().writeToZookeeper(TEST_TABLE.getName(), serialized2);

代码示例来源：origin: harbby/presto-connectors

public void writeNamespaceToZooKeeper(String namespace,
  PermissionCache<TablePermission> tablePerms) {
 byte[] serialized = new byte[0];
 if (tablePerms != null) {
  serialized = AccessControlLists.writePermissionsAsBytes(tablePerms.getAllPermissions(), conf);
 }
 zkperms.writeToZookeeper(Bytes.toBytes(AccessControlLists.toNamespaceEntry(namespace)),
   serialized);
}

代码示例来源：origin: harbby/presto-connectors

public void writeTableToZooKeeper(TableName table,
  PermissionCache<TablePermission> tablePerms) {
 byte[] serialized = new byte[0];
 if (tablePerms != null) {
  serialized = AccessControlLists.writePermissionsAsBytes(tablePerms.getAllPermissions(), conf);
 }
 zkperms.writeToZookeeper(table.getName(), serialized);
}

代码示例来源：origin: harbby/presto-connectors

void initialize(RegionCoprocessorEnvironment e) throws IOException {
 final Region region = e.getRegion();
 Configuration conf = e.getConfiguration();
 Map<byte[], ListMultimap<String,TablePermission>> tables =
   AccessControlLists.loadAll(region);
 // For each table, write out the table's permissions to the respective
 // znode for that table.
 for (Map.Entry<byte[], ListMultimap<String,TablePermission>> t:
  tables.entrySet()) {
  byte[] entry = t.getKey();
  ListMultimap<String,TablePermission> perms = t.getValue();
  byte[] serialized = AccessControlLists.writePermissionsAsBytes(perms, conf);
  this.authManager.getZKPermissionWatcher().writeToZookeeper(entry, serialized);
 }
 initialized = true;
}

代码示例来源：origin: harbby/presto-connectors

AccessControlLists.getPermissions(conf, entry);
 byte[] serialized = AccessControlLists.writePermissionsAsBytes(perms, conf);
 zkw.writeToZookeeper(entry, serialized);
} catch (IOException ex) {
 LOG.error("Failed updating permissions mirror for '" + Bytes.toString(entry) + "'",