This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 076a89e32b refactor(#3095): Remove deprecated processing element API
without version number (#3096)
076a89e32b is described below
commit 076a89e32bbbc80d21e208a1216ea68790d357ad
Author: Philipp Zehnder <[email protected]>
AuthorDate: Fri Aug 2 17:25:36 2024 +0200
refactor(#3095): Remove deprecated processing element API without version
number (#3096)
* refactor(#3095): Remove deprecated processing element API without version
number
* refactor(#3095): Migrate further processors
---
.../connect/AdapterWorkerManagementTest.java | 2 +-
.../ConnectWorkerDescriptionProviderTest.java | 2 +-
.../management/init/DeclarersSingletonTest.java | 12 +++---
.../jvm/welford/WelfordChangeDetection.java | 2 +-
.../jvm/processor/jseval/JSEvalProcessor.java | 3 +-
.../jvm/processor/math/MathOpProcessor.java | 3 +-
.../math/staticmathop/StaticMathOpProcessor.java | 3 +-
.../sizemeasure/SizeMeasureProcessor.java | 45 ++++++++++-----------
.../trigonometry/TrigonometryProcessor.java | 3 +-
.../valuechange/ValueChangeProcessor.java | 3 +-
.../booleanfilter/BooleanFilterProcessor.java | 3 +-
.../jvm/processor/compose/ComposeProcessor.java | 3 +-
.../processor/enrich/MergeByEnrichProcessor.java | 3 +-
.../jvm/processor/limit/RateLimitProcessor.java | 2 +-
.../jvm/processor/merge/MergeByTimeProcessor.java | 3 +-
.../movingaverage/MovingAverageProcessor.java | 3 +-
.../numericalfilter/NumericalFilterProcessor.java | 3 +-
.../NumericalTextFilterProcessor.java | 3 +-
.../processor/projection/ProjectionProcessor.java | 3 +-
.../processor/schema/MergeBySchemaProcessor.java | 3 +-
.../sdt/SwingingDoorTrendingFilterProcessor.java | 3 +-
.../processor/textfilter/TextFilterProcessor.java | 3 +-
.../threshold/ThresholdDetectionProcessor.java | 3 +-
.../throughputmon/ThroughputMonitorProcessor.java | 3 +-
.../processors/siddhi/count/CountAggregation.java | 3 +-
.../filter/NumericalFilterSiddhiProcessor.java | 3 +-
.../siddhi/frequency/FrequencySiddhiProcessor.java | 3 +-
.../FrequencyChangeSiddhiProcessor.java | 3 +-
.../siddhi/listcollector/ListCollector.java | 3 +-
.../processors/siddhi/listfilter/ListFilter.java | 3 +-
.../siddhi/sequence/SequenceSiddhiProcessor.java | 3 +-
.../siddhi/stop/StreamStopSiddhiProcessor.java | 3 +-
.../streampipes/processors/siddhi/topk/TopK.java | 3 +-
.../processors/siddhi/trend/TrendProcessor.java | 3 +-
.../buffergeometry/BufferGeomProcessor.java | 3 +-
.../bufferpoint/BufferPointProcessor.java | 3 +-
.../geo/jvm/jts/processor/epsg/EpsgProcessor.java | 3 +-
.../LatLngToJtsPointProcessor.java | 2 +-
.../reprojection/ReprojectionProcessor.java | 3 +-
.../trajectory/TrajectoryFromPointsProcessor.java | 2 +-
.../complex/TopologyValidationProcessor.java | 3 +-
.../simple/GeometryValidationProcessor.java | 3 +-
.../HaversineDistanceCalculatorProcessor.java | 2 +-
...HaversineStaticDistanceCalculatorProcessor.java | 2 +-
.../googlemaps/GoogleMapsGeocoderProcessor.java | 2 +-
.../GoogleMapsStaticGeocoderProcessor.java | 2 +-
.../geocityname/GeoCityNameRevdecodeProcessor.java | 2 +-
.../speedcalculator/SpeedCalculatorProcessor.java | 2 +-
.../GenericImageClassificationProcessor.java | 4 +-
.../imagecropper/ImageCropperProcessor.java | 3 +-
.../processor/qrreader/QrCodeReaderProcessor.java | 3 +-
.../jvm/processor/chunker/ChunkerProcessor.java | 3 +-
.../language/LanguageDetectionProcessor.java | 3 +-
.../processor/namefinder/NameFinderProcessor.java | 3 +-
.../partofspeech/PartOfSpeechProcessor.java | 3 +-
.../SentenceDetectionProcessor.java | 3 +-
.../processor/tokenizer/TokenizerProcessor.java | 4 +-
.../processor/array/count/CountArrayProcessor.java | 3 +-
.../processor/array/split/SplitArrayProcessor.java | 3 +-
.../counter/BooleanCounterProcessor.java | 3 +-
.../edge/SignalEdgeFilterProcessor.java | 4 +-
.../inverter/BooleanInverterProcessor.java | 3 +-
.../logical/BooleanOperatorProcessor.java | 3 +-
.../state/BooleanToStateProcessor.java | 4 +-
.../timekeeping/BooleanTimekeepingProcessor.java | 4 +-
.../booloperator/timer/BooleanTimerProcessor.java | 3 +-
.../CsvMetadataEnrichmentProcessor.java | 4 +-
.../fieldrename/FiledRenameProcessor.java | 3 +-
.../jvm/processor/hasher/FieldHasherProcessor.java | 3 +-
.../jvm/processor/mapper/FieldMapperProcessor.java | 3 +-
.../MeasurementUnitConverterProcessor.java | 4 +-
.../jvm/processor/round/RoundProcessor.java | 2 +-
.../state/buffer/StateBufferProcessor.java | 4 +-
.../buffer/StateBufferLabelerProcessor.java | 4 +-
.../labeler/number/NumberLabelerProcessor.java | 4 +-
.../counter/StringCounterProcessor.java | 4 +-
.../state/StringToStateProcessor.java | 4 +-
.../stringoperator/timer/StringTimerProcessor.java | 3 +-
.../jvm/processor/task/TaskDurationProcessor.java | 4 +-
.../TimestampExtractorProcessor.java | 4 +-
.../TransformToBooleanProcessor.java | 3 +-
.../change/ChangedValueDetectionProcessor.java | 3 +-
.../value/duration/CalculateDurationProcessor.java | 3 +-
.../streampipes/sdk/builder/DataSinkBuilder.java | 30 --------------
.../sdk/builder/ProcessingElementBuilder.java | 46 ----------------------
.../adapter/AdapterConfigurationBuilder.java | 14 -------
.../adapter/AdapterConfigurationBuilderTest.java | 19 +++++----
.../extractor/AdapterParameterExtractorTest.java | 16 +++++---
88 files changed, 201 insertions(+), 225 deletions(-)
diff --git
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerManagementTest.java
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerManagementTest.java
index ff7eb0294e..33f49575e3 100644
---
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerManagementTest.java
+++
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerManagementTest.java
@@ -36,7 +36,7 @@ public class AdapterWorkerManagementTest {
@Test
public void invokeAdapterNotPresent() throws AdapterException {
var adapterDescription = AdapterConfigurationBuilder
- .create("id", null)
+ .create("id", 0, null)
.build();
var declarerSingleton = mock(IDeclarersSingleton.class);
diff --git
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/ConnectWorkerDescriptionProviderTest.java
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/ConnectWorkerDescriptionProviderTest.java
index 602b0a4316..9ca0911886 100644
---
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/ConnectWorkerDescriptionProviderTest.java
+++
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/ConnectWorkerDescriptionProviderTest.java
@@ -44,7 +44,7 @@ public class ConnectWorkerDescriptionProviderTest {
var testAdapter = mock(StreamPipesAdapter.class);
doAnswer(invocation ->
AdapterConfigurationBuilder
- .create(adapterId, null)
+ .create(adapterId, 0, null)
.buildConfiguration())
.when(testAdapter)
.declareConfig();
diff --git
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/init/DeclarersSingletonTest.java
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/init/DeclarersSingletonTest.java
index 1a8c2504a3..e632a80cf9 100644
---
a/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/init/DeclarersSingletonTest.java
+++
b/streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/init/DeclarersSingletonTest.java
@@ -36,16 +36,18 @@ public class DeclarersSingletonTest {
var id = "id";
var testAdapter = mock(StreamPipesAdapter.class);
doAnswer(invocation ->
- AdapterConfigurationBuilder
- .create(id, null)
- .buildConfiguration())
+ AdapterConfigurationBuilder
+ .create(id, 0, null)
+ .buildConfiguration())
.when(testAdapter)
.declareConfig();
- DeclarersSingleton.getInstance().setAdapters(List.of(testAdapter));
+ DeclarersSingleton.getInstance()
+ .setAdapters(List.of(testAdapter));
- var result = DeclarersSingleton.getInstance().getAdapter(id);
+ var result = DeclarersSingleton.getInstance()
+ .getAdapter(id);
Assertions.assertTrue(result.isPresent());
Assertions.assertEquals(testAdapter, result.get());
diff --git
a/streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetection.java
b/streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetection.java
index e134583407..f44f299e05 100644
---
a/streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetection.java
+++
b/streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetection.java
@@ -54,7 +54,7 @@ public class WelfordChangeDetection extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.changedetection.jvm.welford")
+ return
ProcessingElementBuilder.create("org.apache.streampipes.processors.changedetection.jvm.welford",
0)
.category(DataProcessorType.VALUE_OBSERVER)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalProcessor.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalProcessor.java
index aed774190d..78ee849115 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalProcessor.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalProcessor.java
@@ -50,7 +50,8 @@ public class JSEvalProcessor extends StreamPipesDataProcessor
{
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.enricher.jvm.jseval")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.enricher.jvm.jseval", 0)
.category(DataProcessorType.SCRIPTING)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/MathOpProcessor.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/MathOpProcessor.java
index 3e031ee6b5..7a2409d1b2 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/MathOpProcessor.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/MathOpProcessor.java
@@ -58,7 +58,8 @@ public class MathOpProcessor extends StreamPipesDataProcessor
{
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.enricher.jvm.processor.math.mathop")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.enricher.jvm.processor.math.mathop",
0)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
.category(DataProcessorType.ALGORITHM)
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/staticmathop/StaticMathOpProcessor.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/staticmathop/StaticMathOpProcessor.java
index 5e1739b283..bdafa65682 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/staticmathop/StaticMathOpProcessor.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/math/staticmathop/StaticMathOpProcessor.java
@@ -56,7 +56,8 @@ public class StaticMathOpProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.enricher.jvm.processor.math.staticmathop",
0)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
.category(DataProcessorType.ALGORITHM)
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/SizeMeasureProcessor.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/SizeMeasureProcessor.java
index c9d2cdc15f..47a955052b 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/SizeMeasureProcessor.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/SizeMeasureProcessor.java
@@ -58,28 +58,29 @@ public class SizeMeasureProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.enricher.jvm.sizemeasure")
-
.category(DataProcessorType.STRUCTURE_ANALYTICS)
-
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
- .withLocales(Locales.EN)
- .requiredStream(StreamRequirementsBuilder
- .create()
-
.requiredProperty(EpRequirements.anyProperty())
- .build())
- .requiredSingleValueSelection(
- Labels.withId(SIZE_UNIT),
- Options.from(
- new Tuple2<>(BYTES_OPTION,
BYTE_SIZE),
- new Tuple2<>(KILO_BYTES_OPTION,
KILOBYTE_SIZE),
- new Tuple2<>(MEGA_BYTES_OPTION,
MEGABYTE_SIZE)
- )
- )
-
.outputStrategy(OutputStrategies.append(EpProperties.doubleEp(
- Labels.withId(EVENT_SIZE),
- EVENT_SIZE,
- "http://schema.org/contentSize";
- )))
- .build();
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.enricher.jvm.sizemeasure",
0)
+ .category(DataProcessorType.STRUCTURE_ANALYTICS)
+ .withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
+ .withLocales(Locales.EN)
+ .requiredStream(StreamRequirementsBuilder
+ .create()
+ .requiredProperty(EpRequirements.anyProperty())
+ .build())
+ .requiredSingleValueSelection(
+ Labels.withId(SIZE_UNIT),
+ Options.from(
+ new Tuple2<>(BYTES_OPTION, BYTE_SIZE),
+ new Tuple2<>(KILO_BYTES_OPTION, KILOBYTE_SIZE),
+ new Tuple2<>(MEGA_BYTES_OPTION, MEGABYTE_SIZE)
+ )
+ )
+ .outputStrategy(OutputStrategies.append(EpProperties.doubleEp(
+ Labels.withId(EVENT_SIZE),
+ EVENT_SIZE,
+ "http://schema.org/contentSize";
+ )))
+ .build();
}
@Override
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/trigonometry/TrigonometryProcessor.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/trigonometry/TrigonometryProcessor.java
index 2e7aa9ae3b..eb96233d70 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/trigonometry/TrigonometryProcessor.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/trigonometry/TrigonometryProcessor.java
@@ -50,7 +50,8 @@ public class TrigonometryProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.enricher.jvm.processor.trigonometry")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.enricher.jvm.processor.trigonometry",
0)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
.category(DataProcessorType.ALGORITHM)
diff --git
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessor.java
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessor.java
index 5c98b4e248..fac9005d72 100644
---
a/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessor.java
+++
b/streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessor.java
@@ -51,7 +51,8 @@ public class ValueChangeProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.enricher.jvm.valuechange")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.enricher.jvm.valuechange",
0)
.category(DataProcessorType.VALUE_OBSERVER)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/booleanfilter/BooleanFilterProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/booleanfilter/BooleanFilterProcessor.java
index 8dee88c451..a6a6bca00b 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/booleanfilter/BooleanFilterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/booleanfilter/BooleanFilterProcessor.java
@@ -50,7 +50,8 @@ public class BooleanFilterProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.processor.booleanfilter")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.filters.jvm.processor.booleanfilter",
0)
.category(DataProcessorType.FILTER, DataProcessorType.BOOLEAN_OPERATOR)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/compose/ComposeProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/compose/ComposeProcessor.java
index 1e0af967e2..4147c092a8 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/compose/ComposeProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/compose/ComposeProcessor.java
@@ -47,7 +47,8 @@ public class ComposeProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.compose")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.compose", 0)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/enrich/MergeByEnrichProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/enrich/MergeByEnrichProcessor.java
index f6232076c0..e14a4bb0a1 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/enrich/MergeByEnrichProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/enrich/MergeByEnrichProcessor.java
@@ -49,7 +49,8 @@ public class MergeByEnrichProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.enrich")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.enrich", 0)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitProcessor.java
index c58e384dca..b58ff51881 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitProcessor.java
@@ -72,7 +72,7 @@ public class RateLimitProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.limit")
+ return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.limit",
0)
.category(DataProcessorType.FILTER,
DataProcessorType.STRUCTURE_ANALYTICS)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/merge/MergeByTimeProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/merge/MergeByTimeProcessor.java
index c425e5d099..60e2b69131 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/merge/MergeByTimeProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/merge/MergeByTimeProcessor.java
@@ -56,7 +56,8 @@ public class MergeByTimeProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.merge")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.merge", 0)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON,
"merge_description.png")
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/MovingAverageProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/MovingAverageProcessor.java
index 4caddf00d2..6cb32fb619 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/MovingAverageProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/MovingAverageProcessor.java
@@ -59,7 +59,8 @@ public class MovingAverageProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.movingaverage")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.movingaverage",
0)
.category(DataProcessorType.FILTER)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
index e81a99005c..ed67e9173f 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericalfilter/NumericalFilterProcessor.java
@@ -51,7 +51,8 @@ public class NumericalFilterProcessor implements
IStreamPipesDataProcessor {
public IDataProcessorConfiguration declareConfig() {
return DataProcessorConfiguration.create(
NumericalFilterProcessor::new,
-
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.numericalfilter")
+ ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.filters.jvm.numericalfilter", 0)
.category(DataProcessorType.FILTER)
.withAssets(ExtensionAssetType.DOCUMENTATION,
ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericaltextfilter/NumericalTextFilterProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericaltextfilter/NumericalTextFilterProcessor.java
index b1527e0abf..0bc1c6d84a 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericaltextfilter/NumericalTextFilterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/numericaltextfilter/NumericalTextFilterProcessor.java
@@ -58,7 +58,8 @@ public class NumericalTextFilterProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.numericaltextfilter")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.filters.jvm.numericaltextfilter", 0)
.category(DataProcessorType.FILTER, DataProcessorType.STRING_OPERATOR)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/projection/ProjectionProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/projection/ProjectionProcessor.java
index c933da7bf5..6866ef3c60 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/projection/ProjectionProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/projection/ProjectionProcessor.java
@@ -41,7 +41,8 @@ public class ProjectionProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.project")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.project", 0)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/schema/MergeBySchemaProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/schema/MergeBySchemaProcessor.java
index ee9c15c26e..b61b78abc9 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/schema/MergeBySchemaProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/schema/MergeBySchemaProcessor.java
@@ -39,7 +39,8 @@ public class MergeBySchemaProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.schema")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.schema", 0)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/sdt/SwingingDoorTrendingFilterProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/sdt/SwingingDoorTrendingFilterProcessor.java
index 44986856c0..f01f507da3 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/sdt/SwingingDoorTrendingFilterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/sdt/SwingingDoorTrendingFilterProcessor.java
@@ -54,7 +54,8 @@ public class SwingingDoorTrendingFilterProcessor extends
StreamPipesDataProcesso
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.sdt")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.sdt", 0)
.category(DataProcessorType.FILTER)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/textfilter/TextFilterProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/textfilter/TextFilterProcessor.java
index 66e3a2285e..0a9c558f48 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/textfilter/TextFilterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/textfilter/TextFilterProcessor.java
@@ -48,7 +48,8 @@ public class TextFilterProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.textfilter")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.textfilter", 0)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
.category(DataProcessorType.FILTER, DataProcessorType.STRING_OPERATOR)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/threshold/ThresholdDetectionProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/threshold/ThresholdDetectionProcessor.java
index e1934ee457..950dbcb488 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/threshold/ThresholdDetectionProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/threshold/ThresholdDetectionProcessor.java
@@ -53,7 +53,8 @@ public class ThresholdDetectionProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.threshold")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.threshold", 0)
.category(DataProcessorType.FILTER)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/throughputmon/ThroughputMonitorProcessor.java
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/throughputmon/ThroughputMonitorProcessor.java
index 959a7bfb60..c07242ab62 100644
---
a/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/throughputmon/ThroughputMonitorProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/processor/throughputmon/ThroughputMonitorProcessor.java
@@ -56,7 +56,8 @@ public class ThroughputMonitorProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.filters.jvm.throughputmon")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.filters.jvm.throughputmon",
0)
.category(DataProcessorType.STRUCTURE_ANALYTICS)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/count/CountAggregation.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/count/CountAggregation.java
index d6e86bd6c2..1000163dcc 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/count/CountAggregation.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/count/CountAggregation.java
@@ -55,7 +55,8 @@ public class CountAggregation extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.count")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.count", 0)
.category(DataProcessorType.COUNT_OPERATOR)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalFilterSiddhiProcessor.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalFilterSiddhiProcessor.java
index b53f1408b4..4f1f2863c0 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalFilterSiddhiProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalFilterSiddhiProcessor.java
@@ -50,7 +50,8 @@ public class NumericalFilterSiddhiProcessor extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.numericalfilter")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.numericalfilter", 0)
.category(DataProcessorType.FILTER)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/FrequencySiddhiProcessor.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/FrequencySiddhiProcessor.java
index 62d8660c23..9afe6e2565 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/FrequencySiddhiProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/FrequencySiddhiProcessor.java
@@ -43,7 +43,8 @@ public class FrequencySiddhiProcessor extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.frequency")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.frequency", 0)
.category(DataProcessorType.FILTER)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/FrequencyChangeSiddhiProcessor.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/FrequencyChangeSiddhiProcessor.java
index 4937f4e05a..fce4659b2b 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/FrequencyChangeSiddhiProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/FrequencyChangeSiddhiProcessor.java
@@ -44,7 +44,8 @@ public class FrequencyChangeSiddhiProcessor extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.frequencychange")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.frequencychange", 0)
.category(DataProcessorType.FILTER)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listcollector/ListCollector.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listcollector/ListCollector.java
index a281c6702e..6d908bd7dc 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listcollector/ListCollector.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listcollector/ListCollector.java
@@ -59,7 +59,8 @@ public class ListCollector extends StreamPipesSiddhiProcessor
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.listcollector")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.listcollector", 0)
.withLocales(Locales.EN)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listfilter/ListFilter.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listfilter/ListFilter.java
index 1e09c70eda..5a6627e90b 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listfilter/ListFilter.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/listfilter/ListFilter.java
@@ -48,7 +48,8 @@ public class ListFilter extends StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.listfilter")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.listfilter", 0)
.withLocales(Locales.EN)
.category(DataProcessorType.FILTER)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/SequenceSiddhiProcessor.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/SequenceSiddhiProcessor.java
index 8c980e3d43..82eff41beb 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/SequenceSiddhiProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/SequenceSiddhiProcessor.java
@@ -41,7 +41,8 @@ public class SequenceSiddhiProcessor extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.sequence")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.sequence", 0)
.category(DataProcessorType.FILTER)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/StreamStopSiddhiProcessor.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/StreamStopSiddhiProcessor.java
index 16e8ec2495..a24a6e4709 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/StreamStopSiddhiProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/StreamStopSiddhiProcessor.java
@@ -43,7 +43,8 @@ public class StreamStopSiddhiProcessor extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.stop")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.stop", 0)
.withLocales(Locales.EN)
.category(DataProcessorType.FILTER)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/topk/TopK.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/topk/TopK.java
index 5c3c845c40..86b67b54d3 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/topk/TopK.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/topk/TopK.java
@@ -70,7 +70,8 @@ public class TopK extends StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.topk")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.topk", 0)
.withLocales(Locales.EN)
.category(DataProcessorType.TRANSFORM)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/TrendProcessor.java
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/TrendProcessor.java
index 2f05e05933..80407f918c 100644
---
a/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/TrendProcessor.java
+++
b/streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/TrendProcessor.java
@@ -68,7 +68,8 @@ public class TrendProcessor extends
StreamPipesSiddhiProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.siddhi.increase")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.siddhi.increase", 0)
.withLocales(Locales.EN)
.category(DataProcessorType.PATTERN_DETECT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/buffergeometry/BufferGeomProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/buffergeometry/BufferGeomProcessor.java
index 93ec528938..6c97cfe0df 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/buffergeometry/BufferGeomProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/buffergeometry/BufferGeomProcessor.java
@@ -73,7 +73,8 @@ public class BufferGeomProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.buffergeometry",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/bufferpoint/BufferPointProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/bufferpoint/BufferPointProcessor.java
index 93f097eb28..d9577aa93f 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/bufferpoint/BufferPointProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/bufferpoint/BufferPointProcessor.java
@@ -66,7 +66,8 @@ public class BufferPointProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.bufferpoint",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON,
"output.png")
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/epsg/EpsgProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/epsg/EpsgProcessor.java
index 46a604013d..1ea86f4c2e 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/epsg/EpsgProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/epsg/EpsgProcessor.java
@@ -43,7 +43,8 @@ public class EpsgProcessor extends StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.geo.jvm.jts.processor.epsg")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.epsg", 0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latlngtojtspoint/LatLngToJtsPointProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latlngtojtspoint/LatLngToJtsPointProcessor.java
index ef67ca0a11..4d51338dba 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latlngtojtspoint/LatLngToJtsPointProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/latlngtojtspoint/LatLngToJtsPointProcessor.java
@@ -56,7 +56,7 @@ public class LatLngToJtsPointProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
-
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint")
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.latlngtojtspoint",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/reprojection/ReprojectionProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/reprojection/ReprojectionProcessor.java
index 5e4a380401..13f5d807b6 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/reprojection/ReprojectionProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/reprojection/ReprojectionProcessor.java
@@ -56,7 +56,8 @@ public class ReprojectionProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.reprojection",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/TrajectoryFromPointsProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/TrajectoryFromPointsProcessor.java
index df9fc8c000..a52194658c 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/TrajectoryFromPointsProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/trajectory/TrajectoryFromPointsProcessor.java
@@ -65,7 +65,7 @@ public class TrajectoryFromPointsProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
-
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory")
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.trajectory", 0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/complex/TopologyValidationProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/complex/TopologyValidationProcessor.java
index 6e79bf908c..16ceff5a0b 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/complex/TopologyValidationProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/complex/TopologyValidationProcessor.java
@@ -61,7 +61,8 @@ public class TopologyValidationProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.validation.complex",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/simple/GeometryValidationProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/simple/GeometryValidationProcessor.java
index 15d58939c8..422d89d2f7 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/simple/GeometryValidationProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/jts/processor/validation/simple/GeometryValidationProcessor.java
@@ -61,7 +61,8 @@ public class GeometryValidationProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.geo.jvm.jts.processor.validation.simple",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversine/HaversineDistanceCalculatorProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversine/HaversineDistanceCalculatorProcessor.java
index f582e3cadc..1a0b7d7d30 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversine/HaversineDistanceCalculatorProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversine/HaversineDistanceCalculatorProcessor.java
@@ -56,7 +56,7 @@ public class HaversineDistanceCalculatorProcessor extends
StreamPipesDataProcess
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine")
+
"org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversine",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversinestatic/HaversineStaticDistanceCalculatorProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversinestatic/HaversineStaticDistanceCalculatorProcessor.java
index e94544897c..320d69bbe7 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversinestatic/HaversineStaticDistanceCalculatorProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/distancecalculator/haversinestatic/HaversineStaticDistanceCalculatorProcessor.java
@@ -58,7 +58,7 @@ public class HaversineStaticDistanceCalculatorProcessor
extends StreamPipesDataP
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic")
+
"org.apache.streampipes.processors.geo.jvm.latlong.processor.distancecalculator.haversinestatic",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemaps/GoogleMapsGeocoderProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemaps/GoogleMapsGeocoderProcessor.java
index 1498b50498..b42df348fa 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemaps/GoogleMapsGeocoderProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemaps/GoogleMapsGeocoderProcessor.java
@@ -55,7 +55,7 @@ public class GoogleMapsGeocoderProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
-
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps")
+
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemaps",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemapsstatic/GoogleMapsStaticGeocoderProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemapsstatic/GoogleMapsStaticGeocoderProcessor.java
index b0edecaedf..83d2de7ae1 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemapsstatic/GoogleMapsStaticGeocoderProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/geocoder/googlemapsstatic/GoogleMapsStaticGeocoderProcessor.java
@@ -56,7 +56,7 @@ public class GoogleMapsStaticGeocoderProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
-
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic")
+
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.geocoder.googlemapsstatic",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/revgeocoder/geocityname/GeoCityNameRevdecodeProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/revgeocoder/geocityname/GeoCityNameRevdecodeProcessor.java
index 66f67cbd65..17f7e0cd70 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/revgeocoder/geocityname/GeoCityNameRevdecodeProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/revgeocoder/geocityname/GeoCityNameRevdecodeProcessor.java
@@ -59,7 +59,7 @@ public class GeoCityNameRevdecodeProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
-
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname")
+
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.revgeocoder.geocityname",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/speedcalculator/SpeedCalculatorProcessor.java
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/speedcalculator/SpeedCalculatorProcessor.java
index ad3099e25c..8ce6949610 100644
---
a/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/speedcalculator/SpeedCalculatorProcessor.java
+++
b/streampipes-extensions/streampipes-processors-geo-jvm/src/main/java/org/apache/streampipes/processors/geo/jvm/latlong/processor/speedcalculator/SpeedCalculatorProcessor.java
@@ -59,7 +59,7 @@ public class SpeedCalculatorProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
-
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator")
+
.create("org.apache.streampipes.processors.geo.jvm.latlong.processor.speedcalculator",
0)
.category(DataProcessorType.GEO)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationProcessor.java
b/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationProcessor.java
index bcc53e6e0e..d4be3b03a9 100644
---
a/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationProcessor.java
+++
b/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/genericclassification/GenericImageClassificationProcessor.java
@@ -64,8 +64,8 @@ public class GenericImageClassificationProcessor extends
StreamPipesDataProcesso
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processor.imageclassification.jvm.generic-image-classification",
0)
.category(DataProcessorType.IMAGE_PROCESSING)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperProcessor.java
b/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperProcessor.java
index bea40f2d58..c6cc15c69e 100644
---
a/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperProcessor.java
+++
b/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/imagecropper/ImageCropperProcessor.java
@@ -51,7 +51,8 @@ public class ImageCropperProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processor.imageclassification.jvm.image-cropper")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processor.imageclassification.jvm.image-cropper",
0)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
.category(DataProcessorType.IMAGE_PROCESSING)
diff --git
a/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderProcessor.java
b/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderProcessor.java
index ccb2de497c..59982cbfe9 100644
---
a/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderProcessor.java
+++
b/streampipes-extensions/streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing/jvm/processor/qrreader/QrCodeReaderProcessor.java
@@ -63,7 +63,8 @@ public class QrCodeReaderProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processor.imageclassification.qrcode")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processor.imageclassification.qrcode",
0)
.category(DataProcessorType.IMAGE_PROCESSING)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/ChunkerProcessor.java
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/ChunkerProcessor.java
index 2e57f76d29..63c90ac447 100644
---
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/ChunkerProcessor.java
+++
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/ChunkerProcessor.java
@@ -63,7 +63,8 @@ public class ChunkerProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.textmining.jvm.chunker")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.textmining.jvm.chunker", 0)
.category(DataProcessorType.ENRICH_TEXT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/LanguageDetectionProcessor.java
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/LanguageDetectionProcessor.java
index ec1b2979b0..0f4dca2d76 100644
---
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/LanguageDetectionProcessor.java
+++
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/LanguageDetectionProcessor.java
@@ -57,7 +57,8 @@ public class LanguageDetectionProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.textmining.jvm.languagedetection")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.textmining.jvm.languagedetection", 0)
.category(DataProcessorType.ENRICH_TEXT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/NameFinderProcessor.java
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/NameFinderProcessor.java
index a2510d0b5e..8120a8467f 100644
---
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/NameFinderProcessor.java
+++
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/NameFinderProcessor.java
@@ -59,7 +59,8 @@ public class NameFinderProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.textmining.jvm.namefinder")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.textmining.jvm.namefinder",
0)
.category(DataProcessorType.ENRICH_TEXT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/PartOfSpeechProcessor.java
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/PartOfSpeechProcessor.java
index b09a3a8f8f..4f2eddab07 100644
---
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/PartOfSpeechProcessor.java
+++
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/PartOfSpeechProcessor.java
@@ -57,7 +57,8 @@ public class PartOfSpeechProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.textmining.jvm.partofspeech")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.textmining.jvm.partofspeech", 0)
.category(DataProcessorType.ENRICH_TEXT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionProcessor.java
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionProcessor.java
index 58c04879a8..83136155d3 100644
---
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionProcessor.java
+++
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionProcessor.java
@@ -52,7 +52,8 @@ public class SentenceDetectionProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.textmining.jvm.sentencedetection")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.textmining.jvm.sentencedetection", 0)
.category(DataProcessorType.ENRICH_TEXT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/TokenizerProcessor.java
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/TokenizerProcessor.java
index 5192d0d5e0..a40cda4643 100644
---
a/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/TokenizerProcessor.java
+++
b/streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/TokenizerProcessor.java
@@ -53,10 +53,10 @@ public class TokenizerProcessor extends
StreamPipesDataProcessor {
private TokenizerME tokenizer;
- //TODO: Maybe change outputStrategy to an array instead of tons of different
strings
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.textmining.jvm.tokenizer")
+ return ProcessingElementBuilder
+ .create("org.apache.streampipes.processors.textmining.jvm.tokenizer",
0)
.category(DataProcessorType.ENRICH_TEXT)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.withLocales(Locales.EN)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayProcessor.java
index a092875d18..0e72d26823 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayProcessor.java
@@ -49,7 +49,8 @@ public class CountArrayProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.count-array")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.count-array", 0)
.category(DataProcessorType.COUNT_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArrayProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArrayProcessor.java
index 7e3126cc84..742c0243d8 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArrayProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArrayProcessor.java
@@ -60,7 +60,8 @@ public class SplitArrayProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.split-array")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.split-array", 0)
.category(DataProcessorType.TRANSFORM)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterProcessor.java
index 8ea8eec04c..802a61c8bc 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterProcessor.java
@@ -62,7 +62,8 @@ public class BooleanCounterProcessor implements
IStreamPipesDataProcessor {
public IDataProcessorConfiguration declareConfig() {
return DataProcessorConfiguration.create(
BooleanCounterProcessor::new,
-
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.booloperator.counter")
+ ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.booloperator.counter",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR,
DataProcessorType.COUNT_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION,
ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessor.java
index 7cf715e911..efd28c53d4 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessor.java
@@ -65,8 +65,8 @@ public class SignalEdgeFilterProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.booloperator.edge",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR, DataProcessorType.FILTER)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessor.java
index 8dfc04dec5..6be14a9edc 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessor.java
@@ -41,7 +41,8 @@ public class BooleanInverterProcessor extends
StreamPipesDataProcessor {
private String invertFieldName;
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.booloperator.inverter")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.booloperator.inverter",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/BooleanOperatorProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/BooleanOperatorProcessor.java
index 3fef1fd6b3..7db430aee1 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/BooleanOperatorProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/logical/BooleanOperatorProcessor.java
@@ -54,7 +54,8 @@ public class BooleanOperatorProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.booloperator.logical")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.booloperator.logical",
0)
.withAssets(ExtensionAssetType.DOCUMENTATION)
.withLocales(Locales.EN)
.category(DataProcessorType.BOOLEAN_OPERATOR)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateProcessor.java
index f435864dea..2736cc7864 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateProcessor.java
@@ -68,8 +68,8 @@ public class BooleanToStateProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.booloperator.state",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/BooleanTimekeepingProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/BooleanTimekeepingProcessor.java
index 2202386d8e..71be83b2a9 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/BooleanTimekeepingProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/BooleanTimekeepingProcessor.java
@@ -66,8 +66,8 @@ public class BooleanTimekeepingProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.booloperator.timekeeping",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR, DataProcessorType.TIME)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON,
"time_measure_example.png")
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/BooleanTimerProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/BooleanTimerProcessor.java
index b9517b2f1f..26eb03588f 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/BooleanTimerProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/BooleanTimerProcessor.java
@@ -62,7 +62,8 @@ public class BooleanTimerProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.booloperator.timer")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.booloperator.timer",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR, DataProcessorType.TIME)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/CsvMetadataEnrichmentProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/CsvMetadataEnrichmentProcessor.java
index 910ccb69c2..d4ea565869 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/CsvMetadataEnrichmentProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/CsvMetadataEnrichmentProcessor.java
@@ -89,8 +89,8 @@ public class CsvMetadataEnrichmentProcessor
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm"
- + ".csvmetadata")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.csvmetadata", 0)
.category(DataProcessorType.ENRICH)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessor.java
index e0c2519305..5cb782974c 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessor.java
@@ -46,7 +46,8 @@ public class FiledRenameProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.fieldrename")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.fieldrename", 0)
.category(DataProcessorType.TRANSFORM)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessor.java
index 4aeafdac09..0425bc55df 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessor.java
@@ -47,7 +47,8 @@ public class FieldHasherProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.fieldhasher")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.fieldhasher", 0)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.requiredStream(StreamRequirementsBuilder
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/mapper/FieldMapperProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/mapper/FieldMapperProcessor.java
index 4d7c01dbc7..55ff21c66a 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/mapper/FieldMapperProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/mapper/FieldMapperProcessor.java
@@ -57,7 +57,8 @@ public class FieldMapperProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.field-mapper")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.field-mapper", 0)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.requiredStream(StreamRequirementsBuilder
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/measurementconverter/MeasurementUnitConverterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/measurementconverter/MeasurementUnitConverterProcessor.java
index 045b1d4a26..b61742f89b 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/measurementconverter/MeasurementUnitConverterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/measurementconverter/MeasurementUnitConverterProcessor.java
@@ -64,8 +64,8 @@ public class MeasurementUnitConverterProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.measurementunitconverter")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.measurementunitconverter",
0)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.requiredStream(StreamRequirementsBuilder
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/round/RoundProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/round/RoundProcessor.java
index a692999f6f..51fc61494a 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/round/RoundProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/round/RoundProcessor.java
@@ -65,7 +65,7 @@ public class RoundProcessor extends StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
return ProcessingElementBuilder
- .create("org.apache.streampipes.processors.transformation.jvm.round")
+ .create("org.apache.streampipes.processors.transformation.jvm.round",
0)
.category(DataProcessorType.TRANSFORM)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferProcessor.java
index 08632fa745..c9a7d12812 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferProcessor.java
@@ -62,8 +62,8 @@ public class StateBufferProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.state.buffer")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.state.buffer",
0)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
.requiredStream(StreamRequirementsBuilder.create()
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerProcessor.java
index 3f7c5be966..85b5c948ca 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerProcessor.java
@@ -83,8 +83,8 @@ public class StateBufferLabelerProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.buffer",
0)
.category(DataProcessorType.STRING_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerProcessor.java
index 742ae2082f..90fc371d98 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerProcessor.java
@@ -67,8 +67,8 @@ public class NumberLabelerProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.state.labeler.number",
0)
.category(DataProcessorType.ENRICH)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterProcessor.java
index 6283397a8e..f90150520d 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterProcessor.java
@@ -57,8 +57,8 @@ public class StringCounterProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.stringoperator.counter")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.stringoperator.counter",
0)
.category(DataProcessorType.STRING_OPERATOR,
DataProcessorType.COUNT_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateProcessor.java
index 08bcff5349..72ad99ffb0 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateProcessor.java
@@ -51,8 +51,8 @@ public class StringToStateProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.stringoperator.state",
0)
.category(DataProcessorType.STRING_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerProcessor.java
index c00fcdfc50..2a0acb9026 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerProcessor.java
@@ -68,7 +68,8 @@ public class StringTimerProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.stringoperator.timer")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.stringoperator.timer",
0)
.category(DataProcessorType.STRING_OPERATOR, DataProcessorType.TIME)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/TaskDurationProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/TaskDurationProcessor.java
index 72a43e4e47..44fa065b28 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/TaskDurationProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/TaskDurationProcessor.java
@@ -59,8 +59,8 @@ public class TaskDurationProcessor extends
StreamPipesDataProcessor {
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm"
- + ".taskduration")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.taskduration", 0)
.category(DataProcessorType.TIME)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractorProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractorProcessor.java
index 4915192557..dd4802ef88 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractorProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractorProcessor.java
@@ -57,8 +57,8 @@ public class TimestampExtractorProcessor extends
StreamPipesDataProcessor
@Override
public DataProcessorDescription declareModel() {
- return ProcessingElementBuilder.create(
-
"org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.processor.timestampextractor",
0)
.category(DataProcessorType.TIME)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanProcessor.java
index 00e74b3972..316aa9c375 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanProcessor.java
@@ -62,7 +62,8 @@ public class TransformToBooleanProcessor
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.transform-to-boolean")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.transform-to-boolean",
0)
.category(DataProcessorType.BOOLEAN_OPERATOR)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetectionProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetectionProcessor.java
index 91d23605c6..bb133d26e4 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetectionProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetectionProcessor.java
@@ -60,7 +60,8 @@ public class ChangedValueDetectionProcessor
//TODO: Change Icon
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.changed-value")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.changed-value", 0)
.category(DataProcessorType.VALUE_OBSERVER)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION)
diff --git
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDurationProcessor.java
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDurationProcessor.java
index 4bf279e26e..5526288782 100644
---
a/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDurationProcessor.java
+++
b/streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDurationProcessor.java
@@ -58,7 +58,8 @@ public class CalculateDurationProcessor extends
StreamPipesDataProcessor {
//TODO: Change Icon
@Override
public DataProcessorDescription declareModel() {
- return
ProcessingElementBuilder.create("org.apache.streampipes.processors.transformation.jvm.duration-value")
+ return ProcessingElementBuilder
+
.create("org.apache.streampipes.processors.transformation.jvm.duration-value",
0)
.category(DataProcessorType.TIME)
.withLocales(Locales.EN)
.withAssets(ExtensionAssetType.DOCUMENTATION, ExtensionAssetType.ICON)
diff --git
a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSinkBuilder.java
b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSinkBuilder.java
index 1480f6c131..05b1f8b8bf 100644
---
a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSinkBuilder.java
+++
b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSinkBuilder.java
@@ -45,36 +45,6 @@ public class DataSinkBuilder extends
AbstractProcessingElementBuilder<DataSinkBu
this.elementDescription.setVersion(version);
}
- /**
- * Creates a new data sink using the builder pattern.
- * @deprecated
- * This method is no longer recommend since we rely on a version for
migration purposes.
- * <p> Please adopt {@link #create(String, int)} instead.
- * @param id A unique identifier of the new element, e.g.,
com.mycompany.sink.mynewdatasink
- * @param label A human-readable name of the element.
- * Will later be shown as the element name in the
StreamPipes UI.
- * @param description A human-readable description of the element.
- */
- @Deprecated(since = "0.93.0", forRemoval = true)
- public static DataSinkBuilder create(String id, String label, String
description) {
- return new DataSinkBuilder(id, label, description, 0);
- }
-
- /**
- * Creates a new data sink using the builder pattern.
- * {@link
org.apache.streampipes.sdk.builder.AbstractProcessingElementBuilder#withLocales(Locales...)}
- * must be called, to provide a label and description.
- * @deprecated
- * This method is no longer recommend since we rely on a version for
migration purposes.
- * <p> Please adopt {@link #create(String, int)} instead.
- *
- * @param id A unique identifier of the new element, e.g.,
com.mycompany.sink.mynewdatasink
- */
- @Deprecated(since = "0.93.0", forRemoval = true)
- public static DataSinkBuilder create(String id) {
- return new DataSinkBuilder(id, 0);
- }
-
/**
* Creates a new data sink using the builder pattern.
* {@link
org.apache.streampipes.sdk.builder.AbstractProcessingElementBuilder#withLocales(Locales...)}
diff --git
a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/ProcessingElementBuilder.java
b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/ProcessingElementBuilder.java
index c244a2cf11..f30bfa5eed 100644
---
a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/ProcessingElementBuilder.java
+++
b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/ProcessingElementBuilder.java
@@ -21,7 +21,6 @@ package org.apache.streampipes.sdk.builder;
import org.apache.streampipes.model.DataProcessorType;
import org.apache.streampipes.model.graph.DataProcessorDescription;
import org.apache.streampipes.model.output.OutputStrategy;
-import org.apache.streampipes.sdk.helpers.Label;
import org.apache.streampipes.sdk.helpers.Locales;
import java.util.ArrayList;
@@ -47,21 +46,6 @@ public class ProcessingElementBuilder
this.elementDescription.setVersion(version);
}
- /**
- * Creates a new processing element using the builder pattern.
- * @deprecated
- * This method is no longer recommend since we rely on a version for
migration purposes.
- * <p> Please adopt {@link #create(String, String, String, int)} instead.
- * @param id A unique identifier of the new element, e.g.,
com.mycompany.processor.mynewdataprocessor
- * @param label A human-readable name of the element.
- * Will later be shown as the element name in the
StreamPipes UI.
- * @param description A human-readable description of the element.
- */
- @Deprecated(since = "0.93.0", forRemoval = true)
- public static ProcessingElementBuilder create(String id, String label,
String description) {
- return new ProcessingElementBuilder(id, label, description, 0);
- }
-
/**
* Creates a new processing element based on a label using the builder
pattern.
* @param id A unique identifier of the new element, e.g.,
com.mycompany.processor.mynewdataprocessor
@@ -76,36 +60,6 @@ public class ProcessingElementBuilder
return new ProcessingElementBuilder(id, label, description, version);
}
- /**
- * Creates a new processing element based on a label using the builder
pattern.
- * @deprecated
- * This method is no longer recommend since we rely on a version for
migration purposes.
- * <p> Please adopt {@link #create(String, String, String, int)} instead.
- */
- @Deprecated(since = "0.93.0", forRemoval = true)
- public static ProcessingElementBuilder create(Label label) {
- return new ProcessingElementBuilder(label.getInternalId(),
label.getLabel(), label.getDescription(), 0);
- }
-
- /**
- * Creates a new processing element using the builder pattern.
- * @deprecated
- * This method is no longer recommend since we rely on a version for
migration purposes.
- * <p> Please adopt {@link #create(String, int)} instead.
- * If no label and description is
- * given
- * for an element,
- * {@link
org.apache.streampipes.sdk.builder.AbstractProcessingElementBuilder#withLocales(Locales...)}
- * must be called.
- *
- * @param id A unique identifier of the new element, e.g.,
com.mycompany.sink.mynewdatasink
- *
- */
- @Deprecated(since = "0.93.0", forRemoval = true)
- public static ProcessingElementBuilder create(String id) {
- return new ProcessingElementBuilder(id, 0);
- }
-
/**
* Creates a new processing element using the builder pattern. If no label
and description is
* given
diff --git
a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilder.java
b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilder.java
index 8fae9b83e2..9d8df25cb0 100644
---
a/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilder.java
+++
b/streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilder.java
@@ -50,20 +50,6 @@ public class AdapterConfigurationBuilder extends
this.supplier = supplier;
}
- /**
- * Creates a new adapter configuration using the builder pattern.
- * @deprecated
- * This method is no longer recommend since we rely on a version for
migration purposes.
- * <p> Please adopt {@link #create(String, int, Supplier)} instead.
- * @param appId A unique identifier of the new adapter, e.g.,
com.mycompany.processor.mynewdataprocessor
- * @param supplier instance of the adapter to be described
- */
- @Deprecated(since = "0.93.0", forRemoval = true)
- public static AdapterConfigurationBuilder create(String appId,
-
Supplier<StreamPipesAdapter> supplier) {
- return new AdapterConfigurationBuilder(appId, 0, supplier);
- }
-
/**
* Creates a new adapter configuration using the builder pattern.
* @param appId A unique identifier of the new adapter, e.g.,
com.mycompany.processor.mynewdataprocessor
diff --git
a/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilderTest.java
b/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilderTest.java
index 6a6e139d9a..db6bd41de6 100644
---
a/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilderTest.java
+++
b/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilderTest.java
@@ -37,12 +37,14 @@ public class AdapterConfigurationBuilderTest {
@Test
public void create() {
var adapterConfiguration = AdapterConfigurationBuilder
- .create(id, null)
+ .create(id, 0, null)
.buildConfiguration();
Assertions.assertNotNull(adapterConfiguration);
- Assertions.assertEquals(id,
-
adapterConfiguration.getAdapterDescription().getAppId()
+ Assertions.assertEquals(
+ id,
+ adapterConfiguration.getAdapterDescription()
+ .getAppId()
);
var expected = new AdapterDescription();
@@ -54,7 +56,7 @@ public class AdapterConfigurationBuilderTest {
public void withOneParser() {
var expected = mock(IParser.class);
var adapterConfiguration = AdapterConfigurationBuilder
- .create(id, null)
+ .create(id, 0, null)
.withSupportedParsers(expected)
.buildConfiguration();
@@ -66,7 +68,7 @@ public class AdapterConfigurationBuilderTest {
var parser1 = mock(IParser.class);
var parser2 = mock(IParser.class);
var adapterConfiguration = AdapterConfigurationBuilder
- .create(id, null)
+ .create(id, 0, null)
.withSupportedParsers(parser1, parser2)
.buildConfiguration();
@@ -78,7 +80,7 @@ public class AdapterConfigurationBuilderTest {
var parser1 = mock(IParser.class);
var parser2 = mock(IParser.class);
var adapterConfiguration = AdapterConfigurationBuilder
- .create(id, null)
+ .create(id, 0, null)
.withSupportedParsers(parser1)
.withSupportedParsers(parser2)
.buildConfiguration();
@@ -89,11 +91,12 @@ public class AdapterConfigurationBuilderTest {
@Test
public void withCategory() {
var adapterConfiguration = AdapterConfigurationBuilder
- .create(id, null)
+ .create(id, 0, null)
.withCategory(AdapterType.Manufacturing)
.buildConfiguration();
- var actual = adapterConfiguration.getAdapterDescription().getCategory();
+ var actual = adapterConfiguration.getAdapterDescription()
+ .getCategory();
Assertions.assertEquals(1, actual.size());
Assertions.assertEquals(AdapterType.Manufacturing.getCode(),
actual.get(0));
diff --git
a/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/extractor/AdapterParameterExtractorTest.java
b/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/extractor/AdapterParameterExtractorTest.java
index bc7605f3cf..b473cb4875 100644
---
a/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/extractor/AdapterParameterExtractorTest.java
+++
b/streampipes-sdk/src/test/java/org/apache/streampipes/sdk/extractor/AdapterParameterExtractorTest.java
@@ -43,20 +43,26 @@ public class AdapterParameterExtractorTest {
when(parserInstance.declareDescription()).thenReturn(parserDescription);
when(parserInstance.fromDescription(any())).thenReturn(parserInstance);
- var adapterConfiguration = AdapterConfigurationBuilder.create("test", null)
- .withSupportedParsers(parserInstance)
- .buildConfiguration();
+ var adapterConfiguration = AdapterConfigurationBuilder.create("test", 0,
null)
+
.withSupportedParsers(parserInstance)
+
.buildConfiguration();
var adapterDescription = adapterConfiguration.getAdapterDescription();
// set the selected boolean for our parser configuration
- ((StaticPropertyAlternatives) (adapterDescription.getConfig().get(0)))
+ (
+ (StaticPropertyAlternatives) (
+ adapterDescription.getConfig()
+ .get(0)
+ )
+ )
.getAlternatives()
.get(0)
.setSelected(true);
var adapterParameterExtractor = AdapterParameterExtractor.from(
adapterConfiguration.getAdapterDescription(),
- List.of(parserInstance));
+ List.of(parserInstance)
+ );
Assertions.assertEquals(parserInstance,
adapterParameterExtractor.selectedParser());
}
