Changed Methods |
void accept(JoinCollector, WritableComparable)
|
Change in signature from (JoinCollector, K, extends, WritableComparable ) to (JoinCollector, WritableComparable ).
|
If key provided matches that of this Composite give JoinCollector iterator over values it may emit. |
void add(ComposableRecordReader )
|
Change in signature from (ComposableRecordReader ) to ComposableRecordReader .
|
Add a RecordReader to this collection. |
int compareTo(ComposableRecordReader )
|
Change in signature from (ComposableRecordReader ) to ComposableRecordReader .
|
Implement Comparable contract (compare key of join or head of heap with that of another). |
WritableComparable createKey()
|
Change in return type from (K, extends, WritableComparable ) to WritableComparable .
|
Create a new key value common to all child RRs. |
void fillJoinCollector(WritableComparable )
|
Change in signature from (K, extends, WritableComparable ) to WritableComparable .
|
For all child RRs offering the key provided obtain an iterator at that position in the JoinCollector. |
ResetableIterator getDelegate()
|
Change in return type from ResetableIterator to ResetableIterator .
|
Obtain an iterator over the child RRs apropos of the value type ultimately emitted from this join. |
PriorityQueue getRecordReaderQueue()
|
Change in return type from (ComposableRecordReader> ) to PriorityQueue .
|
Return sorted list of RecordReaders for this composite. |
void skip(WritableComparable )
|
Change in signature from (K, extends, WritableComparable ) to WritableComparable .
|
Pass skip key to child RRs. |
WritableComparable key()
|
Change in return type from (K, extends, WritableComparable ) to WritableComparable .
|
Return the key for the current join or the value at the top of the RecordReader heap. |
void key(WritableComparable )
|
Change in signature from (K, extends, WritableComparable ) to WritableComparable .
|
Clone the key at the top of this RR into the given object. |