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/05/20 22:03:37 UTC
[incubator-streampipes-examples] branch dev updated: Add example
for user-defined output strategy
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-examples.git
The following commit(s) were added to refs/heads/dev by this push:
new 7e37ceb Add example for user-defined output strategy
7e37ceb is described below
commit 7e37ceb741adc3351f6176a58c01a172b3a3198d
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Thu May 21 00:03:20 2020 +0200
Add example for user-defined output strategy
---
.../pe/examples/jvm/staticproperty/CodeInputExampleController.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CodeInputExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CodeInputExampleController.java
index 447bd9c..85a6d6d 100644
--- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CodeInputExampleController.java
+++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CodeInputExampleController.java
@@ -23,7 +23,7 @@ public class CodeInputExampleController extends StandaloneEventProcessingDeclare
create()
.requiredProperty(EpRequirements.anyProperty())
.build())
- .outputStrategy(OutputStrategies.keep())
+ .outputStrategy(OutputStrategies.userDefined())
.supportedProtocols(SupportedProtocols.kafka())
.supportedFormats(SupportedFormats.jsonFormat())