List of addToken() Examples

Examples of addToken()

com.plainsource.commons.text.template.token.TokenList.addToken()
limelight.io.Templater.addToken()
net.percederberg.grammatica.parser.ProductionPatternAlternative.addToken()
Adds a token to this alternative. The token is appended to the end of the element list. The multiplicity values specified define if the token is optional or required, and if it can be repeated. @param id the token (pattern) id @param min the minimum number of occurancies @param max the maximum number of occurancies, or-1 for infinite
net.sourceforge.chaperon.grammar.token.TokenList.addToken()
Add a token to this list. The method also executes the setOwner method from the token. @param token Token, which should be added @return Index of the token in this list
org.apache.beehive.netui.script.el.ExpressionTerm.addToken()
org.apache.cxf.ws.security.policy.model.SupportingToken.addToken()
@param token The token to set.
org.apache.hadoop.security.Credentials.addToken()
Add a token in the storage (in memory) @param alias the alias for the key @param t the token object
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
org.apache.hadoop.security.UserGroupInformation.addToken()
Add a token to this UGI @param token Token to be added @return true on successful add of new token
org.apache.myfaces.tobago.layout.LayoutTokens.addToken()
org.apache.stanbol.enhancer.nlp.model.AnalysedText.addToken()
org.apache.stanbol.enhancer.nlp.model.Section.addToken()
Adds an Token relative to this Sentence @param start the start of the token relative to the sentence @param end @return
org.apache.stanbol.enhancer.nlp.model.Sentence.addToken()
org.apache.wss4j.policy.model.SupportingTokens.addToken()
org.sonar.api.batch.sensor.duplication.DuplicationTokenBuilder.addToken()
Call this method to register a new token. @param line Line number of the token. Line starts at 1. @param image Text of the token.
parserTXT.Comando.addToken()
Adiciona um token ao final da lista de tokens. @param _token Token a ser adicionado. @return true caso seja inserido com sucesso.

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

        sm);
    Text host = new Text(addr.getAddress().getHostAddress() + ":"
        + addr.getPort());
    token.setService(host);
    LOG.info("Service IP address for token is " + host);
    current.addToken(token);


    current.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws IOException {
        TestSaslProtocol proxy = null;
        try {

View Full Code Here

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

    if (ClientDatanodeProtocol.LOG.isDebugEnabled()) {
      ClientDatanodeProtocol.LOG.info("ClientDatanodeProtocol addr=" + addr);
    }
    UserGroupInformation ticket = UserGroupInformation
        .createRemoteUser(block.toString());
    ticket.addToken(token);
    return (ClientDatanodeProtocol)RPC.getProxy(ClientDatanodeProtocol.class,
        ClientDatanodeProtocol.versionID, addr, ticket, conf, NetUtils
        .getDefaultSocketFactory(conf));
  }

View Full Code Here

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

    
    Token<JobTokenIdentifier> jt = TokenCache.getJobToken(credentials);
    jt.setService(new Text(address.getAddress().getHostAddress() + ":"
        + address.getPort()));
    UserGroupInformation current = UserGroupInformation.getCurrentUser();
    current.addToken(jt);


    UserGroupInformation taskOwner 
     = UserGroupInformation.createRemoteUser(firstTaskid.getJobID().toString());
    taskOwner.addToken(jt);

View Full Code Here

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

    UserGroupInformation current = UserGroupInformation.getCurrentUser();
    current.addToken(jt);


    UserGroupInformation taskOwner 
     = UserGroupInformation.createRemoteUser(firstTaskid.getJobID().toString());
    taskOwner.addToken(jt);
    
    // Set the credentials
    defaultConf.setCredentials(credentials);
    
    final TaskUmbilicalProtocol umbilical =

View Full Code Here

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

        JvmMetrics.init(task.getPhase().toString(), job.getSessionId());
        LOG.debug("Creating remote user to execute task: " + job.get("user.name"));
        childUGI = UserGroupInformation.createRemoteUser(job.get("user.name"));
        // Add tokens to new user so that it may execute its task correctly.
        for(Token<?> token : UserGroupInformation.getCurrentUser().getTokens()) {
          childUGI.addToken(token);
        }
        
        // Create a final reference to the task for the doAs block
        final Task taskFinal = task;
        childUGI.doAs(new PrivilegedExceptionAction<Object>() {

View Full Code Here

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

    // Maybe consider converting to Hadoop token, serialize de-serialize etc
    // before trying to renew the token.


    UserGroupInformation ugi = UserGroupInformation
        .createRemoteUser(user);
    ugi.addToken(ConverterUtils.convertFromYarn(token, rmAddress));


    final YarnRPC rpc = YarnRPC.create(conf);
    ApplicationClientProtocol clientRMWithDT = ugi
        .doAs(new PrivilegedAction<ApplicationClientProtocol>() {
          @Override

View Full Code Here

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

    DelegationTokenIdentifier dtId = new DelegationTokenIdentifier(owner, owner, null);
    Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>(
        dtId, sm);
    SecurityUtil.setTokenService(token, addr);
    LOG.info("Service for token is " + token.getService());
    current.addToken(token);
    current.doAs(new PrivilegedExceptionAction<Object>() {
      @Override
      public Object run() throws Exception {
        ClientProtocol proxy = null;
        try {

View Full Code Here

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

  public boolean bulkLoadHFiles(final List<Pair<byte[], String>> familyPaths,
                                final Token<?> userToken, final String bulkToken, boolean assignSeqNum) throws IOException {
    User user = getActiveUser();
    final UserGroupInformation ugi = user.getUGI();
    if(userToken != null) {
      ugi.addToken(userToken);
    } else if (provider.isHadoopSecurityEnabled()) {
      //we allow this to pass through in "simple" security mode
      //for mini cluster testing
      throw new DoNotRetryIOException("User token cannot be null");
    }

View Full Code Here

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

    final Configuration conf = TEST_UTIL.getConfiguration();
    UserGroupInformation.setConfiguration(conf);
    Token<AuthenticationTokenIdentifier> token =
        secretManager.generateToken("testuser");
    LOG.debug("Got token: " + token.toString());
    testuser.addToken(token);


    // verify the server authenticates us as this token user
    testuser.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws Exception {
        Configuration c = server.getConfiguration();

View Full Code Here

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

                  new Text(request.getFsToken().getService()));
    final String bulkToken = request.getBulkToken();
    User user = getActiveUser();
    final UserGroupInformation ugi = user.getUGI();
    if(userToken != null) {
      ugi.addToken(userToken);
    } else if (userProvider.isHadoopSecurityEnabled()) {
      //we allow this to pass through in "simple" security mode
      //for mini cluster testing
      ResponseConverter.setControllerException(controller,
          new DoNotRetryIOException("User token cannot be null"));

View Full Code Here

0 1 2 3 4 5 6

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.