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 |
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 boolean |
OuterJoinRecordReader.combine(Object[] srcs,
TupleWritable dst)
Emit everything from the collector.
|
protected abstract boolean |
CompositeRecordReader.combine(Object[] srcs,
TupleWritable value) |
protected boolean |
InnerJoinRecordReader.combine(Object[] srcs,
TupleWritable dst)
Return true iff the tuple is full (all data sources contain this key).
|
protected abstract V |
MultiFilterRecordReader.emit(TupleWritable dst)
For each tuple emitted, return a value (typically one of the values
in the tuple).
|
protected V |
OverrideRecordReader.emit(TupleWritable dst)
Emit the value with the highest position 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 © 2018 Apache Software Foundation. All rights reserved.