FWWTrigger.java

package org.apache.cassandra.triggers;

import java.nio.ByteBuffer;
import java.util.Collection;
import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.db.Mutation;
import org.apache.cassandra.db.Cell;

public class FWWTrigger implements ITrigger {
    public Collection<Mutation> augment(ByteBuffer partitionKey, ColumnFamily update) {
        ColumnFamily tupdate = update.cloneMe();
        update.clear();
        for (Cell tcell : tupdate)
            update.addColumn(tcell.withUpdatedTimestamp(tcell.timestamp() * -1));
        return null;
    }
}