Uses of Class
org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader

Packages that use ComposableRecordReader

Package	Description
org.apache.hadoop.mapreduce.lib.join

Uses of ComposableRecordReader in org.apache.hadoop.mapreduce.lib.join

Subclasses of ComposableRecordReader in 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.

Fields in org.apache.hadoop.mapreduce.lib.join declared as ComposableRecordReader

Modifier and Type	Field and Description
protected ComposableRecordReader<K,? extends V>[]	CompositeRecordReader.kids

Fields in org.apache.hadoop.mapreduce.lib.join with type parameters of type ComposableRecordReader

Modifier and Type	Field and Description
protected static Map<String,Constructor<? extends ComposableRecordReader>>	Parser.Node.rrCstrMap

Methods in org.apache.hadoop.mapreduce.lib.join that return ComposableRecordReader

Modifier and Type	Method and Description
abstract ComposableRecordReader<K,V>	ComposableInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context)

Methods in org.apache.hadoop.mapreduce.lib.join that return types with arguments of type ComposableRecordReader

Modifier and Type	Method and Description
protected PriorityQueue<ComposableRecordReader<K,?>>	CompositeRecordReader.getRecordReaderQueue() Return sorted list of RecordReaders for this composite.

Methods in org.apache.hadoop.mapreduce.lib.join with parameters of type ComposableRecordReader

Modifier and Type	Method and Description
void	CompositeRecordReader.add(ComposableRecordReader<K,? extends V> rr) Add a RecordReader to this collection.
int	CompositeRecordReader.compareTo(ComposableRecordReader<K,?> other) Implement Comparable contract (compare key of join or head of heap with that of another).
int	WrappedRecordReader.compareTo(ComposableRecordReader<K,?> other) Implement Comparable contract (compare key at head of proxied RR with that of another).

Method parameters in org.apache.hadoop.mapreduce.lib.join with type arguments of type ComposableRecordReader

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.