Package | Description |
---|---|
com.asakusafw.runtime.stage |
Classes for Hadoop stages.
|
com.asakusafw.runtime.stage.input |
Classes for stage inputs.
|
Modifier and Type | Method and Description |
---|---|
protected abstract List<StageInput> |
AbstractStageClient.getStageInputs()
Returns the stage inputs.
|
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.mapreduce.InputSplit> |
TemporaryInputFormat.getSplits(org.apache.hadoop.mapreduce.JobContext context,
List<StageInput> inputList)
Computes and returns splits for the specified inputs.
|
List<org.apache.hadoop.mapreduce.InputSplit> |
BridgeInputFormat.getSplits(org.apache.hadoop.mapreduce.JobContext context,
List<StageInput> inputList)
Computes and returns splits for the specified inputs.
|
static void |
StageInputDriver.set(org.apache.hadoop.mapreduce.Job job,
List<StageInput> inputList)
Sets the input specification for this job.
|
Copyright © 2011–2019 Asakusa Framework Team. All rights reserved.