org.apache.hadoop.mapreduce.lib.join

クラス JoinRecordReader<K extends WritableComparable<?>>

java.lang.Object

org.apache.hadoop.mapreduce.RecordReader<K,V>

org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader<K,X>

org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader<K,Writable,TupleWritable>

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

すべての実装されたインタフェース:

Closeable, AutoCloseable, Comparable<ComposableRecordReader<K,?>>, Configurable

直系の既知のサブクラス:

InnerJoinRecordReader, OuterJoinRecordReader

@InterfaceAudience.Public
 @InterfaceStability.Stable
public abstract class JoinRecordReader<K extends WritableComparable<?>>
extends CompositeRecordReader<K,Writable,TupleWritable>

Base class for Composite joins returning Tuples of arbitrary Writables.

フィールドのサマリー

クラスから継承されたフィールド org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader

conf, jc, key, keyclass, kids, value

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
JoinRecordReader(int id, Configuration conf, int capacity, Class<? extends WritableComparator> cmpcl)

メソッドのサマリー

修飾子とタイプ	メソッドと説明
TupleWritable	createValue() Create instance of value.
protected ResetableIterator<TupleWritable>	getDelegate() Return an iterator wrapping the JoinCollector.
boolean	nextKeyValue() Emit the next set of key, value pairs as defined by the child RecordReaders and operation associated with this composite RR.

クラスから継承されたメソッド org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader

accept, add, close, combine, compareTo, createKey, createTupleWritable, fillJoinCollector, getComparator, getConf, getCurrentKey, getCurrentValue, getProgress, getRecordReaderQueue, hasNext, id, initialize, key, key, setConf, skip

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

JoinRecordReader

public JoinRecordReader(int id,
                        Configuration conf,
                        int capacity,
                        Class<? extends WritableComparator> cmpcl)
                 throws IOException

例外:

IOException

メソッドの詳細

nextKeyValue

public boolean nextKeyValue()
                     throws IOException,
                            InterruptedException

Emit the next set of key, value pairs as defined by the child RecordReaders and operation associated with this composite RR.

定義:

nextKeyValue クラス内 RecordReader<K extends WritableComparable<?>,TupleWritable>

戻り値:

true if a key/value pair was read

例外:

IOException

InterruptedException

createValue

public TupleWritable createValue()

クラスからコピーされた説明: ComposableRecordReader

Create instance of value.

getDelegate

protected ResetableIterator<TupleWritable> getDelegate()

Return an iterator wrapping the JoinCollector.

定義:

getDelegate クラス内 CompositeRecordReader<K extends WritableComparable<?>,Writable,TupleWritable>