T
- target typepublic final class TemporaryOutputFormat<T>
extends org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.NullWritable,T>
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_FILE_NAME
The default output name prefix.
|
static String |
KEY_FILE_NAME
The Hadoop property key of output name prefix.
|
Constructor and Description |
---|
TemporaryOutputFormat() |
Modifier and Type | Method and Description |
---|---|
void |
checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) |
<V> org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,V> |
createRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context,
String name,
Class<V> dataType)
Creates a new
RecordWriter to output temporary data. |
org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter |
getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
static org.apache.hadoop.fs.Path |
getOutputPath(org.apache.hadoop.mapreduce.JobContext context)
Returns the output path.
|
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,T> |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
static void |
setOutputPath(org.apache.hadoop.mapreduce.JobContext context,
org.apache.hadoop.fs.Path path)
Configures output path.
|
public static final String KEY_FILE_NAME
public static final String DEFAULT_FILE_NAME
public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context) throws IOException, InterruptedException
checkOutputSpecs
in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.NullWritable,T>
IOException
InterruptedException
public org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,T> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
getRecordWriter
in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.NullWritable,T>
IOException
InterruptedException
public <V> org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,V> createRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context, String name, Class<V> dataType) throws IOException, InterruptedException
RecordWriter
to output temporary data.V
- value typecontext
- current contextname
- output namedataType
- value typeIOException
- if failed to create a new RecordWriter
InterruptedException
- if interruptedIllegalArgumentException
- if some parameters were null
public org.apache.hadoop.mapreduce.lib.output.FileOutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
getOutputCommitter
in class org.apache.hadoop.mapreduce.OutputFormat<org.apache.hadoop.io.NullWritable,T>
IOException
public static org.apache.hadoop.fs.Path getOutputPath(org.apache.hadoop.mapreduce.JobContext context)
context
- current contextIllegalArgumentException
- if some parameters were null
setOutputPath(JobContext, Path)
public static void setOutputPath(org.apache.hadoop.mapreduce.JobContext context, org.apache.hadoop.fs.Path path)
context
- current contextpath
- target output pathIllegalArgumentException
- if some parameters were null
Copyright © 2011–2018 Asakusa Framework Team. All rights reserved.