Return-Path: Delivered-To: apmail-hadoop-mapreduce-commits-archive@minotaur.apache.org Received: (qmail 76836 invoked from network); 20 May 2010 05:04:11 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 20 May 2010 05:04:11 -0000 Received: (qmail 46686 invoked by uid 500); 20 May 2010 05:04:11 -0000 Delivered-To: apmail-hadoop-mapreduce-commits-archive@hadoop.apache.org Received: (qmail 46657 invoked by uid 500); 20 May 2010 05:04:11 -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 46566 invoked by uid 99); 20 May 2010 05:04:11 -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:04:11 +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:03:59 +0000 Received: by eris.apache.org (Postfix, from userid 65534) id 199F72388A4B; Thu, 20 May 2010 05:03:37 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: mapreduce-commits@hadoop.apache.org From: acmurthy@apache.org X-Mailer: svnmailer-1.0.8 Message-Id: <20100520050337.199F72388A4B@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org 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 { /** 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 { 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 { 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 { 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 { 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 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 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 { 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 { /** 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, V1 extends Writable> extends Reducer { 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, 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, V1 extends Writable> extends Mapper { 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, V1 extends Writable> extends Reducer { 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 { TreeMap 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 * ... * */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class ChainMapper extends Mapper { 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; * ... * */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class ChainReducer extends Reducer { 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 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 extends InputFormat implements Configurable { @@ -59,6 +63,7 @@ public class DBInputFormatonly the key to the database with a batch SQL query. * */ +@InterfaceAudience.Public +@InterfaceStability.Stable public class DBOutputFormat extends OutputFormat { @@ -59,6 +63,7 @@ extends OutputFormat { /** * A RecordWriter that writes the reduce output to a SQL table */ + @InterfaceStability.Evolving public class DBRecordWriter extends RecordWriter { 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 extends RecordReader { 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; * } *

*/ +@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 extends DBInputFormat implements Configurable { @@ -67,6 +71,7 @@ public class DataDrivenDBInputFormat extends DBRecordReader { 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 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 extends DBRecordReader { 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 extends DataDrivenDBRecordReader { 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 extends DBRecordReader { /** 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 extends DataDrivenDBInputFormat 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 extends DataDrivenDBRecordReader { 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("");