| Package | Description | 
|---|---|
| org.apache.hadoop.mapred.join | 
| Modifier and Type | Method and Description | 
|---|---|
protected TupleWritable | 
CompositeRecordReader.createInternalValue()
Create a value to be used internally for joins. 
 | 
TupleWritable | 
JoinRecordReader.createValue()
Create an object of the appropriate type to be used as a value. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected ResetableIterator<TupleWritable> | 
JoinRecordReader.getDelegate()
Return an iterator wrapping the JoinCollector. 
 | 
ComposableRecordReader<K,TupleWritable> | 
CompositeInputFormat.getRecordReader(InputSplit split,
               JobConf job,
               Reporter reporter)
Construct a CompositeRecordReader for the children of this InputFormat
 as defined in the init expression. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected boolean | 
InnerJoinRecordReader.combine(Object[] srcs,
       TupleWritable dst)
Return true iff the tuple is full (all data sources contain this key). 
 | 
protected boolean | 
OuterJoinRecordReader.combine(Object[] srcs,
       TupleWritable dst)
Emit everything from the collector. 
 | 
protected boolean | 
MultiFilterRecordReader.combine(Object[] srcs,
       TupleWritable dst)
Default implementation offers  
MultiFilterRecordReader.emit(org.apache.hadoop.mapred.join.TupleWritable) every Tuple from the
 collector (the outer join of child RRs). | 
protected abstract boolean | 
CompositeRecordReader.combine(Object[] srcs,
       TupleWritable value)  | 
protected V | 
OverrideRecordReader.emit(TupleWritable dst)
Emit the value with the highest position in the tuple. 
 | 
protected abstract V | 
MultiFilterRecordReader.emit(TupleWritable dst)
For each tuple emitted, return a value (typically one of the values
 in the tuple). 
 | 
boolean | 
JoinRecordReader.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. 
 | 
Copyright © 2022 Apache Software Foundation. All rights reserved.