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
*/
+@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("");