org.apache.hadoop.mapreduce.lib.join

クラス OuterJoinRecordReader<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>

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

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

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

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

Full outer join.

フィールドのサマリー

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

conf, jc, key, keyclass, kids, value

メソッドのサマリー

修飾子とタイプ	メソッドと説明
protected boolean	combine(Object[] srcs, TupleWritable dst) Emit everything from the collector.

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

createValue, getDelegate, nextKeyValue

クラスから継承されたメソッド 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

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

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

メソッドの詳細

combine

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

Emit everything from the collector.

定義:

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