|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.hadoop.mapreduce.RecordReader<K,V>
org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader<K,X>
org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader<K,V,V>
org.apache.hadoop.mapreduce.lib.join.MultiFilterRecordReader<K,V>
@InterfaceAudience.Public @InterfaceStability.Stable public abstract class MultiFilterRecordReader<K extends WritableComparable<?>,V extends Writable>
Base class for Composite join returning values derived from multiple sources, but generally not tuples.
| Field Summary |
|---|
| Fields inherited from class org.apache.hadoop.mapreduce.lib.join.CompositeRecordReader |
|---|
conf, jc, key, keyclass, kids, value |
| Constructor Summary | |
|---|---|
MultiFilterRecordReader(int id,
Configuration conf,
int capacity,
Class<? extends WritableComparator> cmpcl)
|
|
| Method Summary | |
|---|---|
protected boolean |
combine(Object[] srcs,
TupleWritable dst)
Default implementation offers emit(org.apache.hadoop.mapreduce.lib.join.TupleWritable) every Tuple from the
collector (the outer join of child RRs). |
protected abstract V |
emit(TupleWritable dst)
For each tuple emitted, return a value (typically one of the values in the tuple). |
protected ResetableIterator<V> |
getDelegate()
Return an iterator returning a single value from the tuple. |
void |
initialize(InputSplit split,
TaskAttemptContext context)
Called once at initialization. |
boolean |
nextKeyValue()
Read the next key, value pair. |
| 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, key, key, setConf, skip |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public MultiFilterRecordReader(int id,
Configuration conf,
int capacity,
Class<? extends WritableComparator> cmpcl)
throws IOException
IOException| Method Detail |
|---|
protected abstract V emit(TupleWritable dst)
throws IOException
IOException
protected boolean combine(Object[] srcs,
TupleWritable dst)
emit(org.apache.hadoop.mapreduce.lib.join.TupleWritable) every Tuple from the
collector (the outer join of child RRs).
combine in class CompositeRecordReader<K extends WritableComparable<?>,V extends Writable,V extends Writable>
public boolean nextKeyValue()
throws IOException,
InterruptedException
nextKeyValue in class RecordReader<K extends WritableComparable<?>,V extends Writable>IOException
InterruptedException
public void initialize(InputSplit split,
TaskAttemptContext context)
throws IOException,
InterruptedException
RecordReader
initialize in class CompositeRecordReader<K extends WritableComparable<?>,V extends Writable,V extends Writable>split - the split that defines the range of records to readcontext - the information about the task
IOException
InterruptedExceptionprotected ResetableIterator<V> getDelegate()
getDelegate in class CompositeRecordReader<K extends WritableComparable<?>,V extends Writable,V extends Writable>MultiFilterRecordReader.MultiFilterDelegationIterator
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||