diff --git a/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js new file mode 100644 index 0000000..808c5b5 --- /dev/null +++ b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/map.js @@ -0,0 +1,23 @@ +function(doc,meta) { + if(doc.usageRecordType == "StorageUsageRecord" || doc.recordType == "StorageUsageRecord"){ + if((doc.dataVolume && isNaN(Number(doc.dataVolume))) || (doc.operationCount && isNaN(Number(doc.operationCount)))){ + emit([0, "Invalid Value", doc.id], doc); + return; + } + var data = {}; + data.dataVolume = doc.dataVolume ? Number(doc.dataVolume) : 0; + data.operationCount = doc.operationCount ? Number(doc.operationCount) : 1; + var timestamp = Number(doc.creationTime); + var date = new Date(timestamp); + var dataKey = []; + dataKey.push(date.getUTCFullYear()); + dataKey.push(date.getUTCMonth()+1); + dataKey.push(date.getUTCDate()); + dataKey.push(date.getUTCHours()); + dataKey.push(date.getUTCMinutes()); + dataKey.push(doc.operationType); + + emit(dataKey, data); + } +} + diff --git a/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js new file mode 100644 index 0000000..29d805d --- /dev/null +++ b/src/main/resources/MapReduce/extraStorageUsageRecord/noContext/operationType/reduce.js @@ -0,0 +1,14 @@ +function(keys, values, rereduce){ + var total = 0; + var dataVolume = 0; + for(i=0; i