public class RCFileMapReduceOutputFormat extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<org.apache.hadoop.io.WritableComparable<?>,BytesRefArrayWritable>
Constructor and Description |
---|
RCFileMapReduceOutputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,BytesRefArrayWritable> |
getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext task) |
static void |
setColumnNumber(org.apache.hadoop.conf.Configuration conf,
int columnNum)
Set number of columns into the given configuration.
|
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputName, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputName, setOutputPath
public static void setColumnNumber(org.apache.hadoop.conf.Configuration conf, int columnNum)
conf
- configuration instance which need to set the column numbercolumnNum
- column number for RCFile's Writerpublic org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,BytesRefArrayWritable> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext task) throws IOException, InterruptedException
getRecordWriter
in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<org.apache.hadoop.io.WritableComparable<?>,BytesRefArrayWritable>
IOException
InterruptedException
Copyright © 2016 The Apache Software Foundation. All rights reserved.