This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch SP-1592 in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 2ceb7ac84d1a693fd518edee144e299118c1dccc Merge: 5468a1db4 1cb22eb9d Author: Philipp Zehnder <[email protected]> AuthorDate: Fri Jun 2 15:26:45 2023 +0200 Merge branch 'remove-set-adapters' into SP-1592 .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 | 19 +- .../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 + .../management/management/GuessManagement.java | 10 +- .../dataexplorer/commons/DataExplorerUtils.java | 10 +- .../dataexplorer/commons/TimeSeriesStore.java | 4 +- .../export/resolver/AdapterResolver.java | 10 +- streampipes-extensions-api/pom.xml | 12 +- .../api/DataSetReplayFinishedNotifier.java | 23 -- .../extensions/api/config/IConfigExtractor.java | 9 +- .../api/connect}/AdapterOutputCollector.java | 2 +- .../api/connect/IAdapterConfiguration.java | 16 +- .../extensions/api/connect}/IEventCollector.java | 2 +- .../extensions/api/connect}/IParser.java | 6 +- .../api/connect/IParserEventHandler.java | 6 +- .../extensions/api/connect/StreamPipesAdapter.java | 15 +- .../context/IAdapterGuessSchemaContext.java | 10 +- .../connect}/context/IAdapterRuntimeContext.java | 4 +- .../api/declarer/PipelineTemplateDeclarer.java | 25 -- .../api}/extractor/IAdapterParameterExtractor.java | 6 +- .../IDataProcessorParameterExtractor.java} | 10 +- .../api/extractor/IDataSinkParameterExtractor.java | 10 +- .../api/extractor/IParameterExtractor.java | 119 ++++++++ .../IStaticPropertyExtractor.java} | 10 +- .../api/monitoring/IPipelineElementLogger.java | 6 +- .../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 +- .../extensions/api/pe/context/RuntimeContext.java | 16 +- .../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 | 48 +-- .../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 +- ...StreamPipesClientRuntimeConnectionResolver.java | 4 +- .../management/config/ConfigExtractor.java | 6 +- .../connect/AdapterWorkerManagement.java | 15 +- .../connect/ConnectWorkerDescriptionProvider.java | 3 +- .../management/connect/GuessManagement.java | 2 +- .../management/connect/PullAdapterScheduler.java | 30 +- .../management/connect/RuntimeResovable.java | 5 +- .../connect/adapter/model/EventCollector.java | 2 +- .../connect/adapter/parser/CsvParser.java | 8 +- .../connect/adapter/parser/ImageParser.java | 6 +- .../connect/adapter/parser/JsonParsers.java | 10 +- .../management/connect/adapter/parser/Parsers.java | 2 +- .../connect/adapter/parser/json/GeoJsonParser.java | 4 +- .../adapter/parser/json/JsonArrayKeyParser.java | 4 +- .../adapter/parser/json/JsonArrayParser.java | 4 +- .../adapter/parser/json/JsonObjectParser.java | 4 +- .../connect/adapter/parser/json/JsonParser.java | 4 +- .../connect/adapter/parser/xml/XmlParser.java | 6 +- .../elements/SendToBrokerAdapterSink.java | 2 +- .../context/AdapterContextGenerator.java | 18 +- .../context/SpAdapterGuessSchemaContext.java | 1 + .../context/SpAdapterRuntimeContext.java | 3 +- .../management/init/DeclarersSingleton.java | 120 ++++---- .../management/init/IDeclarersSingleton.java | 4 +- .../management/init/RunningAdapterInstances.java | 10 +- .../management/init/RunningInstances.java | 15 +- .../management/model/SpServiceDefinition.java | 44 ++- .../model/SpServiceDefinitionBuilder.java | 18 +- .../management/util/RuntimeContextUtils.java | 31 +- .../management/util/ServiceDefinitionUtil.java | 13 +- .../connect/AdapterWorkerManagementTest.java | 2 +- .../ConnectWorkerDescriptionProviderTest.java | 11 +- .../connect/adapter/parser/CsvParserTest.java | 10 +- .../connect/adapter/parser/XmlParserTest.java | 6 +- .../adapter/parser/json/GeoJsonParserTest.java | 6 +- .../parser/json/JsonArrayKeyParserTest.java | 8 +- .../adapter/parser/json/JsonArrayParserTest.java | 6 +- .../adapter/parser/json/JsonObjectParsersTest.java | 12 +- .../management/init/DeclarersSingletonTest.java | 8 +- .../model/SpServiceDefinitionBuilderTest.java | 16 +- .../streampipes-connect-adapters-iiot/pom.xml | 5 + .../connect/iiot/adapters/opcua/OpcUaAdapter.java | 26 +- .../opcua/configuration/SpOpcUaConfigBuilder.java | 4 +- .../iiot/adapters/opcua/utils/OpcUaUtil.java | 6 +- .../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 23 +- .../plc4x/passive/Plc4xPassiveAdapter.java | 101 ------- .../iiot/adapters/plc4x/s7/Plc4xS7Adapter.java | 23 +- .../iiot/adapters/ros/RosBridgeAdapter.java | 24 +- .../simulator/machine/MachineDataSimulator.java | 2 +- .../machine/MachineDataSimulatorAdapter.java | 19 +- .../iiot/protocol/stream/BrokerEventProcessor.java | 4 +- .../iiot/protocol/stream/FileReplayAdapter.java | 18 +- .../iiot/protocol/stream/HttpServerProtocol.java | 55 ++-- .../iiot/protocol/stream/HttpStreamProtocol.java | 24 +- .../iiot/protocol/stream/KafkaProtocol.java | 25 +- .../connect/iiot/protocol/stream/MqttProtocol.java | 22 +- .../connect/iiot/protocol/stream/NatsProtocol.java | 22 +- .../iiot/protocol/stream/TubeMQProtocol.java | 27 +- .../iiot/protocol/stream/pulsar/PulsarConfig.java | 4 +- .../protocol/stream/pulsar/PulsarProtocol.java | 24 +- .../protocol/stream/rocketmq/RocketMQProtocol.java | 22 +- .../strings.en | 2 + .../streampipes/connect/ConnectAdapterInit.java | 31 +- .../streampipes/connect/adapters/PullAdapter.java | 90 ------ .../connect/adapters/PullRestAdapter.java | 67 ----- .../adapters/coindesk/CoindeskBitcoinAdapter.java | 218 ++++++++------ .../connect/adapters/flic/FlicMQTTAdapter.java | 196 ++++++------- .../connect/adapters/image/ImageZipAdapter.java | 143 ++++----- .../adapters/image/stream/ImageStreamAdapter.java | 118 ++++---- .../connect/adapters/iss/IssAdapter.java | 221 +++++++------- .../connect/adapters/netio/NetioMQTTAdapter.java | 231 +++++++-------- .../connect/adapters/netio/NetioRestAdapter.java | 325 ++++++++++----------- .../connect/adapters/slack/SlackAdapter.java | 145 ++++----- .../connect/adapters/slack/SlackConsumer.java | 13 +- .../connect/adapters/ti/TISensorTag.java | 325 ++++++++++----------- .../adapters/wikipedia/WikipediaAdapter.java | 241 +++++++-------- .../wikipedia/WikipediaEditedArticlesAdapter.java | 58 ++-- .../wikipedia/WikipediaModelConverter.java | 82 ++++-- .../wikipedia/WikipediaNewArticlesAdapter.java | 59 ++-- .../adapters/wikipedia/WikipediaSseConsumer.java | 2 +- .../streampipes/connect/config/ConfigKeys.java | 31 -- .../connect/config/ConnectWorkerConfig.java | 81 ----- .../influx/adapter/InfluxDbStreamAdapter.java | 28 +- .../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 - .../integration/adapters/AdapterTesterBase.java | 14 +- .../integration/adapters/MqttAdapterTester.java | 10 +- .../integration/adapters/PulsarAdapterTester.java | 10 +- .../connect/grounding/ProtocolDescription.java | 2 +- .../model/message/DataSetModificationMessage.java | 51 ---- .../apache/streampipes/model/message/Message.java | 1 - .../model/runtime/DataSetStatusMessage.java | 66 ----- .../model/template/PipelineTemplateInvocation.java | 12 +- .../PipelineTemplateInvocationGenerator.java | 2 +- .../PipelineTemplateInvocationHandler.java | 2 +- .../AbstractPipelineElementResource.java | 12 +- .../extensions/html/page/WelcomePageGenerator.java | 52 ++-- .../extensions/monitoring/MonitoringResource.java | 2 +- .../pe/DataProcessorPipelineElementResource.java | 34 ++- .../pe/DataSinkPipelineElementResource.java | 33 ++- .../pe/DataStreamPipelineElementResource.java | 8 +- .../pe/InvocablePipelineElementResource.java | 72 ++--- .../extensions/pe/PipelineTemplateResource.java | 35 --- .../rest/impl/PipelineElementRuntimeInfo.java | 2 - streampipes-sdk/pom.xml | 5 + .../sdk/builder}/adapter/AdapterConfiguration.java | 37 ++- .../adapter/AdapterConfigurationBuilder.java | 17 +- .../processor/DataProcessorConfiguration.java | 52 ++++ .../sdk/builder/sink/DataSinkConfiguration.java | 52 ++++ .../builder/stream/DataStreamConfiguration.java | 52 ++++ .../sdk/extractor/AbstractParameterExtractor.java | 52 +++- .../sdk/extractor/AdapterParameterExtractor.java | 3 +- .../sdk/extractor/DataSinkParameterExtractor.java | 7 +- .../ProcessingElementParameterExtractor.java | 6 +- .../sdk/extractor/StaticPropertyExtractor.java | 4 +- .../adapter/AdapterConfigurationBuilderTest.java | 14 +- .../builder}/adapter/AdapterConfigurationTest.java | 8 +- .../extractor/AdapterParameterExtractorTest.java | 6 +- .../extensions/ExtensionsResourceConfig.java | 2 - .../service/extensions/ServiceTagProvider.java | 9 +- .../function/StreamPipesFunctionHandler.java | 14 +- .../sources/AbstractAdapterIncludedStream.java | 17 +- .../sources/AbstractAlreadyExistingStream.java | 25 +- .../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 ++- ...SinkDeclarer.java => FlinkDataSinkProgram.java} | 11 +- .../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 +- ...taProcessorDeclarer.java => IFlinkProgram.java} | 19 +- .../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 +- .../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 | 25 +- .../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 +++- ui/cypress/support/builder/AdapterBuilder.ts | 1 - ui/cypress/support/utils/PipelineUtils.ts | 8 - ui/deployment/modules.yml | 2 +- .../src/lib/model/gen/streampipes-model.ts | 87 ++---- ui/src/app/editor/services/editor.service.ts | 1 - 532 files changed, 5459 insertions(+), 6757 deletions(-)
