org.apache.hadoop.mapreduce.lib.join

Class ComposableInputFormat<K extends WritableComparable<?>,V extends Writable>

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<K,V>

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

Constructors

Constructor and Description
ComposableInputFormat()

Method Summary

Modifier and Type	Method and Description
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