Uses of Interface
org.apache.hadoop.mapred.join.ComposableRecordReader

Packages that use ComposableRecordReader

org.apache.hadoop.mapred.join

Given a set of sorted datasets keyed with the same class and yielding equal partitions, it is possible to effect a join of those datasets prior to the map.

Uses of ComposableRecordReader in org.apache.hadoop.mapred.join

Classes in org.apache.hadoop.mapred.join that implement ComposableRecordReader

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.mapred.join declared as ComposableRecordReader

protected ComposableRecordReader<K,? extends V>[]

CompositeRecordReader.kids

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

protected static Map<String,Constructor<? extends ComposableRecordReader>>

Parser.Node.rrCstrMap

Methods in org.apache.hadoop.mapred.join that return ComposableRecordReader

ComposableRecordReader<K,V>	ComposableInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter)
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.

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

protected PriorityQueue<ComposableRecordReader<K,?>>

CompositeRecordReader.getRecordReaderQueue() Return sorted list of RecordReaders for this composite.

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

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.mapred.join with type arguments of type ComposableRecordReader

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.