import org.apache.cassandra.dht.LocalToken; //导入依赖的package包/类
/**
 * Returns the decoratedKey for a column value
 * @param value column value
 * @return decorated key
 */
public DecoratedKey getIndexKeyFor(ByteBuffer value)
{
    // FIXME: this imply one column definition per index
    ByteBuffer name = columnDefs.iterator().next().name.bytes;
    return new BufferDecoratedKey(new LocalToken(baseCfs.metadata.getColumnDefinition(name).type, value), value);
}
 

import org.apache.cassandra.dht.LocalToken; //导入依赖的package包/类
/**
 * Returns the decoratedKey for a column value
 * @param value column value
 * @return decorated key
 */
public DecoratedKey getIndexKeyFor(ByteBuffer value)
{
    // FIXME: this imply one column definition per index
    ByteBuffer name = columnDefs.iterator().next().name.bytes;
    return new DecoratedKey(new LocalToken(baseCfs.metadata.getColumnDefinition(name).type, value), value);
}
 

import org.apache.cassandra.dht.LocalToken; //导入依赖的package包/类
public static void cleanupIndexEntry(ColumnFamilyStore cfs, ByteBuffer key, IColumn column)
{
    if (column.isMarkedForDelete())
        return;
    int localDeletionTime = (int) (System.currentTimeMillis() / 1000);
    DecoratedKey<LocalToken> valueKey = cfs.getIndexKeyFor(column.name(), column.value());
    ColumnFamily cfi = cfs.newIndexedColumnFamily(column.name());
    cfi.addTombstone(key, localDeletionTime, column.timestamp());
    Memtable fullMemtable = cfs.getIndexedColumnFamilyStore(column.name()).apply(valueKey, cfi);
    if (logger.isDebugEnabled())
        logger.debug("removed index entry for cleaned-up value {}:{}", valueKey, cfi);
    if (fullMemtable != null)
        fullMemtable.cfs.maybeSwitchMemtable(fullMemtable, false);
}
 

import org.apache.cassandra.dht.LocalToken; //导入依赖的package包/类
@Override
public DecoratedKey getIndexKeyFor(ByteBuffer value)
{
    return new BufferDecoratedKey(new LocalToken(getIndexKeyComparator(), value), value);
}
 

import org.apache.cassandra.dht.LocalToken; //导入依赖的package包/类
@Override
public DecoratedKey getIndexKeyFor(ByteBuffer value)
{
    return new DecoratedKey(new LocalToken(getIndexKeyComparator(), value), value);
}