public final class StageInputDriver extends Object
Modifier and Type | Method and Description |
---|---|
static long |
estimateInputSize(org.apache.hadoop.mapreduce.JobContext context)
Returns the estimated input data-size.
|
static void |
set(org.apache.hadoop.mapreduce.Job job,
List<StageInput> inputList)
Sets the input specification for this job.
|
public static void set(org.apache.hadoop.mapreduce.Job job, List<StageInput> inputList)
job
- current jobinputList
- each input specificationIllegalArgumentException
- if some parameters were null
public static long estimateInputSize(org.apache.hadoop.mapreduce.JobContext context) throws InterruptedException
context
- the current job contextInterruptedException
- if interrupted whileIllegalArgumentException
- if some parameters were null
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.