Package org.apache.cassandra.serializers
Class ListSerializer<T>
- java.lang.Object
-
- org.apache.cassandra.serializers.TypeSerializer<T>
-
- org.apache.cassandra.serializers.CollectionSerializer<java.util.List<T>>
-
- org.apache.cassandra.serializers.ListSerializer<T>
-
public class ListSerializer<T> extends CollectionSerializer<java.util.List<T>>
-
-
Field Summary
Fields Modifier and Type Field Description TypeSerializer<T>elements
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleananyMatch(java.nio.ByteBuffer serializedList, java.util.function.Predicate<java.nio.ByteBuffer> predicate)<V> booleananyMatch(V input, ValueAccessor<V> accessor, java.util.function.Predicate<V> predicate)<V> java.util.List<T>deserializeForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)java.nio.ByteBuffergetElement(java.nio.ByteBuffer input, int index)<V> VgetElement(V input, ValueAccessor<V> accessor, int index)Returns the element at the given index in a list.intgetElementCount(java.util.List<T> value)static <T> ListSerializer<T>getInstance(TypeSerializer<T> elements)java.nio.ByteBuffergetSerializedValue(java.nio.ByteBuffer collection, java.nio.ByteBuffer key, AbstractType<?> comparator)Extract an element from a serialized collection.java.nio.ByteBuffergetSliceFromSerialized(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.java.lang.Class<java.util.List<T>>getType()protected java.util.List<java.nio.ByteBuffer>serializeValues(java.util.List<T> values)java.lang.StringtoString(java.util.List<T> value)<V> voidvalidateForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)-
Methods inherited from class org.apache.cassandra.serializers.CollectionSerializer
copyAsNewCollection, deserialize, deserializeForNativeProtocol, pack, pack, readCollectionSize, readCollectionSize, readNonNullValue, readValue, serialize, sizeOfCollectionSize, sizeOfValue, skipValue, skipValue, validate, writeCollectionSize, writeValue
-
Methods inherited from class org.apache.cassandra.serializers.TypeSerializer
deserialize, toCQLLiteral, validate
-
-
-
-
Field Detail
-
elements
public final TypeSerializer<T> elements
-
-
Method Detail
-
getInstance
public static <T> ListSerializer<T> getInstance(TypeSerializer<T> elements)
-
serializeValues
protected java.util.List<java.nio.ByteBuffer> serializeValues(java.util.List<T> values)
- Specified by:
serializeValuesin classCollectionSerializer<java.util.List<T>>
-
getElementCount
public int getElementCount(java.util.List<T> value)
- Specified by:
getElementCountin classCollectionSerializer<java.util.List<T>>
-
validateForNativeProtocol
public <V> void validateForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)- Specified by:
validateForNativeProtocolin classCollectionSerializer<java.util.List<T>>
-
deserializeForNativeProtocol
public <V> java.util.List<T> deserializeForNativeProtocol(V input, ValueAccessor<V> accessor, ProtocolVersion version)
- Specified by:
deserializeForNativeProtocolin classCollectionSerializer<java.util.List<T>>
-
anyMatch
public boolean anyMatch(java.nio.ByteBuffer serializedList, java.util.function.Predicate<java.nio.ByteBuffer> predicate)
-
anyMatch
public <V> boolean anyMatch(V input, ValueAccessor<V> accessor, java.util.function.Predicate<V> predicate)
-
getElement
public <V> V getElement(V input, ValueAccessor<V> accessor, int index)Returns the element at the given index in a list.- Parameters:
input- a serialized listindex- the index to get- Returns:
- the serialized element at the given index, or null if the index exceeds the list size
-
getElement
public java.nio.ByteBuffer getElement(java.nio.ByteBuffer input, int index)
-
toString
public java.lang.String toString(java.util.List<T> value)
- Specified by:
toStringin classTypeSerializer<java.util.List<T>>
-
getType
public java.lang.Class<java.util.List<T>> getType()
- Specified by:
getTypein classTypeSerializer<java.util.List<T>>
-
getSerializedValue
public java.nio.ByteBuffer getSerializedValue(java.nio.ByteBuffer collection, java.nio.ByteBuffer key, AbstractType<?> comparator)Description copied from class:CollectionSerializerExtract 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
nullotherwise.- Specified by:
getSerializedValuein classCollectionSerializer<java.util.List<T>>- Parameters:
collection- the serialized collection. This cannot benull.key- the key to extract (This cannot benullnorByteBufferUtil.UNSET_BYTE_BUFFER).comparator- the type to use to compare thekeyvalue to those in the collection.- Returns:
- the value associated with
keyif one exists,nullotherwise
-
getSliceFromSerialized
public java.nio.ByteBuffer getSliceFromSerialized(java.nio.ByteBuffer collection, java.nio.ByteBuffer from, java.nio.ByteBuffer to, AbstractType<?> comparator, boolean frozen)Description copied from class:CollectionSerializerReturns 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
nullone for non-frozen collections.- Specified by:
getSliceFromSerializedin classCollectionSerializer<java.util.List<T>>- Parameters:
collection- the serialized collection. This cannot benull.from- the left bound of the slice to extract. This cannot benullbut if this isByteBufferUtil.UNSET_BYTE_BUFFER, then the returned slice starts at the beginning ofcollection.comparator- the type to use to compare thefromandtovalues to those in the collection.frozen-trueif the collection is a frozen one,falseotherwise- Returns:
- a serialized collection corresponding to slice
[from, to]ofcollection.
-
-