Examples of org.apache.hadoop.security.TokenStorage.addToken()

Class org.apache.hadoop.security.TokenStorage

Examples of org.apache.hadoop.security.TokenStorage.addToken()

org.apache.hadoop.security.TokenStorage.addToken()
Add a token in the storage (in memory) @param alias the alias for the key @param t the token object

      InetAddress.getByName(dfs.getUri().getHost()).getHostAddress() 
      + ":" + dfs.getUri().getPort();
    token.setService(new Text(nnAddress));
    
    TokenStorage ts = new TokenStorage();
    ts.addToken(new Text(shortName), token);
    ts.write(out);
  }
  
  /**
   * Utility method to obtain a delegation token over http

View Full Code Here

            nn.getDelegationToken(new Text(req.getUserPrincipal().getName()));
          String s = nn.rpcAddress.getAddress().getHostAddress() 
                     + ":" + nn.rpcAddress.getPort();
          token.setService(new Text(s));
          TokenStorage ts = new TokenStorage();
          ts.addToken(new Text(ugi.getShortUserName()), token);
          ts.write(dosFinal);
          dosFinal.close();
          return null;
        }
      });

View Full Code Here

    services.add(service1);
    services.add(service2);
    
    token1.setService(service1);
    token2.setService(service2);
    ts.addToken(new Text("sometoken1"), token1);
    ts.addToken(new Text("sometoken2"), token2);
    
    // create keys and put it in
    final KeyGenerator kg = KeyGenerator.getInstance(DEFAULT_HMAC_ALGORITHM);
    String alias = "alias";

View Full Code Here

    services.add(service2);
    
    token1.setService(service1);
    token2.setService(service2);
    ts.addToken(new Text("sometoken1"), token1);
    ts.addToken(new Text("sometoken2"), token2);
    
    // create keys and put it in
    final KeyGenerator kg = KeyGenerator.getInstance(DEFAULT_HMAC_ALGORITHM);
    String alias = "alias";
    Map<Text, byte[]> m = new HashMap<Text, byte[]>(10);

View Full Code Here

    String nn3 = DelegationTokenRenewal.SCHEME + "://host3:0";
    
    TokenStorage ts = new TokenStorage();
    
    // register the token for renewal
    ts.addToken(new Text(nn1), token1);
    ts.addToken(new Text(nn2), token2);
    ts.addToken(new Text(nn3), token3);
    
    // register the tokens for renewal
    DelegationTokenRenewal.registerDelegationTokensForRenewal(

View Full Code Here

    
    TokenStorage ts = new TokenStorage();
    
    // register the token for renewal
    ts.addToken(new Text(nn1), token1);
    ts.addToken(new Text(nn2), token2);
    ts.addToken(new Text(nn3), token3);
    
    // register the tokens for renewal
    DelegationTokenRenewal.registerDelegationTokensForRenewal(
        new JobID("job1", 1), ts, conf);

View Full Code Here

    TokenStorage ts = new TokenStorage();
    
    // register the token for renewal
    ts.addToken(new Text(nn1), token1);
    ts.addToken(new Text(nn2), token2);
    ts.addToken(new Text(nn3), token3);
    
    // register the tokens for renewal
    DelegationTokenRenewal.registerDelegationTokensForRenewal(
        new JobID("job1", 1), ts, conf);
    // first 3 initial renewals + 1 real

View Full Code Here

    //to cause this one to be set for renew in 2 secs
    dfs.setTokenToRenewIn2Sec(token4); 
    System.out.println("token="+token4+" should be renewed for 2 secs");
    
    String nn4 = DelegationTokenRenewal.SCHEME + "://host4:0";
    ts.addToken(new Text(nn4), token4);
    


    JobID jid2 = new JobID("job2",1);
    DelegationTokenRenewal.registerDelegationTokensForRenewal(jid2, ts, conf);
    DelegationTokenRenewal.removeDelegationTokenRenewalForJob(jid2);

View Full Code Here

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.