Package | Description |
---|---|
org.apache.hadoop.mapreduce.lib.join |
Modifier and Type | Class and Description |
---|---|
class |
CompositeRecordReader<K extends WritableComparable<?>,V extends Writable,X extends Writable>
A RecordReader that can effect joins of RecordReaders sharing a common key
type and partitioning.
|
class |
InnerJoinRecordReader<K extends WritableComparable<?>>
Full inner join.
|
class |
JoinRecordReader<K extends WritableComparable<?>>
Base class for Composite joins returning Tuples of arbitrary Writables.
|
class |
MultiFilterRecordReader<K extends WritableComparable<?>,V extends Writable>
Base class for Composite join returning values derived from multiple
sources, but generally not tuples.
|
class |
OuterJoinRecordReader<K extends WritableComparable<?>>
Full outer join.
|
class |
OverrideRecordReader<K extends WritableComparable<?>,V extends Writable>
Prefer the "rightmost" data source for this key.
|
class |
WrappedRecordReader<K extends WritableComparable<?>,U extends Writable>
Proxy class for a RecordReader participating in the join framework.
|
Modifier and Type | Field and Description |
---|---|
protected ComposableRecordReader<K,? extends V>[] |
CompositeRecordReader.kids |
Modifier and Type | Field and Description |
---|---|
protected static Map<String,Constructor<? extends ComposableRecordReader>> |
Parser.Node.rrCstrMap |
Modifier and Type | Method and Description |
---|---|
abstract ComposableRecordReader<K,V> |
ComposableInputFormat.createRecordReader(InputSplit split,
TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
protected PriorityQueue<ComposableRecordReader<K,?>> |
CompositeRecordReader.getRecordReaderQueue()
Return sorted list of RecordReaders for this composite.
|
Modifier and Type | Method and Description |
---|---|
void |
CompositeRecordReader.add(ComposableRecordReader<K,? extends V> rr)
Add a RecordReader to this collection.
|
int |
WrappedRecordReader.compareTo(ComposableRecordReader<K,?> other)
Implement Comparable contract (compare key at head of proxied RR
with that of another).
|
int |
CompositeRecordReader.compareTo(ComposableRecordReader<K,?> other)
Implement Comparable contract (compare key of join or head of heap
with that of another).
|
Modifier and Type | Method and Description |
---|---|
protected static void |
Parser.Node.addIdentifier(String ident,
Class<?>[] mcstrSig,
Class<? extends Parser.Node> nodetype,
Class<? extends ComposableRecordReader> cl)
For a given identifier, add a mapping to the nodetype for the parse
tree and to the ComposableRecordReader to be created, including the
formals required to invoke the constructor.
|
Copyright © 2016 Apache Software Foundation. All Rights Reserved.