You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by im...@apache.org on 2015/07/23 14:18:53 UTC
[11/18] stratos git commit: Adding DAS Artifacts
Adding DAS Artifacts
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/a62fab20
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/a62fab20
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/a62fab20
Branch: refs/heads/master
Commit: a62fab2081f3b015a713465dc40fde3c184aa24e
Parents: 632a3a4
Author: Thanuja <th...@wso2.com>
Authored: Wed Jul 22 18:16:01 2015 +0530
Committer: Thanuja <th...@wso2.com>
Committed: Wed Jul 22 18:16:01 2015 +0530
----------------------------------------------------------------------
DAS-Artifacts/CCEventReceiver.xml | 9 ++
DAS-Artifacts/SparkQuery.txt | 19 ++++
...g.apache.stratos.cloud.controller_1.0.0.json | 112 +++++++++++++++++++
.../org_apache_stratos_cloud_controller.xml | 1 +
DAS-Artifacts/sparkudf-1.0-SNAPSHOT.jar | Bin 0 -> 2428 bytes
5 files changed, 141 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/a62fab20/DAS-Artifacts/CCEventReceiver.xml
----------------------------------------------------------------------
diff --git a/DAS-Artifacts/CCEventReceiver.xml b/DAS-Artifacts/CCEventReceiver.xml
new file mode 100644
index 0000000..0ddd086
--- /dev/null
+++ b/DAS-Artifacts/CCEventReceiver.xml
@@ -0,0 +1,9 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventReceiver name="CCEventReceiver" statistics="disable"
+ trace="enable" xmlns="http://wso2.org/carbon/eventreceiver">
+ <from eventAdapterType="wso2event">
+ <property name="events.duplicated.in.cluster">false</property>
+ </from>
+ <mapping customMapping="disable" type="wso2event"/>
+ <to streamName="org.apache.stratos.cloud.controller" version="1.0.0"/>
+</eventReceiver>
http://git-wip-us.apache.org/repos/asf/stratos/blob/a62fab20/DAS-Artifacts/SparkQuery.txt
----------------------------------------------------------------------
diff --git a/DAS-Artifacts/SparkQuery.txt b/DAS-Artifacts/SparkQuery.txt
new file mode 100644
index 0000000..39f7d47
--- /dev/null
+++ b/DAS-Artifacts/SparkQuery.txt
@@ -0,0 +1,19 @@
+CREATE TEMPORARY TABLE memberstatus
+USING CarbonAnalytics
+OPTIONS (tableName "ORG_APACHE_STRATOS_CLOUD_CONTROLLER");
+
+CREATE TEMPORARY TABLE memberstatusnew
+USING CarbonAnalytics
+OPTIONS (tableName "CLUSTER_MEMBER_NEW",
+ schema "startTime String, endTime String, clusterId STRING, activatedInstanceCount INT, terminatedInstanceCount INT, activeInstanceCount INT");
+
+
+;WITH InstanceCount as
+(select clusterId, count(case when status='Active' and timeStamp > current_time(null)-60000 and timeStamp <= current_time(null) then 1 else NULL end) as activatedInstanceCount, count(case when status='Terminated' and timeStamp > current_time(null)-60000 and timeStamp <= current_time(null) then 1 else NULL end) as terminatedInstanceCount, (sum(case when status='Active' then 1 else 0 end) - sum(case when status='Terminated' then 1 else 0 end))as activeInstanceCount from memberstatus group by clusterId)
+INSERT INTO table memberstatusnew select time(current_time(null)-60000),time(current_time(null)),clusterId, activatedInstanceCount, terminatedInstanceCount,activeInstanceCount from InstanceCount;
+
+CREATE TEMPORARY TABLE membersnew
+USING CarbonAnalytics
+OPTIONS (tableName "MEMBER_NEW",schema "clusterId STRING, clusterInstanceId STRING, partitionId STRING, networkId STRING, cartridgeType STRING, instanceType STRING, memberId STRING, scalingTime LONG,scalingReason STRING, timeStamp LONG");
+
+INSERT INTO TABLE membersnew select clusterId, clusterInstanceId,partitionId,networkId,cartridgeType,instanceType, memberId, time(scalingTime),scalingReason,time(timeStamp) FROM memberstatus where status='Created';
http://git-wip-us.apache.org/repos/asf/stratos/blob/a62fab20/DAS-Artifacts/org.apache.stratos.cloud.controller_1.0.0.json
----------------------------------------------------------------------
diff --git a/DAS-Artifacts/org.apache.stratos.cloud.controller_1.0.0.json b/DAS-Artifacts/org.apache.stratos.cloud.controller_1.0.0.json
new file mode 100644
index 0000000..de1025f
--- /dev/null
+++ b/DAS-Artifacts/org.apache.stratos.cloud.controller_1.0.0.json
@@ -0,0 +1,112 @@
+{
+ "name": "org.apache.stratos.cloud.controller",
+ "version": "1.0.0",
+ "nickName": "cloud.controller",
+ "description": "Instances booted up by the Cloud Controller",
+ "payloadData": [
+ {
+ "name": "timeStamp",
+ "type": "LONG"
+ },
+ {
+ "name": "memberId",
+ "type": "STRING"
+ },
+ {
+ "name": "cartridgeType",
+ "type": "STRING"
+ },
+ {
+ "name": "clusterId",
+ "type": "STRING"
+ },
+ {
+ "name": "clusterInstanceId",
+ "type": "STRING"
+ },
+ {
+ "name": "lbclusterId",
+ "type": "STRING"
+ },
+ {
+ "name": "partitionId",
+ "type": "STRING"
+ },
+ {
+ "name": "networkId",
+ "type": "STRING"
+ },
+ {
+ "name": "instanceType",
+ "type": "STRING"
+ },
+ {
+ "name": "scalingReason",
+ "type": "STRING"
+ },
+ {
+ "name": "scalingTime",
+ "type": "LONG"
+ },
+ {
+ "name": "isMultiTenant",
+ "type": "STRING"
+ },
+ {
+ "name": "iaas",
+ "type": "STRING"
+ },
+ {
+ "name": "status",
+ "type": "STRING"
+ },
+ {
+ "name": "hostName",
+ "type": "STRING"
+ },
+ {
+ "name": "hypervisor",
+ "type": "STRING"
+ },
+ {
+ "name": "ram",
+ "type": "STRING"
+ },
+ {
+ "name": "imageId",
+ "type": "STRING"
+ },
+ {
+ "name": "loginPort",
+ "type": "INT"
+ },
+ {
+ "name": "osName",
+ "type": "STRING"
+ },
+ {
+ "name": "osVersion",
+ "type": "STRING"
+ },
+ {
+ "name": "osArch",
+ "type": "STRING"
+ },
+ {
+ "name": "is64bitOS",
+ "type": "STRING"
+ },
+ {
+ "name": "privateIPAddresses",
+ "type": "STRING"
+ },
+ {
+ "name": "publicIPAddresses",
+ "type": "STRING"
+ },
+ {
+ "name": "allocateIPAddresses",
+ "type": "STRING"
+ }
+ ]
+}
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/stratos/blob/a62fab20/DAS-Artifacts/org_apache_stratos_cloud_controller.xml
----------------------------------------------------------------------
diff --git a/DAS-Artifacts/org_apache_stratos_cloud_controller.xml b/DAS-Artifacts/org_apache_stratos_cloud_controller.xml
new file mode 100644
index 0000000..ee99acd
--- /dev/null
+++ b/DAS-Artifacts/org_apache_stratos_cloud_controller.xml
@@ -0,0 +1 @@
+<?xml version="1.0" encoding="UTF-8" standalone="yes"?><EventStoreConfiguration><TableSchema><ColumnDefinition><Name>timeStamp</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>LONG</Type></ColumnDefinition><ColumnDefinition><Name>memberId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>cartridgeType</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>clusterId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>clusterInstanceId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScorePar
am>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>lbclusterId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>partitionId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>networkId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>instanceType</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>scalingReason</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam
><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>scalingTime</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>LONG</Type></ColumnDefinition><ColumnDefinition><Name>isMultiTenant</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>iaas</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>status</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>hostName</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><Co
lumnDefinition><Name>hypervisor</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>ram</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>imageId</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>loginPort</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>INTEGER</Type></ColumnDefinition><ColumnDefinition><Name>osName</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>osVersion</Name><EnableIn
dexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>osArch</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>is64bitOS</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>privateIPAddresses</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>publicIPAddresses</Name><EnableIndexing>false</EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition><ColumnDefinition><Name>allocateIPAddresses</Name><EnableIndexing>false<
/EnableIndexing><IsPrimaryKey>false</IsPrimaryKey><EnableScoreParam>false</EnableScoreParam><Type>STRING</Type></ColumnDefinition></TableSchema><Source><StreamId>org.apache.stratos.cloud.controller:1.0.0</StreamId></Source><RecordStoreName>EVENT_STORE</RecordStoreName></EventStoreConfiguration>
\ No newline at end of file
http://git-wip-us.apache.org/repos/asf/stratos/blob/a62fab20/DAS-Artifacts/sparkudf-1.0-SNAPSHOT.jar
----------------------------------------------------------------------
diff --git a/DAS-Artifacts/sparkudf-1.0-SNAPSHOT.jar b/DAS-Artifacts/sparkudf-1.0-SNAPSHOT.jar
new file mode 100644
index 0000000..3328918
Binary files /dev/null and b/DAS-Artifacts/sparkudf-1.0-SNAPSHOT.jar differ