This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/pip/streampipes-client-python/pytest-8.4.2
in repository https://gitbox.apache.org/repos/asf/streampipes.git
omit 0149c145ad Merge branch 'dev' into
dependabot/pip/streampipes-client-python/pytest-8.4.2
omit 15dc5d4c25 chore(deps-dev): bump pytest in /streampipes-client-python
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 a3eae71669 refactor: Remove deprecated mqtt adapters (#3905)
add 8eca197cb4 fix: Decrease max idle time in PLC4X adapter (#3920)
add 2ffc1c1e2d chore(deps-dev): bump black from 25.9.0 to 25.11.0 in
/streampipes-client-python (#3914)
add a78db59a84 chore(deps-dev): bump pytest in /streampipes-client-python
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 (0149c145ad)
\
N -- N -- N
refs/heads/dependabot/pip/streampipes-client-python/pytest-8.4.2 (a78db59a84)
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 -
.gitignore | 2 +
.../dev/img/favicon.png => .idea/icon.png | Bin
LICENSE | 7 -
.../README.md | 38 --
.../pom.xml | 63 ---
.../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 | 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__Parameters.java | 52 ---
.../__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 +--
.../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 -
pom.xml | 24 -
streampipes-client-python/poetry.lock | 68 +--
streampipes-client-python/pyproject.toml | 4 +-
.../apache/streampipes/commons/constants/Envs.java | 7 -
.../commons/environment/DefaultEnvironment.java | 15 -
.../commons/environment/Environment.java | 7 -
streampipes-extensions-api/pom.xml | 16 +-
.../iiot/IIoTAdaptersExtensionModuleExport.java | 2 -
.../iiot/adapters/iolink/IfmAlMqttAdapter.java | 223 ---------
.../iiot/adapters/iolink/sensor/IoLinkSensor.java | 29 --
.../iiot/adapters/iolink/sensor/SensorVVB001.java | 162 -------
.../adapters/iolink/sensor/SensorVVB001Test.java | 50 --
.../streampipes-connect-adapters/pom.xml | 5 -
.../GeneralAdaptersExtensionModuleExport.java | 4 -
.../connect/adapters/netio/NetioMQTTAdapter.java | 121 -----
.../connect/adapters/netio/NetioRestAdapter.java | 175 -------
.../connect/adapters/netio/NetioUtils.java | 182 --------
.../adapters/netio/model/NetioAllPowerOutputs.java | 50 --
.../adapters/netio/model/NetioGlobalMeasure.java | 94 ----
.../adapters/netio/model/NetioPowerOutput.java | 126 ------
.../connection/ContinuousPlcRequestReader.java | 4 +-
.../plc/cache/SpCachedPlcConnectionManager.java | 2 +-
.../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 -
.../src/main/resources/docker-compose.yml | 25 -
.../apache/streampipes/model/ShortUserInfo.java | 17 +-
.../apache/streampipes/rest/impl/UserResource.java | 32 +-
.../rest/impl/admin/PermissionResource.java | 36 +-
.../rest/impl/admin/UserGroupResource.java | 1 -
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 ---
.../filters-siddhi/count1/description.json | 26 --
.../filters-siddhi/count1/expected.csv | 4 -
.../filters-siddhi/count1/input.csv | 4 -
ui/cypress/support/utils/UserUtils.ts | 12 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 38 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 50 +-
.../support/utils/dataExplorer/DataExplorerBtns.ts | 100 +++-
.../utils/dataExplorer/DataExplorerUtils.ts | 58 +--
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 57 +++
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 41 +-
ui/cypress/support/utils/user/UserBtns.ts | 22 +
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 21 +-
.../editAdapterTransformationRulesAreKept.spec.ts | 20 +-
.../connect/editAdapterValuesAndFields.spec.ts | 12 +-
.../tests/dataExplorer/configuration.smoke.spec.ts | 20 +-
.../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 +-
.../platform-services/src/lib/apis/user.service.ts | 9 +-
.../src/lib/model/gen/streampipes-model.ts | 14 +-
.../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 | 13 +-
.../streampipes/shared-ui/src/public-api.ts | 1 +
.../endpoint-item/endpoint-item.component.ts | 7 +-
.../existing-adapters.component.html | 1 -
.../existing-adapters.component.ts | 5 +-
ui/src/app/core-ui/core-ui.module.ts | 2 -
.../dashboard-overview-table.component.html | 1 -
.../dashboard-overview-table.component.ts | 3 -
.../overview/dashboard-overview.component.html | 1 -
.../overview/dashboard-overview.component.ts | 4 -
.../services/data-explorer-shared.service.ts | 2 +-
.../data-explorer-overview-table.component.html | 6 +-
.../data-explorer-overview-table.component.ts | 3 -
.../overview/data-explorer-overview.component.html | 1 -
.../overview/data-explorer-overview.component.ts | 4 -
.../pipeline-overview.component.html | 1 -
.../pipeline-overview.component.ts | 4 -
.../services/pipeline-operations.service.ts | 17 +-
395 files changed, 636 insertions(+), 20688 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/Dockerfile
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__Parameters.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
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/sensor/IoLinkSensor.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/sensor/SensorVVB001.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/test/java/org/apache/streampipes/connect/iiot/adapters/iolink/sensor/SensorVVB001Test.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioAllPowerOutputs.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioGlobalMeasure.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioPowerOutput.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
delete mode 100644
streampipes-maven-plugin/src/main/resources/docker-compose.yml
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
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%)
