This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/org.apache.maven.plugins-maven-archetype-plugin-3.4.1
in repository https://gitbox.apache.org/repos/asf/streampipes.git
discard 147ccc41f5 chore(deps): bump
org.apache.maven.plugins:maven-archetype-plugin
add db174852a7 chore(deps-dev): bump @typescript-eslint/eslint-plugin from
8.32.1 to 8.46.1 in /ui (#3856)
add 97ffb4a572 chore(deps-dev): bump blacken-docs from 1.19.1 to 1.20.0 in
/streampipes-client-python (#3857)
add 045abd5781 chore(deps-dev): bump pre-commit from 3.5.0 to 4.3.0 in
/streampipes-client-python (#3858)
add 55e44c6bff Moved Add Assets for Charts from PopUp during Save to
Button in Edit Mode (#3853)
add 8ca6a08004 fix: Minor various layout issues in the UI (#3867)
add f532080c7f feat: Add translations to the Connect view (#3868)
add 03ee016dc9 Small fixes for the export provider settings and the
retention mechanism (#3870)
add da9c179b7f fix: Modify index of OPC-UA migration v6
add 7e10c042b1 fix: Minor layout improvements in retention dialog (#3872)
add cff6242080 3861 Undefined Roots do not show an error message (#3871)
add 3aa1a453a6 fix(#3632): Allow more general OPC-UA variable nodes (#3877)
add 22b0c888df feat: Add option to manually change language (#3878)
add 1133a5a8ed Migration for missing Export Provider Type "FOLDER" (#3875)
add 8f4df6cc8a chore(deps): bump actions/upload-artifact from 4 to 5
(#3881)
add 5aec1ac0fa refactor: Add additional logging in adapter health check
(#3882)
add 45b68b1233 fix: Button margin and close button in data explorer (#3883)
add f624cdb364 Bug Fix: Pipeline not found always showing in pipeline root
(#3879)
add 6d13945c00 3860 translation in connect (#3873)
add 30272f2819 3862 deleting resource delete asset link (#3874)
add d60417f3dc feat: Enhance Develocity Build Scans (#3869)
add 8893b6852d Small fix for the failing test in PipelineAsset. (#3884)
add dce7d250ab fix(3887): permission objects lost after exporting and re
importing assets with sanitized resource ids (#3888)
add e776239bcc refactor: Use nats as default and clean up of readme (#3886)
add 93d9179782 [maven-release-plugin] prepare branch @{releaseLabel}
add 2a122df84f [maven-release-plugin] prepare for next development
iteration
add ecaa286dbf feat: Add loadbalancer (#3795)
add 7ce00b2233 feat:Add SpRateLimiter and SpMemoryManager (#3796)
add e940e092b0 fix: Access rights for adapter and pipeline endpoints
(#3890)
add 2661dd08f1 fix: Avoid sending events twice in adapter sink (#3892)
add 85c51cde18 fix(#3893): Fix translation bug in data lake configuration
(#3894)
add d866764436 feat: Bump PLC4X version, improve connection cache
management (#3744)
add 23257ffba9 fix(#3893): Fix handle failing plc read (#3899)
add 152862830f fix: Mark old mqtt based adapters as deprecated for future
removal (#3900)
add beae74fbb7 fix: Only admins can see dashboard permissions dialog
(#3901)
add 9c862aaf11 fix: Bump remaining snapshot versions to 0.99 (#3902)
add 349aff2a04 Role Management for Assets in create Tasks (#3897)
add ce6cab09d1 feat: Add more descriptive sidebar (#3891)
add 7a8a54b953 fix: Use relative imports
add 4d36a7259f chore(deps-dev): bump isort from 5.13.2 to 7.0.0 in
/streampipes-client-python (#3864)
add 1e4b5fa734 Fix for failing cypress user tests (#3911)
add c750ddbe72 fix: Reduce duplicated dependencies (#3912)
add c277ce2421 feat(#3904): Resource owners can manage permissions (#3906)
add e45d7c97de Cypress Test Code Structure: Harmonization between Bnt and
Utils (#3915)
add 937aab7f2e fix: Remove flaky count e2e test (#3913)
add 9e41826b50 refactor(#3909): Remove flink wrapper (#3910)
add b5c355d346 refactor(#3907): update docker-compose.yml to use nats
broker (#3908)
add 3d98170b7b chore(deps): bump
org.apache.maven.plugins:maven-archetype-plugin
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (147ccc41f5)
\
N -- N -- N
refs/heads/dependabot/maven/org.apache.maven.plugins-maven-archetype-plugin-3.4.1
(3d98170b7b)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 7 -
.github/workflows/extensions-docs.yml | 6 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/pypi-deployment.yml | 2 +-
.github/workflows/python-docs.yml | 2 +-
.gitignore | 2 +
.../dev/img/favicon.png => .idea/icon.png | Bin
.mvn/develocity.xml | 2 +-
LICENSE | 7 -
.../streampipes-archetype-extensions-jvm/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 2 +-
.../README.md | 38 --
.../pom.xml | 63 ---
.../META-INF/maven/archetype-metadata.xml | 72 ---
.../resources/archetype-resources/development/env | 20 -
.../src/main/resources/archetype-resources/pom.xml | 159 ------
.../archetype-resources/src/main/java/Init.java | 64 ---
.../src/main/java/config/ConfigKeys.java | 33 --
.../__packageName__/__classNamePrefix__.java | 42 --
.../__classNamePrefix__Controller.java | 76 ---
.../__classNamePrefix__Parameters.java | 41 --
.../__classNamePrefix__Program.java | 70 ---
.../documentation.md | 42 --
.../icon.png | Bin 13563 -> 0 bytes
.../strings.en | 5 -
.../streampipes-archetype-pe-sinks-flink/README.md | 38 --
.../streampipes-archetype-pe-sinks-flink/pom.xml | 62 ---
.../META-INF/maven/archetype-metadata.xml | 72 ---
.../main/resources/archetype-resources/Dockerfile | 20 -
.../resources/archetype-resources/development/env | 20 -
.../src/main/resources/archetype-resources/pom.xml | 160 ------
.../archetype-resources/src/main/java/Init.java | 63 ---
.../src/main/java/config/ConfigKeys.java | 32 --
.../__classNamePrefix__Controller.java | 74 ---
.../__classNamePrefix__Program.java | 68 ---
.../documentation.md | 39 --
.../__package__.pe.sink.__packageName__/icon.png | Bin 13563 -> 0 bytes
.../__package__.pe.sink.__packageName__/strings.en | 11 -
docker-compose.yml | 61 ++-
installer/cli/.env | 2 +-
installer/cli/README.md | 2 +-
.../standalone/jobmanager/docker-compose.dev.yml | 20 -
.../standalone/jobmanager/docker-compose.yml | 32 --
.../docker-compose.dev.yml | 21 -
.../pipeline-elements-all-flink/docker-compose.yml | 31 --
.../standalone/taskmanager/docker-compose.dev.yml | 19 -
.../standalone/taskmanager/docker-compose.yml | 37 --
installer/cli/environments/full-monitoring | 1 -
installer/compose/.env | 2 +-
installer/compose/README.md | 50 +-
...r-compose.full.yml => docker-compose.kafka.yml} | 39 +-
installer/compose/docker-compose.nats.yml | 114 ----
installer/compose/docker-compose.pulsar.yml | 109 ----
installer/compose/docker-compose.yml | 45 +-
installer/k8s/Chart.yaml | 2 +-
installer/k8s/README.md | 4 +-
installer/k8s/values.yaml | 2 +-
pom.xml | 40 +-
streampipes-client-api/pom.xml | 8 +-
streampipes-client-python/poetry.lock | 27 +-
streampipes-client-python/pyproject.toml | 6 +-
streampipes-client/pom.xml | 14 +-
streampipes-commons/pom.xml | 2 +-
.../apache/streampipes/commons/constants/Envs.java | 76 ++-
.../commons/environment/DefaultEnvironment.java | 187 ++++++-
.../commons/environment/Environment.java | 102 +++-
.../commons/environment/Environments.java | 1 -
.../variable/BooleanEnvironmentVariable.java | 1 -
...ariable.java => DoubleEnvironmentVariable.java} | 17 +-
...Variable.java => FloatEnvironmentVariable.java} | 17 +-
.../variable/IntEnvironmentVariable.java | 1 -
...tVariable.java => LongEnvironmentVariable.java} | 10 +-
.../variable/StringEnvironmentVariable.java | 1 -
.../commons/exceptions/SpHttpErrorStatusCode.java | 2 +-
.../prometheus/StreamPipesCollectorRegistry.java | 47 +-
.../loadbalancer/LoadBalancerMetrics.java | 50 ++
.../prometheus/loadbalancer/LoadBalancerStats.java | 52 ++
.../prometheus/service/ElementServiceMetrics.java | 58 +--
.../prometheus/service/ElementServiceStats.java | 3 -
.../spmemorymanager/SpMemoryManagerMetrics.java | 30 +-
.../spmemorymanager/SpMemoryManagerStats.java | 66 +++
.../spratelimiter/SpRateLimiterMetrics.java | 50 +-
.../spratelimiter/SpRateLimiterStats.java | 66 +++
streampipes-connect-management/pom.xml | 12 +-
.../management/health/AdapterHealthCheck.java | 184 ++++---
.../management/AdapterMasterManagement.java | 172 +++---
streampipes-connect-shared/pom.xml | 10 +-
streampipes-data-explorer-api/pom.xml | 8 +-
streampipes-data-explorer-export/pom.xml | 8 +-
streampipes-data-explorer-influx/pom.xml | 16 +-
streampipes-data-explorer-iotdb/pom.xml | 16 +-
streampipes-data-explorer-management/pom.xml | 10 +-
streampipes-data-explorer/pom.xml | 10 +-
streampipes-data-export/pom.xml | 12 +-
.../export/dataimport/PerformImportGenerator.java | 12 +-
streampipes-dataformat/pom.xml | 4 +-
streampipes-extensions-api/pom.xml | 27 +-
.../extensions/api/limiter/SpRateLimiter.java | 307 +++++++++++
.../api/memorymanager/SpMemoryManager.java | 331 ++++++++++++
.../api/monitoring/SpMonitoringManager.java | 6 +-
.../api/pe/routing/RawDataProcessor.java | 2 +-
streampipes-extensions-management/pom.xml | 22 +-
.../connect/HttpServerAdapterManagement.java | 2 +-
.../management/connect/PullAdapterScheduler.java | 5 +-
.../elements/SendToBrokerAdapterSink.java | 8 +-
.../monitoring/ServiceLoadDataReportGenerator.java | 102 ++--
streampipes-extensions/pom.xml | 4 +-
.../streampipes-connect-adapters-iiot/pom.xml | 10 +-
.../iiot/adapters/iolink/IfmAlMqttAdapter.java | 1 +
.../connect/iiot/adapters/oi4/Oi4Adapter.java | 6 +
.../streampipes-connect-adapters/pom.xml | 10 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 1 +
.../connect/adapters/netio/NetioRestAdapter.java | 1 +
.../connect/adapters/netio/NetioUtils.java | 1 +
.../streampipes-connectors-influx/pom.xml | 8 +-
.../streampipes-connectors-kafka/pom.xml | 14 +-
.../streampipes-connectors-mqtt/pom.xml | 8 +-
.../streampipes-connectors-nats/pom.xml | 10 +-
.../streampipes-connectors-opcua/pom.xml | 10 +-
.../connectors/opcua/adapter/OpcUaNodeBrowser.java | 15 +-
.../opcua/migration/OpcUaAdapterMigrationV6.java | 3 +-
.../opcua/model/node/BasicVariableNodeInfo.java | 8 +-
.../model/nodename/NamingStrategyResolver.java | 4 +-
.../opcua/model/nodename/ParsedNodeIdResolver.java | 4 +-
.../opcua/model/nodename/SimpleNameResolver.java | 8 +-
.../opcua/utils/OpcUaNamingStrategy.java | 8 +-
.../connectors/opcua/utils/OpcUaTypes.java | 4 +-
.../streampipes-connectors-plc/pom.xml | 14 +-
.../connectors/plc/PlcConnectorsModuleExport.java | 4 +-
.../connection/ContinuousPlcRequestReader.java | 38 +-
.../generic/connection/PlcEventGenerator.java | 7 +-
.../generic/model/Plc4xConnectionExtractor.java | 11 +-
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 2 +-
.../plc/cache/SpCachedPlcConnectionManager.java | 178 +++++++
.../plc/cache/SpConnectionContainer.java | 235 +++++++++
.../plc/cache/SpLeasedPlcConnection.java | 575 +++++++++++++++++++++
.../plc/adapter/ConnectionContainerReproTest.java | 167 ++++++
.../streampipes-connectors-pulsar/pom.xml | 8 +-
.../streampipes-connectors-rocketmq/pom.xml | 8 +-
.../rocketmq/adapter/RocketMQConsumer.java | 10 +-
.../rocketmq/sink/RocketMQPublisherSink.java | 2 +-
.../streampipes-connectors-ros/pom.xml | 10 +-
.../streampipes-connectors-tubemq/pom.xml | 8 +-
.../streampipes-extensions-all-iiot/pom.xml | 50 +-
.../streampipes-extensions-all-jvm/pom.xml | 62 +--
.../streampipes-extensions-iiot-minimal/pom.xml | 40 +-
.../Dockerfile | 20 -
.../development/env | 20 -
.../pom.xml | 122 -----
.../boilerpipe/BoilerpipeDocumentSource.java | 27 -
.../boilerpipe/BoilerpipeExtractor.java | 64 ---
.../kohlschutter/boilerpipe/BoilerpipeFilter.java | 36 --
.../kohlschutter/boilerpipe/BoilerpipeInput.java | 33 --
.../boilerpipe/BoilerpipeProcessingException.java | 41 --
.../boilerpipe/conditions/TextBlockCondition.java | 36 --
.../kohlschutter/boilerpipe/document/Image.java | 108 ----
.../boilerpipe/document/TextBlock.java | 283 ----------
.../boilerpipe/document/TextDocument.java | 133 -----
.../document/TextDocumentStatistics.java | 62 ---
.../boilerpipe/document/package-info.java | 22 -
.../boilerpipe/estimators/SimpleEstimator.java | 61 ---
.../boilerpipe/extractors/ArticleExtractor.java | 64 ---
.../extractors/ArticleSentencesExtractor.java | 45 --
.../boilerpipe/extractors/CanolaExtractor.java | 94 ----
.../boilerpipe/extractors/CommonExtractors.java | 56 --
.../boilerpipe/extractors/DefaultExtractor.java | 47 --
.../boilerpipe/extractors/ExtractorBase.java | 109 ----
.../extractors/KeepEverythingExtractor.java | 39 --
.../KeepEverythingWithMinKWordsExtractor.java | 44 --
.../extractors/LargestContentExtractor.java | 50 --
.../extractors/NumWordsRulesExtractor.java | 43 --
.../boilerpipe/extractors/package-info.java | 22 -
.../boilerpipe/filters/debug/PrintDebugFilter.java | 66 ---
.../filters/english/DensityRulesClassifier.java | 110 ----
.../filters/english/HeuristicFilterBase.java | 38 --
.../english/IgnoreBlocksAfterContentFilter.java | 78 ---
.../IgnoreBlocksAfterContentFromEndFilter.java | 74 ---
.../english/KeepLargestFulltextBlockFilter.java | 81 ---
.../filters/english/MinFulltextWordsFilter.java | 59 ---
.../filters/english/NumWordsRulesClassifier.java | 110 ----
.../filters/english/TerminatingBlocksFinder.java | 109 ----
.../boilerpipe/filters/english/package-info.java | 25 -
.../heuristics/AddPrecedingLabelsFilter.java | 82 ---
.../filters/heuristics/ArticleMetadataFilter.java | 63 ---
.../filters/heuristics/BlockProximityFusion.java | 122 -----
.../filters/heuristics/ContentFusion.java | 72 ---
.../heuristics/DocumentTitleMatchClassifier.java | 170 ------
.../heuristics/ExpandTitleToContentFilter.java | 70 ---
.../filters/heuristics/KeepLargestBlockFilter.java | 117 -----
.../boilerpipe/filters/heuristics/LabelFusion.java | 87 ----
.../LargeBlockSameTagLevelToContentFilter.java | 70 ---
.../filters/heuristics/ListAtEndFilter.java | 57 --
.../heuristics/SimpleBlockFusionProcessor.java | 67 ---
.../TrailingHeadlineToBoilerplateFilter.java | 64 ---
.../filters/heuristics/package-info.java | 22 -
.../filters/simple/BoilerplateBlockFilter.java | 64 ---
.../boilerpipe/filters/simple/InvertedFilter.java | 49 --
.../filters/simple/LabelToBoilerplateFilter.java | 58 ---
.../filters/simple/LabelToContentFilter.java | 54 --
.../simple/MarkEverythingBoilerplateFilter.java | 49 --
.../simple/MarkEverythingContentFilter.java | 48 --
.../filters/simple/MinClauseWordsFilter.java | 108 ----
.../boilerpipe/filters/simple/MinWordsFilter.java | 53 --
.../filters/simple/SplitParagraphBlocksFilter.java | 79 ---
.../filters/simple/SurroundingToContentFilter.java | 77 ---
.../boilerpipe/filters/simple/package-info.java | 23 -
.../boilerpipe/labels/ConditionalLabelAction.java | 40 --
.../boilerpipe/labels/DefaultLabels.java | 46 --
.../boilerpipe/labels/LabelAction.java | 47 --
.../com/kohlschutter/boilerpipe/package-info.java | 22 -
.../sax/BoilerpipeHTMLContentHandler.java | 440 ----------------
.../boilerpipe/sax/BoilerpipeHTMLParser.java | 74 ---
.../boilerpipe/sax/BoilerpipeSAXInput.java | 71 ---
.../boilerpipe/sax/CommonTagActions.java | 343 ------------
.../boilerpipe/sax/DefaultTagActionMap.java | 81 ---
.../kohlschutter/boilerpipe/sax/HTMLDocument.java | 56 --
.../kohlschutter/boilerpipe/sax/HTMLFetcher.java | 91 ----
.../boilerpipe/sax/HTMLHighlighter.java | 504 ------------------
.../boilerpipe/sax/ImageExtractor.java | 278 ----------
.../boilerpipe/sax/InputSourceable.java | 28 -
.../boilerpipe/sax/MarkupTagAction.java | 117 -----
.../com/kohlschutter/boilerpipe/sax/TagAction.java | 38 --
.../kohlschutter/boilerpipe/sax/TagActionMap.java | 59 ---
.../kohlschutter/boilerpipe/sax/package-info.java | 23 -
.../boilerpipe/util/UnicodeTokenizer.java | 40 --
.../kohlschutter/boilerpipe/util/package-info.java | 23 -
.../flink/AbstractFlinkTransformationProgram.java | 29 --
.../pe/flink/AbstractPatternDetectionProgram.java | 39 --
.../pe/flink/AllFlinkPipelineElementsInit.java | 91 ----
.../streampipes/pe/flink/config/ConfigKeys.java | 28 -
.../pe/flink/extensions/MapKeySelector.java | 43 --
.../pe/flink/extensions/SlidingBatchWindow.java | 50 --
.../flink/extensions/SlidingEventTimeWindow.java | 79 ---
.../flink/extensions/TimestampMappingFunction.java | 28 -
.../pe/flink/processor/absence/Absence.java | 21 -
.../flink/processor/absence/AbsenceController.java | 82 ---
.../flink/processor/absence/AbsenceParameters.java | 55 --
.../pe/flink/processor/absence/AbsenceProgram.java | 127 -----
.../flink/processor/aggregation/Aggregation.java | 87 ----
.../aggregation/AggregationController.java | 162 ------
.../aggregation/AggregationParameters.java | 83 ---
.../processor/aggregation/AggregationProgram.java | 87 ----
.../processor/aggregation/AggregationType.java | 26 -
.../processor/aggregation/CountAggregation.java | 55 --
.../processor/aggregation/TimeAggregation.java | 54 --
.../processor/aggregation/config/aggregation.md | 23 -
.../streampipes/pe/flink/processor/and/And.java | 21 -
.../pe/flink/processor/and/AndController.java | 84 ---
.../pe/flink/processor/and/AndParameters.java | 59 ---
.../pe/flink/processor/and/AndProgram.java | 75 ---
.../pe/flink/processor/and/TimeUnit.java | 22 -
.../pe/flink/processor/and/TimeUnitConverter.java | 34 --
.../boilerplate/BoilerplateController.java | 105 ----
.../boilerplate/BoilerplateParameters.java | 49 --
.../processor/boilerplate/BoilerplateProgram.java | 38 --
.../processor/boilerplate/BoilerplateRemover.java | 104 ----
.../flink/processor/boilerplate/ExtractorMode.java | 28 -
.../pe/flink/processor/boilerplate/OutputMode.java | 25 -
.../flink/processor/common/TimestampExtractor.java | 36 --
.../flink/processor/converter/FieldConverter.java | 62 ---
.../converter/FieldConverterController.java | 155 ------
.../converter/FieldConverterParameters.java | 42 --
.../processor/converter/FieldConverterProgram.java | 35 --
.../pe/flink/processor/count/CountController.java | 86 ---
.../pe/flink/processor/count/CountMapper.java | 38 --
.../pe/flink/processor/count/CountParameters.java | 50 --
.../pe/flink/processor/count/CountProgram.java | 51 --
.../pe/flink/processor/count/CountTrigger.java | 46 --
.../flink/processor/count/TimeWindowConverter.java | 35 --
.../pe/flink/processor/count/Tuple2MapMapper.java | 39 --
.../processor/eventcount/EventCountController.java | 77 ---
.../processor/eventcount/EventCountMapper.java | 29 --
.../eventcount/EventCountOutputMapper.java | 39 --
.../processor/eventcount/EventCountParameters.java | 42 --
.../processor/eventcount/EventCountProgram.java | 41 --
.../flink/processor/gridenricher/CellOption.java | 128 -----
.../processor/gridenricher/EnrichmentSettings.java | 84 ---
.../gridenricher/SpatialGridCalculator.java | 64 ---
.../gridenricher/SpatialGridConstants.java | 31 --
.../gridenricher/SpatialGridEnricher.java | 61 ---
.../SpatialGridEnrichmentController.java | 102 ----
.../SpatialGridEnrichmentParameters.java | 36 --
.../gridenricher/SpatialGridEnrichmentProgram.java | 36 --
.../MeasurementUnitConverter.java | 58 ---
.../MeasurementUnitConverterController.java | 128 -----
.../MeasurementUnitConverterParameters.java | 52 --
.../MeasurementUnitConverterProgram.java | 40 --
.../processor/peak/PeakDetectionCalculator.java | 135 -----
.../processor/peak/PeakDetectionController.java | 90 ----
.../processor/peak/PeakDetectionParameters.java | 84 ---
.../flink/processor/peak/PeakDetectionProgram.java | 73 ---
.../processor/peak/utils/SlidingBatchWindow.java | 53 --
.../pe/flink/processor/rate/EventRate.java | 40 --
.../flink/processor/rate/EventRateController.java | 67 ---
.../flink/processor/rate/EventRateParameter.java | 37 --
.../pe/flink/processor/rate/EventRateProgram.java | 49 --
.../pe/flink/processor/rename/FieldRenamer.java | 48 --
.../processor/rename/FieldRenamerController.java | 68 ---
.../processor/rename/FieldRenamerParameters.java | 52 --
.../processor/rename/FieldRenamerProgram.java | 38 --
.../pe/flink/processor/sequence/EventStorage.java | 41 --
.../pe/flink/processor/sequence/Sequence.java | 86 ---
.../processor/sequence/SequenceController.java | 67 ---
.../processor/sequence/SequenceParameters.java | 42 --
.../flink/processor/sequence/SequenceProgram.java | 46 --
.../stat/summary/StatisticsSummaryCalculator.java | 64 ---
.../stat/summary/StatisticsSummaryController.java | 107 ----
.../stat/summary/StatisticsSummaryParameters.java | 38 --
.../stat/summary/StatisticsSummaryProgram.java | 36 --
.../window/StatisticsSummaryCalculatorWindow.java | 69 ---
.../window/StatisticsSummaryControllerWindow.java | 117 -----
.../window/StatisticsSummaryParametersWindow.java | 69 ---
.../StatisticsSummaryParamsSerializable.java | 62 ---
.../window/StatisticsSummaryProgramWindow.java | 67 ---
.../processor/timestamp/TimestampController.java | 66 ---
.../processor/timestamp/TimestampEnricher.java | 42 --
.../processor/timestamp/TimestampParameters.java | 38 --
.../processor/timestamp/TimestampProgram.java | 37 --
.../urldereferencing/UrlDereferencing.java | 57 --
.../UrlDereferencingController.java | 71 ---
.../UrlDereferencingParameter.java | 42 --
.../urldereferencing/UrlDereferencingProgram.java | 38 --
.../pe/flink/processor/wordcount/Word.java | 54 --
.../processor/wordcount/WordCountController.java | 76 ---
.../processor/wordcount/WordCountParameters.java | 42 --
.../processor/wordcount/WordCountProgram.java | 45 --
.../pe/flink/processor/wordcount/WordSplitter.java | 44 --
.../processor/wordcount/WordToEventConverter.java | 34 --
.../elasticsearch/ElasticSearchController.java | 72 ---
.../elasticsearch/ElasticSearchParameters.java | 58 ---
.../sink/elasticsearch/ElasticSearchProgram.java | 81 ---
.../ElasticsearchIndexRequestBuilder.java | 55 --
.../elastic/ActionRequestFailureHandler.java | 42 --
.../elastic/BulkProcessorIndexer.java | 55 --
.../elastic/Elasticsearch6ApiCallBridge.java | 116 -----
.../elastic/ElasticsearchApiCallBridge.java | 97 ----
.../elasticsearch/elastic/ElasticsearchSink.java | 93 ----
.../elastic/ElasticsearchSinkBase.java | 456 ----------------
.../elastic/ElasticsearchSinkFunction.java | 40 --
.../elasticsearch/elastic/NoOpFailureHandler.java | 39 --
.../sink/elasticsearch/elastic/RequestIndexer.java | 37 --
.../documentation.md | 45 --
.../icon.png | Bin 9425 -> 0 bytes
.../strings.en | 32 --
.../documentation.md | 55 --
.../icon.png | Bin 1854 -> 0 bytes
.../strings.en | 53 --
.../documentation.md | 60 ---
.../icon.png | Bin 4738 -> 0 bytes
.../strings.en | 29 --
.../documentation.md | 50 --
.../strings.en | 26 -
.../documentation.md | 48 --
.../icon.png | Bin 6197 -> 0 bytes
.../strings.en | 23 -
.../documentation.md | 45 --
.../icon.png | Bin 7429 -> 0 bytes
.../strings.en | 23 -
.../documentation.md | 42 --
.../icon.png | Bin 19386 -> 0 bytes
.../strings.en | 20 -
.../documentation.md | 47 --
.../strings.en | 25 -
.../documentation.md | 47 --
.../icon.png | Bin 2516 -> 0 bytes
.../strings.en | 31 --
.../documentation.md | 47 --
.../icon.png | Bin 20685 -> 0 bytes
.../strings.en | 40 --
.../documentation.md | 47 --
.../icon.png | Bin 710 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 49 --
.../icon.png | Bin 23118 -> 0 bytes
.../strings.en | 35 --
.../documentation.md | 37 --
.../icon.png | Bin 4378 -> 0 bytes
.../strings.en | 22 -
.../documentation.md | 47 --
.../icon.png | Bin 15515 -> 0 bytes
.../strings.en | 27 -
.../documentation.md | 48 --
.../icon.png | Bin 11482 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 63 ---
.../icon.png | Bin 11398 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 62 ---
.../icon.png | Bin 14453 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 48 --
.../icon.png | Bin 19799 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 47 --
.../icon.png | Bin 10904 -> 0 bytes
.../strings.en | 25 -
.../documentation.md | 43 --
.../icon.png | Bin 12949 -> 0 bytes
.../strings.en | 28 -
.../documentation.md | 54 --
.../icon.png | Bin 20411 -> 0 bytes
.../strings.en | 25 -
.../streampipes-pipeline-elements-shared/pom.xml | 4 +-
.../pom.xml | 6 +-
.../streampipes-processors-enricher-jvm/pom.xml | 10 +-
.../streampipes-processors-filters-jvm/pom.xml | 8 +-
.../streampipes-processors-filters-siddhi/pom.xml | 8 +-
.../streampipes-processors-geo-jvm/pom.xml | 6 +-
.../pom.xml | 6 +-
.../streampipes-processors-llm-jvm/pom.xml | 8 +-
.../streampipes-processors-text-mining-jvm/pom.xml | 6 +-
.../pom.xml | 10 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 10 +-
.../streampipes-sinks-databases-jvm/pom.xml | 6 +-
.../streampipes-sinks-internal-jvm/pom.xml | 12 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 23 +-
.../streampipes-sinks-notifications-jvm/pom.xml | 8 +-
streampipes-integration-tests/pom.xml | 22 +-
.../pom.xml | 48 +-
.../loadbalance/ExtensionServiceSelector.java | 61 +++
.../streampipes/loadbalance/LoadBalancer.java | 26 +-
.../loadbalance/LoadBalancerConfig.java | 75 +++
.../streampipes/loadbalance/LoadManager.java | 240 +++++++++
.../streampipes/loadbalance/PipelineMigrator.java | 18 +-
.../loadbalance/ResourceUnitMigration.java | 330 ++++++++++++
.../loadbalance/ServiceLoadCalculator.java | 135 +++++
.../loadbalance/impl/AbstractPipelineMigrator.java | 208 ++++++++
.../loadbalance/impl/ExtensibleLoadManager.java | 60 +++
.../loadbalance/impl/MinimumLoadSelector.java | 124 +++++
.../loadbalance/impl/OverloadMigrator.java | 93 ++++
.../loadbalance/impl/ThresholdMigrator.java | 138 +++++
.../loadbalance/impl/TransferMigrator.java | 145 ++++++
.../loadbalance/impl/WeightedFirstSelector.java | 172 ++++++
.../loadbalance/impl/WeightedRandomSelector.java | 155 ++++++
.../pipeline/ExtensionsLogProvider.java | 28 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 60 +--
.../service}/ExtensionServiceExecutions.java | 33 +-
.../service/ExtensionsServiceReportExecutor.java | 89 ++++
.../unit}/ExtensionsServiceEndpointUtils.java | 2 +-
.../loadbalance/unit/InvokeHttpRequest.java | 131 +++++
.../unit/PipelineElementPartitioner.java | 458 ++++++++++++++++
.../loadbalance/unit/ResourceUnitScanner.java | 370 +++++++++++++
.../loadbalance/unit/ResourceUnitStatsScanner.java | 345 +++++++++++++
streampipes-mail/pom.xml | 4 +-
streampipes-maven-plugin/pom.xml | 4 +-
.../src/main/resources/docker-compose.yml | 25 -
streampipes-measurement-units/pom.xml | 4 +-
streampipes-messaging-jms/pom.xml | 4 +-
.../messaging/jms/ActiveMQConsumer.java | 10 +-
streampipes-messaging-kafka/pom.xml | 6 +-
.../messaging/kafka/SpKafkaConsumer.java | 9 +-
streampipes-messaging-mqtt/pom.xml | 4 +-
streampipes-messaging-nats/pom.xml | 4 +-
streampipes-messaging-pulsar/pom.xml | 4 +-
.../messaging/pulsar/PulsarConsumer.java | 10 +-
streampipes-messaging/pom.xml | 4 +-
.../messaging/InternalEventProcessor.java | 2 +-
streampipes-model-client/pom.xml | 6 +-
.../streampipes/model/client/user/UserAccount.java | 9 +
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 8 +-
.../apache/streampipes/model/ShortUserInfo.java | 17 +-
.../org/apache/streampipes/model/UserInfo.java | 9 +
.../model/connect/adapter/AdapterDescription.java | 1 +
.../model/datalake/DataLakeMeasure.java | 8 +
.../svcdiscovery/SpServiceRegistration.java | 17 +
.../svcdiscovery/SpServiceTagPrefix.java | 5 +
.../loadbalancer/LoadBalanceResourceUnit.java | 120 +++++
.../loadbalancer/LoadBalanceResourceUnitStats.java | 154 ++++++
.../model/loadbalancer/ServiceLoadDataReport.java | 249 +++++++--
.../model/monitoring/MessageCounter.java | 9 +
.../model/monitoring/SpMetricsEntry.java | 5 +-
.../streampipes/model/pipeline/Pipeline.java | 20 +
streampipes-pipeline-management/pom.xml | 36 +-
.../ExtensionsServiceEndpointGenerator.java | 100 ++--
.../execution/task/DiscoverEndpointsTask.java | 32 +-
.../manager/health/PipelineHealthCheck.java | 81 ++-
.../manager/health/ServiceHealthCheck.java | 55 +-
.../manager/health/ServiceRegistrationManager.java | 28 +-
.../manager/pipeline/PipelineManager.java | 35 +-
streampipes-resource-management/pom.xml | 8 +-
.../DataExplorerWidgetResourceManager.java | 2 +-
streampipes-rest-core-base/pom.xml | 10 +-
streampipes-rest-extensions/pom.xml | 8 +-
streampipes-rest-shared/pom.xml | 6 +-
streampipes-rest/pom.xml | 31 +-
.../rest/impl/AbstractMonitoringResource.java | 2 +-
.../rest/impl/AdapterMonitoringResource.java | 66 ++-
.../rest/impl/AssetManagementResource.java | 14 +-
.../streampipes/rest/impl/FunctionsResource.java | 2 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 8 +-
.../streampipes/rest/impl/PipelineResource.java | 10 +-
.../apache/streampipes/rest/impl/UserResource.java | 32 +-
.../rest/impl/admin/PermissionResource.java | 36 +-
.../impl/admin/ServiceRegistrationResource.java | 8 +-
.../rest/impl/admin/UserGroupResource.java | 1 -
.../rest/impl/connect/AdapterResource.java | 214 ++++----
.../rest/impl/connect/CompactAdapterResource.java | 2 +-
.../rest/impl/datalake/DataLakeWidgetResource.java | 2 +-
streampipes-sdk-bundle/pom.xml | 18 +-
streampipes-sdk/pom.xml | 10 +-
.../adapter/AdapterConfigurationBuilder.java | 4 +
streampipes-security-jwt/pom.xml | 4 +-
streampipes-serializers-json/pom.xml | 8 +-
streampipes-service-base/pom.xml | 6 +-
streampipes-service-core-minimal/pom.xml | 6 +-
streampipes-service-core/pom.xml | 28 +-
.../service/core/StreamPipesCoreApplication.java | 117 ++---
.../core/migrations/AvailableMigrations.java | 6 +-
.../AddDefaultExportProviderMigration.java} | 34 +-
.../v0980/FixImportedPermissionsMigration.java | 116 +++++
.../service/core/scheduler/DataLakeScheduler.java | 6 +-
streampipes-service-discovery-api/pom.xml | 4 +-
.../svcdiscovery/api/ISpServiceDiscovery.java | 9 +
streampipes-service-discovery/pom.xml | 8 +-
.../svcdiscovery/SpServiceDiscoveryCore.java | 16 +
streampipes-service-extensions/pom.xml | 6 +-
.../StreamPipesExtensionsServiceBase.java | 2 +
streampipes-storage-api/pom.xml | 8 +-
.../streampipes/storage/api/CRUDStorage.java | 1 +
.../streampipes/storage/api/IGenericStorage.java | 2 +
.../streampipes/storage/api/IPipelineStorage.java | 1 -
streampipes-storage-couchdb/pom.xml | 10 +-
.../storage/couchdb/impl/DefaultCrudStorage.java | 13 +-
.../storage/couchdb/impl/GenericStorageImpl.java | 39 ++
.../impl/PipelineCanvasMetadataStorageImpl.java | 2 +-
.../storage/couchdb/impl/PipelineStorageImpl.java | 12 +-
streampipes-storage-management/pom.xml | 6 +-
streampipes-test-utils-executors/pom.xml | 6 +-
streampipes-test-utils/pom.xml | 8 +-
streampipes-user-management/pom.xml | 8 +-
.../user/management/util/UserInfoUtil.java | 1 +
streampipes-vocabulary/pom.xml | 2 +-
streampipes-wrapper-distributed/pom.xml | 6 +-
streampipes-wrapper-flink/pom.xml | 160 ------
.../flink/FlinkDataProcessorCompatProgram.java | 76 ---
.../wrapper/flink/FlinkDataProcessorDeclarer.java | 66 ---
.../wrapper/flink/FlinkDataProcessorProgram.java | 30 --
.../wrapper/flink/FlinkDataProcessorRuntime.java | 116 -----
.../wrapper/flink/FlinkDataSinkCompatProgram.java | 38 --
.../wrapper/flink/FlinkDataSinkDeclarer.java | 62 ---
.../wrapper/flink/FlinkDataSinkProgram.java | 30 --
.../wrapper/flink/FlinkDataSinkRuntime.java | 74 ---
.../wrapper/flink/FlinkDeploymentConfig.java | 65 ---
.../flink/FlinkMiniClusterDeploymentConfig.java | 26 -
.../streampipes/wrapper/flink/FlinkRuntime.java | 355 -------------
.../wrapper/flink/FlinkRuntimeProvider.java | 37 --
.../wrapper/flink/FlinkSpMiniCluster.java | 57 --
.../wrapper/flink/IDataProcessorProgram.java | 28 -
.../wrapper/flink/IDataSinkProgram.java | 28 -
.../streampipes/wrapper/flink/IFlinkProgram.java | 39 --
.../wrapper/flink/consumer/JmsFlinkConsumer.java | 73 ---
.../wrapper/flink/consumer/MqttFlinkConsumer.java | 73 ---
.../flink/converter/EventToMapConverter.java | 34 --
.../flink/converter/MapToEventConverter.java | 51 --
.../wrapper/flink/logger/StatisticLogger.java | 41 --
.../flink/serializer/ByteArrayDeserializer.java | 45 --
.../flink/serializer/ByteArraySerializer.java | 44 --
.../flink/serializer/SimpleJmsSerializer.java | 45 --
.../flink/serializer/SimpleKafkaSerializer.java | 38 --
.../wrapper/flink/sink/JmsFlinkProducer.java | 66 ---
.../wrapper/flink/sink/MqttFlinkProducer.java | 66 ---
streampipes-wrapper-kafka-streams/pom.xml | 6 +-
streampipes-wrapper-siddhi/pom.xml | 4 +-
streampipes-wrapper-standalone/pom.xml | 6 +-
.../standalone/function/StreamPipesFunction.java | 9 +-
.../routing/StandaloneSpInputCollector.java | 9 +-
.../routing/StandaloneSpOutputCollector.java | 5 +-
.../runtime/StandaloneEventProcessorRuntime.java | 13 +-
.../runtime/StandaloneEventSinkRuntime.java | 13 +-
streampipes-wrapper/pom.xml | 14 +-
.../filters-siddhi/count1/description.json | 26 -
.../filters-siddhi/count1/expected.csv | 4 -
.../filters-siddhi/count1/input.csv | 4 -
ui/cypress/support/utils/UserUtils.ts | 27 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 44 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 50 +-
.../support/utils/dataExplorer/DataExplorerBtns.ts | 120 ++++-
.../utils/dataExplorer/DataExplorerUtils.ts | 94 ++--
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 69 +++
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 41 +-
ui/cypress/support/utils/user/UserBtns.ts | 61 +++
ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 4 +-
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 21 +-
.../editAdapterTransformationRulesAreKept.spec.ts | 20 +-
.../connect/editAdapterValuesAndFields.spec.ts | 12 +-
.../dataExplorer/addAssetsToDataView.smoke.spec.ts | 14 +-
.../tests/dataExplorer/configuration.smoke.spec.ts | 20 +-
.../tests/dataExplorer/dataViewAssets.spec.ts | 60 ---
.../tests/dataExplorer/timeOrderDataView.spec.ts | 4 +-
ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 2 +-
.../tests/pipeline/renamePipelineTest.spec.ts | 5 +-
.../pipeline/updatePipelineTest.smoke.spec.ts | 3 +-
.../PipelineElementDocumentation.spec.ts | 5 +-
.../connectConfigurationTemplate.spec.ts | 3 +-
.../userManagement/testGroupManagement.spec.ts | 11 +-
.../tests/userManagement/testUserRoleAsset.spec.ts | 139 +++++
ui/deployment/base-navigation.component.mst | 70 ++-
.../Dockerfile => ui/deployment/categories.yml | 17 +-
ui/deployment/home.service.mst | 2 +-
ui/deployment/i18n/de.json | 174 +++++--
ui/deployment/i18n/en.json | 159 +++++-
ui/deployment/modules.yml | 35 +-
ui/deployment/prebuild.js | 15 +-
ui/deployment/theme/_custom-variables.scss | 22 +-
ui/develocity.config.js | 95 +++-
ui/package-lock.json | 152 ++++--
ui/package.json | 4 +-
.../platform-services/src/lib/apis/user.service.ts | 9 +-
.../src/lib/model/gen/streampipes-model-client.ts | 7 +-
.../src/lib/model/gen/streampipes-model.ts | 17 +-
.../src/lib/model/types/data-type.ts | 11 +
...sset-browser-filter-asset-model.component.html} | 14 +-
.../asset-browser-filter-asset-model.component.ts} | 22 +-
.../asset-browser-filter-labels.component.html | 81 +--
.../asset-browser-filter-labels.component.ts | 8 +
.../asset-browser-filter.component.html | 5 +
.../asset-browser-filter.component.ts | 7 +-
.../asset-browser-toolbar.component.html | 64 ++-
.../asset-browser-toolbar.component.scss} | 25 +-
.../asset-browser-toolbar.component.ts | 54 +-
.../asset-browser/asset-browser.model.ts | 11 +
.../asset-browser/asset-browser.service.ts | 156 ++++--
.../basic-inner-panel.component.html | 1 +
.../basic-inner-panel.component.scss | 18 +-
.../basic-inner-panel.component.ts | 3 +
.../basic-nav-tabs/basic-nav-tabs.component.html | 15 +-
.../basic-nav-tabs/basic-nav-tabs.component.scss | 10 +-
.../basic-view/basic-view.component.html | 6 +-
.../basic-view/basic-view.component.scss | 8 +-
.../split-section/split-section.component.html | 2 +-
.../split-section/split-section.component.scss | 2 +-
.../object-permission-dialog.component.html | 73 ++-
.../object-permission-dialog.component.scss | 0
.../object-permission-dialog.component.ts | 117 +++--
.../shared-ui/src/lib/shared-ui.module.ts | 16 +-
.../streampipes/shared-ui/src/public-api.ts | 2 +
.../asset-overview/asset-overview.component.html | 2 +-
.../datalake-configuration.component.html | 7 +-
.../datalake-configuration.component.ts | 40 +-
.../select-export/select-format.component.ts | 2 +-
.../select-data-retention.component.html | 2 +-
.../data-retention-dialog.component.html | 2 +-
.../data-retention-dialog.component.ts | 14 +-
.../delete-export-provider-dialog.component.ts | 2 +-
.../export-provider-dialog.component.html | 47 +-
.../export-provider-dialog.component.ts | 8 +-
.../endpoint-item/endpoint-item.component.ts | 7 +-
.../security-user-config.component.html | 2 +-
.../adapter-configuration.component.html | 22 +-
.../adapter-configuration.component.ts | 6 +
.../adapter-deployment-settings.component.html | 6 +-
.../adapter-settings.component.html | 10 +-
.../error-message/error-message.component.html | 6 +-
.../event-property-row.component.html | 18 +-
.../event-schema-preview.component.html | 9 +-
.../event-schema/event-schema.component.html | 6 +-
.../schema-editor-header.component.html | 4 +-
.../start-adapter-configuration.component.html | 118 +++--
.../start-adapter-configuration.component.ts | 27 +-
.../abstract-adapter-details.directive.ts | 22 +-
.../adapter-details-code.component.html | 26 +-
.../adapter-details-data.component.html | 55 +-
.../adapter-details-logs.component.html | 24 +-
.../adapter-details-metrics.component.html | 28 +-
.../adapter-description.component.html | 8 +-
.../data-marketplace.component.html | 4 +-
.../existing-adapters.component.html | 560 +++++++++-----------
.../existing-adapters.component.ts | 79 +--
.../filter-toolbar/filter-toolbar.component.html | 19 +-
.../filter-toolbar/filter-toolbar.component.ts | 4 -
.../adapter-started-dialog.component.html | 2 +-
.../adapter-started-dialog.component.ts | 42 +-
...adapter-started-update-migration.component.html | 38 +-
.../delete-adapter-dialog.component.html | 52 +-
.../all-adapter-actions-dialog.component.html | 39 +-
.../all-adapter-actions-dialog.component.ts | 14 +-
ui/src/app/core-ui/core-ui.module.ts | 2 -
.../app/core/collapse.service.ts} | 30 +-
ui/src/app/core/components/bars.scss | 34 --
.../breadcrumb/breadcrumb.component.scss | 5 +-
.../components/breadcrumb/breadcrumb.component.ts | 28 +-
.../core/components/iconbar/iconbar.component.html | 151 ++++--
.../core/components/iconbar/iconbar.component.scss | 251 +++++++++
.../core/components/iconbar/iconbar.component.ts | 2 +-
.../streampipes/streampipes.component.html | 24 +-
.../streampipes/streampipes.component.scss | 57 +-
.../streampipes/streampipes.component.ts | 31 +-
.../core/components/toolbar/toolbar.component.html | 47 +-
.../core/components/toolbar/toolbar.component.scss | 17 +-
.../core/components/toolbar/toolbar.component.ts | 5 +-
ui/src/app/core/core.module.ts | 2 +
ui/src/app/core/navigation.backup | 220 ++++++++
.../dashboard-overview-table.component.html | 6 +-
.../dashboard-overview-table.component.ts | 53 +-
.../overview/dashboard-overview.component.html | 59 +--
.../overview/dashboard-overview.component.ts | 21 +-
.../panel/dashboard-panel.component.html | 177 ++++---
.../components/panel/dashboard-panel.component.ts | 12 +-
.../edit-dashboard-dialog.component.html | 69 +--
.../edit-dashboard-dialog.component.ts | 15 +-
.../data-explorer-chart-container.component.html | 27 +-
.../services/data-explorer-shared.service.ts | 2 +-
.../data-explorer-chart-view.component.html | 95 ++--
.../data-explorer-chart-view.component.ts | 146 ++++--
...data-explorer-chart-view-toolbar.component.html | 13 +
.../data-explorer-chart-view-toolbar.component.ts | 29 +-
.../data-explorer-overview-table.component.html | 6 +-
.../data-explorer-overview-table.component.ts | 49 +-
.../overview/data-explorer-overview.component.html | 59 +--
.../overview/data-explorer-overview.component.ts | 28 +-
.../overview/data-explorer-overview.directive.ts | 59 ---
.../dialog/asset-dialog.component.html | 100 ++--
.../data-explorer/dialog/asset-dialog.component.ts | 76 +--
.../save-pipeline-settings.component.html | 38 +-
.../save-pipeline-settings.component.ts | 14 +
.../save-pipeline/save-pipeline.component.html | 9 +-
ui/src/app/editor/editor.component.ts | 10 +-
.../components/auth-box/auth-box.component.html | 4 +-
.../components/auth-box/auth-box.component.scss | 4 +-
.../login/components/login/login.component.html | 36 +-
.../components/register/register.component.html | 22 +-
.../restore-password.component.html | 26 +-
.../login/components/terms/terms.component.html | 4 +-
ui/src/app/login/login.module.ts | 2 +
.../pipeline-details.component.html | 6 +
.../pipeline-details/pipeline-details.component.ts | 35 +-
.../pipeline-overview.component.html | 68 +--
.../pipeline-overview.component.ts | 4 -
ui/src/app/pipelines/pipelines.component.html | 177 +++----
ui/src/app/pipelines/pipelines.component.ts | 69 +--
.../services/pipeline-operations.service.ts | 17 +-
.../profile/components/basic-profile-settings.ts | 12 +-
.../general-profile-settings.component.html | 43 +-
.../general/general-profile-settings.component.ts | 7 +
.../token/token-management-settings.component.html | 47 +-
ui/src/app/profile/profile.component.html | 8 +-
ui/src/app/profile/profile.module.ts | 4 +
ui/src/scss/sp/_variables.scss | 2 +
ui/src/scss/sp/buttons-mat3.scss | 14 +-
ui/src/scss/sp/layout.scss | 2 -
ui/src/scss/sp/main.scss | 11 -
742 files changed, 12325 insertions(+), 23149 deletions(-)
copy ui/deployment/dev/img/favicon.png => .idea/icon.png (100%)
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/README.md
delete mode 100644 archetypes/streampipes-archetype-pe-processors-flink/pom.xml
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/META-INF/maven/archetype-metadata.xml
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/development/env
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/pom.xml
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/Init.java
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/config/ConfigKeys.java
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__.java
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Controller.java
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Parameters.java
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/java/pe/processor/__packageName__/__classNamePrefix__Program.java
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.processor.__packageName__/documentation.md
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.processor.__packageName__/icon.png
delete mode 100644
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.processor.__packageName__/strings.en
delete mode 100644 archetypes/streampipes-archetype-pe-sinks-flink/README.md
delete mode 100644 archetypes/streampipes-archetype-pe-sinks-flink/pom.xml
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/META-INF/maven/archetype-metadata.xml
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/Dockerfile
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/development/env
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/pom.xml
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/Init.java
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/config/ConfigKeys.java
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Controller.java
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Program.java
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.sink.__packageName__/documentation.md
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.sink.__packageName__/icon.png
delete mode 100644
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/resources/__package__.pe.sink.__packageName__/strings.en
delete mode 100644
installer/cli/deploy/standalone/jobmanager/docker-compose.dev.yml
delete mode 100644
installer/cli/deploy/standalone/jobmanager/docker-compose.yml
delete mode 100644
installer/cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.dev.yml
delete mode 100644
installer/cli/deploy/standalone/pipeline-elements-all-flink/docker-compose.yml
delete mode 100644
installer/cli/deploy/standalone/taskmanager/docker-compose.dev.yml
delete mode 100644
installer/cli/deploy/standalone/taskmanager/docker-compose.yml
rename installer/compose/{docker-compose.full.yml => docker-compose.kafka.yml}
(83%)
delete mode 100644 installer/compose/docker-compose.nats.yml
delete mode 100644 installer/compose/docker-compose.pulsar.yml
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/{StringEnvironmentVariable.java
=> DoubleEnvironmentVariable.java} (71%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/{StringEnvironmentVariable.java
=> FloatEnvironmentVariable.java} (71%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/{StringEnvironmentVariable.java
=> LongEnvironmentVariable.java} (79%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/loadbalancer/LoadBalancerMetrics.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/loadbalancer/LoadBalancerStats.java
copy
streampipes-service-base/src/main/java/org/apache/streampipes/service/base/StreamPipesPrometheusConfig.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spmemorymanager/SpMemoryManagerMetrics.java
(54%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spmemorymanager/SpMemoryManagerStats.java
rename
archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/pe/sink/__packageName__/__classNamePrefix__Parameters.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spratelimiter/SpRateLimiterMetrics.java
(52%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/prometheus/spratelimiter/SpRateLimiterStats.java
create mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/limiter/SpRateLimiter.java
create mode 100644
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/memorymanager/SpMemoryManager.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache/SpCachedPlcConnectionManager.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache/SpConnectionContainer.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/cache/SpLeasedPlcConnection.java
create mode 100644
streampipes-extensions/streampipes-connectors-plc/src/test/java/org/apache/streampipes/extensions/connectors/plc/adapter/ConnectionContainerReproTest.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/Dockerfile
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/development/env
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/pom.xml
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/BoilerpipeDocumentSource.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/BoilerpipeExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/BoilerpipeFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/BoilerpipeInput.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/BoilerpipeProcessingException.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/conditions/TextBlockCondition.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/document/Image.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/document/TextBlock.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/document/TextDocument.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/document/TextDocumentStatistics.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/document/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/estimators/SimpleEstimator.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/ArticleExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/ArticleSentencesExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/CanolaExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/CommonExtractors.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/DefaultExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/ExtractorBase.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/KeepEverythingExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/KeepEverythingWithMinKWordsExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/LargestContentExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/NumWordsRulesExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/extractors/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/debug/PrintDebugFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/DensityRulesClassifier.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/HeuristicFilterBase.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/IgnoreBlocksAfterContentFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/IgnoreBlocksAfterContentFromEndFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/KeepLargestFulltextBlockFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/MinFulltextWordsFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/NumWordsRulesClassifier.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/TerminatingBlocksFinder.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/english/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/AddPrecedingLabelsFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/ArticleMetadataFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/BlockProximityFusion.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/ContentFusion.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/DocumentTitleMatchClassifier.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/ExpandTitleToContentFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/KeepLargestBlockFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/LabelFusion.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/LargeBlockSameTagLevelToContentFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/ListAtEndFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/SimpleBlockFusionProcessor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/TrailingHeadlineToBoilerplateFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/heuristics/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/BoilerplateBlockFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/InvertedFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/LabelToBoilerplateFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/LabelToContentFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/MarkEverythingBoilerplateFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/MarkEverythingContentFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/MinClauseWordsFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/MinWordsFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/SplitParagraphBlocksFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/SurroundingToContentFilter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/filters/simple/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/labels/ConditionalLabelAction.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/labels/DefaultLabels.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/labels/LabelAction.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/BoilerpipeHTMLContentHandler.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/BoilerpipeHTMLParser.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/BoilerpipeSAXInput.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/CommonTagActions.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/DefaultTagActionMap.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/HTMLDocument.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/HTMLFetcher.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/HTMLHighlighter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/ImageExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/InputSourceable.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/MarkupTagAction.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/TagAction.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/TagActionMap.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/sax/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/util/UnicodeTokenizer.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/com/kohlschutter/boilerpipe/util/package-info.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AbstractFlinkTransformationProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AbstractPatternDetectionProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/AllFlinkPipelineElementsInit.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/config/ConfigKeys.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/extensions/MapKeySelector.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/extensions/SlidingBatchWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/extensions/SlidingEventTimeWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/extensions/TimestampMappingFunction.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/absence/Absence.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/absence/AbsenceController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/absence/AbsenceParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/absence/AbsenceProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/Aggregation.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/AggregationController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/AggregationParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/AggregationProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/AggregationType.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/CountAggregation.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/TimeAggregation.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/aggregation/config/aggregation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/and/And.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/and/AndController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/and/AndParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/and/AndProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/and/TimeUnit.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/and/TimeUnitConverter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/boilerplate/BoilerplateController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/boilerplate/BoilerplateParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/boilerplate/BoilerplateProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/boilerplate/BoilerplateRemover.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/boilerplate/ExtractorMode.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/boilerplate/OutputMode.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/common/TimestampExtractor.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/converter/FieldConverter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/converter/FieldConverterController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/converter/FieldConverterParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/converter/FieldConverterProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/CountController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/CountMapper.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/CountParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/CountProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/CountTrigger.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/TimeWindowConverter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/count/Tuple2MapMapper.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/eventcount/EventCountController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/eventcount/EventCountMapper.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/eventcount/EventCountOutputMapper.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/eventcount/EventCountParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/eventcount/EventCountProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/CellOption.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/EnrichmentSettings.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/SpatialGridCalculator.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/SpatialGridConstants.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/SpatialGridEnricher.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/SpatialGridEnrichmentController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/SpatialGridEnrichmentParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/gridenricher/SpatialGridEnrichmentProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/measurementunitonverter/MeasurementUnitConverter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/measurementunitonverter/MeasurementUnitConverterController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/measurementunitonverter/MeasurementUnitConverterParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/measurementunitonverter/MeasurementUnitConverterProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/peak/PeakDetectionCalculator.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/peak/PeakDetectionController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/peak/PeakDetectionParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/peak/PeakDetectionProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/peak/utils/SlidingBatchWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rate/EventRate.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rate/EventRateController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rate/EventRateParameter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rate/EventRateProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rename/FieldRenamer.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rename/FieldRenamerController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rename/FieldRenamerParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/rename/FieldRenamerProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/sequence/EventStorage.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/sequence/Sequence.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/sequence/SequenceController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/sequence/SequenceParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/sequence/SequenceProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/summary/StatisticsSummaryCalculator.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/summary/StatisticsSummaryController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/summary/StatisticsSummaryParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/summary/StatisticsSummaryProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/window/StatisticsSummaryCalculatorWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/window/StatisticsSummaryControllerWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/window/StatisticsSummaryParametersWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/window/StatisticsSummaryParamsSerializable.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/stat/window/StatisticsSummaryProgramWindow.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/timestamp/TimestampController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/timestamp/TimestampEnricher.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/timestamp/TimestampParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/timestamp/TimestampProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/urldereferencing/UrlDereferencing.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/urldereferencing/UrlDereferencingController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/urldereferencing/UrlDereferencingParameter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/urldereferencing/UrlDereferencingProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/Word.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/WordCountController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/WordCountParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/WordCountProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/WordSplitter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/WordToEventConverter.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/ElasticSearchController.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/ElasticSearchParameters.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/ElasticSearchProgram.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/ElasticsearchIndexRequestBuilder.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/ActionRequestFailureHandler.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/BulkProcessorIndexer.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/Elasticsearch6ApiCallBridge.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/ElasticsearchApiCallBridge.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/ElasticsearchSink.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/ElasticsearchSinkBase.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/ElasticsearchSinkFunction.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/NoOpFailureHandler.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/sink/elasticsearch/elastic/RequestIndexer.java
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processor.geo.flink/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processor.geo.flink/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processor.geo.flink/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.aggregation/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.aggregation/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.aggregation/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.count/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.count/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.count/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.eventcount/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.eventcount/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.rate/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.rate/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.aggregation.flink.rate/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.enricher.flink.processor.urldereferencing/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.enricher.flink.timestamp/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.enricher.flink.timestamp/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.enricher.flink.timestamp/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.absence/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.absence/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.and/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.and/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.and/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.peak-detection/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.sequence/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.sequence/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.pattern-detection.flink.sequence/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.statistics.flink.statistics-summary-window/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.statistics.flink.statistics-summary-window/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.statistics.flink.statistics-summary-window/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.statistics.flink.statistics-summary/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.statistics.flink.statistics-summary/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.statistics.flink.statistics-summary/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.textmining.flink.wordcount/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.textmining.flink.wordcount/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.textmining.flink.wordcount/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-converter/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-converter/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-converter/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-mapper/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-mapper/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-mapper/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-renamer/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-renamer/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.field-renamer/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.fieldhasher/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.fieldhasher/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.fieldhasher/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.measurementunitconverter/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.measurementunitconverter/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.measurementunitconverter/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.processors.transformation.flink.processor.boilerplate/strings.en
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.sinks.databases.flink.elasticsearch/documentation.md
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.sinks.databases.flink.elasticsearch/icon.png
delete mode 100644
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/resources/org.apache.streampipes.sinks.databases.flink.elasticsearch/strings.en
copy {streampipes-sdk-bundle => streampipes-load-balancer}/pom.xml (68%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/ExtensionServiceSelector.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/IMigrationHandler.java
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadBalancer.java
(59%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadBalancerConfig.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/LoadManager.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/IMigrationHandler.java
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/PipelineMigrator.java
(66%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/ResourceUnitMigration.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/ServiceLoadCalculator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/AbstractPipelineMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/ExtensibleLoadManager.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/MinimumLoadSelector.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/OverloadMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/ThresholdMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/TransferMigrator.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/WeightedFirstSelector.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/impl/WeightedRandomSelector.java
rename
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance}/pipeline/ExtensionsLogProvider.java
(84%)
rename
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance}/pipeline/ExtensionsServiceLogExecutor.java
(68%)
copy
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service}/ExtensionServiceExecutions.java
(59%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service/ExtensionsServiceReportExecutor.java
copy
{streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint
=>
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit}/ExtensionsServiceEndpointUtils.java
(97%)
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/InvokeHttpRequest.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/PipelineElementPartitioner.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/ResourceUnitScanner.java
create mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/unit/ResourceUnitStatsScanner.java
delete mode 100644
streampipes-maven-plugin/src/main/resources/docker-compose.yml
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/LoadBalanceResourceUnit.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/loadbalancer/LoadBalanceResourceUnitStats.java
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/{v970/AddLinkSettingsMigration.java
=> v0980/AddDefaultExportProviderMigration.java} (62%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v0980/FixImportedPermissionsMigration.java
delete mode 100644 streampipes-wrapper-flink/pom.xml
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorCompatProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorDeclarer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorRuntime.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkCompatProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkDeclarer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkRuntime.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDeploymentConfig.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkMiniClusterDeploymentConfig.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntime.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntimeProvider.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkSpMiniCluster.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IDataProcessorProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IDataSinkProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IFlinkProgram.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/consumer/JmsFlinkConsumer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/consumer/MqttFlinkConsumer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/converter/EventToMapConverter.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/converter/MapToEventConverter.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/logger/StatisticLogger.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/serializer/ByteArrayDeserializer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/serializer/ByteArraySerializer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/serializer/SimpleJmsSerializer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/serializer/SimpleKafkaSerializer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/JmsFlinkProducer.java
delete mode 100644
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/MqttFlinkProducer.java
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-siddhi/count1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-siddhi/count1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-siddhi/count1/input.csv
create mode 100644 ui/cypress/support/utils/user/UserBtns.ts
delete mode 100644 ui/cypress/tests/dataExplorer/dataViewAssets.spec.ts
create mode 100644 ui/cypress/tests/userManagement/testUserRoleAsset.spec.ts
rename
archetypes/streampipes-archetype-pe-processors-flink/src/main/resources/archetype-resources/Dockerfile
=> ui/deployment/categories.yml (78%)
copy
ui/projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-filter/{asset-browser-filter-sites/asset-browser-filter-sites.component.html
=>
asset-browser-filter-asset-model/asset-browser-filter-asset-model.component.html}
(81%)
copy
ui/projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-filter/{asset-browser-filter-sites/asset-browser-filter-sites.component.ts
=>
asset-browser-filter-asset-model/asset-browser-filter-asset-model.component.ts}
(70%)
copy
ui/{src/app/data-explorer/components/overview/data-explorer-overview.component.scss
=>
projects/streampipes/shared-ui/src/lib/components/asset-browser/asset-browser-toolbar/asset-browser-toolbar.component.scss}
(82%)
rename ui/{src/app/core-ui =>
projects/streampipes/shared-ui/src/lib/dialog}/object-permission-dialog/object-permission-dialog.component.html
(85%)
rename ui/{src/app/core-ui =>
projects/streampipes/shared-ui/src/lib/dialog}/object-permission-dialog/object-permission-dialog.component.scss
(100%)
rename ui/{src/app/core-ui =>
projects/streampipes/shared-ui/src/lib/dialog}/object-permission-dialog/object-permission-dialog.component.ts
(74%)
copy
ui/{projects/streampipes/platform-services/src/lib/services/pipeline-element-icon-text.service.ts
=> src/app/core/collapse.service.ts} (61%)
delete mode 100644 ui/src/app/core/components/bars.scss
create mode 100644 ui/src/app/core/navigation.backup
delete mode 100644
ui/src/app/data-explorer/components/overview/data-explorer-overview.directive.ts
