|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ComposableRecordReader<K extends WritableComparable,V extends Writable>
Additional operations required of a RecordReader to participate in a join.
Method Summary | |
---|---|
void |
accept(org.apache.hadoop.mapred.join.CompositeRecordReader.JoinCollector jc,
K key)
While key-value pairs from this RecordReader match the given key, register them with the JoinCollector provided. |
boolean |
hasNext()
Returns true if the stream is not empty, but provides no guarantee that a call to next(K,V) will succeed. |
int |
id()
Return the position in the collector this class occupies. |
K |
key()
Return the key this RecordReader would supply on a call to next(K,V) |
void |
key(K key)
Clone the key at the head of this RecordReader into the object provided. |
void |
skip(K key)
Skip key-value pairs with keys less than or equal to the key provided. |
Methods inherited from interface org.apache.hadoop.mapred.RecordReader |
---|
close, createKey, createValue, getPos, getProgress, next |
Methods inherited from interface java.lang.Comparable |
---|
compareTo |
Method Detail |
---|
int id()
K key()
void key(K key) throws IOException
IOException
boolean hasNext()
void skip(K key) throws IOException
IOException
void accept(org.apache.hadoop.mapred.join.CompositeRecordReader.JoinCollector jc, K key) throws IOException
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |