com.datasalt.pangool.tuplemr.mapred.lib.output
Class HadoopOutputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.OutputFormat
      extended by com.datasalt.pangool.tuplemr.mapred.lib.output.HadoopOutputFormat
All Implemented Interfaces:
Serializable, org.apache.hadoop.conf.Configurable

public class HadoopOutputFormat
extends org.apache.hadoop.mapreduce.OutputFormat
implements org.apache.hadoop.conf.Configurable, Serializable

See Also:
Serialized Form

Constructor Summary
HadoopOutputFormat(Class<? extends org.apache.hadoop.mapreduce.OutputFormat> wrappedOutputFormat)
           
 
Method Summary
 void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
           
 org.apache.hadoop.conf.Configuration getConf()
           
 org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 org.apache.hadoop.mapreduce.RecordWriter getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 void setConf(org.apache.hadoop.conf.Configuration conf)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

HadoopOutputFormat

public HadoopOutputFormat(Class<? extends org.apache.hadoop.mapreduce.OutputFormat> wrappedOutputFormat)
Method Detail

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                         throws IOException,
                                                                InterruptedException
Specified by:
getRecordWriter in class org.apache.hadoop.mapreduce.OutputFormat
Throws:
IOException
InterruptedException

checkOutputSpecs

public void checkOutputSpecs(org.apache.hadoop.mapreduce.JobContext context)
                      throws IOException,
                             InterruptedException
Specified by:
checkOutputSpecs in class org.apache.hadoop.mapreduce.OutputFormat
Throws:
IOException
InterruptedException

getOutputCommitter

public org.apache.hadoop.mapreduce.OutputCommitter getOutputCommitter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                               throws IOException,
                                                                      InterruptedException
Specified by:
getOutputCommitter in class org.apache.hadoop.mapreduce.OutputFormat
Throws:
IOException
InterruptedException

setConf

public void setConf(org.apache.hadoop.conf.Configuration conf)
Specified by:
setConf in interface org.apache.hadoop.conf.Configurable

getConf

public org.apache.hadoop.conf.Configuration getConf()
Specified by:
getConf in interface org.apache.hadoop.conf.Configurable


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.