import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
public NonTerminal prepare(String keyspace, ColumnSpecification receiver) throws InvalidRequestException
{
    if (receiver.type.isCollection())
    {
        switch (((CollectionType) receiver.type).kind)
        {
            case LIST:
                return new Lists.Marker(bindIndex, receiver);
            case SET:
                return new Sets.Marker(bindIndex, receiver);
            case MAP:
                return new Maps.Marker(bindIndex, receiver);
            default:
                throw new AssertionError();
        }
    }
    else if (receiver.type.isUDT())
    {
        return new UserTypes.Marker(bindIndex, receiver);
    }

    return new Constants.Marker(bindIndex, receiver);
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
@Override
public String toString()
{
    if (isCounterCell())
        return String.format("[%s=%d ts=%d]", column().name, CounterContext.instance().total(value()), timestamp());

    AbstractType<?> type = column().type;
    if (type instanceof CollectionType && type.isMultiCell())
    {
        CollectionType ct = (CollectionType)type;
        return String.format("[%s[%s]=%s %s]",
                             column().name,
                             ct.nameComparator().getString(path().get(0)),
                             ct.valueComparator().getString(value()),
                             livenessInfoString());
    }
    if (isTombstone())
        return String.format("[%s=<tombstone> %s]", column().name, livenessInfoString());
    else
        return String.format("[%s=%s %s]", column().name, type.getString(value()), livenessInfoString());
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
public Operation prepare(CFDefinition.Name receiver) throws InvalidRequestException
{
    Term v = value.prepare(receiver);

    if (receiver.type instanceof CounterColumnType)
        throw new InvalidRequestException(String.format("Cannot set the value of counter column %s (counters can only be incremented/decremented, not set)", receiver));

    if (!(receiver.type instanceof CollectionType))
        return new Constants.Setter(receiver.kind == CFDefinition.Name.Kind.VALUE_ALIAS ? null : receiver.name, v);

    switch (((CollectionType)receiver.type).kind)
    {
        case LIST:
            return new Lists.Setter(receiver.name, v);
        case SET:
            return new Sets.Setter(receiver.name, v);
        case MAP:
            return new Maps.Setter(receiver.name, v);
    }
    throw new AssertionError();
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
private static void addValue(Selection.ResultSetBuilder result, ColumnDefinition def, CQL3Row row, QueryOptions options)
{
    if (row == null)
    {
        result.add((ByteBuffer)null);
        return;
    }

    if (def.type.isCollection())
    {
        List<Cell> collection = row.getCollection(def.name);
        ByteBuffer value = collection == null
                         ? null
                         : ((CollectionType)def.type).serializeForNativeProtocol(collection, options.getProtocolVersion());
        result.add(value);
        return;
    }

    result.add(row.getColumn(def.name));
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
public Operation prepare(String keyspace, ColumnDefinition receiver) throws InvalidRequestException
{
    Term v = value.prepare(keyspace, receiver);

    if (receiver.type instanceof CounterColumnType)
        throw new InvalidRequestException(String.format("Cannot set the value of counter column %s (counters can only be incremented/decremented, not set)", receiver));

    if (!(receiver.type instanceof CollectionType))
        return new Constants.Setter(receiver, v);

    switch (((CollectionType)receiver.type).kind)
    {
        case LIST:
            return new Lists.Setter(receiver, v);
        case SET:
            return new Sets.Setter(receiver, v);
        case MAP:
            return new Maps.Setter(receiver, v);
    }
    throw new AssertionError();
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
@Override
public String toString()
{
    // This assert we're dealing with a collection since that's the only thing it's used for so far.
    AbstractType<?> type = ((CollectionType<?>)column().type).nameComparator();
    return String.format("[%s:%s]", from == CellPath.BOTTOM ? "" : type.getString(from.get(0)), to == CellPath.TOP ? "" : type.getString(to.get(0)));
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
/**
 * The type of the cell values for cell belonging to this column.
 *
 * This is the same than the column type, except for collections where it's the 'valueComparator'
 * of the collection.
 */
public AbstractType<?> cellValueType()
{
    return type instanceof CollectionType
         ? ((CollectionType)type).valueComparator()
         : type;
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
public boolean hasCollectionColumns()
{
    for (ColumnDefinition def : partitionColumns())
        if (def.type instanceof CollectionType && def.type.isMultiCell())
            return true;
    return false;
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
public boolean hasDroppedCollectionColumns()
{
    for (DroppedColumn def : getDroppedColumns().values())
        if (def.type instanceof CollectionType && def.type.isMultiCell())
            return true;
    return false;
}
 

import org.apache.cassandra.db.marshal.CollectionType; //导入依赖的package包/类
public AbstractMarker prepare(String keyspace, ColumnSpecification receiver) throws InvalidRequestException
{
    if (!(receiver.type instanceof CollectionType))
        return new Constants.Marker(bindIndex, receiver);

    switch (((CollectionType)receiver.type).kind)
    {
        case LIST: return new Lists.Marker(bindIndex, receiver);
        case SET:  return new Sets.Marker(bindIndex, receiver);
        case MAP:  return new Maps.Marker(bindIndex, receiver);
    }
    throw new AssertionError();
}