org.apache.hadoop.mapreduce.lib.join

Class InnerJoinRecordReader<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.InnerJoinRecordReader<K>

All Implemented Interfaces:

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

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

Full inner join.

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader

conf, jc, key, keyclass, kids, value

Method Summary

Modifier and Type	Method and Description
protected boolean	combine(Object[] srcs, TupleWritable dst) Return true iff the tuple is full (all data sources contain this key).

Methods inherited from class org.apache.hadoop.mapreduce.lib.join.JoinRecordReader

createValue, getDelegate, nextKeyValue

Methods 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

Methods inherited from class java.lang.Object

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

Method Detail

combine

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

Return true iff the tuple is full (all data sources contain this key).

Specified by:

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