com.datasalt.pangool.tuplemr.serialization
Class TupleDeserializer

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

public class TupleDeserializer
extends Object
implements org.apache.hadoop.io.serializer.Deserializer<DatumWrapper<ITuple>>


Constructor Summary
TupleDeserializer(HadoopSerialization ser, TupleMRConfig tupleMRConfig, org.apache.hadoop.conf.Configuration conf)
           
 
Method Summary
 void close()
           
 DatumWrapper<ITuple> deserialize(DatumWrapper<ITuple> t)
           
 void open(InputStream in)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TupleDeserializer

public TupleDeserializer(HadoopSerialization ser,
                         TupleMRConfig tupleMRConfig,
                         org.apache.hadoop.conf.Configuration conf)
Method Detail

open

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

deserialize

public DatumWrapper<ITuple> deserialize(DatumWrapper<ITuple> t)
                                 throws IOException
Specified by:
deserialize in interface org.apache.hadoop.io.serializer.Deserializer<DatumWrapper<ITuple>>
Throws:
IOException

close

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


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