@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.Modifier and Type | Method and Description |
---|---|
V |
createValue()
Create instance of value.
|
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, getDelegate, initialize, nextKeyValue
accept, add, close, compareTo, createKey, createTupleWritable, getComparator, getConf, getCurrentKey, getCurrentValue, getProgress, getRecordReaderQueue, hasNext, id, key, key, setConf, skip
protected V emit(TupleWritable dst)
emit
in class MultiFilterRecordReader<K extends WritableComparable<?>,V extends Writable>
public V createValue()
ComposableRecordReader
protected void fillJoinCollector(K iterkey) throws IOException, InterruptedException
fillJoinCollector
in class CompositeRecordReader<K extends WritableComparable<?>,V extends Writable,V extends Writable>
IOException
InterruptedException
Copyright © 2024 Apache Software Foundation. All rights reserved.