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

YarnAppSecurityManager.writeDelegationTokenToFile介绍

[英]Write the current delegation token to the token file.
[中]将当前委派令牌写入令牌文件。

代码示例

代码示例来源：origin: apache/incubator-gobblin

/**
 * Renew the existing delegation token.
 */
private synchronized void renewDelegationToken() throws IOException, InterruptedException {
 this.token.renew(this.fs.getConf());
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants if this is not the first login
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}

代码示例来源：origin: apache/incubator-gobblin

/**
 * Login the user from a given keytab file.
 */
private void loginFromKeytab() throws IOException {
 String keyTabFilePath = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_FILE_PATH);
 if (Strings.isNullOrEmpty(keyTabFilePath)) {
  throw new IOException("Keytab file path is not defined for Kerberos login");
 }
 if (!new File(keyTabFilePath).exists()) {
  throw new IOException("Keytab file not found at: " + keyTabFilePath);
 }
 String principal = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_PRINCIPAL_NAME);
 if (Strings.isNullOrEmpty(principal)) {
  principal = this.loginUser.getShortUserName() + "/localhost@LOCALHOST";
 }
 Configuration conf = new Configuration();
 conf.set("hadoop.security.authentication",
   UserGroupInformation.AuthenticationMethod.KERBEROS.toString().toLowerCase());
 UserGroupInformation.setConfiguration(conf);
 UserGroupInformation.loginUserFromKeytab(principal, keyTabFilePath);
 LOGGER.info(String.format("Logged in from keytab file %s using principal %s", keyTabFilePath, principal));
 this.loginUser = UserGroupInformation.getLoginUser();
 getNewDelegationTokenForLoginUser();
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}

代码示例来源：origin: apache/incubator-gobblin

@Test(dependsOnMethods = "testGetNewDelegationTokenForLoginUser")
public void testWriteDelegationTokenToFile() throws IOException {
 this.yarnAppSecurityManager.writeDelegationTokenToFile();
 Assert.assertTrue(this.localFs.exists(this.tokenFilePath));
 assertToken(YarnHelixUtils.readTokensFromFile(this.tokenFilePath, this.configuration));
}

代码示例来源：origin: org.apache.gobblin/gobblin-yarn

/**
 * Renew the existing delegation token.
 */
private synchronized void renewDelegationToken() throws IOException, InterruptedException {
 this.token.renew(this.fs.getConf());
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants if this is not the first login
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}

代码示例来源：origin: org.apache.gobblin/gobblin-yarn

/**
 * Login the user from a given keytab file.
 */
private void loginFromKeytab() throws IOException {
 String keyTabFilePath = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_FILE_PATH);
 if (Strings.isNullOrEmpty(keyTabFilePath)) {
  throw new IOException("Keytab file path is not defined for Kerberos login");
 }
 if (!new File(keyTabFilePath).exists()) {
  throw new IOException("Keytab file not found at: " + keyTabFilePath);
 }
 String principal = this.config.getString(GobblinYarnConfigurationKeys.KEYTAB_PRINCIPAL_NAME);
 if (Strings.isNullOrEmpty(principal)) {
  principal = this.loginUser.getShortUserName() + "/localhost@LOCALHOST";
 }
 Configuration conf = new Configuration();
 conf.set("hadoop.security.authentication",
   UserGroupInformation.AuthenticationMethod.KERBEROS.toString().toLowerCase());
 UserGroupInformation.setConfiguration(conf);
 UserGroupInformation.loginUserFromKeytab(principal, keyTabFilePath);
 LOGGER.info(String.format("Logged in from keytab file %s using principal %s", keyTabFilePath, principal));
 this.loginUser = UserGroupInformation.getLoginUser();
 getNewDelegationTokenForLoginUser();
 writeDelegationTokenToFile();
 if (!this.firstLogin) {
  // Send a message to the controller and all the participants
  sendTokenFileUpdatedMessage(InstanceType.CONTROLLER);
  sendTokenFileUpdatedMessage(InstanceType.PARTICIPANT);
 }
}