You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ob...@apache.org on 2021/12/04 13:20:57 UTC
[incubator-streampipes] branch dev updated: [STREAMPIPES-474] Fix resource folder name.
This is an automated email from the ASF dual-hosted git repository.
obermeier 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 ad6fa9a [STREAMPIPES-474] Fix resource folder name.
ad6fa9a is described below
commit ad6fa9afa33cdc18af5c6c07dec2a61add3b6ab8
Author: Stefan Obermeier <ob...@apache.org>
AuthorDate: Sat Dec 4 14:18:53 2021 +0100
[STREAMPIPES-474] Fix resource folder name.
To make the resources like icon and description accesebal and avoid NPEs
---
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../__packageName__/__classNamePrefix__Controller.java | 7 +++++--
4 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__/documentation.md b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.processor/documentation.md
similarity index 100%
rename from archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__/documentation.md
rename to archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.processor/documentation.md
diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__/icon.png b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.processor/icon.png
similarity index 100%
rename from archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__/icon.png
rename to archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.processor/icon.png
diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__/strings.en b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.processor/strings.en
similarity index 100%
rename from archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__/strings.en
rename to archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/resources/__package__.pe.__packageName__.processor/strings.en
diff --git a/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Controller.java b/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Controller.java
index d233f97..7efd741 100644
--- a/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Controller.java
+++ b/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Controller.java
@@ -62,8 +62,11 @@ public class ${classNamePrefix}Controller extends FlinkDataProcessorDeclarer<${c
}
@Override
- public FlinkDataProcessorRuntime<${classNamePrefix}Parameters> getRuntime(DataProcessorInvocation
- graph, ProcessingElementParameterExtractor extractor) {
+ public FlinkDataProcessorRuntime<${classNamePrefix}Parameters> getRuntime(
+ DataProcessorInvocation graph,
+ ProcessingElementParameterExtractor extractor,
+ ConfigExtractor configExtractor,
+ StreamPipesClient streamPipesClient) {
String exampleText = extractor.singleValueParameter(EXAMPLE_KEY, String.class);
${classNamePrefix}Parameters params = new ${classNamePrefix}Parameters(graph, exampleText);