public class StageInputFormat
extends org.apache.hadoop.mapreduce.InputFormat
InputFormat
for handling handling multiple Map operations.Constructor and Description |
---|
StageInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader |
createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
static Class<? extends SplitCombiner> |
getSplitCombinerClass(org.apache.hadoop.mapreduce.JobContext context)
Returns the
SplitCombiner class used in the current job. |
List<org.apache.hadoop.mapreduce.InputSplit> |
getSplits(org.apache.hadoop.mapreduce.JobContext context) |
static void |
setSplitCombinerClass(org.apache.hadoop.mapreduce.JobContext context,
Class<? extends SplitCombiner> aClass)
Sets the
SplitCombiner class for the current job. |
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
IOException
InterruptedException
public static Class<? extends SplitCombiner> getSplitCombinerClass(org.apache.hadoop.mapreduce.JobContext context)
SplitCombiner
class used in the current job.context
- the current job contextSplitCombiner
classpublic static void setSplitCombinerClass(org.apache.hadoop.mapreduce.JobContext context, Class<? extends SplitCombiner> aClass)
SplitCombiner
class for the current job.context
- the current job contextaClass
- the SplitCombiner
classpublic org.apache.hadoop.mapreduce.RecordReader createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
createRecordReader
in class org.apache.hadoop.mapreduce.InputFormat
IOException
InterruptedException
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.