Author: acmurthy Date: Thu May 20 05:03:20 2010 New Revision: 946526 URL: http://svn.apache.org/viewvc?rev=946526&view=rev Log: MAPREDUCE-1623. Apply audience and stability notations to Hadoop Map-Reduce. Contributed by Tom White. Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/filecache/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/protocol/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/package-info.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/package-info.java Modified: hadoop/mapreduce/trunk/CHANGES.txt hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/BackupStore.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Counters.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFile.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileInputStream.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileOutputStream.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidInputException.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IsolationRunner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobClient.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConf.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConfigurable.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContext.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobEndNotifier.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobPriority.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobProfile.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueInfo.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobStatus.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JvmTask.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueLineRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueTextInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LineRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LocalJobRunner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapFileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapOutputFile.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapReduceBase.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapReducePolicyProvider.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapRunnable.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapRunner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MapTaskCompletionEventsUpdate.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Mapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Merger.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MultiFileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/MultiFileSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/OutputCollector.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/OutputCommitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/OutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/OutputLogFilter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Partitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/RawKeyValueIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/RecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/RecordWriter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ReduceTask.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Reducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Reporter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/RunningJob.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileAsBinaryInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileAsBinaryOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileAsTextInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileAsTextRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileInputFilter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SequenceFileRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/SkipBadRecords.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TIPStatus.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Task.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskAttemptContext.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskAttemptContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskAttemptID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskCompletionEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskController.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskGraphServlet.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskLog.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskLogAppender.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskLogServlet.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskReport.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskStatus.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskTracker.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskTrackerStatus.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TaskUmbilicalProtocol.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TextInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/TextOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Utils.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/jobcontrol/Job.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/jobcontrol/JobControl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/ArrayListBackedIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/ComposableInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/ComposableRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/CompositeInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/CompositeInputSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/CompositeRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/InnerJoinRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/JoinRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/MultiFilterRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/OuterJoinRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/OverrideRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/Parser.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/ResetableIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/StreamBackedIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/TupleWritable.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/join/WrappedRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/BinaryPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/ChainMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/ChainReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/CombineFileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/CombineFileRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/CombineFileSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/DelegatingInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/DelegatingMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/FieldSelectionMapReduce.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/FilterOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/HashPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/IdentityMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/IdentityReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/InputSampler.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/InverseMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedComparator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/KeyFieldBasedPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/LazyOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/LongSumReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/MultipleInputs.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/MultipleOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/MultipleOutputs.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/MultipleSequenceFileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/MultipleTextOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/MultithreadedMapRunner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/NLineInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/NullOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/RegexMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/TokenCountMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/TotalOrderPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/DoubleValueSum.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMax.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueMin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/LongValueSum.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMax.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/StringValueMin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/UniqValueCount.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/UserDefinedValueAggregatorDescriptor.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorBaseDescriptor.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorCombiner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorDescriptor.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJob.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorJobBase.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueAggregatorReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/aggregate/ValueHistogram.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/db/DBConfiguration.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/db/DBInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/db/DBOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/lib/db/DBWritable.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/pipes/Submitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/tools/MRAdmin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Cluster.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/ClusterMetrics.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Counter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/CounterGroup.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Counters.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/ID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/InputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/InputSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Job.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/JobCounter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/JobID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/JobPriority.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/JobStatus.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/JobSubmitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/MRConfig.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Mapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/MarkableIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/MarkableIteratorInterface.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/OutputCommitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/OutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Partitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/QueueAclsInfo.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/QueueInfo.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/QueueState.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/RecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/RecordWriter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/Reducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/StatusReporter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskAttemptID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCompletionEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskCounter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskID.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskReport.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskTrackerInfo.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/TaskType.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/filecache/DistributedCache.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/EventReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/HistoryViewer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobFinishedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistory.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobHistoryParser.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInfoChangeEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobInitedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobPriorityChangeEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobStatusChangedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobSubmittedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/JobUnsuccessfulCompletionEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/MapAttemptFinishedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/ReduceAttemptFinishedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptFinishedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptStartedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskAttemptUnsuccessfulCompletionEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFailedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskFinishedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskStartedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/jobhistory/TaskUpdatedEvent.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/DoubleValueSum.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMax.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueMin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/LongValueSum.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMax.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/StringValueMin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UniqValueCount.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/UserDefinedValueAggregatorDescriptor.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorBaseDescriptor.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorCombiner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorDescriptor.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJob.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorJobBase.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueAggregatorReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/aggregate/ValueHistogram.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/Chain.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/chain/ChainReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BigDecimalSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/BooleanSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBConfiguration.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DBWritable.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DataDrivenDBRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/DateSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/FloatSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/IntegerSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDBRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/MySQLDataDrivenDBRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDBRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDataDrivenDBRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/OracleDateSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/db/TextSplitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionHelper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/fieldsel/FieldSelectionReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/CombineFileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/CombineFileRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/CombineFileSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/DelegatingInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/DelegatingMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/DelegatingRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/FileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/FileSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/InvalidInputException.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/KeyValueLineRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/KeyValueTextInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/LineRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/MultipleInputs.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/NLineInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileAsBinaryInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileAsTextInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileAsTextRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileInputFilter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/SequenceFileRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/input/TextInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/jobcontrol/ControlledJob.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/jobcontrol/JobControl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/ArrayListBackedIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/ComposableInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/ComposableRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/CompositeInputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/CompositeInputSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/CompositeRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/InnerJoinRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/JoinRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/MultiFilterRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/OuterJoinRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/OverrideRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/Parser.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/ResetableIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/StreamBackedIterator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/TupleWritable.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/join/WrappedRecordReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/map/InverseMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/map/MultithreadedMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/map/RegexMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/map/TokenCounterMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/map/WrappedMapper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/FileOutputCommitter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/FileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/FilterOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/LazyOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/MapFileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/MultipleOutputs.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/NullOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/SequenceFileAsBinaryOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/SequenceFileOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/output/TextOutputFormat.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/partition/BinaryPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/partition/HashPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/partition/InputSampler.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/partition/KeyFieldBasedComparator.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/partition/KeyFieldBasedPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/partition/TotalOrderPartitioner.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/reduce/IntSumReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/reduce/LongSumReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/lib/reduce/WrappedReducer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/protocol/ClientProtocol.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/SecureShuffleUtils.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/TokenCache.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/DelegationTokenRenewal.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenIdentifier.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSecretManager.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/JobTokenSelector.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenIdentifier.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSecretManager.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/security/token/delegation/DelegationTokenSelector.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JTConfig.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/JobTrackerJspHelper.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/State.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/jobtracker/TaskTracker.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/Localizer.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/server/tasktracker/TTConfig.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplit.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/JobSplitWriter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/split/SplitMetaInfoReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/JobContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/MapContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/ReduceContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskAttemptContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/TaskInputOutputContextImpl.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryReader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/InMemoryWriter.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/MergeManager.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/Shuffle.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/task/reduce/ShuffleHeader.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/tools/CLI.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ConfigUtil.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxMemoryCalculatorPlugin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/LinuxResourceCalculatorPlugin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/MemoryCalculatorPlugin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcessTree.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ProcfsBasedProcessTree.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapreduce/util/ResourceCalculatorPlugin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/LinuxMemoryCalculatorPlugin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/MemoryCalculatorPlugin.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcessTree.java hadoop/mapreduce/trunk/src/java/org/apache/hadoop/util/ProcfsBasedProcessTree.java Modified: hadoop/mapreduce/trunk/CHANGES.txt URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/CHANGES.txt?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/CHANGES.txt (original) +++ hadoop/mapreduce/trunk/CHANGES.txt Thu May 20 05:03:20 2010 @@ -762,6 +762,9 @@ Release 0.21.0 - Unreleased MAPREDUCE-1749. Move configuration strings out of JobContext so that it can be made public stable. (omalley) + 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 Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/DistributedCache.java Thu May 20 05:03:20 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. + * + *

DistributedCache is a facility provided by the Map-Reduce + * framework to cache files (text, archives, jars etc.) needed by applications. + *

+ * + *

Applications specify the files, via urls (hdfs:// or http://) to be cached + * via the {@link org.apache.hadoop.mapred.JobConf}. The + * DistributedCache 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.

+ * + *

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.

+ * + *

DistributedCache 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.

* - * @deprecated Instead use - * {@link org.apache.hadoop.mapreduce.filecache.DistributedCache} + *

DistributedCache 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.

* + *

Here is an illustrative example on how to use the + * DistributedCache:

+ * 

+ *     // Setting up the cache for the application
+ *     
+ *     1. Copy the requisite files to the FileSystem:
+ *     
+ *     $ 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 JobConf:
+ *     
+ *     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);
+ *       }
+ *     }
+ *     
+ *

+ * + * 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 { // Added: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/package-info.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/package-info.java?rev=946526&view=auto ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/package-info.java (added) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/filecache/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. + * + */ +/** + * Deprecated. Use {@link org.apache.hadoop.mapreduce.Job} instead. + */ +@Deprecated +package org.apache.hadoop.filecache; Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/AdminOperationsProtocol.java Thu May 20 05:03:20 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.server.jobtracker.JTConfig; import org.apache.hadoop.security.KerberosInfo; @@ -30,6 +32,8 @@ import org.apache.hadoop.security.Kerber */ @KerberosInfo( serverPrincipal = JTConfig.JT_USER_NAME) +@InterfaceAudience.Private +@InterfaceStability.Stable public interface AdminOperationsProtocol extends VersionedProtocol { /** Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/BackupStore.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/BackupStore.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/BackupStore.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/BackupStore.java Thu May 20 05:03:20 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 { private static final Log LOG = LogFactory.getLog(BackupStore.class.getName()); Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ClusterStatus.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/Counters.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Counters.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Counters.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/Counters.java Thu May 20 05:03:20 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 { private static final Log LOG = LogFactory.getLog(Counters.class); private static final char GROUP_OPEN = '{'; Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileAlreadyExistsException.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/FileInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileInputFormat.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileInputFormat.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileInputFormat.java Thu May 20 05:03:20 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 implements InputFormat { public static final Log LOG = Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputCommitter.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/FileOutputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputFormat.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputFormat.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileOutputFormat.java Thu May 20 05:03:20 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 implements OutputFormat { /** Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileSplit.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileSplit.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileSplit.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/FileSplit.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/ID.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ID.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ID.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/ID.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/IFile.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFile.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFile.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFile.java Thu May 20 05:03:20 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 /** * IFile is the simple format * for the intermediate map-outputs in Map-Reduce. - * + * * There is a Writer to write out map-outputs in this format and * a Reader to read files of this format. - * - * - * 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 { /** * IFile.Writer to write out intermediate map-outputs. */ + @InterfaceAudience.Private + @InterfaceStability.Unstable public static class Writer { FSDataOutputStream out; boolean ownOutputStream = false; @@ -270,6 +271,8 @@ public class IFile { /** * IFile.Reader to read intermediate map-outputs. */ + @InterfaceAudience.Private + @InterfaceStability.Unstable public static class Reader { private static final int DEFAULT_BUFFER_SIZE = 128*1024; private static final int MAX_VINT_SIZE = 9; Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileInputStream.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileInputStream.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileInputStream.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileInputStream.java Thu May 20 05:03:20 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}. - * - * - * 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/trunk/src/java/org/apache/hadoop/mapred/IFileOutputStream.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileOutputStream.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileOutputStream.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IFileOutputStream.java Thu May 20 05:03:20 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 - * - * - * 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/trunk/src/java/org/apache/hadoop/mapred/InputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputFormat.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputFormat.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputFormat.java Thu May 20 05:03:20 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 { /** Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputSplit.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputSplit.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputSplit.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InputSplit.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InterTrackerProtocol.java Thu May 20 05:03:20 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.server.jobtracker.JTConfig; import org.apache.hadoop.mapreduce.server.tasktracker.TTConfig; @@ -32,6 +34,8 @@ import org.apache.hadoop.security.Kerber @KerberosInfo( serverPrincipal = JTConfig.JT_USER_NAME, clientPrincipal = TTConfig.TT_USER_NAME) +@InterfaceAudience.Private +@InterfaceStability.Stable interface InterTrackerProtocol extends VersionedProtocol { /** * version 3 introduced to replace Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidFileTypeException.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/InvalidInputException.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidInputException.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidInputException.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidInputException.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/InvalidJobConfException.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/IsolationRunner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IsolationRunner.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IsolationRunner.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/IsolationRunner.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.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/trunk/src/java/org/apache/hadoop/mapred/JobClient.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobClient.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobClient.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobClient.java Thu May 20 05:03:20 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/trunk/src/java/org/apache/hadoop/mapred/JobConf.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConf.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConf.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConf.java Thu May 20 05:03:20 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); Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConfigurable.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConfigurable.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConfigurable.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobConfigurable.java Thu May 20 05:03:20 2010 @@ -18,8 +18,13 @@ package org.apache.hadoop.mapred; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** That what may be configured. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface JobConfigurable { /** Initializes a new instance from a {@link JobConf}. * Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContext.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContext.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContext.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContext.java Thu May 20 05:03:20 2010 @@ -18,12 +18,16 @@ package org.apache.hadoop.mapred; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.util.Progressable; /** * @deprecated Use {@link org.apache.hadoop.mapreduce.JobContext} instead. */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public interface JobContext extends org.apache.hadoop.mapreduce.JobContext { /** * Get the job Configuration Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContextImpl.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContextImpl.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContextImpl.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobContextImpl.java Thu May 20 05:03:20 2010 @@ -17,12 +17,16 @@ package org.apache.hadoop.mapred; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.util.Progressable; /** * @deprecated Use {@link org.apache.hadoop.mapreduce.JobContext} instead. */ @Deprecated +@InterfaceAudience.Private +@InterfaceStability.Unstable public class JobContextImpl extends org.apache.hadoop.mapreduce.task.JobContextImpl implements JobContext { Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobEndNotifier.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobEndNotifier.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobEndNotifier.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobEndNotifier.java Thu May 20 05:03:20 2010 @@ -30,7 +30,11 @@ import org.apache.commons.httpclient.URI import org.apache.commons.httpclient.methods.GetMethod; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; +@InterfaceAudience.Private +@InterfaceStability.Unstable public class JobEndNotifier { private static final Log LOG = LogFactory.getLog(JobEndNotifier.class.getName()); Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobID.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobID.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobID.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobID.java Thu May 20 05:03:20 2010 @@ -21,6 +21,9 @@ package org.apache.hadoop.mapred; import java.io.DataInput; import java.io.IOException; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * JobID represents the immutable and unique identifier for * the job. JobID consists of two parts. First part @@ -39,6 +42,8 @@ import java.io.IOException; * @see TaskAttemptID */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class JobID extends org.apache.hadoop.mapreduce.JobID { /** * Constructs a JobID object Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobInProgress.java Thu May 20 05:03:20 2010 @@ -40,6 +40,8 @@ import java.util.concurrent.atomic.Atomi 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.FSDataOutputStream; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.LocalFileSystem; @@ -88,15 +90,13 @@ import org.apache.hadoop.security.token. import org.apache.hadoop.security.token.TokenIdentifier; import org.apache.hadoop.util.StringUtils; -/************************************************************* - * JobInProgress maintains all the info for keeping - * a Job on the straight and narrow. It keeps its JobProfile - * and its latest JobStatus, plus a set of tables for - * doing bookkeeping of its Tasks. - * *********************************************************** - * - * This is NOT a public interface! +/** + * JobInProgress maintains all the info for keeping a Job on the straight and + * narrow. It keeps its JobProfile and its latest JobStatus, plus a set of + * tables for doing bookkeeping of its Tasks. */ +@InterfaceAudience.LimitedPrivate({"MapReduce"}) +@InterfaceStability.Unstable public class JobInProgress { /** * Used when the a kill is issued to a job which is initializing. Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobPriority.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobPriority.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobPriority.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobPriority.java Thu May 20 05:03:20 2010 @@ -17,11 +17,16 @@ */ package org.apache.hadoop.mapred; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; + /** * Used to describe the priority of the running job. * @deprecated Use {@link org.apache.hadoop.mapreduce.JobPriority} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public enum JobPriority { VERY_HIGH, Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobProfile.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobProfile.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobProfile.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobProfile.java Thu May 20 05:03:20 2010 @@ -22,6 +22,8 @@ import java.io.DataOutput; import java.io.IOException; import java.net.URL; +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.WritableFactories; @@ -32,6 +34,8 @@ import org.apache.hadoop.io.WritableFact * whether living or dead. * **************************************************/ +@InterfaceAudience.LimitedPrivate({"MapReduce"}) +@InterfaceStability.Unstable public class JobProfile implements Writable { static { // register a ctor Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueInfo.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueInfo.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueInfo.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobQueueInfo.java Thu May 20 05:03:20 2010 @@ -21,6 +21,8 @@ import java.util.ArrayList; import java.util.List; import java.util.Properties; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapreduce.QueueInfo; import org.apache.hadoop.mapreduce.QueueState; @@ -30,6 +32,8 @@ import org.apache.hadoop.mapreduce.Queue * @deprecated Use {@link QueueInfo} instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class JobQueueInfo extends QueueInfo { /** Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobStatus.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobStatus.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobStatus.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobStatus.java Thu May 20 05:03:20 2010 @@ -19,6 +19,8 @@ package org.apache.hadoop.mapred; import java.util.Map; +import org.apache.hadoop.classification.InterfaceAudience; +import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.mapreduce.JobACL; import org.apache.hadoop.security.authorize.AccessControlList; @@ -30,6 +32,8 @@ import org.apache.hadoop.security.author *@deprecated Use {@link org.apache.hadoop.mapreduce.JobStatus} instead **/ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class JobStatus extends org.apache.hadoop.mapreduce.JobStatus { public static final int RUNNING = Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JobTracker.java Thu May 20 05:03:20 2010 @@ -52,6 +52,8 @@ import java.util.concurrent.CopyOnWriteA 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.FSDataInputStream; import org.apache.hadoop.fs.FSDataOutputStream; @@ -111,6 +113,8 @@ import org.apache.hadoop.util.VersionInf * tracking MR jobs in a network environment. * *******************************************************/ +@InterfaceAudience.Private +@InterfaceStability.Unstable public class JobTracker implements MRConstants, InterTrackerProtocol, ClientProtocol, TaskTrackerManager, RefreshUserToGroupMappingsProtocol, RefreshAuthorizationPolicyProtocol, AdminOperationsProtocol, JTConfig { @@ -148,6 +152,8 @@ public class JobTracker implements MRCon private final float MIN_HEARTBEATS_SCALING_FACTOR = 0.01f; private final float DEFAULT_HEARTBEATS_SCALING_FACTOR = 1.0f; + @InterfaceAudience.Private + @InterfaceStability.Unstable public static enum State { INITIALIZING, RUNNING } State state = State.INITIALIZING; private static final int FS_ACCESS_RETRY_PERIOD = 10000; @@ -188,6 +194,8 @@ public class JobTracker implements MRCon /** * A client tried to submit a job before the Job Tracker was ready. */ + @InterfaceAudience.Private + @InterfaceStability.Unstable public static class IllegalStateException extends IOException { private static final long serialVersionUID = 1L; Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JvmTask.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JvmTask.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JvmTask.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/JvmTask.java Thu May 20 05:03:20 2010 @@ -21,16 +21,16 @@ package org.apache.hadoop.mapred; 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; /** - * Task abstraction that can be serialized, implements the writable interface - * - * - * This method is intended only for use by the Map/Reduce framework and not - * for external users - * + * Task abstraction that can be serialized, implements the writable interface. */ +@InterfaceAudience.Private +@InterfaceStability.Unstable public class JvmTask implements Writable { Task t; boolean shouldDie; Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueLineRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueLineRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueLineRecordReader.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueLineRecordReader.java Thu May 20 05:03:20 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.conf.Configuration; import org.apache.hadoop.io.LongWritable; import org.apache.hadoop.io.Text; @@ -35,6 +37,8 @@ import org.apache.hadoop.io.Text; * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class KeyValueLineRecordReader implements RecordReader { private final LineRecordReader lineRecordReader; Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueTextInputFormat.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueTextInputFormat.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueTextInputFormat.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/KeyValueTextInputFormat.java Thu May 20 05:03:20 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; import org.apache.hadoop.fs.Path; import org.apache.hadoop.io.Text; @@ -38,6 +40,8 @@ import org.apache.hadoop.io.compress.Spl * instead */ @Deprecated +@InterfaceAudience.Public +@InterfaceStability.Stable public class KeyValueTextInputFormat extends FileInputFormat implements JobConfigurable { Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LineRecordReader.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LineRecordReader.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LineRecordReader.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LineRecordReader.java Thu May 20 05:03:20 2010 @@ -21,6 +21,8 @@ package org.apache.hadoop.mapred; 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.FileSystem; @@ -43,6 +45,8 @@ import org.apache.commons.logging.Log; * {@link org.apache.hadoop.mapreduce.lib.input.LineRecordReader} instead. */ @Deprecated +@InterfaceAudience.LimitedPrivate({"MapReduce", "Pig"}) +@InterfaceStability.Unstable public class LineRecordReader implements RecordReader { private static final Log LOG = LogFactory.getLog(LineRecordReader.class.getName()); Modified: hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LocalJobRunner.java URL: http://svn.apache.org/viewvc/hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LocalJobRunner.java?rev=946526&r1=946525&r2=946526&view=diff ============================================================================== --- hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LocalJobRunner.java (original) +++ hadoop/mapreduce/trunk/src/java/org/apache/hadoop/mapred/LocalJobRunner.java Thu May 20 05:03:20 2010 @@ -34,6 +34,8 @@ import java.util.concurrent.atomic.Atomi 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; @@ -59,7 +61,9 @@ import org.apache.hadoop.mapreduce.split import org.apache.hadoop.security.UserGroupInformation; import org.apache.hadoop.security.token.Token; -/** Implements MapReduce locally, in-process, for debugging. */ +/** Implements MapReduce locally, in-process, for debugging. */ +@InterfaceAudience.Private +@InterfaceStability.Unstable public class LocalJobRunner implements ClientProtocol { public static final Log LOG = LogFactory.getLog(LocalJobRunner.class);