YARN-805. Fix javadoc and annotations on classes in the yarn-api package. Contributed by Jian He.

git-svn-id: https://svn.apache.org/repos/asf/hadoop/common/trunk@1493992 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Siddharth Seth 2013-06-18 03:10:11 +00:00
parent 52ebd9c389
commit 2b14656ab5
182 changed files with 1108 additions and 245 deletions

View File

@ -241,7 +241,7 @@ protected void containerFailedOnHost(String hostName) {
ResourceRequest zeroedRequest = ResourceRequest zeroedRequest =
ResourceRequest.newInstance(req.getPriority(), ResourceRequest.newInstance(req.getPriority(),
req.getResourceName(), req.getCapability(), req.getResourceName(), req.getCapability(),
req.getNumContainers()); req.getNumContainers(), req.getRelaxLocality());
zeroedRequest.setNumContainers(0); zeroedRequest.setNumContainers(0);
// to be sent to RM on next heartbeat // to be sent to RM on next heartbeat

View File

@ -1219,7 +1219,7 @@ public synchronized Allocation allocate(
for (ResourceRequest req : ask) { for (ResourceRequest req : ask) {
ResourceRequest reqCopy = ResourceRequest.newInstance(req ResourceRequest reqCopy = ResourceRequest.newInstance(req
.getPriority(), req.getResourceName(), req.getCapability(), req .getPriority(), req.getResourceName(), req.getCapability(), req
.getNumContainers()); .getNumContainers(), req.getRelaxLocality());
askCopy.add(reqCopy); askCopy.add(reqCopy);
} }
lastAsk = ask; lastAsk = ask;

View File

@ -406,6 +406,9 @@ Release 2.1.0-beta - UNRELEASED
YARN-833. Moved Graph and VisualizeStateMachine into yarn.state package. YARN-833. Moved Graph and VisualizeStateMachine into yarn.state package.
(Zhijie Shen via vinodkv) (Zhijie Shen via vinodkv)
YARN-805. Fix javadoc and annotations on classes in the yarn-api
package. (Jian He via sseth)
OPTIMIZATIONS OPTIMIZATIONS
YARN-512. Log aggregation root directory check is more expensive than it YARN-512. Log aggregation root directory check is more expensive than it

View File

@ -23,6 +23,7 @@
import org.apache.hadoop.classification.InterfaceAudience.Private; import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest; import org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenRequest;
import org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse; import org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse;
import org.apache.hadoop.yarn.api.protocolrecords.GetAllApplicationsRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetAllApplicationsRequest;
@ -73,7 +74,7 @@ public interface ApplicationClientProtocol {
* a new application.</p> * a new application.</p>
* *
* <p>The <code>ResourceManager</code> also responds with details such * <p>The <code>ResourceManager</code> also responds with details such
* as minimum and maximum resource capabilities in the cluster as specified in * as maximum resource capabilities in the cluster as specified in
* {@link GetNewApplicationResponse}.</p> * {@link GetNewApplicationResponse}.</p>
* *
* @param request request to get a new <code>ApplicationId</code> * @param request request to get a new <code>ApplicationId</code>
@ -83,6 +84,8 @@ public interface ApplicationClientProtocol {
* @throws IOException * @throws IOException
* @see #submitApplication(SubmitApplicationRequest) * @see #submitApplication(SubmitApplicationRequest)
*/ */
@Public
@Stable
public GetNewApplicationResponse getNewApplication( public GetNewApplicationResponse getNewApplication(
GetNewApplicationRequest request) GetNewApplicationRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -112,6 +115,8 @@ public GetNewApplicationResponse getNewApplication(
* @throws IOException * @throws IOException
* @see #getNewApplication(GetNewApplicationRequest) * @see #getNewApplication(GetNewApplicationRequest)
*/ */
@Public
@Stable
public SubmitApplicationResponse submitApplication( public SubmitApplicationResponse submitApplication(
SubmitApplicationRequest request) SubmitApplicationRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -129,13 +134,15 @@ public SubmitApplicationResponse submitApplication(
* <p>Currently, the <code>ResourceManager</code> returns an empty response * <p>Currently, the <code>ResourceManager</code> returns an empty response
* on success and throws an exception on rejecting the request.</p> * on success and throws an exception on rejecting the request.</p>
* *
* @param request request to abort a submited application * @param request request to abort a submitted application
* @return <code>ResourceManager</code> returns an empty response * @return <code>ResourceManager</code> returns an empty response
* on success and throws an exception on rejecting the request * on success and throws an exception on rejecting the request
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
* @see #getQueueUserAcls(GetQueueUserAclsInfoRequest) * @see #getQueueUserAcls(GetQueueUserAclsInfoRequest)
*/ */
@Public
@Stable
public KillApplicationResponse forceKillApplication( public KillApplicationResponse forceKillApplication(
KillApplicationRequest request) KillApplicationRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -171,6 +178,8 @@ public KillApplicationResponse forceKillApplication(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetApplicationReportResponse getApplicationReport( public GetApplicationReportResponse getApplicationReport(
GetApplicationReportRequest request) GetApplicationReportRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -189,6 +198,8 @@ public GetApplicationReportResponse getApplicationReport(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetClusterMetricsResponse getClusterMetrics( public GetClusterMetricsResponse getClusterMetrics(
GetClusterMetricsRequest request) GetClusterMetricsRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -211,6 +222,8 @@ public GetClusterMetricsResponse getClusterMetrics(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetAllApplicationsResponse getAllApplications( public GetAllApplicationsResponse getAllApplications(
GetAllApplicationsRequest request) GetAllApplicationsRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -228,6 +241,8 @@ public GetAllApplicationsResponse getAllApplications(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetClusterNodesResponse getClusterNodes( public GetClusterNodesResponse getClusterNodes(
GetClusterNodesRequest request) GetClusterNodesRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -247,6 +262,8 @@ public GetClusterNodesResponse getClusterNodes(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetQueueInfoResponse getQueueInfo( public GetQueueInfoResponse getQueueInfo(
GetQueueInfoRequest request) GetQueueInfoRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -264,6 +281,8 @@ public GetQueueInfoResponse getQueueInfo(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetQueueUserAclsInfoResponse getQueueUserAcls( public GetQueueUserAclsInfoResponse getQueueUserAcls(
GetQueueUserAclsInfoRequest request) GetQueueUserAclsInfoRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -272,7 +291,7 @@ public GetQueueUserAclsInfoResponse getQueueUserAcls(
* <p>The interface used by clients to get delegation token, enabling the * <p>The interface used by clients to get delegation token, enabling the
* containers to be able to talk to the service using those tokens. * containers to be able to talk to the service using those tokens.
* *
* <p> The <code>ResourceManager</code> responds with the delegation token * <p> The <code>ResourceManager</code> responds with the delegation
* {@link Token} that can be used by the client to speak to this * {@link Token} that can be used by the client to speak to this
* service. * service.
* @param request request to get a delegation token for the client. * @param request request to get a delegation token for the client.
@ -280,12 +299,14 @@ public GetQueueUserAclsInfoResponse getQueueUserAcls(
* @throws YarnException * @throws YarnException
* @throws IOException * @throws IOException
*/ */
@Public
@Stable
public GetDelegationTokenResponse getDelegationToken( public GetDelegationTokenResponse getDelegationToken(
GetDelegationTokenRequest request) GetDelegationTokenRequest request)
throws YarnException, IOException; throws YarnException, IOException;
/** /**
* Renew an existing delegation token. * Renew an existing delegation {@link Token}.
* *
* @param request the delegation token to be renewed. * @param request the delegation token to be renewed.
* @return the new expiry time for the delegation token. * @return the new expiry time for the delegation token.
@ -293,12 +314,13 @@ public GetDelegationTokenResponse getDelegationToken(
* @throws IOException * @throws IOException
*/ */
@Private @Private
@Unstable
public RenewDelegationTokenResponse renewDelegationToken( public RenewDelegationTokenResponse renewDelegationToken(
RenewDelegationTokenRequest request) throws YarnException, RenewDelegationTokenRequest request) throws YarnException,
IOException; IOException;
/** /**
* Cancel an existing delegation token. * Cancel an existing delegation {@link Token}.
* *
* @param request the delegation token to be cancelled. * @param request the delegation token to be cancelled.
* @return an empty response. * @return an empty response.
@ -306,6 +328,7 @@ public RenewDelegationTokenResponse renewDelegationToken(
* @throws IOException * @throws IOException
*/ */
@Private @Private
@Unstable
public CancelDelegationTokenResponse cancelDelegationToken( public CancelDelegationTokenResponse cancelDelegationToken(
CancelDelegationTokenRequest request) throws YarnException, CancelDelegationTokenRequest request) throws YarnException,
IOException; IOException;

View File

@ -17,9 +17,13 @@
*/ */
package org.apache.hadoop.yarn.api; package org.apache.hadoop.yarn.api;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.ipc.ProtocolInfo; import org.apache.hadoop.ipc.ProtocolInfo;
import org.apache.hadoop.yarn.proto.ApplicationClientProtocol.ApplicationClientProtocolService; import org.apache.hadoop.yarn.proto.ApplicationClientProtocol.ApplicationClientProtocolService;
@Private
@Unstable
@ProtocolInfo(protocolName = "org.apache.hadoop.yarn.api.ApplicationClientProtocolPB", @ProtocolInfo(protocolName = "org.apache.hadoop.yarn.api.ApplicationClientProtocolPB",
protocolVersion = 1) protocolVersion = 1)
public interface ApplicationClientProtocolPB extends ApplicationClientProtocolService.BlockingInterface { public interface ApplicationClientProtocolPB extends ApplicationClientProtocolService.BlockingInterface {

View File

@ -18,6 +18,8 @@
package org.apache.hadoop.yarn.api; package org.apache.hadoop.yarn.api;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Evolving;
import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.security.UserGroupInformation;
import org.apache.hadoop.util.Shell; import org.apache.hadoop.util.Shell;
@ -27,6 +29,8 @@
* *
* TODO: Investigate the semantics and security of each cross-boundary refs. * TODO: Investigate the semantics and security of each cross-boundary refs.
*/ */
@Public
@Evolving
public interface ApplicationConstants { public interface ApplicationConstants {
/** /**
@ -35,6 +39,9 @@ public interface ApplicationConstants {
*/ */
public static final String APP_SUBMIT_TIME_ENV = "APP_SUBMIT_TIME_ENV"; public static final String APP_SUBMIT_TIME_ENV = "APP_SUBMIT_TIME_ENV";
/**
* The cache file into which container token is written
*/
public static final String CONTAINER_TOKEN_FILE_ENV_NAME = public static final String CONTAINER_TOKEN_FILE_ENV_NAME =
UserGroupInformation.HADOOP_TOKEN_FILE_LOCATION; UserGroupInformation.HADOOP_TOKEN_FILE_LOCATION;
@ -46,6 +53,10 @@ public interface ApplicationConstants {
public static final String APPLICATION_WEB_PROXY_BASE_ENV = public static final String APPLICATION_WEB_PROXY_BASE_ENV =
"APPLICATION_WEB_PROXY_BASE"; "APPLICATION_WEB_PROXY_BASE";
/**
* The temporary environmental variable for container log directory. This
* should be replaced by real container log directory on container launch.
*/
public static final String LOG_DIR_EXPANSION_VAR = "<LOG_DIR>"; public static final String LOG_DIR_EXPANSION_VAR = "<LOG_DIR>";
public static final String STDERR = "stderr"; public static final String STDERR = "stderr";

View File

@ -54,7 +54,7 @@ public interface ApplicationMasterProtocol {
* {@link RegisterApplicationMasterRequest}.</p> * {@link RegisterApplicationMasterRequest}.</p>
* *
* <p>The <code>ResourceManager</code> responds with critical details such * <p>The <code>ResourceManager</code> responds with critical details such
* as minimum and maximum resource capabilities in the cluster as specified in * as maximum resource capabilities in the cluster as specified in
* {@link RegisterApplicationMasterResponse}.</p> * {@link RegisterApplicationMasterResponse}.</p>
* *
* @param request registration request * @param request registration request
@ -64,6 +64,8 @@ public interface ApplicationMasterProtocol {
* @see RegisterApplicationMasterRequest * @see RegisterApplicationMasterRequest
* @see RegisterApplicationMasterResponse * @see RegisterApplicationMasterResponse
*/ */
@Public
@Stable
public RegisterApplicationMasterResponse registerApplicationMaster( public RegisterApplicationMasterResponse registerApplicationMaster(
RegisterApplicationMasterRequest request) RegisterApplicationMasterRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -86,6 +88,8 @@ public RegisterApplicationMasterResponse registerApplicationMaster(
* @see FinishApplicationMasterRequest * @see FinishApplicationMasterRequest
* @see FinishApplicationMasterResponse * @see FinishApplicationMasterResponse
*/ */
@Public
@Stable
public FinishApplicationMasterResponse finishApplicationMaster( public FinishApplicationMasterResponse finishApplicationMaster(
FinishApplicationMasterRequest request) FinishApplicationMasterRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@ -122,6 +126,8 @@ public FinishApplicationMasterResponse finishApplicationMaster(
* @see AllocateRequest * @see AllocateRequest
* @see AllocateResponse * @see AllocateResponse
*/ */
@Public
@Stable
public AllocateResponse allocate(AllocateRequest request) public AllocateResponse allocate(AllocateRequest request)
throws YarnException, IOException; throws YarnException, IOException;
} }

View File

@ -17,9 +17,13 @@
*/ */
package org.apache.hadoop.yarn.api; package org.apache.hadoop.yarn.api;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.ipc.ProtocolInfo; import org.apache.hadoop.ipc.ProtocolInfo;
import org.apache.hadoop.yarn.proto.ApplicationMasterProtocol.ApplicationMasterProtocolService; import org.apache.hadoop.yarn.proto.ApplicationMasterProtocol.ApplicationMasterProtocolService;
@Private
@Unstable
@ProtocolInfo(protocolName = "org.apache.hadoop.yarn.api.ApplicationMasterProtocolPB", @ProtocolInfo(protocolName = "org.apache.hadoop.yarn.api.ApplicationMasterProtocolPB",
protocolVersion = 1) protocolVersion = 1)
public interface ApplicationMasterProtocolPB extends ApplicationMasterProtocolService.BlockingInterface { public interface ApplicationMasterProtocolPB extends ApplicationMasterProtocolService.BlockingInterface {

View File

@ -17,9 +17,13 @@
*/ */
package org.apache.hadoop.yarn.api; package org.apache.hadoop.yarn.api;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.ipc.ProtocolInfo; import org.apache.hadoop.ipc.ProtocolInfo;
import org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService; import org.apache.hadoop.yarn.proto.ContainerManagementProtocol.ContainerManagementProtocolService;
@Private
@Unstable
@ProtocolInfo( @ProtocolInfo(
protocolName = "org.apache.hadoop.yarn.api.ContainerManagementProtocolPB", protocolName = "org.apache.hadoop.yarn.api.ContainerManagementProtocolPB",
protocolVersion = 1) protocolVersion = 1)

View File

@ -20,6 +20,8 @@
import java.io.IOException; import java.io.IOException;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.tools.GetUserMappingsProtocol; import org.apache.hadoop.tools.GetUserMappingsProtocol;
import org.apache.hadoop.yarn.exceptions.YarnException; import org.apache.hadoop.yarn.exceptions.YarnException;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsRequest;
@ -35,26 +37,41 @@
import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsRequest;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsResponse;
@Public
@Stable
public interface ResourceManagerAdministrationProtocol extends GetUserMappingsProtocol { public interface ResourceManagerAdministrationProtocol extends GetUserMappingsProtocol {
@Public
@Stable
public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request) public RefreshQueuesResponse refreshQueues(RefreshQueuesRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@Public
@Stable
public RefreshNodesResponse refreshNodes(RefreshNodesRequest request) public RefreshNodesResponse refreshNodes(RefreshNodesRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@Public
@Stable
public RefreshSuperUserGroupsConfigurationResponse public RefreshSuperUserGroupsConfigurationResponse
refreshSuperUserGroupsConfiguration( refreshSuperUserGroupsConfiguration(
RefreshSuperUserGroupsConfigurationRequest request) RefreshSuperUserGroupsConfigurationRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@Public
@Stable
public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings( public RefreshUserToGroupsMappingsResponse refreshUserToGroupsMappings(
RefreshUserToGroupsMappingsRequest request) RefreshUserToGroupsMappingsRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@Public
@Stable
public RefreshAdminAclsResponse refreshAdminAcls( public RefreshAdminAclsResponse refreshAdminAcls(
RefreshAdminAclsRequest request) RefreshAdminAclsRequest request)
throws YarnException, IOException; throws YarnException, IOException;
@Public
@Stable
public RefreshServiceAclsResponse refreshServiceAcls( public RefreshServiceAclsResponse refreshServiceAcls(
RefreshServiceAclsRequest request) RefreshServiceAclsRequest request)
throws YarnException, IOException; throws YarnException, IOException;

View File

@ -17,9 +17,13 @@
*/ */
package org.apache.hadoop.yarn.api; package org.apache.hadoop.yarn.api;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.ipc.ProtocolInfo; import org.apache.hadoop.ipc.ProtocolInfo;
import org.apache.hadoop.yarn.proto.ResourceManagerAdministrationProtocol.ResourceManagerAdministrationProtocolService; import org.apache.hadoop.yarn.proto.ResourceManagerAdministrationProtocol.ResourceManagerAdministrationProtocolService;
@Private
@Unstable
@ProtocolInfo( @ProtocolInfo(
protocolName = "org.apache.hadoop.yarn.api.ResourceManagerAdministrationProtocolPB", protocolName = "org.apache.hadoop.yarn.api.ResourceManagerAdministrationProtocolPB",
protocolVersion = 1) protocolVersion = 1)

View File

@ -0,0 +1,21 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
@InterfaceAudience.Public
package org.apache.hadoop.yarn.api;
import org.apache.hadoop.classification.InterfaceAudience;

View File

@ -59,6 +59,8 @@
@Stable @Stable
public abstract class AllocateRequest { public abstract class AllocateRequest {
@Public
@Stable
public static AllocateRequest newInstance( public static AllocateRequest newInstance(
ApplicationAttemptId applicationAttemptId, int responseID, ApplicationAttemptId applicationAttemptId, int responseID,
float appProgress, List<ResourceRequest> resourceAsk, float appProgress, List<ResourceRequest> resourceAsk,

View File

@ -43,10 +43,10 @@
* <ul> * <ul>
* <li>Response ID to track duplicate responses.</li> * <li>Response ID to track duplicate responses.</li>
* <li> * <li>
* A reboot flag to let the <code>ApplicationMaster</code> know that its * An AMCommand sent by ResourceManager to let the <code>ApplicationMaster</code>
* horribly out of sync and needs to reboot.</li> * take some actions (resync, shutdown etc.).
* <li>A list of newly allocated {@link Container}.</li> * <li>A list of newly allocated {@link Container}.</li>
* <li>A list of completed {@link Container}.</li> * <li>A list of completed {@link Container}s' statuses.</li>
* <li> * <li>
* The available headroom for resources in the cluster for the * The available headroom for resources in the cluster for the
* application. * application.
@ -63,6 +63,8 @@
@Stable @Stable
public abstract class AllocateResponse { public abstract class AllocateResponse {
@Public
@Stable
public static AllocateResponse newInstance(int responseId, public static AllocateResponse newInstance(int responseId,
List<ContainerStatus> completedContainers, List<ContainerStatus> completedContainers,
List<Container> allocatedContainers, List<NodeReport> updatedNodes, List<Container> allocatedContainers, List<NodeReport> updatedNodes,
@ -124,8 +126,8 @@ public static AllocateResponse newInstance(int responseId,
* <code>ResourceManager</code>. * <code>ResourceManager</code>.
* @param containers list of <em>newly allocated</em> <code>Container</code> * @param containers list of <em>newly allocated</em> <code>Container</code>
*/ */
@Public @Private
@Stable @Unstable
public abstract void setAllocatedContainers(List<Container> containers); public abstract void setAllocatedContainers(List<Container> containers);
/** /**
@ -160,7 +162,7 @@ public static AllocateResponse newInstance(int responseId,
* @return The delta of updated nodes since the last response * @return The delta of updated nodes since the last response
*/ */
@Public @Public
@Unstable @Stable
public abstract List<NodeReport> getUpdatedNodes(); public abstract List<NodeReport> getUpdatedNodes();
@Private @Private
@ -180,16 +182,16 @@ public static AllocateResponse newInstance(int responseId,
public abstract void setNumClusterNodes(int numNodes); public abstract void setNumClusterNodes(int numNodes);
/** /**
* Get the description of containers owned by the AM, but requested back by * <p>Get the description of containers owned by the AM, but requested back by
* the cluster. Note that the RM may have an inconsistent view of the * the cluster. Note that the RM may have an inconsistent view of the
* resources owned by the AM. These messages are advisory, and the AM may * resources owned by the AM. These messages are advisory, and the AM may
* elect to ignore them. * elect to ignore them.<p>
* *
* The message is a snapshot of the resources the RM wants back from the AM. * <p>The message is a snapshot of the resources the RM wants back from the AM.
* While demand persists, the RM will repeat its request; applications should * While demand persists, the RM will repeat its request; applications should
* not interpret each message as a request for <emph>additional<emph> * not interpret each message as a request for <em>additional<em>
* resources on top of previous messages. Resources requested consistently * resources on top of previous messages. Resources requested consistently
* over some duration may be forcibly killed by the RM. * over some duration may be forcibly killed by the RM.<p>
* *
* @return A specification of the resources to reclaim from this AM. * @return A specification of the resources to reclaim from this AM.
*/ */
@ -201,23 +203,22 @@ public static AllocateResponse newInstance(int responseId,
@Unstable @Unstable
public abstract void setPreemptionMessage(PreemptionMessage request); public abstract void setPreemptionMessage(PreemptionMessage request);
@Public
@Stable
public abstract void setNMTokens(List<NMToken> nmTokens);
/** /**
* Get the list of NMTokens required for communicating with NM. New NMTokens * <p>Get the list of NMTokens required for communicating with NM. New NMTokens
* issued only if * issued only if<p>
* 1) AM is receiving first container on underlying NodeManager. * <p>1) AM is receiving first container on underlying NodeManager.<br>
* OR * OR<br>
* 2) NMToken master key rolled over in ResourceManager and AM is getting new * 2) NMToken master key rolled over in ResourceManager and AM is getting new
* container on the same underlying NodeManager. * container on the same underlying NodeManager.<p>
* AM will receive one NMToken per NM irrespective of the number of containers * <p>AM will receive one NMToken per NM irrespective of the number of containers
* issued on same NM. AM is expected to store these tokens until issued a * issued on same NM. AM is expected to store these tokens until issued a
* new token for the same NM. * new token for the same NM.<p>
*/ */
@Public @Public
@Stable @Stable
public abstract List<NMToken> getNMTokens(); public abstract List<NMToken> getNMTokens();
@Private
@Unstable
public abstract void setNMTokens(List<NMToken> nmTokens);
} }

View File

@ -18,8 +18,8 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Evolving; import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.records.Token; import org.apache.hadoop.yarn.api.records.Token;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -27,10 +27,12 @@
* The request issued by the client to the {@code ResourceManager} to cancel a * The request issued by the client to the {@code ResourceManager} to cancel a
* delegation token. * delegation token.
*/ */
@Public @Private
@Evolving @Unstable
public abstract class CancelDelegationTokenRequest { public abstract class CancelDelegationTokenRequest {
@Private
@Unstable
public static CancelDelegationTokenRequest newInstance(Token dToken) { public static CancelDelegationTokenRequest newInstance(Token dToken) {
CancelDelegationTokenRequest request = CancelDelegationTokenRequest request =
Records.newRecord(CancelDelegationTokenRequest.class); Records.newRecord(CancelDelegationTokenRequest.class);
@ -38,6 +40,15 @@ public static CancelDelegationTokenRequest newInstance(Token dToken) {
return request; return request;
} }
/**
* Get the delegation token requested to be cancelled.
* @return the delegation token requested to be cancelled.
*/
@Private
@Unstable
public abstract Token getDelegationToken(); public abstract Token getDelegationToken();
@Private
@Unstable
public abstract void setDelegationToken(Token dToken); public abstract void setDelegationToken(Token dToken);
} }

View File

@ -18,17 +18,19 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Evolving; import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
/** /**
* The response from the {@code ResourceManager} to a cancelDelegationToken * The response from the {@code ResourceManager} to a cancelDelegationToken
* request. * request.
*/ */
@Public @Private
@Evolving @Unstable
public abstract class CancelDelegationTokenResponse { public abstract class CancelDelegationTokenResponse {
@Private
@Unstable
public static CancelDelegationTokenResponse newInstance() { public static CancelDelegationTokenResponse newInstance() {
CancelDelegationTokenResponse response = CancelDelegationTokenResponse response =
Records.newRecord(CancelDelegationTokenResponse.class); Records.newRecord(CancelDelegationTokenResponse.class);

View File

@ -46,8 +46,12 @@
* *
* @see ApplicationMasterProtocol#finishApplicationMaster(FinishApplicationMasterRequest) * @see ApplicationMasterProtocol#finishApplicationMaster(FinishApplicationMasterRequest)
*/ */
@Public
@Stable
public abstract class FinishApplicationMasterRequest { public abstract class FinishApplicationMasterRequest {
@Public
@Stable
public static FinishApplicationMasterRequest newInstance( public static FinishApplicationMasterRequest newInstance(
ApplicationAttemptId appAttemptId, FinalApplicationStatus finalAppStatus, ApplicationAttemptId appAttemptId, FinalApplicationStatus finalAppStatus,
String diagnostics, String url) { String diagnostics, String url) {

View File

@ -18,8 +18,10 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ApplicationMasterProtocol; import org.apache.hadoop.yarn.api.ApplicationMasterProtocol;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -34,6 +36,8 @@
@Public @Public
@Stable @Stable
public abstract class FinishApplicationMasterResponse { public abstract class FinishApplicationMasterResponse {
@Private
@Unstable
public static FinishApplicationMasterResponse newInstance() { public static FinishApplicationMasterResponse newInstance() {
FinishApplicationMasterResponse response = FinishApplicationMasterResponse response =
Records.newRecord(FinishApplicationMasterResponse.class); Records.newRecord(FinishApplicationMasterResponse.class);

View File

@ -34,6 +34,8 @@
@Public @Public
@Stable @Stable
public abstract class GetAllApplicationsRequest { public abstract class GetAllApplicationsRequest {
@Public
@Stable
public static GetAllApplicationsRequest newInstance() { public static GetAllApplicationsRequest newInstance() {
GetAllApplicationsRequest request = GetAllApplicationsRequest request =
Records.newRecord(GetAllApplicationsRequest.class); Records.newRecord(GetAllApplicationsRequest.class);

View File

@ -42,7 +42,8 @@
@Public @Public
@Stable @Stable
public abstract class GetAllApplicationsResponse { public abstract class GetAllApplicationsResponse {
@Private
@Unstable
public static GetAllApplicationsResponse newInstance( public static GetAllApplicationsResponse newInstance(
List<ApplicationReport> applications) { List<ApplicationReport> applications) {
GetAllApplicationsResponse response = GetAllApplicationsResponse response =

View File

@ -39,6 +39,8 @@
@Stable @Stable
public abstract class GetApplicationReportRequest { public abstract class GetApplicationReportRequest {
@Public
@Stable
public static GetApplicationReportRequest newInstance( public static GetApplicationReportRequest newInstance(
ApplicationId applicationId) { ApplicationId applicationId) {
GetApplicationReportRequest request = GetApplicationReportRequest request =
@ -51,11 +53,15 @@ public static GetApplicationReportRequest newInstance(
* Get the <code>ApplicationId</code> of the application. * Get the <code>ApplicationId</code> of the application.
* @return <code>ApplicationId</code> of the application * @return <code>ApplicationId</code> of the application
*/ */
@Public
@Stable
public abstract ApplicationId getApplicationId(); public abstract ApplicationId getApplicationId();
/** /**
* Set the <code>ApplicationId</code> of the application * Set the <code>ApplicationId</code> of the application
* @param applicationId <code>ApplicationId</code> of the application * @param applicationId <code>ApplicationId</code> of the application
*/ */
@Public
@Stable
public abstract void setApplicationId(ApplicationId applicationId); public abstract void setApplicationId(ApplicationId applicationId);
} }

View File

@ -40,6 +40,8 @@
@Stable @Stable
public abstract class GetApplicationReportResponse { public abstract class GetApplicationReportResponse {
@Private
@Unstable
public static GetApplicationReportResponse newInstance( public static GetApplicationReportResponse newInstance(
ApplicationReport ApplicationReport) { ApplicationReport ApplicationReport) {
GetApplicationReportResponse response = GetApplicationReportResponse response =

View File

@ -34,6 +34,8 @@
@Public @Public
@Stable @Stable
public abstract class GetClusterMetricsRequest { public abstract class GetClusterMetricsRequest {
@Public
@Stable
public static GetClusterMetricsRequest newInstance() { public static GetClusterMetricsRequest newInstance() {
GetClusterMetricsRequest request = GetClusterMetricsRequest request =
Records.newRecord(GetClusterMetricsRequest.class); Records.newRecord(GetClusterMetricsRequest.class);

View File

@ -37,6 +37,8 @@
@Stable @Stable
public abstract class GetClusterMetricsResponse { public abstract class GetClusterMetricsResponse {
@Private
@Unstable
public static GetClusterMetricsResponse public static GetClusterMetricsResponse
newInstance(YarnClusterMetrics metrics) { newInstance(YarnClusterMetrics metrics) {
GetClusterMetricsResponse response = GetClusterMetricsResponse response =

View File

@ -34,6 +34,8 @@
@Public @Public
@Stable @Stable
public abstract class GetClusterNodesRequest { public abstract class GetClusterNodesRequest {
@Public
@Stable
public static GetClusterNodesRequest newInstance() { public static GetClusterNodesRequest newInstance() {
GetClusterNodesRequest request = GetClusterNodesRequest request =
Records.newRecord(GetClusterNodesRequest.class); Records.newRecord(GetClusterNodesRequest.class);

View File

@ -43,6 +43,8 @@
@Stable @Stable
public abstract class GetClusterNodesResponse { public abstract class GetClusterNodesResponse {
@Private
@Unstable
public static GetClusterNodesResponse public static GetClusterNodesResponse
newInstance(List<NodeReport> nodeReports) { newInstance(List<NodeReport> nodeReports) {
GetClusterNodesResponse response = GetClusterNodesResponse response =

View File

@ -35,6 +35,8 @@
@Stable @Stable
public abstract class GetContainerStatusRequest { public abstract class GetContainerStatusRequest {
@Public
@Stable
public static GetContainerStatusRequest newInstance(ContainerId containerId) { public static GetContainerStatusRequest newInstance(ContainerId containerId) {
GetContainerStatusRequest request = GetContainerStatusRequest request =
Records.newRecord(GetContainerStatusRequest.class); Records.newRecord(GetContainerStatusRequest.class);

View File

@ -37,6 +37,8 @@
@Stable @Stable
public abstract class GetContainerStatusResponse { public abstract class GetContainerStatusResponse {
@Private
@Unstable
public static GetContainerStatusResponse newInstance( public static GetContainerStatusResponse newInstance(
ContainerStatus containerStatus) { ContainerStatus containerStatus) {
GetContainerStatusResponse response = GetContainerStatusResponse response =

View File

@ -19,7 +19,7 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Evolving; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
/** /**
@ -28,9 +28,11 @@
* for more information. * for more information.
*/ */
@Public @Public
@Evolving @Stable
public abstract class GetDelegationTokenRequest { public abstract class GetDelegationTokenRequest {
@Public
@Stable
public GetDelegationTokenRequest newInstance(String renewer) { public GetDelegationTokenRequest newInstance(String renewer) {
GetDelegationTokenRequest request = GetDelegationTokenRequest request =
Records.newRecord(GetDelegationTokenRequest.class); Records.newRecord(GetDelegationTokenRequest.class);
@ -38,6 +40,11 @@ public GetDelegationTokenRequest newInstance(String renewer) {
return request; return request;
} }
@Public
@Stable
public abstract String getRenewer(); public abstract String getRenewer();
@Public
@Stable
public abstract void setRenewer(String renewer); public abstract void setRenewer(String renewer);
} }

View File

@ -18,8 +18,10 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Evolving; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier; import org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
import org.apache.hadoop.yarn.api.records.Token; import org.apache.hadoop.yarn.api.records.Token;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -32,9 +34,11 @@
* *
*/ */
@Public @Public
@Evolving @Stable
public abstract class GetDelegationTokenResponse { public abstract class GetDelegationTokenResponse {
@Private
@Unstable
public static GetDelegationTokenResponse newInstance(Token rmDTToken) { public static GetDelegationTokenResponse newInstance(Token rmDTToken) {
GetDelegationTokenResponse response = GetDelegationTokenResponse response =
Records.newRecord(GetDelegationTokenResponse.class); Records.newRecord(GetDelegationTokenResponse.class);
@ -47,6 +51,11 @@ public static GetDelegationTokenResponse newInstance(Token rmDTToken) {
* {@link AbstractDelegationTokenIdentifier}. * {@link AbstractDelegationTokenIdentifier}.
* *
*/ */
@Public
@Stable
public abstract Token getRMDelegationToken(); public abstract Token getRMDelegationToken();
@Private
@Unstable
public abstract void setRMDelegationToken(Token rmDTToken); public abstract void setRMDelegationToken(Token rmDTToken);
} }

View File

@ -35,6 +35,8 @@
@Public @Public
@Stable @Stable
public abstract class GetNewApplicationRequest { public abstract class GetNewApplicationRequest {
@Public
@Stable
public static GetNewApplicationRequest newInstance() { public static GetNewApplicationRequest newInstance() {
GetNewApplicationRequest request = GetNewApplicationRequest request =
Records.newRecord(GetNewApplicationRequest.class); Records.newRecord(GetNewApplicationRequest.class);

View File

@ -37,6 +37,8 @@
@Stable @Stable
public abstract class GetNewApplicationResponse { public abstract class GetNewApplicationResponse {
@Private
@Unstable
public static GetNewApplicationResponse newInstance( public static GetNewApplicationResponse newInstance(
ApplicationId applicationId, Resource minCapability, ApplicationId applicationId, Resource minCapability,
Resource maxCapability) { Resource maxCapability) {

View File

@ -33,6 +33,8 @@
@Stable @Stable
public abstract class GetQueueInfoRequest { public abstract class GetQueueInfoRequest {
@Public
@Stable
public static GetQueueInfoRequest public static GetQueueInfoRequest
newInstance(String queueName, boolean includeApplications, newInstance(String queueName, boolean includeApplications,
boolean includeChildQueues, boolean recursive) { boolean includeChildQueues, boolean recursive) {
@ -48,12 +50,16 @@ public abstract class GetQueueInfoRequest {
* Get the <em>queue name</em> for which to get queue information. * Get the <em>queue name</em> for which to get queue information.
* @return <em>queue name</em> for which to get queue information * @return <em>queue name</em> for which to get queue information
*/ */
@Public
@Stable
public abstract String getQueueName(); public abstract String getQueueName();
/** /**
* Set the <em>queue name</em> for which to get queue information * Set the <em>queue name</em> for which to get queue information
* @param queueName <em>queue name</em> for which to get queue information * @param queueName <em>queue name</em> for which to get queue information
*/ */
@Public
@Stable
public abstract void setQueueName(String queueName); public abstract void setQueueName(String queueName);
/** /**
@ -61,6 +67,8 @@ public abstract class GetQueueInfoRequest {
* @return <code>true</code> if applications' information is to be included, * @return <code>true</code> if applications' information is to be included,
* else <code>false</code> * else <code>false</code>
*/ */
@Public
@Stable
public abstract boolean getIncludeApplications(); public abstract boolean getIncludeApplications();
/** /**
@ -68,6 +76,8 @@ public abstract class GetQueueInfoRequest {
* @param includeApplications fetch information about <em>active * @param includeApplications fetch information about <em>active
* applications</em>? * applications</em>?
*/ */
@Public
@Stable
public abstract void setIncludeApplications(boolean includeApplications); public abstract void setIncludeApplications(boolean includeApplications);
/** /**
@ -75,12 +85,16 @@ public abstract class GetQueueInfoRequest {
* @return <code>true</code> if information about child queues is required, * @return <code>true</code> if information about child queues is required,
* else <code>false</code> * else <code>false</code>
*/ */
@Public
@Stable
public abstract boolean getIncludeChildQueues(); public abstract boolean getIncludeChildQueues();
/** /**
* Should we fetch information about <em>child queues</em>? * Should we fetch information about <em>child queues</em>?
* @param includeChildQueues fetch information about <em>child queues</em>? * @param includeChildQueues fetch information about <em>child queues</em>?
*/ */
@Public
@Stable
public abstract void setIncludeChildQueues(boolean includeChildQueues); public abstract void setIncludeChildQueues(boolean includeChildQueues);
/** /**
@ -88,6 +102,8 @@ public abstract class GetQueueInfoRequest {
* @return <code>true</code> if information about entire hierarchy is * @return <code>true</code> if information about entire hierarchy is
* required, <code>false</code> otherwise * required, <code>false</code> otherwise
*/ */
@Public
@Stable
public abstract boolean getRecursive(); public abstract boolean getRecursive();
/** /**
@ -95,6 +111,8 @@ public abstract class GetQueueInfoRequest {
* @param recursive fetch information on the entire <em>child queue * @param recursive fetch information on the entire <em>child queue
* hierarchy</em>? * hierarchy</em>?
*/ */
@Public
@Stable
public abstract void setRecursive(boolean recursive); public abstract void setRecursive(boolean recursive);
} }

View File

@ -41,6 +41,8 @@
@Stable @Stable
public abstract class GetQueueInfoResponse { public abstract class GetQueueInfoResponse {
@Private
@Unstable
public static GetQueueInfoResponse newInstance(QueueInfo queueInfo) { public static GetQueueInfoResponse newInstance(QueueInfo queueInfo) {
GetQueueInfoResponse response = Records.newRecord(GetQueueInfoResponse.class); GetQueueInfoResponse response = Records.newRecord(GetQueueInfoResponse.class);
response.setQueueInfo(queueInfo); response.setQueueInfo(queueInfo);
@ -51,6 +53,8 @@ public static GetQueueInfoResponse newInstance(QueueInfo queueInfo) {
* Get the <code>QueueInfo</code> for the specified queue. * Get the <code>QueueInfo</code> for the specified queue.
* @return <code>QueueInfo</code> for the specified queue * @return <code>QueueInfo</code> for the specified queue
*/ */
@Public
@Stable
public abstract QueueInfo getQueueInfo(); public abstract QueueInfo getQueueInfo();
@Private @Private

View File

@ -34,6 +34,8 @@
@Public @Public
@Stable @Stable
public abstract class GetQueueUserAclsInfoRequest { public abstract class GetQueueUserAclsInfoRequest {
@Public
@Stable
public static GetQueueUserAclsInfoRequest newInstance() { public static GetQueueUserAclsInfoRequest newInstance() {
GetQueueUserAclsInfoRequest request = GetQueueUserAclsInfoRequest request =
Records.newRecord(GetQueueUserAclsInfoRequest.class); Records.newRecord(GetQueueUserAclsInfoRequest.class);

View File

@ -44,6 +44,8 @@
@Stable @Stable
public abstract class GetQueueUserAclsInfoResponse { public abstract class GetQueueUserAclsInfoResponse {
@Private
@Unstable
public static GetQueueUserAclsInfoResponse newInstance( public static GetQueueUserAclsInfoResponse newInstance(
List<QueueUserACLInfo> queueUserAclsList) { List<QueueUserACLInfo> queueUserAclsList) {
GetQueueUserAclsInfoResponse response = GetQueueUserAclsInfoResponse response =

View File

@ -18,10 +18,8 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ApplicationClientProtocol; import org.apache.hadoop.yarn.api.ApplicationClientProtocol;
import org.apache.hadoop.yarn.api.records.ApplicationId; import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -39,6 +37,8 @@
@Stable @Stable
public abstract class KillApplicationRequest { public abstract class KillApplicationRequest {
@Public
@Stable
public static KillApplicationRequest newInstance(ApplicationId applicationId) { public static KillApplicationRequest newInstance(ApplicationId applicationId) {
KillApplicationRequest request = KillApplicationRequest request =
Records.newRecord(KillApplicationRequest.class); Records.newRecord(KillApplicationRequest.class);
@ -54,7 +54,7 @@ public static KillApplicationRequest newInstance(ApplicationId applicationId) {
@Stable @Stable
public abstract ApplicationId getApplicationId(); public abstract ApplicationId getApplicationId();
@Private @Public
@Unstable @Stable
public abstract void setApplicationId(ApplicationId applicationId); public abstract void setApplicationId(ApplicationId applicationId);
} }

View File

@ -18,8 +18,10 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ApplicationClientProtocol; import org.apache.hadoop.yarn.api.ApplicationClientProtocol;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -34,6 +36,8 @@
@Public @Public
@Stable @Stable
public abstract class KillApplicationResponse { public abstract class KillApplicationResponse {
@Private
@Unstable
public static KillApplicationResponse newInstance() { public static KillApplicationResponse newInstance() {
KillApplicationResponse response = KillApplicationResponse response =
Records.newRecord(KillApplicationResponse.class); Records.newRecord(KillApplicationResponse.class);

View File

@ -18,9 +18,15 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshAdminAclsRequest { public abstract class RefreshAdminAclsRequest {
@Public
@Stable
public static RefreshAdminAclsRequest newInstance() { public static RefreshAdminAclsRequest newInstance() {
RefreshAdminAclsRequest request = RefreshAdminAclsRequest request =
Records.newRecord(RefreshAdminAclsRequest.class); Records.newRecord(RefreshAdminAclsRequest.class);

View File

@ -18,9 +18,17 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshAdminAclsResponse { public abstract class RefreshAdminAclsResponse {
@Private
@Unstable
public static RefreshAdminAclsResponse newInstance() { public static RefreshAdminAclsResponse newInstance() {
RefreshAdminAclsResponse response = RefreshAdminAclsResponse response =
Records.newRecord(RefreshAdminAclsResponse.class); Records.newRecord(RefreshAdminAclsResponse.class);

View File

@ -18,9 +18,15 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshNodesRequest { public abstract class RefreshNodesRequest {
@Public
@Stable
public static RefreshNodesRequest newInstance() { public static RefreshNodesRequest newInstance() {
RefreshNodesRequest request = Records.newRecord(RefreshNodesRequest.class); RefreshNodesRequest request = Records.newRecord(RefreshNodesRequest.class);
return request; return request;

View File

@ -18,9 +18,17 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshNodesResponse { public abstract class RefreshNodesResponse {
@Private
@Unstable
public static RefreshNodesResponse newInstance() { public static RefreshNodesResponse newInstance() {
RefreshNodesResponse response = RefreshNodesResponse response =
Records.newRecord(RefreshNodesResponse.class); Records.newRecord(RefreshNodesResponse.class);

View File

@ -18,9 +18,15 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshQueuesRequest { public abstract class RefreshQueuesRequest {
@Public
@Stable
public static RefreshQueuesRequest newInstance() { public static RefreshQueuesRequest newInstance() {
RefreshQueuesRequest request = RefreshQueuesRequest request =
Records.newRecord(RefreshQueuesRequest.class); Records.newRecord(RefreshQueuesRequest.class);

View File

@ -18,9 +18,17 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshQueuesResponse { public abstract class RefreshQueuesResponse {
@Private
@Unstable
public static RefreshQueuesResponse newInstance() { public static RefreshQueuesResponse newInstance() {
RefreshQueuesResponse response = RefreshQueuesResponse response =
Records.newRecord(RefreshQueuesResponse.class); Records.newRecord(RefreshQueuesResponse.class);

View File

@ -18,9 +18,15 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshServiceAclsRequest { public abstract class RefreshServiceAclsRequest {
@Public
@Stable
public static RefreshServiceAclsRequest newInstance() { public static RefreshServiceAclsRequest newInstance() {
RefreshServiceAclsRequest request = RefreshServiceAclsRequest request =
Records.newRecord(RefreshServiceAclsRequest.class); Records.newRecord(RefreshServiceAclsRequest.class);

View File

@ -18,9 +18,17 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshServiceAclsResponse { public abstract class RefreshServiceAclsResponse {
@Private
@Unstable
public static RefreshServiceAclsResponse newInstance() { public static RefreshServiceAclsResponse newInstance() {
RefreshServiceAclsResponse response = RefreshServiceAclsResponse response =
Records.newRecord(RefreshServiceAclsResponse.class); Records.newRecord(RefreshServiceAclsResponse.class);

View File

@ -18,9 +18,15 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshSuperUserGroupsConfigurationRequest { public abstract class RefreshSuperUserGroupsConfigurationRequest {
@Public
@Stable
public static RefreshSuperUserGroupsConfigurationRequest newInstance() { public static RefreshSuperUserGroupsConfigurationRequest newInstance() {
RefreshSuperUserGroupsConfigurationRequest request = RefreshSuperUserGroupsConfigurationRequest request =
Records.newRecord(RefreshSuperUserGroupsConfigurationRequest.class); Records.newRecord(RefreshSuperUserGroupsConfigurationRequest.class);

View File

@ -18,9 +18,17 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshSuperUserGroupsConfigurationResponse { public abstract class RefreshSuperUserGroupsConfigurationResponse {
@Private
@Unstable
public static RefreshSuperUserGroupsConfigurationResponse newInstance() { public static RefreshSuperUserGroupsConfigurationResponse newInstance() {
RefreshSuperUserGroupsConfigurationResponse response = RefreshSuperUserGroupsConfigurationResponse response =
Records.newRecord(RefreshSuperUserGroupsConfigurationResponse.class); Records.newRecord(RefreshSuperUserGroupsConfigurationResponse.class);

View File

@ -18,9 +18,15 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshUserToGroupsMappingsRequest { public abstract class RefreshUserToGroupsMappingsRequest {
@Public
@Stable
public static RefreshUserToGroupsMappingsRequest newInstance() { public static RefreshUserToGroupsMappingsRequest newInstance() {
RefreshUserToGroupsMappingsRequest request = RefreshUserToGroupsMappingsRequest request =
Records.newRecord(RefreshUserToGroupsMappingsRequest.class); Records.newRecord(RefreshUserToGroupsMappingsRequest.class);

View File

@ -18,9 +18,17 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@Public
@Stable
public abstract class RefreshUserToGroupsMappingsResponse { public abstract class RefreshUserToGroupsMappingsResponse {
@Private
@Unstable
public static RefreshUserToGroupsMappingsResponse newInstance() { public static RefreshUserToGroupsMappingsResponse newInstance() {
RefreshUserToGroupsMappingsResponse response = RefreshUserToGroupsMappingsResponse response =
Records.newRecord(RefreshUserToGroupsMappingsResponse.class); Records.newRecord(RefreshUserToGroupsMappingsResponse.class);

View File

@ -18,10 +18,8 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ApplicationMasterProtocol; import org.apache.hadoop.yarn.api.ApplicationMasterProtocol;
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId; import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -48,6 +46,17 @@
@Stable @Stable
public abstract class RegisterApplicationMasterRequest { public abstract class RegisterApplicationMasterRequest {
/**
* Create a new instance of <code>RegisterApplicationMasterRequest</code>.
* If <em>port, trackingUrl</em> is not used, use the following default value:
* <ul>
* <li>port: -1</li>
* <li>trackingUrl: null</li>
* </ul>
* @return the new instance of <code>RegisterApplicationMasterRequest</code>
*/
@Public
@Stable
public static RegisterApplicationMasterRequest newInstance( public static RegisterApplicationMasterRequest newInstance(
ApplicationAttemptId applicationAttemptId, String host, int port, ApplicationAttemptId applicationAttemptId, String host, int port,
String trackingUrl) { String trackingUrl) {
@ -95,8 +104,8 @@ public static RegisterApplicationMasterRequest newInstance(
* @param host <em>host</em> on which the <code>ApplicationMaster</code> * @param host <em>host</em> on which the <code>ApplicationMaster</code>
* is running * is running
*/ */
@Private @Public
@Unstable @Stable
public abstract void setHost(String host); public abstract void setHost(String host);
/** /**

View File

@ -46,7 +46,8 @@
@Public @Public
@Stable @Stable
public abstract class RegisterApplicationMasterResponse { public abstract class RegisterApplicationMasterResponse {
@Private
@Unstable
public static RegisterApplicationMasterResponse newInstance( public static RegisterApplicationMasterResponse newInstance(
Resource minCapability, Resource maxCapability, Resource minCapability, Resource maxCapability,
Map<ApplicationAccessType, String> acls) { Map<ApplicationAccessType, String> acls) {
@ -86,17 +87,20 @@ public static RegisterApplicationMasterResponse newInstance(
@Unstable @Unstable
public abstract void setApplicationACLs(Map<ApplicationAccessType, String> acls); public abstract void setApplicationACLs(Map<ApplicationAccessType, String> acls);
/**
* <p>Get ClientToAMToken master key.</p>
* <p>The ClientToAMToken master key is sent to <code>ApplicationMaster</code>
* by <code>ResourceManager</code> via {@link RegisterApplicationMasterResponse}
* , used to verify corresponding ClientToAMToken.</p>
*/
@Public
@Stable
public abstract ByteBuffer getClientToAMTokenMasterKey();
/** /**
* Set ClientToAMToken master key. * Set ClientToAMToken master key.
*/ */
@Public @Public
@Stable @Stable
public abstract void setClientToAMTokenMasterKey(ByteBuffer key); public abstract void setClientToAMTokenMasterKey(ByteBuffer key);
/**
* Get ClientToAMToken master key.
*/
@Public
@Stable
public abstract ByteBuffer getClientToAMTokenMasterKey();
} }

View File

@ -18,8 +18,8 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Evolving; import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.records.Token; import org.apache.hadoop.yarn.api.records.Token;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -27,10 +27,11 @@
* The request issued by the client to renew a delegation token from * The request issued by the client to renew a delegation token from
* the {@code ResourceManager}. * the {@code ResourceManager}.
*/ */
@Public @Private
@Evolving @Unstable
public abstract class RenewDelegationTokenRequest { public abstract class RenewDelegationTokenRequest {
@Private
@Unstable
public static RenewDelegationTokenRequest newInstance(Token dToken) { public static RenewDelegationTokenRequest newInstance(Token dToken) {
RenewDelegationTokenRequest request = RenewDelegationTokenRequest request =
Records.newRecord(RenewDelegationTokenRequest.class); Records.newRecord(RenewDelegationTokenRequest.class);
@ -38,7 +39,15 @@ public static RenewDelegationTokenRequest newInstance(Token dToken) {
return request; return request;
} }
/**
* Get the delegation token requested to be renewed by the client.
* @return the delegation token requested to be renewed by the client.
*/
@Private
@Unstable
public abstract Token getDelegationToken(); public abstract Token getDelegationToken();
@Private
@Unstable
public abstract void setDelegationToken(Token dToken); public abstract void setDelegationToken(Token dToken);
} }

View File

@ -18,17 +18,19 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Evolving; import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
/** /**
* The response to a renewDelegationToken call to the {@code ResourceManager}. * The response to a renewDelegationToken call to the {@code ResourceManager}.
*/ */
@Public @Private
@Evolving @Unstable
public abstract class RenewDelegationTokenResponse { public abstract class RenewDelegationTokenResponse {
@Private
@Unstable
public static RenewDelegationTokenResponse newInstance(long expTime) { public static RenewDelegationTokenResponse newInstance(long expTime) {
RenewDelegationTokenResponse response = RenewDelegationTokenResponse response =
Records.newRecord(RenewDelegationTokenResponse.class); Records.newRecord(RenewDelegationTokenResponse.class);
@ -36,7 +38,11 @@ public static RenewDelegationTokenResponse newInstance(long expTime) {
return response; return response;
} }
@Private
@Unstable
public abstract long getNextExpirationTime(); public abstract long getNextExpirationTime();
@Private
@Unstable
public abstract void setNextExpirationTime(long expTime); public abstract void setNextExpirationTime(long expTime);
} }

View File

@ -22,6 +22,7 @@
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.yarn.api.ContainerManagementProtocol; import org.apache.hadoop.yarn.api.ContainerManagementProtocol;
import org.apache.hadoop.yarn.api.records.ContainerLaunchContext; import org.apache.hadoop.yarn.api.records.ContainerLaunchContext;
import org.apache.hadoop.yarn.api.records.NMToken;
import org.apache.hadoop.yarn.api.records.Token; import org.apache.hadoop.yarn.api.records.Token;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -40,7 +41,8 @@
@Public @Public
@Stable @Stable
public abstract class StartContainerRequest { public abstract class StartContainerRequest {
@Public
@Stable
public static StartContainerRequest newInstance( public static StartContainerRequest newInstance(
ContainerLaunchContext context, Token container) { ContainerLaunchContext context, Token container) {
StartContainerRequest request = StartContainerRequest request =
@ -71,6 +73,16 @@ public static StartContainerRequest newInstance(
@Stable @Stable
public abstract void setContainerLaunchContext(ContainerLaunchContext context); public abstract void setContainerLaunchContext(ContainerLaunchContext context);
/**
* <p>Get the container token to be used for authorization during starting
* container.</p>
* <p>Note: {@link NMToken} will be used for authenticating communication with </code>
* NodeManager</code>.</p>
* @return the container token to be used for authorization during starting
* container.
* @see NMToken
* @see ContainerManagementProtocol#startContainer(StartContainerRequest)
*/
@Public @Public
@Stable @Stable
public abstract Token getContainerToken(); public abstract Token getContainerToken();

View File

@ -21,8 +21,10 @@
import java.nio.ByteBuffer; import java.nio.ByteBuffer;
import java.util.Map; import java.util.Map;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ContainerManagementProtocol; import org.apache.hadoop.yarn.api.ContainerManagementProtocol;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -37,6 +39,8 @@
@Stable @Stable
public abstract class StartContainerResponse { public abstract class StartContainerResponse {
@Private
@Unstable
public static StartContainerResponse newInstance( public static StartContainerResponse newInstance(
Map<String, ByteBuffer> serviceResponses) { Map<String, ByteBuffer> serviceResponses) {
StartContainerResponse response = StartContainerResponse response =
@ -52,6 +56,8 @@ public static StartContainerResponse newInstance(
* and their corresponding opaque blob <code>ByteBuffer</code>s</p> * and their corresponding opaque blob <code>ByteBuffer</code>s</p>
* @return a Map between the auxiliary service names and their outputs * @return a Map between the auxiliary service names and their outputs
*/ */
@Public
@Stable
public abstract Map<String, ByteBuffer> getAllServiceResponse(); public abstract Map<String, ByteBuffer> getAllServiceResponse();
/** /**
@ -61,5 +67,7 @@ public static StartContainerResponse newInstance(
* @param serviceResponses A map from auxiliary service names to the opaque * @param serviceResponses A map from auxiliary service names to the opaque
* blob <code>ByteBuffer</code>s for that auxiliary service * blob <code>ByteBuffer</code>s for that auxiliary service
*/ */
@Private
@Unstable
public abstract void setAllServiceResponse(Map<String, ByteBuffer> serviceResponses); public abstract void setAllServiceResponse(Map<String, ByteBuffer> serviceResponses);
} }

View File

@ -34,6 +34,8 @@
@Stable @Stable
public abstract class StopContainerRequest { public abstract class StopContainerRequest {
@Public
@Stable
public static StopContainerRequest newInstance(ContainerId containerId) { public static StopContainerRequest newInstance(ContainerId containerId) {
StopContainerRequest request = StopContainerRequest request =
Records.newRecord(StopContainerRequest.class); Records.newRecord(StopContainerRequest.class);

View File

@ -18,8 +18,10 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ContainerManagementProtocol; import org.apache.hadoop.yarn.api.ContainerManagementProtocol;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -35,6 +37,8 @@
@Public @Public
@Stable @Stable
public abstract class StopContainerResponse { public abstract class StopContainerResponse {
@Private
@Unstable
public static StopContainerResponse newInstance() { public static StopContainerResponse newInstance() {
StopContainerResponse response = StopContainerResponse response =
Records.newRecord(StopContainerResponse.class); Records.newRecord(StopContainerResponse.class);

View File

@ -42,6 +42,8 @@
@Stable @Stable
public abstract class SubmitApplicationRequest { public abstract class SubmitApplicationRequest {
@Public
@Stable
public static SubmitApplicationRequest newInstance( public static SubmitApplicationRequest newInstance(
ApplicationSubmissionContext context) { ApplicationSubmissionContext context) {
SubmitApplicationRequest request = SubmitApplicationRequest request =

View File

@ -18,8 +18,10 @@
package org.apache.hadoop.yarn.api.protocolrecords; package org.apache.hadoop.yarn.api.protocolrecords;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceAudience.Public; import org.apache.hadoop.classification.InterfaceAudience.Public;
import org.apache.hadoop.classification.InterfaceStability.Stable; import org.apache.hadoop.classification.InterfaceStability.Stable;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.ApplicationClientProtocol; import org.apache.hadoop.yarn.api.ApplicationClientProtocol;
import org.apache.hadoop.yarn.util.Records; import org.apache.hadoop.yarn.util.Records;
@ -34,6 +36,8 @@
@Public @Public
@Stable @Stable
public abstract class SubmitApplicationResponse { public abstract class SubmitApplicationResponse {
@Private
@Unstable
public static SubmitApplicationResponse newInstance() { public static SubmitApplicationResponse newInstance() {
SubmitApplicationResponse response = SubmitApplicationResponse response =
Records.newRecord(SubmitApplicationResponse.class); Records.newRecord(SubmitApplicationResponse.class);

View File

@ -23,24 +23,26 @@
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest; import org.apache.hadoop.yarn.api.protocolrecords.AllocateRequest;
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId; import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
import org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest;
import org.apache.hadoop.yarn.api.records.ContainerId; import org.apache.hadoop.yarn.api.records.ContainerId;
import org.apache.hadoop.yarn.api.records.ResourceBlacklistRequest;
import org.apache.hadoop.yarn.api.records.ResourceRequest; import org.apache.hadoop.yarn.api.records.ResourceRequest;
import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationAttemptIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationAttemptIdPBImpl;
import org.apache.hadoop.yarn.api.records.impl.pb.ResourceBlacklistRequestPBImpl;
import org.apache.hadoop.yarn.api.records.impl.pb.ContainerIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ContainerIdPBImpl;
import org.apache.hadoop.yarn.api.records.impl.pb.ResourceBlacklistRequestPBImpl;
import org.apache.hadoop.yarn.api.records.impl.pb.ResourceRequestPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ResourceRequestPBImpl;
import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAttemptIdProto; import org.apache.hadoop.yarn.proto.YarnProtos.ApplicationAttemptIdProto;
import org.apache.hadoop.yarn.proto.YarnProtos.ResourceBlacklistRequestProto;
import org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto; import org.apache.hadoop.yarn.proto.YarnProtos.ContainerIdProto;
import org.apache.hadoop.yarn.proto.YarnProtos.ResourceBlacklistRequestProto;
import org.apache.hadoop.yarn.proto.YarnProtos.ResourceRequestProto; import org.apache.hadoop.yarn.proto.YarnProtos.ResourceRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateRequestProtoOrBuilder;
@Private
@Unstable
public class AllocateRequestPBImpl extends AllocateRequest { public class AllocateRequestPBImpl extends AllocateRequest {
AllocateRequestProto proto = AllocateRequestProto.getDefaultInstance(); AllocateRequestProto proto = AllocateRequestProto.getDefaultInstance();
AllocateRequestProto.Builder builder = null; AllocateRequestProto.Builder builder = null;

View File

@ -23,6 +23,8 @@
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse; import org.apache.hadoop.yarn.api.protocolrecords.AllocateResponse;
import org.apache.hadoop.yarn.api.records.AMCommand; import org.apache.hadoop.yarn.api.records.AMCommand;
import org.apache.hadoop.yarn.api.records.Container; import org.apache.hadoop.yarn.api.records.Container;
@ -44,10 +46,11 @@
import org.apache.hadoop.yarn.proto.YarnProtos.ResourceProto; import org.apache.hadoop.yarn.proto.YarnProtos.ResourceProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.AllocateResponseProtoOrBuilder;
import org.apache.hadoop.yarn.util.ProtoUtils;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.NMTokenProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.NMTokenProto;
import org.apache.hadoop.yarn.util.ProtoUtils;
@Private
@Unstable
public class AllocateResponsePBImpl extends AllocateResponse { public class AllocateResponsePBImpl extends AllocateResponse {
AllocateResponseProto proto = AllocateResponseProto.getDefaultInstance(); AllocateResponseProto proto = AllocateResponseProto.getDefaultInstance();
AllocateResponseProto.Builder builder = null; AllocateResponseProto.Builder builder = null;

View File

@ -17,6 +17,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto; import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProto;
import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProtoOrBuilder; import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenRequestProtoOrBuilder;
import org.apache.hadoop.security.proto.SecurityProtos.TokenProto; import org.apache.hadoop.security.proto.SecurityProtos.TokenProto;
@ -24,6 +26,8 @@
import org.apache.hadoop.yarn.api.records.Token; import org.apache.hadoop.yarn.api.records.Token;
import org.apache.hadoop.yarn.api.records.impl.pb.TokenPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.TokenPBImpl;
@Private
@Unstable
public class CancelDelegationTokenRequestPBImpl extends public class CancelDelegationTokenRequestPBImpl extends
CancelDelegationTokenRequest { CancelDelegationTokenRequest {

View File

@ -17,9 +17,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto; import org.apache.hadoop.security.proto.SecurityProtos.CancelDelegationTokenResponseProto;
import org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse; import org.apache.hadoop.yarn.api.protocolrecords.CancelDelegationTokenResponse;
@Private
@Unstable
public class CancelDelegationTokenResponsePBImpl extends CancelDelegationTokenResponse { public class CancelDelegationTokenResponsePBImpl extends CancelDelegationTokenResponse {
CancelDelegationTokenResponseProto proto = CancelDelegationTokenResponseProto CancelDelegationTokenResponseProto proto = CancelDelegationTokenResponseProto

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest; import org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterRequest;
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId; import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
import org.apache.hadoop.yarn.api.records.FinalApplicationStatus; import org.apache.hadoop.yarn.api.records.FinalApplicationStatus;
@ -29,7 +31,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterRequestProtoOrBuilder;
import org.apache.hadoop.yarn.util.ProtoUtils; import org.apache.hadoop.yarn.util.ProtoUtils;
@Private
@Unstable
public class FinishApplicationMasterRequestPBImpl extends FinishApplicationMasterRequest { public class FinishApplicationMasterRequestPBImpl extends FinishApplicationMasterRequest {
FinishApplicationMasterRequestProto proto = FinishApplicationMasterRequestProto.getDefaultInstance(); FinishApplicationMasterRequestProto proto = FinishApplicationMasterRequestProto.getDefaultInstance();
FinishApplicationMasterRequestProto.Builder builder = null; FinishApplicationMasterRequestProto.Builder builder = null;

View File

@ -19,11 +19,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse; import org.apache.hadoop.yarn.api.protocolrecords.FinishApplicationMasterResponse;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.FinishApplicationMasterResponseProto;
@Private
@Unstable
public class FinishApplicationMasterResponsePBImpl extends FinishApplicationMasterResponse { public class FinishApplicationMasterResponsePBImpl extends FinishApplicationMasterResponse {
FinishApplicationMasterResponseProto proto = FinishApplicationMasterResponseProto.getDefaultInstance(); FinishApplicationMasterResponseProto proto = FinishApplicationMasterResponseProto.getDefaultInstance();
FinishApplicationMasterResponseProto.Builder builder = null; FinishApplicationMasterResponseProto.Builder builder = null;
@ -63,16 +65,4 @@ public boolean equals(Object other) {
public String toString() { public String toString() {
return getProto().toString().replaceAll("\\n", ", ").replaceAll("\\s+", " "); return getProto().toString().replaceAll("\\n", ", ").replaceAll("\\s+", " ");
} }
private void maybeInitBuilder() {
if (viaProto || builder == null) {
builder = FinishApplicationMasterResponseProto.newBuilder(proto);
}
viaProto = false;
}
} }

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetAllApplicationsRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetAllApplicationsRequest;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetAllApplicationsRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetAllApplicationsRequestProto;
@Private
@Unstable
public class GetAllApplicationsRequestPBImpl extends GetAllApplicationsRequest { public class GetAllApplicationsRequestPBImpl extends GetAllApplicationsRequest {
GetAllApplicationsRequestProto proto = GetAllApplicationsRequestProto.getDefaultInstance(); GetAllApplicationsRequestProto proto = GetAllApplicationsRequestProto.getDefaultInstance();
GetAllApplicationsRequestProto.Builder builder = null; GetAllApplicationsRequestProto.Builder builder = null;

View File

@ -22,6 +22,8 @@
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetAllApplicationsResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetAllApplicationsResponse;
import org.apache.hadoop.yarn.api.records.ApplicationReport; import org.apache.hadoop.yarn.api.records.ApplicationReport;
import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationReportPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationReportPBImpl;
@ -29,6 +31,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetAllApplicationsResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetAllApplicationsResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetAllApplicationsResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetAllApplicationsResponseProtoOrBuilder;
@Private
@Unstable
public class GetAllApplicationsResponsePBImpl public class GetAllApplicationsResponsePBImpl
extends GetAllApplicationsResponse { extends GetAllApplicationsResponse {

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportRequest;
import org.apache.hadoop.yarn.api.records.ApplicationId; import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationIdPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportRequestProtoOrBuilder;
@Private
@Unstable
public class GetApplicationReportRequestPBImpl extends GetApplicationReportRequest { public class GetApplicationReportRequestPBImpl extends GetApplicationReportRequest {
GetApplicationReportRequestProto proto = GetApplicationReportRequestProto.getDefaultInstance(); GetApplicationReportRequestProto proto = GetApplicationReportRequestProto.getDefaultInstance();
GetApplicationReportRequestProto.Builder builder = null; GetApplicationReportRequestProto.Builder builder = null;

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetApplicationReportResponse;
import org.apache.hadoop.yarn.api.records.ApplicationReport; import org.apache.hadoop.yarn.api.records.ApplicationReport;
import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationReportPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationReportPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetApplicationReportResponseProtoOrBuilder;
@Private
@Unstable
public class GetApplicationReportResponsePBImpl extends GetApplicationReportResponse { public class GetApplicationReportResponsePBImpl extends GetApplicationReportResponse {
GetApplicationReportResponseProto proto = GetApplicationReportResponseProto.getDefaultInstance(); GetApplicationReportResponseProto proto = GetApplicationReportResponseProto.getDefaultInstance();
GetApplicationReportResponseProto.Builder builder = null; GetApplicationReportResponseProto.Builder builder = null;

View File

@ -19,11 +19,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsRequest;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsRequestProto;
@Private
@Unstable
public class GetClusterMetricsRequestPBImpl extends GetClusterMetricsRequest { public class GetClusterMetricsRequestPBImpl extends GetClusterMetricsRequest {
GetClusterMetricsRequestProto proto = GetClusterMetricsRequestProto.getDefaultInstance(); GetClusterMetricsRequestProto proto = GetClusterMetricsRequestProto.getDefaultInstance();
GetClusterMetricsRequestProto.Builder builder = null; GetClusterMetricsRequestProto.Builder builder = null;

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetClusterMetricsResponse;
import org.apache.hadoop.yarn.api.records.YarnClusterMetrics; import org.apache.hadoop.yarn.api.records.YarnClusterMetrics;
import org.apache.hadoop.yarn.api.records.impl.pb.YarnClusterMetricsPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.YarnClusterMetricsPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterMetricsResponseProtoOrBuilder;
@Private
@Unstable
public class GetClusterMetricsResponsePBImpl extends GetClusterMetricsResponse { public class GetClusterMetricsResponsePBImpl extends GetClusterMetricsResponse {
GetClusterMetricsResponseProto proto = GetClusterMetricsResponseProto.getDefaultInstance(); GetClusterMetricsResponseProto proto = GetClusterMetricsResponseProto.getDefaultInstance();
GetClusterMetricsResponseProto.Builder builder = null; GetClusterMetricsResponseProto.Builder builder = null;

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesRequest;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesRequestProto;
@Private
@Unstable
public class GetClusterNodesRequestPBImpl extends GetClusterNodesRequest { public class GetClusterNodesRequestPBImpl extends GetClusterNodesRequest {
GetClusterNodesRequestProto proto = GetClusterNodesRequestProto.getDefaultInstance(); GetClusterNodesRequestProto proto = GetClusterNodesRequestProto.getDefaultInstance();

View File

@ -22,6 +22,8 @@
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetClusterNodesResponse;
import org.apache.hadoop.yarn.api.records.NodeReport; import org.apache.hadoop.yarn.api.records.NodeReport;
import org.apache.hadoop.yarn.api.records.impl.pb.NodeReportPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.NodeReportPBImpl;
@ -29,6 +31,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetClusterNodesResponseProtoOrBuilder;
@Private
@Unstable
public class GetClusterNodesResponsePBImpl extends GetClusterNodesResponse { public class GetClusterNodesResponsePBImpl extends GetClusterNodesResponse {
GetClusterNodesResponseProto proto = GetClusterNodesResponseProto proto =

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusRequest;
import org.apache.hadoop.yarn.api.records.ContainerId; import org.apache.hadoop.yarn.api.records.ContainerId;
import org.apache.hadoop.yarn.api.records.impl.pb.ContainerIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ContainerIdPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusRequestProtoOrBuilder;
@Private
@Unstable
public class GetContainerStatusRequestPBImpl extends GetContainerStatusRequest { public class GetContainerStatusRequestPBImpl extends GetContainerStatusRequest {
GetContainerStatusRequestProto proto = GetContainerStatusRequestProto.getDefaultInstance(); GetContainerStatusRequestProto proto = GetContainerStatusRequestProto.getDefaultInstance();
GetContainerStatusRequestProto.Builder builder = null; GetContainerStatusRequestProto.Builder builder = null;

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetContainerStatusResponse;
import org.apache.hadoop.yarn.api.records.ContainerStatus; import org.apache.hadoop.yarn.api.records.ContainerStatus;
import org.apache.hadoop.yarn.api.records.impl.pb.ContainerStatusPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ContainerStatusPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetContainerStatusResponseProtoOrBuilder;
@Private
@Unstable
public class GetContainerStatusResponsePBImpl extends GetContainerStatusResponse { public class GetContainerStatusResponsePBImpl extends GetContainerStatusResponse {
GetContainerStatusResponseProto proto = GetContainerStatusResponseProto.getDefaultInstance(); GetContainerStatusResponseProto proto = GetContainerStatusResponseProto.getDefaultInstance();
GetContainerStatusResponseProto.Builder builder = null; GetContainerStatusResponseProto.Builder builder = null;

View File

@ -17,10 +17,14 @@
*/ */
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto; import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProto;
import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProtoOrBuilder; import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenRequestProtoOrBuilder;
import org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetDelegationTokenRequest;
@Private
@Unstable
public class GetDelegationTokenRequestPBImpl extends GetDelegationTokenRequest { public class GetDelegationTokenRequestPBImpl extends GetDelegationTokenRequest {
String renewer; String renewer;

View File

@ -18,6 +18,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProto; import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProto;
import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProtoOrBuilder; import org.apache.hadoop.security.proto.SecurityProtos.GetDelegationTokenResponseProtoOrBuilder;
import org.apache.hadoop.security.proto.SecurityProtos.TokenProto; import org.apache.hadoop.security.proto.SecurityProtos.TokenProto;
@ -25,6 +27,8 @@
import org.apache.hadoop.yarn.api.records.Token; import org.apache.hadoop.yarn.api.records.Token;
import org.apache.hadoop.yarn.api.records.impl.pb.TokenPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.TokenPBImpl;
@Private
@Unstable
public class GetDelegationTokenResponsePBImpl extends GetDelegationTokenResponse { public class GetDelegationTokenResponsePBImpl extends GetDelegationTokenResponse {
Token appToken; Token appToken;

View File

@ -19,10 +19,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationRequest;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationRequestProto;
@Private
@Unstable
public class GetNewApplicationRequestPBImpl extends GetNewApplicationRequest { public class GetNewApplicationRequestPBImpl extends GetNewApplicationRequest {
GetNewApplicationRequestProto proto = GetNewApplicationRequestProto.getDefaultInstance(); GetNewApplicationRequestProto proto = GetNewApplicationRequestProto.getDefaultInstance();
GetNewApplicationRequestProto.Builder builder = null; GetNewApplicationRequestProto.Builder builder = null;

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetNewApplicationResponse;
import org.apache.hadoop.yarn.api.records.ApplicationId; import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.Resource; import org.apache.hadoop.yarn.api.records.Resource;
@ -29,6 +31,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetNewApplicationResponseProtoOrBuilder;
@Private
@Unstable
public class GetNewApplicationResponsePBImpl extends GetNewApplicationResponse { public class GetNewApplicationResponsePBImpl extends GetNewApplicationResponse {
GetNewApplicationResponseProto proto = GetNewApplicationResponseProto.getDefaultInstance(); GetNewApplicationResponseProto proto = GetNewApplicationResponseProto.getDefaultInstance();
GetNewApplicationResponseProto.Builder builder = null; GetNewApplicationResponseProto.Builder builder = null;

View File

@ -18,10 +18,14 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoRequest;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoRequestProtoOrBuilder;
@Private
@Unstable
public class GetQueueInfoRequestPBImpl extends GetQueueInfoRequest { public class GetQueueInfoRequestPBImpl extends GetQueueInfoRequest {
GetQueueInfoRequestProto proto = GetQueueInfoRequestProto proto =

View File

@ -18,6 +18,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetQueueInfoResponse;
import org.apache.hadoop.yarn.api.records.QueueInfo; import org.apache.hadoop.yarn.api.records.QueueInfo;
import org.apache.hadoop.yarn.api.records.impl.pb.QueueInfoPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.QueueInfoPBImpl;
@ -25,6 +27,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueInfoResponseProtoOrBuilder;
@Private
@Unstable
public class GetQueueInfoResponsePBImpl extends GetQueueInfoResponse { public class GetQueueInfoResponsePBImpl extends GetQueueInfoResponse {
QueueInfo queueInfo; QueueInfo queueInfo;

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest; import org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoRequest;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoRequestProto;
@Private
@Unstable
public class GetQueueUserAclsInfoRequestPBImpl extends GetQueueUserAclsInfoRequest { public class GetQueueUserAclsInfoRequestPBImpl extends GetQueueUserAclsInfoRequest {
GetQueueUserAclsInfoRequestProto proto = GetQueueUserAclsInfoRequestProto proto =

View File

@ -22,6 +22,8 @@
import java.util.Iterator; import java.util.Iterator;
import java.util.List; import java.util.List;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse; import org.apache.hadoop.yarn.api.protocolrecords.GetQueueUserAclsInfoResponse;
import org.apache.hadoop.yarn.api.records.QueueUserACLInfo; import org.apache.hadoop.yarn.api.records.QueueUserACLInfo;
import org.apache.hadoop.yarn.api.records.impl.pb.QueueUserACLInfoPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.QueueUserACLInfoPBImpl;
@ -29,6 +31,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoResponseProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoResponseProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.GetQueueUserAclsInfoResponseProtoOrBuilder;
@Private
@Unstable
public class GetQueueUserAclsInfoResponsePBImpl extends GetQueueUserAclsInfoResponse { public class GetQueueUserAclsInfoResponsePBImpl extends GetQueueUserAclsInfoResponse {
List<QueueUserACLInfo> queueUserAclsInfoList; List<QueueUserACLInfo> queueUserAclsInfoList;

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest; import org.apache.hadoop.yarn.api.protocolrecords.KillApplicationRequest;
import org.apache.hadoop.yarn.api.records.ApplicationId; import org.apache.hadoop.yarn.api.records.ApplicationId;
import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationIdPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationRequestProtoOrBuilder;
@Private
@Unstable
public class KillApplicationRequestPBImpl extends KillApplicationRequest { public class KillApplicationRequestPBImpl extends KillApplicationRequest {
KillApplicationRequestProto proto = KillApplicationRequestProto.getDefaultInstance(); KillApplicationRequestProto proto = KillApplicationRequestProto.getDefaultInstance();
KillApplicationRequestProto.Builder builder = null; KillApplicationRequestProto.Builder builder = null;

View File

@ -19,11 +19,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse; import org.apache.hadoop.yarn.api.protocolrecords.KillApplicationResponse;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationResponseProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.KillApplicationResponseProto;
@Private
@Unstable
public class KillApplicationResponsePBImpl extends KillApplicationResponse { public class KillApplicationResponsePBImpl extends KillApplicationResponse {
KillApplicationResponseProto proto = KillApplicationResponseProto.getDefaultInstance(); KillApplicationResponseProto proto = KillApplicationResponseProto.getDefaultInstance();
KillApplicationResponseProto.Builder builder = null; KillApplicationResponseProto.Builder builder = null;
@ -63,11 +65,4 @@ public boolean equals(Object other) {
public String toString() { public String toString() {
return getProto().toString().replaceAll("\\n", ", ").replaceAll("\\s+", " "); return getProto().toString().replaceAll("\\n", ", ").replaceAll("\\s+", " ");
} }
private void maybeInitBuilder() {
if (viaProto || builder == null) {
builder = KillApplicationResponseProto.newBuilder(proto);
}
viaProto = false;
}
} }

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsRequest;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshAdminAclsRequestProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshAdminAclsRequestProto;
@Private
@Unstable
public class RefreshAdminAclsRequestPBImpl public class RefreshAdminAclsRequestPBImpl
extends RefreshAdminAclsRequest { extends RefreshAdminAclsRequest {

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshAdminAclsResponse;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshAdminAclsResponseProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshAdminAclsResponseProto;
@Private
@Unstable
public class RefreshAdminAclsResponsePBImpl extends RefreshAdminAclsResponse { public class RefreshAdminAclsResponsePBImpl extends RefreshAdminAclsResponse {
RefreshAdminAclsResponseProto proto = RefreshAdminAclsResponseProto.getDefaultInstance(); RefreshAdminAclsResponseProto proto = RefreshAdminAclsResponseProto.getDefaultInstance();

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshNodesRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshNodesRequest;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesRequestProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesRequestProto;
@Private
@Unstable
public class RefreshNodesRequestPBImpl extends RefreshNodesRequest { public class RefreshNodesRequestPBImpl extends RefreshNodesRequest {
RefreshNodesRequestProto proto = RefreshNodesRequestProto.getDefaultInstance(); RefreshNodesRequestProto proto = RefreshNodesRequestProto.getDefaultInstance();

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshNodesResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshNodesResponse;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesResponseProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshNodesResponseProto;
@Private
@Unstable
public class RefreshNodesResponsePBImpl extends RefreshNodesResponse { public class RefreshNodesResponsePBImpl extends RefreshNodesResponse {
RefreshNodesResponseProto proto = RefreshNodesResponseProto.getDefaultInstance(); RefreshNodesResponseProto proto = RefreshNodesResponseProto.getDefaultInstance();

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshQueuesRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshQueuesRequest;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshQueuesRequestProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshQueuesRequestProto;
@Private
@Unstable
public class RefreshQueuesRequestPBImpl extends RefreshQueuesRequest { public class RefreshQueuesRequestPBImpl extends RefreshQueuesRequest {
RefreshQueuesRequestProto proto = RefreshQueuesRequestProto.getDefaultInstance(); RefreshQueuesRequestProto proto = RefreshQueuesRequestProto.getDefaultInstance();

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshQueuesResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshQueuesResponse;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshQueuesResponseProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshQueuesResponseProto;
@Private
@Unstable
public class RefreshQueuesResponsePBImpl extends RefreshQueuesResponse { public class RefreshQueuesResponsePBImpl extends RefreshQueuesResponse {
RefreshQueuesResponseProto proto = RefreshQueuesResponseProto.getDefaultInstance(); RefreshQueuesResponseProto proto = RefreshQueuesResponseProto.getDefaultInstance();

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshServiceAclsRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshServiceAclsRequest;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshServiceAclsRequestProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshServiceAclsRequestProto;
@Private
@Unstable
public class RefreshServiceAclsRequestPBImpl extends RefreshServiceAclsRequest { public class RefreshServiceAclsRequestPBImpl extends RefreshServiceAclsRequest {
RefreshServiceAclsRequestProto proto = RefreshServiceAclsRequestProto proto =

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshServiceAclsResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshServiceAclsResponse;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshServiceAclsResponseProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshServiceAclsResponseProto;
@Private
@Unstable
public class RefreshServiceAclsResponsePBImpl extends public class RefreshServiceAclsResponsePBImpl extends
RefreshServiceAclsResponse { RefreshServiceAclsResponse {

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshSuperUserGroupsConfigurationRequest;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshSuperUserGroupsConfigurationRequestProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshSuperUserGroupsConfigurationRequestProto;
@Private
@Unstable
public class RefreshSuperUserGroupsConfigurationRequestPBImpl public class RefreshSuperUserGroupsConfigurationRequestPBImpl
extends RefreshSuperUserGroupsConfigurationRequest { extends RefreshSuperUserGroupsConfigurationRequest {

View File

@ -18,10 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshSuperUserGroupsConfigurationResponse;
import org.apache.hadoop.yarn.api.records.impl.pb.ProtoBase;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshSuperUserGroupsConfigurationResponseProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshSuperUserGroupsConfigurationResponseProto;
@Private
@Unstable
public class RefreshSuperUserGroupsConfigurationResponsePBImpl extends RefreshSuperUserGroupsConfigurationResponse { public class RefreshSuperUserGroupsConfigurationResponsePBImpl extends RefreshSuperUserGroupsConfigurationResponse {
RefreshSuperUserGroupsConfigurationResponseProto proto = RefreshSuperUserGroupsConfigurationResponseProto.getDefaultInstance(); RefreshSuperUserGroupsConfigurationResponseProto proto = RefreshSuperUserGroupsConfigurationResponseProto.getDefaultInstance();

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsRequest; import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsRequest;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshUserToGroupsMappingsRequestProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshUserToGroupsMappingsRequestProto;
@Private
@Unstable
public class RefreshUserToGroupsMappingsRequestPBImpl public class RefreshUserToGroupsMappingsRequestPBImpl
extends RefreshUserToGroupsMappingsRequest { extends RefreshUserToGroupsMappingsRequest {

View File

@ -18,9 +18,13 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsResponse; import org.apache.hadoop.yarn.api.protocolrecords.RefreshUserToGroupsMappingsResponse;
import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshUserToGroupsMappingsResponseProto; import org.apache.hadoop.yarn.proto.YarnServerResourceManagerServiceProtos.RefreshUserToGroupsMappingsResponseProto;
@Private
@Unstable
public class RefreshUserToGroupsMappingsResponsePBImpl extends RefreshUserToGroupsMappingsResponse { public class RefreshUserToGroupsMappingsResponsePBImpl extends RefreshUserToGroupsMappingsResponse {
RefreshUserToGroupsMappingsResponseProto proto = RefreshUserToGroupsMappingsResponseProto.getDefaultInstance(); RefreshUserToGroupsMappingsResponseProto proto = RefreshUserToGroupsMappingsResponseProto.getDefaultInstance();

View File

@ -19,6 +19,8 @@
package org.apache.hadoop.yarn.api.protocolrecords.impl.pb; package org.apache.hadoop.yarn.api.protocolrecords.impl.pb;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest; import org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterRequest;
import org.apache.hadoop.yarn.api.records.ApplicationAttemptId; import org.apache.hadoop.yarn.api.records.ApplicationAttemptId;
import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationAttemptIdPBImpl; import org.apache.hadoop.yarn.api.records.impl.pb.ApplicationAttemptIdPBImpl;
@ -26,8 +28,8 @@
import org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto; import org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProto;
import org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProtoOrBuilder; import org.apache.hadoop.yarn.proto.YarnServiceProtos.RegisterApplicationMasterRequestProtoOrBuilder;
@Private
@Unstable
public class RegisterApplicationMasterRequestPBImpl extends RegisterApplicationMasterRequest { public class RegisterApplicationMasterRequestPBImpl extends RegisterApplicationMasterRequest {
RegisterApplicationMasterRequestProto proto = RegisterApplicationMasterRequestProto.getDefaultInstance(); RegisterApplicationMasterRequestProto proto = RegisterApplicationMasterRequestProto.getDefaultInstance();
RegisterApplicationMasterRequestProto.Builder builder = null; RegisterApplicationMasterRequestProto.Builder builder = null;

View File

@ -25,6 +25,8 @@
import java.util.List; import java.util.List;
import java.util.Map; import java.util.Map;
import org.apache.hadoop.classification.InterfaceAudience.Private;
import org.apache.hadoop.classification.InterfaceStability.Unstable;
import org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse; import org.apache.hadoop.yarn.api.protocolrecords.RegisterApplicationMasterResponse;
import org.apache.hadoop.yarn.api.records.ApplicationAccessType; import org.apache.hadoop.yarn.api.records.ApplicationAccessType;
import org.apache.hadoop.yarn.api.records.Resource; import org.apache.hadoop.yarn.api.records.Resource;
@ -38,6 +40,8 @@
import com.google.protobuf.ByteString; import com.google.protobuf.ByteString;
@Private
@Unstable
public class RegisterApplicationMasterResponsePBImpl extends public class RegisterApplicationMasterResponsePBImpl extends
RegisterApplicationMasterResponse { RegisterApplicationMasterResponse {
RegisterApplicationMasterResponseProto proto = RegisterApplicationMasterResponseProto proto =

Some files were not shown because too many files have changed in this diff Show More