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

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

All Implemented Interfaces:

cascading.tuple.Comparison<com.google.protobuf.Message>, org.apache.hadoop.io.serializer.Serialization<com.google.protobuf.Message>

public class ProtobufSerialization
extends Object
implements org.apache.hadoop.io.serializer.Serialization<com.google.protobuf.Message>, cascading.tuple.Comparison<com.google.protobuf.Message>

Serialization format class

Author:

Ning Liang

Constructor Summary

ProtobufSerialization()

Method Summary

boolean	accept(Class<?> klass)
Comparator<com.google.protobuf.Message>	getComparator(Class<com.google.protobuf.Message> klass)
org.apache.hadoop.io.serializer.Deserializer<com.google.protobuf.Message>	getDeserializer(Class<com.google.protobuf.Message> klass)
org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message>	getSerializer(Class<com.google.protobuf.Message> klass)

Methods inherited from class java.lang.Object

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

Constructor Detail

ProtobufSerialization

public ProtobufSerialization()

Method Detail

accept

public boolean accept(Class<?> klass)

Specified by:

accept in interface org.apache.hadoop.io.serializer.Serialization<com.google.protobuf.Message>

getDeserializer

public org.apache.hadoop.io.serializer.Deserializer<com.google.protobuf.Message> getDeserializer(Class<com.google.protobuf.Message> klass)

Specified by:

getDeserializer in interface org.apache.hadoop.io.serializer.Serialization<com.google.protobuf.Message>

getSerializer

public org.apache.hadoop.io.serializer.Serializer<com.google.protobuf.Message> getSerializer(Class<com.google.protobuf.Message> klass)

Specified by:

getSerializer in interface org.apache.hadoop.io.serializer.Serialization<com.google.protobuf.Message>

getComparator

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

Specified by:

getComparator in interface cascading.tuple.Comparison<com.google.protobuf.Message>