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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.join.ComposableInputFormat<K,V>
Direct Known Subclasses:
Parser.Node

@InterfaceAudience.Public
@InterfaceStability.Stable
public abstract class ComposableInputFormat<K extends WritableComparable<?>,V extends Writable>
extends InputFormat<K,V>

Refinement of InputFormat requiring implementors to provide ComposableRecordReader instead of RecordReader.


Constructor Summary
ComposableInputFormat()
           
 
Method Summary
abstract  ComposableRecordReader<K,V> createRecordReader(InputSplit split, TaskAttemptContext context)
          Create a record reader for a given split.
 
Methods inherited from class org.apache.hadoop.mapreduce.InputFormat
getSplits
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ComposableInputFormat

public ComposableInputFormat()
Method Detail

createRecordReader

public abstract ComposableRecordReader<K,V> createRecordReader(InputSplit split,
                                                               TaskAttemptContext context)
                                                                                                       throws IOException,
                                                                                                              InterruptedException
Description copied from class: InputFormat
Create a record reader for a given split. The framework will call RecordReader.initialize(InputSplit, TaskAttemptContext) before the split is used.

Specified by:
createRecordReader in class InputFormat<K extends WritableComparable<?>,V extends Writable>
Parameters:
split - the split to be read
context - the information about the task
Returns:
a new record reader
Throws:
IOException
InterruptedException


Copyright © 2012 Apache Software Foundation. All Rights Reserved.