From bd9e7b066555896ed104cba41e9ac3cb4bb60b6e Mon Sep 17 00:00:00 2001
From: Luca Frosini <luca.frosini@isti.cnr.it>
Date: Mon, 13 Jul 2015 14:13:33 +0000
Subject: [PATCH] Removed Map Reduce and moved in
 accounting-analytics-persistence-couchdb project

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/accounting/accounting-analytics@117190 82a268e6-3cf1-43bd-a215-b396298e98cf
---
 src/main/resources/ServiceUsageRecord.js | 42 ------------------------
 src/main/resources/StorageUsageRecord.js | 10 ------
 2 files changed, 52 deletions(-)
 delete mode 100644 src/main/resources/ServiceUsageRecord.js
 delete mode 100644 src/main/resources/StorageUsageRecord.js

diff --git a/src/main/resources/ServiceUsageRecord.js b/src/main/resources/ServiceUsageRecord.js
deleted file mode 100644
index ca7de09..0000000
--- a/src/main/resources/ServiceUsageRecord.js
+++ /dev/null
@@ -1,42 +0,0 @@
-{
-   "_id": "_design/ServiceUsageRecord",
-   "language": "javascript",
-   "views": {
-       "all": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "serviceClass": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.serviceClass);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "serviceName": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.serviceClass);\n\t\tdataKey.unshift(doc.serviceName);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "scope": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.scope);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "consumerId": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.consumerId);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "host": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.host);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "callerHost": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.callerHost);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "mixed": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.calledMethod);\n\t\tdataKey.unshift(doc.serviceName);\n\t\tdataKey.unshift(doc.serviceClass);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       },
-       "calledMethod": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"ServiceUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"duration\" : doc.duration, \n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount : 1,\n\t\t\t\"maxInvocationTime\" : doc.maxInvocationTime ? doc.maxInvocationTime : doc.duration, \n\t\t\t\"minInvocationTime\" : doc.minInvocationTime ? doc.minInvocationTime : doc.duration\n\t\t}\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\tdataKey.unshift(doc.calledMethod);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}",
-           "reduce": "function(keys, values, rereduce){\n\tvar maxInvocationTime = values[0].maxInvocationTime;\n\tvar minInvocationTime = values[0].minInvocationTime;\n\tvar total = 0;\n\tvar numerator = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tnumerator += values[i].operationCount * values[i].duration;\n\t\tif(maxInvocationTime<=values[i].maxInvocationTime){\n\t\t\tmaxInvocationTime = values[i].maxInvocationTime;\n\t\t}\n\t\tif(minInvocationTime>=values[i].minInvocationTime){\n\t\t\tminInvocationTime = values[i].minInvocationTime;\n\t\t}\n\t}\n\t\n\treturn {\n\t\t\"duration\" : numerator/total,\n\t\t\"operationCount\" : total,\n\t\t\"maxInvocationTime\" : maxInvocationTime,\n\t\t\"minInvocationTime\" : minInvocationTime\n\t};\n}"
-       }
-   }
-}
\ No newline at end of file
diff --git a/src/main/resources/StorageUsageRecord.js b/src/main/resources/StorageUsageRecord.js
deleted file mode 100644
index c4535dc..0000000
--- a/src/main/resources/StorageUsageRecord.js
+++ /dev/null
@@ -1,10 +0,0 @@
-{
-   "_id": "_design/StorageUsageRecord",
-   "language": "javascript",
-   "views": {
-       "dataVolume": {
-           "map": "function(doc) {\n\tif(doc.usageRecordType == \"StorageUsageRecord\"){\n\t\tvar data = {\n\t\t\t\"dataVolume\" : doc.dataVolume ? doc.dataVolume : 0,\n\t\t\t\"operationCount\" : doc.operationCount ? doc.operationCount :  1,\n\t\t\t\n\t\t};\n\t\tvar dataKey = getDataKey(doc.creationTime);\n\t\temit(dataKey, data);\n\t}\n}\n\n\nfunction getDataKey(timestamp){\n\tvar date = new Date(timestamp);\n\tvar key = [];\n\tkey.push(date.getFullYear());\n\tkey.push(date.getUTCMonth()+1);\n\tkey.push(date.getUTCDate());\n\tkey.push(date.getUTCHours());\n\tkey.push(date.getUTCMinutes());\n\tkey.push(date.getUTCSeconds());\n\tkey.push(date.getUTCMilliseconds());\n\treturn key;\n}\n\n",
-           "reduce": "function(keys, values, rereduce){\n\tvar total = 0;\n\tvar dataVolume = 0;\n\tfor(i=0; i<values.length; i++){\n\t\ttotal += values[i].operationCount;\n\t\tdataVolume += values[i].dataVolume;\n\t}\n\t\n\treturn {\n\t\t\"operationCount\" : total,\n\t\t\"dataVolume\" : dataVolume\n\t};\n}"
-       }
-   }
-}
\ No newline at end of file