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

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

All Implemented Interfaces:

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

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

Deserializes delimited protobufs from input stream

Author:

Ning Liang

Constructor Summary

ProtobufDeserializer(Class<com.google.protobuf.Message> klass)

Method Summary

void	close()
com.google.protobuf.Message	deserialize(com.google.protobuf.Message message)
void	open(InputStream inStream)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufDeserializer

public ProtobufDeserializer(Class<com.google.protobuf.Message> klass)

Method Detail

open

public void open(InputStream inStream)
          throws IOException

Specified by:

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

Throws:

IOException

deserialize

public com.google.protobuf.Message deserialize(com.google.protobuf.Message message)
                                        throws IOException

Specified by:

deserialize in interface org.apache.hadoop.io.serializer.Deserializer<com.google.protobuf.Message>

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

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

Throws:

IOException