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 [4/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/Reducer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Reducer.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Reducer.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Reducer.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/StatusReporter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/StatusReporter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/StatusReporter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/StatusReporter.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskCounter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCounter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCounter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCounter.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskID.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskID.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskID.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskReport.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskReport.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskReport.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskReport.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/TaskType.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskType.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskType.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskType.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java Thu May 20 05:03:20 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 

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

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java Thu May 20 05:03:20 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();
 

Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/package-info.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/package-info.java?rev=946526&view=auto
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/package-info.java (added)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/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.jobhistory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java Thu May 20 05:03:20 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;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java Thu May 20 05:03:20 2010
@@ -22,6 +22,8 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.hadoop.io.DefaultStringifier;
 import org.apache.hadoop.io.Stringifier;
@@ -43,6 +45,8 @@ import org.apache.hadoop.util.Reflection
  * The Chain class provides all the common functionality for the
  * {@link ChainMapper} and the {@link ChainReducer} classes.
  */
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
 public class Chain {
   protected static final String CHAIN_MAPPER = "mapreduce.chain.mapper";
   protected static final String CHAIN_REDUCER = "mapreduce.chain.reducer";

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainMapper.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainMapper.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainMapper.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainMapper.java Thu May 20 05:03:20 2010
@@ -19,6 +19,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.conf.Configuration;
 import org.apache.hadoop.mapreduce.Job;
 import org.apache.hadoop.mapreduce.Mapper;
@@ -77,6 +79,8 @@ import org.apache.hadoop.mapreduce.lib.c
  * ...
  * </pre>
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ChainMapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT> extends
     Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainReducer.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainReducer.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainReducer.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainReducer.java Thu May 20 05:03:20 2010
@@ -17,6 +17,8 @@
  */
 package org.apache.hadoop.mapreduce.lib.chain;
 
+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.Mapper;
@@ -81,6 +83,8 @@ import java.io.IOException;
  * ...
  * </pre>
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class ChainReducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT> extends
     Reducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BigDecimalSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BigDecimalSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BigDecimalSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BigDecimalSplitter.java Thu May 20 05:03:20 2010
@@ -27,6 +27,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.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.MRJobConfig;
@@ -34,6 +36,8 @@ import org.apache.hadoop.mapreduce.MRJob
 /**
  * Implement DBSplitter over BigDecimal values.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class BigDecimalSplitter implements DBSplitter {
   private static final Log LOG = LogFactory.getLog(BigDecimalSplitter.class);
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BooleanSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BooleanSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BooleanSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BooleanSplitter.java Thu May 20 05:03:20 2010
@@ -23,12 +23,16 @@ import java.sql.SQLException;
 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.mapreduce.InputSplit;
 
 /**
  * Implement DBSplitter over boolean values.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class BooleanSplitter implements DBSplitter {
   public List<InputSplit> split(Configuration conf, ResultSet results, String colName)
       throws SQLException {

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBConfiguration.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBConfiguration.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBConfiguration.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBConfiguration.java Thu May 20 05:03:20 2010
@@ -22,6 +22,8 @@ import java.sql.Connection;
 import java.sql.DriverManager;
 import java.sql.SQLException;
 
+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.lib.db.DBInputFormat.NullDBWritable;
@@ -39,6 +41,8 @@ import org.apache.hadoop.mapreduce.lib.d
  * @see DBInputFormat#setInput(Job, Class, String, String, String, String...)
  * @see DBOutputFormat#setOutput(Job, String, String...)
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class DBConfiguration {
 
   /** The JDBC Driver class name */

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBInputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBInputFormat.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBInputFormat.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBInputFormat.java Thu May 20 05:03:20 2010
@@ -40,6 +40,8 @@ import org.apache.hadoop.mapreduce.MRJob
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 /**
@@ -51,6 +53,8 @@ import org.apache.hadoop.conf.Configurat
  * The SQL query, and input class can be using one of the two 
  * setInput methods.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class DBInputFormat<T extends DBWritable>
     extends InputFormat<LongWritable, T> implements Configurable {
 
@@ -59,6 +63,7 @@ public class DBInputFormat<T extends DBW
   /**
    * A Class that does nothing, implementing DBWritable
    */
+  @InterfaceStability.Evolving
   public static class NullDBWritable implements DBWritable, Writable {
     @Override
     public void readFields(DataInput in) throws IOException { }
@@ -73,6 +78,7 @@ public class DBInputFormat<T extends DBW
   /**
    * A InputSplit that spans a set of rows
    */
+  @InterfaceStability.Evolving
   public static class DBInputSplit extends InputSplit implements Writable {
 
     private long end = 0;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBOutputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBOutputFormat.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBOutputFormat.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBOutputFormat.java Thu May 20 05:03:20 2010
@@ -25,6 +25,8 @@ import java.sql.SQLException;
 
 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.mapreduce.Job;
 import org.apache.hadoop.mapreduce.JobContext;
 import org.apache.hadoop.mapreduce.OutputCommitter;
@@ -43,6 +45,8 @@ import org.apache.hadoop.util.StringUtil
  * writes <b>only the key</b> to the database with a batch SQL query.  
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class DBOutputFormat<K  extends DBWritable, V> 
 extends OutputFormat<K,V> {
 
@@ -59,6 +63,7 @@ extends OutputFormat<K,V> {
   /**
    * A RecordWriter that writes the reduce output to a SQL table
    */
+  @InterfaceStability.Evolving
   public class DBRecordWriter 
       extends RecordWriter<K, V> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBRecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBRecordReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBRecordReader.java Thu May 20 05:03:20 2010
@@ -41,6 +41,8 @@ import org.apache.hadoop.mapreduce.JobCo
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 
@@ -49,6 +51,8 @@ import org.apache.hadoop.conf.Configurat
  * Emits LongWritables containing the record number as 
  * key and DBWritables as value.  
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class DBRecordReader<T extends DBWritable> extends
     RecordReader<LongWritable, T> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBSplitter.java Thu May 20 05:03:20 2010
@@ -22,6 +22,8 @@ import java.sql.ResultSet;
 import java.sql.SQLException;
 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.mapreduce.InputSplit;
 
@@ -33,6 +35,8 @@ import org.apache.hadoop.mapreduce.Input
  * DBSplitter implementations should perform this for a data type or family
  * of data types.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public interface DBSplitter {
   /**
    * Given a ResultSet containing one record (and already advanced to that record)

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBWritable.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBWritable.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBWritable.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBWritable.java Thu May 20 05:03:20 2010
@@ -21,6 +21,8 @@ import java.sql.PreparedStatement;
 import java.sql.ResultSet;
 import java.sql.SQLException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Writable;
 
 /**
@@ -73,6 +75,8 @@ import org.apache.hadoop.io.Writable;
  * }
  * </pre></p>
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public interface DBWritable {
 
   /**

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBInputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBInputFormat.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBInputFormat.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBInputFormat.java Thu May 20 05:03:20 2010
@@ -45,6 +45,8 @@ import org.apache.hadoop.mapreduce.MRJob
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 
@@ -54,6 +56,8 @@ import org.apache.hadoop.conf.Configurat
  * splits, it tries to generate WHERE clauses which separate the data into roughly
  * equivalent shards.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class DataDrivenDBInputFormat<T extends DBWritable>
     extends DBInputFormat<T> implements Configurable {
 
@@ -67,6 +71,7 @@ public class DataDrivenDBInputFormat<T e
   /**
    * A InputSplit that spans a set of rows
    */
+  @InterfaceStability.Evolving
   public static class DataDrivenDBInputSplit extends DBInputFormat.DBInputSplit {
 
     private String lowerBoundClause;

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBRecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBRecordReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBRecordReader.java Thu May 20 05:03:20 2010
@@ -41,6 +41,8 @@ import org.apache.hadoop.mapreduce.JobCo
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 
@@ -50,6 +52,8 @@ import org.apache.hadoop.conf.Configurat
  * Emits LongWritables containing the record number as
  * key and DBWritables as value.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class DataDrivenDBRecordReader<T extends DBWritable> extends DBRecordReader<T> {
 
   private static final Log LOG = LogFactory.getLog(DataDrivenDBRecordReader.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DateSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DateSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DateSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DateSplitter.java Thu May 20 05:03:20 2010
@@ -30,6 +30,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.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.MRJobConfig;
@@ -39,6 +41,8 @@ import org.apache.hadoop.mapreduce.MRJob
  * Make use of logic from IntegerSplitter, since date/time are just longs
  * in Java.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class DateSplitter extends IntegerSplitter {
 
   private static final Log LOG = LogFactory.getLog(DateSplitter.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/FloatSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/FloatSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/FloatSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/FloatSplitter.java Thu May 20 05:03:20 2010
@@ -26,6 +26,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.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.MRJobConfig;
@@ -33,6 +35,8 @@ import org.apache.hadoop.mapreduce.MRJob
 /**
  * Implement DBSplitter over floating-point values.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class FloatSplitter implements DBSplitter {
 
   private static final Log LOG = LogFactory.getLog(FloatSplitter.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/IntegerSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/IntegerSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/IntegerSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/IntegerSplitter.java Thu May 20 05:03:20 2010
@@ -23,6 +23,8 @@ import java.sql.SQLException;
 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.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.MRJobConfig;
@@ -30,6 +32,8 @@ import org.apache.hadoop.mapreduce.MRJob
 /**
  * Implement DBSplitter over integer values.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class IntegerSplitter implements DBSplitter {
   public List<InputSplit> split(Configuration conf, ResultSet results, String colName)
       throws SQLException {

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDBRecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDBRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDBRecordReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDBRecordReader.java Thu May 20 05:03:20 2010
@@ -23,11 +23,15 @@ import java.sql.ResultSet;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 
 /**
  * A RecordReader that reads records from a MySQL table.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class MySQLDBRecordReader<T extends DBWritable> extends DBRecordReader<T> {
 
   public MySQLDBRecordReader(DBInputFormat.DBInputSplit split, 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDataDrivenDBRecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDataDrivenDBRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDataDrivenDBRecordReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDataDrivenDBRecordReader.java Thu May 20 05:03:20 2010
@@ -23,11 +23,15 @@ import java.sql.ResultSet;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 
 /**
  * A RecordReader that reads records from a MySQL table via DataDrivenDBRecordReader
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class MySQLDataDrivenDBRecordReader<T extends DBWritable>
     extends DataDrivenDBRecordReader<T> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDBRecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDBRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDBRecordReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDBRecordReader.java Thu May 20 05:03:20 2010
@@ -23,6 +23,8 @@ import java.sql.Connection;
 import java.sql.SQLException;
 import java.lang.reflect.Method;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -30,6 +32,8 @@ import org.apache.commons.logging.LogFac
 /**
  * A RecordReader that reads records from an Oracle SQL table.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class OracleDBRecordReader<T extends DBWritable> extends DBRecordReader<T> {
 
   /** Configuration key to set to a timezone string. */

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBInputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBInputFormat.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBInputFormat.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBInputFormat.java Thu May 20 05:03:20 2010
@@ -44,12 +44,16 @@ import org.apache.hadoop.mapreduce.JobCo
 import org.apache.hadoop.mapreduce.RecordReader;
 import org.apache.hadoop.mapreduce.TaskAttemptContext;
 import org.apache.hadoop.util.ReflectionUtils;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configurable;
 import org.apache.hadoop.conf.Configuration;
 
 /**
  * A InputFormat that reads input data from an SQL table in an Oracle db.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class OracleDataDrivenDBInputFormat<T extends DBWritable>
     extends DataDrivenDBInputFormat<T> implements Configurable {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBRecordReader.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBRecordReader.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBRecordReader.java Thu May 20 05:03:20 2010
@@ -23,11 +23,15 @@ import java.sql.ResultSet;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.conf.Configuration;
 
 /**
  * A RecordReader that reads records from a Oracle table via DataDrivenDBRecordReader
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class OracleDataDrivenDBRecordReader<T extends DBWritable>
     extends DataDrivenDBRecordReader<T> {
 

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDateSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDateSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDateSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDateSplitter.java Thu May 20 05:03:20 2010
@@ -20,12 +20,17 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.Date;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
 /**
  * Implement DBSplitter over date/time values returned by an Oracle db.
  * Make use of logic from DateSplitter, since this just needs to use
  * some Oracle-specific functions on the formatting end when generating
  * InputSplits.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class OracleDateSplitter extends DateSplitter {
 
   @SuppressWarnings("unchecked")

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/TextSplitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/TextSplitter.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/TextSplitter.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/TextSplitter.java Thu May 20 05:03:20 2010
@@ -28,6 +28,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.mapreduce.InputSplit;
 import org.apache.hadoop.mapreduce.MRJobConfig;
@@ -35,6 +37,8 @@ import org.apache.hadoop.mapreduce.MRJob
 /**
  * Implement DBSplitter over text strings.
  */
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
 public class TextSplitter extends BigDecimalSplitter {
 
   private static final Log LOG = LogFactory.getLog(TextSplitter.class);

Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionHelper.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionHelper.java?rev=946526&r1=946525&r2=946526&view=diff
==============================================================================
--- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionHelper.java (original)
+++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionHelper.java Thu May 20 05:03:20 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapreduce.lib.
 
 import java.util.List;
 
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
 import org.apache.hadoop.io.Text;
 
 /**
@@ -53,6 +55,8 @@ import org.apache.hadoop.io.Text;
  * the key is never ignored.
  * 
  */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
 public class FieldSelectionHelper {
 
   public static Text emptyText = new Text("");



Mime
View raw message