hadoop-mapreduce-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From acmur...@apache.org
Subject svn commit: r946533 [4/7] - in /hadoop/mapreduce/branches/branch-0.21: ./ conf/ src/c++/ src/contrib/ src/contrib/block_forensics/ src/contrib/capacity-scheduler/ src/contrib/data_join/ src/contrib/dynamic-scheduler/ src/contrib/eclipse-plugin/ src/con...
Date Thu, 20 May 2010 05:44:28 GMT
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Cluster.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Cluster.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Cluster.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Cluster.java Thu May 20 05:44:18 2010
@@ -24,6 +24,8 @@ import java.security.PrivilegedException
 import java.util.ArrayList;
 import java.util.List;
 
+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.fs.Path;
@@ -47,6 +49,8 @@ import org.apache.hadoop.security.token.
 /**
  * Provides a way to access information about the map/reduce cluster.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class Cluster {
   private ClientProtocol client;
   private UserGroupInformation ugi;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ClusterMetrics.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ClusterMetrics.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ClusterMetrics.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ClusterMetrics.java Thu May 20 05:44:18 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.Writable;
 
 /**
@@ -53,6 +55,8 @@ import org.apache.hadoop.io.Writable;
  * 
  * @see Cluster
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class ClusterMetrics implements Writable {
   private int runningMaps;
   private int runningReduces;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counter.java Thu May 20 05:44:18 2010
@@ -22,6 +22,8 @@ import java.io.IOException;
 import java.io.DataInput;
 import java.io.DataOutput;
 
+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;
@@ -36,6 +38,8 @@ import org.apache.hadoop.io.WritableUtil
  * <p><code>Counters</code> are bunched into Groups, each comprising of
  * counters from a particular <code>Enum</code> class. 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class Counter implements Writable {
 
   private String name;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/CounterGroup.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/CounterGroup.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/CounterGroup.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/CounterGroup.java Thu May 20 05:44:18 2010
@@ -26,6 +26,8 @@ import java.util.MissingResourceExceptio
 import java.util.ResourceBundle;
 import java.util.TreeMap;
 
+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;
@@ -34,6 +36,8 @@ import org.apache.hadoop.io.WritableUtil
  * A group of {@link Counter}s that logically belong together. Typically,
  * it is an {@link Enum} subclass and the counters are the values.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class CounterGroup implements Writable, Iterable<Counter> {
   private String name;
   private String displayName;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counters.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counters.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counters.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counters.java Thu May 20 05:44:18 2010
@@ -26,9 +26,13 @@ import java.util.Iterator;
 import java.util.Map;
 import java.util.TreeMap;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.io.Writable;
 
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class Counters implements Writable,Iterable<CounterGroup> {
   /**
    * A cache from enum values to the associated counter. Dramatically speeds up

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ID.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ID.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ID.java Thu May 20 05:44:18 2010
@@ -22,6 +22,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.WritableComparable;
 
 /**
@@ -33,6 +35,8 @@ import org.apache.hadoop.io.WritableComp
  * @see TaskID
  * @see TaskAttemptID
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class ID implements WritableComparable<ID> {
   protected static final char SEPARATOR = '_';
   protected int id;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputFormat.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputFormat.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputFormat.java Thu May 20 05:44:18 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapreduce;
 import java.io.IOException;
 import java.util.List;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.mapreduce.lib.input.FileInputFormat;
 
@@ -63,6 +65,8 @@ import org.apache.hadoop.mapreduce.lib.i
  * @see RecordReader
  * @see FileInputFormat
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class InputFormat<K, V> {
 
   /** 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputSplit.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputSplit.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputSplit.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputSplit.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce;
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.InputFormat;
 import org.apache.hadoop.mapreduce.Mapper;
 import org.apache.hadoop.mapreduce.RecordReader;
@@ -35,6 +37,8 @@ import org.apache.hadoop.mapreduce.Recor
  * @see InputFormat
  * @see RecordReader
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class InputSplit {
   /**
    * Get the size of the split, so that the input splits can be sorted by size.

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Job.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Job.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Job.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Job.java Thu May 20 05:44:18 2010
@@ -34,6 +34,8 @@ import javax.security.auth.login.LoginEx
 
 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.Configuration.IntegerRanges;
 import org.apache.hadoop.fs.Path;
@@ -79,9 +81,12 @@ import org.apache.hadoop.util.StringUtil
  * 
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class Job extends JobContextImpl implements JobContext {  
   private static final Log LOG = LogFactory.getLog(Job.class);
 
+  @InterfaceStability.Evolving
   public static enum JobState {DEFINE, RUNNING};
   private static final long MAX_JOBSTATUS_AGE = 1000 * 2;
   public static final String OUTPUT_FILTER = "mapreduce.client.output.filter";
@@ -102,6 +107,7 @@ public class Job extends JobContextImpl 
   public static final String SUBMIT_REPLICATION = 
     "mapreduce.client.submit.file.replication";
 
+  @InterfaceStability.Evolving
   public static enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL }
 
   static {

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobCounter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobCounter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobCounter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobCounter.java Thu May 20 05:44:18 2010
@@ -18,7 +18,12 @@
 
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 // Per-job counters
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public enum JobCounter {
   NUM_FAILED_MAPS, 
   NUM_FAILED_REDUCES,

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobID.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobID.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobID.java Thu May 20 05:44:18 2010
@@ -23,6 +23,8 @@ import java.io.DataOutput;
 import java.io.IOException;
 import java.text.NumberFormat;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 
 /**
@@ -44,6 +46,8 @@ import org.apache.hadoop.io.Text;
  * @see org.apache.hadoop.mapred.JobTracker#getNewJobId()
  * @see org.apache.hadoop.mapred.JobTracker#getStartTime()
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class JobID extends org.apache.hadoop.mapred.ID 
                    implements Comparable<ID> {
   protected static final String JOB = "job";

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobPriority.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobPriority.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobPriority.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobPriority.java Thu May 20 05:44:18 2010
@@ -17,10 +17,15 @@
  */
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Used to describe the priority of the running job. 
  *
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public enum JobPriority {
   VERY_HIGH,
   HIGH,

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobStatus.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobStatus.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobStatus.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobStatus.java Thu May 20 05:44:18 2010
@@ -24,6 +24,8 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.Map.Entry;
 
+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.WritableFactories;
@@ -34,6 +36,8 @@ import org.apache.hadoop.security.author
 /**************************************************
  * Describes the current status of a job.
  **************************************************/
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class JobStatus implements Writable, Cloneable {
 
   static {                                      // register a ctor

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java Thu May 20 05:44:18 2010
@@ -30,6 +30,8 @@ import java.util.Map;
 
 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.FSDataOutputStream;
 import org.apache.hadoop.fs.FileSystem;
@@ -48,6 +50,8 @@ import org.codehaus.jackson.JsonParseExc
 import org.codehaus.jackson.map.JsonMappingException;
 import org.codehaus.jackson.map.ObjectMapper;
 
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 class JobSubmitter {
   protected static final Log LOG = LogFactory.getLog(JobSubmitter.class);
   private FileSystem jtFs;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MRConfig.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MRConfig.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MRConfig.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MRConfig.java Thu May 20 05:44:18 2010
@@ -17,6 +17,7 @@
  */
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
 import org.apache.hadoop.mapred.JobTracker;
 import org.apache.hadoop.mapred.TaskTracker;
 
@@ -27,6 +28,7 @@ import org.apache.hadoop.mapred.TaskTrac
  * keys should have "mapreduce.cluster." as the prefix. 
  *
  */
+@InterfaceAudience.Private
 public interface MRConfig {
 
   // Cluster-level configuration parameters

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Mapper.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Mapper.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Mapper.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Mapper.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce;
 
 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.io.RawComparator;
 import org.apache.hadoop.io.compress.CompressionCodec;
@@ -93,6 +95,8 @@ import org.apache.hadoop.mapreduce.task.
  * @see Partitioner  
  * @see Reducer
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {
 
   /**

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIterator.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIterator.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIterator.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIterator.java Thu May 20 05:44:18 2010
@@ -21,11 +21,16 @@ package org.apache.hadoop.mapreduce;
 import java.io.IOException;
 import java.util.Iterator;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * <code>MarkableIterator</code> is a wrapper iterator class that 
  * implements the {@link MarkableIteratorInterface}.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class MarkableIterator<VALUE> 
   implements MarkableIteratorInterface<VALUE> {
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIteratorInterface.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIteratorInterface.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIteratorInterface.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIteratorInterface.java Thu May 20 05:44:18 2010
@@ -21,6 +21,9 @@ package org.apache.hadoop.mapreduce;
 import java.io.IOException;
 import java.util.Iterator;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * <code>MarkableIteratorInterface</code> is an interface for a iterator that 
  * supports mark-reset functionality. 
@@ -29,6 +32,8 @@ import java.util.Iterator;
  * will go back to the last record before the call to the previous mark.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 interface MarkableIteratorInterface<VALUE> extends Iterator<VALUE> {
   /**
    * Mark the current record. A subsequent call to reset will rewind

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputCommitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputCommitter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputCommitter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputCommitter.java Thu May 20 05:44:18 2010
@@ -19,6 +19,9 @@
 package org.apache.hadoop.mapreduce;
 
 import java.io.IOException;
+
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 /**
  * <code>OutputCommitter</code> describes the commit of task output for a 
  * Map-Reduce job.
@@ -54,6 +57,8 @@ import java.io.IOException;
  * @see TaskAttemptContext 
  *
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class OutputCommitter {
   /**
    * For the framework to setup the job output during initialization

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputFormat.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputFormat.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce;
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 
 /** 
@@ -41,6 +43,8 @@ import org.apache.hadoop.fs.FileSystem;
  * 
  * @see RecordWriter
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class OutputFormat<K, V> {
 
   /** 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Partitioner.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Partitioner.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Partitioner.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Partitioner.java Thu May 20 05:44:18 2010
@@ -18,6 +18,9 @@
 
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /** 
  * Partitions the key space.
  * 
@@ -30,6 +33,8 @@ package org.apache.hadoop.mapreduce;
  * 
  * @see Reducer
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class Partitioner<KEY, VALUE> {
   
   /** 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueAclsInfo.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueAclsInfo.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueAclsInfo.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueAclsInfo.java Thu May 20 05:44:18 2010
@@ -20,6 +20,9 @@ package org.apache.hadoop.mapreduce;
 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;
@@ -29,6 +32,8 @@ import org.apache.hadoop.io.WritableUtil
  *  user.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class QueueAclsInfo implements Writable {
 
   private String queueName;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueInfo.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueInfo.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueInfo.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueInfo.java Thu May 20 05:44:18 2010
@@ -24,6 +24,8 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Properties;
 
+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;
@@ -33,6 +35,8 @@ import org.apache.hadoop.io.WritableUtil
  * maintained by the Hadoop Map/Reduce framework.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class QueueInfo implements Writable {
 
   private String queueName = "";

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueState.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueState.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueState.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueState.java Thu May 20 05:44:18 2010
@@ -20,9 +20,14 @@ package org.apache.hadoop.mapreduce;
 import java.util.HashMap;
 import java.util.Map;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Enum representing queue state
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public enum QueueState {
 
   STOPPED("stopped"), RUNNING("running"), UNDEFINED("undefined");

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordReader.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordReader.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordReader.java Thu May 20 05:44:18 2010
@@ -21,12 +21,17 @@ package org.apache.hadoop.mapreduce;
 import java.io.Closeable;
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * The record reader breaks the data into key/value pairs for input to the
  * {@link Mapper}.
  * @param <KEYIN>
  * @param <VALUEIN>
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class RecordReader<KEYIN, VALUEIN> implements Closeable {
 
   /**

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordWriter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordWriter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordWriter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordWriter.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce;
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 
 /**
@@ -31,6 +33,8 @@ import org.apache.hadoop.fs.FileSystem;
  * 
  * @see OutputFormat
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public abstract class RecordWriter<K, V> {
   /** 
    * Writes a key/value pair.

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Reducer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Reducer.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Reducer.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Reducer.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce;
 
 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.io.RawComparator;
 import org.apache.hadoop.mapred.RawKeyValueIterator;
@@ -115,6 +117,8 @@ import org.apache.hadoop.mapred.RawKeyVa
  * @see Mapper
  * @see Partitioner
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class Reducer<KEYIN,VALUEIN,KEYOUT,VALUEOUT> {
 
   /**

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/StatusReporter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/StatusReporter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/StatusReporter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/StatusReporter.java Thu May 20 05:44:18 2010
@@ -17,6 +17,9 @@
  */
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+
+@InterfaceAudience.Private
 public abstract class StatusReporter {
   public abstract Counter getCounter(Enum<?> name);
   public abstract Counter getCounter(String group, String name);

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java Thu May 20 05:44:18 2010
@@ -22,6 +22,9 @@ import java.io.DataInput;
 import java.io.DataOutput;
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * TaskAttemptID represents the immutable and unique identifier for 
  * a task attempt. Each task attempt is one particular instance of a Map or
@@ -42,6 +45,8 @@ import java.io.IOException;
  * @see JobID
  * @see TaskID
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class TaskAttemptID extends org.apache.hadoop.mapred.ID {
   protected static final String ATTEMPT = "attempt";
   private TaskID taskId;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java Thu May 20 05:44:18 2010
@@ -22,6 +22,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.Writable;
 import org.apache.hadoop.io.WritableUtils;
 
@@ -29,7 +31,11 @@ import org.apache.hadoop.io.WritableUtil
  * This is used to track task completion events on 
  * job tracker. 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class TaskCompletionEvent implements Writable{
+  @InterfaceAudience.Public
+  @InterfaceStability.Evolving
   static public enum Status {FAILED, KILLED, SUCCEEDED, OBSOLETE, TIPFAILED};
     
   private int eventId; 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCounter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCounter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCounter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCounter.java Thu May 20 05:44:18 2010
@@ -18,7 +18,12 @@
 
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 // Counters used by Task classes
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public enum TaskCounter {
   MAP_INPUT_RECORDS, 
   MAP_OUTPUT_RECORDS,

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskID.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskID.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskID.java Thu May 20 05:44:18 2010
@@ -26,6 +26,8 @@ import java.util.EnumMap;
 import java.util.HashMap;
 import java.util.Map;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.WritableUtils;
 
 
@@ -51,6 +53,8 @@ import org.apache.hadoop.io.WritableUtil
  * @see JobID
  * @see TaskAttemptID
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class TaskID extends org.apache.hadoop.mapred.ID {
   protected static final String TASK = "task";
   protected static final NumberFormat idFormat = NumberFormat.getInstance();

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskReport.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskReport.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskReport.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskReport.java Thu May 20 05:44:18 2010
@@ -24,12 +24,16 @@ import java.util.ArrayList;
 import java.util.Arrays;
 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.io.Writable;
 import org.apache.hadoop.io.WritableUtils;
 import org.apache.hadoop.mapred.TIPStatus;
 
 /** A report on the state of a task. */
+@InterfaceAudience.Private
+@InterfaceStability.Evolving
 public class TaskReport implements Writable {
   private TaskID taskid;
   private float progress;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java Thu May 20 05:44:18 2010
@@ -21,12 +21,16 @@ 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;
 
 /**
  * Information about TaskTracker.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class TaskTrackerInfo implements Writable {
   String name;
   boolean isBlacklisted = false;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskType.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskType.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskType.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskType.java Thu May 20 05:44:18 2010
@@ -18,9 +18,14 @@
 
 package org.apache.hadoop.mapreduce;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Enum for map, reduce, job-setup, job-cleanup, task-cleanup task types.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public enum TaskType {
   MAP, REDUCE, JOB_SETUP, JOB_CLEANUP, TASK_CLEANUP
 }

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.file
 
 import java.io.*;
 import java.util.*;
+
+import org.apache.hadoop.classification.InterfaceAudience;
 import org.apache.hadoop.conf.*;
 import org.apache.hadoop.util.*;
 import org.apache.hadoop.fs.*;
@@ -130,6 +132,7 @@ import java.net.URI;
  * @see org.apache.hadoop.mapred.JobClient
  */
 @Deprecated
+@InterfaceAudience.Private
 public class DistributedCache {
   /**
    * Get the locally cached file or archive; it could either be 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java Thu May 20 05:44:18 2010
@@ -24,6 +24,8 @@ import java.io.IOException;
 import java.io.EOFException;
 import java.io.StringBufferInputStream;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.mapreduce.Counter;
@@ -37,6 +39,8 @@ import org.apache.avro.io.JsonDecoder;
 import org.apache.avro.io.DatumReader;
 import org.apache.avro.specific.SpecificDatumReader;
 
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class EventReader implements Closeable {
   private String version;
   private Schema schema;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java Thu May 20 05:44:18 2010
@@ -20,10 +20,15 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Interface for event wrapper classes.  Implementations each wrap an
  * Avro-generated class, adding constructors and accessor methods.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public interface HistoryEvent {
 
   /** Return this event's type. */

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java Thu May 20 05:44:18 2010
@@ -29,6 +29,8 @@ import java.util.Map;
 import java.util.Set;
 import java.util.TreeSet;
 
+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.fs.Path;
@@ -49,6 +51,8 @@ import org.apache.hadoop.util.StringUtil
  * HistoryViewer is used to parse and view the JobHistory files 
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class HistoryViewer {
   private static SimpleDateFormat dateFormat = 
     new SimpleDateFormat("d-MMM-yyyy HH:mm:ss");

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.Counters;
 import org.apache.hadoop.mapreduce.JobID;
 
@@ -29,6 +31,8 @@ import org.apache.avro.util.Utf8;
  * Event to record successful completion of job
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobFinishedEvent  implements HistoryEvent {
   private JobFinished datum = new JobFinished();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java Thu May 20 05:44:18 2010
@@ -35,6 +35,8 @@ import java.util.concurrent.TimeUnit;
 
 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.ChecksumException;
 import org.apache.hadoop.fs.CreateFlag;
 import org.apache.hadoop.fs.FSDataOutputStream;
@@ -54,6 +56,8 @@ import org.apache.hadoop.util.StringUtil
  * job history information.
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobHistory {
 
   final Log LOG = LogFactory.getLog(JobHistory.class);

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java Thu May 20 05:44:18 2010
@@ -22,6 +22,8 @@ import java.io.IOException;
 import java.util.HashMap;
 import java.util.Map;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.fs.FSDataInputStream;
 import org.apache.hadoop.fs.FileSystem;
 import org.apache.hadoop.fs.Path;
@@ -42,6 +44,8 @@ import org.apache.hadoop.security.author
  * job = parser.parse();
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobHistoryParser {
 
   private final FSDataInputStream in;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.JobID;
 
 import org.apache.avro.util.Utf8;
@@ -28,6 +30,8 @@ import org.apache.avro.util.Utf8;
  * Event to record changes in the submit and launch time of
  * a job
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobInfoChangeEvent implements HistoryEvent {
   private JobInfoChange datum = new JobInfoChange();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.JobID;
 
 import org.apache.avro.util.Utf8;
@@ -28,6 +30,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the initialization of a job
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobInitedEvent implements HistoryEvent {
   private JobInited datum = new JobInited();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapred.JobPriority;
 import org.apache.hadoop.mapreduce.JobID;
 
@@ -29,6 +31,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the change of priority of a job
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobPriorityChangeEvent implements HistoryEvent {
   private JobPriorityChange datum = new JobPriorityChange();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.JobID;
 
 import org.apache.avro.util.Utf8;
@@ -28,6 +30,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the change of status for a job
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobStatusChangedEvent implements HistoryEvent {
   private JobStatusChanged datum = new JobStatusChanged();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java Thu May 20 05:44:18 2010
@@ -22,6 +22,8 @@ import java.util.HashMap;
 import java.util.Map;
 import java.util.Map.Entry;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.JobACL;
 import org.apache.hadoop.mapreduce.JobID;
 import org.apache.hadoop.security.authorize.AccessControlList;
@@ -32,6 +34,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the submission of a job
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobSubmittedEvent implements HistoryEvent {
   private JobSubmitted datum = new JobSubmitted();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.JobID;
 
 import org.apache.avro.util.Utf8;
@@ -28,6 +30,8 @@ import org.apache.avro.util.Utf8;
  * Event to record Failed and Killed completion of jobs
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class JobUnsuccessfulCompletionEvent implements HistoryEvent {
   private JobUnsuccessfulCompletion datum
     = new JobUnsuccessfulCompletion();

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.Counters;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.mapreduce.TaskID;
@@ -31,6 +33,8 @@ import org.apache.avro.util.Utf8;
  * Event to record successful completion of a map attempt
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class MapAttemptFinishedEvent  implements HistoryEvent {
   private MapAttemptFinished datum = new MapAttemptFinished();
   

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.Counters;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.mapreduce.TaskID;
@@ -31,6 +33,8 @@ import org.apache.avro.util.Utf8;
  * Event to record successful completion of a reduce attempt
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class ReduceAttemptFinishedEvent  implements HistoryEvent {
   private ReduceAttemptFinished datum =
     new ReduceAttemptFinished();

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.Counters;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.mapreduce.TaskID;
@@ -31,6 +33,8 @@ import org.apache.avro.util.Utf8;
  * Event to record successful task completion
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskAttemptFinishedEvent  implements HistoryEvent {
   private TaskAttemptFinished datum = new TaskAttemptFinished();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.mapreduce.TaskID;
 import org.apache.hadoop.mapreduce.TaskType;
@@ -30,6 +32,8 @@ import org.apache.avro.util.Utf8;
  * Event to record start of a task attempt
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskAttemptStartedEvent implements HistoryEvent {
   private TaskAttemptStarted datum = new TaskAttemptStarted();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.mapreduce.TaskID;
 import org.apache.hadoop.mapreduce.TaskType;
@@ -30,6 +32,8 @@ import org.apache.avro.util.Utf8;
  * Event to record unsuccessful (Killed/Failed) completion of task attempts
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskAttemptUnsuccessfulCompletionEvent implements HistoryEvent {
   private TaskAttemptUnsuccessfulCompletion datum =
     new TaskAttemptUnsuccessfulCompletion();

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.TaskAttemptID;
 import org.apache.hadoop.mapreduce.TaskID;
 import org.apache.hadoop.mapreduce.TaskType;
@@ -30,6 +32,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the failure of a task
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskFailedEvent implements HistoryEvent {
   private TaskFailed datum = new TaskFailed();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.Counters;
 import org.apache.hadoop.mapreduce.TaskID;
 import org.apache.hadoop.mapreduce.TaskType;
@@ -30,6 +32,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the successful completion of a task
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskFinishedEvent implements HistoryEvent {
   private TaskFinished datum = new TaskFinished();
   

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.TaskID;
 import org.apache.hadoop.mapreduce.TaskType;
 
@@ -29,6 +31,8 @@ import org.apache.avro.util.Utf8;
  * Event to record the start of a task
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskStartedEvent implements HistoryEvent {
   private TaskStarted datum = new TaskStarted();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.jobh
 
 import java.io.IOException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.mapreduce.TaskID;
 
 import org.apache.avro.util.Utf8;
@@ -28,6 +30,8 @@ import org.apache.avro.util.Utf8;
  * Event to record updates to a task
  *
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class TaskUpdatedEvent implements HistoryEvent {
   private TaskUpdated datum = new TaskUpdated();
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java Thu May 20 05:44:18 2010
@@ -20,12 +20,17 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 
 /**
  * This class implements a value aggregator that sums up a sequence of double
  * values.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class DoubleValueSum implements ValueAggregator<String> {
 
   double sum = 0;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java Thu May 20 05:44:18 2010
@@ -20,11 +20,16 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This class implements a value aggregator that maintain the maximum of 
  * a sequence of long values.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class LongValueMax implements ValueAggregator<String> {
 
   long maxVal = Long.MIN_VALUE;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java Thu May 20 05:44:18 2010
@@ -20,11 +20,16 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This class implements a value aggregator that maintain the minimum of 
  * a sequence of long values.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class LongValueMin implements ValueAggregator<String> {
 
   long minVal = Long.MAX_VALUE;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java Thu May 20 05:44:18 2010
@@ -20,11 +20,16 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This class implements a value aggregator that sums up 
  * a sequence of long values.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class LongValueSum implements ValueAggregator<String> {
 
   long sum = 0;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java Thu May 20 05:44:18 2010
@@ -20,11 +20,16 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This class implements a value aggregator that maintain the biggest of 
  * a sequence of strings.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class StringValueMax implements ValueAggregator<String> {
 
   String maxVal = null;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java Thu May 20 05:44:18 2010
@@ -20,11 +20,16 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This class implements a value aggregator that maintain the smallest of 
  * a sequence of strings.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class StringValueMin implements ValueAggregator<String> {
 
   String minVal = null;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java Thu May 20 05:44:18 2010
@@ -23,10 +23,15 @@ import java.util.Iterator;
 import java.util.Set;
 import java.util.TreeMap;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This class implements a value aggregator that dedupes a sequence of objects.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class UniqValueCount implements ValueAggregator<Object> {
   public static final String MAX_NUM_UNIQUE_VALUES = 
     "mapreduce.aggregate.max.num.unique.values";

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java Thu May 20 05:44:18 2010
@@ -22,6 +22,8 @@ import java.lang.reflect.Constructor;
 import java.util.ArrayList;
 import java.util.Map.Entry;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.Text;
 
@@ -34,6 +36,8 @@ import org.apache.hadoop.io.Text;
  * delegate invocations of generateKeyValPairs function to the created object.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class UserDefinedValueAggregatorDescriptor implements
     ValueAggregatorDescriptor {
   private String className;

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java Thu May 20 05:44:18 2010
@@ -20,10 +20,15 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * This interface defines the minimal protocol for value aggregators.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public interface ValueAggregator<E> {
 
   /**

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java Thu May 20 05:44:18 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapreduce.lib.
 import java.util.ArrayList;
 import java.util.Map.Entry;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.Text;
 import org.apache.hadoop.mapreduce.MRJobConfig;
@@ -29,6 +31,8 @@ import org.apache.hadoop.mapreduce.MRJob
  * This class implements the common functionalities of 
  * the subclasses of ValueAggregatorDescriptor class.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueAggregatorBaseDescriptor 
     implements ValueAggregatorDescriptor {
 

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java Thu May 20 05:44:18 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapreduce.lib.
 import java.io.IOException;
 import java.util.Iterator;
 
+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.WritableComparable;
@@ -29,6 +31,8 @@ import org.apache.hadoop.mapreduce.Reduc
 /**
  * This class implements the generic combiner of Aggregate.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueAggregatorCombiner<K1 extends WritableComparable<?>,
                                      V1 extends Writable>
   extends Reducer<Text, Text, Text, Text> {

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java Thu May 20 05:44:18 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapreduce.lib.
 import java.util.ArrayList;
 import java.util.Map.Entry;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.Text;
 
@@ -37,6 +39,8 @@ import org.apache.hadoop.io.Text;
  * id/value pairs.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public interface ValueAggregatorDescriptor {
 
   public static final String TYPE_SEPARATOR = ":";

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java Thu May 20 05:44:18 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapreduce.lib.
 import java.io.IOException;
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.fs.Path;
 import org.apache.hadoop.io.Text;
@@ -78,6 +80,8 @@ import org.apache.hadoop.util.GenericOpt
  * user plugin class
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueAggregatorJob {
 
   public static JobControl createValueAggregatorJobs(String args[],

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.ArrayList;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.Writable;
 import org.apache.hadoop.io.WritableComparable;
@@ -28,6 +30,8 @@ import org.apache.hadoop.io.WritableComp
  * This abstract class implements some common functionalities of the
  * the generic mapper, reducer and combiner classes of Aggregate.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueAggregatorJobBase<K1 extends WritableComparable<?>,
                                              V1 extends Writable>
 {

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java Thu May 20 05:44:18 2010
@@ -22,6 +22,8 @@ import java.io.IOException;
 import java.util.Iterator;
 import java.util.Map.Entry;
 
+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.WritableComparable;
@@ -30,6 +32,8 @@ import org.apache.hadoop.mapreduce.Mappe
 /**
  * This class implements the generic mapper of Aggregate.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueAggregatorMapper<K1 extends WritableComparable<?>,
                                    V1 extends Writable>
   extends Mapper<K1, V1, Text, Text> {

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.lib.
 
 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.WritableComparable;
@@ -28,6 +30,8 @@ import org.apache.hadoop.mapreduce.Reduc
 /**
  * This class implements the generic reducer of Aggregate.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueAggregatorReducer<K1 extends WritableComparable<?>,
                                     V1 extends Writable>
   extends Reducer<Text, Text, Text, Text> {

Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java Thu May 20 05:44:18 2010
@@ -24,12 +24,17 @@ import java.util.TreeMap;
 import java.util.Map.Entry;
 import java.util.Arrays;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 
 /**
  * This class implements a value aggregator that computes the 
  * histogram of a sequence of strings.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ValueHistogram implements ValueAggregator<String> {
 
   TreeMap<Object, Object> items = null;



Mime
View raw message