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

ZKAuthorizor.initUser介绍

暂无

代码示例

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

@Override
public void initUser(String user) throws AccumuloSecurityException {
 zkAuthorizor.initUser(Base64.getEncoder().encodeToString(user.getBytes(UTF_8)));
}

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

@Override
public void initializeSecurity(TCredentials itw, String rootuser)
  throws AccumuloSecurityException {
 ZooReaderWriter zoo = context.getZooReaderWriter();
 // create the root user with all system privileges, no table privileges, and no record-level
 // authorizations
 Set<SystemPermission> rootPerms = new TreeSet<>();
 for (SystemPermission p : SystemPermission.values())
  rootPerms.add(p);
 Map<Table.ID,Set<TablePermission>> tablePerms = new HashMap<>();
 // Allow the root user to flush the metadata tables
 tablePerms.put(MetadataTable.ID, Collections.singleton(TablePermission.ALTER_TABLE));
 tablePerms.put(RootTable.ID, Collections.singleton(TablePermission.ALTER_TABLE));
 try {
  // prep parent node of users with root username
  if (!zoo.exists(ZKUserPath))
   zoo.putPersistentData(ZKUserPath, rootuser.getBytes(UTF_8), NodeExistsPolicy.FAIL);
  initUser(rootuser);
  zoo.putPersistentData(ZKUserPath + "/" + rootuser + ZKUserAuths,
    ZKSecurityTool.convertAuthorizations(Authorizations.EMPTY), NodeExistsPolicy.FAIL);
 } catch (KeeperException | InterruptedException e) {
  log.error("{}", e.getMessage(), e);
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

@Override
public void initUser(String user) throws AccumuloSecurityException {
 zkAuthorizor.initUser(Base64.encodeBase64String(user.getBytes(UTF_8)));
}

代码示例来源：origin: org.apache.accumulo/accumulo-server

@Override
public void initializeSecurity(TCredentials itw, String rootuser) throws AccumuloSecurityException {
 IZooReaderWriter zoo = ZooReaderWriter.getRetryingInstance();
 // create the root user with all system privileges, no table privileges, and no record-level authorizations
 Set<SystemPermission> rootPerms = new TreeSet<SystemPermission>();
 for (SystemPermission p : SystemPermission.values())
  rootPerms.add(p);
 Map<String,Set<TablePermission>> tablePerms = new HashMap<String,Set<TablePermission>>();
 // Allow the root user to flush the !METADATA table
 tablePerms.put(Constants.METADATA_TABLE_ID, Collections.singleton(TablePermission.ALTER_TABLE));
 try {
  // prep parent node of users with root username
  if (!zoo.exists(ZKUserPath))
   zoo.putPersistentData(ZKUserPath, rootuser.getBytes(UTF_8), NodeExistsPolicy.FAIL);
  initUser(rootuser);
  zoo.putPersistentData(ZKUserPath + "/" + rootuser + ZKUserAuths, ZKSecurityTool.convertAuthorizations(Constants.NO_AUTHS), NodeExistsPolicy.FAIL);
 } catch (KeeperException e) {
  log.error(e, e);
  throw new RuntimeException(e);
 } catch (InterruptedException e) {
  log.error(e, e);
  throw new RuntimeException(e);
 }
}

代码示例来源：origin: org.apache.accumulo/accumulo-server-base

@Override
public void initializeSecurity(TCredentials itw, String rootuser)
  throws AccumuloSecurityException {
 IZooReaderWriter zoo = ZooReaderWriter.getInstance();
 // create the root user with all system privileges, no table privileges, and no record-level
 // authorizations
 Set<SystemPermission> rootPerms = new TreeSet<>();
 for (SystemPermission p : SystemPermission.values())
  rootPerms.add(p);
 Map<String,Set<TablePermission>> tablePerms = new HashMap<>();
 // Allow the root user to flush the metadata tables
 tablePerms.put(MetadataTable.ID, Collections.singleton(TablePermission.ALTER_TABLE));
 tablePerms.put(RootTable.ID, Collections.singleton(TablePermission.ALTER_TABLE));
 try {
  // prep parent node of users with root username
  if (!zoo.exists(ZKUserPath))
   zoo.putPersistentData(ZKUserPath, rootuser.getBytes(UTF_8), NodeExistsPolicy.FAIL);
  initUser(rootuser);
  zoo.putPersistentData(ZKUserPath + "/" + rootuser + ZKUserAuths,
    ZKSecurityTool.convertAuthorizations(Authorizations.EMPTY), NodeExistsPolicy.FAIL);
 } catch (KeeperException e) {
  log.error("{}", e.getMessage(), e);
  throw new RuntimeException(e);
 } catch (InterruptedException e) {
  log.error("{}", e.getMessage(), e);
  throw new RuntimeException(e);
 }
}