org.apache.hadoop.mapred.join

类 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>

所有已实现的接口:

Comparable<ComposableRecordReader<K,?>>, Configurable, ComposableRecordReader<K,TupleWritable>, RecordReader<K,TupleWritable>

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

Full inner join.

嵌套类概要

从类继承的嵌套类/接口 org.apache.hadoop.mapred.join.JoinRecordReader

JoinRecordReader.JoinDelegationIterator

字段概要

从类继承的字段 org.apache.hadoop.mapred.join.CompositeRecordReader

jc, kids

方法概要

方法

限定符和类型	方法和说明
protected boolean	combine(Object[] srcs, TupleWritable dst) Return true iff the tuple is full (all data sources contain this key).

从类继承的方法 org.apache.hadoop.mapred.join.JoinRecordReader

createValue, getDelegate, next

从类继承的方法 org.apache.hadoop.mapred.join.CompositeRecordReader

accept, add, close, compareTo, createInternalValue, createKey, fillJoinCollector, getComparator, getConf, getPos, getProgress, getRecordReaderQueue, hasNext, id, key, key, setConf, skip

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

从接口继承的方法 org.apache.hadoop.mapred.join.ComposableRecordReader

accept, hasNext, id, key, key, skip

从接口继承的方法 org.apache.hadoop.mapred.RecordReader

close, createKey, getPos, getProgress

从接口继承的方法 java.lang.Comparable

compareTo

方法详细资料

combine

protected boolean combine(Object[] srcs,
              TupleWritable dst)

Return true iff the tuple is full (all data sources contain this key).

指定者:

combine 在类中 CompositeRecordReader<K extends WritableComparable,Writable,TupleWritable>