com.twitter.elephantbird.cascading2.io.protobuf
Class ProtobufSerializer

java.lang.Object
  com.twitter.elephantbird.cascading2.io.protobuf.ProtobufSerializer

All Implemented Interfaces:

org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message>

public class ProtobufSerializer
extends Object
implements org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message>

Serializes protobufs with delimiters

Author:

Ning Liang

Constructor Summary

ProtobufSerializer()

Method Summary

void	close()
void	open(OutputStream outStream)
void	serialize(com.google.protobuf.Message message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ProtobufSerializer

public ProtobufSerializer()

Method Detail

open

public void open(OutputStream outStream)
          throws IOException

Specified by:

open in interface org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message>

Throws:

IOException

serialize

public void serialize(com.google.protobuf.Message message)
               throws IOException

Specified by:

serialize in interface org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message>

Throws:

IOException