META-INF/MANIFEST.MF
META-INF/NOTICE.txt
META-INF/LICENSE.txt
org/apache/hadoop/fi/ProbabilityModel.java
org/apache/hadoop/fi/FiConfig.java
org/apache/hadoop/FailMapper.java
org/apache/hadoop/io/TestSequenceFileMergeProgress.java
org/apache/hadoop/io/FileBench.java
org/apache/hadoop/conf/TestNoDefaultsJobConf.java
org/apache/hadoop/FailingMapper.java
org/apache/hadoop/mapreduce/EntityWriterV2.java
org/apache/hadoop/mapreduce/TimelineServicePerformance.java
org/apache/hadoop/mapreduce/TestValueIterReset.java
org/apache/hadoop/mapreduce/GrowingSleepJob.java
org/apache/hadoop/mapreduce/TestTaskContext.java
org/apache/hadoop/mapreduce/JobHistoryFileParser.java
org/apache/hadoop/mapreduce/filecache/TestURIFragments.java
org/apache/hadoop/mapreduce/MapReduceTestUtil.java
org/apache/hadoop/mapreduce/TimelineEntityConverterV2.java
org/apache/hadoop/mapreduce/v2/TestNonExistentJob.java
org/apache/hadoop/mapreduce/v2/TestMRJobsWithProfiler.java
org/apache/hadoop/mapreduce/v2/TestRMNMInfo.java
org/apache/hadoop/mapreduce/v2/TestMROldApiJobs.java
org/apache/hadoop/mapreduce/v2/MiniMRYarnCluster.java
org/apache/hadoop/mapreduce/v2/TestSpeculativeExecution.java
org/apache/hadoop/mapreduce/v2/TestMRAMWithNonNormalizedCapabilities.java
org/apache/hadoop/mapreduce/v2/TestSpeculativeExecutionWithMRApp.java
org/apache/hadoop/mapreduce/v2/TestMiniMRProxyUser.java
org/apache/hadoop/mapreduce/v2/TestMRJobs.java
org/apache/hadoop/mapreduce/v2/TestMRAppWithCombiner.java
org/apache/hadoop/mapreduce/v2/TestUberAM.java
org/apache/hadoop/mapreduce/v2/TestMRJobsWithHistoryService.java
org/apache/hadoop/mapreduce/TestMROutputFormat.java
org/apache/hadoop/mapreduce/TestLocalRunner.java
org/apache/hadoop/mapreduce/lib/db/TestDataDrivenDBInputFormat.java
org/apache/hadoop/mapreduce/lib/db/TestDBOutputFormat.java
org/apache/hadoop/mapreduce/lib/db/TestTextSplitter.java
org/apache/hadoop/mapreduce/lib/db/TestIntegerSplitter.java
org/apache/hadoop/mapreduce/lib/partition/TestMRKeyFieldBasedPartitioner.java
org/apache/hadoop/mapreduce/lib/partition/TestInputSampler.java
org/apache/hadoop/mapreduce/lib/partition/TestMRKeyFieldBasedComparator.java
org/apache/hadoop/mapreduce/lib/partition/TestKeyFieldHelper.java
org/apache/hadoop/mapreduce/lib/partition/TestBinaryPartitioner.java
org/apache/hadoop/mapreduce/lib/partition/TestTotalOrderPartitioner.java
org/apache/hadoop/mapreduce/lib/map/TestMultithreadedMapper.java
org/apache/hadoop/mapreduce/lib/chain/TestChainErrors.java
org/apache/hadoop/mapreduce/lib/chain/TestSingleElementChain.java
org/apache/hadoop/mapreduce/lib/chain/TestMapReduceChain.java
org/apache/hadoop/mapreduce/lib/output/TestMRMultipleOutputs.java
org/apache/hadoop/mapreduce/lib/output/TestMRSequenceFileAsBinaryOutputFormat.java
org/apache/hadoop/mapreduce/lib/output/TestMRCJCFileOutputCommitter.java
org/apache/hadoop/mapreduce/lib/output/TestJobOutputCommitter.java
org/apache/hadoop/mapreduce/lib/input/TestDelegatingInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestMRCJCFileInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestMRSequenceFileAsTextInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestMRSequenceFileInputFilter.java
org/apache/hadoop/mapreduce/lib/input/TestCombineTextInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestMRKeyValueTextInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestLineRecordReaderJobs.java
org/apache/hadoop/mapreduce/lib/input/TestFixedLengthInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestCombineFileInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestNLineInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestMRSequenceFileAsBinaryInputFormat.java
org/apache/hadoop/mapreduce/lib/input/TestMultipleInputs.java
org/apache/hadoop/mapreduce/lib/input/TestCombineSequenceFileInputFormat.java
org/apache/hadoop/mapreduce/lib/fieldsel/TestMRFieldSelection.java
org/apache/hadoop/mapreduce/lib/aggregate/TestMapReduceAggregates.java
org/apache/hadoop/mapreduce/lib/aggregate/AggregatorTests.java
org/apache/hadoop/mapreduce/lib/jobcontrol/TestMapReduceJobControlWithMocks.java
org/apache/hadoop/mapreduce/lib/jobcontrol/TestMapReduceJobControl.java
org/apache/hadoop/mapreduce/lib/jobcontrol/TestControlledJob.java
org/apache/hadoop/mapreduce/lib/join/TestWrappedRRClassloader.java
org/apache/hadoop/mapreduce/lib/join/TestJoinProperties.java
org/apache/hadoop/mapreduce/lib/join/TestJoinTupleWritable.java
org/apache/hadoop/mapreduce/lib/join/TestJoinDatamerge.java
org/apache/hadoop/mapreduce/security/CredentialsTestJob.java
org/apache/hadoop/mapreduce/security/TestMRCredentials.java
org/apache/hadoop/mapreduce/security/TestJHSSecurity.java
org/apache/hadoop/mapreduce/security/token/delegation/TestDelegationToken.java
org/apache/hadoop/mapreduce/security/ssl/TestEncryptedShuffle.java
org/apache/hadoop/mapreduce/security/TestUmbilicalProtocolWithJobToken.java
org/apache/hadoop/mapreduce/security/TestBinaryTokenFile.java
org/apache/hadoop/mapreduce/TestYarnClientProtocolProvider.java
org/apache/hadoop/mapreduce/TestMapReduce.java
org/apache/hadoop/mapreduce/TimelineEntityConverterV1.java
org/apache/hadoop/mapreduce/TestMapCollection.java
org/apache/hadoop/mapreduce/MiniHadoopClusterManager.java
org/apache/hadoop/mapreduce/RandomWriter.java
org/apache/hadoop/mapreduce/TestLargeSort.java
org/apache/hadoop/mapreduce/FailJob.java
org/apache/hadoop/mapreduce/util/MRAsyncDiskService.java
org/apache/hadoop/mapreduce/util/TestMRAsyncDiskService.java
org/apache/hadoop/mapreduce/TestChild.java
org/apache/hadoop/mapreduce/TestClientProtocolProviderImpls.java
org/apache/hadoop/mapreduce/SleepJob.java
org/apache/hadoop/mapreduce/JobHistoryFileReplayMapperV1.java
org/apache/hadoop/mapreduce/JobHistoryFileReplayHelper.java
org/apache/hadoop/mapreduce/TestMapperReducerCleanup.java
org/apache/hadoop/mapreduce/SimpleEntityWriterConstants.java
org/apache/hadoop/mapreduce/GenericMRLoadGenerator.java
org/apache/hadoop/mapreduce/TestNoJobSetupCleanup.java
org/apache/hadoop/mapreduce/TestMapReduceLazyOutput.java
org/apache/hadoop/mapreduce/TestMRJobClient.java
org/apache/hadoop/mapreduce/LargeSorter.java
org/apache/hadoop/mapreduce/SimpleEntityWriterV1.java
org/apache/hadoop/mapreduce/SimpleEntityWriterV2.java
org/apache/hadoop/mapreduce/TestCounters.java
org/apache/hadoop/mapreduce/JobHistoryFileReplayMapperV2.java
org/apache/hadoop/mapreduce/TestNewCombinerGrouping.java
org/apache/hadoop/mapreduce/RandomTextWriter.java
org/apache/hadoop/util/TestMRCJCReflectionUtils.java
org/apache/hadoop/util/TestMRCJCRunJar.java
org/apache/hadoop/util/Hello.java
org/apache/hadoop/fs/TestDFSIO.java
org/apache/hadoop/fs/TestJHLA.java
org/apache/hadoop/fs/DFSCIOTest.java
org/apache/hadoop/fs/DistributedFSCheck.java
org/apache/hadoop/fs/JHLogAnalyzer.java
org/apache/hadoop/fs/loadGenerator/LoadGeneratorMR.java
org/apache/hadoop/fs/slive/OperationData.java
org/apache/hadoop/fs/slive/DataHasher.java
org/apache/hadoop/fs/slive/CreateOp.java
org/apache/hadoop/fs/slive/Constants.java
org/apache/hadoop/fs/slive/MkdirOp.java
org/apache/hadoop/fs/slive/Helper.java
org/apache/hadoop/fs/slive/ListOp.java
org/apache/hadoop/fs/slive/ReadOp.java
org/apache/hadoop/fs/slive/ConfigExtractor.java
org/apache/hadoop/fs/slive/OperationWeight.java
org/apache/hadoop/fs/slive/AppendOp.java
org/apache/hadoop/fs/slive/SleepOp.java
org/apache/hadoop/fs/slive/Operation.java
org/apache/hadoop/fs/slive/RouletteSelector.java
org/apache/hadoop/fs/slive/DataWriter.java
org/apache/hadoop/fs/slive/DataVerifier.java
org/apache/hadoop/fs/slive/SliveReducer.java
org/apache/hadoop/fs/slive/Range.java
org/apache/hadoop/fs/slive/TestSlive.java
org/apache/hadoop/fs/slive/TruncateOp.java
org/apache/hadoop/fs/slive/DeleteOp.java
org/apache/hadoop/fs/slive/PathFinder.java
org/apache/hadoop/fs/slive/WeightSelector.java
org/apache/hadoop/fs/slive/Formatter.java
org/apache/hadoop/fs/slive/Weights.java
org/apache/hadoop/fs/slive/ReportWriter.java
org/apache/hadoop/fs/slive/BadFileException.java
org/apache/hadoop/fs/slive/Timer.java
org/apache/hadoop/fs/slive/ArgumentParser.java
org/apache/hadoop/fs/slive/RenameOp.java
org/apache/hadoop/fs/slive/DummyInputFormat.java
org/apache/hadoop/fs/slive/ConfigOption.java
org/apache/hadoop/fs/slive/ObserveableOp.java
org/apache/hadoop/fs/slive/ConfigMerger.java
org/apache/hadoop/fs/slive/SlivePartitioner.java
org/apache/hadoop/fs/slive/SliveMapper.java
org/apache/hadoop/fs/slive/SliveTest.java
org/apache/hadoop/fs/slive/OperationFactory.java
org/apache/hadoop/fs/slive/OperationOutput.java
org/apache/hadoop/fs/IOMapperBase.java
org/apache/hadoop/fs/AccumulatingReducer.java
org/apache/hadoop/fs/TestFileSystem.java
org/apache/hadoop/ipc/TestMRCJCSocketFactory.java
org/apache/hadoop/test/MapredTestDriver.java
org/apache/hadoop/mapred/TestMROpportunisticMaps.java
org/apache/hadoop/mapred/MRBench.java
org/apache/hadoop/mapred/MiniMRCluster.java
org/apache/hadoop/mapred/TestMRCJCJobConf.java
org/apache/hadoop/mapred/TestTextInputFormat.java
org/apache/hadoop/mapred/TestMRCJCJobClient.java
org/apache/hadoop/mapred/TestSpecialCharactersInOutputPath.java
org/apache/hadoop/mapred/pipes/TestPipes.java
org/apache/hadoop/mapred/pipes/PipeReducerStub.java
org/apache/hadoop/mapred/pipes/PipeApplicationStub.java
org/apache/hadoop/mapred/pipes/TestPipesNonJavaInputFormat.java
org/apache/hadoop/mapred/pipes/CommonStub.java
org/apache/hadoop/mapred/pipes/WordCountInputFormat.java
org/apache/hadoop/mapred/pipes/TestPipeApplication.java
org/apache/hadoop/mapred/pipes/PipeApplicationRunnableStub.java
org/apache/hadoop/mapred/TestJobCounters.java
org/apache/hadoop/mapred/TestOldCombinerGrouping.java
org/apache/hadoop/mapred/TestJobName.java
org/apache/hadoop/mapred/TestNetworkedJob.java
org/apache/hadoop/mapred/MRCaching.java
org/apache/hadoop/mapred/TestQueueConfigurationParser.java
org/apache/hadoop/mapred/TestCollect.java
org/apache/hadoop/mapred/WordCount.java
org/apache/hadoop/mapred/TestMRCJCFileInputFormat.java
org/apache/hadoop/mapred/TestJobSysDirWithDFS.java
org/apache/hadoop/mapred/TestMapOutputType.java
org/apache/hadoop/mapred/TestTextOutputFormat.java
org/apache/hadoop/mapred/MiniMRYarnClusterAdapter.java
org/apache/hadoop/mapred/lib/TestChainMapReduce.java
org/apache/hadoop/mapred/lib/TestDelegatingInputFormat.java
org/apache/hadoop/mapred/lib/db/TestConstructQuery.java
org/apache/hadoop/mapred/lib/TestKeyFieldBasedComparator.java
org/apache/hadoop/mapred/lib/TestKeyFieldBasedPartitioner.java
org/apache/hadoop/mapred/lib/TestLineInputFormat.java
org/apache/hadoop/mapred/lib/aggregate/TestAggregates.java
org/apache/hadoop/mapred/lib/aggregate/AggregatorTests.java
org/apache/hadoop/mapred/lib/TestChain.java
org/apache/hadoop/mapred/lib/TestMultithreadedMapRunner.java
org/apache/hadoop/mapred/lib/TestMultipleOutputs.java
org/apache/hadoop/mapred/lib/TestMultipleInputs.java
org/apache/hadoop/mapred/TestClusterMapReduceTestCase.java
org/apache/hadoop/mapred/ThreadedMapBenchmark.java
org/apache/hadoop/mapred/EmptyInputFormat.java
org/apache/hadoop/mapred/TestCombineOutputCollector.java
org/apache/hadoop/mapred/TestClientServiceDelegate.java
org/apache/hadoop/mapred/TestFieldSelection.java
org/apache/hadoop/mapred/ReliabilityTest.java
org/apache/hadoop/mapred/TestSequenceFileAsTextInputFormat.java
org/apache/hadoop/mapred/TestCombineTextInputFormat.java
org/apache/hadoop/mapred/HadoopTestCase.java
org/apache/hadoop/mapred/TestSortedRanges.java
org/apache/hadoop/mapred/TestMiniMRClasspath.java
org/apache/hadoop/mapred/TestIFileStreams.java
org/apache/hadoop/mapred/TestLocalMRNotification.java
org/apache/hadoop/mapred/TestUserDefinedCounters.java
org/apache/hadoop/mapred/TestSequenceFileAsBinaryOutputFormat.java
org/apache/hadoop/mapred/TestInputPath.java
org/apache/hadoop/mapred/TestMerge.java
org/apache/hadoop/mapred/TestReduceFetchFromPartialMem.java
org/apache/hadoop/mapred/UtilsForTests.java
org/apache/hadoop/mapred/TestJobCleanup.java
org/apache/hadoop/mapred/MiniMRClientClusterFactory.java
org/apache/hadoop/mapred/TestReduceFetch.java
org/apache/hadoop/mapred/TestStatisticsCollector.java
org/apache/hadoop/mapred/TestMapProgress.java
org/apache/hadoop/mapred/TestSequenceFileInputFormat.java
org/apache/hadoop/mapred/TestClusterMRNotification.java
org/apache/hadoop/mapred/ClusterMapReduceTestCase.java
org/apache/hadoop/mapred/TestYARNRunner.java
org/apache/hadoop/mapred/TestLineRecordReaderJobs.java
org/apache/hadoop/mapred/TestMultipleTextOutputFormat.java
org/apache/hadoop/mapred/TestFixedLengthInputFormat.java
org/apache/hadoop/mapred/TestBadRecords.java
org/apache/hadoop/mapred/TestComparators.java
org/apache/hadoop/mapred/TestWritableJobConf.java
org/apache/hadoop/mapred/TestIFile.java
#内容未全部加载,请点击展开加载全部代码(NowJava.com)
|