## 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:
  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(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(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>`

Copyright © 2009 The Apache Software Foundation