org.apache.hadoop.mapreduce.lib.join
Class ComposableRecordReader<K extends WritableComparable<?>,V extends Writable>

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordReader<K,V>
      extended by org.apache.hadoop.mapreduce.lib.join.ComposableRecordReader<K,V>
All Implemented Interfaces:
Closeable, Comparable<ComposableRecordReader<K,?>>
Direct Known Subclasses:
CompositeRecordReader, WrappedRecordReader

@InterfaceAudience.Public
@InterfaceStability.Stable
public abstract class ComposableRecordReader<K extends WritableComparable<?>,V extends Writable>
extends RecordReader<K,V>
implements Comparable<ComposableRecordReader<K,?>>

Additional operations required of a RecordReader to participate in a join.


Constructor Summary
ComposableRecordReader()
           
 
Method Summary
 
Methods inherited from class org.apache.hadoop.mapreduce.RecordReader
close, getCurrentKey, getCurrentValue, getProgress, initialize, nextKeyValue
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface java.lang.Comparable
compareTo
 

Constructor Detail

ComposableRecordReader

public ComposableRecordReader()


Copyright © 2012 Apache Software Foundation. All Rights Reserved.