From 6ce0f9d036ba9f8a08eb9d29052e25ed85c2ddf4 Mon Sep 17 00:00:00 2001 From: Philipp Zehnder Date: Mon, 17 Jun 2024 10:49:18 +0200 Subject: [PATCH] refactor(#2938): Replace ExtensionsModelSubmitter in archetypes --- .../resources/archetype-resources/src/main/java/Init.java | 4 ++-- .../resources/archetype-resources/src/main/java/Init.java | 4 ++-- .../resources/archetype-resources/src/main/java/Init.java | 4 ++-- .../streampipes/pe/flink/AllFlinkPipelineElementsInit.java | 4 ++-- streampipes-maven-plugin/README.md | 2 +- 5 files changed, 9 insertions(+), 9 deletions(-) diff --git a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java index d1b9cd51e7..b467203177 100644 --- a/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java +++ b/archetypes/streampipes-archetype-extensions-jvm/src/main/resources/archetype-resources/src/main/java/Init.java @@ -32,7 +32,7 @@ import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory; import org.apache.streampipes.messaging.nats.SpNatsProtocolFactory; import org.apache.streampipes.messaging.pulsar.SpPulsarProtocolFactory; -import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter; +import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase; import org.apache.streampipes.wrapper.standalone.runtime.StandaloneStreamPipesRuntimeProvider; import ${package}.pe.${packageName}.${classNamePrefix}DataProcessor; @@ -40,7 +40,7 @@ import ${package}.pe.${packageName}.${classNamePrefix}GenericAdapter; import ${package}.pe.${packageName}.${classNamePrefix}SpecificAdapter; -public class Init extends ExtensionsModelSubmitter { +public class Init extends StreamPipesExtensionsServiceBase { public static void main(String[] args) { new Init().init(); diff --git a/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java b/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java index 58f30bf004..71e371dc77 100644 --- a/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java +++ b/archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java @@ -36,9 +36,9 @@ import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory; import org.apache.streampipes.messaging.pulsar.SpPulsarProtocolFactory; import org.apache.streampipes.messaging.nats.SpNatsProtocolFactory; -import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter; +import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase; -public class Init extends ExtensionsModelSubmitter { +public class Init extends StreamPipesExtensionsServiceBase { public static void main(String[] args) throws Exception { new Init().init(); diff --git a/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java b/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java index f0258d8ffc..b320c7a3ca 100644 --- a/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java +++ b/archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java @@ -32,12 +32,12 @@ import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory; import org.apache.streampipes.messaging.pulsar.SpPulsarProtocolFactory; import org.apache.streampipes.messaging.nats.SpNatsProtocolFactory; -import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter; +import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase; import ${package}.config.ConfigKeys; import ${package}.pe.sink.${packageName}.${classNamePrefix}Controller; -public class Init extends ExtensionsModelSubmitter { +public class Init extends StreamPipesExtensionsServiceBase { public static void main(String[] args) throws Exception { new Init().init(); diff --git a/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java b/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java index 47e568367f..033e658399 100644 --- a/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java +++ b/streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java @@ -47,11 +47,11 @@ import org.apache.streampipes.pe.flink.processor.urldereferencing.UrlDereferencingController; import org.apache.streampipes.pe.flink.processor.wordcount.WordCountController; import org.apache.streampipes.pe.flink.sink.elasticsearch.ElasticSearchController; -import org.apache.streampipes.service.extensions.ExtensionsModelSubmitter; +import org.apache.streampipes.service.extensions.StreamPipesExtensionsServiceBase; import org.apache.streampipes.wrapper.flink.FlinkRuntimeProvider; -public class AllFlinkPipelineElementsInit extends ExtensionsModelSubmitter { +public class AllFlinkPipelineElementsInit extends StreamPipesExtensionsServiceBase { public static void main(String[] args) { new AllFlinkPipelineElementsInit().init(); diff --git a/streampipes-maven-plugin/README.md b/streampipes-maven-plugin/README.md index 70c9fffb5b..6e1ea1b260 100644 --- a/streampipes-maven-plugin/README.md +++ b/streampipes-maven-plugin/README.md @@ -31,7 +31,7 @@ The streampipes-maven-plugin can either be started from the command line or embe ### Prerequisites -The plugin must be started from a module which contains an `Init` class which inherits `ExtensionsModelSubmitter`. +The plugin must be started from a module which contains an `Init` class which inherits `StreamPipesExtensionsServiceBase`. By default, the goal runs in the `package` phase. ### Command line