[streampipes] branch dev updated (839e10d85 -> 752289c6a)

[zehnder]

This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


    from 839e10d85 monthly update of vulnerability report (#1644)
     add 752289c6a Refactor connect adapter API (#1290)

No new revisions were added by this update.

Summary of changes:
 .github/workflows/pr-validation.yml                |   2 +-
 pom.xml                                            |  24 +-
 .../pom.xml                                        |  36 +-
 .../org/apache/streampipes/client/api/CRUDApi.java |   0
 .../apache/streampipes/client/api/IAdminApi.java   |  19 +-
 .../streampipes/client/api/ICustomRequestApi.java  |  17 +-
 .../client/api/IDataLakeMeasureApi.java            |  20 +-
 .../streampipes/client/api/IDataProcessorApi.java  |  67 ++
 .../streampipes/client/api/IDataSinkApi.java       |  57 ++
 .../streampipes/client/api/IDataStreamApi.java     |  52 ++
 .../apache/streampipes/client/api/IFileApi.java    |   8 +-
 .../streampipes/client/api/INotificationsApi.java  |   6 +-
 .../streampipes/client/api/IPipelineApi.java       |  28 +-
 .../client/api/IPipelineElementTemplateApi.java    |  21 +-
 .../streampipes/client/api/IStreamPipesClient.java |  59 ++
 .../client/api}/annotation/NotYetImplemented.java  |   2 +-
 .../config}/ClientConnectionConfigResolver.java    |   2 +-
 .../api/config}/ClientConnectionUrlResolver.java   |   4 +-
 .../api/config/IStreamPipesClientConfig.java       |  17 +-
 .../client/api/constants}/InputStreamIndex.java    |   2 +-
 .../api}/credentials/CredentialsProvider.java      |   2 +-
 .../client/api}/live/EventProcessor.java           |   2 +-
 .../streampipes/client/api/live/IKafkaConfig.java  |   8 +-
 streampipes-client/pom.xml                         |   7 +-
 .../streampipes/client/StreamPipesClient.java      |  43 +-
 .../streampipes/client/StreamPipesCredentials.java |   2 +-
 .../apache/streampipes/client/api/AdminApi.java    |   6 +-
 .../streampipes/client/api/CustomRequestApi.java   |   5 +-
 .../streampipes/client/api/DataLakeMeasureApi.java |   3 +-
 .../streampipes/client/api/DataProcessorApi.java   |  21 +-
 .../apache/streampipes/client/api/DataSinkApi.java |  22 +-
 .../streampipes/client/api/DataStreamApi.java      |  19 +-
 .../org/apache/streampipes/client/api/FileApi.java |   5 +-
 .../streampipes/client/api/NotificationsApi.java   |   3 +-
 .../apache/streampipes/client/api/PipelineApi.java |   6 +-
 .../client/api/PipelineElementTemplateApi.java     |   2 +-
 .../api/SupportsPipelineElementTemplateApi.java    |  23 -
 .../credentials/StreamPipesApiKeyCredentials.java  |   1 +
 .../credentials/StreamPipesTokenCredentials.java   |   1 +
 .../streampipes/client/http/HttpRequest.java       |   2 +-
 .../streampipes/client/live/KafkaConfig.java       |   6 +-
 .../client/live/SubscriptionManager.java           |   6 +-
 .../client/model/StreamPipesClientConfig.java      |   8 +-
 .../model/StreamPipesClientConnectionConfig.java   |   3 +-
 .../apache/streampipes/commons/constants/Envs.java |  10 +-
 .../commons/environment/DefaultEnvironment.java    |  15 +
 .../commons/environment/Environment.java           |   7 +
 .../exceptions/connect}/AdapterException.java      |   2 +-
 .../exceptions/connect}/ParseException.java        |   2 +-
 .../management/health/AdapterHealthCheck.java      |   9 +-
 .../management/AdapterMasterManagement.java        |  68 +-
 .../management/DescriptionManagement.java          |  18 +-
 .../management/management/GuessManagement.java     |  21 +-
 .../management/management/SourcesManagement.java   |  78 +--
 .../management/UnitMasterManagement.java           |   2 +-
 .../management/management/WorkerRestClient.java    |  30 +-
 .../management/AdapterMasterManagementTest.java    |   7 +-
 .../management/SourcesManagementTest.java          |   5 +-
 .../dataexplorer/commons/DataExplorerUtils.java    |  10 +-
 .../dataexplorer/commons/TimeSeriesStore.java      |   4 +-
 .../export/resolver/AdapterResolver.java           |  13 +-
 .../export/resolver/PipelineResolver.java          |   6 -
 streampipes-extensions-api/pom.xml                 |  12 +-
 .../api/DataSetReplayFinishedNotifier.java         |  23 -
 .../extensions/api/config/IConfigExtractor.java    |   9 +-
 ...{Connector.java => AdapterOutputCollector.java} |   6 +-
 .../extensions/api/connect/IAdapter.java           |  41 --
 .../api/connect/IAdapterConfiguration.java         |  18 +-
 .../{EmitBinaryEvent.java => IEventCollector.java} |   6 +-
 .../extensions/api/connect/IFormat.java            |  49 --
 .../extensions/api/connect/IParser.java            |  31 +-
 .../{Connector.java => IParserEventHandler.java}   |   7 +-
 .../{Connector.java => IPollingSettings.java}      |   7 +-
 .../extensions/api/connect/IProtocol.java          |  44 --
 .../connect/{Connector.java => IPullAdapter.java}  |   9 +-
 .../extensions/api/connect/StreamPipesAdapter.java |  39 ++
 .../context/IAdapterGuessSchemaContext.java        |  12 +-
 .../connect/context/IAdapterRuntimeContext.java    |   9 +-
 .../extensions/api/declarer/DataSetDeclarer.java   |  29 -
 .../api/declarer/PipelineTemplateDeclarer.java     |  25 -
 .../api/extractor/IAdapterParameterExtractor.java  |  22 +-
 .../IDataProcessorParameterExtractor.java}         |  10 +-
 .../api/extractor/IDataSinkParameterExtractor.java |  10 +-
 .../api/extractor/IParameterExtractor.java         | 119 ++++
 .../IStaticPropertyExtractor.java}                 |  10 +-
 .../IPipelineElementLogger.java}                   |   7 +-
 .../api}/monitoring/SpMonitoringManager.java       |   2 +-
 .../api/pe/IStreamPipesDataProcessor.java          |  29 +-
 .../extensions/api/pe/IStreamPipesDataSink.java    |  20 +-
 .../IStreamPipesDataStream.java}                   |   7 +-
 .../api/pe/IStreamPipesPipelineElement.java        |  10 +-
 .../api/pe/config/IDataProcessorConfiguration.java |  16 +-
 .../config/IDataSinkConfiguration.java}            |   8 +-
 .../config/IDataStreamConfiguration.java}          |  13 +-
 .../config/IPipelineElementConfiguration.java}     |  15 +-
 .../pe/context/EventProcessorRuntimeContext.java   |   7 +-
 .../api/pe}/context/EventSinkRuntimeContext.java   |   2 +-
 .../api/pe/context/IContextGenerator.java          |  10 +-
 .../context/RuntimeContext.java}                   |  15 +-
 .../api/pe/param/IDataProcessorParameters.java     |  16 +-
 .../param/IDataSinkParameters.java}                |   8 +-
 .../api/pe/param/IInternalRuntimeParameters.java   |  11 +-
 .../api/pe/param/IParameterGenerator.java          |  13 +-
 .../api/pe/param/IPipelineElementParameters.java   |  33 +-
 .../api/pe/param}/InputStreamParams.java           |  17 +-
 .../api/pe/param}/OutputStreamParams.java          |   6 +-
 .../api/pe}/routing/PipelineElementCollector.java  |   2 +-
 .../api/pe}/routing/RawDataProcessor.java          |   2 +-
 .../api/pe}/routing/SpInputCollector.java          |   2 +-
 .../api/pe}/routing/SpOutputCollector.java         |   2 +-
 .../runtime/IDataProcessorRuntime.java}            |   7 +-
 .../runtime/IDataSinkRuntime.java}                 |   7 +-
 .../runtime/IStreamPipesRuntime.java}              |  15 +-
 .../runtime/IStreamPipesRuntimeProvider.java}      |   9 +-
 .../runtime/ResolvesContainerProvidedOptions.java  |   4 +-
 .../ResolvesContainerProvidedOutputStrategy.java   |   4 +-
 .../api/runtime/SupportsRuntimeConfig.java         |   4 +-
 streampipes-extensions-management/pom.xml          |   4 +
 ...StreamPipesClientRuntimeConnectionResolver.java |   4 +-
 .../management/config/ConfigExtractor.java         |  10 +-
 .../management/connect/AdapterUtils.java           |  70 --
 .../connect/AdapterWorkerManagement.java           |  89 +--
 .../connect/ConnectWorkerDescriptionProvider.java  |  96 +--
 .../management/connect/GuessManagement.java        |  71 +-
 .../management/connect/PullAdapterScheduler.java   |  62 ++
 .../management/connect/RuntimeResovable.java       |  26 +-
 .../management/connect/adapter/Adapter.java        |  75 ---
 .../connect/adapter/AdapterPipelineGenerator.java  |  11 -
 .../connect/adapter/AdapterRegistry.java           |  73 --
 .../connect/adapter/GroundingService.java          |  47 --
 .../connect/adapter/format/csv/CsvFormat.java      | 145 ----
 .../connect/adapter/format/csv/CsvParser.java      | 196 ------
 .../adapter/format/geojson/GeoJsonFormat.java      | 152 -----
 .../connect/adapter/format/image/ImageFormat.java  |  64 --
 .../connect/adapter/format/image/ImageParser.java  |  60 --
 .../adapter/format/json/AbstractJsonFormat.java    |  45 --
 .../adapter/format/json/AbstractJsonParser.java    |  76 ---
 .../adapter/format/json/arraykey/JsonFormat.java   |  55 --
 .../adapter/format/json/arraykey/JsonParser.java   | 207 ------
 .../format/json/arraynokey/JsonArrayFormat.java    |  50 --
 .../format/json/arraynokey/JsonArrayParser.java    | 182 -----
 .../format/json/object/JsonObjectParser.java       |  74 --
 .../connect/adapter/format/xml/XmlFormat.java      |  91 ---
 .../connect/adapter/format/xml/XmlParser.java      | 161 -----
 .../EventCollector.java}                           |  35 +-
 .../adapter/model/generic/GenericAdapter.java      |  99 ---
 .../model/generic/GenericDataSetAdapter.java       |  68 --
 .../model/generic/GenericDataStreamAdapter.java    |  68 --
 .../connect/adapter/model/generic/Parser.java      |  47 --
 .../model/specific/SpecificDataSetAdapter.java     |  33 -
 .../model/specific/SpecificDataStreamAdapter.java  |  33 -
 .../connect/adapter/parser/CsvParser.java          | 203 ++++++
 .../connect/adapter/parser/ImageParser.java        |  87 +++
 .../connect/adapter/parser/JsonParsers.java        | 132 ++++
 .../SchemaGuesser.java => parser/ParserUtils.java} |  35 +-
 .../SpecificAdapter.java => parser/Parsers.java}   |  22 +-
 .../geojson => parser/json}/GeoJsonConstants.java  |   2 +-
 .../geojson => parser/json}/GeoJsonParser.java     | 168 +++--
 .../adapter/parser/json/JsonArrayKeyParser.java    |  84 +++
 .../adapter/parser/json/JsonArrayParser.java       |  59 ++
 .../json/JsonObjectParser.java}                    |  38 +-
 .../connect/adapter/parser/json/JsonParser.java    |  58 ++
 .../{format => parser}/util/JsonEventProperty.java |  12 +-
 .../{format => parser}/xml/XmlMapConverter.java    |   2 +-
 .../connect/adapter/parser/xml/XmlParser.java      | 122 ++++
 .../connect/adapter/preprocessing/Util.java        |  14 -
 .../elements/SendToBrokerAdapterSink.java          |   2 +-
 .../connect/adapter/sdk/ParameterExtractor.java    | 147 ----
 .../connect/adapter/util/PollingSettings.java      |  30 +-
 .../context/AdapterContextGenerator.java           |  39 ++
 .../context/SpAdapterGuessSchemaContext.java       |  36 +-
 .../context/SpAdapterRuntimeContext.java           |  24 +-
 .../management/init/DeclarersSingleton.java        | 213 +++---
 .../management/init/IDeclarersSingleton.java       |  17 +-
 .../management/init/RunningAdapterInstances.java   |  10 +-
 .../management/init/RunningDatasetInstances.java   |  55 --
 .../management/init/RunningInstances.java          |  15 +-
 .../management/locales/LabelGenerator.java         |  53 +-
 .../management/model/SpServiceDefinition.java      |  72 +-
 .../model/SpServiceDefinitionBuilder.java          |  33 +-
 .../management/util/RuntimeContextUtils.java       |  31 +-
 .../management/util/ServiceDefinitionUtil.java     |  26 +-
 .../connect/AdapterWorkerManagementTest.java       |  94 +--
 .../ConnectWorkerDescriptionProviderTest.java      |  79 +++
 .../management/connect/GuessManagementTest.java    |  49 ++
 .../extensions/management/connect/Utils.java       |  46 --
 .../connect/adapter/GroundingServiceTest.java      |  85 ---
 .../format/json/arraykey/JsonParserTest.java       |  91 ---
 .../json/arraynokey/JsonArrayParserTest.java       |  93 ---
 .../adapter/format/json/geojson/GeoJsonTest.java   | 330 ---------
 .../format/json/object/JsonObjectParserTest.java   |  79 ---
 .../connect/adapter/format/json/xml/XmlTest.java   | 302 ---------
 .../adapter/format/xml/XmlMapConverterTest.java    |  56 --
 .../connect/adapter/parser/CsvParserTest.java      | 166 +++++
 .../connect/adapter/parser/ParserTest.java}        |  17 +-
 .../connect/adapter/parser/XmlParserTest.java      |  96 +++
 .../adapter/parser/json/GeoJsonParserTest.java     | 111 +++
 .../parser/json/JsonArrayKeyParserTest.java        | 113 ++++
 .../adapter/parser/json/JsonArrayParserTest.java   |  90 +++
 .../adapter/parser/json/JsonObjectParsersTest.java |  95 +++
 .../DeclarersSingletonTest.java}                   |  36 +-
 .../model/SpServiceDefinitionBuilderTest.java      |  70 ++
 .../streampipes-connect-adapters-iiot/pom.xml      |   5 +
 .../connect/iiot/ConnectAdapterIiotInit.java       |  12 +-
 .../connect/iiot/adapters/PullAdapter.java         | 114 ----
 .../connect/iiot/adapters/PullRestAdapter.java     |  72 --
 .../connect/iiot/adapters/opcua/OpcUaAdapter.java  | 167 +++--
 .../connect/iiot/adapters/opcua/SpOpcUaClient.java |   3 +-
 .../opcua/configuration/SpOpcUaConfig.java         |   3 -
 .../opcua/configuration/SpOpcUaConfigBuilder.java  |  26 +-
 .../iiot/adapters/opcua/utils/OpcUaUtil.java       |  16 +-
 .../adapters/plc4x/modbus/Plc4xModbusAdapter.java  | 188 +++---
 .../plc4x/passive/Plc4xPassiveAdapter.java         | 117 ----
 .../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java     | 279 ++++----
 .../iiot/adapters/ros/RosBridgeAdapter.java        | 185 +++--
 .../simulator/machine/MachineDataSimulator.java    |  17 +-
 .../machine/MachineDataSimulatorAdapter.java       |  84 +++
 .../machine/MachineDataSimulatorUtils.java         |   2 +-
 .../machine/MachineDataStreamAdapter.java          |  96 ---
 .../connect/iiot/protocol/set/FileProtocol.java    | 140 ----
 .../connect/iiot/protocol/set/HttpProtocol.java    | 148 ----
 .../iiot/protocol/stream/BrokerEventProcessor.java |  25 +-
 .../iiot/protocol/stream/BrokerProtocol.java       |  58 --
 .../iiot/protocol/stream/FileReplayAdapter.java    | 229 +++++++
 .../iiot/protocol/stream/FileStreamProtocol.java   | 329 ---------
 .../protocol/stream/HttpServerEventReceiver.java   |  36 -
 .../iiot/protocol/stream/HttpServerProtocol.java   | 144 ++--
 .../iiot/protocol/stream/HttpStreamProtocol.java   | 160 +++--
 .../iiot/protocol/stream/KafkaProtocol.java        | 258 ++++---
 .../connect/iiot/protocol/stream/MqttProtocol.java | 105 ++-
 .../connect/iiot/protocol/stream/NatsProtocol.java | 107 ++-
 .../connect/iiot/protocol/stream/PullProtocol.java | 103 ---
 .../iiot/protocol/stream/TubeMQProtocol.java       | 127 ++--
 .../iiot/protocol/stream/pulsar/PulsarConfig.java  |  63 ++
 .../protocol/stream/pulsar/PulsarProtocol.java     | 144 ++--
 .../protocol/stream/rocketmq/RocketMQProtocol.java | 118 ++--
 .../connect/iiot/utils/FileProtocolUtils.java      |   2 +-
 .../documentation.md                               |  33 -
 .../icon.png                                       | Bin 99909 -> 0 bytes
 .../strings.en                                     |  41 --
 .../documentation.md                               |  33 -
 .../icon.png                                       | Bin 99909 -> 0 bytes
 .../strings.en                                     |  42 --
 .../documentation.md                               |   0
 .../icon.png                                       | Bin
 .../strings.en                                     |  26 +-
 .../documentation.md                               |   0
 .../icon.png                                       | Bin
 .../strings.en                                     |   9 +-
 .../documentation.md                               |  32 -
 .../documentation.md                               |  32 -
 .../icon.png                                       | Bin 17467 -> 0 bytes
 .../strings.en                                     |  25 -
 .../streampipes/connect/ConnectAdapterInit.java    |  15 +-
 .../streampipes/connect/adapters/PullAdapter.java  | 105 ---
 .../connect/adapters/PullRestAdapter.java          |  73 --
 .../adapters/coindesk/CoindeskBitcoinAdapter.java  | 145 ++--
 .../connect/adapters/flic/FlicMQTTAdapter.java     | 109 +--
 .../connect/adapters/gdelt/GdeltAdapter.java       | 406 ++++++-----
 .../connect/adapters/iex/IexCloudAdapter.java      |  71 +-
 .../connect/adapters/iex/IexCloudNewsAdapter.java  | 219 +++---
 .../connect/adapters/iex/IexCloudStockAdapter.java | 165 ++---
 .../connect/adapters/image/ImageZipAdapter.java    |  30 +-
 .../adapters/image/set/ImageSetAdapter.java        | 100 ---
 .../adapters/image/stream/ImageStreamAdapter.java  |  63 +-
 .../connect/adapters/iss/IssAdapter.java           |  78 +--
 .../connect/adapters/netio/NetioMQTTAdapter.java   | 107 +--
 .../connect/adapters/netio/NetioRestAdapter.java   | 184 ++---
 .../adapters/sensemap/OpenSenseMapAdapter.java     | 742 ++++++++++-----------
 .../simulator/random/RandomDataSetAdapter.java     |  91 ---
 .../simulator/random/RandomDataSimulator.java      |  87 ---
 .../simulator/random/RandomDataSimulatorUtils.java |  48 --
 .../simulator/random/RandomDataStreamAdapter.java  |  88 ---
 .../connect/adapters/slack/SlackAdapter.java       |  59 +-
 .../connect/adapters/slack/SlackConsumer.java      |  13 +-
 .../connect/adapters/ti/TISensorTag.java           |  92 +--
 .../adapters/wikipedia/WikipediaAdapter.java       |  46 +-
 .../wikipedia/WikipediaEditedArticlesAdapter.java  |  29 +-
 .../wikipedia/WikipediaModelConverter.java         |   2 +-
 .../wikipedia/WikipediaNewArticlesAdapter.java     |  30 +-
 .../adapters/wikipedia/WikipediaSseConsumer.java   |   2 +-
 .../streampipes/connect/config/ConfigKeys.java     |  31 -
 .../connect/config/ConnectWorkerConfig.java        |  81 ---
 .../documentation.md                               |  32 -
 .../icon.png                                       | Bin 5332 -> 0 bytes
 .../strings.en                                     |  26 -
 .../documentation.md                               |  33 -
 .../icon.png                                       | Bin 13079 -> 0 bytes
 .../connect/adapters/generic/UtilTest.java         |  52 --
 .../generic/protocol/set/HttpProtocolTest.java     | 123 ----
 .../connect/adapters/ti/TISensorTagTest.java       |  78 +--
 .../connectors/influx/InfluxConnectorsInit.java    |   3 +-
 .../connectors/influx/adapter/InfluxDbClient.java  |   2 +-
 .../influx/adapter/InfluxDbStreamAdapter.java      | 153 ++---
 .../connectors/influx/shared/InfluxConfigs.java    |   4 +-
 .../connectors/influx/sink/InfluxDbSink.java       |   6 +-
 .../streampipes-extensions-all-jvm/pom.xml         |   1 -
 .../extensions/all/jvm/AllExtensionsInit.java      |   3 +-
 .../pe/jvm/AllPipelineElementsInit.java            |   2 +
 .../config/kafka/kafka/KafkaConnectUtils.java      |   4 +-
 .../pe/shared/config/mqtt/MqttConnectUtils.java    |   6 +-
 .../pe/shared/config/nats/NatsConfigUtils.java     |   4 +-
 .../flink/AbstractAggregationProgram.java          |  49 --
 .../aggregation/AggregationController.java         |  12 +-
 .../aggregation/AggregationParameters.java         |   4 +-
 .../processor/aggregation/AggregationProgram.java  |  47 +-
 .../flink/processor/count/CountController.java     |  12 +-
 .../flink/processor/count/CountParameters.java     |   6 +-
 .../flink/processor/count/CountProgram.java        |  21 +-
 .../processor/eventcount/EventCountController.java |  12 +-
 .../processor/eventcount/EventCountParameters.java |   4 +-
 .../processor/eventcount/EventCountProgram.java    |  18 +-
 .../flink/processor/rate/EventRate.java            |   2 +-
 .../flink/processor/rate/EventRateController.java  |  12 +-
 .../flink/processor/rate/EventRateParameter.java   |   4 +-
 .../flink/processor/rate/EventRateProgram.java     |  16 +-
 .../jvm/welford/WelfordChangeDetection.java        |   6 +-
 .../enricher/flink/AbstractEnricherProgram.java    |  49 --
 .../enricher/flink/EnricherFlinkInit.java          |   5 +-
 .../processor/timestamp/TimestampController.java   |  12 +-
 .../processor/timestamp/TimestampParameters.java   |   4 +-
 .../processor/timestamp/TimestampProgram.java      |  15 +-
 .../UrlDereferencingController.java                |  23 +-
 .../UrlDereferencingParameter.java                 |   4 +-
 .../urldereferencing/UrlDereferencingProgram.java  |  14 +-
 .../jvm/processor/jseval/JSEvalProcessor.java      |   6 +-
 .../jvm/processor/math/MathOpProcessor.java        |   6 +-
 .../math/staticmathop/StaticMathOpProcessor.java   |   6 +-
 .../sizemeasure/SizeMeasureProcessor.java          |   6 +-
 .../trigonometry/TrigonometryProcessor.java        |   6 +-
 .../valuechange/ValueChangeProcessor.java          |   6 +-
 .../booleanfilter/BooleanFilterProcessor.java      |   6 +-
 .../jvm/processor/compose/ComposeProcessor.java    |   6 +-
 .../processor/enrich/MergeByEnrichProcessor.java   |   6 +-
 .../jvm/processor/limit/RateLimitProcessor.java    |   6 +-
 .../jvm/processor/limit/util/WindowFactory.java    |   2 +-
 .../jvm/processor/limit/window/CronWindow.java     |   2 +-
 .../jvm/processor/limit/window/LengthWindow.java   |   2 +-
 .../jvm/processor/limit/window/ScheduleWindow.java |   2 +-
 .../jvm/processor/limit/window/TimeWindow.java     |   2 +-
 .../jvm/processor/merge/MergeByTimeProcessor.java  |   6 +-
 .../movingaverage/MovingAverageProcessor.java      |   8 +-
 .../numericalfilter/NumericalFilterProcessor.java  |  60 +-
 .../NumericalTextFilterProcessor.java              |   6 +-
 .../processor/projection/ProjectionProcessor.java  |   6 +-
 .../processor/schema/MergeBySchemaProcessor.java   |   6 +-
 .../processor/sdt/SwingingDoorTrendingFilter.java  |   2 +-
 .../sdt/SwingingDoorTrendingFilterProcessor.java   |   6 +-
 .../processor/textfilter/TextFilterProcessor.java  |   8 +-
 .../threshold/ThresholdDetectionProcessor.java     |   6 +-
 .../throughputmon/ThroughputMonitorProcessor.java  |   6 +-
 .../processors/siddhi/count/CountAggregation.java  |   3 +-
 .../filter/NumericalFilterSiddhiProcessor.java     |   3 +-
 .../siddhi/frequency/FrequencySiddhiProcessor.java |   5 +-
 .../FrequencyChangeSiddhiProcessor.java            |   7 +-
 .../siddhi/listcollector/ListCollector.java        |   3 +-
 .../processors/siddhi/listfilter/ListFilter.java   |   7 +-
 .../siddhi/sequence/SequenceSiddhiProcessor.java   |   7 +-
 .../siddhi/stop/StreamStopSiddhiProcessor.java     |   7 +-
 .../streampipes/processors/siddhi/topk/TopK.java   |   7 +-
 .../processors/siddhi/trend/TrendProcessor.java    |   7 +-
 .../siddhi/trend/TestTrendProcessor.java           |   6 +-
 .../processor/geo/flink/AbstractGeoProgram.java    |  47 --
 .../SpatialGridEnrichmentController.java           |  12 +-
 .../SpatialGridEnrichmentParameters.java           |   4 +-
 .../gridenricher/SpatialGridEnrichmentProgram.java |  14 +-
 .../buffergeometry/BufferGeomProcessor.java        |   6 +-
 .../bufferpoint/BufferPointProcessor.java          |   6 +-
 .../geo/jvm/jts/processor/epsg/EpsgProcessor.java  |   6 +-
 .../LatLngToJtsPointProcessor.java                 |   6 +-
 .../reprojection/ReprojectionProcessor.java        |   6 +-
 .../trajectory/TrajectoryFromPointsProcessor.java  |   6 +-
 .../complex/TopologyValidationProcessor.java       |   8 +-
 .../simple/GeometryValidationProcessor.java        |   6 +-
 .../HaversineDistanceCalculatorProcessor.java      |   6 +-
 ...HaversineStaticDistanceCalculatorProcessor.java |   6 +-
 .../googlemaps/GoogleMapsGeocoderProcessor.java    |   6 +-
 .../GoogleMapsStaticGeocoderProcessor.java         |   6 +-
 .../geocityname/GeoCityNameRevdecodeProcessor.java |   6 +-
 .../speedcalculator/SpeedCalculatorProcessor.java  |   6 +-
 .../GenericImageClassificationProcessor.java       |   6 +-
 .../imagecropper/ImageCropperProcessor.java        |   6 +-
 .../imageenrichment/ImageEnrichmentProcessor.java  |   6 +-
 .../processor/qrreader/QrCodeReaderProcessor.java  |   6 +-
 .../flink/AbstractPatternDetectionProgram.java     |  30 +-
 .../flink/processor/absence/AbsenceController.java |  12 +-
 .../flink/processor/absence/AbsenceParameters.java |   4 +-
 .../flink/processor/absence/AbsenceProgram.java    |  12 +-
 .../flink/processor/and/AndController.java         |  12 +-
 .../flink/processor/and/AndParameters.java         |   4 +-
 .../detection/flink/processor/and/AndProgram.java  |   8 +-
 .../processor/peak/PeakDetectionController.java    |  12 +-
 .../processor/peak/PeakDetectionParameters.java    |   4 +-
 .../flink/processor/peak/PeakDetectionProgram.java |  10 +-
 .../processor/sequence/SequenceController.java     |  12 +-
 .../processor/sequence/SequenceParameters.java     |   4 +-
 .../flink/processor/sequence/SequenceProgram.java  |  17 +-
 .../flink/AbstractStatisticsProgram.java           |  49 --
 .../stat/summary/StatisticsSummaryController.java  |  12 +-
 .../stat/summary/StatisticsSummaryParameters.java  |   4 +-
 .../stat/summary/StatisticsSummaryProgram.java     |  16 +-
 .../window/StatisticsSummaryControllerWindow.java  |  12 +-
 .../window/StatisticsSummaryParametersWindow.java  |   4 +-
 .../window/StatisticsSummaryProgramWindow.java     |  17 +-
 .../pom.xml                                        |   2 +-
 .../flink/AbstractTextMiningProgram.java           |  49 --
 .../language/LanguageDetectionController.java      |  13 +-
 .../language/LanguageDetectionParameters.java      |   4 +-
 .../language/LanguageDetectionProgram.java         |  14 +-
 .../processor/sentiment/SentimentDetection.java    |  21 -
 .../sentiment/SentimentDetectionController.java    |  21 -
 .../sentiment/SentimentDetectionParameters.java    |  21 -
 .../sentiment/SentimentDetectionProgram.java       |  21 -
 .../processor/wordcount/WordCountController.java   |  13 +-
 .../processor/wordcount/WordCountParameters.java   |   4 +-
 .../processor/wordcount/WordCountProgram.java      |  16 +-
 .../jvm/processor/chunker/ChunkerProcessor.java    |   6 +-
 .../language/LanguageDetectionProcessor.java       |   6 +-
 .../processor/namefinder/NameFinderProcessor.java  |   6 +-
 .../partofspeech/PartOfSpeechProcessor.java        |   6 +-
 .../SentenceDetectionProcessor.java                |   6 +-
 .../processor/tokenizer/TokenizerProcessor.java    |   6 +-
 .../flink/AbstractFlinkTransformationProgram.java  |  32 +-
 .../flink/TransformationFlinkInit.java             |   4 -
 .../boilerplate/BoilerplateController.java         |  12 +-
 .../boilerplate/BoilerplateParameters.java         |   4 +-
 .../processor/boilerplate/BoilerplateProgram.java  |  10 +-
 .../converter/FieldConverterController.java        |  16 +-
 .../converter/FieldConverterParameters.java        |   4 +-
 .../processor/converter/FieldConverterProgram.java |  10 +-
 .../flink/processor/hasher/FieldHasher.java        |  46 --
 .../processor/hasher/FieldHasherController.java    |  74 --
 .../processor/hasher/FieldHasherParameters.java    |  45 --
 .../flink/processor/hasher/FieldHasherProgram.java |  46 --
 .../hasher/algorithm/HashAlgorithmType.java        |  33 -
 .../hasher/algorithm/Sha1HashAlgorithm.java        |  32 -
 .../hasher/algorithm/Sha2HashAlgorithm.java        |  32 -
 .../flink/processor/mapper/FieldMapper.java        |  56 --
 .../processor/mapper/FieldMapperController.java    |  93 ---
 .../processor/mapper/FieldMapperParameters.java    |  43 --
 .../flink/processor/mapper/FieldMapperProgram.java |  40 --
 .../MeasurementUnitConverterController.java        |  16 +-
 .../MeasurementUnitConverterParameters.java        |   4 +-
 .../MeasurementUnitConverterProgram.java           |  10 +-
 .../processor/rename/FieldRenamerController.java   |  12 +-
 .../processor/rename/FieldRenamerParameters.java   |   4 +-
 .../processor/rename/FieldRenamerProgram.java      |  10 +-
 .../transformation/jvm/TransformationJvmInit.java  |   2 +
 .../processor/array/count/CountArrayProcessor.java |   6 +-
 .../processor/array/split/SplitArrayProcessor.java |   6 +-
 .../counter/BooleanCounterProcessor.java           |  63 +-
 .../edge/SignalEdgeFilterProcessor.java            |   6 +-
 .../inverter/BooleanInverterProcessor.java         |   8 +-
 .../logical/BooleanOperatorProcessor.java          |   6 +-
 .../state/BooleanToStateProcessor.java             |   6 +-
 .../timekeeping/BooleanTimekeepingProcessor.java   |   6 +-
 .../booloperator/timer/BooleanTimerProcessor.java  |   6 +-
 .../CsvMetadataEnrichmentProcessor.java            |  14 +-
 .../fieldrename/FiledRenameProcessor.java          |   6 +-
 .../jvm/processor/hasher/FieldHasherProcessor.java |   6 +-
 .../jvm/processor/mapper/FieldMapperProcessor.java |   6 +-
 .../MeasurementUnitConverterProcessor.java         |  11 +-
 .../state/buffer/StateBufferProcessor.java         |   6 +-
 .../buffer/StateBufferLabelerProcessor.java        |   6 +-
 .../labeler/number/NumberLabelerProcessor.java     |   6 +-
 .../counter/StringCounterProcessor.java            |   6 +-
 .../state/StringToStateProcessor.java              |   6 +-
 .../stringoperator/timer/StringTimerProcessor.java |   6 +-
 .../jvm/processor/task/TaskDurationProcessor.java  |   6 +-
 .../TimestampExtractorProcessor.java               |   6 +-
 .../TransformToBooleanProcessor.java               |   6 +-
 .../change/ChangedValueDetectionProcessor.java     |   6 +-
 .../value/duration/CalculateDurationProcessor.java |   6 +-
 .../counter/TestBooleanCounterProcessor.java       |  10 +-
 .../inverter/TestBooleanInverterProcessor.java     |   6 +-
 .../counter/TestStringCounterProcessor.java        |   6 +-
 .../state/TestStringToStateProcessor.java          |   4 +-
 .../timer/TestStringTimerProcessor.java            |   4 +-
 .../jvm/bufferrest/BufferRestPublisherSink.java    |   4 +-
 .../sinks/brokers/jvm/jms/JmsPublisherSink.java    |   4 +-
 .../sinks/brokers/jvm/kafka/KafkaParameters.java   |   5 +-
 .../sinks/brokers/jvm/kafka/KafkaPublishSink.java  |   4 +-
 .../sinks/brokers/jvm/mqtt/MqttClient.java         |   2 +-
 .../sinks/brokers/jvm/mqtt/MqttPublisherSink.java  |   4 +-
 .../sinks/brokers/jvm/mqtt/common/MqttOptions.java |   7 +-
 .../sinks/brokers/jvm/nats/NatsController.java     |   6 +-
 .../sinks/brokers/jvm/pulsar/PulsarParameters.java |   5 +-
 .../brokers/jvm/pulsar/PulsarPublisherSink.java    |   4 +-
 .../jvm/rabbitmq/RabbitMqPublisherSink.java        |   4 +-
 .../sinks/brokers/jvm/rest/RestSink.java           |   4 +-
 .../brokers/jvm/rocketmq/RocketMQParameters.java   |   5 +-
 .../jvm/rocketmq/RocketMQPublisherSink.java        |   4 +-
 .../sinks/brokers/jvm/tubemq/TubeMQParameters.java |   5 +-
 .../brokers/jvm/tubemq/TubeMQPublisherSink.java    |   4 +-
 .../brokers/jvm/websocket/WebsocketServerSink.java |   4 +-
 .../brokers/jvm/pulsar/TestPulsarParameters.java   |   2 +-
 .../jvm/pulsar/TestPulsarPublisherSink.java        |   2 +-
 .../jvm/rocketmq/TestRocketMQPublisherSink.java    |   2 +-
 .../elasticsearch/ElasticSearchController.java     |  22 +-
 .../elasticsearch/ElasticSearchParameters.java     |   4 +-
 .../flink/elasticsearch/ElasticSearchProgram.java  |  34 +-
 .../sinks/databases/jvm/couchdb/CouchDbSink.java   |   4 +-
 .../sinks/databases/jvm/ditto/DittoSink.java       |   4 +-
 .../sinks/databases/jvm/iotdb/IotDbSink.java       |   4 +-
 .../jdbcclient/model/JdbcConnectionParameters.java |  11 +-
 .../sinks/databases/jvm/opcua/OpcUaSink.java       |   4 +-
 .../databases/jvm/postgresql/PostgreSqlSink.java   |   7 +-
 .../sinks/databases/jvm/redis/RedisSink.java       |   7 +-
 .../sinks/internal/jvm/datalake/DataLakeSink.java  |   6 +-
 .../jvm/notification/NotificationProducer.java     |  12 +-
 .../sinks/notifications/jvm/email/EmailSink.java   |   8 +-
 .../notifications/jvm/onesignal/OneSignalSink.java |   4 +-
 .../jvm/slack/SlackNotificationSink.java           |   4 +-
 .../notifications/jvm/telegram/TelegramSink.java   |   4 +-
 .../watertank/streams/FlowRate2Stream.java         |   1 -
 streampipes-integration-tests/pom.xml              | 155 +++--
 .../integration/adapters/AdapterTesterBase.java    | 135 +++-
 .../integration/adapters/AdaptersTest.java         |  27 +-
 .../integration/adapters/MqttAdapterTester.java    | 137 ++--
 .../integration/adapters/PulsarAdapterTester.java  | 122 ++--
 streampipes-model/pom.xml                          |  14 +
 .../org/apache/streampipes/model/SpDataSet.java    | 121 ----
 .../org/apache/streampipes/model/SpDataStream.java |   5 -
 .../model/connect/adapter/AdapterDescription.java  |  67 +-
 .../connect/adapter/AdapterSetDescription.java     |  57 --
 .../connect/adapter/AdapterStreamDescription.java  |  68 --
 .../connect/adapter/GenericAdapterDescription.java |  35 -
 .../adapter/GenericAdapterSetDescription.java      |  79 ---
 .../adapter/GenericAdapterStreamDescription.java   |  76 ---
 .../adapter/SpecificAdapterSetDescription.java     |  37 -
 .../adapter/SpecificAdapterStreamDescription.java  |  37 -
 ...rmatDescription.java => ParserDescription.java} |  50 +-
 .../connect/grounding/ProtocolDescription.java     |   1 +
 .../connect/grounding/ProtocolSetDescription.java  |  41 --
 .../grounding/ProtocolStreamDescription.java       |  41 --
 .../model/connect/guess/FieldStatusInfo.java       |  20 +
 .../model/connect/guess/GuessSchema.java           |  26 +
 .../model/connect/guess/GuessTypeInfo.java         |  19 +
 .../connect/rules/DebugSinkRuleDescription.java    |  27 -
 .../rules/TransformationRuleDescription.java       |   1 -
 .../rules/value/AddTimestampRuleDescription.java   |   4 +
 .../model/grounding/EventGrounding.java            |   7 +-
 .../model/message/DataSetModificationMessage.java  |  51 --
 .../apache/streampipes/model/message/Message.java  |   1 -
 .../model/runtime/DataSetStatusMessage.java        |  66 --
 .../streampipes/model/schema/Enumeration.java      |  17 +
 .../streampipes/model/schema/EventProperty.java    |  60 +-
 .../model/schema/EventPropertyList.java            |  21 +
 .../model/schema/EventPropertyNested.java          |  20 +
 .../model/schema/EventPropertyPrimitive.java       |  32 +
 .../streampipes/model/schema/EventSchema.java      |   7 +
 .../model/schema/QuantitativeValue.java            |  19 +
 .../staticproperty/StaticPropertyAlternative.java  |   3 +-
 .../model/template/PipelineTemplateInvocation.java |  12 +-
 .../org/apache/streampipes/model/util/Cloner.java  |  38 +-
 .../connect/adapter/AdapterDescriptionTest.java    |   2 +-
 .../manager/execution/PipelineExecutionInfo.java   |  21 -
 .../ExtensionsServiceEndpointGenerator.java        |  18 +-
 .../ExtensionsServiceEndpointProvider.java         |  12 -
 .../http/DetachPipelineElementSubmitter.java       |   5 -
 .../http/InvokePipelineElementSubmitter.java       |   5 -
 .../execution/http/PipelineElementSubmitter.java   |  11 +-
 .../provider/CurrentPipelineElementProvider.java   |   5 -
 .../provider/PipelineElementProvider.java          |   2 -
 .../provider/StoredPipelineElementProvider.java    |   9 -
 .../execution/task/AfterInvocationTask.java        |   8 +-
 .../execution/task/DiscoverEndpointsTask.java      |  13 -
 .../manager/execution/task/SubmitRequestTask.java  |   3 +-
 .../manager/matching/DataSetGroundingSelector.java | 128 ----
 .../streampipes/manager/operations/Operations.java |   7 -
 .../manager/preview/PipelinePreview.java           |   2 -
 .../storage/RunningPipelineElementStorage.java     |   3 -
 .../manager/template/AdapterTemplateHandler.java   |  12 +-
 .../template/PipelineElementTemplateVisitor.java   |   6 +-
 .../manager/template/PipelineGenerator.java        |  12 +-
 .../template/PipelineTemplateGenerator.java        |  17 +-
 .../PipelineTemplateInvocationGenerator.java       |   2 +-
 .../PipelineTemplateInvocationHandler.java         |   2 +-
 .../management/DataStreamResourceManager.java      |   3 +-
 .../resource/management/secret/SecretService.java  |   7 +-
 .../management/AdapterResourceManagerTest.java     |   4 +-
 .../AbstractPipelineElementResource.java           |  12 +-
 .../extensions/connect/AdapterWorkerResource.java  |  62 +-
 .../rest/extensions/connect/GuessResource.java     |   9 +-
 .../connect/RuntimeResolvableResource.java         |  11 +-
 .../extensions/html/page/WelcomePageGenerator.java |  55 +-
 .../extensions/monitoring/MonitoringResource.java  |   2 +-
 .../pe/DataProcessorPipelineElementResource.java   |  34 +-
 .../pe/DataSinkPipelineElementResource.java        |  33 +-
 .../pe/DataStreamPipelineElementResource.java      |  65 +-
 .../pe/InvocablePipelineElementResource.java       |  72 +-
 .../extensions/pe/PipelineTemplateResource.java    |  35 -
 .../apache/streampipes/rest/ResetManagement.java   |   2 +-
 .../rest/impl/PipelineElementRuntimeInfo.java      |   2 -
 .../streampipes/rest/impl/PipelineResource.java    |  12 -
 .../streampipes/rest/impl/PipelineTemplate.java    |  19 -
 .../admin/ExtensionsServiceEndpointResource.java   |   3 +-
 .../rest/impl/connect/AdapterResource.java         |  10 +-
 .../rest/impl/connect/DescriptionResource.java     |  13 +-
 .../rest/impl/connect/GuessResource.java           |   2 +-
 .../impl/connect/RuntimeResolvableResource.java    |   5 +-
 .../rest/impl/connect/SourcesResource.java         |  81 ---
 .../rest/impl/connect/UnitResource.java            |   2 +-
 streampipes-sdk/pom.xml                            |  10 +
 .../apache/streampipes/sdk/StaticProperties.java   |   2 +
 .../streampipes/sdk/builder/DataSetBuilder.java    |  80 ---
 .../sdk/builder/adapter/AdapterConfiguration.java  | 108 +++
 .../adapter/AdapterConfigurationBuilder.java       |  91 +++
 .../builder/adapter/AdapterDescriptionBuilder.java |  55 --
 .../adapter/GenericDataStreamAdapterBuilder.java   |  86 ---
 ...nBuilder.java => ParserDescriptionBuilder.java} |  35 +-
 .../adapter/ProtocolDescriptionBuilder.java        |  83 ---
 .../adapter/SpecificDataSetAdapterBuilder.java     |  68 --
 .../adapter/SpecificDataStreamAdapterBuilder.java  |  68 --
 .../processor/DataProcessorConfiguration.java      |  52 ++
 .../sdk/builder/sink/DataSinkConfiguration.java    |  52 ++
 .../builder/stream/DataStreamConfiguration.java    |  52 ++
 .../sdk/extractor/AbstractParameterExtractor.java  |  52 +-
 .../sdk/extractor/AdapterParameterExtractor.java   |  94 +++
 .../sdk/extractor/DataSinkParameterExtractor.java  |   7 +-
 .../ProcessingElementParameterExtractor.java       |   6 +-
 .../sdk/extractor/StaticPropertyExtractor.java     |   4 +-
 .../adapter/AdapterConfigurationBuilderTest.java   | 102 +++
 .../builder/adapter/AdapterConfigurationTest.java} |  18 +-
 .../GenericDataStreamAdapterBuilderTest.java       |  89 ---
 .../extractor/AdapterParameterExtractorTest.java   |  62 ++
 .../service/core/StreamPipesResourceConfig.java    |   2 -
 .../core/migrations/AvailableMigrations.java       |   4 +-
 .../core/migrations/v093/AdapterBackupWriter.java  |  63 ++
 .../core/migrations/v093/AdapterMigration.java     | 143 ++++
 .../migrations/v093/format/CsvFormatMigrator.java  |  70 ++
 .../v093/format/EmptyFormatMigrator.java           |  11 +-
 .../migrations/v093/format/FormatMigrator.java     |  10 +-
 .../migrations/v093/format/JsonFormatMigrator.java |  73 ++
 .../migrations/v093/format/XmlFormatMigrator.java  |  49 ++
 .../migrations/v093/migrator/AdapterMigrator.java  |  11 +-
 .../v093/migrator/GenericAdapterMigrator.java      | 139 ++++
 .../migrations/v093/migrator/MigrationHelpers.java |  54 ++
 .../v093/migrator/SpecificAdapterMigrator.java     |  36 +-
 .../v093/utils/AdapterMigrationUtils.java          |  67 ++
 .../core/migrations/v093/utils/DocumentKeys.java   |  11 +-
 .../core/migrations/v093/utils/FormatIds.java      |  38 ++
 .../migrations/v093/utils/GenericAdapterUtils.java | 313 +++++++++
 .../extensions/ExtensionsModelSubmitter.java       |   2 +-
 .../extensions/ExtensionsResourceConfig.java       |   2 -
 .../service/extensions/ServiceTagProvider.java     |  15 +-
 .../connect/ConnectWorkerRegistrationService.java  |   8 +-
 .../function/StreamPipesFunctionHandler.java       |  14 +-
 .../sources/AbstractAdapterIncludedStream.java     |  17 +-
 .../sources/AbstractAlreadyExistingStream.java     |  25 +-
 .../storage/couchdb/serializer/GsonSerializer.java |  18 -
 .../streampipes/storage/couchdb/utils/Utils.java   |   4 +
 .../template/PipelineElementTemplateHelpers.java   |   2 +-
 .../distributed/runtime/DistributedRuntime.java    |  55 +-
 streampipes-wrapper-flink/pom.xml                  |   7 +-
 .../flink/FlinkDataProcessorCompatProgram.java     |  76 +++
 .../wrapper/flink/FlinkDataProcessorDeclarer.java  |  46 +-
 ...eclarer.java => FlinkDataProcessorProgram.java} |  11 +-
 .../wrapper/flink/FlinkDataProcessorRuntime.java   |  92 +--
 .../wrapper/flink/FlinkDataSinkCompatProgram.java  |  20 +-
 .../wrapper/flink/FlinkDataSinkDeclarer.java       |  43 +-
 .../wrapper/flink/FlinkDataSinkProgram.java        |  17 +-
 .../wrapper/flink/FlinkDataSinkRuntime.java        |  55 +-
 .../streampipes/wrapper/flink/FlinkRuntime.java    | 137 ++--
 .../wrapper/flink/FlinkRuntimeProvider.java        |  20 +-
 .../wrapper/flink/IDataProcessorProgram.java       |   9 +-
 .../wrapper/flink/IDataSinkProgram.java            |   9 +-
 .../streampipes/wrapper/flink/IFlinkProgram.java   |  34 +-
 .../flink/converter/MapToEventConverter.java       |  15 +-
 ...clarer.java => KafkaStreamRuntimeProvider.java} |  19 +-
 .../kafka/KafkaStreamsDataProcessorRuntime.java    |  75 ++-
 .../kafka/KafkaStreamsDataSinkDeclarer.java        |  25 -
 .../wrapper/kafka/KafkaStreamsDataSinkRuntime.java |  28 +-
 .../wrapper/kafka/KafkaStreamsOutputCollector.java |  73 ++
 .../wrapper/kafka/KafkaStreamsRuntime.java         |  78 ++-
 .../wrapper/kafka/converter/MapToJsonFormat.java   |  45 --
 .../wrapper/siddhi/engine/SiddhiEngine.java        |  13 +-
 .../wrapper/siddhi/engine/SiddhiEventEngine.java   |  68 --
 .../siddhi/engine/SiddhiStatementGenerator.java    |   6 +-
 .../siddhi/engine/StreamPipesSiddhiProcessor.java  |  36 +-
 .../callback/SiddhiOutputStreamCallback.java       |  18 +-
 .../engine/generator/EventTypeGenerator.java       |   8 +-
 .../engine/generator/InputStreamNameGenerator.java |   8 +-
 .../engine/generator/SiddhiAppGenerator.java       |   9 +-
 .../generator/SiddhiInvocationConfigGenerator.java |  22 +-
 .../siddhi/model/SiddhiProcessorParams.java        |  10 +-
 .../wrapper/siddhi/utils/SiddhiUtils.java          |   8 +-
 .../AbstractConfiguredPipelineElement.java         |  46 --
 .../ConfiguredExternalEventProcessor.java          |  33 -
 .../standalone/ConfiguredExternalEventSink.java    |  32 -
 .../wrapper/standalone/ProcessorParams.java        |  36 -
 .../streampipes/wrapper/standalone/SinkParams.java |  36 -
 .../standalone/StreamPipesDataProcessor.java       |  54 +-
 .../wrapper/standalone/StreamPipesDataSink.java    |  50 +-
 .../StreamPipesExternalDataProcessor.java          | 148 ----
 .../StandaloneEventProcessingDeclarer.java         |  55 --
 .../StandaloneEventProcessorDeclarerSingleton.java |  60 --
 .../declarer/StandaloneEventSinkDeclarer.java      |  55 --
 .../StandaloneEventSinkDeclarerSingleton.java      |  54 --
 .../StandaloneExternalEventProcessingDeclarer.java |  55 --
 .../StandaloneExternalEventSinkDeclarer.java       |  61 --
 .../standalone/function/FunctionContext.java       |   4 +-
 .../function/FunctionContextGenerator.java         |   2 +-
 .../standalone/function/StreamPipesFunction.java   |   8 +-
 .../standalone/routing/StandaloneSpCollector.java  |   2 +-
 .../routing/StandaloneSpInputCollector.java        |   4 +-
 .../routing/StandaloneSpOutputCollector.java       |   4 +-
 .../runtime/StandaloneEventProcessorRuntime.java   |  89 +--
 .../runtime/StandaloneEventSinkRuntime.java        |  68 +-
 .../StandaloneExternalEventProcessorRuntime.java   |  69 --
 .../StandaloneExternalEventSinkRuntime.java        |  69 --
 .../runtime/StandalonePipelineElementRuntime.java  | 116 ++--
 .../StandaloneStreamPipesRuntimeProvider.java}     |  22 +-
 .../context/SpEventProcessorRuntimeContext.java    |  28 +-
 .../wrapper/context/SpEventSinkRuntimeContext.java |  12 +-
 .../wrapper/context/SpRuntimeContext.java          |  26 +-
 .../generator/DataProcessorContextGenerator.java   |  39 ++
 .../generator/DataSinkContextGenerator.java        |  28 +-
 .../wrapper/declarer/EventProcessorDeclarer.java   |  48 --
 .../wrapper/declarer/EventSinkDeclarer.java        |  43 --
 .../wrapper/declarer/PipelineElementDeclarer.java  |  75 ---
 .../wrapper/params/DataProcessorParameters.java    |  98 +++
 ...kBindingParams.java => DataSinkParameters.java} |  30 +-
 .../InternalRuntimeParameters.java}                |  21 +-
 .../wrapper/params/PipelineElementParameters.java  | 115 ++++
 .../wrapper/params/binding/BindingParams.java      |  72 --
 .../binding/EventProcessorBindingParams.java       |  75 ---
 .../wrapper/params/compat/ProcessorParams.java     | 126 ++++
 .../wrapper/params/compat/SinkParams.java          |  97 +++
 .../generator/DataProcessorParameterGenerator.java |  55 ++
 .../generator/DataSinkParameterGenerator.java      |  51 ++
 .../PipelineElementParameterGenerator.java         |  58 ++
 .../runtime/EventProcessorRuntimeParams.java       |  54 --
 .../params/runtime/EventSinkRuntimeParams.java     |  50 --
 .../wrapper/params/runtime/RuntimeParams.java      | 112 ----
 .../wrapper/runtime/EventProcessor.java            |  38 --
 .../wrapper/runtime/ExternalEventProcessor.java    |  31 -
 .../wrapper/runtime/ExternalEventSink.java         |  30 -
 .../wrapper/runtime/PipelineElementRuntime.java    |  63 +-
 ...{GenericAdapterBuilder.ts => AdapterBuilder.ts} |  55 +-
 ui/cypress/support/builder/ProcessorTestBuilder.ts |  44 --
 .../support/builder/SpecificAdapterBuilder.ts      |  75 ---
 ui/cypress/support/model/AdapterInput.ts           |   6 +
 ui/cypress/support/model/GenericAdapterInput.ts    |  26 -
 ui/cypress/support/model/SpecificAdapterInput.ts   |  24 -
 ui/cypress/support/utils/PipelineUtils.ts          |   8 -
 ui/cypress/support/utils/PrepareTestDataUtils.ts   |  15 +-
 .../support/utils/ProcessingElementTestUtils.ts    |  11 +-
 .../support/utils/ThirdPartyIntegrationUtils.ts    |  16 +-
 ui/cypress/support/utils/connect/ConnectBtns.ts    |  54 +-
 ui/cypress/support/utils/connect/ConnectUtils.ts   |  78 +--
 ui/cypress/support/utils/datalake/DataLakeUtils.ts |  12 +-
 .../adapter/createAdapterWithoutStarting.spec.ts   |   8 +-
 ui/cypress/tests/adapter/editAdapter.smoke.spec.ts |  13 +-
 ui/cypress/tests/adapter/fileStream.smoke.spec.ts  |  11 +-
 .../adapter/machineDataSimulator.smoke.spec.ts     |  10 +-
 ui/cypress/tests/adapter/opcAdapter.ts             |  11 +-
 .../tests/adapter/persistInDataLake.smoke.spec.ts  |  11 +-
 .../tests/adapter/randomDataSimulatorStream.ts     |   6 +-
 ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts |   4 +-
 ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts    |   7 +-
 ui/cypress/tests/thirdparty/Mqtt.ts                |   2 +-
 ui/deployment/modules.yml                          |   2 +-
 .../src/lib/apis/adapter.service.ts                |  26 +-
 .../lib/apis/pipeline-element-template.service.ts  |  25 +-
 .../src/lib/apis/pipeline-element.service.ts       |  18 +-
 .../src/lib/model/gen/streampipes-model-client.ts  | 102 +--
 .../src/lib/model/gen/streampipes-model.ts         | 460 +++----------
 .../endpoint-item/endpoint-item.component.ts       |   2 -
 .../assets/dialog/base-asset-links.directive.ts    |   4 +-
 .../edit-asset-link-dialog.component.ts            |   7 -
 .../manage-asset-links-dialog.component.ts         |   9 -
 .../adapter-configuration-header.component.html    |  10 +-
 .../adapter-configuration-header.component.scss    |   4 -
 .../adapter-configuration-header.component.ts      |   5 -
 .../adapter-configuration.component.html           |  29 +-
 .../adapter-configuration.component.ts             |  57 +-
 .../adapter-settings.component.html}               |   0
 .../adapter-settings.component.scss}               |   0
 .../adapter-settings.component.ts}                 |  16 +-
 .../adapter-template-configuration.directive.ts    |  10 +-
 .../format-configuration.component.html            |  78 ---
 .../format-configuration.component.ts              | 131 ----
 .../format-item-json.component.html                |  28 -
 .../format-item-json.component.scss                |  46 --
 .../format-item-json/format-item-json.component.ts |  31 -
 .../format-item/format-item.component.html         |  30 -
 .../format-item/format-item.component.scss         |  46 --
 .../format-item/format-item.component.ts           |  62 --
 .../format-list/format-list.component.html         |  51 --
 .../format-list/format-list.component.scss         |  32 -
 .../format-list/format-list.component.ts           |  94 ---
 .../generic-adapter-configuration.component.html   | 101 ---
 .../generic-adapter-configuration.component.scss   |  21 -
 .../generic-adapter-configuration.component.ts     | 102 ---
 .../specific-adapter-configuration.component.scss  |  21 -
 .../start-adapter-configuration.component.ts       |   4 +-
 .../abstract-adapter-details.directive.ts          |   4 +-
 .../adapter-description.component.html             |  15 -
 .../adapter-description.component.ts               |  26 +-
 .../data-marketplace/data-marketplace.component.ts |  27 +-
 .../edit-adapter/edit-adapter.component.ts         |   4 +-
 .../existing-adapters.component.html               |  69 +-
 .../existing-adapters.component.ts                 |  33 +-
 .../filter-toolbar/filter-toolbar.component.html   |  12 -
 .../filter-toolbar/filter-toolbar.component.ts     |   1 -
 .../new-adapter/new-adapter.component.ts           |   6 +-
 ui/src/app/connect/connect.module.ts               |  16 +-
 .../adapter-started-dialog.component.html          |  20 +-
 .../adapter-started-dialog.component.ts            |  28 +-
 .../delete-adapter-dialog.component.ts             |   4 +-
 .../all-adapter-actions-dialog.component.ts        |  16 +-
 ui/src/app/connect/filter/adapter-filter.pipe.ts   |  31 +-
 ui/src/app/connect/services/connect.service.ts     | 134 +---
 ui/src/app/connect/services/rest.service.ts        |  23 +-
 .../static-alternatives.component.html             |   9 -
 .../pipeline-element-options.component.ts          |   1 -
 .../components/pipeline/pipeline.component.ts      |  26 +-
 ui/src/app/editor/constants/editor.constants.ts    |   2 -
 .../pipeline-element-discovery.component.ts        |   3 -
 ui/src/app/editor/model/editor.model.ts            |   3 -
 ui/src/app/editor/services/editor.service.ts       |  24 +-
 ui/src/app/editor/services/jsplumb.service.ts      |  74 +-
 ui/src/app/editor/utils/editor.utils.ts            |  16 +-
 .../monitoring/pipeline-monitoring.component.ts    |   2 -
 .../pipeline-element-statistics.component.ts       |   4 -
 826 files changed, 11458 insertions(+), 18926 deletions(-)
 copy {streampipes-extensions-api => streampipes-client-api}/pom.xml (67%)
 copy {streampipes-client => 
streampipes-client-api}/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
 (100%)
 copy 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/specific/SpecificAdapter.java
 => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IAdminApi.java
 (67%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/ICustomRequestApi.java
 (76%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataLakeMeasureApi.java
 (70%)
 create mode 100644 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataProcessorApi.java
 create mode 100644 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataSinkApi.java
 create mode 100644 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IDataStreamApi.java
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineApi.java
 => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IFileApi.java
 (82%)
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataSinkApi.java
 => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/INotificationsApi.java
 (87%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IPipelineApi.java
 (58%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IPipelineElementTemplateApi.java
 (67%)
 create mode 100644 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/IStreamPipesClient.java
 rename {streampipes-client/src/main/java/org/apache/streampipes/client => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api}/annotation/NotYetImplemented.java
 (94%)
 rename {streampipes-client/src/main/java/org/apache/streampipes/client/model 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config}/ClientConnectionConfigResolver.java
 (96%)
 rename {streampipes-client/src/main/java/org/apache/streampipes/client/model 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config}/ClientConnectionUrlResolver.java
 (88%)
 copy 
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/RunningPipelineElementStorage.java
 => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/config/IStreamPipesClientConfig.java
 (69%)
 rename {streampipes-client/src/main/java/org/apache/streampipes/client/model 
=> 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/constants}/InputStreamIndex.java
 (94%)
 copy {streampipes-client/src/main/java/org/apache/streampipes/client => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api}/credentials/CredentialsProvider.java
 (94%)
 copy {streampipes-client/src/main/java/org/apache/streampipes/client => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api}/live/EventProcessor.java
 (95%)
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataProcessorApi.java
 => 
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/live/IKafkaConfig.java
 (85%)
 delete mode 100644 
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineElementTemplateApi.java
 rename 
{streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/exception
 => 
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/connect}/AdapterException.java
 (94%)
 rename 
{streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/exception
 => 
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/connect}/ParseException.java
 (94%)
 delete mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/DataSetReplayFinishedNotifier.java
 rename 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/HashAlgorithm.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/config/IConfigExtractor.java
 (81%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/{Connector.java
 => AdapterOutputCollector.java} (92%)
 delete mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IAdapter.java
 copy 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/specific/SpecificAdapter.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IAdapterConfiguration.java
 (69%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/{EmitBinaryEvent.java
 => IEventCollector.java} (89%)
 delete mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IFormat.java
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/{Connector.java
 => IParserEventHandler.java} (81%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/{Connector.java
 => IPollingSettings.java} (88%)
 delete mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/IProtocol.java
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/{Connector.java
 => IPullAdapter.java} (76%)
 create mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/StreamPipesAdapter.java
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/context/IAdapterGuessSchemaContext.java
 (71%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/connect/context/IAdapterRuntimeContext.java
 (76%)
 delete mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/DataSetDeclarer.java
 delete mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/PipelineTemplateDeclarer.java
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/Protocol.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/extractor/IAdapterParameterExtractor.java
 (65%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventProcessingAgentDeclarer.java
 => extractor/IDataProcessorParameterExtractor.java} (77%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/extractor/IDataSinkParameterExtractor.java
 (79%)
 create mode 100644 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/extractor/IParameterExtractor.java
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/Declarer.java
 => extractor/IStaticPropertyExtractor.java} (79%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{connect/Connector.java
 => monitoring/IPipelineElementLogger.java} (85%)
 rename 
{streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api}/monitoring/SpMonitoringManager.java
 (98%)
 copy 
streampipes-extensions/streampipes-processors-aggregation-flink/src/main/java/org/apache/streampipes/processors/aggregation/flink/processor/rate/EventRate.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/IStreamPipesDataProcessor.java
 (52%)
 rename 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/EventSink.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/IStreamPipesDataSink.java
 (58%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/DataStreamDeclarer.java
 => pe/IStreamPipesDataStream.java} (78%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/IStreamPipesPipelineElement.java
 (76%)
 rename 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/Md5HashAlgorithm.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/config/IDataProcessorConfiguration.java
 (62%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventConsumerDeclarer.java
 => pe/config/IDataSinkConfiguration.java} (77%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/DataStreamDeclarer.java
 => pe/config/IDataStreamConfiguration.java} (77%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/InvocableDeclarer.java
 => pe/config/IPipelineElementConfiguration.java} (67%)
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataStreamApi.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/context/EventProcessorRuntimeContext.java
 (86%)
 rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/context/EventSinkRuntimeContext.java
 (93%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/context/IContextGenerator.java
 (75%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/Declarer.java
 => pe/context/RuntimeContext.java} (64%)
 rename 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/EventProcessorRuntimeContext.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IDataProcessorParameters.java
 (63%)
 copy 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventConsumerDeclarer.java
 => pe/param/IDataSinkParameters.java} (76%)
 copy 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/routing/SpOutputCollector.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IInternalRuntimeParameters.java
 (77%)
 rename 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/PipelineElement.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IParameterGenerator.java
 (71%)
 copy 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/RuntimeContext.java
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param/IPipelineElementParameters.java
 (56%)
 rename 
{streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param}/InputStreamParams.java
 (86%)
 rename 
{streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding
 => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe/param}/OutputStreamParams.java
 (93%)
 rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/PipelineElementCollector.java
 (95%)
 rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/RawDataProcessor.java
 (94%)
 rename {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/SpInputCollector.java
 (93%)
 copy {streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper => 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/pe}/routing/SpOutputCollector.java
 (94%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventProcessingAgentDeclarer.java
 => pe/runtime/IDataProcessorRuntime.java} (77%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/SemanticEventConsumerDeclarer.java
 => pe/runtime/IDataSinkRuntime.java} (78%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/InvocableDeclarer.java
 => pe/runtime/IStreamPipesRuntime.java} (66%)
 rename 
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/{declarer/Declarer.java
 => pe/runtime/IStreamPipesRuntimeProvider.java} (76%)
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterUtils.java
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/PullAdapterScheduler.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/Adapter.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/AdapterRegistry.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/GroundingService.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/csv/CsvFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/csv/CsvParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/geojson/GeoJsonFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/image/ImageFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/image/ImageParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/AbstractJsonFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/AbstractJsonParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/arraykey/JsonFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/arraykey/JsonParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/arraynokey/JsonArrayFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/arraynokey/JsonArrayParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/object/JsonObjectParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/xml/XmlFormat.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/format/xml/XmlParser.java
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{format/json/object/JsonObjectFormat.java
 => model/EventCollector.java} (52%)
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/GenericAdapter.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/GenericDataSetAdapter.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/GenericDataStreamAdapter.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/generic/Parser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/specific/SpecificDataSetAdapter.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/model/specific/SpecificDataStreamAdapter.java
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParser.java
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/ImageParser.java
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/JsonParsers.java
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{guess/SchemaGuesser.java
 => parser/ParserUtils.java} (57%)
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{model/specific/SpecificAdapter.java
 => parser/Parsers.java} (74%)
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{format/geojson
 => parser/json}/GeoJsonConstants.java (98%)
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{format/geojson
 => parser/json}/GeoJsonParser.java (60%)
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/JsonArrayKeyParser.java
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/JsonArrayParser.java
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{preprocessing/elements/DebugAdapterSink.java
 => parser/json/JsonObjectParser.java} (52%)
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/JsonParser.java
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{format
 => parser}/util/JsonEventProperty.java (92%)
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/{format
 => parser}/xml/XmlMapConverter.java (99%)
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/parser/xml/XmlParser.java
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/adapter/sdk/ParameterExtractor.java
 create mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/context/AdapterContextGenerator.java
 copy 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/RuntimeContext.java
 => 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/context/SpAdapterGuessSchemaContext.java
 (55%)
 copy 
streampipes-extensions/streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/urldereferencing/UrlDereferencingProgram.java
 => 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/context/SpAdapterRuntimeContext.java
 (60%)
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java 
=> 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init/IDeclarersSingleton.java
 (78%)
 delete mode 100644 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/init/RunningDatasetInstances.java
 rename 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/RuntimeContext.java
 => 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/util/RuntimeContextUtils.java
 (62%)
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/ConnectWorkerDescriptionProviderTest.java
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/GuessManagementTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/Utils.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/GroundingServiceTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/arraykey/JsonParserTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/arraynokey/JsonArrayParserTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/geojson/GeoJsonTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/object/JsonObjectParserTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/json/xml/XmlTest.java
 delete mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/format/xml/XmlMapConverterTest.java
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/CsvParserTest.java
 rename 
streampipes-extensions-management/src/{main/java/org/apache/streampipes/extensions/management/connect/adapter/util/AdapterOutputCollector.java
 => 
test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/ParserTest.java}
 (71%)
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/XmlParserTest.java
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/GeoJsonParserTest.java
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/JsonArrayKeyParserTest.java
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/JsonArrayParserTest.java
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/json/JsonObjectParsersTest.java
 rename 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/{connect/adapter/format/csv/CsvParserTest.java
 => init/DeclarersSingletonTest.java} (50%)
 create mode 100644 
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/model/SpServiceDefinitionBuilderTest.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/PullAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/PullRestAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/plc4x/passive/Plc4xPassiveAdapter.java
 create mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataSimulatorAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataStreamAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/set/FileProtocol.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/set/HttpProtocol.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/BrokerProtocol.java
 create mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/FileReplayAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/FileStreamProtocol.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpServerEventReceiver.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/PullProtocol.java
 create mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/pulsar/PulsarConfig.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.set/documentation.md
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.set/icon.png
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.set/strings.en
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.stream/documentation.md
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.stream/icon.png
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.stream/strings.en
 copy 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.protocol.stream.file
 => 
org.apache.streampipes.connect.iiot.adapters.simulator.machine.v2.file}/documentation.md
 (100%)
 rename 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.protocol.set.file
 => 
org.apache.streampipes.connect.iiot.adapters.simulator.machine.v2.file}/icon.png
 (100%)
 rename 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.protocol.set.file
 => 
org.apache.streampipes.connect.iiot.adapters.simulator.machine.v2.file}/strings.en
 (51%)
 copy 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.adapters.simulator.machine
 => 
org.apache.streampipes.connect.iiot.adapters.simulator.machine.v2}/documentation.md
 (100%)
 copy 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.adapters.simulator.machine
 => org.apache.streampipes.connect.iiot.adapters.simulator.machine.v2}/icon.png 
(100%)
 rename 
streampipes-extensions/{streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdataset
 => 
streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.simulator.machine.v2}/strings.en
 (72%)
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.file/documentation.md
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.http/documentation.md
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.http/icon.png
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.http/strings.en
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/PullAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/PullRestAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/set/ImageSetAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataSetAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataSimulator.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataSimulatorUtils.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/simulator/random/RandomDataStreamAdapter.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/config/ConfigKeys.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/config/ConnectWorkerConfig.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.set/documentation.md
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.set/icon.png
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.image.set/strings.en
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdataset/documentation.md
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.randomdataset/icon.png
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/UtilTest.java
 delete mode 100644 
streampipes-extensions/streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/protocol/set/HttpProtocolTest.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-aggregation-flink/src/main/java/org/apache/streampipes/processors/aggregation/flink/AbstractAggregationProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/AbstractEnricherProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/AbstractGeoProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-statistics-flink/src/main/java/org/apache/streampipes/processors/statistics/flink/AbstractStatisticsProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/AbstractTextMiningProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetection.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetectionController.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetectionParameters.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-text-mining-flink/src/main/java/org/apache/streampipes/processors/textmining/flink/processor/sentiment/SentimentDetectionProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasher.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasherController.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasherParameters.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/FieldHasherProgram.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/HashAlgorithmType.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/Sha1HashAlgorithm.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/hasher/algorithm/Sha2HashAlgorithm.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapper.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapperController.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapperParameters.java
 delete mode 100644 
streampipes-extensions/streampipes-processors-transformation-flink/src/main/java/org/apache/streampipes/processors/transformation/flink/processor/mapper/FieldMapperProgram.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/SpDataSet.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterSetDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/AdapterStreamDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/GenericAdapterDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/GenericAdapterSetDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/GenericAdapterStreamDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/SpecificAdapterSetDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/SpecificAdapterStreamDescription.java
 rename 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/{FormatDescription.java
 => ParserDescription.java} (51%)
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/ProtocolSetDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/grounding/ProtocolStreamDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/connect/rules/DebugSinkRuleDescription.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/message/DataSetModificationMessage.java
 delete mode 100644 
streampipes-model/src/main/java/org/apache/streampipes/model/runtime/DataSetStatusMessage.java
 delete mode 100644 
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/DataSetGroundingSelector.java
 delete mode 100644 
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/PipelineTemplateResource.java
 delete mode 100644 
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/connect/SourcesResource.java
 delete mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/DataSetBuilder.java
 create mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfiguration.java
 create mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilder.java
 delete mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/AdapterDescriptionBuilder.java
 delete mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/GenericDataStreamAdapterBuilder.java
 rename 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/{FormatDescriptionBuilder.java
 => ParserDescriptionBuilder.java} (64%)
 delete mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/ProtocolDescriptionBuilder.java
 delete mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/SpecificDataSetAdapterBuilder.java
 delete mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/adapter/SpecificDataStreamAdapterBuilder.java
 create mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/processor/DataProcessorConfiguration.java
 create mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/sink/DataSinkConfiguration.java
 create mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/builder/stream/DataStreamConfiguration.java
 create mode 100644 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/extractor/AdapterParameterExtractor.java
 create mode 100644 
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationBuilderTest.java
 rename 
streampipes-sdk/src/{main/java/org/apache/streampipes/sdk/builder/adapter/GenericDataSetAdapterBuilder.java
 => 
test/java/org/apache/streampipes/sdk/builder/adapter/AdapterConfigurationTest.java}
 (64%)
 delete mode 100644 
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/builder/adapter/GenericDataStreamAdapterBuilderTest.java
 create mode 100644 
streampipes-sdk/src/test/java/org/apache/streampipes/sdk/extractor/AdapterParameterExtractorTest.java
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/AdapterBackupWriter.java
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/AdapterMigration.java
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/CsvFormatMigrator.java
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
 (77%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/FormatMigrator.java
 (81%)
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/JsonFormatMigrator.java
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/XmlFormatMigrator.java
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator/AdapterMigrator.java
 (77%)
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator/GenericAdapterMigrator.java
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator/MigrationHelpers.java
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/SendToPipeline.java
 => 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator/SpecificAdapterMigrator.java
 (50%)
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/utils/AdapterMigrationUtils.java
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/credentials/CredentialsProvider.java
 => 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/utils/DocumentKeys.java
 (78%)
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/utils/FormatIds.java
 create mode 100644 
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/utils/GenericAdapterUtils.java
 create mode 100644 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataProcessorCompatProgram.java
 copy 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/{FlinkDataSinkDeclarer.java
 => FlinkDataProcessorProgram.java} (75%)
 copy 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/routing/SpOutputCollector.java
 => 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkCompatProgram.java
 (63%)
 rename 
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/AdapterSourceType.java
 => 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkDataSinkProgram.java
 (73%)
 rename 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ConfiguredEventProcessor.java
 => 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/FlinkRuntimeProvider.java
 (58%)
 copy 
streampipes-client/src/main/java/org/apache/streampipes/client/live/EventProcessor.java
 => 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IDataProcessorProgram.java
 (77%)
 rename 
streampipes-client/src/main/java/org/apache/streampipes/client/live/EventProcessor.java
 => 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IDataSinkProgram.java
 (79%)
 rename 
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/GetNEvents.java
 => 
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/IFlinkProgram.java
 (56%)
 rename 
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/{KafkaStreamsDataProcessorDeclarer.java
 => KafkaStreamRuntimeProvider.java} (58%)
 delete mode 100644 
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsDataSinkDeclarer.java
 create mode 100644 
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsOutputCollector.java
 delete mode 100644 
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/converter/MapToJsonFormat.java
 delete mode 100644 
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEventEngine.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/AbstractConfiguredPipelineElement.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ConfiguredExternalEventProcessor.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ConfiguredExternalEventSink.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ProcessorParams.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesExternalDataProcessor.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventProcessingDeclarer.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventProcessorDeclarerSingleton.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventSinkDeclarer.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneEventSinkDeclarerSingleton.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneExternalEventProcessingDeclarer.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/declarer/StandaloneExternalEventSinkDeclarer.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/runtime/StandaloneExternalEventProcessorRuntime.java
 delete mode 100644 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/runtime/StandaloneExternalEventSinkRuntime.java
 rename 
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/{ConfiguredEventSink.java
 => runtime/StandaloneStreamPipesRuntimeProvider.java} (57%)
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/generator/DataProcessorContextGenerator.java
 copy 
streampipes-wrapper-kafka-streams/src/main/java/org/apache/streampipes/wrapper/kafka/KafkaStreamsDataSinkRuntime.java
 => 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/context/generator/DataSinkContextGenerator.java
 (50%)
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/declarer/EventProcessorDeclarer.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/declarer/EventSinkDeclarer.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/declarer/PipelineElementDeclarer.java
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/DataProcessorParameters.java
 rename 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/{binding/EventSinkBindingParams.java
 => DataSinkParameters.java} (51%)
 rename 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/{routing/SpOutputCollector.java
 => params/InternalRuntimeParameters.java} (54%)
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/PipelineElementParameters.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding/BindingParams.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/binding/EventProcessorBindingParams.java
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/compat/ProcessorParams.java
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/compat/SinkParams.java
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/generator/DataProcessorParameterGenerator.java
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/generator/DataSinkParameterGenerator.java
 create mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/generator/PipelineElementParameterGenerator.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/runtime/EventProcessorRuntimeParams.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/runtime/EventSinkRuntimeParams.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/params/runtime/RuntimeParams.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/EventProcessor.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/ExternalEventProcessor.java
 delete mode 100644 
streampipes-wrapper/src/main/java/org/apache/streampipes/wrapper/runtime/ExternalEventSink.java
 rename ui/cypress/support/builder/{GenericAdapterBuilder.ts => 
AdapterBuilder.ts} (59%)
 delete mode 100644 ui/cypress/support/builder/ProcessorTestBuilder.ts
 delete mode 100644 ui/cypress/support/builder/SpecificAdapterBuilder.ts
 delete mode 100644 ui/cypress/support/model/GenericAdapterInput.ts
 delete mode 100644 ui/cypress/support/model/SpecificAdapterInput.ts
 rename 
ui/src/app/connect/components/adapter-configuration/{specific-adapter-configuration/specific-adapter-configuration.component.html
 => adapter-settings/adapter-settings.component.html} (100%)
 rename 
ui/src/app/connect/components/adapter-configuration/{format-configuration/format-configuration.component.scss
 => adapter-settings/adapter-settings.component.scss} (100%)
 rename 
ui/src/app/connect/components/adapter-configuration/{specific-adapter-configuration/specific-adapter-configuration.component.ts
 => adapter-settings/adapter-settings.component.ts} (86%)
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-configuration.component.html
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-configuration.component.ts
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-item-json/format-item-json.component.html
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-item-json/format-item-json.component.scss
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-item-json/format-item-json.component.ts
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-item/format-item.component.html
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-item/format-item.component.scss
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-item/format-item.component.ts
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-list/format-list.component.html
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-list/format-list.component.scss
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/format-configuration/format-list/format-list.component.ts
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/generic-adapter-configuration/generic-adapter-configuration.component.html
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/generic-adapter-configuration/generic-adapter-configuration.component.scss
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/generic-adapter-configuration/generic-adapter-configuration.component.ts
 delete mode 100644 
ui/src/app/connect/components/adapter-configuration/specific-adapter-configuration/specific-adapter-configuration.component.scss