com.datasalt.pangool.serialization
Class ProtoStuffSerialization.ProtoStuffSerializer<T extends com.dyuproject.protostuff.Schema>

java.lang.Object
  extended by com.datasalt.pangool.serialization.ProtoStuffSerialization.ProtoStuffSerializer<T>
All Implemented Interfaces:
org.apache.hadoop.io.serializer.Serializer<T>
Enclosing class:
ProtoStuffSerialization

public static class ProtoStuffSerialization.ProtoStuffSerializer<T extends com.dyuproject.protostuff.Schema>
extends Object
implements org.apache.hadoop.io.serializer.Serializer<T>


Field Summary
protected static ThreadLocal<com.dyuproject.protostuff.LinkedBuffer> threadLocalBuffer
           
 
Constructor Summary
ProtoStuffSerialization.ProtoStuffSerializer()
           
 
Method Summary
 void close()
           
 void open(OutputStream out)
           
 void serialize(T t)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

threadLocalBuffer

protected static ThreadLocal<com.dyuproject.protostuff.LinkedBuffer> threadLocalBuffer
Constructor Detail

ProtoStuffSerialization.ProtoStuffSerializer

public ProtoStuffSerialization.ProtoStuffSerializer()
Method Detail

open

public void open(OutputStream out)
          throws IOException
Specified by:
open in interface org.apache.hadoop.io.serializer.Serializer<T extends com.dyuproject.protostuff.Schema>
Throws:
IOException

serialize

public void serialize(T t)
               throws IOException
Specified by:
serialize in interface org.apache.hadoop.io.serializer.Serializer<T extends com.dyuproject.protostuff.Schema>
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface org.apache.hadoop.io.serializer.Serializer<T extends com.dyuproject.protostuff.Schema>
Throws:
IOException


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