Use ExtensionsModelSubmitter over StandaloneModelSubmitter (#956)

apache · Dec 30, 2022 · 032ffba · 032ffba
1 parent 9db245b
commit 032ffba
Show file tree

Hide file tree

Showing 25 changed files with 48 additions and 53 deletions.
diff --git a/.../main/java/org/apache/streampipes/container/standalone/init/StandaloneModelSubmitter.java b/.../main/java/org/apache/streampipes/container/standalone/init/StandaloneModelSubmitter.java
@@ -27,8 +27,6 @@
 import org.apache.streampipes.service.extensions.base.WebSecurityConfig;
 import org.apache.streampipes.svcdiscovery.api.model.SpServiceTag;
 
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
@@ -42,9 +40,6 @@
 @Import({PipelineElementContainerResourceConfig.class, WebSecurityConfig.class})
 public abstract class StandaloneModelSubmitter extends StreamPipesExtensionsServiceBase {
 
-  private static final Logger LOG =
-      LoggerFactory.getLogger(StandaloneModelSubmitter.class.getCanonicalName());
-
   @Deprecated
   public void init(PeConfig peConfig) {
     DeclarersSingleton.getInstance()

diff --git a/...all-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java b/...all-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java
@@ -17,9 +17,9 @@
  */
 package org.apache.streampipes.pe.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -37,7 +37,7 @@
 import org.apache.streampipes.sinks.databases.flink.DatabasesFlinkInit;
 
 
-public class AllFlinkPipelineElementsInit extends StandaloneModelSubmitter {
+public class AllFlinkPipelineElementsInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new AllFlinkPipelineElementsInit().init();

diff --git a/...elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java b/...elements-all-jvm/src/main/java/org/apache/streampipes/pe/jvm/AllPipelineElementsInit.java
@@ -17,9 +17,9 @@
  */
 package org.apache.streampipes.pe.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -40,7 +40,7 @@
 import org.apache.streampipes.sinks.internal.jvm.SinksInternalJvmInit;
 import org.apache.streampipes.sinks.notifications.jvm.SinksNotificationsJvmInit;
 
-public class AllPipelineElementsInit extends StandaloneModelSubmitter {
+public class AllPipelineElementsInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new AllPipelineElementsInit().init();

diff --git a/...c/main/java/org/apache/streampipes/processors/aggregation/flink/AggregationFlinkInit.java b/...c/main/java/org/apache/streampipes/processors/aggregation/flink/AggregationFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.aggregation.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -34,7 +34,7 @@
 import org.apache.streampipes.processors.aggregation.flink.processor.eventcount.EventCountController;
 import org.apache.streampipes.processors.aggregation.flink.processor.rate.EventRateController;
 
-public class AggregationFlinkInit extends StandaloneModelSubmitter {
+public class AggregationFlinkInit extends ExtensionsModelSubmitter {
 
   public static final String SERVICE_GROUP = "org.apache.streampipes.processors.aggregation.flink";
 

diff --git a/...in/java/org/apache/streampipes/processors/changedetection/jvm/ChangeDetectionJvmInit.java b/...in/java/org/apache/streampipes/processors/changedetection/jvm/ChangeDetectionJvmInit.java
@@ -19,9 +19,9 @@
 package org.apache.streampipes.processors.changedetection.jvm;
 
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -32,7 +32,7 @@
 import org.apache.streampipes.processors.changedetection.jvm.cusum.CusumController;
 import org.apache.streampipes.processors.changedetection.jvm.welford.WelfordChangeDetection;
 
-public class ChangeDetectionJvmInit extends StandaloneModelSubmitter {
+public class ChangeDetectionJvmInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new ChangeDetectionJvmInit().init();

diff --git a/...ink/src/main/java/org/apache/streampipes/processors/enricher/flink/EnricherFlinkInit.java b/...ink/src/main/java/org/apache/streampipes/processors/enricher/flink/EnricherFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.enricher.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -32,7 +32,7 @@
 import org.apache.streampipes.processors.enricher.flink.processor.timestamp.TimestampController;
 import org.apache.streampipes.processors.enricher.flink.processor.urldereferencing.UrlDereferencingController;
 
-public class EnricherFlinkInit extends StandaloneModelSubmitter {
+public class EnricherFlinkInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new EnricherFlinkInit().init();

diff --git a/...her-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherJvmInit.java b/...her-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/EnricherJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.enricher.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -35,7 +35,7 @@
 import org.apache.streampipes.processors.enricher.jvm.processor.trigonometry.TrigonometryProcessor;
 import org.apache.streampipes.processors.enricher.jvm.processor.valuechange.ValueChangeProcessor;
 
-public class EnricherJvmInit extends StandaloneModelSubmitter {
+public class EnricherJvmInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new EnricherJvmInit().init();

diff --git a/...lters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java b/...lters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/FiltersJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.filters.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -42,7 +42,7 @@
 import org.apache.streampipes.processors.filters.jvm.processor.threshold.ThresholdDetectionProcessor;
 import org.apache.streampipes.processors.filters.jvm.processor.throughputmon.ThroughputMonitorProcessor;
 
-public class FiltersJvmInit extends StandaloneModelSubmitter {
+public class FiltersJvmInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new FiltersJvmInit().init();

diff --git a/...ters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/FiltersSiddhiInit.java b/...ters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/FiltersSiddhiInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.siddhi;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -35,7 +35,7 @@
 import org.apache.streampipes.processors.siddhi.topk.TopK;
 import org.apache.streampipes.processors.siddhi.trend.TrendController;
 
-public class FiltersSiddhiInit extends StandaloneModelSubmitter {
+public class FiltersSiddhiInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new FiltersSiddhiInit().init();

diff --git a/...sors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/GeoFlinkInit.java b/...sors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/GeoFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processor.geo.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -31,7 +31,7 @@
 import org.apache.streampipes.processor.geo.flink.config.ConfigKeys;
 import org.apache.streampipes.processor.geo.flink.processor.gridenricher.SpatialGridEnrichmentController;
 
-public class GeoFlinkInit extends StandaloneModelSubmitter {
+public class GeoFlinkInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new GeoFlinkInit().init();

diff --git a/...rocessors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/GeoJvmInit.java b/...rocessors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/GeoJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.geo.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -39,7 +39,7 @@
 import org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname.GeoCityNameRevdecodeProcessor;
 import org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator.SpeedCalculatorProcessor;
 
-public class GeoJvmInit extends StandaloneModelSubmitter {
+public class GeoJvmInit extends ExtensionsModelSubmitter {
 
   @Override
   public SpServiceDefinition provideServiceDefinition() {

diff --git a/...in/java/org/apache/streampipes/processors/imageprocessing/jvm/ImageProcessingJvmInit.java b/...in/java/org/apache/streampipes/processors/imageprocessing/jvm/ImageProcessingJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.imageprocessing.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -33,7 +33,7 @@
 import org.apache.streampipes.processors.imageprocessing.jvm.processor.imageenrichment.ImageEnrichmentController;
 import org.apache.streampipes.processors.imageprocessing.jvm.processor.qrreader.QrCodeReaderController;
 
-public class ImageProcessingJvmInit extends StandaloneModelSubmitter {
+public class ImageProcessingJvmInit extends ExtensionsModelSubmitter {
 
   @Override
   public SpServiceDefinition provideServiceDefinition() {

diff --git a/.../org/apache/streampipes/processors/pattern/detection/flink/PatternDetectionFlinkInit.java b/.../org/apache/streampipes/processors/pattern/detection/flink/PatternDetectionFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.pattern.detection.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -34,7 +34,7 @@
 import org.apache.streampipes.processors.pattern.detection.flink.processor.peak.PeakDetectionController;
 import org.apache.streampipes.processors.pattern.detection.flink.processor.sequence.SequenceController;
 
-public class PatternDetectionFlinkInit extends StandaloneModelSubmitter {
+public class PatternDetectionFlinkInit extends ExtensionsModelSubmitter {
 
   public static final String SERVICE_GROUP = "org.apache.streampipes.processors.patterndetection.flink";
 

diff --git a/...src/main/java/org/apache/streampipes/processors/statistics/flink/StatisticsFlinkInit.java b/...src/main/java/org/apache/streampipes/processors/statistics/flink/StatisticsFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.statistics.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -32,7 +32,7 @@
 import org.apache.streampipes.processors.statistics.flink.processor.stat.summary.StatisticsSummaryController;
 import org.apache.streampipes.processors.statistics.flink.processor.stat.window.StatisticsSummaryControllerWindow;
 
-public class StatisticsFlinkInit extends StandaloneModelSubmitter {
+public class StatisticsFlinkInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new StatisticsFlinkInit().init();

diff --git a/...src/main/java/org/apache/streampipes/processors/textmining/flink/TextMiningFlinkInit.java b/...src/main/java/org/apache/streampipes/processors/textmining/flink/TextMiningFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.textmining.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -31,7 +31,7 @@
 import org.apache.streampipes.processors.textmining.flink.config.ConfigKeys;
 import org.apache.streampipes.processors.textmining.flink.processor.wordcount.WordCountController;
 
-public class TextMiningFlinkInit extends StandaloneModelSubmitter {
+public class TextMiningFlinkInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new TextMiningFlinkInit().init();

diff --git a/...jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/TextMiningJvmInit.java b/...jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/TextMiningJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.textmining.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -35,7 +35,7 @@
 import org.apache.streampipes.processors.textmining.jvm.processor.sentencedetection.SentenceDetectionController;
 import org.apache.streampipes.processors.textmining.jvm.processor.tokenizer.TokenizerController;
 
-public class TextMiningJvmInit extends StandaloneModelSubmitter {
+public class TextMiningJvmInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new TextMiningJvmInit().init();

diff --git a/.../java/org/apache/streampipes/processors/transformation/flink/TransformationFlinkInit.java b/.../java/org/apache/streampipes/processors/transformation/flink/TransformationFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.transformation.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -36,7 +36,7 @@
 import org.apache.streampipes.processors.transformation.flink.processor.measurementunitonverter.MeasurementUnitConverterController;
 import org.apache.streampipes.processors.transformation.flink.processor.rename.FieldRenamerController;
 
-public class TransformationFlinkInit extends StandaloneModelSubmitter {
+public class TransformationFlinkInit extends ExtensionsModelSubmitter {
 
   public static final String SERVICE_GROUP = "org.apache.streampipes.processors.transformation.flink";
 

diff --git a/...main/java/org/apache/streampipes/processors/transformation/jvm/TransformationJvmInit.java b/...main/java/org/apache/streampipes/processors/transformation/jvm/TransformationJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.processors.transformation.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -52,7 +52,7 @@
 import org.apache.streampipes.processors.transformation.jvm.processor.value.change.ChangedValueDetectionController;
 import org.apache.streampipes.processors.transformation.jvm.processor.value.duration.CalculateDurationController;
 
-public class TransformationJvmInit extends StandaloneModelSubmitter {
+public class TransformationJvmInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new TransformationJvmInit().init();

diff --git a/...ks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java b/...ks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.sinks.brokers.jvm;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -39,7 +39,7 @@
 import org.apache.streampipes.sinks.brokers.jvm.rocketmq.RocketMQPublisherSink;
 import org.apache.streampipes.sinks.brokers.jvm.websocket.WebsocketServerSink;
 
-public class BrokersJvmInit extends StandaloneModelSubmitter {
+public class BrokersJvmInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new BrokersJvmInit().init();

diff --git a/...-flink/src/main/java/org/apache/streampipes/sinks/databases/flink/DatabasesFlinkInit.java b/...-flink/src/main/java/org/apache/streampipes/sinks/databases/flink/DatabasesFlinkInit.java
@@ -18,9 +18,9 @@
 
 package org.apache.streampipes.sinks.databases.flink;
 
+import org.apache.streampipes.container.extensions.ExtensionsModelSubmitter;
 import org.apache.streampipes.container.model.SpServiceDefinition;
 import org.apache.streampipes.container.model.SpServiceDefinitionBuilder;
-import org.apache.streampipes.container.standalone.init.StandaloneModelSubmitter;
 import org.apache.streampipes.dataformat.cbor.CborDataFormatFactory;
 import org.apache.streampipes.dataformat.fst.FstDataFormatFactory;
 import org.apache.streampipes.dataformat.json.JsonDataFormatFactory;
@@ -31,7 +31,7 @@
 import org.apache.streampipes.sinks.databases.flink.config.ConfigKeys;
 import org.apache.streampipes.sinks.databases.flink.elasticsearch.ElasticSearchController;
 
-public class DatabasesFlinkInit extends StandaloneModelSubmitter {
+public class DatabasesFlinkInit extends ExtensionsModelSubmitter {
 
   public static void main(String[] args) {
     new DatabasesFlinkInit().init();