You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by sl...@apache.org on 2016/11/14 09:13:59 UTC
[2/3] cassandra git commit: example/triggers build fail.
example/triggers build fail.
patch by Sylvain Lebresne; reviewed by Alex Petrov for CASSANDRA-12861
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/5e9d9ebb
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/5e9d9ebb
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/5e9d9ebb
Branch: refs/heads/trunk
Commit: 5e9d9ebb0fb70020d9c83ae99c2ff97aa79ee422
Parents: 5788155
Author: Sylvain Lebresne <sy...@datastax.com>
Authored: Wed Nov 9 15:33:10 2016 +0100
Committer: Sylvain Lebresne <sy...@datastax.com>
Committed: Mon Nov 14 10:13:06 2016 +0100
----------------------------------------------------------------------
.../apache/cassandra/triggers/AuditTrigger.java | 17 +++++++++--------
1 file changed, 9 insertions(+), 8 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/5e9d9ebb/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java
----------------------------------------------------------------------
diff --git a/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java b/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java
index 7739450..1efbf13 100644
--- a/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java
+++ b/examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java
@@ -22,10 +22,11 @@ import java.util.Collection;
import java.util.Collections;
import java.util.Properties;
+import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.config.Schema;
import org.apache.cassandra.db.Mutation;
-import org.apache.cassandra.db.RowUpdateBuilder;
import org.apache.cassandra.db.partitions.Partition;
+import org.apache.cassandra.db.partitions.PartitionUpdate;
import org.apache.cassandra.io.util.FileUtils;
import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.UUIDGen;
@@ -39,15 +40,15 @@ public class AuditTrigger implements ITrigger
String auditKeyspace = properties.getProperty("keyspace");
String auditTable = properties.getProperty("table");
- RowUpdateBuilder audit = new RowUpdateBuilder(Schema.instance.getCFMetaData(auditKeyspace, auditTable),
- FBUtilities.timestampMicros(),
- UUIDGen.getTimeUUID());
+ CFMetaData metadata = Schema.instance.getCFMetaData(auditKeyspace, auditTable);
+ PartitionUpdate.SimpleBuilder audit = PartitionUpdate.simpleBuilder(metadata, UUIDGen.getTimeUUID());
- audit.add("keyspace_name", update.metadata().ksName);
- audit.add("table_name", update.metadata().cfName);
- audit.add("primary_key", update.metadata().getKeyValidator().getString(update.partitionKey().getKey()));
+ audit.row()
+ .add("keyspace_name", update.metadata().ksName)
+ .add("table_name", update.metadata().cfName)
+ .add("primary_key", update.metadata().getKeyValidator().getString(update.partitionKey().getKey()));
- return Collections.singletonList(audit.build());
+ return Collections.singletonList(audit.buildAsMutation());
}
private static Properties loadProperties()