com.asakusafw.runtime.stage.input

Class BridgeInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>

com.asakusafw.runtime.stage.input.BridgeInputFormat

public final class BridgeInputFormat
extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>

A bridge implementation for Hadoop InputFormat.

Since:

0.2.5

Version:

0.7.3

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BridgeInputFormat.BridgeInputSplit A bridge implementation for Hadoop InputSplit.
static class	BridgeInputFormat.NullInputSplit Empty implementation for Hadoop InputSplit.
static class	BridgeInputFormat.NullRecordReader<KEYIN,VALUEIN> Empty implementation for Hadoop RecordReader.

Constructor Summary

Constructors

Constructor and Description
BridgeInputFormat()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,Object>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context) Deprecated.
List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.JobContext context, List<StageInput> inputList) Computes and returns splits for the specified inputs.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BridgeInputFormat

public BridgeInputFormat()

Method Detail

getSplits

@Deprecated
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context)
                                                                   throws IOException,
                                                                          InterruptedException

Deprecated.

Specified by:

getSplits in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>

Throws:

IOException

InterruptedException

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context,
                                                              List<StageInput> inputList)
                                                       throws IOException,
                                                              InterruptedException

Computes and returns splits for the specified inputs.

Parameters:

context - current job context

inputList - target input list

Returns:

the computed splits

Throws:

IOException - if failed to compute splits

InterruptedException - if interrupted while computing inputs

IllegalArgumentException - if some parameters were null

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.NullWritable,Object> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                             org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                      throws IOException,
                                                                                                             InterruptedException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>

Throws:

IOException

InterruptedException