From mapreduce-commits-return-862-apmail-hadoop-mapreduce-commits-archive=hadoop.apache.org@hadoop.apache.org Thu May 20 05:45:06 2010 Return-Path: Delivered-To: apmail-hadoop-mapreduce-commits-archive@minotaur.apache.org Received: (qmail 90319 invoked from network); 20 May 2010 05:45:06 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 20 May 2010 05:45:06 -0000 Received: (qmail 77115 invoked by uid 500); 20 May 2010 05:45:06 -0000 Delivered-To: apmail-hadoop-mapreduce-commits-archive@hadoop.apache.org Received: (qmail 77092 invoked by uid 500); 20 May 2010 05:45:06 -0000 Mailing-List: contact mapreduce-commits-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: mapreduce-dev@hadoop.apache.org Delivered-To: mailing list mapreduce-commits@hadoop.apache.org Received: (qmail 77084 invoked by uid 99); 20 May 2010 05:45:06 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 May 2010 05:45:06 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 20 May 2010 05:44:57 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 216FC2388A41; Thu, 20 May 2010 05:44:34 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r946533 [3/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 -0000 To: mapreduce-commits@hadoop.apache.org From: acmurthy@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20100520054434.216FC2388A41@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ArrayListBackedIterator.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ArrayListBackedIterator.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ArrayListBackedIterator.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ArrayListBackedIterator.java Thu May 20 05:44:18 2010 @@ -19,6 +19,8 @@ package org.apache.hadoop.mapred.join; import java.util.ArrayList; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; /** @@ -30,6 +32,8 @@ import org.apache.hadoop.io.Writable; * {@link org.apache.hadoop.mapreduce.lib.join.ArrayListBackedIterator} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ArrayListBackedIterator extends org.apache.hadoop.mapreduce.lib.join.ArrayListBackedIterator implements ResetableIterator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableInputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableInputFormat.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.join; 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.WritableComparable; import org.apache.hadoop.mapred.InputFormat; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.Reporter * {@link org.apache.hadoop.mapreduce.lib.join.ComposableInputFormat} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface ComposableInputFormat extends InputFormat { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableRecordReader.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.join; 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.WritableComparable; import org.apache.hadoop.mapred.RecordReader; @@ -30,6 +32,8 @@ import org.apache.hadoop.mapred.RecordRe * {@link org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface ComposableRecordReader extends RecordReader, Comparable> { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputFormat.java Thu May 20 05:44:18 2010 @@ -24,6 +24,8 @@ import java.util.Map; import java.util.regex.Matcher; import java.util.regex.Pattern; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.mapred.InputFormat; @@ -48,6 +50,8 @@ import org.apache.hadoop.mapred.Reporter * {@link org.apache.hadoop.mapreduce.lib.join.CompositeInputFormat} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class CompositeInputFormat implements ComposableInputFormat { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputSplit.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputSplit.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputSplit.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputSplit.java Thu May 20 05:44:18 2010 @@ -23,6 +23,8 @@ import java.io.DataOutput; import java.io.IOException; import java.util.HashSet; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Text; import org.apache.hadoop.io.WritableUtils; import org.apache.hadoop.mapred.InputSplit; @@ -36,6 +38,8 @@ import org.apache.hadoop.util.Reflection * {@link org.apache.hadoop.mapreduce.lib.join.CompositeInputSplit} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class CompositeInputSplit implements InputSplit { private int fill = 0; Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeRecordReader.java Thu May 20 05:44:18 2010 @@ -23,6 +23,8 @@ import java.util.ArrayList; import java.util.Comparator; import java.util.PriorityQueue; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configurable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.io.Writable; @@ -40,6 +42,8 @@ import org.apache.hadoop.util.Reflection * {@link org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class CompositeRecordReader< K extends WritableComparable, // key type V extends Writable, // accepts RecordReader as children Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/InnerJoinRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/InnerJoinRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/InnerJoinRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/InnerJoinRecordReader.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.join; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparator; import org.apache.hadoop.mapred.JobConf; @@ -31,6 +33,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.join.InnerJoinRecordReader} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class InnerJoinRecordReader extends JoinRecordReader { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/JoinRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/JoinRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/JoinRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/JoinRecordReader.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.join; import java.io.IOException; import java.util.PriorityQueue; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparator; @@ -33,6 +35,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.join.JoinRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class JoinRecordReader extends CompositeRecordReader implements ComposableRecordReader { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/MultiFilterRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/MultiFilterRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/MultiFilterRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/MultiFilterRecordReader.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.join; import java.io.IOException; import java.util.PriorityQueue; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparator; @@ -36,6 +38,8 @@ import org.apache.hadoop.mapred.RecordRe * {@link org.apache.hadoop.mapreduce.lib.join.MultiFilterRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class MultiFilterRecordReader extends CompositeRecordReader Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OuterJoinRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OuterJoinRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OuterJoinRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OuterJoinRecordReader.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.join; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparator; import org.apache.hadoop.mapred.JobConf; @@ -31,6 +33,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.join.OuterJoinRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class OuterJoinRecordReader extends JoinRecordReader { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OverrideRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OverrideRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OverrideRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OverrideRecordReader.java Thu May 20 05:44:18 2010 @@ -22,6 +22,8 @@ import java.io.IOException; import java.util.ArrayList; import java.util.PriorityQueue; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.io.WritableComparator; @@ -36,6 +38,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.join.OverrideRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class OverrideRecordReader extends MultiFilterRecordReader { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/Parser.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/Parser.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/Parser.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/Parser.java Thu May 20 05:44:18 2010 @@ -32,6 +32,8 @@ import java.util.ListIterator; import java.util.Map; import java.util.Stack; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.WritableComparator; import org.apache.hadoop.mapred.FileInputFormat; import org.apache.hadoop.mapred.InputFormat; @@ -62,13 +64,19 @@ import org.apache.hadoop.util.Reflection * @deprecated Use {@link org.apache.hadoop.mapreduce.lib.join.Parser} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Evolving public class Parser { + @InterfaceAudience.Public + @InterfaceStability.Evolving public enum TType { CIF, IDENT, COMMA, LPAREN, RPAREN, QUOT, NUM, } /** * Tagged-union type for tokens from the join expression. * @see Parser.TType */ + @InterfaceAudience.Public + @InterfaceStability.Evolving public static class Token { private TType type; @@ -89,6 +97,8 @@ public class Parser { } } + @InterfaceAudience.Public + @InterfaceStability.Evolving public static class NumToken extends Token { private double num; public NumToken(double num) { @@ -98,6 +108,8 @@ public class Parser { public double getNum() { return num; } } + @InterfaceAudience.Public + @InterfaceStability.Evolving public static class NodeToken extends Token { private Node node; NodeToken(Node node) { @@ -109,6 +121,8 @@ public class Parser { } } + @InterfaceAudience.Public + @InterfaceStability.Evolving public static class StrToken extends Token { private String str; public StrToken(TType type, String str) { @@ -167,6 +181,8 @@ public class Parser { } } + @InterfaceAudience.Public + @InterfaceStability.Evolving public abstract static class Node implements ComposableInputFormat { /** * Return the node type registered for the particular identifier. Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ResetableIterator.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ResetableIterator.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ResetableIterator.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ResetableIterator.java Thu May 20 05:44:18 2010 @@ -17,6 +17,8 @@ */ package org.apache.hadoop.mapred.join; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; /** @@ -28,6 +30,8 @@ import org.apache.hadoop.io.Writable; * {@link org.apache.hadoop.mapreduce.lib.join.ResetableIterator} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface ResetableIterator extends org.apache.hadoop.mapreduce.lib.join.ResetableIterator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/StreamBackedIterator.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/StreamBackedIterator.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/StreamBackedIterator.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/StreamBackedIterator.java Thu May 20 05:44:18 2010 @@ -17,6 +17,8 @@ */ package org.apache.hadoop.mapred.join; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; /** @@ -27,6 +29,8 @@ import org.apache.hadoop.io.Writable; * {@link org.apache.hadoop.mapreduce.lib.join.StreamBackedIterator} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class StreamBackedIterator extends org.apache.hadoop.mapreduce.lib.join.StreamBackedIterator implements ResetableIterator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/TupleWritable.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/TupleWritable.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/TupleWritable.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/TupleWritable.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.join; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Writable; /** @@ -36,6 +38,8 @@ import org.apache.hadoop.io.Writable; * {@link org.apache.hadoop.mapreduce.lib.join.TupleWritable} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class TupleWritable extends org.apache.hadoop.mapreduce.lib.join.TupleWritable { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/WrappedRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/WrappedRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/WrappedRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/WrappedRecordReader.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.join; 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.WritableComparable; import org.apache.hadoop.io.WritableComparator; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.RecordRe * {@link org.apache.hadoop.mapreduce.lib.join.WrappedRecordReader} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class WrappedRecordReader implements ComposableRecordReader { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/BinaryPartitioner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/BinaryPartitioner.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/BinaryPartitioner.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/BinaryPartitioner.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.BinaryComparable; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Partitioner; @@ -32,6 +34,8 @@ import org.apache.hadoop.mapred.Partitio * instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class BinaryPartitioner extends org.apache.hadoop.mapreduce.lib.partition.BinaryPartitioner implements Partitioner { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainMapper.java Thu May 20 05:44:18 2010 @@ -17,6 +17,8 @@ */ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Mapper; import org.apache.hadoop.mapred.OutputCollector; @@ -90,6 +92,8 @@ import java.io.IOException; * Use {@link org.apache.hadoop.mapreduce.lib.chain.ChainMapper} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ChainMapper implements Mapper { /** Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainReducer.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainReducer.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainReducer.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainReducer.java Thu May 20 05:44:18 2010 @@ -17,6 +17,8 @@ */ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.*; import java.io.IOException; @@ -90,6 +92,8 @@ import java.util.Iterator; * Use {@link org.apache.hadoop.mapreduce.lib.chain.ChainReducer} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ChainReducer implements Reducer { /** Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileInputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileInputFormat.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.InputFormat; import org.apache.hadoop.mapred.InputSplit; import org.apache.hadoop.mapred.JobConf; @@ -50,6 +52,8 @@ import org.apache.hadoop.mapreduce.TaskA * {@link org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat} */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class CombineFileInputFormat extends org.apache.hadoop.mapreduce.lib.input.CombineFileInputFormat implements InputFormat{ Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileRecordReader.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileRecordReader.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileRecordReader.java Thu May 20 05:44:18 2010 @@ -24,6 +24,8 @@ import java.lang.reflect.*; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.*; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; /** @@ -37,6 +39,8 @@ import org.apache.hadoop.conf.Configurat * {@link org.apache.hadoop.mapreduce.lib.input.CombineFileRecordReader} */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class CombineFileRecordReader implements RecordReader { static final Class [] constructorSignature = new Class [] Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileSplit.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileSplit.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileSplit.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileSplit.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.Path; import org.apache.hadoop.mapred.InputSplit; import org.apache.hadoop.mapred.JobConf; @@ -27,6 +29,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.input.CombineFileSplit} */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class CombineFileSplit extends org.apache.hadoop.mapreduce.lib.input.CombineFileSplit implements InputSplit { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingInputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingInputFormat.java Thu May 20 05:44:18 2010 @@ -26,6 +26,8 @@ import java.util.List; 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.fs.Path; import org.apache.hadoop.mapred.FileInputFormat; import org.apache.hadoop.mapred.InputFormat; @@ -45,6 +47,8 @@ import org.apache.hadoop.util.Reflection * {@link org.apache.hadoop.mapreduce.lib.input.DelegatingInputFormat} instead */ @Deprecated +@InterfaceAudience.Private +@InterfaceStability.Unstable public class DelegatingInputFormat implements InputFormat { public InputSplit[] getSplits(JobConf conf, int numSplits) throws IOException { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingMapper.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.Path; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Mapper; @@ -36,6 +38,8 @@ import org.apache.hadoop.util.Reflection * {@link org.apache.hadoop.mapreduce.lib.input.DelegatingMapper} instead */ @Deprecated +@InterfaceAudience.Private +@InterfaceStability.Unstable public class DelegatingMapper implements Mapper { private JobConf conf; Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FieldSelectionMapReduce.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FieldSelectionMapReduce.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FieldSelectionMapReduce.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FieldSelectionMapReduce.java Thu May 20 05:44:18 2010 @@ -25,6 +25,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.io.Text; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Mapper; @@ -67,6 +69,8 @@ import org.apache.hadoop.mapreduce.lib.f * {@link FieldSelectionReducer} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class FieldSelectionMapReduce implements Mapper, Reducer { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FilterOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FilterOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FilterOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FilterOutputFormat.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.OutputFormat; @@ -33,6 +35,8 @@ import org.apache.hadoop.util.Progressab * {@link org.apache.hadoop.mapreduce.lib.output.FilterOutputFormat} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class FilterOutputFormat implements OutputFormat { protected OutputFormat baseOut; Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/HashPartitioner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/HashPartitioner.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/HashPartitioner.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/HashPartitioner.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.Partitioner; import org.apache.hadoop.mapred.JobConf; @@ -26,6 +28,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.partition.HashPartitioner} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class HashPartitioner implements Partitioner { public void configure(JobConf job) {} Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityMapper.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.Mapper; import org.apache.hadoop.mapred.OutputCollector; import org.apache.hadoop.mapred.Reporter; @@ -29,6 +31,8 @@ import org.apache.hadoop.mapred.MapReduc * @deprecated Use {@link org.apache.hadoop.mapreduce.Mapper} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class IdentityMapper extends MapReduceBase implements Mapper { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityReducer.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityReducer.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityReducer.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityReducer.java Thu May 20 05:44:18 2010 @@ -22,6 +22,8 @@ import java.io.IOException; import java.util.Iterator; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.Reducer; import org.apache.hadoop.mapred.OutputCollector; import org.apache.hadoop.mapred.Reporter; @@ -31,6 +33,8 @@ import org.apache.hadoop.mapred.MapReduc * @deprecated Use {@link org.apache.hadoop.mapreduce.Reducer} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class IdentityReducer extends MapReduceBase implements Reducer { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InputSampler.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InputSampler.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InputSampler.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InputSampler.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapreduce.Job; @@ -28,6 +30,8 @@ import org.apache.hadoop.mapreduce.Job; * {@link org.apache.hadoop.mapreduce.lib.partition.InputSampler} */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class InputSampler extends org.apache.hadoop.mapreduce.lib.partition.InputSampler { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InverseMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InverseMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InverseMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InverseMapper.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.MapReduceBase; import org.apache.hadoop.mapred.Mapper; import org.apache.hadoop.mapred.OutputCollector; @@ -30,6 +32,8 @@ import org.apache.hadoop.mapred.Reporter * instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class InverseMapper extends MapReduceBase implements Mapper { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedComparator.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedComparator.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedComparator.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedComparator.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.JobConfigurable; import org.apache.hadoop.mapreduce.JobContext; @@ -41,6 +43,8 @@ import org.apache.hadoop.mapreduce.JobCo * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class KeyFieldBasedComparator extends org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedComparator implements JobConfigurable { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedPartitioner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedPartitioner.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedPartitioner.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedPartitioner.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Partitioner; @@ -37,6 +39,8 @@ import org.apache.hadoop.mapred.Partitio * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class KeyFieldBasedPartitioner extends org.apache.hadoop.mapreduce.lib.partition.KeyFieldBasedPartitioner implements Partitioner { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LazyOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LazyOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LazyOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LazyOutputFormat.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.OutputFormat; @@ -34,6 +36,8 @@ import org.apache.hadoop.util.Reflection * {@link org.apache.hadoop.mapreduce.lib.output.LazyOutputFormat} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class LazyOutputFormat extends FilterOutputFormat { /** * Set the underlying output format for LazyOutputFormat. Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LongSumReducer.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LongSumReducer.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LongSumReducer.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LongSumReducer.java Thu May 20 05:44:18 2010 @@ -26,6 +26,8 @@ import org.apache.hadoop.mapred.OutputCo import org.apache.hadoop.mapred.Reporter; import org.apache.hadoop.mapred.MapReduceBase; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.LongWritable; /** A {@link Reducer} that sums long values. @@ -33,6 +35,8 @@ import org.apache.hadoop.io.LongWritable * instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class LongSumReducer extends MapReduceBase implements Reducer { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleInputs.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleInputs.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleInputs.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleInputs.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ import java.util.Collections; 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.Path; import org.apache.hadoop.mapred.InputFormat; import org.apache.hadoop.mapred.JobConf; @@ -34,6 +36,8 @@ import org.apache.hadoop.util.Reflection * {@link org.apache.hadoop.mapreduce.lib.input.MultipleInputs} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class MultipleInputs { /** * Add a {@link Path} with a custom {@link InputFormat} to the list of Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputFormat.java Thu May 20 05:44:18 2010 @@ -22,6 +22,8 @@ import java.io.IOException; import java.util.Iterator; import java.util.TreeMap; +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.mapred.JobConf; @@ -53,6 +55,8 @@ import org.apache.hadoop.util.Progressab * {@link org.apache.hadoop.mapreduce.lib.output.MultipleOutputs} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class MultipleOutputFormat extends FileOutputFormat { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputs.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputs.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputs.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputs.java Thu May 20 05:44:18 2010 @@ -17,6 +17,8 @@ */ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.WritableComparable; @@ -116,6 +118,8 @@ import java.util.*; * {@link org.apache.hadoop.mapreduce.lib.output.MultipleOutputs} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class MultipleOutputs { private static final String NAMED_OUTPUTS = "mo.namedOutputs"; Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleSequenceFileOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleSequenceFileOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleSequenceFileOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleSequenceFileOutputFormat.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.RecordWriter; @@ -33,6 +35,8 @@ import org.apache.hadoop.util.Progressab * {@link org.apache.hadoop.mapreduce.lib.output.MultipleOutputs} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class MultipleSequenceFileOutputFormat extends MultipleOutputFormat { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleTextOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleTextOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleTextOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleTextOutputFormat.java Thu May 20 05:44:18 2010 @@ -20,6 +20,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.RecordWriter; @@ -33,6 +35,8 @@ import org.apache.hadoop.util.Progressab * {@link org.apache.hadoop.mapreduce.lib.output.MultipleOutputs} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class MultipleTextOutputFormat extends MultipleOutputFormat { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java Thu May 20 05:44:18 2010 @@ -19,6 +19,8 @@ package org.apache.hadoop.mapred.lib; import org.apache.hadoop.util.ReflectionUtils; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.MapRunnable; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Mapper; @@ -51,6 +53,8 @@ import java.util.concurrent.*; * @deprecated Use {@link MultithreadedMapper} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class MultithreadedMapRunner implements MapRunnable { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NLineInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NLineInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NLineInputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NLineInputFormat.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.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.fs.FileStatus; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; @@ -54,6 +56,8 @@ import org.apache.hadoop.mapred.Reporter * {@link org.apache.hadoop.mapreduce.lib.input.NLineInputFormat} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class NLineInputFormat extends FileInputFormat implements JobConfigurable { private int N = 1; Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NullOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NullOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NullOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NullOutputFormat.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.OutputFormat; @@ -31,6 +33,8 @@ import org.apache.hadoop.util.Progressab * {@link org.apache.hadoop.mapreduce.lib.output.NullOutputFormat} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class NullOutputFormat implements OutputFormat { public RecordWriter getRecordWriter(FileSystem ignored, JobConf job, Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/RegexMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/RegexMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/RegexMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/RegexMapper.java Thu May 20 05:44:18 2010 @@ -22,6 +22,8 @@ import java.io.IOException; import java.util.regex.Matcher; import java.util.regex.Pattern; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapred.JobConf; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.Reporter * @deprecated Use {@link org.apache.hadoop.mapreduce.lib.map.RegexMapper} */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class RegexMapper extends MapReduceBase implements Mapper { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TokenCountMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TokenCountMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TokenCountMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TokenCountMapper.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.lib; import java.io.IOException; import java.util.StringTokenizer; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapred.MapReduceBase; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.Reporter * {@link org.apache.hadoop.mapreduce.lib.map.TokenCounterMapper} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class TokenCountMapper extends MapReduceBase implements Mapper { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java Thu May 20 05:44:18 2010 @@ -19,6 +19,8 @@ package org.apache.hadoop.mapred.lib; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.WritableComparable; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.Partitioner; @@ -30,6 +32,8 @@ import org.apache.hadoop.mapred.Partitio * {@link org.apache.hadoop.mapreduce.lib.partition.TotalOrderPartitioner} */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class TotalOrderPartitioner,V> extends org.apache.hadoop.mapreduce.lib.partition.TotalOrderPartitioner implements Partitioner { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/DoubleValueSum.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/DoubleValueSum.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/DoubleValueSum.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/DoubleValueSum.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +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. @@ -26,6 +29,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.DoubleValueSum} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class DoubleValueSum extends org.apache.hadoop.mapreduce.lib.aggregate.DoubleValueSum implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMax.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMax.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMax.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMax.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * This class implements a value aggregator that maintain the maximum of @@ -27,6 +30,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.LongValueMax} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class LongValueMax extends org.apache.hadoop.mapreduce.lib.aggregate.LongValueMax implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMin.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMin.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMin.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMin.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +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. @@ -26,6 +29,8 @@ package org.apache.hadoop.mapred.lib.agg *{@link org.apache.hadoop.mapreduce.lib.aggregate.LongValueMin} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class LongValueMin extends org.apache.hadoop.mapreduce.lib.aggregate.LongValueMin implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueSum.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueSum.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueSum.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueSum.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +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. @@ -26,6 +29,8 @@ package org.apache.hadoop.mapred.lib.agg *{@link org.apache.hadoop.mapreduce.lib.aggregate.LongValueSum} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class LongValueSum extends org.apache.hadoop.mapreduce.lib.aggregate.LongValueSum implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMax.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMax.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMax.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMax.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +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. @@ -26,6 +29,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.StringValueMax} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class StringValueMax extends org.apache.hadoop.mapreduce.lib.aggregate.StringValueMax implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMin.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMin.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMin.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMin.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +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. @@ -26,6 +29,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.StringValueMin} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class StringValueMin extends org.apache.hadoop.mapreduce.lib.aggregate.StringValueMin implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UniqValueCount.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UniqValueCount.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UniqValueCount.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UniqValueCount.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * This class implements a value aggregator that dedupes a sequence of objects. * @@ -25,6 +28,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.UniqValueCount} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class UniqValueCount extends org.apache.hadoop.mapreduce.lib.aggregate.UniqValueCount implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UserDefinedValueAggregatorDescriptor.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UserDefinedValueAggregatorDescriptor.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UserDefinedValueAggregatorDescriptor.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UserDefinedValueAggregatorDescriptor.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib.aggregate; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.JobConf; /** @@ -31,6 +33,8 @@ import org.apache.hadoop.mapred.JobConf; * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class UserDefinedValueAggregatorDescriptor extends org.apache.hadoop. mapreduce.lib.aggregate.UserDefinedValueAggregatorDescriptor implements ValueAggregatorDescriptor { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregator.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregator.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregator.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregator.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * This interface defines the minimal protocol for value aggregators. * @@ -25,6 +28,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregator} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface ValueAggregator extends org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregator { } Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorBaseDescriptor.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorBaseDescriptor.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorBaseDescriptor.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorBaseDescriptor.java Thu May 20 05:44:18 2010 @@ -19,6 +19,9 @@ package org.apache.hadoop.mapred.lib.aggregate; 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.mapred.JobConf; @@ -31,6 +34,8 @@ import org.apache.hadoop.mapred.JobConf; * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ValueAggregatorBaseDescriptor extends org.apache.hadoop.mapreduce. lib.aggregate.ValueAggregatorBaseDescriptor implements ValueAggregatorDescriptor { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorCombiner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorCombiner.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorCombiner.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorCombiner.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.lib.agg 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; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.Reporter * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ValueAggregatorCombiner extends ValueAggregatorJobBase { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorDescriptor.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorDescriptor.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorDescriptor.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorDescriptor.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib.aggregate; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapred.JobConf; @@ -37,6 +39,8 @@ import org.apache.hadoop.mapred.JobConf; * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface ValueAggregatorDescriptor extends org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorDescriptor { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJob.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJob.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJob.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJob.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.lib.agg 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; @@ -81,6 +83,8 @@ import org.apache.hadoop.util.GenericOpt * {@link org.apache.hadoop.mapreduce.lib.aggregate.ValueAggregatorJob} instead */ @Deprecated +@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/mapred/lib/aggregate/ValueAggregatorJobBase.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJobBase.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJobBase.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJobBase.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.lib.agg import java.io.IOException; import java.util.ArrayList; +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; @@ -36,6 +38,8 @@ import org.apache.hadoop.mapred.Reducer; * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public abstract class ValueAggregatorJobBase implements Mapper, Reducer { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorMapper.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorMapper.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorMapper.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/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; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.Reporter * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ValueAggregatorMapper extends ValueAggregatorJobBase { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorReducer.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorReducer.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorReducer.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorReducer.java Thu May 20 05:44:18 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred.lib.agg 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; @@ -35,6 +37,8 @@ import org.apache.hadoop.mapred.Reporter * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ValueAggregatorReducer extends ValueAggregatorJobBase { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueHistogram.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueHistogram.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueHistogram.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueHistogram.java Thu May 20 05:44:18 2010 @@ -18,6 +18,9 @@ package org.apache.hadoop.mapred.lib.aggregate; +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. @@ -26,6 +29,8 @@ package org.apache.hadoop.mapred.lib.agg * {@link org.apache.hadoop.mapreduce.lib.aggregate.ValueHistogram} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class ValueHistogram extends org.apache.hadoop.mapreduce.lib.aggregate.ValueHistogram implements ValueAggregator { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBConfiguration.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBConfiguration.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBConfiguration.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBConfiguration.java Thu May 20 05:44:18 2010 @@ -18,6 +18,8 @@ package org.apache.hadoop.mapred.lib.db; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapred.JobConf; /** @@ -25,6 +27,8 @@ import org.apache.hadoop.mapred.JobConf; * {@link org.apache.hadoop.mapreduce.lib.db.DBConfiguration} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class DBConfiguration extends org.apache.hadoop.mapreduce.lib.db.DBConfiguration { /** The JDBC Driver class name */ Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBInputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBInputFormat.java Thu May 20 05:44:18 2010 @@ -23,6 +23,8 @@ import java.sql.Connection; 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.io.LongWritable; import org.apache.hadoop.io.Writable; @@ -39,6 +41,8 @@ import org.apache.hadoop.mapreduce.Job; * Use {@link org.apache.hadoop.mapreduce.lib.db.DBInputFormat} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class DBInputFormat extends org.apache.hadoop.mapreduce.lib.db.DBInputFormat implements InputFormat, JobConfigurable { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBOutputFormat.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBOutputFormat.java Thu May 20 05:44:18 2010 @@ -23,6 +23,8 @@ import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.SQLException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.mapred.JobConf; import org.apache.hadoop.mapred.OutputFormat; @@ -38,6 +40,8 @@ import org.apache.hadoop.util.Progressab * @deprecated Use org.apache.hadoop.mapreduce.lib.db.DBOutputFormat instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class DBOutputFormat extends org.apache.hadoop.mapreduce.lib.db.DBOutputFormat implements OutputFormat { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBWritable.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBWritable.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBWritable.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBWritable.java Thu May 20 05:44:18 2010 @@ -17,11 +17,16 @@ */ package org.apache.hadoop.mapred.lib.db; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * @deprecated * Use {@link org.apache.hadoop.mapreduce.lib.db.DBWritable} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface DBWritable extends org.apache.hadoop.mapreduce.lib.db.DBWritable { Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/pipes/Submitter.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/pipes/Submitter.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/pipes/Submitter.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/pipes/Submitter.java Thu May 20 05:44:18 2010 @@ -37,6 +37,8 @@ import org.apache.commons.cli.ParseExcep import org.apache.commons.cli.Parser; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.conf.Configured; import org.apache.hadoop.mapreduce.MRJobConfig; @@ -64,6 +66,8 @@ import org.apache.hadoop.util.Tool; * The main entry point and job submitter. It may either be used as a command * line-based or API-based method to launch Pipes jobs. */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class Submitter extends Configured implements Tool { protected static final Log LOG = LogFactory.getLog(Submitter.class); Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/tools/MRAdmin.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/tools/MRAdmin.java?rev=946533&r1=946532&r2=946533&view=diff ============================================================================== --- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/tools/MRAdmin.java (original) +++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/tools/MRAdmin.java Thu May 20 05:44:18 2010 @@ -19,6 +19,8 @@ package org.apache.hadoop.mapred.tools; 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.conf.Configured; import org.apache.hadoop.ipc.RPC; @@ -39,6 +41,8 @@ import org.apache.hadoop.util.ToolRunner * and 1) refresh the service-level authorization policy, 2) refresh queue acl * properties. */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class MRAdmin extends Configured implements Tool { public MRAdmin() {