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.git
commit 6e1c9ef5a06220f5f1cc5a8004b10b929a400f60 Author: Dominik Riemer <[email protected]> AuthorDate: Sun Oct 18 16:03:37 2020 +0200 [STREAMPIPES-249] Add compact data sink --- .../streampipes/wrapper/standalone/SinkParams.java | 18 +++++++++++++++++- .../wrapper/standalone/StreamPipesDataSink.java | 16 +++++++++++++++- 2 files changed, 32 insertions(+), 2 deletions(-) diff --git a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java index b0d234e..31b317b 100644 --- a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java +++ b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java @@ -16,5 +16,21 @@ * */ package org.apache.streampipes.wrapper.standalone; -public class SinkParams { + +import org.apache.streampipes.model.graph.DataSinkInvocation; +import org.apache.streampipes.sdk.extractor.DataSinkParameterExtractor; +import org.apache.streampipes.wrapper.params.binding.EventSinkBindingParams; + +public class SinkParams extends EventSinkBindingParams { + + private DataSinkParameterExtractor extractor; + + public SinkParams(DataSinkInvocation graph) { + super(graph); + this.extractor = DataSinkParameterExtractor.from(graph); + } + + public DataSinkParameterExtractor extractor() { + return this.extractor; + } } diff --git a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java index 59b1241..b087b0b 100644 --- a/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java +++ b/streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java @@ -16,5 +16,19 @@ * */ package org.apache.streampipes.wrapper.standalone; -public class StreamPipesDataSink { + +import org.apache.streampipes.model.graph.DataSinkInvocation; +import org.apache.streampipes.sdk.extractor.DataSinkParameterExtractor; +import org.apache.streampipes.wrapper.runtime.EventSink; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventSinkDeclarer; + +import java.util.function.Supplier; + +public abstract class StreamPipesDataSink extends StandaloneEventSinkDeclarer<SinkParams> implements EventSink<SinkParams> { + + @Override + public ConfiguredEventSink<SinkParams> onInvocation(DataSinkInvocation graph, DataSinkParameterExtractor extractor) { + Supplier<EventSink<SinkParams>> supplier = () -> this; + return new ConfiguredEventSink<>(new SinkParams(graph), supplier); + } }
