| Package | Description | 
|---|---|
| org.apache.hadoop.mapred.join | |
| org.apache.hadoop.mapreduce.lib.join | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TupleWritable
Writable type storing multiple  
Writables. | 
| Modifier and Type | Method and Description | 
|---|---|
protected TupleWritable | 
CompositeRecordReader.createTupleWritable()
Create a value to be used internally for joins. 
 | 
TupleWritable | 
JoinRecordReader.createValue()  | 
| Modifier and Type | Method and Description | 
|---|---|
RecordReader<K,TupleWritable> | 
CompositeInputFormat.createRecordReader(InputSplit split,
                  TaskAttemptContext taskContext)
Construct a CompositeRecordReader for the children of this InputFormat
 as defined in the init expression. 
 | 
protected ResetableIterator<TupleWritable> | 
JoinRecordReader.getDelegate()
Return an iterator wrapping the JoinCollector. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
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.mapreduce.lib.join.TupleWritable) every Tuple from the
 collector (the outer join of child RRs). | 
protected boolean | 
InnerJoinRecordReader.combine(Object[] srcs,
       TupleWritable dst)
Return true iff the tuple is full (all data sources contain this key). 
 | 
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). 
 | 
Copyright © 2022 Apache Software Foundation. All rights reserved.