@InterfaceAudience.Public @InterfaceStability.Stable public class OuterJoinRecordReader<K extends WritableComparable<?>> extends JoinRecordReader<K>
Modifier and Type | Method and Description |
---|---|
protected boolean |
combine(Object[] srcs,
TupleWritable dst)
Emit everything from the collector.
|
createValue, getDelegate, nextKeyValue
accept, add, close, compareTo, createKey, createTupleWritable, fillJoinCollector, getComparator, getConf, getCurrentKey, getCurrentValue, getProgress, getRecordReaderQueue, hasNext, id, initialize, key, key, setConf, skip
protected boolean combine(Object[] srcs, TupleWritable dst)
combine
in class CompositeRecordReader<K extends WritableComparable<?>,Writable,TupleWritable>
Copyright © 2015 Apache Software Foundation. All rights reserved.