Package 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>
@Public
@Stable
public class OuterJoinRecordReader<K extends WritableComparable>
extends JoinRecordReader<K>
Full outer join.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.hadoop.mapred.join.JoinRecordReader
org.apache.hadoop.mapred.join.JoinRecordReader.JoinDelegationIterator -
Field Summary
Fields inherited from class org.apache.hadoop.mapred.join.CompositeRecordReader
jc, kids -
Method Summary
Modifier and TypeMethodDescriptionprotected booleancombine(Object[] srcs, TupleWritable dst) Emit everything from the collector.Methods inherited from class org.apache.hadoop.mapred.join.JoinRecordReader
createValue, getDelegate, nextMethods 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, skipMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.lang.Comparable
compareToMethods inherited from interface org.apache.hadoop.mapred.join.ComposableRecordReader
accept, hasNext, id, key, key, skipMethods inherited from interface org.apache.hadoop.mapred.RecordReader
close, createKey, getPos, getProgress
-
Method Details
-
combine
Emit everything from the collector.- Specified by:
combinein classCompositeRecordReader<K extends WritableComparable,Writable, TupleWritable>
-