com.datasalt.pangool.tuplemr.mapred.lib.output
Class TupleTextOutputFormat.TupleTextRecordWriter

java.lang.Object
  extended by org.apache.hadoop.mapreduce.RecordWriter<ITuple,org.apache.hadoop.io.NullWritable>
      extended by com.datasalt.pangool.tuplemr.mapred.lib.output.TupleTextOutputFormat.TupleTextRecordWriter
Enclosing class:
TupleTextOutputFormat

public static class TupleTextOutputFormat.TupleTextRecordWriter
extends org.apache.hadoop.mapreduce.RecordWriter<ITuple,org.apache.hadoop.io.NullWritable>


Constructor Summary
TupleTextOutputFormat.TupleTextRecordWriter(Schema schema, TupleTextOutputFormat.CustomCSVWriter writer)
           
 
Method Summary
 void close(org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
 void write(ITuple tuple, org.apache.hadoop.io.NullWritable toIgnore)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TupleTextOutputFormat.TupleTextRecordWriter

public TupleTextOutputFormat.TupleTextRecordWriter(Schema schema,
                                                   TupleTextOutputFormat.CustomCSVWriter writer)
Method Detail

close

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

write

public void write(ITuple tuple,
                  org.apache.hadoop.io.NullWritable toIgnore)
           throws IOException,
                  InterruptedException
Specified by:
write in class org.apache.hadoop.mapreduce.RecordWriter<ITuple,org.apache.hadoop.io.NullWritable>
Throws:
IOException
InterruptedException


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