You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/04/18 15:11:09 UTC
[incubator-streampipes] branch dev updated (64f6b27 -> aaa3e3e)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 64f6b27 STREAMPIPES-105: Create Kafka Publisher Sink
add 99c736a [STREAMPIPES-106] Upgrade Siddhi dependency to v5.1.12
new 43111e0 Merge branch 'STREAMPIPES-106' of https://github.com/grainier/incubator-streampipes into grainier-STREAMPIPES-106
new 1989343 Change Siddhi wrapper to work with new API
new aaa3e3e Merge branch 'grainier-STREAMPIPES-106' into dev
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
LICENSE-binary | 8 ++++----
pom.xml | 10 +++++-----
streampipes-wrapper-siddhi/pom.xml | 11 ++++++-----
.../wrapper/siddhi/engine/SiddhiDebugCallback.java | 2 +-
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 15 +++++++++------
.../wrapper/siddhi/manager/SpSiddhiManager.java | 2 +-
6 files changed, 26 insertions(+), 22 deletions(-)
[incubator-streampipes] 01/03: Merge branch 'STREAMPIPES-106' of
https://github.com/grainier/incubator-streampipes into
grainier-STREAMPIPES-106
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 43111e0eb68a2c6a6e45a140811f49488da36c71
Merge: 64f6b27 99c736a
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sat Apr 18 12:20:11 2020 +0200
Merge branch 'STREAMPIPES-106' of https://github.com/grainier/incubator-streampipes into grainier-STREAMPIPES-106
LICENSE-binary | 8 ++++----
pom.xml | 10 +++++-----
streampipes-wrapper-siddhi/pom.xml | 11 ++++++-----
.../wrapper/siddhi/engine/SiddhiDebugCallback.java | 2 +-
.../streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java | 10 +++++-----
.../streampipes/wrapper/siddhi/manager/SpSiddhiManager.java | 2 +-
6 files changed, 22 insertions(+), 21 deletions(-)
[incubator-streampipes] 02/03: Change Siddhi wrapper to work with
new API
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 19893436c3b248a2dbdb615a087e747c6fb2ffc6
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sat Apr 18 17:10:19 2020 +0200
Change Siddhi wrapper to work with new API
---
.../apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java b/streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java
index 6bab4b8..4c35128 100644
--- a/streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java
+++ b/streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java
@@ -120,6 +120,8 @@ public abstract class SiddhiEventEngine<B extends EventProcessorBindingParams> i
});
}
+ siddhiAppRuntime.start();
+
}
private String getOutputTopicName(B parameters) {
@@ -136,7 +138,8 @@ public abstract class SiddhiEventEngine<B extends EventProcessorBindingParams> i
schemaInfo, SourceInfo sourceInfo) {
Map<String, Object> outMap = new HashMap<>();
for (int i = 0; i < sortedEventKeys.size(); i++) {
- outMap.put(sortedEventKeys.get(i), event.getData(i));
+ List<Object> tmp = (List<Object>) event.getData(i);
+ outMap.put(sortedEventKeys.get(i), tmp.get(0));
}
return EventFactory.fromMap(outMap, sourceInfo, schemaInfo);
}
[incubator-streampipes] 03/03: Merge branch
'grainier-STREAMPIPES-106' into dev
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit aaa3e3e03112a5e430b075a3d419464edf4ecb16
Merge: 64f6b27 1989343
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sat Apr 18 17:10:49 2020 +0200
Merge branch 'grainier-STREAMPIPES-106' into dev
LICENSE-binary | 8 ++++----
pom.xml | 10 +++++-----
streampipes-wrapper-siddhi/pom.xml | 11 ++++++-----
.../wrapper/siddhi/engine/SiddhiDebugCallback.java | 2 +-
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 15 +++++++++------
.../wrapper/siddhi/manager/SpSiddhiManager.java | 2 +-
6 files changed, 26 insertions(+), 22 deletions(-)