...
Code Block |
---|
language | sql |
---|
title | Sample Hive Script based Notification |
---|
|
CREATE EXTERNAL TABLE IF NOT EXISTS BAMNotifications
(id STRING, streamId STRING, country STRING, requestCount STRING)
STORED BY 'org.apache.hadoop.hive.cassandra.CassandraStorageHandler'
WITH SERDEPROPERTIES (
"wso2.carbon.datasource.name" = "WSO2BAM_UTIL_DATASOURCE" ,
"cassandra.cf.name" = "bam_notification_messages" ,
"cassandra.columns.mapping" = ":key,streamId,country,requestCount" );
insert into table BAMNotifications select countryCode, "country_notifications:1.0.0", country, requestCount from CountrySummary where requestCount > 600; |
The above snippet can be used with the HTTPD log analyzing sample Hive script.
Info |
---|
|
Hive Script based Notifications are only support in the default (super) tenant for the moment |