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

cosmetic trigger corrections (examples)

This commit is contained in:
Aleksey Yeschenko 2013-07-23 01:39:46 +03:00
parent 76664d2c1c
commit d7e14829fa
3 changed files with 11 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
examples/triggers/README.txt
View File

@ -16,6 +16,6 @@ Copy conf/* to <cassandra_home>/conf/
Create column family configured in InvertedIndex.properties Create column family configured in InvertedIndex.properties
Example: Keyspace1.InvertedIndex as configured in InvertedIndex.properties Example: Keyspace1.InvertedIndex as configured in InvertedIndex.properties
Configure trigger on the table. Configure trigger on the table.
Example: CREATE TRIGGER test1 ON "Keyspace1"."Standard1" Example: CREATE TRIGGER test1 ON "Keyspace1"."Standard1"
EXECUTE ('org.apache.cassandra.triggers.InvertedIndex'); USING 'org.apache.cassandra.triggers.InvertedIndex';
Start inserting data to the column family which has the triggers. Start inserting data to the column family which has the triggers.

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

@ -24,11 +24,12 @@ import java.util.Collection;
import java.util.List; import java.util.List;
import java.util.Properties; import java.util.Properties;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.apache.cassandra.db.ColumnFamily; import org.apache.cassandra.db.ColumnFamily;
import org.apache.cassandra.db.RowMutation; import org.apache.cassandra.db.RowMutation;
import org.apache.cassandra.io.util.FileUtils; import org.apache.cassandra.io.util.FileUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
public class InvertedIndex implements ITrigger { public class InvertedIndex implements ITrigger {
private static final Logger logger = LoggerFactory.getLogger(InvertedIndex.class); private static final Logger logger = LoggerFactory.getLogger(InvertedIndex.class);

12
src/java/org/apache/cassandra/cql3/Cql.g
View File

@ -502,19 +502,19 @@ createIndexStatement returns [CreateIndexStatement expr]
; ;
/** /**
* CREATE TRIGGER [triggerName] ON columnFamily (columnName) EXECUTE (class, class); * CREATE TRIGGER triggerName ON columnFamily USING 'triggerClass';
*/ */
createTriggerStatement returns [CreateTriggerStatement expr] createTriggerStatement returns [CreateTriggerStatement expr]
: K_CREATE K_TRIGGER (tn=IDENT) K_ON cf=columnFamilyName K_USING tc1=STRING_LITERAL : K_CREATE K_TRIGGER (name=IDENT) K_ON cf=columnFamilyName K_USING cls=STRING_LITERAL
{ $expr = new CreateTriggerStatement(cf, $tn.text, $tc1.text); } { $expr = new CreateTriggerStatement(cf, $name.text, $cls.text); }
; ;
/** /**
* DROP TRIGGER [triggerName] ON columnFamily (columnName); * DROP TRIGGER triggerName ON columnFamily;
*/ */
dropTriggerStatement returns [DropTriggerStatement expr] dropTriggerStatement returns [DropTriggerStatement expr]
: K_DROP K_TRIGGER (tn=IDENT) K_ON cf=columnFamilyName : K_DROP K_TRIGGER (name=IDENT) K_ON cf=columnFamilyName
{ $expr = new DropTriggerStatement(cf, $tn.text); } { $expr = new DropTriggerStatement(cf, $name.text); }
; ;
/** /**