[incubator-streampipes] branch dev updated: Create new CouchDB view at installation time

[ri...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new e9b1a11  Create new CouchDB view at installation time
e9b1a11 is described below

commit e9b1a1101e58d040fe6879a344a4ca944ebe66f5
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Mon Mar 16 20:46:05 2020 +0100

    Create new CouchDB view at installation time
---
 .../org/apache/streampipes/manager/setup/CouchDbInstallationStep.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/CouchDbInstallationStep.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/CouchDbInstallationStep.java
index 18855dd..2dc0051 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/CouchDbInstallationStep.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/CouchDbInstallationStep.java
@@ -106,7 +106,7 @@ public class CouchDbInstallationStep implements InstallationStep {
             Map<String, MapReduce> views = new HashMap<>();
 
             MapReduce notificationTypeFunction = new MapReduce();
-            notificationTypeFunction.setMap("function (doc) { var vizName = doc.title.replace(/\\s/g, '-'); var indexName = doc.correspondingPipelineId + '-' + vizName; emit(indexName, doc);}");
+            notificationTypeFunction.setMap("function (doc) { var vizName = doc.title.replace(/\\s/g, '-'); var indexName = doc.correspondingPipelineId + '-' + vizName; emit([indexName, doc.createdAtTimestamp], doc);}");
 
             views.put("notificationtypes", notificationTypeFunction);