public class BytesSerialization extends Configured implements Comparison<byte[]>, Serialization<byte[]>
Serialization
interface for use
by byte
arrays (byte[]
).
To use, callTupleSerializationProps.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.Modifier and Type | Class and Description |
---|---|
static class |
BytesSerialization.RawBytesDeserializer |
static class |
BytesSerialization.RawBytesSerializer |
Constructor and Description |
---|
BytesSerialization() |
Modifier and Type | Method and Description |
---|---|
boolean |
accept(Class<?> c) |
Comparator<byte[]> |
getComparator(Class<byte[]> type) |
Deserializer<byte[]> |
getDeserializer(Class<byte[]> c) |
Serializer<byte[]> |
getSerializer(Class<byte[]> c) |
getConf, setConf
public BytesSerialization()
public boolean accept(Class<?> c)
accept
in interface Serialization<byte[]>
public Serializer<byte[]> getSerializer(Class<byte[]> c)
getSerializer
in interface Serialization<byte[]>
public Deserializer<byte[]> getDeserializer(Class<byte[]> c)
getDeserializer
in interface Serialization<byte[]>
public Comparator<byte[]> getComparator(Class<byte[]> type)
getComparator
in interface Comparison<byte[]>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.