org.apache.hadoop.mapred.join
Class OuterJoinRecordReader<K extends WritableComparable>

java.lang.Object
  extended by org.apache.hadoop.mapred.join.CompositeRecordReader<K,Writable,TupleWritable>
      extended by org.apache.hadoop.mapred.join.JoinRecordReader<K>
          extended by org.apache.hadoop.mapred.join.OuterJoinRecordReader<K>
All Implemented Interfaces:
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
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>


Copyright © 2013 Apache Software Foundation. All Rights Reserved.