From commits-return-63-archive-asf-public=cust-asf.ponee.io@streampipes.apache.org Wed Dec 11 22:59:38 2019 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [207.244.88.153]) by mx-eu-01.ponee.io (Postfix) with SMTP id 0939A180638 for ; Wed, 11 Dec 2019 23:59:36 +0100 (CET) Received: (qmail 69682 invoked by uid 500); 11 Dec 2019 22:59:36 -0000 Mailing-List: contact commits-help@streampipes.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streampipes.apache.org Delivered-To: mailing list commits@streampipes.apache.org Received: (qmail 69671 invoked by uid 99); 11 Dec 2019 22:59:36 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 11 Dec 2019 22:59:36 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id 124998D80D; Wed, 11 Dec 2019 22:59:36 +0000 (UTC) Date: Wed, 11 Dec 2019 22:59:35 +0000 To: "commits@streampipes.apache.org" Subject: [incubator-streampipes-examples] branch dev updated: STREAMPIPES-4: Rename project namespace to Apache coordinates MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <157610517598.7681.12141171652079942765@gitbox.apache.org> From: riemer@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: incubator-streampipes-examples X-Git-Refname: refs/heads/dev X-Git-Reftype: branch X-Git-Oldrev: 5189d13cbc59b41eaea4026a926c0c77b5065999 X-Git-Newrev: 94c72704c69b00809b054c2c8c1c2c6eb8a2d453 X-Git-Rev: 94c72704c69b00809b054c2c8c1c2c6eb8a2d453 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated 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 94c7270 STREAMPIPES-4: Rename project namespace to Apache coordinates 94c7270 is described below commit 94c72704c69b00809b054c2c8c1c2c6eb8a2d453 Author: Dominik Riemer AuthorDate: Wed Dec 11 23:58:25 2019 +0100 STREAMPIPES-4: Rename project namespace to Apache coordinates --- pom.xml | 30 ++++++------- .../pom.xml | 16 +++---- .../streampipes/pe/examples/jvm/ExamplesInit.java | 50 +++++++++++----------- .../pe/examples/jvm/base/DummyController.java | 14 +++--- .../pe/examples/jvm/base/DummyEngine.java | 12 +++--- .../pe/examples/jvm/base/DummyParameters.java | 6 +-- .../pe/examples/jvm/config/ConfigKeys.java | 2 +- .../pe/examples/jvm/config/ExamplesJvmConfig.java | 8 ++-- .../examples/jvm/engine/ExampleExternalEngine.java | 8 ++-- .../engine/ExampleExternalEngineController.java | 22 +++++----- .../engine/ExampleExternalEngineParameters.java | 6 +-- .../jvm/eventmodel/EventModelExamples.java | 16 +++---- .../jvm/outputstrategy/AppendOutputController.java | 38 ++++++++-------- .../jvm/outputstrategy/CustomOutputController.java | 32 +++++++------- .../CustomTransformOutputController.java | 44 +++++++++---------- .../jvm/outputstrategy/FixedOutputController.java | 36 ++++++++-------- .../jvm/outputstrategy/KeepOutputController.java | 32 +++++++------- .../outputstrategy/TransformOutputController.java | 38 ++++++++-------- .../requirements/ListRequirementsController.java | 30 ++++++------- .../requirements/NestedRequirementsController.java | 2 +- .../SimpleStreamRequirementsController.java | 30 ++++++------- .../CollectionExampleController.java | 34 +++++++-------- .../MultiValueSelectionExampleController.java | 34 +++++++-------- .../NaryMappingPropertyExampleController.java | 34 +++++++-------- .../NumberParameterExampleController.java | 32 +++++++------- .../NumberParameterWithRangeExampleController.java | 32 +++++++------- .../RuntimeResolvableSingleValue.java | 38 ++++++++-------- .../SecretStaticPropertyExampleController.java | 32 +++++++------- .../SingleValueSelectionExampleController.java | 34 +++++++-------- .../StaticPropertyAlternativesController.java | 38 ++++++++-------- .../TextParameterExampleController.java | 32 +++++++------- .../UnaryMappingPropertyExampleController.java | 34 +++++++-------- 32 files changed, 423 insertions(+), 423 deletions(-) diff --git a/pom.xml b/pom.xml index 6cb7238..69fd0eb 100644 --- a/pom.xml +++ b/pom.xml @@ -23,7 +23,7 @@ 4.0.0 - org.streampipes + org.apache.streampipes streampipes-parent 0.65.1-SNAPSHOT @@ -45,52 +45,52 @@ - org.streampipes + org.apache.streampipes streampipes-commons ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-sources ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-container-standalone ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-wrapper-standalone ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-wrapper-flink ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-sdk ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-config ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-dataformat-json ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-messaging-kafka ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-messaging-jms ${streampipes.version} @@ -100,22 +100,22 @@ ${lightcouch.version} - org.streampipes + org.apache.streampipes streampipes-measurement-units ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-pipeline-elements-shared ${project.version} - org.streampipes + org.apache.streampipes streampipes-test-utils ${streampipes.version} - org.streampipes + org.apache.streampipes streampipes-wrapper-siddhi ${streampipes.version} diff --git a/streampipes-pipeline-elements-examples-processors-jvm/pom.xml b/streampipes-pipeline-elements-examples-processors-jvm/pom.xml index feab841..1f2d908 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/pom.xml +++ b/streampipes-pipeline-elements-examples-processors-jvm/pom.xml @@ -22,7 +22,7 @@ xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> streampipes-pipeline-elements-examples - org.streampipes + org.apache.streampipes 0.65.1-SNAPSHOT 4.0.0 @@ -31,31 +31,31 @@ - org.streampipes + org.apache.streampipes streampipes-wrapper-standalone - org.streampipes + org.apache.streampipes streampipes-sdk - org.streampipes + org.apache.streampipes streampipes-container-standalone - org.streampipes + org.apache.streampipes streampipes-config - org.streampipes + org.apache.streampipes streampipes-dataformat-json - org.streampipes + org.apache.streampipes streampipes-messaging-kafka - org.streampipes + org.apache.streampipes streampipes-messaging-jms diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/ExamplesInit.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/ExamplesInit.java similarity index 51% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/ExamplesInit.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/ExamplesInit.java index 93cc77f..8fb9487 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/ExamplesInit.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/ExamplesInit.java @@ -15,32 +15,32 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm; +package org.apache.streampipes.pe.examples.jvm; -import org.streampipes.container.init.DeclarersSingleton; -import org.streampipes.container.standalone.init.StandaloneModelSubmitter; -import org.streampipes.dataformat.json.JsonDataFormatFactory; -import org.streampipes.messaging.jms.SpJmsProtocolFactory; -import org.streampipes.messaging.kafka.SpKafkaProtocolFactory; -import org.streampipes.pe.examples.jvm.config.ExamplesJvmConfig; -import org.streampipes.pe.examples.jvm.engine.ExampleExternalEngineController; -import org.streampipes.pe.examples.jvm.outputstrategy.AppendOutputController; -import org.streampipes.pe.examples.jvm.outputstrategy.CustomOutputController; -import org.streampipes.pe.examples.jvm.outputstrategy.CustomTransformOutputController; -import org.streampipes.pe.examples.jvm.outputstrategy.FixedOutputController; -import org.streampipes.pe.examples.jvm.outputstrategy.KeepOutputController; -import org.streampipes.pe.examples.jvm.outputstrategy.TransformOutputController; -import org.streampipes.pe.examples.jvm.staticproperty.CollectionExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.MultiValueSelectionExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.NaryMappingPropertyExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.NumberParameterExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.NumberParameterWithRangeExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.RuntimeResolvableSingleValue; -import org.streampipes.pe.examples.jvm.staticproperty.SecretStaticPropertyExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.SingleValueSelectionExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.StaticPropertyAlternativesController; -import org.streampipes.pe.examples.jvm.staticproperty.TextParameterExampleController; -import org.streampipes.pe.examples.jvm.staticproperty.UnaryMappingPropertyExampleController; +import org.apache.streampipes.container.init.DeclarersSingleton; +import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter; +import org.apache.streampipes.dataformat.json.JsonDataFormatFactory; +import org.apache.streampipes.messaging.jms.SpJmsProtocolFactory; +import org.apache.streampipes.messaging.kafka.SpKafkaProtocolFactory; +import org.apache.streampipes.pe.examples.jvm.config.ExamplesJvmConfig; +import org.apache.streampipes.pe.examples.jvm.engine.ExampleExternalEngineController; +import org.apache.streampipes.pe.examples.jvm.outputstrategy.AppendOutputController; +import org.apache.streampipes.pe.examples.jvm.outputstrategy.CustomOutputController; +import org.apache.streampipes.pe.examples.jvm.outputstrategy.CustomTransformOutputController; +import org.apache.streampipes.pe.examples.jvm.outputstrategy.FixedOutputController; +import org.apache.streampipes.pe.examples.jvm.outputstrategy.KeepOutputController; +import org.apache.streampipes.pe.examples.jvm.outputstrategy.TransformOutputController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.CollectionExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.MultiValueSelectionExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.NaryMappingPropertyExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.NumberParameterExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.NumberParameterWithRangeExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.RuntimeResolvableSingleValue; +import org.apache.streampipes.pe.examples.jvm.staticproperty.SecretStaticPropertyExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.SingleValueSelectionExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.StaticPropertyAlternativesController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.TextParameterExampleController; +import org.apache.streampipes.pe.examples.jvm.staticproperty.UnaryMappingPropertyExampleController; public class ExamplesInit extends StandaloneModelSubmitter { diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyController.java similarity index 69% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyController.java index 0acf760..9dda049 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyController.java @@ -15,14 +15,14 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.base; +package org.apache.streampipes.pe.examples.jvm.base; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.wrapper.params.binding.EventProcessorBindingParams; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.wrapper.params.binding.EventProcessorBindingParams; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class DummyController extends StandaloneEventProcessingDeclarer { diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyEngine.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyEngine.java similarity index 77% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyEngine.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyEngine.java index 6c0c0ba..cfe579f 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyEngine.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyEngine.java @@ -15,13 +15,13 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.base; +package org.apache.streampipes.pe.examples.jvm.base; -import org.streampipes.commons.exceptions.SpRuntimeException; -import org.streampipes.model.runtime.Event; -import org.streampipes.wrapper.context.EventProcessorRuntimeContext; -import org.streampipes.wrapper.routing.SpOutputCollector; -import org.streampipes.wrapper.runtime.EventProcessor; +import org.apache.streampipes.commons.exceptions.SpRuntimeException; +import org.apache.streampipes.model.runtime.Event; +import org.apache.streampipes.wrapper.context.EventProcessorRuntimeContext; +import org.apache.streampipes.wrapper.routing.SpOutputCollector; +import org.apache.streampipes.wrapper.runtime.EventProcessor; public class DummyEngine implements EventProcessor { diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyParameters.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyParameters.java similarity index 82% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyParameters.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyParameters.java index 69448fd..cbba25e 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/base/DummyParameters.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/base/DummyParameters.java @@ -15,10 +15,10 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.base; +package org.apache.streampipes.pe.examples.jvm.base; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.wrapper.params.binding.EventProcessorBindingParams; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.wrapper.params.binding.EventProcessorBindingParams; public class DummyParameters extends EventProcessorBindingParams { diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/config/ConfigKeys.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/config/ConfigKeys.java similarity index 95% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/config/ConfigKeys.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/config/ConfigKeys.java index b64c559..612ff00 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/config/ConfigKeys.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/config/ConfigKeys.java @@ -16,7 +16,7 @@ * */ -package org.streampipes.pe.examples.jvm.config; +package org.apache.streampipes.pe.examples.jvm.config; public class ConfigKeys { final static String HOST = "SP_HOST"; diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/config/ExamplesJvmConfig.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/config/ExamplesJvmConfig.java similarity index 90% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/config/ExamplesJvmConfig.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/config/ExamplesJvmConfig.java index 11ae48d..345c777 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/config/ExamplesJvmConfig.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/config/ExamplesJvmConfig.java @@ -16,11 +16,11 @@ * */ -package org.streampipes.pe.examples.jvm.config; +package org.apache.streampipes.pe.examples.jvm.config; -import org.streampipes.config.SpConfig; -import org.streampipes.container.model.PeConfig; +import org.apache.streampipes.config.SpConfig; +import org.apache.streampipes.container.model.PeConfig; public enum ExamplesJvmConfig implements PeConfig { INSTANCE; @@ -30,7 +30,7 @@ public enum ExamplesJvmConfig implements PeConfig { public final static String serverUrl; public final static String iconBaseUrl; - private final static String service_id = "pe/org.streampipes.processors.examples.jvm"; + private final static String service_id = "pe/org.apache.streampipes.processors.examples.jvm"; private final static String service_name = "Processors Examples JVM"; private final static String service_container_name = "processors-examples-jvm"; diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngine.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngine.java similarity index 83% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngine.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngine.java index 6543e64..09fc94f 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngine.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngine.java @@ -15,13 +15,13 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.engine; +package org.apache.streampipes.pe.examples.jvm.engine; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.streampipes.commons.exceptions.SpRuntimeException; -import org.streampipes.wrapper.context.EventProcessorRuntimeContext; -import org.streampipes.wrapper.runtime.ExternalEventProcessor; +import org.apache.streampipes.commons.exceptions.SpRuntimeException; +import org.apache.streampipes.wrapper.context.EventProcessorRuntimeContext; +import org.apache.streampipes.wrapper.runtime.ExternalEventProcessor; public class ExampleExternalEngine implements ExternalEventProcessor { diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngineController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngineController.java similarity index 66% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngineController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngineController.java index 53b095f..8acbb8c 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngineController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngineController.java @@ -15,24 +15,24 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.engine; +package org.apache.streampipes.pe.examples.jvm.engine; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.wrapper.standalone.ConfiguredExternalEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneExternalEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.wrapper.standalone.ConfiguredExternalEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneExternalEventProcessingDeclarer; public class ExampleExternalEngineController extends StandaloneExternalEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.engine.external", "Example " + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.engine.external", "Example " + "External Engine", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngineParameters.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngineParameters.java similarity index 82% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngineParameters.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngineParameters.java index 5872897..6f15a65 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/engine/ExampleExternalEngineParameters.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/engine/ExampleExternalEngineParameters.java @@ -15,10 +15,10 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.engine; +package org.apache.streampipes.pe.examples.jvm.engine; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.wrapper.params.binding.EventProcessorBindingParams; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.wrapper.params.binding.EventProcessorBindingParams; public class ExampleExternalEngineParameters extends EventProcessorBindingParams { diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/eventmodel/EventModelExamples.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/eventmodel/EventModelExamples.java similarity index 84% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/eventmodel/EventModelExamples.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/eventmodel/EventModelExamples.java index 8f41244..6e50c02 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/eventmodel/EventModelExamples.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/eventmodel/EventModelExamples.java @@ -15,14 +15,14 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.eventmodel; - -import org.streampipes.commons.exceptions.SpRuntimeException; -import org.streampipes.model.runtime.Event; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.wrapper.context.EventProcessorRuntimeContext; -import org.streampipes.wrapper.routing.SpOutputCollector; -import org.streampipes.wrapper.runtime.EventProcessor; +package org.apache.streampipes.pe.examples.jvm.eventmodel; + +import org.apache.streampipes.commons.exceptions.SpRuntimeException; +import org.apache.streampipes.model.runtime.Event; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.wrapper.context.EventProcessorRuntimeContext; +import org.apache.streampipes.wrapper.routing.SpOutputCollector; +import org.apache.streampipes.wrapper.runtime.EventProcessor; import java.util.List; diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/AppendOutputController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/AppendOutputController.java similarity index 59% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/AppendOutputController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/AppendOutputController.java index a062bbb..94b106b 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/AppendOutputController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/AppendOutputController.java @@ -15,30 +15,30 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.outputstrategy; - -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpProperties; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.vocabulary.SO; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +package org.apache.streampipes.pe.examples.jvm.outputstrategy; + +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpProperties; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.vocabulary.SO; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class AppendOutputController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.outputstrategy" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.outputstrategy" + ".append", "Append output example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/CustomOutputController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/CustomOutputController.java similarity index 62% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/CustomOutputController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/CustomOutputController.java index 7b6a83a..fb0eff9 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/CustomOutputController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/CustomOutputController.java @@ -15,21 +15,21 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.outputstrategy; - -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +package org.apache.streampipes.pe.examples.jvm.outputstrategy; + +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; import java.util.List; @@ -37,7 +37,7 @@ public class CustomOutputController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.outputstrategy" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.outputstrategy" + ".fixed", "Fixed output example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/KeepOutputController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/KeepOutputController.java similarity index 61% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/KeepOutputController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/KeepOutputController.java index 7e1d9df..9506ffc 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/KeepOutputController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/KeepOutputController.java @@ -15,27 +15,27 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.outputstrategy; - -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +package org.apache.streampipes.pe.examples.jvm.outputstrategy; + +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class KeepOutputController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.outputstrategy" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.outputstrategy" + ".keep", "Keep output example example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/TransformOutputController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/TransformOutputController.java similarity index 60% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/TransformOutputController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/TransformOutputController.java index db58104..7aff086 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/outputstrategy/TransformOutputController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/outputstrategy/TransformOutputController.java @@ -15,25 +15,25 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.outputstrategy; +package org.apache.streampipes.pe.examples.jvm.outputstrategy; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.model.schema.PropertyScope; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.sdk.helpers.TransformOperations; -import org.streampipes.sdk.utils.Datatypes; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.model.schema.PropertyScope; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.sdk.helpers.TransformOperations; +import org.apache.streampipes.sdk.utils.Datatypes; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; import java.util.List; @@ -41,7 +41,7 @@ public class TransformOutputController extends StandaloneEventProcessingDeclarer @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.outputstrategy" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.outputstrategy" + ".transform", "Transform output example example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/ListRequirementsController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/ListRequirementsController.java similarity index 64% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/ListRequirementsController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/ListRequirementsController.java index 92d1c67..604ac82 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/ListRequirementsController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/ListRequirementsController.java @@ -15,27 +15,27 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.requirements; +package org.apache.streampipes.pe.examples.jvm.requirements; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.sdk.utils.Datatypes; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.sdk.utils.Datatypes; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class ListRequirementsController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.requirements" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.requirements" + ".list", "List requirements specification examples", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/NestedRequirementsController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/NestedRequirementsController.java similarity index 93% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/NestedRequirementsController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/NestedRequirementsController.java index f1f197c..16f9a53 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/NestedRequirementsController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/NestedRequirementsController.java @@ -15,7 +15,7 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.requirements; +package org.apache.streampipes.pe.examples.jvm.requirements; public class NestedRequirementsController { } diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/SimpleStreamRequirementsController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/SimpleStreamRequirementsController.java similarity index 69% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/SimpleStreamRequirementsController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/SimpleStreamRequirementsController.java index 7d5c259..70a6bcb 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/requirements/SimpleStreamRequirementsController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/requirements/SimpleStreamRequirementsController.java @@ -15,27 +15,27 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.requirements; +package org.apache.streampipes.pe.examples.jvm.requirements; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.vocabulary.SO; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.vocabulary.SO; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class SimpleStreamRequirementsController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.requirements" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.requirements" + ".simple", "Simple requirements specification examples", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/CollectionExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CollectionExampleController.java similarity index 65% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/CollectionExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CollectionExampleController.java index 684d919..eacd294 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/CollectionExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/CollectionExampleController.java @@ -15,23 +15,23 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.StaticProperties; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.StaticProperties; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; import java.util.List; @@ -39,7 +39,7 @@ public class CollectionExampleController extends StandaloneEventProcessingDeclar @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".collection", "Collection Example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/MultiValueSelectionExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/MultiValueSelectionExampleController.java similarity index 65% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/MultiValueSelectionExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/MultiValueSelectionExampleController.java index ebdd589..dfbb362 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/MultiValueSelectionExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/MultiValueSelectionExampleController.java @@ -15,23 +15,23 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.Options; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.Options; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; import java.util.List; @@ -39,7 +39,7 @@ public class MultiValueSelectionExampleController extends StandaloneEventProcess @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".multivalue", "Multi value selection example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NaryMappingPropertyExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NaryMappingPropertyExampleController.java similarity index 63% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NaryMappingPropertyExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NaryMappingPropertyExampleController.java index a6f1e6c..14354ee 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NaryMappingPropertyExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NaryMappingPropertyExampleController.java @@ -15,23 +15,23 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.model.schema.PropertyScope; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.model.schema.PropertyScope; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; import java.util.List; @@ -40,7 +40,7 @@ public class NaryMappingPropertyExampleController extends @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".mappingnary", "Nary Mapping Property Example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NumberParameterExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NumberParameterExampleController.java similarity index 68% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NumberParameterExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NumberParameterExampleController.java index 635f45c..595fdae 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NumberParameterExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NumberParameterExampleController.java @@ -15,22 +15,22 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class NumberParameterExampleController extends StandaloneEventProcessingDeclarer { @@ -38,7 +38,7 @@ public class NumberParameterExampleController extends StandaloneEventProcessingD @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".numberparameter", "Number Parameter Example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NumberParameterWithRangeExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NumberParameterWithRangeExampleController.java similarity index 66% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NumberParameterWithRangeExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NumberParameterWithRangeExampleController.java index 9bc2bb1..d1b57e2 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/NumberParameterWithRangeExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/NumberParameterWithRangeExampleController.java @@ -15,22 +15,22 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class NumberParameterWithRangeExampleController extends StandaloneEventProcessingDeclarer { @@ -39,7 +39,7 @@ public class NumberParameterWithRangeExampleController extends @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".numberparameterrange", "Number Parameter With Range", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/RuntimeResolvableSingleValue.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/RuntimeResolvableSingleValue.java similarity index 73% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/RuntimeResolvableSingleValue.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/RuntimeResolvableSingleValue.java index 0a77785..2bc7e7e 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/RuntimeResolvableSingleValue.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/RuntimeResolvableSingleValue.java @@ -15,26 +15,26 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; import org.apache.kafka.clients.consumer.KafkaConsumer; -import org.streampipes.container.api.ResolvesContainerProvidedOptions; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.model.staticproperty.Option; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.extractor.StaticPropertyExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.container.api.ResolvesContainerProvidedOptions; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.model.staticproperty.Option; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.extractor.StaticPropertyExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; import java.util.Arrays; import java.util.List; @@ -50,7 +50,7 @@ public class RuntimeResolvableSingleValue extends @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".runtimeresolvablesingle", "Runtime-resolvable single value example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/SecretStaticPropertyExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/SecretStaticPropertyExampleController.java similarity index 65% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/SecretStaticPropertyExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/SecretStaticPropertyExampleController.java index 3a2b4e8..3435c6e 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/SecretStaticPropertyExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/SecretStaticPropertyExampleController.java @@ -15,22 +15,22 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class SecretStaticPropertyExampleController extends StandaloneEventProcessingDeclarer { @@ -38,7 +38,7 @@ public class SecretStaticPropertyExampleController extends StandaloneEventProces @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".secret", "Secret Parameter Example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/SingleValueSelectionExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/SingleValueSelectionExampleController.java similarity index 65% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/SingleValueSelectionExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/SingleValueSelectionExampleController.java index 694ee9f..e461a79 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/SingleValueSelectionExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/SingleValueSelectionExampleController.java @@ -15,30 +15,30 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.Options; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.Options; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class SingleValueSelectionExampleController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".singlevalue", "Single value selection example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/StaticPropertyAlternativesController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/StaticPropertyAlternativesController.java similarity index 70% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/StaticPropertyAlternativesController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/StaticPropertyAlternativesController.java index a496b0b..9a51b6e 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/StaticPropertyAlternativesController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/StaticPropertyAlternativesController.java @@ -15,25 +15,25 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.StaticProperties; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.Alternatives; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.Options; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.StaticProperties; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.Alternatives; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.Options; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class StaticPropertyAlternativesController extends StandaloneEventProcessingDeclarer { @@ -43,7 +43,7 @@ public class StaticPropertyAlternativesController extends @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".alternatives", "Static property alternatives example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/TextParameterExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/TextParameterExampleController.java similarity index 65% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/TextParameterExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/TextParameterExampleController.java index ca5a36d..d610806 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/TextParameterExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/TextParameterExampleController.java @@ -15,22 +15,22 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class TextParameterExampleController extends StandaloneEventProcessingDeclarer { @@ -38,7 +38,7 @@ public class TextParameterExampleController extends StandaloneEventProcessingDec @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".textparameter", "Text Parameter Example", "") .requiredStream(StreamRequirementsBuilder. create() diff --git a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/UnaryMappingPropertyExampleController.java b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/UnaryMappingPropertyExampleController.java similarity index 62% rename from streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/UnaryMappingPropertyExampleController.java rename to streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/UnaryMappingPropertyExampleController.java index 33b884f..0ddeec6 100644 --- a/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/streampipes/pe/examples/jvm/staticproperty/UnaryMappingPropertyExampleController.java +++ b/streampipes-pipeline-elements-examples-processors-jvm/src/main/java/org/apache/streampipes/pe/examples/jvm/staticproperty/UnaryMappingPropertyExampleController.java @@ -15,30 +15,30 @@ * limitations under the License. * */ -package org.streampipes.pe.examples.jvm.staticproperty; +package org.apache.streampipes.pe.examples.jvm.staticproperty; -import org.streampipes.model.graph.DataProcessorDescription; -import org.streampipes.model.graph.DataProcessorInvocation; -import org.streampipes.model.schema.PropertyScope; -import org.streampipes.pe.examples.jvm.base.DummyEngine; -import org.streampipes.pe.examples.jvm.base.DummyParameters; -import org.streampipes.sdk.builder.ProcessingElementBuilder; -import org.streampipes.sdk.builder.StreamRequirementsBuilder; -import org.streampipes.sdk.extractor.ProcessingElementParameterExtractor; -import org.streampipes.sdk.helpers.EpRequirements; -import org.streampipes.sdk.helpers.Labels; -import org.streampipes.sdk.helpers.OutputStrategies; -import org.streampipes.sdk.helpers.SupportedFormats; -import org.streampipes.sdk.helpers.SupportedProtocols; -import org.streampipes.wrapper.standalone.ConfiguredEventProcessor; -import org.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; +import org.apache.streampipes.model.graph.DataProcessorDescription; +import org.apache.streampipes.model.graph.DataProcessorInvocation; +import org.apache.streampipes.model.schema.PropertyScope; +import org.apache.streampipes.pe.examples.jvm.base.DummyEngine; +import org.apache.streampipes.pe.examples.jvm.base.DummyParameters; +import org.apache.streampipes.sdk.builder.ProcessingElementBuilder; +import org.apache.streampipes.sdk.builder.StreamRequirementsBuilder; +import org.apache.streampipes.sdk.extractor.ProcessingElementParameterExtractor; +import org.apache.streampipes.sdk.helpers.EpRequirements; +import org.apache.streampipes.sdk.helpers.Labels; +import org.apache.streampipes.sdk.helpers.OutputStrategies; +import org.apache.streampipes.sdk.helpers.SupportedFormats; +import org.apache.streampipes.sdk.helpers.SupportedProtocols; +import org.apache.streampipes.wrapper.standalone.ConfiguredEventProcessor; +import org.apache.streampipes.wrapper.standalone.declarer.StandaloneEventProcessingDeclarer; public class UnaryMappingPropertyExampleController extends StandaloneEventProcessingDeclarer { @Override public DataProcessorDescription declareModel() { - return ProcessingElementBuilder.create("org.streampipes.examples.staticproperty" + + return ProcessingElementBuilder.create("org.apache.streampipes.examples.staticproperty" + ".mappingunary", "Unary Mapping Property Example", "") .requiredStream(StreamRequirementsBuilder. create()