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	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).

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.