cascading.tuple.hadoop
Class BytesSerialization
java.lang.Object
org.apache.hadoop.conf.Configured
cascading.tuple.hadoop.BytesSerialization
- All Implemented Interfaces:
- Comparison<byte[]>, Configurable, Serialization<byte[]>
- Direct Known Subclasses:
- NoTokenTestBytesSerialization
public class BytesSerialization
- extends Configured
- implements Comparison<byte[]>, Serialization<byte[]>
Class BytesSerialization is an implementation of Hadoop's Serialization
interface for use
by byte
arrays (byte[]
).
To use, call
TupleSerialization.addSerialization(properties, BytesSerialization.class.getName() );
This class also implements Comparison
so it is not required to set a BytesComparator
when attempting to group on a byte array via GroupBy or CoGroup.
- See Also:
TupleSerialization.addSerialization(java.util.Map, String)
,
BytesComparator
,
Comparison
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
BytesSerialization
public BytesSerialization()
accept
public boolean accept(Class<?> c)
- Specified by:
accept
in interface Serialization<byte[]>
getSerializer
public Serializer<byte[]> getSerializer(Class<byte[]> c)
- Specified by:
getSerializer
in interface Serialization<byte[]>
getDeserializer
public Deserializer<byte[]> getDeserializer(Class<byte[]> c)
- Specified by:
getDeserializer
in interface Serialization<byte[]>
getComparator
public Comparator<byte[]> getComparator(Class<byte[]> type)
- Specified by:
getComparator
in interface Comparison<byte[]>
Copyright © 2007-2012 Concurrent, Inc. All Rights Reserved.