Package org.apache.cassandra.db.marshal

Class DynamicCompositeType

java.lang.Object

org.apache.cassandra.db.marshal.AbstractType<java.nio.ByteBuffer>

org.apache.cassandra.db.marshal.AbstractCompositeType

org.apache.cassandra.db.marshal.DynamicCompositeType

All Implemented Interfaces:

java.util.Comparator<java.nio.ByteBuffer>, AssignmentTestable

public class DynamicCompositeType
extends AbstractCompositeType

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DynamicCompositeType.FixedValueComparator
static class	DynamicCompositeType.Serializer

Nested classes/interfaces inherited from class org.apache.cassandra.db.marshal.AbstractCompositeType

AbstractCompositeType.ParsedComparator

Nested classes/interfaces inherited from class org.apache.cassandra.db.marshal.AbstractType

AbstractType.ComparisonType

Nested classes/interfaces inherited from interface org.apache.cassandra.cql3.AssignmentTestable

AssignmentTestable.TestResult

Field Summary

Fields

Modifier and Type	Field	Description
java.util.Map<java.lang.Byte,AbstractType<?>>	aliases

Fields inherited from class org.apache.cassandra.db.marshal.AbstractType

comparatorSet, comparisonType, isByteOrderComparable, reverseComparator

Method Summary

Modifier and Type	Method	Description
java.nio.ByteBuffer	decompose(java.lang.Object... objects)
AbstractType<?>	expandUserTypes()	Replace any instances of UserType with equivalent TupleType-s.
protected <V> AbstractType<?>	getAndAppendComparator(int i, V value, ValueAccessor<V> accessor, java.lang.StringBuilder sb, int offset)	Adds type information from @param bb to @param sb.
protected <VL,VR> AbstractType<?>	getComparator(int i, VL left, ValueAccessor<VL> accessorL, VR right, ValueAccessor<VR> accessorR, int offsetL, int offsetR)	Adds DynamicCompositeType type information from @param bb1 to @param bb2.
protected <V> AbstractType<?>	getComparator(int i, V value, ValueAccessor<V> accessor, int offset)
protected <V> int	getComparatorSize(int i, V value, ValueAccessor<V> accessor, int offset)
static DynamicCompositeType	getInstance(java.util.Map<java.lang.Byte,AbstractType<?>> aliases)
static DynamicCompositeType	getInstance(TypeParser parser)
TypeSerializer<java.nio.ByteBuffer>	getSerializer()
boolean	isCompatibleWith(AbstractType<?> previous)	Returns true if this comparator is compatible with the provided previous comparator, that is if previous can safely be replaced by this.
protected AbstractCompositeType.ParsedComparator	parseComparator(int i, java.lang.String part)	Used by fromString
protected <V> boolean	readIsStatic(V value, ValueAccessor<V> accessor)
<V> boolean	referencesUserType(V name, ValueAccessor<V> accessor)
protected int	startingOffset(boolean isStatic)
java.lang.String	toString()	This must be overriden by subclasses if necessary so that for any AbstractType, this == TypeParser.parse(toString()).
protected <V> AbstractType<?>	validateComparator(int i, V input, ValueAccessor<V> accessor, int offset)	Like getComparator, but validates that @param i does not exceed the defined range
DynamicCompositeType	withUpdatedUserType(UserType udt)	Returns an instance of this type with all references to the provided user type recursively replaced with its new definition.

Methods inherited from class org.apache.cassandra.db.marshal.AbstractCompositeType

compareCustom, escape, fromJSONObject, fromString, getString, split, toJSONString, validate, validate

Methods inherited from class org.apache.cassandra.db.marshal.AbstractType

asCQL3Type, asCQLTypeStringList, checkComparable, compare, compare, compareCollectionMembers, compareForCQL, compose, compose, decompose, decomposeUntyped, freeze, freezeNestedMulticellTypes, getComponents, getString, getString, isCollection, isCounter, isEmptyValueMeaningless, isFreezable, isFrozenCollection, isMultiCell, isReversed, isSerializationCompatibleWith, isTuple, isUDT, isValueCompatibleWith, isValueCompatibleWithInternal, parseDefaultParameters, read, readArray, readBuffer, readBuffer, referencesDuration, referencesUserType, skipValue, subTypes, testAssignment, testAssignment, toCQLString, toJSONString, toString, udfType, unwrap, validateCellValue, validateCollectionMember, valueLengthIfFixed, writeValue, writeValue, writtenLength, writtenLength

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Comparator

equals, reversed, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong

Field Detail

aliases

public final java.util.Map<java.lang.Byte,AbstractType<?>> aliases

Method Detail

getInstance

public static DynamicCompositeType getInstance(TypeParser parser)

getInstance

public static DynamicCompositeType getInstance(java.util.Map<java.lang.Byte,AbstractType<?>> aliases)

getSerializer

public TypeSerializer<java.nio.ByteBuffer> getSerializer()

Overrides:

getSerializer in class AbstractCompositeType

readIsStatic

protected <V> boolean readIsStatic(V value,
                                   ValueAccessor<V> accessor)

Specified by:

readIsStatic in class AbstractCompositeType

startingOffset

protected int startingOffset(boolean isStatic)

Specified by:

startingOffset in class AbstractCompositeType

getComparatorSize

protected <V> int getComparatorSize(int i,
                                    V value,
                                    ValueAccessor<V> accessor,
                                    int offset)

Specified by:

getComparatorSize in class AbstractCompositeType

getComparator

protected <V> AbstractType<?> getComparator(int i,
                                            V value,
                                            ValueAccessor<V> accessor,
                                            int offset)

Specified by:

getComparator in class AbstractCompositeType

Parameters:

i - DynamicCompositeType will read the type information from @param bb

value - name of type definition

Returns:

the comparator for the given component. static CompositeType will consult

getComparator

protected <VL,VR> AbstractType<?> getComparator(int i,
                                                      VL left,
                                                      ValueAccessor<VL> accessorL,
                                                      VR right,
                                                      ValueAccessor<VR> accessorR,
                                                      int offsetL,
                                                      int offsetR)

Description copied from class: AbstractCompositeType

Adds DynamicCompositeType type information from @param bb1 to @param bb2.

Specified by:

getComparator in class AbstractCompositeType

Parameters:

i - is ignored.

getAndAppendComparator

protected <V> AbstractType<?> getAndAppendComparator(int i,
                                                     V value,
                                                     ValueAccessor<V> accessor,
                                                     java.lang.StringBuilder sb,
                                                     int offset)

Description copied from class: AbstractCompositeType

Adds type information from @param bb to @param sb. @param i is ignored.

Specified by:

getAndAppendComparator in class AbstractCompositeType

parseComparator

protected AbstractCompositeType.ParsedComparator parseComparator(int i,
                                                                 java.lang.String part)

Description copied from class: AbstractCompositeType

Used by fromString

Specified by:

parseComparator in class AbstractCompositeType

validateComparator

protected <V> AbstractType<?> validateComparator(int i,
                                                 V input,
                                                 ValueAccessor<V> accessor,
                                                 int offset)
                                          throws MarshalException

Description copied from class: AbstractCompositeType

Like getComparator, but validates that @param i does not exceed the defined range

Specified by:

validateComparator in class AbstractCompositeType

Throws:

MarshalException

decompose

public java.nio.ByteBuffer decompose(java.lang.Object... objects)

Specified by:

decompose in class AbstractCompositeType

isCompatibleWith

public boolean isCompatibleWith(AbstractType<?> previous)

Description copied from class: AbstractType

Returns true if this comparator is compatible with the provided previous comparator, that is if previous can safely be replaced by this. A comparator cn should be compatible with a previous one cp if forall columns c1 and c2, if cn.validate(c1) and cn.validate(c2) and cn.compare(c1, c2) == v, then cp.validate(c1) and cp.validate(c2) and cp.compare(c1, c2) == v. Note that a type should be compatible with at least itself and when in doubt, keep the default behavior of not being compatible with any other comparator!

Overrides:

isCompatibleWith in class AbstractType<java.nio.ByteBuffer>

referencesUserType

public <V> boolean referencesUserType(V name,
                                      ValueAccessor<V> accessor)

Overrides:

referencesUserType in class AbstractType<java.nio.ByteBuffer>

withUpdatedUserType

public DynamicCompositeType withUpdatedUserType(UserType udt)

Description copied from class: AbstractType

Returns an instance of this type with all references to the provided user type recursively replaced with its new definition.

Overrides:

withUpdatedUserType in class AbstractType<java.nio.ByteBuffer>

expandUserTypes

public AbstractType<?> expandUserTypes()

Description copied from class: AbstractType

Replace any instances of UserType with equivalent TupleType-s. We need it for dropped_columns, to allow safely dropping unused user types later without retaining any references to them in system_schema.dropped_columns.

Overrides:

expandUserTypes in class AbstractType<java.nio.ByteBuffer>

toString

public java.lang.String toString()

Description copied from class: AbstractType

This must be overriden by subclasses if necessary so that for any AbstractType, this == TypeParser.parse(toString()). Note that for backwards compatibility this includes the full classname. For CQL purposes the short name is fine.

Overrides:

toString in class AbstractType<java.nio.ByteBuffer>