public class OverrideRecordReader<K extends WritableComparable,V extends Writable> extends MultiFilterRecordReader<K,V>
MultiFilterRecordReader.MultiFilterDelegationIterator
jc, kids
限定符和类型 | 方法和说明 |
---|---|
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
close, createKey, getPos, getProgress
compareTo
protected V emit(TupleWritable dst)
emit
在类中 MultiFilterRecordReader<K extends WritableComparable,V extends Writable>
protected void fillJoinCollector(K iterkey) throws IOException
fillJoinCollector
在类中 CompositeRecordReader<K extends WritableComparable,V extends Writable,V extends Writable>
IOException
Copyright © 2009 The Apache Software Foundation