This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch
3095-remove-deprecated-builder-api-and-migrate-to-new-api-with-version
in repository https://gitbox.apache.org/repos/asf/streampipes.git
The following commit(s) were added to
refs/heads/3095-remove-deprecated-builder-api-and-migrate-to-new-api-with-version
by this push:
new 828d1ddda6 refactor(#3095): Remove deprecated processing element API
without version number
828d1ddda6 is described below
commit 828d1ddda61a89ed053c70e58518b5346be993e2
Author: Philipp Zehnder <[email protected]>
AuthorDate: Thu Aug 1 07:29:09 2024 +0200
refactor(#3095): Remove deprecated processing element API without version
number
---
.../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 +-
.../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 -------
60 files changed, 132 insertions(+), 180 deletions(-)
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-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
