Return-Path:
The ResourceManager
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}.
ApplicationId
@@ -83,6 +84,8 @@ public interface ApplicationClientProtoc
* @throws IOException
* @see #submitApplication(SubmitApplicationRequest)
*/
+ @Public
+ @Stable
public GetNewApplicationResponse getNewApplication(
GetNewApplicationRequest request)
throws YarnException, IOException;
@@ -112,6 +115,8 @@ public interface ApplicationClientProtoc
* @throws IOException
* @see #getNewApplication(GetNewApplicationRequest)
*/
+ @Public
+ @Stable
public SubmitApplicationResponse submitApplication(
SubmitApplicationRequest request)
throws YarnException, IOException;
@@ -129,13 +134,15 @@ public interface ApplicationClientProtoc
* Currently, the ResourceManager
returns an empty response
* on success and throws an exception on rejecting the request.
ResourceManager
returns an empty response
* on success and throws an exception on rejecting the request
* @throws YarnException
* @throws IOException
* @see #getQueueUserAcls(GetQueueUserAclsInfoRequest)
*/
+ @Public
+ @Stable
public KillApplicationResponse forceKillApplication(
KillApplicationRequest request)
throws YarnException, IOException;
@@ -171,6 +178,8 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetApplicationReportResponse getApplicationReport(
GetApplicationReportRequest request)
throws YarnException, IOException;
@@ -189,6 +198,8 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetClusterMetricsResponse getClusterMetrics(
GetClusterMetricsRequest request)
throws YarnException, IOException;
@@ -211,6 +222,8 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetAllApplicationsResponse getAllApplications(
GetAllApplicationsRequest request)
throws YarnException, IOException;
@@ -228,6 +241,8 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetClusterNodesResponse getClusterNodes(
GetClusterNodesRequest request)
throws YarnException, IOException;
@@ -247,6 +262,8 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetQueueInfoResponse getQueueInfo(
GetQueueInfoRequest request)
throws YarnException, IOException;
@@ -264,6 +281,8 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetQueueUserAclsInfoResponse getQueueUserAcls(
GetQueueUserAclsInfoRequest request)
throws YarnException, IOException;
@@ -272,7 +291,7 @@ public interface ApplicationClientProtoc
* The interface used by clients to get delegation token, enabling the * containers to be able to talk to the service using those tokens. * - *
The ResourceManager
responds with the delegation token
+ *
The ResourceManager
responds with the delegation
* {@link Token} that can be used by the client to speak to this
* service.
* @param request request to get a delegation token for the client.
@@ -280,12 +299,14 @@ public interface ApplicationClientProtoc
* @throws YarnException
* @throws IOException
*/
+ @Public
+ @Stable
public GetDelegationTokenResponse getDelegationToken(
GetDelegationTokenRequest request)
throws YarnException, IOException;
/**
- * Renew an existing delegation token.
+ * Renew an existing delegation {@link Token}.
*
* @param request the delegation token to be renewed.
* @return the new expiry time for the delegation token.
@@ -293,12 +314,13 @@ public interface ApplicationClientProtoc
* @throws IOException
*/
@Private
+ @Unstable
public RenewDelegationTokenResponse renewDelegationToken(
RenewDelegationTokenRequest request) throws YarnException,
IOException;
/**
- * Cancel an existing delegation token.
+ * Cancel an existing delegation {@link Token}.
*
* @param request the delegation token to be cancelled.
* @return an empty response.
@@ -306,6 +328,7 @@ public interface ApplicationClientProtoc
* @throws IOException
*/
@Private
+ @Unstable
public CancelDelegationTokenResponse cancelDelegationToken(
CancelDelegationTokenRequest request) throws YarnException,
IOException;
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationClientProtocolPB.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationClientProtocolPB.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationClientProtocolPB.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationClientProtocolPB.java Tue Jun 18 03:16:04 2013
@@ -17,9 +17,13 @@
*/
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.yarn.proto.ApplicationClientProtocol.ApplicationClientProtocolService;
+@Private
+@Unstable
@ProtocolInfo(protocolName = "org.apache.hadoop.yarn.api.ApplicationClientProtocolPB",
protocolVersion = 1)
public interface ApplicationClientProtocolPB extends ApplicationClientProtocolService.BlockingInterface {
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationConstants.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationConstants.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationConstants.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/ApplicationConstants.java Tue Jun 18 03:16:04 2013
@@ -18,6 +18,8 @@
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.util.Shell;
@@ -27,6 +29,8 @@ import org.apache.hadoop.util.Shell;
*
* TODO: Investigate the semantics and security of each cross-boundary refs.
*/
+@Public
+@Evolving
public interface ApplicationConstants {
/**
@@ -35,6 +39,9 @@ public interface ApplicationConstants {
*/
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 =
UserGroupInformation.HADOOP_TOKEN_FILE_LOCATION;
@@ -46,6 +53,10 @@ public interface ApplicationConstants {
public static final String APPLICATION_WEB_PROXY_BASE_ENV =
"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 = "
The ResourceManager
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}.
ApplicationMaster
know that its
- * horribly out of sync and needs to reboot.ApplicationMaster
+ * take some actions (resync, shutdown etc.).
* ResourceManager
.
* @param containers list of newly allocated Container
*/
- @Public
- @Stable
+ @Private
+ @Unstable
public abstract void setAllocatedContainers(ListGet 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 * resources owned by the AM. These messages are advisory, and the AM may - * elect to ignore them. + * elect to ignore them.
* - * The message is a snapshot of the resources the RM wants back from the AM. + *
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
- * not interpret each message as a request for
*
* @return A specification of the resources to reclaim from this AM.
*/
@@ -200,24 +202,23 @@ public abstract class AllocateResponse {
@Private
@Unstable
public abstract void setPreemptionMessage(PreemptionMessage request);
-
- @Public
- @Stable
- public abstract void setNMTokens(List Get the list of NMTokens required for communicating with NM. New NMTokens
+ * issued only if
+ * 1) AM is receiving first container on underlying NodeManager.
+ * 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
- * new token for the same NM.
+ * new token for the same NM.
*/
@Public
@Stable
public abstract List
+ * OR
* 2) NMToken master key rolled over in ResourceManager and AM is getting new
- * container on the same underlying NodeManager.
- * AM will receive one NMToken per NM irrespective of the number of containers
+ * container on the same underlying NodeManager.ApplicationId
of the application.
* @return ApplicationId
of the application
*/
+ @Public
+ @Stable
public abstract ApplicationId getApplicationId();
/**
* Set the ApplicationId
of the application
* @param applicationId ApplicationId
of the application
*/
+ @Public
+ @Stable
public abstract void setApplicationId(ApplicationId applicationId);
}
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetApplicationReportResponse.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetApplicationReportResponse.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetApplicationReportResponse.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetApplicationReportResponse.java Tue Jun 18 03:16:04 2013
@@ -40,6 +40,8 @@ import org.apache.hadoop.yarn.util.Recor
@Stable
public abstract class GetApplicationReportResponse {
+ @Private
+ @Unstable
public static GetApplicationReportResponse newInstance(
ApplicationReport ApplicationReport) {
GetApplicationReportResponse response =
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsRequest.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsRequest.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsRequest.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsRequest.java Tue Jun 18 03:16:04 2013
@@ -34,6 +34,8 @@ import org.apache.hadoop.yarn.util.Recor
@Public
@Stable
public abstract class GetClusterMetricsRequest {
+ @Public
+ @Stable
public static GetClusterMetricsRequest newInstance() {
GetClusterMetricsRequest request =
Records.newRecord(GetClusterMetricsRequest.class);
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsResponse.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsResponse.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsResponse.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterMetricsResponse.java Tue Jun 18 03:16:04 2013
@@ -37,6 +37,8 @@ import org.apache.hadoop.yarn.util.Recor
@Stable
public abstract class GetClusterMetricsResponse {
+ @Private
+ @Unstable
public static GetClusterMetricsResponse
newInstance(YarnClusterMetrics metrics) {
GetClusterMetricsResponse response =
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesRequest.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesRequest.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesRequest.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesRequest.java Tue Jun 18 03:16:04 2013
@@ -34,6 +34,8 @@ import org.apache.hadoop.yarn.util.Recor
@Public
@Stable
public abstract class GetClusterNodesRequest {
+ @Public
+ @Stable
public static GetClusterNodesRequest newInstance() {
GetClusterNodesRequest request =
Records.newRecord(GetClusterNodesRequest.class);
Modified: hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesResponse.java
URL: http://svn.apache.org/viewvc/hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesResponse.java?rev=1493994&r1=1493993&r2=1493994&view=diff
==============================================================================
--- hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesResponse.java (original)
+++ hadoop/common/branches/branch-2.1-beta/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/api/protocolrecords/GetClusterNodesResponse.java Tue Jun 18 03:16:04 2013
@@ -43,6 +43,8 @@ import org.apache.hadoop.yarn.util.Recor
@Stable
public abstract class GetClusterNodesResponse {
+ @Private
+ @Unstable
public static GetClusterNodesResponse
newInstance(Listtrue
if applications' information is to be included,
* else false
*/
+ @Public
+ @Stable
public abstract boolean getIncludeApplications();
/**
@@ -68,6 +76,8 @@ public abstract class GetQueueInfoReques
* @param includeApplications fetch information about active
* applications?
*/
+ @Public
+ @Stable
public abstract void setIncludeApplications(boolean includeApplications);
/**
@@ -75,12 +85,16 @@ public abstract class GetQueueInfoReques
* @return true
if information about child queues is required,
* else false
*/
+ @Public
+ @Stable
public abstract boolean getIncludeChildQueues();
/**
* Should we fetch information about child queues?
* @param includeChildQueues fetch information about child queues?
*/
+ @Public
+ @Stable
public abstract void setIncludeChildQueues(boolean includeChildQueues);
/**
@@ -88,6 +102,8 @@ public abstract class GetQueueInfoReques
* @return true
if information about entire hierarchy is
* required, false
otherwise
*/
+ @Public
+ @Stable
public abstract boolean getRecursive();
/**
@@ -95,6 +111,8 @@ public abstract class GetQueueInfoReques
* @param recursive fetch information on the entire child queue
* hierarchy?
*/
+ @Public
+ @Stable
public abstract void setRecursive(boolean recursive);
}