org.apache.hadoop.mapred.join

Class OuterJoinRecordReader<K extends WritableComparable>

java.lang.Object

org.apache.hadoop.mapred.join.CompositeRecordReader<K,Writable,TupleWritable>

org.apache.hadoop.mapred.join.JoinRecordReader<K>

org.apache.hadoop.mapred.join.OuterJoinRecordReader<K>

All Implemented Interfaces:

Closeable, AutoCloseable, Comparable<ComposableRecordReader<K,?>>, Configurable, ComposableRecordReader<K,TupleWritable>, RecordReader<K,TupleWritable>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class OuterJoinRecordReader<K extends WritableComparable>
extends JoinRecordReader<K>

Full outer join.

Field Summary

Fields inherited from class org.apache.hadoop.mapred.join.CompositeRecordReader

jc, kids

Method Summary

Modifier and Type	Method and Description
protected boolean	combine(Object[] srcs, TupleWritable dst) Emit everything from the collector.

Methods inherited from class org.apache.hadoop.mapred.join.JoinRecordReader

createValue, getDelegate, next

Methods inherited from class org.apache.hadoop.mapred.join.CompositeRecordReader

accept, add, close, compareTo, createInternalValue, createKey, fillJoinCollector, getComparator, getConf, getPos, getProgress, getRecordReaderQueue, hasNext, id, key, key, setConf, skip

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.mapred.join.ComposableRecordReader

accept, hasNext, id, key, key, skip

Methods inherited from interface org.apache.hadoop.mapred.RecordReader

close, createKey, getPos, getProgress

Methods inherited from interface java.lang.Comparable

compareTo

Method Detail

combine

protected boolean combine(Object[] srcs,
                          TupleWritable dst)

Emit everything from the collector.

Specified by:

combine in class CompositeRecordReader<K extends WritableComparable,Writable,TupleWritable>