public class StageOutputDriver extends Object
Constructor and Description |
---|
StageOutputDriver(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context)
Creates a new instance.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this driver and finalizes all result sinks.
|
<T extends org.apache.hadoop.io.Writable> |
getResultSink(String name)
Returns the result sink object with the specified name.
|
static void |
set(org.apache.hadoop.mapreduce.Job job,
String outputPath,
Collection<StageOutput> outputList)
Sets the output specification for this job.
|
public StageOutputDriver(org.apache.hadoop.mapreduce.TaskInputOutputContext<?,?,?,?> context) throws IOException, InterruptedException
context
- the current contextIOException
- if failed to initialize this driverInterruptedException
- if interrupted while initializing this driverIllegalArgumentException
- if the parameter is null
public <T extends org.apache.hadoop.io.Writable> Result<T> getResultSink(String name) throws IOException, InterruptedException
set(Job, String, Collection)
.T
- the output data typename
- the sink nameIOException
- if failed to initialize the target sinkInterruptedException
- if interrupted while initializing the target sinkIllegalArgumentException
- if the parameter is null
public void close() throws IOException, InterruptedException
IOException
- if failed to finalize some result sinksInterruptedException
- if interrupted while disposing the driverpublic static void set(org.apache.hadoop.mapreduce.Job job, String outputPath, Collection<StageOutput> outputList) throws IOException
job
- current joboutputPath
- base output pathoutputList
- each output informationIOException
- if failed to configure the output specificationIllegalArgumentException
- if some parameters were null
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.