Uses of Interface
org.apache.hadoop.mapred.join.ComposableRecordReader
Packages that use ComposableRecordReader
-
Uses of ComposableRecordReader in org.apache.hadoop.mapred.join
Classes in org.apache.hadoop.mapred.join that implement ComposableRecordReaderModifier and TypeClassDescriptionclassInnerJoinRecordReader<K extends WritableComparable>Full inner join.classJoinRecordReader<K extends WritableComparable>Base class for Composite joins returning Tuples of arbitrary Writables.classMultiFilterRecordReader<K extends WritableComparable,V extends Writable> Base class for Composite join returning values derived from multiple sources, but generally not tuples.classOuterJoinRecordReader<K extends WritableComparable>Full outer join.classOverrideRecordReader<K extends WritableComparable,V extends Writable> Prefer the "rightmost" data source for this key.classWrappedRecordReader<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 ComposableRecordReaderModifier and TypeFieldDescriptionprotected final ComposableRecordReader<K,? extends V>[] CompositeRecordReader.kidsFields in org.apache.hadoop.mapred.join with type parameters of type ComposableRecordReaderModifier and TypeFieldDescriptionprotected static final Map<String,Constructor<? extends ComposableRecordReader>> Parser.Node.rrCstrMapMethods in org.apache.hadoop.mapred.join that return ComposableRecordReaderModifier and TypeMethodDescriptionComposableInputFormat.getRecordReader(InputSplit split, JobConf job, Reporter reporter) 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 ComposableRecordReaderModifier and TypeMethodDescriptionprotected PriorityQueue<ComposableRecordReader<K,?>> CompositeRecordReader.getRecordReaderQueue()Return sorted list of RecordReaders for this composite.Methods in org.apache.hadoop.mapred.join with parameters of type ComposableRecordReaderModifier and TypeMethodDescriptionvoidCompositeRecordReader.add(ComposableRecordReader<K, ? extends V> rr) Add a RecordReader to this collection.intCompositeRecordReader.compareTo(ComposableRecordReader<K, ?> other) Implement Comparable contract (compare key of join or head of heap with that of another).intWrappedRecordReader.compareTo(ComposableRecordReader<K, ?> other) Implement Comparable contract (compare key at head of proxied RR with that of another).