Class OuterJoinRecordReader<K extends WritableComparable<?>>
java.lang.Object
org.apache.hadoop.mapreduce.RecordReader<K,V>
org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader<K,X>
org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader<K,Writable,TupleWritable>
org.apache.hadoop.mapreduce.lib.join.JoinRecordReader<K>
org.apache.hadoop.mapreduce.lib.join.OuterJoinRecordReader<K>
- All Implemented Interfaces:
Closeable,AutoCloseable,Comparable<ComposableRecordReader<K,,?>> Configurable
@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.mapreduce.lib.join.JoinRecordReader
org.apache.hadoop.mapreduce.lib.join.JoinRecordReader.JoinDelegationIteratorNested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader
org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader.JoinCollector -
Field Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected booleancombine(Object[] srcs, TupleWritable dst) Emit everything from the collector.Methods inherited from class org.apache.hadoop.mapreduce.lib.join.JoinRecordReader
createValue, getDelegate, nextKeyValueMethods inherited from class org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader
accept, add, close, compareTo, createKey, createTupleWritable, fillJoinCollector, getComparator, getConf, getCurrentKey, getCurrentValue, getProgress, getRecordReaderQueue, hasNext, id, initialize, key, key, setConf, skip
-
Method Details
-
combine
Emit everything from the collector.- Specified by:
combinein classCompositeRecordReader<K extends WritableComparable<?>,Writable, TupleWritable>
-