...
Code Block | ||||
---|---|---|---|---|
| ||||
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; |
...