You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2020/09/18 07:32:55 UTC
[incubator-streampipes-extensions] branch rel/0.67.0 updated:
[hotfix] Use append output strategy for generic image classifier
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch rel/0.67.0
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
The following commit(s) were added to refs/heads/rel/0.67.0 by this push:
new 43acc2b [hotfix] Use append output strategy for generic image classifier
new 815ab0a Merge branch 'rel/0.67.0' of github.com:apache/incubator-streampipes-extensions into rel/0.67.0
43acc2b is described below
commit 43acc2b9977e61da8a9f1fb99281fac4bed55aea
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Fri Sep 18 09:32:17 2020 +0200
[hotfix] Use append output strategy for generic image classifier
---
.../genericclassification/GenericImageClassification.java | 7 +++----
.../GenericImageClassificationController.java | 2 +-
2 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassification.java b/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassification.java
index ba52613..7e2d0aa 100644
--- a/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassification.java
+++ b/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassification.java
@@ -88,10 +88,9 @@ public class GenericImageClassification implements EventProcessor<GenericImageCl
if (scores.size() > 0) {
System.out.println(scores.get(0).score +":" +categories.get(scores.get(0).category));
//scores.forEach(score -> System.out.println(score.category +":" +categories.get(score.category) +":" +score));
- Event outEvent = new Event();
- outEvent.addField("score", scores.get(0).score);
- outEvent.addField("category", categories.get(scores.get(0).category));
- out.collect(outEvent);
+ in.addField("score", scores.get(0).score);
+ in.addField("category", categories.get(scores.get(0).category));
+ out.collect(in);
}
}
}
diff --git a/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java b/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java
index b54eb28..a57f70f 100644
--- a/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java
+++ b/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationController.java
@@ -45,7 +45,7 @@ public class GenericImageClassificationController extends StandaloneEventProcess
.domainPropertyReq("https://image.com"), Labels.withId(IMAGE),
PropertyScope.NONE)
.build())
- .outputStrategy(OutputStrategies.fixed(
+ .outputStrategy(OutputStrategies.append(
EpProperties.doubleEp(Labels.empty(), "score", "https://schema.org/score"),
EpProperties.stringEp(Labels.empty(), "category", "https://schema.org/category")