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>

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class InnerJoinRecordReader<K extends WritableComparable>
extends JoinRecordReader<K>

Full inner join.

フィールドのサマリー

クラスから継承されたフィールド 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>