You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by wi...@apache.org on 2020/07/20 15:37:17 UTC
[incubator-streampipes-examples] branch dev updated: [hotfix] minor
to processor id
This is an automated email from the ASF dual-hosted git repository.
wiener pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-examples.git
The following commit(s) were added to refs/heads/dev by this push:
new 6a0185e [hotfix] minor to processor id
6a0185e is described below
commit 6a0185e707213058de12d104937a31567ce7b968
Author: Patrick Wiener <wi...@fzi.de>
AuthorDate: Mon Jul 20 17:37:07 2020 +0200
[hotfix] minor to processor id
---
.../streampipes/pe/examples/jvm/python/GreeterPythonController.java | 2 +-
.../main/java/org/apache/streampipes/pe/examples/jvm/python/greeter.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/GreeterPythonController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/GreeterPythonController.java
index 84e5242..b6138f7 100644
--- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/GreeterPythonController.java
+++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/GreeterPythonController.java
@@ -29,7 +29,7 @@ import org.apache.streampipes.wrapper.standalone.declarer.StandaloneExternalEven
public class GreeterPythonController extends StandaloneExternalEventProcessingDeclarer<GreeterParameters> {
private static final String GREETER_KEY = "greeter-key";
- public static final String PROCESSOR_ID = "org.apache.streampipes.examples.python.processor";
+ public static final String PROCESSOR_ID = "org.apache.streampipes.examples.python.processor.greeter";
@Override
public DataProcessorDescription declareModel() {
diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/greeter.py b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/greeter.py
index b85e1b7..b76e0eb 100644
--- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/greeter.py
+++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/python/greeter.py
@@ -36,7 +36,7 @@ class Greeter(EventProcessor):
def main():
# dict with processor id and processor class
processors = {
- 'org.apache.streampipes.examples.python.processor': Greeter,
+ 'org.apache.streampipes.examples.python.processor.greeter': Greeter,
}
Declarer.add(processors=processors)