You are viewing a plain text version of this content. The canonical link for it is here.
Posted to mapreduce-commits@hadoop.apache.org by ac...@apache.org on 2010/05/20 07:44:28 UTC
svn commit: r946533 [1/7] - in /hadoop/mapreduce/branches/branch-0.21: ./
conf/ src/c++/ src/contrib/ src/contrib/block_forensics/
src/contrib/capacity-scheduler/ src/contrib/data_join/
src/contrib/dynamic-scheduler/ src/contrib/eclipse-plugin/ src/con...
Author: acmurthy
Date: Thu May 20 05:44:18 2010
New Revision: 946533
URL: http://svn.apache.org/viewvc?rev=946533&view=rev
Log:
Merge -r 946525:946526 from trunk to branch-0.21 to fix MAPREDUCE-1623.
Added:
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/filecache/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/filecache/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/filecache/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/protocol/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/protocol/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/split/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/package-info.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/util/package-info.java
- copied unchanged from r946526, hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/package-info.java
Modified:
hadoop/mapreduce/branches/branch-0.21/ (props changed)
hadoop/mapreduce/branches/branch-0.21/.gitignore (props changed)
hadoop/mapreduce/branches/branch-0.21/CHANGES.txt (contents, props changed)
hadoop/mapreduce/branches/branch-0.21/conf/ (props changed)
hadoop/mapreduce/branches/branch-0.21/conf/capacity-scheduler.xml.template (props changed)
hadoop/mapreduce/branches/branch-0.21/src/c++/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/block_forensics/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/build-contrib.xml (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/build.xml (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/capacity-scheduler/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/data_join/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/dynamic-scheduler/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/eclipse-plugin/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/fairscheduler/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/index/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/mrunit/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/streaming/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/contrib/vaidya/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/examples/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/java/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/filecache/DistributedCache.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/BackupStore.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ClusterStatus.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Counters.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFile.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileInputStream.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileOutputStream.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidInputException.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IsolationRunner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobClient.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobConf.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobConfigurable.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobContext.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobEndNotifier.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobInProgress.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobPriority.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobProfile.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobQueueInfo.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobStatus.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobTracker.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JvmTask.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/KeyValueLineRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/KeyValueTextInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/LineRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/LocalJobRunner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapFileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapOutputFile.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapReduceBase.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapReducePolicyProvider.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapRunnable.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapRunner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MapTaskCompletionEventsUpdate.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Mapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Merger.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MultiFileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/MultiFileSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/OutputCollector.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/OutputCommitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/OutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/OutputLogFilter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Partitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/RawKeyValueIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/RecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/RecordWriter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ReduceTask.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Reducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Reporter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/RunningJob.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileAsBinaryInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileAsBinaryOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileAsTextInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileAsTextRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileInputFilter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SequenceFileRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/SkipBadRecords.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TIPStatus.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Task.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskAttemptContext.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskAttemptContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskAttemptID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskCompletionEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskController.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskGraphServlet.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskLog.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskLogAppender.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskLogServlet.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskReport.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskStatus.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskTracker.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TaskUmbilicalProtocol.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TextInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/TextOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Utils.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/jobcontrol/Job.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/jobcontrol/JobControl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ArrayListBackedIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ComposableRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeInputSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/CompositeRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/InnerJoinRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/JoinRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/MultiFilterRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OuterJoinRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/OverrideRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/Parser.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/ResetableIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/StreamBackedIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/TupleWritable.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/join/WrappedRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/BinaryPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/ChainReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/CombineFileSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/DelegatingMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FieldSelectionMapReduce.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/FilterOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/HashPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/IdentityReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InputSampler.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/InverseMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedComparator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LazyOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/LongSumReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleInputs.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleOutputs.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleSequenceFileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultipleTextOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NLineInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/NullOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/RegexMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TokenCountMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/DoubleValueSum.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMax.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueSum.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMax.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UniqValueCount.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/UserDefinedValueAggregatorDescriptor.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorBaseDescriptor.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorCombiner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorDescriptor.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJob.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJobBase.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueHistogram.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBConfiguration.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/lib/db/DBWritable.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/pipes/Submitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/tools/MRAdmin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Cluster.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ClusterMetrics.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/CounterGroup.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Counters.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/ID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/InputSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Job.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobCounter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobPriority.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobStatus.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MRConfig.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Mapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/MarkableIteratorInterface.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputCommitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/OutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Partitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueAclsInfo.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueInfo.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/QueueState.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/RecordWriter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/Reducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/StatusReporter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskCounter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskID.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskReport.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/TaskType.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/BigDecimalSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/BooleanSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DBConfiguration.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DBInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DBOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DBRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DBSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DBWritable.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/DateSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/FloatSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/IntegerSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDBRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDataDrivenDBRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDBRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDateSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/db/TextSplitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionHelper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/CombineFileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/CombineFileRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/CombineFileSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/DelegatingInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/DelegatingMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/DelegatingRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/FileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/FileSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/InvalidInputException.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/KeyValueLineRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/KeyValueTextInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/LineRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/MultipleInputs.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/NLineInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileAsBinaryInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileAsTextInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileAsTextRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileInputFilter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/input/TextInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/jobcontrol/ControlledJob.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/jobcontrol/JobControl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/ArrayListBackedIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/ComposableInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/ComposableRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/CompositeInputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/CompositeInputSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/CompositeRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/InnerJoinRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/JoinRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/MultiFilterRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/OuterJoinRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/OverrideRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/Parser.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/ResetableIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/StreamBackedIterator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/TupleWritable.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/join/WrappedRecordReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/map/InverseMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/map/MultithreadedMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/map/RegexMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/map/TokenCounterMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/map/WrappedMapper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/FileOutputCommitter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/FileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/FilterOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/LazyOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/MapFileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/MultipleOutputs.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/NullOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/SequenceFileAsBinaryOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/SequenceFileOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/output/TextOutputFormat.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/partition/BinaryPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/partition/HashPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/partition/InputSampler.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/partition/KeyFieldBasedComparator.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/partition/KeyFieldBasedPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/partition/TotalOrderPartitioner.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/reduce/IntSumReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/reduce/LongSumReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/lib/reduce/WrappedReducer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/protocol/ClientProtocol.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/SecureShuffleUtils.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/TokenCache.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/DelegationTokenRenewal.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenIdentifier.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSecretManager.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSelector.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenIdentifier.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSecretManager.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSelector.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JTConfig.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JobTrackerJspHelper.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/jobtracker/State.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/jobtracker/TaskTracker.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/tasktracker/Localizer.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/server/tasktracker/TTConfig.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/split/JobSplit.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/split/JobSplitWriter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/JobContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/MapContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/TaskAttemptContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/TaskInputOutputContextImpl.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryReader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryWriter.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/reduce/MergeManager.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/reduce/Shuffle.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/task/reduce/ShuffleHeader.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/tools/CLI.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/ConfigUtil.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/LinuxMemoryCalculatorPlugin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/LinuxResourceCalculatorPlugin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/MemoryCalculatorPlugin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/ProcessTree.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/ProcfsBasedProcessTree.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapreduce/util/ResourceCalculatorPlugin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/util/LinuxMemoryCalculatorPlugin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/util/MemoryCalculatorPlugin.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/util/ProcessTree.java
hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/util/ProcfsBasedProcessTree.java
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/fs/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/hdfs/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/io/FileBench.java (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/io/TestSequenceFileMergeProgress.java (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/ipc/ (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/security/authorize/TestServiceLevelAuthorization.java (props changed)
hadoop/mapreduce/branches/branch-0.21/src/test/mapred/org/apache/hadoop/test/MapredTestDriver.java (props changed)
hadoop/mapreduce/branches/branch-0.21/src/webapps/job/ (props changed)
Propchange: hadoop/mapreduce/branches/branch-0.21/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,2 +1,2 @@
/hadoop/core/branches/branch-0.19/mapred:713112
-/hadoop/mapreduce/trunk:940364,942764
+/hadoop/mapreduce/trunk:940364,942764,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/.gitignore
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/.gitignore:713112
/hadoop/core/trunk/.gitignore:784664-785643
-/hadoop/mapreduce/trunk/.gitignore:940364
+/hadoop/mapreduce/trunk/.gitignore:940364,946526
Modified: hadoop/mapreduce/branches/branch-0.21/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/CHANGES.txt?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/CHANGES.txt (original)
+++ hadoop/mapreduce/branches/branch-0.21/CHANGES.txt Thu May 20 05:44:18 2010
@@ -728,6 +728,9 @@ Release 0.21.0 - Unreleased
This thus removes the incompatible change/feature job-acls from branch 0.21
(vinodkv)
+ MAPREDUCE-1623. Apply audience and stability notations to Hadoop
+ Map-Reduce. (tomwhite via acmurthy)
+
OPTIMIZATIONS
MAPREDUCE-270. Fix the tasktracker to optionally send an out-of-band
Propchange: hadoop/mapreduce/branches/branch-0.21/CHANGES.txt
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/CHANGES.txt:713112
/hadoop/mapreduce/branches/HDFS-641/CHANGES.txt:817878-835964
-/hadoop/mapreduce/trunk/CHANGES.txt:940364,942764
+/hadoop/mapreduce/trunk/CHANGES.txt:940364,942764,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/conf/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/conf:713112
/hadoop/core/trunk/conf:784664-785643
-/hadoop/mapreduce/trunk/conf:940364
+/hadoop/mapreduce/trunk/conf:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/conf/capacity-scheduler.xml.template
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/conf/capacity-scheduler.xml.template:713112
/hadoop/core/trunk/conf/capacity-scheduler.xml.template:776175-785643
-/hadoop/mapreduce/trunk/conf/capacity-scheduler.xml.template:940364
+/hadoop/mapreduce/trunk/conf/capacity-scheduler.xml.template:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/c++/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/c++:713112
/hadoop/core/trunk/src/c++:776175-784663
-/hadoop/mapreduce/trunk/src/c++:940364
+/hadoop/mapreduce/trunk/src/c++:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib:713112
/hadoop/core/trunk/src/contrib:784664-785643
-/hadoop/mapreduce/trunk/src/contrib:940364
+/hadoop/mapreduce/trunk/src/contrib:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/block_forensics/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,2 +1,2 @@
/hadoop/core/branches/branch-0.19/hdfs/src/contrib/block_forensics:713112
-/hadoop/mapreduce/trunk/src/contrib/block_forensics:940364
+/hadoop/mapreduce/trunk/src/contrib/block_forensics:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/build-contrib.xml
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/build-contrib.xml:713112
/hadoop/core/trunk/src/contrib/build-contrib.xml:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/build-contrib.xml:940364
+/hadoop/mapreduce/trunk/src/contrib/build-contrib.xml:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/build.xml
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/build.xml:713112
/hadoop/core/trunk/src/contrib/build.xml:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/build.xml:940364
+/hadoop/mapreduce/trunk/src/contrib/build.xml:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/capacity-scheduler/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/capacity-scheduler:713112
/hadoop/core/trunk/src/contrib/capacity-scheduler:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/capacity-scheduler:940364
+/hadoop/mapreduce/trunk/src/contrib/capacity-scheduler:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/data_join/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/data_join:713112
/hadoop/core/trunk/src/contrib/data_join:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/data_join:940364
+/hadoop/mapreduce/trunk/src/contrib/data_join:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/dynamic-scheduler/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/src/contrib/dynamic-scheduler:713112
/hadoop/core/trunk/src/contrib/dynamic-scheduler:784975-786373
-/hadoop/mapreduce/trunk/src/contrib/dynamic-scheduler:940364
+/hadoop/mapreduce/trunk/src/contrib/dynamic-scheduler:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/eclipse-plugin/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/core/src/contrib/eclipse-plugin:713112
/hadoop/core/trunk/src/contrib/eclipse-plugin:776175-784663
-/hadoop/mapreduce/trunk/src/contrib/eclipse-plugin:940364
+/hadoop/mapreduce/trunk/src/contrib/eclipse-plugin:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/fairscheduler/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/fairscheduler:713112
/hadoop/core/trunk/src/contrib/fairscheduler:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/fairscheduler:940364
+/hadoop/mapreduce/trunk/src/contrib/fairscheduler:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/index/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/index:713112
/hadoop/core/trunk/src/contrib/index:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/index:940364
+/hadoop/mapreduce/trunk/src/contrib/index:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/mrunit/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/mrunit:713112
/hadoop/core/trunk/src/contrib/mrunit:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/mrunit:940364
+/hadoop/mapreduce/trunk/src/contrib/mrunit:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/streaming/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/streaming:713112
/hadoop/core/trunk/src/contrib/streaming:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/streaming:940364
+/hadoop/mapreduce/trunk/src/contrib/streaming:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/contrib/vaidya/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/contrib/vaidya:713112
/hadoop/core/trunk/src/contrib/vaidya:776175-786373
-/hadoop/mapreduce/trunk/src/contrib/vaidya:940364
+/hadoop/mapreduce/trunk/src/contrib/vaidya:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/examples/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/examples:713112
/hadoop/core/trunk/src/examples:776175-784663
-/hadoop/mapreduce/trunk/src/examples:940364
+/hadoop/mapreduce/trunk/src/examples:940364,946526
Propchange: hadoop/mapreduce/branches/branch-0.21/src/java/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Thu May 20 05:44:18 2010
@@ -1,3 +1,3 @@
/hadoop/core/branches/branch-0.19/mapred/src/java:713112
/hadoop/core/trunk/src/mapred:776175-785643
-/hadoop/mapreduce/trunk/src/java:940364
+/hadoop/mapreduce/trunk/src/java:940364,946526
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/filecache/DistributedCache.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/filecache/DistributedCache.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/filecache/DistributedCache.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/filecache/DistributedCache.java Thu May 20 05:44:18 2010
@@ -18,14 +18,116 @@
package org.apache.hadoop.filecache;
+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;
+import org.apache.hadoop.mapreduce.Job;
+import org.apache.hadoop.mapreduce.filecache.TaskDistributedCacheManager;
+import org.apache.hadoop.mapreduce.filecache.TrackerDistributedCacheManager;
+
/**
- * Class is moved to a new package org.apache.hadoop.mapreduce.filecache
+ * Distribute application-specific large, read-only files efficiently.
+ *
+ * <p><code>DistributedCache</code> is a facility provided by the Map-Reduce
+ * framework to cache files (text, archives, jars etc.) needed by applications.
+ * </p>
+ *
+ * <p>Applications specify the files, via urls (hdfs:// or http://) to be cached
+ * via the {@link org.apache.hadoop.mapred.JobConf}. The
+ * <code>DistributedCache</code> assumes that the files specified via urls are
+ * already present on the {@link FileSystem} at the path specified by the url
+ * and are accessible by every machine in the cluster.</p>
+ *
+ * <p>The framework will copy the necessary files on to the slave node before
+ * any tasks for the job are executed on that node. Its efficiency stems from
+ * the fact that the files are only copied once per job and the ability to
+ * cache archives which are un-archived on the slaves.</p>
+ *
+ * <p><code>DistributedCache</code> can be used to distribute simple, read-only
+ * data/text files and/or more complex types such as archives, jars etc.
+ * Archives (zip, tar and tgz/tar.gz files) are un-archived at the slave nodes.
+ * Jars may be optionally added to the classpath of the tasks, a rudimentary
+ * software distribution mechanism. Files have execution permissions.
+ * Optionally users can also direct it to symlink the distributed cache file(s)
+ * into the working directory of the task.</p>
*
- * @deprecated Instead use
- * {@link org.apache.hadoop.mapreduce.filecache.DistributedCache}
+ * <p><code>DistributedCache</code> tracks modification timestamps of the cache
+ * files. Clearly the cache files should not be modified by the application
+ * or externally while the job is executing.</p>
*
+ * <p>Here is an illustrative example on how to use the
+ * <code>DistributedCache</code>:</p>
+ * <p><blockquote><pre>
+ * // Setting up the cache for the application
+ *
+ * 1. Copy the requisite files to the <code>FileSystem</code>:
+ *
+ * $ bin/hadoop fs -copyFromLocal lookup.dat /myapp/lookup.dat
+ * $ bin/hadoop fs -copyFromLocal map.zip /myapp/map.zip
+ * $ bin/hadoop fs -copyFromLocal mylib.jar /myapp/mylib.jar
+ * $ bin/hadoop fs -copyFromLocal mytar.tar /myapp/mytar.tar
+ * $ bin/hadoop fs -copyFromLocal mytgz.tgz /myapp/mytgz.tgz
+ * $ bin/hadoop fs -copyFromLocal mytargz.tar.gz /myapp/mytargz.tar.gz
+ *
+ * 2. Setup the application's <code>JobConf</code>:
+ *
+ * JobConf job = new JobConf();
+ * DistributedCache.addCacheFile(new URI("/myapp/lookup.dat#lookup.dat"),
+ * job);
+ * DistributedCache.addCacheArchive(new URI("/myapp/map.zip", job);
+ * DistributedCache.addFileToClassPath(new Path("/myapp/mylib.jar"), job);
+ * DistributedCache.addCacheArchive(new URI("/myapp/mytar.tar", job);
+ * DistributedCache.addCacheArchive(new URI("/myapp/mytgz.tgz", job);
+ * DistributedCache.addCacheArchive(new URI("/myapp/mytargz.tar.gz", job);
+ *
+ * 3. Use the cached files in the {@link org.apache.hadoop.mapred.Mapper}
+ * or {@link org.apache.hadoop.mapred.Reducer}:
+ *
+ * public static class MapClass extends MapReduceBase
+ * implements Mapper<K, V, K, V> {
+ *
+ * private Path[] localArchives;
+ * private Path[] localFiles;
+ *
+ * public void configure(JobConf job) {
+ * // Get the cached archives/files
+ * localArchives = DistributedCache.getLocalCacheArchives(job);
+ * localFiles = DistributedCache.getLocalCacheFiles(job);
+ * }
+ *
+ * public void map(K key, V value,
+ * OutputCollector<K, V> output, Reporter reporter)
+ * throws IOException {
+ * // Use data from the cached archives/files here
+ * // ...
+ * // ...
+ * output.collect(k, v);
+ * }
+ * }
+ *
+ * </pre></blockquote></p>
+ *
+ * It is also very common to use the DistributedCache by using
+ * {@link org.apache.hadoop.util.GenericOptionsParser}.
+ *
+ * This class includes methods that should be used by users
+ * (specifically those mentioned in the example above, as well
+ * as {@link DistributedCache#addArchiveToClassPath(Path, Configuration)}),
+ * as well as methods intended for use by the MapReduce framework
+ * (e.g., {@link org.apache.hadoop.mapred.JobClient}). For implementation
+ * details, see {@link TrackerDistributedCacheManager} and
+ * {@link TaskDistributedCacheManager}.
+ *
+ * @see org.apache.hadoop.mapred.JobConf
+ * @see org.apache.hadoop.mapred.JobClient
+ * @see org.apache.hadoop.mapreduce.Job
+ * @deprecated Use methods on {@link Job}.
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class DistributedCache extends
org.apache.hadoop.mapreduce.filecache.DistributedCache {
//
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.ipc.VersionedProtocol;
import org.apache.hadoop.mapreduce.MRJobConfig;
import org.apache.hadoop.security.KerberosInfo;
@@ -29,6 +31,8 @@ import org.apache.hadoop.security.Kerber
* NOT_TO_BE_USED_BY_USERS_DIRECTLY.
*/
@KerberosInfo(MRJobConfig.JOB_JOBTRACKER_ID)
+@InterfaceAudience.Private
+@InterfaceStability.Stable
public interface AdminOperationsProtocol extends VersionedProtocol {
/**
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/BackupStore.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/BackupStore.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/BackupStore.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/BackupStore.java Thu May 20 05:44:18 2010
@@ -28,6 +28,8 @@ import java.util.NoSuchElementException;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocalDirAllocator;
@@ -51,6 +53,8 @@ import org.apache.hadoop.mapreduce.TaskA
* file cache when the memory cache becomes full.
*
*/
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
public class BackupStore<K,V> {
private static final Log LOG = LogFactory.getLog(BackupStore.class.getName());
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ClusterStatus.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ClusterStatus.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ClusterStatus.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ClusterStatus.java Thu May 20 05:44:18 2010
@@ -24,6 +24,8 @@ import java.io.IOException;
import java.util.ArrayList;
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;
@@ -62,6 +64,8 @@ import org.apache.hadoop.mapreduce.TaskT
* @deprecated Use {@link ClusterMetrics} or {@link TaskTrackerInfo} instead
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class ClusterStatus implements Writable {
/**
* Class which encapsulates information about a blacklisted tasktracker.
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Counters.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Counters.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Counters.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/Counters.java Thu May 20 05:44:18 2010
@@ -32,6 +32,8 @@ import java.util.MissingResourceExceptio
import java.util.ResourceBundle;
import org.apache.commons.logging.*;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.io.IntWritable;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.io.Writable;
@@ -51,6 +53,8 @@ import org.apache.hadoop.util.StringUtil
* @deprecated Use {@link org.apache.hadoop.mapreduce.Counters} instead.
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class Counters implements Writable, Iterable<Counters.Group> {
private static final Log LOG = LogFactory.getLog(Counters.class);
private static final char GROUP_OPEN = '{';
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java Thu May 20 05:44:18 2010
@@ -20,11 +20,16 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* Used when target file already exists for any operation and
* is not configured to be overwritten.
*/
@Deprecated // may be removed after 0.23
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class FileAlreadyExistsException
extends IOException {
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileInputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileInputFormat.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileInputFormat.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileInputFormat.java Thu May 20 05:44:18 2010
@@ -31,6 +31,8 @@ import java.util.Set;
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.BlockLocation;
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
@@ -56,6 +58,8 @@ import org.apache.hadoop.util.StringUtil
* instead.
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public abstract class FileInputFormat<K, V> implements InputFormat<K, V> {
public static final Log LOG =
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java Thu May 20 05:44:18 2010
@@ -23,6 +23,8 @@ import java.net.URI;
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.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
@@ -30,6 +32,8 @@ import org.apache.hadoop.fs.Path;
/** An {@link OutputCommitter} that commits files specified
* in job output directory i.e. ${mapreduce.output.fileoutputformat.outputdir}.
**/
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class FileOutputCommitter extends OutputCommitter {
public static final Log LOG = LogFactory.getLog(
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputFormat.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputFormat.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileOutputFormat.java Thu May 20 05:44:18 2010
@@ -21,6 +21,8 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
import java.text.NumberFormat;
+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.io.compress.CompressionCodec;
@@ -29,6 +31,8 @@ import org.apache.hadoop.util.Progressab
import org.apache.hadoop.fs.FileAlreadyExistsException;
/** A base class for {@link OutputFormat}. */
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public abstract class FileOutputFormat<K, V> implements OutputFormat<K, V> {
/**
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileSplit.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileSplit.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileSplit.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/FileSplit.java Thu May 20 05:44:18 2010
@@ -22,6 +22,8 @@ import java.io.IOException;
import java.io.DataInput;
import java.io.DataOutput;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.fs.Path;
/** A section of an input file. Returned by {@link
@@ -31,6 +33,8 @@ import org.apache.hadoop.fs.Path;
* instead.
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class FileSplit extends org.apache.hadoop.mapreduce.InputSplit
implements InputSplit {
org.apache.hadoop.mapreduce.lib.input.FileSplit fs;
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ID.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ID.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ID.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/ID.java Thu May 20 05:44:18 2010
@@ -18,6 +18,9 @@
package org.apache.hadoop.mapred;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* A general identifier, which internally stores the id
* as an integer. This is the super class of {@link JobID},
@@ -28,6 +31,8 @@ package org.apache.hadoop.mapred;
* @see TaskAttemptID
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public abstract class ID extends org.apache.hadoop.mapreduce.ID {
/** constructs an ID object from the given int */
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFile.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFile.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFile.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFile.java Thu May 20 05:44:18 2010
@@ -24,6 +24,8 @@ import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.fs.FSDataInputStream;
import org.apache.hadoop.fs.FSDataOutputStream;
@@ -43,15 +45,12 @@ import org.apache.hadoop.io.serializer.S
/**
* <code>IFile</code> is the simple <key-len, value-len, key, value> format
* for the intermediate map-outputs in Map-Reduce.
- *
+ *
* There is a <code>Writer</code> to write out map-outputs in this format and
* a <code>Reader</code> to read files of this format.
- *
- * <FRAMEWORK-USE-ONLY>
- * This method is intended only for use by the Map/Reduce framework and not
- * for external users
- *
*/
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
public class IFile {
public static final int EOF_MARKER = -1; // End of File Marker
@@ -59,6 +58,8 @@ public class IFile {
/**
* <code>IFile.Writer</code> to write out intermediate map-outputs.
*/
+ @InterfaceAudience.Private
+ @InterfaceStability.Unstable
public static class Writer<K extends Object, V extends Object> {
FSDataOutputStream out;
boolean ownOutputStream = false;
@@ -270,6 +271,8 @@ public class IFile {
/**
* <code>IFile.Reader</code> to read intermediate map-outputs.
*/
+ @InterfaceAudience.Private
+ @InterfaceStability.Unstable
public static class Reader<K extends Object, V extends Object> {
private static final int DEFAULT_BUFFER_SIZE = 128*1024;
private static final int MAX_VINT_SIZE = 9;
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileInputStream.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileInputStream.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileInputStream.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileInputStream.java Thu May 20 05:44:18 2010
@@ -22,19 +22,17 @@ import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.fs.ChecksumException;
import org.apache.hadoop.io.IOUtils;
import org.apache.hadoop.util.DataChecksum;
/**
* A checksum input stream, used for IFiles.
* Used to validate the checksum of files created by {@link IFileOutputStream}.
- *
- * <FRAMEWORK-USE-ONLY>
- * This method is intended only for use by the Map/Reduce framework and not
- * for external users
- *
*/
-
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
public class IFileInputStream extends InputStream {
private final InputStream in; //The input stream to be verified for checksum.
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileOutputStream.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileOutputStream.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileOutputStream.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IFileOutputStream.java Thu May 20 05:44:18 2010
@@ -22,18 +22,17 @@ import java.io.IOException;
import java.io.OutputStream;
import java.io.FilterOutputStream;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.util.DataChecksum;
/**
* A Checksum output stream.
* Checksum for the contents of the file is calculated and
* appended to the end of the file on close of the stream.
* Used for IFiles
- *
- * <FRAMEWORK-USE-ONLY>
- * This method is intended only for use by the Map/Reduce framework and not
- * for external users
- *
*/
+@InterfaceAudience.Private
+@InterfaceStability.Unstable
public class IFileOutputStream extends FilterOutputStream {
/**
* The output stream to be checksummed.
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputFormat.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputFormat.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputFormat.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputFormat.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.fs.FileSystem;
/**
@@ -64,6 +66,8 @@ import org.apache.hadoop.fs.FileSystem;
* @deprecated Use {@link org.apache.hadoop.mapreduce.InputFormat} instead.
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public interface InputFormat<K, V> {
/**
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputSplit.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputSplit.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputSplit.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InputSplit.java Thu May 20 05:44:18 2010
@@ -19,6 +19,9 @@
package org.apache.hadoop.mapred;
import java.io.IOException;
+
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.io.Writable;
/**
@@ -34,6 +37,8 @@ import org.apache.hadoop.io.Writable;
* @deprecated Use {@link org.apache.hadoop.mapreduce.InputSplit} instead.
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public interface InputSplit extends Writable {
/**
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java Thu May 20 05:44:18 2010
@@ -20,6 +20,8 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.ipc.VersionedProtocol;
import org.apache.hadoop.mapreduce.MRJobConfig;
import org.apache.hadoop.security.KerberosInfo;
@@ -29,6 +31,8 @@ import org.apache.hadoop.security.Kerber
* The JobTracker is the Server, which implements this protocol.
*/
@KerberosInfo(MRJobConfig.JOB_JOBTRACKER_ID)
+@InterfaceAudience.Private
+@InterfaceStability.Stable
interface InterTrackerProtocol extends VersionedProtocol {
/**
* version 3 introduced to replace
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java Thu May 20 05:44:18 2010
@@ -20,10 +20,15 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* Used when file type differs from the desired file type. like
* getting a file when a directory is expected. Or a wrong file type.
*/
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class InvalidFileTypeException
extends IOException {
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidInputException.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidInputException.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidInputException.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidInputException.java Thu May 20 05:44:18 2010
@@ -21,11 +21,16 @@ import java.io.IOException;
import java.util.List;
import java.util.Iterator;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* This class wraps a list of problems with the input, so that the user
* can get a list of problems together instead of finding and fixing them one
* by one.
*/
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class InvalidInputException extends IOException {
private static final long serialVersionUID = 1L;
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java Thu May 20 05:44:18 2010
@@ -20,10 +20,15 @@ package org.apache.hadoop.mapred;
import java.io.IOException;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
+
/**
* This exception is thrown when jobconf misses some mendatory attributes
* or value of some attributes is invalid.
*/
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class InvalidJobConfException
extends IOException {
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IsolationRunner.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IsolationRunner.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IsolationRunner.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/IsolationRunner.java Thu May 20 05:44:18 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.security.UserGroupInformation;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.LocalDirAllocator;
import org.apache.hadoop.fs.Path;
@@ -43,6 +45,8 @@ import org.apache.hadoop.mapreduce.split
* Users may coerce MapReduce to keep task files around by setting
* mapreduce.task.files.preserve.failedtasks. See mapred_tutorial.xml for more documentation.
*/
+@InterfaceAudience.Public
+@InterfaceStability.Evolving
public class IsolationRunner {
private static final Log LOG =
LogFactory.getLog(IsolationRunner.class.getName());
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobClient.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobClient.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobClient.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobClient.java Thu May 20 05:44:18 2010
@@ -25,6 +25,8 @@ import java.util.ArrayList;
import java.util.Collection;
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.mapred.ClusterStatus.BlackListInfo;
import org.apache.hadoop.mapreduce.Cluster;
@@ -133,6 +135,8 @@ import org.apache.hadoop.util.ToolRunner
* @deprecated Use {@link Job} and {@link Cluster} instead
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class JobClient extends CLI {
public static enum TaskStatusFilter { NONE, KILLED, FAILED, SUCCEEDED, ALL }
private TaskStatusFilter taskOutputFilter = TaskStatusFilter.FAILED;
Modified: hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobConf.java
URL: http://svn.apache.org/viewvc/hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobConf.java?rev=946533&r1=946532&r2=946533&view=diff
==============================================================================
--- hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobConf.java (original)
+++ hadoop/mapreduce/branches/branch-0.21/src/java/org/apache/hadoop/mapred/JobConf.java Thu May 20 05:44:18 2010
@@ -32,6 +32,8 @@ import org.apache.hadoop.mapreduce.filec
import org.apache.hadoop.fs.FileStatus;
import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;
+import org.apache.hadoop.classification.InterfaceAudience;
+import org.apache.hadoop.classification.InterfaceStability;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.io.*;
@@ -106,6 +108,8 @@ import org.apache.log4j.Level;
* @deprecated Use {@link Configuration} instead
*/
@Deprecated
+@InterfaceAudience.Public
+@InterfaceStability.Stable
public class JobConf extends Configuration {
private static final Log LOG = LogFactory.getLog(JobConf.class);