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

ZKAuthorizor介绍

暂无

代码示例

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

public static synchronized Authorizor getInstance() {
 if (zkAuthorizorInstance == null)
  zkAuthorizorInstance = new ZKAuthorizor();
 return zkAuthorizorInstance;
}

代码示例来源：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 changeAuthorizations(String user, Authorizations authorizations)
  throws AccumuloSecurityException {
 zkAuthorizor.changeAuthorizations(Base64.getEncoder().encodeToString(user.getBytes(UTF_8)),
   authorizations);
}

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

protected static Authorizor getAuthorizor(ServerContext context, boolean initialize) {
 Authorizor toRet = Property.createInstanceFromPropertyName(context.getConfiguration(),
   Property.INSTANCE_SECURITY_AUTHORIZOR, Authorizor.class, ZKAuthorizor.getInstance());
 toRet.initialize(context, initialize);
 return toRet;
}

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

@Override
public Authorizations getCachedUserAuthorizations(String user) {
 return zkAuthorizor
   .getCachedUserAuthorizations(Base64.getEncoder().encodeToString(user.getBytes(UTF_8)));
}

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

@Override
public void initialize(ServerContext context, boolean initialize) {
 zkAuthorizor.initialize(context, initialize);
}

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

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

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

@Override
public void initializeSecurity(TCredentials credentials, String rootuser)
  throws AccumuloSecurityException {
 zkAuthorizor.initializeSecurity(credentials,
   Base64.getEncoder().encodeToString(rootuser.getBytes(UTF_8)));
}

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

@Override
public boolean isValidAuthorizations(String user, List<ByteBuffer> list) {
 return zkAuthorizor
   .isValidAuthorizations(Base64.getEncoder().encodeToString(user.getBytes(UTF_8)), list);
}

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

protected static Authorizor getAuthorizor(String instanceId, boolean initialize) {
 Authorizor toRet = Master.createInstanceFromPropertyName(ServerConfiguration.getSiteConfiguration(), Property.INSTANCE_SECURITY_AUTHORIZOR,
   Authorizor.class, ZKAuthorizor.getInstance());
 toRet.initialize(instanceId, initialize);
 return toRet;
}

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

@Override
 public boolean isValidAuthorizations(String user, List<ByteBuffer> auths) {
  if (auths.isEmpty()) {
   // avoid deserializing auths from ZK cache
   return true;
  }

  Authorizations userauths = getCachedUserAuthorizations(user);

  for (ByteBuffer auth : auths) {
   if (!userauths.contains(ByteBufferUtil.toBytes(auth))) {
    return false;
   }
  }

  return true;
 }
}

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

@Override
public void initialize(String instanceId, boolean initialize) {
 zkAuthorizor.initialize(instanceId, initialize);
}

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

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

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

@Override
public void initializeSecurity(TCredentials credentials, String rootuser)
  throws AccumuloSecurityException, ThriftSecurityException {
 zkAuthorizor.initializeSecurity(credentials,
   Base64.encodeBase64String(rootuser.getBytes(UTF_8)));
}

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

@Override
public boolean isValidAuthorizations(String user, List<ByteBuffer> list)
  throws AccumuloSecurityException {
 return zkAuthorizor.isValidAuthorizations(Base64.encodeBase64String(user.getBytes(UTF_8)),
   list);
}

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

public KerberosAuthorizor() {
 zkAuthorizor = new ZKAuthorizor();
}

代码示例来源：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

protected static Authorizor getAuthorizor(String instanceId, boolean initialize) {
 Authorizor toRet = SiteConfiguration.getInstance().instantiateClassProperty(
   Property.INSTANCE_SECURITY_AUTHORIZOR, Authorizor.class, ZKAuthorizor.getInstance());
 toRet.initialize(instanceId, initialize);
 return toRet;
}

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

@Override
public Authorizations getCachedUserAuthorizations(String user) throws AccumuloSecurityException {
 return zkAuthorizor
   .getCachedUserAuthorizations(Base64.encodeBase64String(user.getBytes(UTF_8)));
}

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

@Override
public void changeAuthorizations(String user, Authorizations authorizations)
  throws AccumuloSecurityException {
 zkAuthorizor.changeAuthorizations(Base64.encodeBase64String(user.getBytes(UTF_8)),
   authorizations);
}