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

minor cleanups in trigger sample

This commit is contained in:
Dave Brosius 2014-05-15 22:23:02 -04:00
parent 33939cae69
commit 3ce2ce7144
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
examples/triggers/src/org/apache/cassandra/triggers/InvertedIndex.java
View File

@ -41,13 +41,15 @@ public class InvertedIndex implements ITrigger
{
List<Mutation> mutations = new ArrayList<>(update.getColumnCount());
String indexKeySpace = properties.getProperty("keyspace");
String indexColumnFamily = properties.getProperty("columnfamily")
for (Cell cell : update)
{
// Skip the row marker and other empty values, since they lead to an empty key.
if (cell.value().remaining() > 0)
{
Mutation mutation = new Mutation(properties.getProperty("keyspace"), cell.value());
mutation.add(properties.getProperty("columnfamily"), cell.name(), key, System.currentTimeMillis());
Mutation mutation = new Mutation(indexKeySpace, cell.value());
mutation.add(indexColumnFamily, cell.name(), key, System.currentTimeMillis());
mutations.add(mutation);
}
}