Renamed call and data stream names

revert-dabc3590
lasantha 8 years ago
parent b64e47a26a
commit 705013b5fd

@ -3,10 +3,10 @@
@Plan:description('Identify the call durations of incoming and outgoing calls') @Plan:description('Identify the call durations of incoming and outgoing calls')
@Import('org.wso2.iot.android.call:1.0.0') @Import('iot.per.device.stream.android.call:1.0.0')
define stream CallStream (meta_owner string, meta_deviceId string, meta_timestamp long, number string, type string, startTime long, endTime long); define stream CallStream (meta_owner string, meta_deviceId string, meta_timestamp long, number string, type string, startTime long, endTime long);
@Export('org.wso2.iot.android.call.stats:1.0.0') @Export('iot.per.device.stream.android.call.stats:1.0.0')
define stream CallStatsStream (meta_owner string, meta_deviceId string, meta_timestamp long, number string, type string, duration long, year int, month int, day int, hour int, minute int); define stream CallStatsStream (meta_owner string, meta_deviceId string, meta_timestamp long, number string, type string, duration long, year int, month int, day int, hour int, minute int);
partition with (meta_deviceId of CallStream) partition with (meta_deviceId of CallStream)

@ -2,10 +2,10 @@
@Plan:description('Calculate the total network usage of mobile data and others') @Plan:description('Calculate the total network usage of mobile data and others')
@Import('org.wso2.iot.android.data:1.0.0') @Import('iot.per.device.stream.android.data:1.0.0')
define stream DataStream (meta_owner string, meta_deviceId string, meta_timestamp long, type string, received long, sent long); define stream DataStream (meta_owner string, meta_deviceId string, meta_timestamp long, type string, received long, sent long);
@Export('org.wso2.iot.android.data.stats:1.0.0') @Export('iot.per.device.stream.android.data.stats:1.0.0')
define stream DataStatsStream (meta_owner string, meta_deviceId string, meta_timestamp long, type string, total long, year int, month int, day int, hour int, minute int); define stream DataStatsStream (meta_owner string, meta_deviceId string, meta_timestamp long, type string, total long, year int, month int, day int, hour int, minute int);
partition with (meta_deviceId of DataStream) partition with (meta_deviceId of DataStream)

@ -2,7 +2,7 @@
<Analytics> <Analytics>
<Editable>true</Editable> <Editable>true</Editable>
<Name>AndroidCallScript</Name> <Name>AndroidCallScript</Name>
<Script> CREATE TEMPORARY TABLE AndroidCallData USING CarbonAnalytics OPTIONS(tableName "ORG_WSO2_IOT_ANDROID_CALL_STATS", incrementalParams "ORG_WSO2_IOT_ANDROID_CALL_STATS, DAY"); <Script> CREATE TEMPORARY TABLE AndroidCallData USING CarbonAnalytics OPTIONS(tableName "IOT_PER_DEVICE_STREAM_ANDROID_CALL_STATS", incrementalParams "IOT_PER_DEVICE_STREAM_ANDROID_CALL_STATS, DAY");
CREATE TEMPORARY TABLE Android_Call_Stat_Per_Day USING CarbonAnalytics CREATE TEMPORARY TABLE Android_Call_Stat_Per_Day USING CarbonAnalytics
OPTIONS (tableName "Android_Call_Stat_Per_Day", OPTIONS (tableName "Android_Call_Stat_Per_Day",
@ -15,7 +15,7 @@
FROM AndroidCallData FROM AndroidCallData
GROUP BY year, month, day, meta_deviceId, meta_owner, type ORDER BY timestamp DESC; GROUP BY year, month, day, meta_deviceId, meta_owner, type ORDER BY timestamp DESC;
INCREMENTAL_TABLE_COMMIT ORG_WSO2_IOT_ANDROID_CALL_STATS; INCREMENTAL_TABLE_COMMIT IOT_PER_DEVICE_STREAM_ANDROID_CALL_STATS;
</Script> </Script>
<CronExpression>0 0/5 * * * ?</CronExpression> <CronExpression>0 0/5 * * * ?</CronExpression>
</Analytics> </Analytics>

@ -18,6 +18,6 @@
--> -->
<artifact name= "android_call_stats_event_sink" version="1.0.0" type="analytics/eventstore" serverRole="DataAnalyticsServer"> <artifact name= "android_call_stats_event_sink" version="1.0.0" type="analytics/eventstore" serverRole="DataAnalyticsServer">
<file>org_wso2_iot_android_call_stats.xml</file> <file>iot_per_device_stream_android_call_stats.xml</file>
</artifact> </artifact>

@ -18,6 +18,6 @@
--> -->
<artifact name= "android_call_stats_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer"> <artifact name= "android_call_stats_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer">
<file>org.wso2.iot.android.call.stats_1.0.0.json</file> <file>iot.per.device.stream.android.call.stats_1.0.0.json</file>
</artifact> </artifact>

@ -18,6 +18,6 @@
--> -->
<artifact name= "android_call_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer"> <artifact name= "android_call_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer">
<file>org.wso2.iot.android.call_1.0.0.json</file> <file>iot.per.device.stream.android.call_1.0.0.json</file>
</artifact> </artifact>

@ -2,7 +2,7 @@
<Analytics> <Analytics>
<Editable>true</Editable> <Editable>true</Editable>
<Name>AndroidDataScript</Name> <Name>AndroidDataScript</Name>
<Script> CREATE TEMPORARY TABLE AndroidDataData USING CarbonAnalytics OPTIONS(tableName "ORG_WSO2_IOT_ANDROID_DATA_STATS", incrementalParams "ORG_WSO2_IOT_ANDROID_DATA_STATS, DAY"); <Script> CREATE TEMPORARY TABLE AndroidDataData USING CarbonAnalytics OPTIONS(tableName "IOT_PER_DEVICE_STREAM_ANDROID_DATA_STATS", incrementalParams "IOT_PER_DEVICE_STREAM_ANDROID_DATA_STATS, DAY");
CREATE TEMPORARY TABLE Android_Data_Stat_Per_Day USING CarbonAnalytics CREATE TEMPORARY TABLE Android_Data_Stat_Per_Day USING CarbonAnalytics
OPTIONS (tableName "Android_Data_Stat_Per_Day", OPTIONS (tableName "Android_Data_Stat_Per_Day",
@ -15,7 +15,7 @@
FROM AndroidDataData FROM AndroidDataData
GROUP BY year, month, day, meta_deviceId, meta_owner, type ORDER BY timestamp DESC; GROUP BY year, month, day, meta_deviceId, meta_owner, type ORDER BY timestamp DESC;
INCREMENTAL_TABLE_COMMIT ORG_WSO2_IOT_ANDROID_DATA_STATS; INCREMENTAL_TABLE_COMMIT IOT_PER_DEVICE_STREAM_ANDROID_DATA_STATS;
</Script> </Script>
<CronExpression>0 0/5 * * * ?</CronExpression> <CronExpression>0 0/5 * * * ?</CronExpression>
</Analytics> </Analytics>

@ -18,6 +18,6 @@
--> -->
<artifact name= "android_data_stats_event_sink" version="1.0.0" type="analytics/eventstore" serverRole="DataAnalyticsServer"> <artifact name= "android_data_stats_event_sink" version="1.0.0" type="analytics/eventstore" serverRole="DataAnalyticsServer">
<file>org_wso2_iot_android_data_stats.xml</file> <file>iot_per_device_stream_android_data_stats.xml</file>
</artifact> </artifact>

@ -18,6 +18,6 @@
--> -->
<artifact name= "android_data_stats_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer"> <artifact name= "android_data_stats_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer">
<file>org.wso2.iot.android.data.stats_1.0.0.json</file> <file>iot.per.device.stream.android.data.stats_1.0.0.json</file>
</artifact> </artifact>

@ -18,6 +18,6 @@
--> -->
<artifact name= "android_data_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer"> <artifact name= "android_data_streams" version="1.0.0" type="event/stream" serverRole="DataAnalyticsServer">
<file>org.wso2.iot.android.data_1.0.0.json</file> <file>iot.per.device.stream.android.data_1.0.0.json</file>
</artifact> </artifact>

Loading…
Cancel
Save