org.apache.hadoop.mapred.join
Class InnerJoinRecordReader<K extends WritableComparable>

java.lang.Object
  extended by org.apache.hadoop.mapred.join.CompositeRecordReader<K,Writable,TupleWritable>
      extended by org.apache.hadoop.mapred.join.JoinRecordReader<K>
          extended by org.apache.hadoop.mapred.join.InnerJoinRecordReader<K>
All Implemented Interfaces:
Comparable<ComposableRecordReader<K,?>>, Configurable, ComposableRecordReader<K,TupleWritable>, RecordReader<K,TupleWritable>

@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.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 © 2012 Apache Software Foundation. All Rights Reserved.