|
1 2 3 4 | CREATE TABLE error_counts AS SELECT error_code, count (*) FROM monitoring_stream WINDOW TUMBLING ( SIZE 1 MINUTE ) WHERE type = 'ERROR' |
1 2 3 4 5 6 | CREATE TABLE possible_fraud AS SELECT card_number, count (*) FROM authorization_attempts WINDOW TUMBLING ( SIZE 5 SECONDS) GROUP BY card_number HAVING count (*) > 3; |
1 2 3 4 5 | CREATE STREAM vip_users AS SELECT userid, page, action FROM clickstream c LEFT JOIN users u ON c.userid = u.user_id WHERE u. level = 'Platinum' ; |
1 2 | CREATE STREAM pageviews (viewtime BIGINT , userid VARCHAR , pageid VARCHAR ) WITH (kafka_topic= 'pageviews' , value_format=’JSON’); |
1 2 | CREATE TABLE users (registertime BIGINT , gender VARCHAR , regionid VARCHAR , userid VARCHAR ) WITH (kafka_topic= 'users' , value_format= 'DELIMITED' ); |