import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private boolean updateDefinition(CFMetaData cfm, ColumnDefinition def, String keyspace, ByteBuffer toReplace, UserType updated)
{
    AbstractType<?> t = updateWith(def.type, keyspace, toReplace, updated);
    if (t == null)
        return false;

    // We need to update this validator ...
    cfm.addOrReplaceColumnDefinition(def.withNewType(t));

    // ... but if it's part of the comparator or key validator, we need to go update those too.
    switch (def.kind)
    {
        case PARTITION_KEY:
            cfm.keyValidator(updateWith(cfm.getKeyValidator(), keyspace, toReplace, updated));
            break;
        case CLUSTERING_COLUMN:
            cfm.comparator = CellNames.fromAbstractType(updateWith(cfm.comparator.asAbstractType(), keyspace, toReplace, updated), cfm.comparator.isDense());
            break;
        default:
            // If it's a collection, we still want to modify the comparator because the collection is aliased in it
            if (def.type instanceof CollectionType)
                cfm.comparator = CellNames.fromAbstractType(updateWith(cfm.comparator.asAbstractType(), keyspace, toReplace, updated), cfm.comparator.isDense());
    }
    return true;
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private boolean updateDefinition(CFMetaData cfm, ColumnDefinition def, String keyspace, ByteBuffer toReplace, UserType updated)
{
    AbstractType<?> t = updateWith(def.type, keyspace, toReplace, updated);
    if (t == null)
        return false;

    // We need to update this validator ...
    cfm.addOrReplaceColumnDefinition(def.withNewType(t));

    // ... but if it's part of the comparator or key validator, we need to go update those too.
    switch (def.kind)
    {
        case PARTITION_KEY:
            cfm.keyValidator(updateWith(cfm.getKeyValidator(), keyspace, toReplace, updated));
            break;
        case CLUSTERING_COLUMN:
            cfm.comparator = CellNames.fromAbstractType(updateWith(cfm.comparator.asAbstractType(), keyspace, toReplace, updated), cfm.comparator.isDense());
            break;
    }
    return true;
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private void retryDummyRead(String ks, String cf) throws PermanentBackendException {

        final long limit = System.currentTimeMillis() + (60L * 1000L);

        while (System.currentTimeMillis() < limit) {
            try {
                SortedSet<CellName> names = new TreeSet<>(new Comparator<CellName>() {
                    // This is a singleton set.  We need to define a comparator because SimpleDenseCellName is not
                    // comparable, but it doesn't have to be a useful comparator
                    @Override
                    public int compare(CellName o1, CellName o2)
                    {
                        return 0;
                    }
                });
                names.add(CellNames.simpleDense(ByteBufferUtil.zeroByteBuffer(1)));
                NamesQueryFilter nqf = new NamesQueryFilter(names);
                SliceByNamesReadCommand cmd = new SliceByNamesReadCommand(ks, ByteBufferUtil.zeroByteBuffer(1), cf, 1L, nqf);
                StorageProxy.read(ImmutableList.<ReadCommand> of(cmd), ConsistencyLevel.QUORUM);
                log.info("Read on CF {} in KS {} succeeded", cf, ks);
                return;
            } catch (Throwable t) {
                log.warn("Failed to read CF {} in KS {} following creation", cf, ks, t);
            }

            try {
                Thread.sleep(1000L);
            } catch (InterruptedException e) {
                throw new PermanentBackendException(e);
            }
        }

        throw new PermanentBackendException("Timed out while attempting to read CF " + cf + " in KS " + ks + " following creation");
    }
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private List<Cell> unthriftifySuper(SuperColumn super_column)
{
    List<Cell> cells = new ArrayList<Cell>(super_column.columns.size());
    for (org.apache.cassandra.thrift.Column column : super_column.columns)
    {
        Cell c = unthriftifySimple(column);
        cells.add(c.withUpdatedName(CellNames.simpleDense(CompositeType.build(super_column.name, c.name().toByteBuffer()))));
    }
    return cells;
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private List<Cell> unthriftifySuperCounter(CounterSuperColumn super_column)
{
    List<Cell> cells = new ArrayList<Cell>(super_column.columns.size());
    for (CounterColumn column : super_column.columns)
    {
        Cell c = unthriftifyCounter(column);
        cells.add(c.withUpdatedName(CellNames.simpleDense(CompositeType.build(super_column.name, c.name().toByteBuffer()))));
    }
    return cells;
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
/** get next row */
public Tuple getNext() throws IOException
{
    try
    {
        // load the next pair
        if (!reader.nextKeyValue())
            return null;

        CfInfo cfInfo = getCfInfo(loadSignature);
        CfDef cfDef = cfInfo.cfDef;
        Row row = reader.getCurrentValue();
        Tuple tuple = TupleFactory.getInstance().newTuple(cfDef.column_metadata.size());
        Iterator<ColumnDef> itera = cfDef.column_metadata.iterator();
        int i = 0;
        while (itera.hasNext())
        {
            ColumnDef cdef = itera.next();
            ByteBuffer columnValue = row.getBytesUnsafe(ByteBufferUtil.string(cdef.name.duplicate()));
            if (columnValue != null)
            {
                Cell cell = new BufferCell(CellNames.simpleDense(cdef.name), columnValue);
                AbstractType<?> validator = getValidatorMap(cfDef).get(cdef.name);
                setTupleValue(tuple, i, cqlColumnToObj(cell, cfDef), validator);
            }
            else
                tuple.set(i, null);
            i++;
        }
        return tuple;
    }
    catch (InterruptedException e)
    {
        throw new IOException(e.getMessage());
    }
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
@Override
public String toString()
{
    StringBuilder sb = new StringBuilder("ColumnFamily(");
    sb.append(metadata.cfName);

    if (isMarkedForDelete())
        sb.append(" -").append(deletionInfo()).append("-");

    sb.append(" [").append(CellNames.getColumnsString(getComparator(), this)).append("])");
    return sb.toString();
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
public List<IMutation> getWriteData()
{
    List<IMutation> rms = new LinkedList<IMutation>();
    Mutation rm = new Mutation(keyspaceName, ByteBufferUtil.bytes("key1"));
    rm.addCounter(cfname, CellNames.simpleDense(ByteBufferUtil.bytes("Column1")), 42);
    rms.add(new CounterMutation(rm, ConsistencyLevel.ONE));
    return rms;
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private ColumnFamily createCF(int nbCol)
{
    ColumnFamily cf = ArrayBackedSortedColumns.factory.create(createMetadata());
    for (int i = 0; i < nbCol; i++)
        cf.addColumn(CellNames.simpleDense(bb(i)), bb(i), 0);
    return cf;
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
@Test
public void test64kColumn()
{
    // a byte buffer more than 64k
    ByteBuffer buffer = ByteBuffer.allocate(1024 * 65);
    buffer.clear();

    //read more than 64k
    for (int i=0; i<1024*64/4 + 1; i++)
        buffer.putInt(0);

    // for read
    buffer.flip();
    Cell cell = new BufferCell(CellNames.simpleDense(ByteBufferUtil.bytes("test")), buffer, 0);

    SecondaryIndexCellSizeTest.MockRowIndex mockRowIndex = new SecondaryIndexCellSizeTest.MockRowIndex();
    SecondaryIndexCellSizeTest.MockColumnIndex mockColumnIndex = new SecondaryIndexCellSizeTest.MockColumnIndex();

    assertTrue(mockRowIndex.validate(cell));
    assertFalse(mockColumnIndex.validate(cell));

    // test less than 64k value
    buffer.flip();
    buffer.clear();
    buffer.putInt(20);
    buffer.flip();

    assertTrue(mockRowIndex.validate(cell));
    assertTrue(mockColumnIndex.validate(cell));
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private static void putColsSuper(ColumnFamilyStore cfs, DecoratedKey key, ByteBuffer scfName, Cell... cols) throws Throwable
{
    ColumnFamily cf = ArrayBackedSortedColumns.factory.create(cfs.keyspace.getName(), cfs.name);
    for (Cell col : cols)
        cf.addColumn(col.withUpdatedName(CellNames.compositeDense(scfName, col.name().toByteBuffer())));
    Mutation rm = new Mutation(cfs.keyspace.getName(), key.getKey(), cf);
    rm.apply();
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
@Test
public void testSliceByNamesCommandOnUUIDTypeSCF() throws Throwable
{
    String keyspaceName = "Keyspace1";
    String cfName = "Super6";
    ByteBuffer superColName = LexicalUUIDType.instance.fromString("a4ed3562-0e8e-4b41-bdfd-c45a2774682d");
    Keyspace keyspace = Keyspace.open(keyspaceName);
    ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(cfName);
    DecoratedKey key = Util.dk("slice-get-uuid-type");

    // Insert a row with one supercolumn and multiple subcolumns
    putColsSuper(cfs, key, superColName, new BufferCell(cellname("a"), ByteBufferUtil.bytes("A"), 1),
                                         new BufferCell(cellname("b"), ByteBufferUtil.bytes("B"), 1));

    // Get the entire supercolumn like normal
    ColumnFamily cfGet = cfs.getColumnFamily(QueryFilter.getIdentityFilter(key, cfName, System.currentTimeMillis()));
    assertEquals(ByteBufferUtil.bytes("A"), cfGet.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("a"))).value());
    assertEquals(ByteBufferUtil.bytes("B"), cfGet.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("b"))).value());

    // Now do the SliceByNamesCommand on the supercolumn, passing both subcolumns in as columns to get
    SortedSet<CellName> sliceColNames = new TreeSet<CellName>(cfs.metadata.comparator);
    sliceColNames.add(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("a")));
    sliceColNames.add(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("b")));
    SliceByNamesReadCommand cmd = new SliceByNamesReadCommand(keyspaceName, key.getKey(), cfName, System.currentTimeMillis(), new NamesQueryFilter(sliceColNames));
    ColumnFamily cfSliced = cmd.getRow(keyspace).cf;

    // Make sure the slice returns the same as the straight get
    assertEquals(ByteBufferUtil.bytes("A"), cfSliced.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("a"))).value());
    assertEquals(ByteBufferUtil.bytes("B"), cfSliced.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("b"))).value());
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
private static void putColsSuper(ColumnFamilyStore cfs, DecoratedKey key, ByteBuffer scfName, Cell... cols) throws Throwable
{
    ColumnFamily cf = ArrayBackedSortedColumns.factory.create(cfs.keyspace.getName(), cfs.name);
    for (Cell col : cols)
        cf.addColumn(col.withUpdatedName(CellNames.compositeDense(scfName, col.name().toByteBuffer())));
    Mutation rm = new Mutation(cfs.keyspace.getName(), key.getKey(), cf);
    rm.applyUnsafe();
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
@Test
public void testSliceByNamesCommandOnUUIDTypeSCF() throws Throwable
{
    String keyspaceName = KEYSPACE1;
    String cfName = CF_SUPER6;
    ByteBuffer superColName = LexicalUUIDType.instance.fromString("a4ed3562-0e8e-4b41-bdfd-c45a2774682d");
    Keyspace keyspace = Keyspace.open(keyspaceName);
    ColumnFamilyStore cfs = keyspace.getColumnFamilyStore(cfName);
    DecoratedKey key = Util.dk("slice-get-uuid-type");

    // Insert a row with one supercolumn and multiple subcolumns
    putColsSuper(cfs, key, superColName, new BufferCell(cellname("a"), ByteBufferUtil.bytes("A"), 1),
                                         new BufferCell(cellname("b"), ByteBufferUtil.bytes("B"), 1));

    // Get the entire supercolumn like normal
    ColumnFamily cfGet = cfs.getColumnFamily(QueryFilter.getIdentityFilter(key, cfName, System.currentTimeMillis()));
    assertEquals(ByteBufferUtil.bytes("A"), cfGet.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("a"))).value());
    assertEquals(ByteBufferUtil.bytes("B"), cfGet.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("b"))).value());

    // Now do the SliceByNamesCommand on the supercolumn, passing both subcolumns in as columns to get
    SortedSet<CellName> sliceColNames = new TreeSet<CellName>(cfs.metadata.comparator);
    sliceColNames.add(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("a")));
    sliceColNames.add(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("b")));
    SliceByNamesReadCommand cmd = new SliceByNamesReadCommand(keyspaceName, key.getKey(), cfName, System.currentTimeMillis(), new NamesQueryFilter(sliceColNames));
    ColumnFamily cfSliced = cmd.getRow(keyspace).cf;

    // Make sure the slice returns the same as the straight get
    assertEquals(ByteBufferUtil.bytes("A"), cfSliced.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("a"))).value());
    assertEquals(ByteBufferUtil.bytes("B"), cfSliced.getColumn(CellNames.compositeDense(superColName, ByteBufferUtil.bytes("b"))).value());
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
@Override
public String toString()
{
    StringBuilder sb = new StringBuilder("ColumnFamily(");
    sb.append(metadata == null ? "<anonymous>" : metadata.cfName);

    if (isMarkedForDelete())
        sb.append(" -").append(deletionInfo()).append("-");

    sb.append(" [").append(CellNames.getColumnsString(getComparator(), this)).append("])");
    return sb.toString();
}
 

import org.apache.cassandra.db.composites.CellNames; //导入依赖的package包/类
@Test
public void test64kColumn()
{
    // a byte buffer more than 64k
    ByteBuffer buffer = ByteBuffer.allocate(1024 * 65);
    buffer.clear();

    //read more than 64k
    for (int i=0; i<1024*64/4 + 1; i++)
        buffer.putInt(0);

    // for read
    buffer.flip();
    Cell cell = new Cell(CellNames.simpleDense(ByteBufferUtil.bytes("test")), buffer, 0);

    SecondaryIndexCellSizeTest.MockRowIndex mockRowIndex = new SecondaryIndexCellSizeTest.MockRowIndex();
    SecondaryIndexCellSizeTest.MockColumnIndex mockColumnIndex = new SecondaryIndexCellSizeTest.MockColumnIndex();

    assertTrue(mockRowIndex.validate(cell));
    assertFalse(mockColumnIndex.validate(cell));

    // test less than 64k value
    buffer.flip();
    buffer.clear();
    buffer.putInt(20);
    buffer.flip();

    assertTrue(mockRowIndex.validate(cell));
    assertTrue(mockColumnIndex.validate(cell));
}