org.apache.hadoop.mapreduce.lib.join.InnerJoinRecordReader<K>

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

@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.mapreduce.lib.join.JoinRecordReader
org.apache.hadoop.mapreduce.lib.join.JoinRecordReader.JoinDelegationIterator

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader
org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader.JoinCollector
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

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

Class InnerJoinRecordReader<K extends WritableComparable<?>>

Nested Class Summary