org.apache.accumulo.core.client.Connector.whoami()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.3k)|赞(0)|评价(0)|浏览(103)

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

Connector.whoami介绍

[英]Get the current user for this connector
[中]获取此连接器的当前用户

代码示例

代码示例来源：origin: Accla/graphulo

/**
 * Check authenticationToken works for this user.
 */
private void checkCredentials() {
 try {
  if (!connector.securityOperations().authenticateUser(connector.whoami(), authenticationToken))
   throw new IllegalArgumentException("instance " + connector.getInstance().getInstanceName() + ": bad username " + connector.whoami() + " with token " + authenticationToken);
 } catch (AccumuloException | AccumuloSecurityException e) {
  throw new IllegalArgumentException("instance " + connector.getInstance().getInstanceName() + ": error with username " + connector.whoami() + " with token " + authenticationToken, e);
 }
}

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

@Override
public int execute(final String fullCommand, final CommandLine cl, final Shell shellState)
  throws AccumuloException, AccumuloSecurityException {
 final String user = cl.getOptionValue(userOpt.getOpt(), shellState.getConnector().whoami());
 final String scanOpts = cl.hasOption(clearOptAuths.getOpt()) ? null
   : cl.getOptionValue(scanOptAuths.getOpt());
 shellState.getConnector().securityOperations().changeUserAuthorizations(user,
   ScanCommand.parseAuthorizations(scanOpts));
 Shell.log.debug("Changed record-level authorizations for user " + user);
 return 0;
}

代码示例来源：origin: NationalSecurityAgency/datawave

protected List<String> readAccumuloAuthorizations() {
  try {
    Connector connector = accumuloConnectionFactory.getConnection(null, AccumuloConnectionFactory.Priority.ADMIN, new HashMap<>());
    Authorizations auths = connector.securityOperations().getUserAuthorizations(connector.whoami());
    return Arrays.asList(auths.toString().split("\\s*,\\s*"));
  } catch (Exception e) {
    throw new RuntimeException("Unable to acquire accumulo connector: " + e.getMessage(), e);
  }
}

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

protected Authorizations getAuths(final CommandLine cl, final Shell shellState)
  throws AccumuloSecurityException, AccumuloException {
 final String user = shellState.getConnector().whoami();
 Authorizations auths = shellState.getConnector().securityOperations()
   .getUserAuthorizations(user);
 if (cl.hasOption(scanOptAuths.getOpt())) {
  auths = ScanCommand.parseAuthorizations(cl.getOptionValue(scanOptAuths.getOpt()));
 }
 return auths;
}

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

@Override
public int execute(final String fullCommand, final CommandLine cl, final Shell shellState)
  throws IOException {
 shellState.getReader().println(shellState.getConnector().whoami());
 return 0;
}

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

@Override
public int execute(final String fullCommand, final CommandLine cl, final Shell shellState)
  throws AccumuloException, AccumuloSecurityException, IOException {
 final String user = cl.getOptionValue(userOpt.getOpt(), shellState.getConnector().whoami());
 // Sort authorizations
 Authorizations auths = shellState.getConnector().securityOperations()
   .getUserAuthorizations(user);
 List<String> set = sortAuthorizations(auths);
 shellState.getReader().println(StringUtils.join(set, ','));
 return 0;
}

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

@Before
public void configureInstance() throws Exception {
 conn = getConnector();
 inst = conn.getInstance();
 ReplicationTable.setOnline(conn);
 conn.securityOperations().grantTablePermission(conn.whoami(), MetadataTable.NAME,
   TablePermission.WRITE);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.READ);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.WRITE);
}

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

@Before
public void setupInstance() throws Exception {
 conn = getConnector();
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.WRITE);
 conn.securityOperations().grantTablePermission(conn.whoami(), MetadataTable.NAME,
   TablePermission.WRITE);
 ReplicationTable.setOnline(conn);
}

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

@Before
public void setupInstance() throws Exception {
 conn = getConnector();
 ReplicationTable.setOnline(conn);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.WRITE);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.READ);
 fs = EasyMock.mock(VolumeManager.class);
}

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

@Before
public void initialize() throws Exception {
 conn = getConnector();
 rcrr = new MockRemoveCompleteReplicationRecords(conn);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.READ);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.WRITE);
 ReplicationTable.setOnline(conn);
}

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

@Before
public void init() throws Exception {
 conn = getConnector();
 assigner = new MockSequentialWorkAssigner(conn);
 // grant ourselves write to the replication table
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.READ);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.WRITE);
 ReplicationTable.setOnline(conn);
}

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

@Before
public void init() throws Exception {
 conn = getConnector();
 assigner = new MockUnorderedWorkAssigner(conn);
 ReplicationTable.setOnline(conn);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.WRITE);
 conn.securityOperations().grantTablePermission(conn.whoami(), ReplicationTable.NAME,
   TablePermission.READ);
}

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

@Override
 public Void run() throws Exception {
  // As the "root" user, open up the connection and get a delegation token
  Connector conn = mac.getConnector(qualifiedNewUser, new KerberosToken());
  log.info("Created connector as {}", qualifiedNewUser);
  assertEquals(qualifiedNewUser, conn.whoami());
  conn.securityOperations().getDelegationToken(new DelegationTokenConfig());
  return null;
 }
});

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

@Before
public void setupInstance() throws Exception {
 conn = getConnector();
 tableName = getUniqueNames(1)[0];
 conn.securityOperations().changeUserAuthorizations(conn.whoami(), AUTHS);
}

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

@Before
public void setupInstance() throws Exception {
 conn = getConnector();
 tableName = getUniqueNames(1)[0];
 conn.securityOperations().changeUserAuthorizations(conn.whoami(), AUTHS);
}

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

@Override
 public Void run() throws Exception {
  Connector conn = mac.getConnector(rootUser.getPrincipal(), new KerberosToken());
  log.info("Created connector as {}", rootUser.getPrincipal());
  assertEquals(rootUser.getPrincipal(), conn.whoami());
  // Make sure the system user doesn't exist -- this will force some RPC to happen server-side
  createTableWithDataAndCompact(conn);
  assertEquals(users, conn.securityOperations().listLocalUsers());
  return null;
 }
});

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

public static IteratorSetting iteratorSetting(int priority, int sleepAfterFirstWrite,
  long batchWriterTimeout, long batchWriterMaxMemory, int numEntriesToWrite, String tableName,
  Connector connector, AuthenticationToken token, boolean clearCacheAfterFirstWrite,
  boolean splitAfterFirstWrite) {
 return iteratorSetting(priority, sleepAfterFirstWrite, batchWriterTimeout, batchWriterMaxMemory,
   numEntriesToWrite, tableName, connector.getInstance().getZooKeepers(),
   connector.getInstance().getInstanceName(),
   connector.getInstance().getZooKeepersSessionTimeOut(), connector.whoami(), token,
   clearCacheAfterFirstWrite, splitAfterFirstWrite);
}

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

@Override
 public AuthenticationToken run() throws Exception {
  Connector conn = mac.getConnector(rootUser.getPrincipal(), new KerberosToken());
  log.info("Created connector as {}", rootUser.getPrincipal());
  assertEquals(rootUser.getPrincipal(), conn.whoami());
  // Should fail
  return conn.securityOperations().getDelegationToken(
    new DelegationTokenConfig().setTokenLifetime(Long.MAX_VALUE, TimeUnit.MILLISECONDS));
 }
});

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

@Override
 public AuthenticationToken run() throws Exception {
  Connector conn = mac.getConnector(rootUser.getPrincipal(), new KerberosToken());
  log.info("Created connector as {}", rootUser.getPrincipal());
  assertEquals(rootUser.getPrincipal(), conn.whoami());
  AuthenticationToken token = conn.securityOperations()
    .getDelegationToken(new DelegationTokenConfig());
  assertTrue("Could not get tables with delegation token", mac
    .getConnector(rootUser.getPrincipal(), token).tableOperations().list().size() > 0);
  return token;
 }
});

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

@Override
 public AuthenticationToken run() throws Exception {
  Connector conn = mac.getConnector(rootUser.getPrincipal(), new KerberosToken());
  log.info("Created connector as {}", rootUser.getPrincipal());
  assertEquals(rootUser.getPrincipal(), conn.whoami());
  AuthenticationToken token = conn.securityOperations()
    .getDelegationToken(new DelegationTokenConfig());
  assertTrue("Could not get tables with delegation token", mac
    .getConnector(rootUser.getPrincipal(), token).tableOperations().list().size() > 0);
  return token;
 }
});

内容来源于网络，如有侵权，请联系作者删除！

Connector

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com