com.datasalt.pangool.tuplemr.serialization
Class TupleSerializer

java.lang.Object
  extended by com.datasalt.pangool.tuplemr.serialization.TupleSerializer
All Implemented Interfaces:
org.apache.hadoop.io.serializer.Serializer<DatumWrapper<ITuple>>

public class TupleSerializer
extends Object
implements org.apache.hadoop.io.serializer.Serializer<DatumWrapper<ITuple>>


Constructor Summary
TupleSerializer(HadoopSerialization ser, TupleMRConfig tupleMRConfig, boolean inputSchemaValidation)
           
 
Method Summary
 void close()
           
 void open(OutputStream out)
           
 void serialize(DatumWrapper<ITuple> wrapper)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TupleSerializer

public TupleSerializer(HadoopSerialization ser,
                       TupleMRConfig tupleMRConfig,
                       boolean inputSchemaValidation)
Method Detail

open

public void open(OutputStream out)
Specified by:
open in interface org.apache.hadoop.io.serializer.Serializer<DatumWrapper<ITuple>>

serialize

public void serialize(DatumWrapper<ITuple> wrapper)
               throws IOException
Specified by:
serialize in interface org.apache.hadoop.io.serializer.Serializer<DatumWrapper<ITuple>>
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface org.apache.hadoop.io.serializer.Serializer<DatumWrapper<ITuple>>
Throws:
IOException


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