hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject svn commit: r946526 [6/6] - in /hadoop/mapreduce/trunk: ./ src/java/org/apache/hadoop/filecache/ src/java/org/apache/hadoop/mapred/ src/java/org/apache/hadoop/mapred/jobcontrol/ src/java/org/apache/hadoop/mapred/join/ src/java/org/apache/hadoop/mapred/...
Date Thu, 20 May 2010 05:03:29 GMT
Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/DelegationTokenRenewal.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/DelegationTokenRenewal.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/DelegationTokenRenewal.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/DelegationTokenRenewal.java Thu May 20 05:03:20 2010
@@ -33,6 +33,7 @@ import java.util.TimerTask;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.hdfs.DistributedFileSystem;
@@ -46,6 +47,7 @@ import org.apache.hadoop.security.token.
 
 
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class DelegationTokenRenewal {
   private static final Log LOG = LogFactory.getLog(DelegationTokenRenewal.class);
   public static final String SCHEME = "hdfs";

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenIdentifier.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenIdentifier.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenIdentifier.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenIdentifier.java Thu May 20 05:03:20 2010
@@ -23,6 +23,7 @@ import java.io.DataOutput;
 import java.io.IOException;
 
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.security.token.TokenIdentifier;
 import org.apache.hadoop.security.UserGroupInformation;
@@ -31,6 +32,7 @@ import org.apache.hadoop.security.UserGr
  * The token identifier for job token
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobTokenIdentifier extends TokenIdentifier {
   private Text jobid;
   final static Text KIND_NAME = new Text("mapreduce.job");

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSecretManager.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSecretManager.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSecretManager.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSecretManager.java Thu May 20 05:03:20 2010
@@ -24,6 +24,7 @@ import java.util.TreeMap;
 import javax.crypto.SecretKey;
 
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.security.token.SecretManager;
 import org.apache.hadoop.security.token.Token;
 
@@ -31,6 +32,7 @@ import org.apache.hadoop.security.token.
  * SecretManager for job token. It can be used to cache generated job tokens.
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobTokenSecretManager extends SecretManager<JobTokenIdentifier> {
   private final SecretKey masterKey;
   private final Map<String, SecretKey> currentJobTokens;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSelector.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSelector.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSelector.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSelector.java Thu May 20 05:03:20 2010
@@ -21,6 +21,7 @@ package org.apache.hadoop.mapreduce.secu
 import java.util.Collection;
 
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.security.token.Token;
 import org.apache.hadoop.security.token.TokenIdentifier;
@@ -31,6 +32,7 @@ import org.apache.hadoop.security.token.
  * and return it.
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobTokenSelector implements TokenSelector<JobTokenIdentifier> {
 
   @SuppressWarnings("unchecked")

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenIdentifier.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenIdentifier.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenIdentifier.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenIdentifier.java Thu May 20 05:03:20 2010
@@ -19,6 +19,7 @@
 package org.apache.hadoop.mapreduce.security.token.delegation;
 
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.security.token.delegation.AbstractDelegationTokenIdentifier;
 
@@ -26,6 +27,7 @@ import org.apache.hadoop.security.token.
  * A delegation token identifier that is specific to MapReduce.
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class DelegationTokenIdentifier 
     extends AbstractDelegationTokenIdentifier {
   static final Text MAPREDUCE_DELEGATION_KIND = 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSecretManager.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSecretManager.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSecretManager.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSecretManager.java Thu May 20 05:03:20 2010
@@ -19,6 +19,7 @@
 package org.apache.hadoop.mapreduce.security.token.delegation;
 
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSecretManager;
 
 /**
@@ -27,6 +28,7 @@ import org.apache.hadoop.security.token.
  * for each token.
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class DelegationTokenSecretManager
     extends AbstractDelegationTokenSecretManager<DelegationTokenIdentifier> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSelector.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSelector.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSelector.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSelector.java Thu May 20 05:03:20 2010
@@ -18,12 +18,14 @@
 package org.apache.hadoop.mapreduce.security.token.delegation;
 
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.security.token.delegation.AbstractDelegationTokenSelector;
 
 /**
  * A delegation token that is specialized for MapReduce
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class DelegationTokenSelector
     extends AbstractDelegationTokenSelector<DelegationTokenIdentifier>{
 

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,23 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.security.token.delegation;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,23 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.security.token;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JTConfig.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JTConfig.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JTConfig.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JTConfig.java Thu May 20 05:03:20 2010
@@ -17,6 +17,8 @@
  */
 package org.apache.hadoop.mapreduce.server.jobtracker;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.MRConfig;
 
 /**
@@ -24,6 +26,8 @@ import org.apache.hadoop.mapreduce.MRCon
  * 
  * The keys should have "mapreduce.jobtracker." as the prefix
  */
+@InterfaceAudience.Private
+@InterfaceStability.Evolving
 public interface JTConfig extends MRConfig {
   // JobTracker configuration parameters
   public static final String JT_IPC_ADDRESS  = "mapreduce.jobtracker.address";

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JobTrackerJspHelper.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JobTrackerJspHelper.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JobTrackerJspHelper.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JobTrackerJspHelper.java Thu May 20 05:03:20 2010
@@ -25,6 +25,8 @@ import java.text.DecimalFormat;
 import javax.servlet.jsp.JspWriter;
 import javax.servlet.http.*;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapred.ClusterStatus;
 import org.apache.hadoop.mapred.JobInProgress;
 import org.apache.hadoop.mapred.JobProfile;
@@ -38,6 +40,8 @@ import org.apache.hadoop.util.StringUtil
 /**
  * Methods to help format output for JobTracker XML JSPX
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobTrackerJspHelper {
 
   public JobTrackerJspHelper() {

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/State.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/State.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/State.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/State.java Thu May 20 05:03:20 2010
@@ -17,9 +17,14 @@
  */
 package org.apache.hadoop.mapreduce.server.jobtracker;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Describes the state of JobTracker 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public enum State {
   INITIALIZING, RUNNING;
 }

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/TaskTracker.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/TaskTracker.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/TaskTracker.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/TaskTracker.java Thu May 20 05:03:20 2010
@@ -19,6 +19,8 @@ package org.apache.hadoop.mapreduce.serv
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapred.JobInProgress;
 import org.apache.hadoop.mapred.JobTracker;
 import org.apache.hadoop.mapred.TaskTrackerStatus;
@@ -29,6 +31,8 @@ import org.apache.hadoop.mapreduce.TaskT
  * The representation of a single <code>TaskTracker</code> as seen by 
  * the {@link JobTracker}.
  */
+@InterfaceAudience.LimitedPrivate("MapReduce")
+@InterfaceStability.Unstable
 public class TaskTracker {
   static final Log LOG = LogFactory.getLog(TaskTracker.class);
   

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/Localizer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/Localizer.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/Localizer.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/Localizer.java Thu May 20 05:03:20 2010
@@ -25,6 +25,8 @@ import java.util.concurrent.atomic.Atomi
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.FileUtil;
 import org.apache.hadoop.fs.Path;
@@ -34,10 +36,8 @@ import org.apache.hadoop.mapred.TaskTrac
 import org.apache.hadoop.mapred.TaskController.InitializationContext;
 import org.apache.hadoop.mapreduce.JobID;
 
-/**
- * 
- * NOTE: This class is internal only and not intended for users!!
- */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class Localizer {
 
   static final Log LOG = LogFactory.getLog(Localizer.class);
@@ -59,10 +59,8 @@ public class Localizer {
     taskController = tc;
   }
 
-  /**
-   * NOTE: This class is internal only class and not intended for users!!
-   * 
-   */
+  @InterfaceAudience.Private
+  @InterfaceStability.Unstable
   public static class PermissionsHandler {
     /**
      * Permission information useful for setting permissions for a given path.
@@ -71,6 +69,8 @@ public class Localizer {
      * be set together, i.e. permissions for group cannot be set different from
      * those for others and vice versa.
      */
+    @InterfaceAudience.Private
+    @InterfaceStability.Unstable
     public static class PermissionsInfo {
       public boolean readPermissions;
       public boolean writePermissions;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/TTConfig.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/TTConfig.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/TTConfig.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/TTConfig.java Thu May 20 05:03:20 2010
@@ -17,6 +17,8 @@
  */
 package org.apache.hadoop.mapreduce.server.tasktracker;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.MRConfig;
 
 /**
@@ -24,7 +26,8 @@ import org.apache.hadoop.mapreduce.MRCon
  * 
  * The keys should have "mapreduce.tasktracker." as the prefix
  */
-
+@InterfaceAudience.Private
+@InterfaceStability.Evolving
 public interface TTConfig extends MRConfig {
 
   // Task-tracker configuration properties

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,23 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.server.tasktracker;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplit.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplit.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplit.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplit.java Thu May 20 05:03:20 2010
@@ -27,6 +27,7 @@ import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.WritableUtils;
 import org.apache.hadoop.mapreduce.InputSplit;
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 
 /**
  * This class groups the fundamental classes associated with
@@ -43,6 +44,7 @@ import org.apache.hadoop.classification.
  * file.
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobSplit {
   static final int META_SPLIT_VERSION = 1;
   static final byte[] META_SPLIT_FILE_HEADER;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplitWriter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplitWriter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplitWriter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplitWriter.java Thu May 20 05:03:20 2010
@@ -36,12 +36,14 @@ import org.apache.hadoop.mapreduce.Job;
 import org.apache.hadoop.mapreduce.JobSubmissionFiles;
 import org.apache.hadoop.mapreduce.split.JobSplit.SplitMetaInfo;
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 
-@InterfaceAudience.Private
 /**
  * The class that is used by the Job clients to write splits (both the meta
  * and the raw bytes parts)
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobSplitWriter {
 
   private static final int splitVersion = JobSplit.META_SPLIT_VERSION;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReader.java Thu May 20 05:03:20 2010
@@ -31,13 +31,14 @@ import org.apache.hadoop.mapreduce.JobID
 import org.apache.hadoop.mapreduce.JobSubmissionFiles;
 import org.apache.hadoop.mapreduce.server.jobtracker.JTConfig;
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 
-@InterfaceAudience.Private
 /**
  * A utility that reads the split meta info and creates
  * split meta info objects
  */
-
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class SplitMetaInfoReader {
   
   public static JobSplit.TaskSplitMetaInfo[] readSplitMetaInfo(

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,22 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.split;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/JobContextImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/JobContextImpl.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/JobContextImpl.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/JobContextImpl.java Thu May 20 05:03:20 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapreduce.task
 import java.io.IOException;
 import java.net.URI;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.conf.Configuration.IntegerRanges;
 import org.apache.hadoop.fs.Path;
@@ -43,6 +45,8 @@ import org.apache.hadoop.security.UserGr
  * A read-only view of the job that is provided to the tasks while they
  * are running.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobContextImpl implements JobContext {
 
   protected final org.apache.hadoop.mapred.JobConf conf;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/MapContextImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/MapContextImpl.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/MapContextImpl.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/MapContextImpl.java Thu May 20 05:03:20 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.task
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.MapContext;
@@ -37,6 +39,8 @@ import org.apache.hadoop.mapreduce.TaskA
  * @param <KEYOUT> the key output type from the Mapper
  * @param <VALUEOUT> the value output type from the Mapper
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class MapContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT> 
     extends TaskInputOutputContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT> 
     implements MapContext<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java Thu May 20 05:03:20 2010
@@ -23,6 +23,8 @@ import java.io.IOException;
 import java.util.Iterator;
 import java.util.NoSuchElementException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.BytesWritable;
 import org.apache.hadoop.io.DataInputBuffer;
@@ -49,6 +51,8 @@ import org.apache.hadoop.util.Progressab
  * @param <KEYOUT> the class of the output keys
  * @param <VALUEOUT> the class of the output values
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ReduceContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
     extends TaskInputOutputContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT> 
     implements ReduceContext<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskAttemptContextImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskAttemptContextImpl.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskAttemptContextImpl.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskAttemptContextImpl.java Thu May 20 05:03:20 2010
@@ -18,6 +18,8 @@
 
 package org.apache.hadoop.mapreduce.task;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
@@ -25,6 +27,8 @@ import org.apache.hadoop.mapreduce.TaskA
 /**
  * The context for task attempts.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskAttemptContextImpl extends JobContextImpl 
     implements TaskAttemptContext {
   private final TaskAttemptID taskId;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskInputOutputContextImpl.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskInputOutputContextImpl.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskInputOutputContextImpl.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskInputOutputContextImpl.java Thu May 20 05:03:20 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.task
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.mapreduce.Counter;
 import org.apache.hadoop.mapreduce.OutputCommitter;
@@ -38,6 +40,8 @@ import org.apache.hadoop.mapreduce.Reduc
  * @param <KEYOUT> the output key type for the task
  * @param <VALUEOUT> the output value type for the task
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public abstract class TaskInputOutputContextImpl<KEYIN,VALUEIN,KEYOUT,VALUEOUT> 
        extends TaskAttemptContextImpl 
        implements TaskInputOutputContext<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,23 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.task;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryReader.java Thu May 20 05:03:20 2010
@@ -22,6 +22,8 @@ import java.io.File;
 import java.io.FileOutputStream;
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.DataInputBuffer;
 import org.apache.hadoop.mapred.IFile.Reader;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
@@ -29,6 +31,8 @@ import org.apache.hadoop.mapreduce.TaskA
 /**
  * <code>IFile.InMemoryReader</code> to read map-outputs present in-memory.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class InMemoryReader<K, V> extends Reader<K, V> {
   private final TaskAttemptID taskAttemptId;
   private final MergeManager<K,V> merger;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryWriter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryWriter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryWriter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryWriter.java Thu May 20 05:03:20 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.task
 import java.io.DataOutputStream;
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.BoundedByteArrayOutputStream;
 import org.apache.hadoop.io.DataInputBuffer;
 import org.apache.hadoop.io.WritableUtils;
@@ -27,6 +29,8 @@ import org.apache.hadoop.mapred.IFile;
 import org.apache.hadoop.mapred.IFileOutputStream;
 import org.apache.hadoop.mapred.IFile.Writer;
 
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class InMemoryWriter<K, V> extends Writer<K, V> {
   private DataOutputStream out;
   

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/MergeManager.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/MergeManager.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/MergeManager.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/MergeManager.java Thu May 20 05:03:20 2010
@@ -27,6 +27,8 @@ import java.util.TreeSet;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.ChecksumFileSystem;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.LocalDirAllocator;
@@ -58,7 +60,8 @@ import org.apache.hadoop.util.Progress;
 import org.apache.hadoop.util.ReflectionUtils;
 
 @SuppressWarnings(value={"unchecked", "deprecation"})
-
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class MergeManager<K, V> {
   
   private static final Log LOG = LogFactory.getLog(MergeManager.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/Shuffle.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/Shuffle.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/Shuffle.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/Shuffle.java Thu May 20 05:03:20 2010
@@ -21,6 +21,8 @@ import java.io.IOException;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.LocalDirAllocator;
 import org.apache.hadoop.io.compress.CompressionCodec;
@@ -37,6 +39,8 @@ import org.apache.hadoop.mapreduce.MRJob
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.util.Progress;
 
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class Shuffle<K, V> implements ExceptionReporter {
   private static final Log LOG = LogFactory.getLog(Shuffle.class);
   private static final int PROGRESS_FREQUENCY = 2000;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/ShuffleHeader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/ShuffleHeader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/ShuffleHeader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/ShuffleHeader.java Thu May 20 05:03:20 2010
@@ -21,6 +21,8 @@ import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.WritableUtils;
@@ -30,6 +32,8 @@ import org.apache.hadoop.io.WritableUtil
  * deciphered by the Fetcher thread of Reduce task
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Stable
 public class ShuffleHeader implements Writable {
 
   /**

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,23 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.task.reduce;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/tools/CLI.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/tools/CLI.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/tools/CLI.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/tools/CLI.java Thu May 20 05:03:20 2010
@@ -23,6 +23,8 @@ import java.util.List;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.ipc.RemoteException;
@@ -47,6 +49,8 @@ import org.apache.hadoop.util.ToolRunner
 /**
  * Interprets the map reduce cli options 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class CLI extends Configured implements Tool {
   private static final Log LOG = LogFactory.getLog(CLI.class);
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ConfigUtil.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ConfigUtil.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ConfigUtil.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ConfigUtil.java Thu May 20 05:03:20 2010
@@ -17,6 +17,8 @@
  */
 package org.apache.hadoop.mapreduce.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.mapreduce.Job;
 import org.apache.hadoop.mapreduce.MRConfig;
@@ -27,6 +29,8 @@ import org.apache.hadoop.mapreduce.serve
 /**
  * Place holder for deprecated keys in the framework 
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ConfigUtil {
 
   /**

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxMemoryCalculatorPlugin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxMemoryCalculatorPlugin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxMemoryCalculatorPlugin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxMemoryCalculatorPlugin.java Thu May 20 05:03:20 2010
@@ -18,6 +18,9 @@
 
 package org.apache.hadoop.mapreduce.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Plugin to calculate virtual and physical memories on Linux systems.
  * @deprecated 
@@ -25,6 +28,8 @@ package org.apache.hadoop.mapreduce.util
  * instead
  */
 @Deprecated
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class LinuxMemoryCalculatorPlugin extends MemoryCalculatorPlugin {
   private LinuxResourceCalculatorPlugin resourceCalculatorPlugin;
   // Use everything from LinuxResourceCalculatorPlugin

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxResourceCalculatorPlugin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxResourceCalculatorPlugin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxResourceCalculatorPlugin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxResourceCalculatorPlugin.java Thu May 20 05:03:20 2010
@@ -27,11 +27,15 @@ import java.util.regex.Pattern;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapred.TaskTrackerStatus;
 
 /**
  * Plugin to calculate resource information on Linux systems.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class LinuxResourceCalculatorPlugin extends ResourceCalculatorPlugin {
   private static final Log LOG =
       LogFactory.getLog(LinuxResourceCalculatorPlugin.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java Thu May 20 05:03:20 2010
@@ -33,6 +33,7 @@ import org.apache.hadoop.mapred.JobConf;
 import org.apache.hadoop.util.AsyncDiskService;
 import org.apache.hadoop.util.StringUtils;
 import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 
 /**
  * This class is a container of multiple thread pools, each for a volume,
@@ -49,6 +50,7 @@ import org.apache.hadoop.classification.
  * thread pools. 
  */
 @InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class MRAsyncDiskService {
   
   public static final Log LOG = LogFactory.getLog(MRAsyncDiskService.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MemoryCalculatorPlugin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MemoryCalculatorPlugin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MemoryCalculatorPlugin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MemoryCalculatorPlugin.java Thu May 20 05:03:20 2010
@@ -18,6 +18,8 @@
 
 package org.apache.hadoop.mapreduce.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.util.ReflectionUtils;
@@ -29,6 +31,8 @@ import org.apache.hadoop.util.Reflection
  *             instead
  */
 @Deprecated
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public abstract class MemoryCalculatorPlugin extends Configured {
 
   /**

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcessTree.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcessTree.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcessTree.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcessTree.java Thu May 20 05:03:20 2010
@@ -24,6 +24,8 @@ import java.util.Arrays;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.util.StringUtils;
 import org.apache.hadoop.util.Shell.ExitCodeException;
 import org.apache.hadoop.util.Shell.ShellCommandExecutor;
@@ -31,6 +33,8 @@ import org.apache.hadoop.util.Shell.Shel
 /** 
  * Process tree related operations
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ProcessTree {
 
   private static final Log LOG = LogFactory.getLog(ProcessTree.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcfsBasedProcessTree.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcfsBasedProcessTree.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcfsBasedProcessTree.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcfsBasedProcessTree.java Thu May 20 05:03:20 2010
@@ -33,12 +33,16 @@ import java.util.LinkedList;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.util.Shell.ShellCommandExecutor;
 import org.apache.hadoop.util.StringUtils;
 
 /**
  * A Proc file-system based ProcessTree. Works only on Linux.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ProcfsBasedProcessTree extends ProcessTree {
 
   static final Log LOG = LogFactory

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ResourceCalculatorPlugin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ResourceCalculatorPlugin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ResourceCalculatorPlugin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ResourceCalculatorPlugin.java Thu May 20 05:03:20 2010
@@ -18,6 +18,8 @@
 
 package org.apache.hadoop.mapreduce.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.conf.Configured;
 import org.apache.hadoop.util.ReflectionUtils;
@@ -26,6 +28,8 @@ import org.apache.hadoop.util.Reflection
  * Plugin to calculate resource information on the system.
  * 
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public abstract class ResourceCalculatorPlugin extends Configured {
 
   /**

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,22 @@
+/*
+ * 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.Private
+@InterfaceStability.Unstable
+package org.apache.hadoop.mapreduce.util;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/LinuxMemoryCalculatorPlugin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/LinuxMemoryCalculatorPlugin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/LinuxMemoryCalculatorPlugin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/LinuxMemoryCalculatorPlugin.java Thu May 20 05:03:20 2010
@@ -18,6 +18,9 @@
 
 package org.apache.hadoop.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Plugin to calculate virtual and physical memories on Linux systems.
  * 
@@ -26,6 +29,8 @@ package org.apache.hadoop.util;
  *             instead
  */
 @Deprecated
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class LinuxMemoryCalculatorPlugin extends
     org.apache.hadoop.mapreduce.util.LinuxMemoryCalculatorPlugin {
   // Inherits everything from the super class

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/MemoryCalculatorPlugin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/MemoryCalculatorPlugin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/MemoryCalculatorPlugin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/MemoryCalculatorPlugin.java Thu May 20 05:03:20 2010
@@ -18,6 +18,8 @@
 
 package org.apache.hadoop.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 
 /**
@@ -29,6 +31,8 @@ import org.apache.hadoop.conf.Configurat
  * 
  */
 @Deprecated
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public abstract class MemoryCalculatorPlugin extends
     org.apache.hadoop.mapreduce.util.MemoryCalculatorPlugin {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcessTree.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcessTree.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcessTree.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcessTree.java Thu May 20 05:03:20 2010
@@ -18,12 +18,17 @@
 
 package org.apache.hadoop.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Process tree related operations
  * 
  * @deprecated Use {@link org.apache.hadoop.mapreduce.util.ProcessTree} instead
  */
 @Deprecated
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ProcessTree extends org.apache.hadoop.mapreduce.util.ProcessTree {
   // Inherits everything from the super class
 }

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcfsBasedProcessTree.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcfsBasedProcessTree.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcfsBasedProcessTree.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcfsBasedProcessTree.java Thu May 20 05:03:20 2010
@@ -18,6 +18,9 @@
 
 package org.apache.hadoop.util;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * A Proc file-system based ProcessTree. Works only on Linux.
  * 
@@ -26,6 +29,8 @@ package org.apache.hadoop.util;
  *             instead
  */
 @Deprecated
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ProcfsBasedProcessTree extends
     org.apache.hadoop.mapreduce.util.ProcfsBasedProcessTree {
 

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/package-info.java Thu May 20 05:03:20 2010
@@ -0,0 +1,24 @@
+/*
+ * 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.
+ */
+/** 
+ * <b>Deprecated.</b> Use {@link org.apache.hadoop.mapreduce.util} instead.
+ */
+@Deprecated
+@InterfaceAudience.Private
+package org.apache.hadoop.util;
+import org.apache.hadoop.classification.InterfaceAudience;
\ No newline at end of file



Mime
View raw message