Uses of Class
org.apache.hadoop.yarn.api.records.Token
Packages that use Token
Package
Description
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
-
Uses of Token in org.apache.hadoop.mapreduce.v2.api.protocolrecords
Methods in org.apache.hadoop.mapreduce.v2.api.protocolrecords that return TokenModifier and TypeMethodDescriptionCancelDelegationTokenRequest.getDelegationToken()RenewDelegationTokenRequest.getDelegationToken()Methods in org.apache.hadoop.mapreduce.v2.api.protocolrecords with parameters of type TokenModifier and TypeMethodDescriptionvoidCancelDelegationTokenRequest.setDelegationToken(Token dToken) voidRenewDelegationTokenRequest.setDelegationToken(Token dToken) -
Uses of Token in org.apache.hadoop.yarn.api.protocolrecords
Methods in org.apache.hadoop.yarn.api.protocolrecords that return TokenModifier and TypeMethodDescriptionabstract TokenAllocateResponse.getAMRMToken()The AMRMToken that belong to this attemptabstract TokenStartContainerRequest.getContainerToken()Get the container token to be used for authorization during starting container.abstract TokenGetDelegationTokenResponse.getRMDelegationToken()The Delegation tokens have a identifier which maps toAbstractDelegationTokenIdentifier.Methods in org.apache.hadoop.yarn.api.protocolrecords that return types with arguments of type TokenModifier and TypeMethodDescriptionIncreaseContainersResourceRequest.getContainersToIncrease()Get a list of container tokens to be used for authorization during container resource increase.ContainerUpdateRequest.getContainersToUpdate()Get a list of container tokens to be used for authorization during container resource update.Methods in org.apache.hadoop.yarn.api.protocolrecords with parameters of type TokenModifier and TypeMethodDescriptionstatic AllocateResponseAllocateResponse.newInstance(int responseId, List<ContainerStatus> completedContainers, List<Container> allocatedContainers, List<NodeReport> updatedNodes, Resource availResources, AMCommand command, int numClusterNodes, PreemptionMessage preempt, List<NMToken> nmTokens, Token amRMToken, List<UpdatedContainer> updatedContainers) static AllocateResponseAllocateResponse.newInstance(int responseId, List<ContainerStatus> completedContainers, List<Container> allocatedContainers, List<NodeReport> updatedNodes, Resource availResources, AMCommand command, int numClusterNodes, PreemptionMessage preempt, List<NMToken> nmTokens, Token amRMToken, List<UpdatedContainer> updatedContainers, CollectorInfo collectorInfo) static AllocateResponseAllocateResponse.newInstance(int responseId, List<ContainerStatus> completedContainers, List<Container> allocatedContainers, List<NodeReport> updatedNodes, Resource availResources, AMCommand command, int numClusterNodes, PreemptionMessage preempt, List<NMToken> nmTokens, Token amRMToken, List<UpdatedContainer> updatedContainers, CollectorInfo collectorInfo, org.apache.hadoop.yarn.api.records.EnhancedHeadroom enhancedHeadroom) static GetDelegationTokenResponseGetDelegationTokenResponse.newInstance(Token rmDTToken) static StartContainerRequestStartContainerRequest.newInstance(ContainerLaunchContext context, Token container) abstract voidAllocateResponse.setAMRMToken(Token amRMToken) abstract voidStartContainerRequest.setContainerToken(Token container) abstract voidGetDelegationTokenResponse.setRMDelegationToken(Token rmDTToken) Method parameters in org.apache.hadoop.yarn.api.protocolrecords with type arguments of type TokenModifier and TypeMethodDescriptionstatic ContainerUpdateRequestContainerUpdateRequest.newInstance(List<Token> containersToIncrease) IncreaseContainersResourceRequest.newInstance(List<Token> containersToIncrease) abstract voidIncreaseContainersResourceRequest.setContainersToIncrease(List<Token> containersToIncrease) Set container tokens to be used during container resource increase.abstract voidContainerUpdateRequest.setContainersToUpdate(List<Token> containersToUpdate) Set container tokens to be used during container resource increase. -
Uses of Token in org.apache.hadoop.yarn.api.records
Methods in org.apache.hadoop.yarn.api.records that return TokenModifier and TypeMethodDescriptionabstract TokenApplicationReport.getAMRMToken()Get the AMRM token of the application.abstract TokenApplicationReport.getClientToAMToken()Get the client token for communicating with theApplicationMaster.abstract TokenCollectorInfo.getCollectorToken()Get delegation token for app collector which AM will use to publish entities.abstract TokenContainer.getContainerToken()Get theContainerTokenfor the container.abstract TokenNMToken.getToken()Get theTokenused for authenticating withNodeManagerstatic TokenMethods in org.apache.hadoop.yarn.api.records with parameters of type TokenModifier and TypeMethodDescriptionstatic ApplicationReportApplicationReport.newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long submitTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken) static ApplicationReportApplicationReport.newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long submitTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) static ApplicationReportApplicationReport.newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken) static ApplicationReportApplicationReport.newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long launchTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) static ApplicationReportApplicationReport.newInstance(ApplicationId applicationId, ApplicationAttemptId applicationAttemptId, String user, String queue, String name, String host, int rpcPort, Token clientToAMToken, YarnApplicationState state, String diagnostics, String url, long startTime, long finishTime, FinalApplicationStatus finalStatus, ApplicationResourceUsageReport appResources, String origTrackingUrl, float progress, String applicationType, Token amRmToken, Set<String> tags, boolean unmanagedApplication, Priority priority, String appNodeLabelExpression, String amNodeLabelExpression) static CollectorInfoCollectorInfo.newInstance(String collectorAddr, Token token) static ContainerContainer.newInstance(ContainerId containerId, NodeId nodeId, String nodeHttpAddress, Resource resource, Priority priority, Token containerToken) static ContainerContainer.newInstance(ContainerId containerId, NodeId nodeId, String nodeHttpAddress, Resource resource, Priority priority, Token containerToken, ExecutionType executionType) static NMTokenabstract voidApplicationReport.setAMRMToken(Token amRmToken) abstract voidApplicationReport.setClientToAMToken(Token clientToAMToken) abstract voidCollectorInfo.setCollectorToken(Token token) abstract voidContainer.setContainerToken(Token containerToken) abstract void -
Uses of Token in org.apache.hadoop.yarn.client.api
Methods in org.apache.hadoop.yarn.client.api that return TokenModifier and TypeMethodDescriptionstatic TokenNMTokenCache.getNMToken(String nodeAddr) Returns NMToken, null if absent.abstract TokenYarnClient.getRMDelegationToken(Text renewer) Get a delegation token so as to be able to talk to YARN using those tokens.Returns NMToken, null if absentMethods in org.apache.hadoop.yarn.client.api with parameters of type TokenModifier and TypeMethodDescriptionstatic voidNMTokenCache.setNMToken(String nodeAddr, Token token) Sets the NMToken for node address only in the singleton obtained fromNMTokenCache.getSingleton().voidSets the NMToken for node address -
Uses of Token in org.apache.hadoop.yarn.util
Methods in org.apache.hadoop.yarn.util with parameters of type TokenModifier and TypeMethodDescriptionstatic <T extends TokenIdentifier>
Token<T>ConverterUtils.convertFromYarn(Token protoToken, InetSocketAddress serviceAddr) Convert a protobuf token into a rpc token and set its service.static <T extends TokenIdentifier>
Token<T>ConverterUtils.convertFromYarn(Token protoToken, Text service) Convert a protobuf token into a rpc token and set its service.