Package org.apache.cassandra.serializers
Class CollectionSerializer<T>
- java.lang.Object
-
- org.apache.cassandra.serializers.TypeSerializer<T>
-
- org.apache.cassandra.serializers.CollectionSerializer<T>
-
- Direct Known Subclasses:
ListSerializer
,MapSerializer
,SetSerializer
public abstract class CollectionSerializer<T> extends TypeSerializer<T>
-
-
Constructor Summary
Constructors Constructor Description CollectionSerializer()
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected java.nio.ByteBuffer
copyAsNewCollection(java.nio.ByteBuffer input, int count, int startPos, int endPos, ProtocolVersion version)
Creates a new serialized map composed from the data frominput
betweenstartPos
(inclusive) andendPos
(exclusive), assuming that data holdscount
elements.<V> T
deserialize(V value, ValueAccessor<V> accessor)
T
deserializeForNativeProtocol(java.nio.ByteBuffer value, ProtocolVersion version)
abstract <V> T
deserializeForNativeProtocol(V value, ValueAccessor<V> accessor, ProtocolVersion version)
protected abstract int
getElementCount(T value)
abstract java.nio.ByteBuffer
getSerializedValue(java.nio.ByteBuffer collection, java.nio.ByteBuffer key, AbstractType<?> comparator)
Extract an element from a serialized collection.abstract java.nio.ByteBuffer
getSliceFromSerialized(java.nio.ByteBuffer collection, java.nio.ByteBuffer from, java.nio.ByteBuffer to, AbstractType<?> comparator, boolean frozen)
Returns the slice of a collection directly from its serialized value.static java.nio.ByteBuffer
pack(java.util.Collection<java.nio.ByteBuffer> values, int elements, ProtocolVersion version)
static <V> V
pack(java.util.Collection<V> values, ValueAccessor<V> accessor, int elements, ProtocolVersion version)
static int
readCollectionSize(java.nio.ByteBuffer input, ProtocolVersion version)
static <V> int
readCollectionSize(V value, ValueAccessor<V> accessor, ProtocolVersion version)
static <V> V
readValue(V input, ValueAccessor<V> accessor, int offset, ProtocolVersion version)
java.nio.ByteBuffer
serialize(T input)
protected abstract java.util.List<java.nio.ByteBuffer>
serializeValues(T value)
static int
sizeOfCollectionSize(int elements, ProtocolVersion version)
static <V> int
sizeOfValue(V value, ValueAccessor<V> accessor, ProtocolVersion version)
protected static void
skipValue(java.nio.ByteBuffer input, ProtocolVersion version)
static <V> int
skipValue(V input, ValueAccessor<V> accessor, int offset, ProtocolVersion version)
<T1> void
validate(T1 value, ValueAccessor<T1> accessor)
abstract <V> void
validateForNativeProtocol(V value, ValueAccessor<V> accessor, ProtocolVersion version)
protected static void
writeCollectionSize(java.nio.ByteBuffer output, int elements, ProtocolVersion version)
static <V> void
writeValue(java.nio.ByteBuffer output, V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
Methods inherited from class org.apache.cassandra.serializers.TypeSerializer
deserialize, getType, toCQLLiteral, toString, validate
-
-
-
-
Method Detail
-
serializeValues
protected abstract java.util.List<java.nio.ByteBuffer> serializeValues(T value)
-
getElementCount
protected abstract int getElementCount(T value)
-
deserializeForNativeProtocol
public abstract <V> T deserializeForNativeProtocol(V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
deserializeForNativeProtocol
public T deserializeForNativeProtocol(java.nio.ByteBuffer value, ProtocolVersion version)
-
validateForNativeProtocol
public abstract <V> void validateForNativeProtocol(V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
serialize
public java.nio.ByteBuffer serialize(T input)
- Specified by:
serialize
in classTypeSerializer<T>
-
deserialize
public <V> T deserialize(V value, ValueAccessor<V> accessor)
- Specified by:
deserialize
in classTypeSerializer<T>
-
validate
public <T1> void validate(T1 value, ValueAccessor<T1> accessor) throws MarshalException
- Specified by:
validate
in classTypeSerializer<T>
- Throws:
MarshalException
-
pack
public static java.nio.ByteBuffer pack(java.util.Collection<java.nio.ByteBuffer> values, int elements, ProtocolVersion version)
-
pack
public static <V> V pack(java.util.Collection<V> values, ValueAccessor<V> accessor, int elements, ProtocolVersion version)
-
writeCollectionSize
protected static void writeCollectionSize(java.nio.ByteBuffer output, int elements, ProtocolVersion version)
-
readCollectionSize
public static int readCollectionSize(java.nio.ByteBuffer input, ProtocolVersion version)
-
readCollectionSize
public static <V> int readCollectionSize(V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
sizeOfCollectionSize
public static int sizeOfCollectionSize(int elements, ProtocolVersion version)
-
writeValue
public static <V> void writeValue(java.nio.ByteBuffer output, V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
readValue
public static <V> V readValue(V input, ValueAccessor<V> accessor, int offset, ProtocolVersion version)
-
skipValue
protected static void skipValue(java.nio.ByteBuffer input, ProtocolVersion version)
-
skipValue
public static <V> int skipValue(V input, ValueAccessor<V> accessor, int offset, ProtocolVersion version)
-
sizeOfValue
public static <V> int sizeOfValue(V value, ValueAccessor<V> accessor, ProtocolVersion version)
-
getSerializedValue
public abstract java.nio.ByteBuffer getSerializedValue(java.nio.ByteBuffer collection, java.nio.ByteBuffer key, AbstractType<?> comparator)
Extract an element from a serialized collection.Note that this is only supported to sets and maps. For sets, this mostly ends up being a check for the presence of the provide key: it will return the key if it's present and
null
otherwise.- Parameters:
collection
- the serialized collection. This cannot benull
.key
- the key to extract (This cannot benull
norByteBufferUtil.UNSET_BYTE_BUFFER
).comparator
- the type to use to compare thekey
value to those in the collection.- Returns:
- the value associated with
key
if one exists,null
otherwise
-
getSliceFromSerialized
public abstract java.nio.ByteBuffer getSliceFromSerialized(java.nio.ByteBuffer collection, java.nio.ByteBuffer from, java.nio.ByteBuffer to, AbstractType<?> comparator, boolean frozen)
Returns the slice of a collection directly from its serialized value.If the slice contains no elements an empty collection will be returned for frozen collections, and a
null
one for non-frozen collections.- Parameters:
collection
- the serialized collection. This cannot benull
.from
- the left bound of the slice to extract. This cannot benull
but if this isByteBufferUtil.UNSET_BYTE_BUFFER
, then the returned slice starts at the beginning ofcollection
.comparator
- the type to use to compare thefrom
andto
values to those in the collection.frozen
-true
if the collection is a frozen one,false
otherwise- Returns:
- a serialized collection corresponding to slice
[from, to]
ofcollection
.
-
copyAsNewCollection
protected java.nio.ByteBuffer copyAsNewCollection(java.nio.ByteBuffer input, int count, int startPos, int endPos, ProtocolVersion version)
Creates a new serialized map composed from the data frominput
betweenstartPos
(inclusive) andendPos
(exclusive), assuming that data holdscount
elements.
-
-