@InterfaceAudience.Public @InterfaceStability.Stable public class OverrideRecordReader<K extends WritableComparable,V extends Writable> extends MultiFilterRecordReader<K,V>
jc, kids
Modifier and Type | Method and Description |
---|---|
protected V |
emit(TupleWritable dst)
Emit the value with the highest position in the tuple.
|
protected void |
fillJoinCollector(K iterkey)
Instead of filling the JoinCollector with iterators from all
data sources, fill only the rightmost for this key.
|
combine, createValue, getDelegate, next
accept, add, close, compareTo, createInternalValue, createKey, getComparator, getConf, getPos, getProgress, getRecordReaderQueue, hasNext, id, key, key, setConf, skip
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, hasNext, id, key, key, skip
close, createKey, getPos, getProgress
compareTo
protected V emit(TupleWritable dst)
emit
in class MultiFilterRecordReader<K extends WritableComparable,V extends Writable>
protected void fillJoinCollector(K iterkey) throws IOException
fillJoinCollector
in class CompositeRecordReader<K extends WritableComparable,V extends Writable,V extends Writable>
IOException
Copyright © 2015 Apache Software Foundation. All rights reserved.