Uses of Class
org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader
Packages that use ComposableRecordReader
-
Uses of ComposableRecordReader in org.apache.hadoop.mapreduce.lib.join
Subclasses of ComposableRecordReader in org.apache.hadoop.mapreduce.lib.joinModifier and TypeClassDescriptionclassCompositeRecordReader<K extends WritableComparable<?>,V extends Writable, X extends Writable> A RecordReader that can effect joins of RecordReaders sharing a common key type and partitioning.classInnerJoinRecordReader<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.mapreduce.lib.join declared as ComposableRecordReaderModifier and TypeFieldDescriptionprotected final ComposableRecordReader<K,? extends V>[] CompositeRecordReader.kidsFields in org.apache.hadoop.mapreduce.lib.join with type parameters of type ComposableRecordReaderModifier and TypeFieldDescriptionprotected static final Map<String,Constructor<? extends ComposableRecordReader>> Parser.Node.rrCstrMapMethods in org.apache.hadoop.mapreduce.lib.join that return ComposableRecordReaderModifier and TypeMethodDescriptionabstract ComposableRecordReader<K,V> ComposableInputFormat.createRecordReader(InputSplit split, TaskAttemptContext context) Methods in org.apache.hadoop.mapreduce.lib.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.mapreduce.lib.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).