Uses of Interface
org.apache.hadoop.mapred.RawKeyValueIterator

Packages that use RawKeyValueIterator
org.apache.hadoop.mapred   
org.apache.hadoop.mapreduce.task   
org.apache.hadoop.mapreduce.task.reduce   
 

Uses of RawKeyValueIterator in org.apache.hadoop.mapred
 

Classes in org.apache.hadoop.mapred that implement RawKeyValueIterator
protected  class MapTask.MapOutputBuffer.MRResultIterator
           
 

Methods in org.apache.hadoop.mapred that return RawKeyValueIterator
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, List<Merger.Segment<K,V>> segments, int mergeFactor, int inMemSegments, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, Counters.Counter readsCounter, Counters.Counter writesCounter, org.apache.hadoop.util.Progress mergePhase)
           
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, List<Merger.Segment<K,V>> segments, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, Counters.Counter readsCounter, Counters.Counter writesCounter, org.apache.hadoop.util.Progress mergePhase)
           
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, org.apache.hadoop.fs.Path[] inputs, boolean deleteInputs, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, Counters.Counter readsCounter, Counters.Counter writesCounter, Counters.Counter mergedMapOutputsCounter, org.apache.hadoop.util.Progress mergePhase)
           
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, org.apache.hadoop.fs.Path[] inputs, boolean deleteInputs, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, Counters.Counter readsCounter, Counters.Counter writesCounter, org.apache.hadoop.util.Progress mergePhase)
           
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, List<Merger.Segment<K,V>> segments, int mergeFactor, int inMemSegments, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, Counters.Counter readsCounter, Counters.Counter writesCounter, org.apache.hadoop.util.Progress mergePhase)
           
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, List<Merger.Segment<K,V>> segments, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, Counters.Counter readsCounter, Counters.Counter writesCounter, org.apache.hadoop.util.Progress mergePhase)
           
static
<K,V> RawKeyValueIterator
Merger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class<K> keyClass, Class<V> valueClass, List<Merger.Segment<K,V>> segments, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator<K> comparator, org.apache.hadoop.util.Progressable reporter, Counters.Counter readsCounter, Counters.Counter writesCounter, org.apache.hadoop.util.Progress mergePhase)
           
 RawKeyValueIterator ShuffleConsumerPlugin.run()
           
 

Methods in org.apache.hadoop.mapred with parameters of type RawKeyValueIterator
abstract  void Task.CombinerRunner.combine(RawKeyValueIterator iterator, OutputCollector<K,V> collector)
          Run the combiner over a set of inputs.
 void Task.OldCombinerRunner.combine(RawKeyValueIterator kvIter, OutputCollector<K,V> combineCollector)
           
 void Task.NewCombinerRunner.combine(RawKeyValueIterator iterator, OutputCollector<K,V> collector)
           
protected static
<INKEY,INVALUE,OUTKEY,OUTVALUE>
Reducer.Context
Task.createReduceContext(Reducer<INKEY,INVALUE,OUTKEY,OUTVALUE> reducer, org.apache.hadoop.conf.Configuration job, TaskAttemptID taskId, RawKeyValueIterator rIter, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<OUTKEY,OUTVALUE> output, OutputCommitter committer, StatusReporter reporter, org.apache.hadoop.io.RawComparator<INKEY> comparator, Class<INKEY> keyClass, Class<INVALUE> valueClass)
           
static
<K,V> void
Merger.writeFile(RawKeyValueIterator records, IFile.Writer<K,V> writer, org.apache.hadoop.util.Progressable progressable, org.apache.hadoop.conf.Configuration conf)
           
 

Constructors in org.apache.hadoop.mapred with parameters of type RawKeyValueIterator
Task.CombineValuesIterator(RawKeyValueIterator in, org.apache.hadoop.io.RawComparator<KEY> comparator, Class<KEY> keyClass, Class<VALUE> valClass, org.apache.hadoop.conf.Configuration conf, Reporter reporter, Counters.Counter combineInputCounter)
           
 

Uses of RawKeyValueIterator in org.apache.hadoop.mapreduce.task
 

Constructors in org.apache.hadoop.mapreduce.task with parameters of type RawKeyValueIterator
ReduceContextImpl(org.apache.hadoop.conf.Configuration conf, TaskAttemptID taskid, RawKeyValueIterator input, Counter inputKeyCounter, Counter inputValueCounter, RecordWriter<KEYOUT,VALUEOUT> output, OutputCommitter committer, StatusReporter reporter, org.apache.hadoop.io.RawComparator<KEYIN> comparator, Class<KEYIN> keyClass, Class<VALUEIN> valueClass)
           
 

Uses of RawKeyValueIterator in org.apache.hadoop.mapreduce.task.reduce
 

Methods in org.apache.hadoop.mapreduce.task.reduce that return RawKeyValueIterator
 RawKeyValueIterator MergeManagerImpl.close()
           
 RawKeyValueIterator MergeManager.close()
          Called at the end of shuffle.
 RawKeyValueIterator Shuffle.run()
           
 



Copyright © 2014 Apache Software Foundation. All Rights Reserved.