com.datasalt.pangool.tuplemr.serialization
Class AvroFieldSerialization.AvroFieldSerializer<T>

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

public static class AvroFieldSerialization.AvroFieldSerializer<T>
extends Object
implements org.apache.hadoop.io.serializer.Serializer<T>


Constructor Summary
AvroFieldSerialization.AvroFieldSerializer(org.apache.avro.Schema schema, boolean isReflect)
           
 
Method Summary
 void close()
           
 void open(OutputStream out)
           
 void serialize(T obj)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AvroFieldSerialization.AvroFieldSerializer

public AvroFieldSerialization.AvroFieldSerializer(org.apache.avro.Schema schema,
                                                  boolean isReflect)
Method Detail

open

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

serialize

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

close

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


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