org.apache.hadoop.security.Credentials.getSecretKey()方法的使用及代码示例

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

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

Credentials.getSecretKey介绍

[英]Returns the key bytes for the alias
[中]返回别名的密钥字节

代码示例

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized void deleteCredentialEntry(String name) throws IOException {
 byte[] cred = credentials.getSecretKey(new Text(name));
 if (cred != null) {
  credentials.removeSecretKey(new Text(name));
 }
 else {
  throw new IOException("Credential " + name + 
    " does not exist in " + this);
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized Metadata getMetadata(String name) throws IOException {
 if (cache.containsKey(name)) {
  return cache.get(name);
 }
 byte[] serialized = credentials.getSecretKey(new Text(name));
 if (serialized == null) {
  return null;
 }
 Metadata result = new Metadata(serialized);
 cache.put(name, result);
 return result;
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized CredentialEntry getCredentialEntry(String alias) {
 byte[] bytes = credentials.getSecretKey(new Text(alias));
 if (bytes == null) {
  return null;
 }
 return new CredentialEntry(
   alias, new String(bytes, StandardCharsets.UTF_8).toCharArray());
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized CredentialEntry createCredentialEntry(String name, char[] credential) 
  throws IOException {
 Text nameT = new Text(name);
 if (credentials.getSecretKey(nameT) != null) {
  throw new IOException("Credential " + name + 
    " already exists in " + this);
 }
 credentials.addSecretKey(new Text(name), 
   new String(credential).getBytes("UTF-8"));
 return new CredentialEntry(name, credential);
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized KeyVersion getKeyVersion(String versionName)
  throws IOException {
 byte[] bytes = credentials.getSecretKey(new Text(versionName));
 if (bytes == null) {
  return null;
 }
 return new KeyVersion(getBaseName(versionName), versionName, bytes);
}

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

/**
 * Copy job credentials to table properties
 * @param tbl
 */
public static void copyJobSecretToTableProperties(TableDesc tbl) throws IOException {
 Credentials credentials = UserGroupInformation.getCurrentUser().getCredentials();
 for (Text key : credentials.getAllSecretKeys()) {
  String keyString = key.toString();
  if (keyString.startsWith(TableDesc.SECRET_PREFIX + TableDesc.SECRET_DELIMIT)) {
   String[] comps = keyString.split(TableDesc.SECRET_DELIMIT);
   String tblName = comps[1];
   String keyName = comps[2];
   if (tbl.getTableName().equalsIgnoreCase(tblName)) {
    tbl.getProperties().put(keyName, new String(credentials.getSecretKey(key)));
   }
  }
 }
}

代码示例来源：origin: org.apache.hadoop/hadoop-common

@Override
public synchronized KeyVersion createKey(String name, byte[] material,
               Options options) throws IOException {
 Text nameT = new Text(name);
 if (credentials.getSecretKey(nameT) != null) {
  throw new IOException("Key " + name + " already exists in " + this);
 }
 if (options.getBitLength() != 8 * material.length) {
  throw new IOException("Wrong key length. Required " +
    options.getBitLength() + ", but got " + (8 * material.length));
 }
 Metadata meta = new Metadata(options.getCipher(), options.getBitLength(),
   options.getDescription(), options.getAttributes(), new Date(), 1);
 cache.put(name, meta);
 String versionName = buildVersionName(name, 0);
 credentials.addSecretKey(nameT, meta.serialize());
 credentials.addSecretKey(new Text(versionName), material);
 return new KeyVersion(name, versionName, material);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * auxiliary method to get user's secret keys..
 * @param alias
 * @return secret key from the storage
 */
public static byte[] getSecretKey(Credentials credentials, Text alias) {
 if(credentials == null)
  return null;
 return credentials.getSecretKey(alias);
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

/**
 * auxiliary method to get user's secret keys..
 * @param alias
 * @return secret key from the storage
 */
public static byte[] getSecretKey(Credentials credentials, Text alias) {
 if(credentials == null)
  return null;
 return credentials.getSecretKey(alias);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

/**
 * auxiliary method to get user's secret keys..
 * @param alias
 * @return secret key from the storage
 */
public static byte[] getSecretKey(Credentials credentials, Text alias) {
 if(credentials == null)
  return null;
 return credentials.getSecretKey(alias);
}

代码示例来源：origin: org.apache.hadoop/hadoop-mapreduce-client-core

@Test
 public void testUGICredentialsPropogation() throws Exception {
  Credentials creds = new Credentials();
  Token<?> token = mock(Token.class);
  Text tokenService = new Text("service");
  Text secretName = new Text("secret");
  byte secret[] = new byte[]{};
    
  creds.addToken(tokenService,  token);
  creds.addSecretKey(secretName, secret);
  UserGroupInformation.getLoginUser().addCredentials(creds);
  
  JobConf jobConf = new JobConf();
  Job job = new Job(jobConf);

  assertSame(token, job.getCredentials().getToken(tokenService));
  assertSame(secret, job.getCredentials().getSecretKey(secretName));
 }
}

代码示例来源：origin: io.hops/hadoop-common

@Override
public CredentialEntry getCredentialEntry(String alias) {
 byte[] bytes = credentials.getSecretKey(new Text(alias));
 if (bytes == null) {
  return null;
 }
 return new CredentialEntry(
   alias, new String(bytes, StandardCharsets.UTF_8).toCharArray());
}

代码示例来源：origin: io.hops/hadoop-common

@Override
public void deleteCredentialEntry(String name) throws IOException {
 byte[] cred = credentials.getSecretKey(new Text(name));
 if (cred != null) {
  credentials.removeSecretKey(new Text(name));
 }
 else {
  throw new IOException("Credential " + name + 
    " does not exist in " + this);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
public void deleteCredentialEntry(String name) throws IOException {
 byte[] cred = credentials.getSecretKey(new Text(name));
 if (cred != null) {
  credentials.removeSecretKey(new Text(name));
 }
 else {
  throw new IOException("Credential " + name + 
    " does not exist in " + this);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

@Override
public CredentialEntry getCredentialEntry(String alias) {
 byte[] bytes = credentials.getSecretKey(new Text(alias));
 if (bytes == null) {
  return null;
 }
 return new CredentialEntry(
   alias, new String(bytes, Charsets.UTF_8).toCharArray());
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Override
public void deleteCredentialEntry(String name) throws IOException {
 byte[] cred = credentials.getSecretKey(new Text(name));
 if (cred != null) {
  credentials.removeSecretKey(new Text(name));
 }
 else {
  throw new IOException("Credential " + name + 
    " does not exist in " + this);
 }
}

代码示例来源：origin: io.hops/hadoop-common

@Override
public CredentialEntry createCredentialEntry(String name, char[] credential) 
  throws IOException {
 Text nameT = new Text(name);
 if (credentials.getSecretKey(nameT) != null) {
  throw new IOException("Credential " + name + 
    " already exists in " + this);
 }
 credentials.addSecretKey(new Text(name), 
   new String(credential).getBytes("UTF-8"));
 return new CredentialEntry(name, credential);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
public CredentialEntry createCredentialEntry(String name, char[] credential) 
  throws IOException {
 Text nameT = new Text(name);
 if (credentials.getSecretKey(nameT) != null) {
  throw new IOException("Credential " + name + 
    " already exists in " + this);
 }
 credentials.addSecretKey(new Text(name), 
   new String(credential).getBytes("UTF-8"));
 return new CredentialEntry(name, credential);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

@Override
public synchronized KeyVersion getKeyVersion(String versionName)
  throws IOException {
 byte[] bytes = credentials.getSecretKey(new Text(versionName));
 if (bytes == null) {
  return null;
 }
 return new KeyVersion(getBaseName(versionName), versionName, bytes);
}

代码示例来源：origin: ch.cern.hadoop/hadoop-common

@Test
public void testUserProvider() throws Exception {
 Configuration conf = new Configuration();
 final String ourUrl = UserProvider.SCHEME_NAME + ":///";
 conf.set(CredentialProviderFactory.CREDENTIAL_PROVIDER_PATH, ourUrl);
 checkSpecificProvider(conf, ourUrl);
 // see if the credentials are actually in the UGI
 Credentials credentials =
   UserGroupInformation.getCurrentUser().getCredentials();
 assertArrayEquals(new byte[]{'1', '2', '3'},
   credentials.getSecretKey(new Text("pass2")));
}

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

Credentials

相关文章

    查看更多

    热门标签

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

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com