public abstract class MultiFilterRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable> extends CompositeRecordReader<K,V,V> implements ComposableRecordReader<K,V>
Modifier and Type | Class and Description |
---|---|
protected class |
MultiFilterRecordReader.MultiFilterDelegationIterator
Proxy the JoinCollector, but include callback to emit.
|
jc, kids
Constructor and Description |
---|
MultiFilterRecordReader(int id,
JobConf conf,
int capacity,
java.lang.Class<? extends org.apache.hadoop.io.WritableComparator> cmpcl) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
combine(java.lang.Object[] srcs,
TupleWritable dst)
Default implementation offers
emit(org.apache.hadoop.mapred.join.TupleWritable) every Tuple from the
collector (the outer join of child RRs). |
V |
createValue()
Create an object of the appropriate type to be used as a value.
|
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.
|
boolean |
next(K key,
V value)
Reads the next key/value pair from the input for processing.
|
accept, add, close, compareTo, createInternalValue, createKey, fillJoinCollector, getComparator, getConf, getPos, getProgress, getRecordReaderQueue, hasNext, id, key, key, setConf, skip
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
accept, hasNext, id, key, key, skip
close, createKey, getPos, getProgress
public MultiFilterRecordReader(int id, JobConf conf, int capacity, java.lang.Class<? extends org.apache.hadoop.io.WritableComparator> cmpcl) throws java.io.IOException
java.io.IOException
protected abstract V emit(TupleWritable dst) throws java.io.IOException
java.io.IOException
protected boolean combine(java.lang.Object[] srcs, TupleWritable dst)
emit(org.apache.hadoop.mapred.join.TupleWritable)
every Tuple from the
collector (the outer join of child RRs).combine
in class CompositeRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
public boolean next(K key, V value) throws java.io.IOException
next
in interface RecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
key
- the key to read data intovalue
- the value to read data intojava.io.IOException
public V createValue()
createValue
in interface RecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
protected ResetableIterator<V> getDelegate()
getDelegate
in class CompositeRecordReader<K extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
MultiFilterRecordReader.MultiFilterDelegationIterator
Copyright © 2009 The Apache Software Foundation