@InterfaceAudience.Public @InterfaceStability.Stable public class OverrideRecordReader<K extends WritableComparable,V extends Writable> extends MultiFilterRecordReader<K,V>
override(S1,S2,S3)
will prefer values
from S3 over S2, and values from S2 over S1 for all keys
emitted from all sources.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 © 2024 Apache Software Foundation. All rights reserved.