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

Packages that use TezRawKeyValueIterator

Package	Description
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.orderedgrouped	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.tez.runtime.library.common.sort.impl	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.tez.runtime.library.common.sort.impl.dflt	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.
org.apache.tez.runtime.library.input	Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements.

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

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

Modifier and Type	Field and Description
protected TezRawKeyValueIterator	ValuesIterator.in

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

Constructor and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
TezRawKeyValueIterator	LocalShuffle.run()

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

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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Method and Description
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

Modifier and Type	Class and Description
protected class	DefaultSorter.MRResultIterator

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

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

Modifier and Type	Field and Description
protected TezRawKeyValueIterator	OrderedGroupedKVInput.rawIter

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

Modifier and Type	Method and Description
TezRawKeyValueIterator	OrderedGroupedInputLegacy.getIterator()