org.apache.hadoop.mapred.join.InnerJoinRecordReader<K>

All Implemented Interfaces:: Closeable, AutoCloseable, Comparable<ComposableRecordReader<K,?>>, Configurable, ComposableRecordReader<K,TupleWritable>, RecordReader<K,TupleWritable>

@Public @Stable 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
org.apache.hadoop.mapred.join.JoinRecordReader.JoinDelegationIterator
Field Summary

Fields inherited from class org.apache.hadoop.mapred.join.CompositeRecordReader
jc, kids
Method Summary

Modifier and Type

Method

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.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 java.lang.Comparable
compareTo

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

Class InnerJoinRecordReader<K extends WritableComparable>

Nested Class Summary