natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

example/triggers build fail. 

patch by Sylvain Lebresne; reviewed by Alex Petrov for CASSANDRA-12861
This commit is contained in:
Sylvain Lebresne 2016-11-09 15:33:10 +01:00
parent 578815541a
commit 5e9d9ebb0f
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
examples/triggers/src/org/apache/cassandra/triggers/AuditTrigger.java
View File

@ -22,10 +22,11 @@ import java.util.Collection;
import java.util.Collections; import java.util.Collections;
import java.util.Properties; import java.util.Properties;
import org.apache.cassandra.config.CFMetaData;
import org.apache.cassandra.config.Schema; import org.apache.cassandra.config.Schema;
import org.apache.cassandra.db.Mutation; 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.Partition;
import org.apache.cassandra.db.partitions.PartitionUpdate;
import org.apache.cassandra.io.util.FileUtils; import org.apache.cassandra.io.util.FileUtils;
import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.UUIDGen; import org.apache.cassandra.utils.UUIDGen;
@ -39,15 +40,15 @@ public class AuditTrigger implements ITrigger
String auditKeyspace = properties.getProperty("keyspace"); String auditKeyspace = properties.getProperty("keyspace");
String auditTable = properties.getProperty("table"); String auditTable = properties.getProperty("table");
RowUpdateBuilder audit = new RowUpdateBuilder(Schema.instance.getCFMetaData(auditKeyspace, auditTable), CFMetaData metadata = Schema.instance.getCFMetaData(auditKeyspace, auditTable);
FBUtilities.timestampMicros(), PartitionUpdate.SimpleBuilder audit = PartitionUpdate.simpleBuilder(metadata, UUIDGen.getTimeUUID());
UUIDGen.getTimeUUID());
audit.add("keyspace_name", update.metadata().ksName); audit.row()
audit.add("table_name", update.metadata().cfName); .add("keyspace_name", update.metadata().ksName)
audit.add("primary_key", update.metadata().getKeyValidator().getString(update.partitionKey().getKey())); .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() private static Properties loadProperties()