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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.OutputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ITuple,org.apache.hadoop.io.NullWritable>
          extended by com.datasalt.pangool.tuplemr.mapred.lib.output.TupleOutputFormat
All Implemented Interfaces:
Serializable

public class TupleOutputFormat
extends org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ITuple,org.apache.hadoop.io.NullWritable>
implements Serializable

An OutputFormat that writes ITuples.

See Also:
Serialized Form

Constructor Summary
TupleOutputFormat()
          Empty constructor means the output Schema will be picked from the first Tuple that is emitted.
TupleOutputFormat(Schema outputSchema)
          Providing output schema enables output validation.
TupleOutputFormat(String outputSchema)
          Deprecated. 
 
Method Summary
 org.apache.hadoop.mapreduce.RecordWriter<ITuple,org.apache.hadoop.io.NullWritable> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat
checkOutputSpecs, getCompressOutput, getDefaultWorkFile, getOutputCommitter, getOutputCompressorClass, getOutputPath, getPathForWorkFile, getUniqueFile, getWorkOutputPath, setCompressOutput, setOutputCompressorClass, setOutputPath
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TupleOutputFormat

public TupleOutputFormat()
Empty constructor means the output Schema will be picked from the first Tuple that is emitted.


TupleOutputFormat

public TupleOutputFormat(Schema outputSchema)
Providing output schema enables output validation.


TupleOutputFormat

@Deprecated
public TupleOutputFormat(String outputSchema)
Deprecated. 

Deprecated. Use TupleOutputFormat(com.datasalt.pangool.io.Schema) instead.

Method Detail

getRecordWriter

public org.apache.hadoop.mapreduce.RecordWriter<ITuple,org.apache.hadoop.io.NullWritable> getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                   throws IOException,
                                                                                                          InterruptedException
Specified by:
getRecordWriter in class org.apache.hadoop.mapreduce.lib.output.FileOutputFormat<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException


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