dR4W9Lc7

1# create keyspace
2CREATE KEYSPACE IF NOT EXISTS siddhi
3WITH replication = {
4  'class':'NetworkTopologyStrategy',
5  'DC1':'1'
6};
7
8# create table
9CREATE TABLE IF NOT EXISTS siddhi.blobs (
10  id TEXT,
11  payload TEXT,
12  timestamp TIMESTAMP,
13
14  PRIMARY KEY(id)
15);
16
17# create trigger
18CREATE TRIGGER siddhi
19  ON siddhi.blobs
20  USING 'com.rahasak.siddhi.SiddhiTrigger';
21  
22# view triggers
23USE system_schema;
24SELECT * FROM triggers;
25
26# drop trigger
27DROP TRIGGER IF EXISTS siddhi ON siddhi.blobs ;