@InterfaceAudience.Public @InterfaceStability.Stable public abstract class JoinRecordReader<K extends WritableComparable> extends CompositeRecordReader<K,Writable,TupleWritable> implements ComposableRecordReader<K,TupleWritable>
jc, kids
Constructor and Description |
---|
JoinRecordReader(int id,
JobConf conf,
int capacity,
Class<? extends WritableComparator> cmpcl) |
Modifier and Type | Method and Description |
---|---|
TupleWritable |
createValue()
Create an object of the appropriate type to be used as a value.
|
protected ResetableIterator<TupleWritable> |
getDelegate()
Return an iterator wrapping the JoinCollector.
|
boolean |
next(K key,
TupleWritable value)
Emit the next set of key, value pairs as defined by the child
RecordReaders and operation associated with this composite RR.
|
accept, add, close, combine, 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
compareTo
public JoinRecordReader(int id, JobConf conf, int capacity, Class<? extends WritableComparator> cmpcl) throws IOException
IOException
public boolean next(K key, TupleWritable value) throws IOException
next
in interface RecordReader<K extends WritableComparable,TupleWritable>
key
- the key to read data intovalue
- the value to read data intoIOException
public TupleWritable createValue()
createValue
in interface RecordReader<K extends WritableComparable,TupleWritable>
protected ResetableIterator<TupleWritable> getDelegate()
getDelegate
in class CompositeRecordReader<K extends WritableComparable,Writable,TupleWritable>
Copyright © 2016 Apache Software Foundation. All rights reserved.