public final class BridgeInputFormat extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>
InputFormat
.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 and Description |
---|
BridgeInputFormat() |
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.
|
@Deprecated public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
getSplits
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>
IOException
InterruptedException
public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext context, List<StageInput> inputList) throws IOException, InterruptedException
context
- current job contextinputList
- target input listIOException
- if failed to compute splitsInterruptedException
- if interrupted while computing inputsIllegalArgumentException
- if some parameters were null
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
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.NullWritable,Object>
IOException
InterruptedException
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.