Uses of Interface
org.apache.tez.runtime.library.common.sort.impl.TezRawKeyValueIterator

Packages that use TezRawKeyValueIterator

org.apache.tez.runtime.library.common
org.apache.tez.runtime.library.common.combine
org.apache.tez.runtime.library.common.localshuffle
org.apache.tez.runtime.library.common.shuffle.impl
org.apache.tez.runtime.library.common.sort.impl
org.apache.tez.runtime.library.common.sort.impl.dflt
org.apache.tez.runtime.library.common.task.impl
org.apache.tez.runtime.library.input

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common

Fields in org.apache.tez.runtime.library.common declared as TezRawKeyValueIterator

protected TezRawKeyValueIterator

ValuesIterator.in

Constructors in org.apache.tez.runtime.library.common with parameters of type TezRawKeyValueIterator

ValuesIterator(TezRawKeyValueIterator in, org.apache.hadoop.io.RawComparator<KEY> comparator, Class<KEY> keyClass, Class<VALUE> valClass, org.apache.hadoop.conf.Configuration conf, org.apache.tez.common.counters.TezCounter inputKeyCounter, org.apache.tez.common.counters.TezCounter inputValueCounter)

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common.combine

Methods in org.apache.tez.runtime.library.common.combine with parameters of type TezRawKeyValueIterator

void	Combiner.combine(TezRawKeyValueIterator rawIter, IFile.Writer writer)

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common.localshuffle

Methods in org.apache.tez.runtime.library.common.localshuffle that return TezRawKeyValueIterator

TezRawKeyValueIterator

LocalShuffle.run()

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common.shuffle.impl

Methods in org.apache.tez.runtime.library.common.shuffle.impl that return TezRawKeyValueIterator

TezRawKeyValueIterator	MergeManager.close()
TezRawKeyValueIterator	Shuffle.waitForInput() Waits for the Shuffle and Merge to complete, and returns an iterator over the input.

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common.sort.impl

Methods in org.apache.tez.runtime.library.common.sort.impl that return TezRawKeyValueIterator

static TezRawKeyValueIterator	TezMerger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class keyClass, Class valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength, int ifileBufferSize, org.apache.hadoop.fs.Path[] inputs, boolean deleteInputs, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator comparator, org.apache.hadoop.util.Progressable reporter, org.apache.tez.common.counters.TezCounter readsCounter, org.apache.tez.common.counters.TezCounter writesCounter, org.apache.tez.common.counters.TezCounter bytesReadCounter, org.apache.hadoop.util.Progress mergePhase)
static TezRawKeyValueIterator	TezMerger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class keyClass, Class valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, boolean ifileReadAhead, int ifileReadAheadLength, int ifileBufferSize, org.apache.hadoop.fs.Path[] inputs, boolean deleteInputs, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator comparator, org.apache.hadoop.util.Progressable reporter, org.apache.tez.common.counters.TezCounter readsCounter, org.apache.tez.common.counters.TezCounter writesCounter, org.apache.tez.common.counters.TezCounter mergedMapOutputsCounter, org.apache.tez.common.counters.TezCounter bytesReadCounter, org.apache.hadoop.util.Progress mergePhase)
static <K,V> TezRawKeyValueIterator	TezMerger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class keyClass, Class valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, List<TezMerger.Segment> segments, int mergeFactor, int inMemSegments, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, org.apache.tez.common.counters.TezCounter readsCounter, org.apache.tez.common.counters.TezCounter writesCounter, org.apache.tez.common.counters.TezCounter bytesReadCounter, org.apache.hadoop.util.Progress mergePhase)
static <K,V> TezRawKeyValueIterator	TezMerger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class keyClass, Class valueClass, org.apache.hadoop.io.compress.CompressionCodec codec, List<TezMerger.Segment> segments, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, boolean considerFinalMergeForProgress, org.apache.tez.common.counters.TezCounter readsCounter, org.apache.tez.common.counters.TezCounter writesCounter, org.apache.tez.common.counters.TezCounter bytesReadCounter, org.apache.hadoop.util.Progress mergePhase)
static <K,V> TezRawKeyValueIterator	TezMerger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class keyClass, Class valueClass, List<TezMerger.Segment> segments, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator comparator, org.apache.hadoop.util.Progressable reporter, boolean sortSegments, org.apache.tez.common.counters.TezCounter readsCounter, org.apache.tez.common.counters.TezCounter writesCounter, org.apache.tez.common.counters.TezCounter bytesReadCounter, org.apache.hadoop.util.Progress mergePhase)
static TezRawKeyValueIterator	TezMerger.merge(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, Class keyClass, Class valueClass, List<TezMerger.Segment> segments, int mergeFactor, org.apache.hadoop.fs.Path tmpDir, org.apache.hadoop.io.RawComparator comparator, org.apache.hadoop.util.Progressable reporter, org.apache.tez.common.counters.TezCounter readsCounter, org.apache.tez.common.counters.TezCounter writesCounter, org.apache.tez.common.counters.TezCounter bytesReadCounter, org.apache.hadoop.util.Progress mergePhase)

Methods in org.apache.tez.runtime.library.common.sort.impl with parameters of type TezRawKeyValueIterator

protected void	ExternalSorter.runCombineProcessor(TezRawKeyValueIterator kvIter, IFile.Writer writer)
static <K,V> void	TezMerger.writeFile(TezRawKeyValueIterator records, IFile.Writer writer, org.apache.hadoop.util.Progressable progressable, long recordsBeforeProgress)

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common.sort.impl.dflt

Classes in org.apache.tez.runtime.library.common.sort.impl.dflt that implement TezRawKeyValueIterator

protected class

DefaultSorter.MRResultIterator

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.common.task.impl

Fields in org.apache.tez.runtime.library.common.task.impl declared as TezRawKeyValueIterator

protected TezRawKeyValueIterator

ValuesIterator.in

Constructors in org.apache.tez.runtime.library.common.task.impl with parameters of type TezRawKeyValueIterator

ValuesIterator(TezRawKeyValueIterator in, org.apache.hadoop.io.RawComparator<KEY> comparator, Class<KEY> keyClass, Class<VALUE> valClass, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.util.Progressable reporter)

Uses of TezRawKeyValueIterator in org.apache.tez.runtime.library.input

Fields in org.apache.tez.runtime.library.input declared as TezRawKeyValueIterator

protected TezRawKeyValueIterator

ShuffledMergedInput.rawIter

Methods in org.apache.tez.runtime.library.input that return TezRawKeyValueIterator

TezRawKeyValueIterator

ShuffledMergedInputLegacy.getIterator()