Examples of renewDelegationToken()

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

449
450
451
452
453
454
455
456
457
458
459
    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

412
413
414
415
416
417
418
419
420
421
422
    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

460
461
462
463
464
465
466
467
468
469
470
    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

378
379
380
381
382
383
384
385
386
387
388
    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

380
381
382
383
384
385
386
387
388
389
390
    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {
View Full Code Here

Examples of org.apache.hadoop.hdfs.server.protocol.NamenodeProtocols.renewDelegationToken()

380
381
382
383
384
385
386
387
388
389
390
    }
    case RENEWDELEGATIONTOKEN:
    {
      final Token<DelegationTokenIdentifier> token = new Token<DelegationTokenIdentifier>();
      token.decodeFromUrlString(delegationTokenArgument.getValue());
      final long expiryTime = np.renewDelegationToken(token);
      final String js = JsonUtil.toJsonString("long", expiryTime);
      return Response.ok(js).type(MediaType.APPLICATION_JSON).build();
    }
    case CANCELDELEGATIONTOKEN:
    {
View Full Code Here

Examples of org.apache.hadoop.mapred.JobClient.renewDelegationToken()

86
87
88
89
90
91
92
93
94
95
96
    assertTrue("createTime < current", createTime < currentTime);
    assertTrue("current < maxTime", currentTime < maxTime);
    client.renewDelegationToken(token);
    client.renewDelegationToken(token);
    try {
      bobClient.renewDelegationToken(token);
      Assert.fail("bob renew");
    } catch (AccessControlException ace) {
      // PASS
    }
    try {
View Full Code Here

Examples of org.apache.hadoop.mapred.JobTracker.renewDelegationToken()

64
65
66
67
68
69
70
71
72
73
74
    ugi.doAs(new PrivilegedExceptionAction<Object>() {
      public Object run() throws Exception {
        try {
          Token<DelegationTokenIdentifier> token = jt
              .getDelegationToken(new Text(ugi.getShortUserName()));
          jt.renewDelegationToken(token);
          jt.cancelDelegationToken(token);
        } catch (IOException e) {
          e.printStackTrace();
          throw e;
        }
View Full Code Here

Examples of org.apache.hadoop.mapreduce.v2.api.MRClientProtocol.renewDelegationToken()

64
65
66
67
68
69
70
71
72
73
74
        SecurityUtil.getTokenServiceAddr(token));
    try {
      RenewDelegationTokenRequest request = Records
          .newRecord(RenewDelegationTokenRequest.class);
      request.setDelegationToken(dToken);
      return histProxy.renewDelegationToken(request).getNextExpirationTime();
    } finally {
      stopHistoryProxy(histProxy);
    }

  }
View Full Code Here

Examples of org.apache.hadoop.yarn.api.ApplicationClientProtocol.renewDelegationToken()

101
102
103
104
105
106
107
108
109
110
111
      if (rmClient != null) {
        try {
          RenewDelegationTokenRequest request =
              Records.newRecord(RenewDelegationTokenRequest.class);
          request.setDelegationToken(convertToProtoToken(token));
          return rmClient.renewDelegationToken(request).getNextExpirationTime();
        } catch (YarnException e) {
          throw new IOException(e);
        } finally {
          RPC.stopProxy(rmClient);
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.