@InterfaceAudience.Public @InterfaceStability.Stable public class OuterJoinRecordReader<K extends WritableComparable> extends JoinRecordReader<K>
JoinRecordReader.JoinDelegationIterator
jc, kids
Modifier and Type | Method and Description |
---|---|
protected boolean |
combine(Object[] srcs,
TupleWritable dst)
Emit everything from the collector.
|
createValue, getDelegate, next
accept, add, close, compareTo, createInternalValue, createKey, fillJoinCollector, 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 boolean combine(Object[] srcs, TupleWritable dst)
combine
in class CompositeRecordReader<K extends WritableComparable,Writable,TupleWritable>
Copyright © 2013 Apache Software Foundation. All rights reserved.