@InterfaceAudience.Public @InterfaceStability.Stable public class OuterJoinRecordReader<K extends WritableComparable> extends JoinRecordReader<K>
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 © 2017 Apache Software Foundation. All rights reserved.