org.apache.hadoop.mapred.join
Class InnerJoinRecordReader<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.InnerJoinRecordReader<K>

All Implemented Interfaces:

java.lang.Comparable<ComposableRecordReader<K,?>>, Configurable, ComposableRecordReader<K,TupleWritable>, RecordReader<K,TupleWritable>

public class InnerJoinRecordReader<K extends WritableComparable>
extends JoinRecordReader<K>

Full inner join.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapred.join.JoinRecordReader

JoinRecordReader.JoinDelegationIterator

Field Summary

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

jc, kids

Method Summary

protected boolean

combine(java.lang.Object[] srcs, TupleWritable dst) Return true iff the tuple is full (all data sources contain this key).

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(java.lang.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>