import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
/**
 * null check on the value to prevent {@link java.lang.IllegalArgumentException}
 * @param updater
 * @param columnName
 * @param value
 */
public static void addUpdateStringValue(ColumnFamilyUpdater<String,String> updater, String columnName, String value )
{
    if (value == null)
    {
        return;
    }
    updater.setString( columnName, value );

}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
protected void doPut(byte[] key, byte[] value) throws StorageException {
	try {
		ColumnFamilyUpdater<byte[], String> updater = template
				.createUpdater(key);
		updater.setByteArray(CassandraStorageSystem.COLUMN_NAME, value);
		template.update(updater);
	} catch (HectorException e) {
		handleHectorException(e);
	}
}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
/** {@inheritDoc} */
@Override
public void close() throws IOException {
    if (dirty) {
        ColumnFamilyUpdater<String, String> updater = template.createUpdater(getPath());
        updater.setByteArray(RRD, buffer);
        template.update(updater);
    }
}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
private void update(ColumnFamilyTemplate<String, String> template) {
    ColumnFamilyUpdater<String, String> updater = template.createUpdater("a key");
    updater.setString("domain", "www.chaosxu.com");
    updater.setLong("time", System.currentTimeMillis());

    template.update(updater);
}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
@Override
public void create(ShardKey shardKey, ActorSystemEvent event, ActorSystemEventListener listener) {
    byte[] value = ActorSystemEventListenerSerializer.get().serialize(listener);
    ColumnFamilyUpdater<Composite,String> updater = columnFamilyTemplate.createUpdater(createKey(shardKey, event));
    updater.setByteArray(listener.getActorId(),value);
    columnFamilyTemplate.update(updater);
}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
@Override
public void delete(ShardKey shardKey, ActorSystemEvent event, ActorRef listenerId) {
    ColumnFamilyUpdater<Composite, String> updater = columnFamilyTemplate.createUpdater();
    updater.addKey(createKey(shardKey, event));
    updater.deleteColumn(listenerId.getActorId());
    columnFamilyTemplate.update(updater);
}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
@Override
public void create(ShardKey shardKey, ScheduledMessage scheduledMessage) {
    final ColumnFamilyUpdater<Composite,Composite> updater = columnFamilyTemplate.createUpdater(createKey(shardKey));
    final Composite columnName = createColumnName(scheduledMessage);
    updater.setByteArray(columnName, ScheduledMessageSerializer.get().serialize(scheduledMessage));
    columnFamilyTemplate.update(updater);
}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
/**
 * Updates the value of the column in the given row (identified by the key).
 *
 * @param key        - key to identify the row.
 * @param columnName - column to be updated.
 * @param value      - value to be inserted.
 */
public void updateString(K key, String columnName, String value) {

	// update the secondary index, if needed
	updateSecondaryIndexes(key, columnName, value, -1, -1);

	final ColumnFamilyTemplate<K, String> columnFamilyLocal = getColumnFamily();
	final ColumnFamilyUpdater<K, String> updater = columnFamilyLocal.createUpdater(key);
	updater.setString(columnName, value);
	columnFamilyLocal.update(updater);


}
 

import me.prettyprint.cassandra.service.template.ColumnFamilyUpdater; //导入依赖的package包/类
/**
 * Updates the value of the column in the given row (identified by the key).
 *
 * @param key        - key to identify the row.
 * @param columnName - column to be updated.
 * @param value      - value to be inserted.
 */
public void updateByteBuffer(K key, String columnName, ByteBuffer value) {
	final ColumnFamilyTemplate<K, String> columnFamilyLocal = getColumnFamily();
	final ColumnFamilyUpdater<K, String> updater = columnFamilyLocal.createUpdater(key);
	updater.setByteBuffer(columnName, value);
	columnFamilyLocal.update(updater);
}