|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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,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
InterruptedException
protected 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 |