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 5468a1db45583a017f8a55e523585c4f47be349e Merge: b04ae11e9 0a471ab7f Author: Philipp Zehnder <[email protected]> AuthorDate: Wed May 31 14:43:49 2023 +0200 Merge branch 'dev' into SP-1592 .asf.yaml | 8 + .../archetype-resources/src/main/java/Init.java | 4 +- .../archetype-resources/src/main/java/Init.java | 4 +- .../archetype-resources/src/main/java/Init.java | 4 +- pom.xml | 4 +- streampipes-client-python/setup.py | 6 +- .../strings.en | 4 - .../connectors/influx/InfluxConnectorsInit.java | 4 +- .../pe/flink/AllFlinkPipelineElementsInit.java | 4 +- .../pe/jvm/AllPipelineElementsInit.java | 4 +- .../aggregation/flink/AggregationFlinkInit.java | 4 +- .../jvm/ChangeDetectionJvmInit.java | 6 +- .../changedetection/jvm/cusum/Cusum.java | 105 -------- .../changedetection/jvm/cusum/CusumController.java | 84 ------- .../jvm/cusum/CusumEventFields.java | 29 --- .../changedetection/jvm/cusum/CusumParameters.java | 49 ---- .../jvm/cusum/WelfordAggregate.java | 60 ----- .../enricher/flink/EnricherFlinkInit.java | 4 +- .../processors/enricher/jvm/EnricherJvmInit.java | 12 +- .../jvm/processor/jseval/JSEvalController.java | 61 ----- .../jvm/processor/jseval/JSEvalParameters.java | 35 --- .../jseval/{JSEval.java => JSEvalProcessor.java} | 47 +++- .../jvm/processor/sizemeasure/SizeMeasure.java | 70 ------ .../sizemeasure/SizeMeasureParameters.java | 36 --- ...reController.java => SizeMeasureProcessor.java} | 58 ++++- .../processors/filters/jvm/FiltersJvmInit.java | 4 +- .../processors/siddhi/FiltersSiddhiInit.java | 14 +- .../processors/siddhi/filter/NumericalFilter.java | 85 ------- .../siddhi/filter/NumericalFilterParameters.java | 50 ---- ...er.java => NumericalFilterSiddhiProcessor.java} | 61 +++-- .../processors/siddhi/frequency/Frequency.java | 54 ----- .../siddhi/frequency/FrequencyParameters.java | 50 ---- ...ntroller.java => FrequencySiddhiProcessor.java} | 41 +++- .../siddhi/frequencychange/FrequencyChange.java | 54 ----- .../frequencychange/FrequencyChangeParameters.java | 61 ----- ...er.java => FrequencyChangeSiddhiProcessor.java} | 40 +++- .../processors/siddhi/sequence/Sequence.java | 57 ----- .../siddhi/sequence/SequenceParameters.java | 40 ---- ...ontroller.java => SequenceSiddhiProcessor.java} | 42 +++- .../processors/siddhi/stop/StreamStop.java | 60 ----- .../siddhi/stop/StreamStopParameters.java | 40 ---- ...troller.java => StreamStopSiddhiProcessor.java} | 41 +++- .../processors/siddhi/trend/TrendController.java | 91 ------- .../processors/siddhi/trend/TrendOperator.java | 13 +- .../processors/siddhi/trend/TrendParameters.java | 66 ------ .../trend/{Trend.java => TrendProcessor.java} | 105 +++++--- .../siddhi/trend/TestTrendProcessor.java | 31 ++- .../siddhi/trend/TrendConfigurationVisitor.java | 156 ++++++++++++ .../processor/geo/flink/GeoFlinkInit.java | 4 +- .../streampipes/processors/geo/jvm/GeoJvmInit.java | 4 +- .../jvm/ImageProcessingJvmInit.java | 4 +- .../detection/flink/PatternDetectionFlinkInit.java | 4 +- .../statistics/flink/StatisticsFlinkInit.java | 4 +- .../textmining/flink/TextMiningFlinkInit.java | 4 +- .../textmining/jvm/TextMiningJvmInit.java | 28 ++- .../textmining/jvm/processor/chunker/Chunker.java | 99 -------- .../jvm/processor/chunker/ChunkerParameters.java | 47 ---- ...hunkerController.java => ChunkerProcessor.java} | 79 ++++-- .../jvm/processor/language/LanguageDetection.java | 79 ------ .../language/LanguageDetectionParameters.java | 41 ---- ...roller.java => LanguageDetectionProcessor.java} | 65 +++-- .../jvm/processor/namefinder/NameFinder.java | 85 ------- .../processor/namefinder/NameFinderParameters.java | 42 ---- ...derController.java => NameFinderProcessor.java} | 85 ++++--- .../jvm/processor/partofspeech/PartOfSpeech.java | 81 ------- .../partofspeech/PartOfSpeechParameters.java | 42 ---- ...hController.java => PartOfSpeechProcessor.java} | 65 +++-- .../sentencedetection/SentenceDetection.java | 79 ------ .../SentenceDetectionParameters.java | 41 ---- ...roller.java => SentenceDetectionProcessor.java} | 64 +++-- .../jvm/processor/tokenizer/Tokenizer.java | 76 ------ .../processor/tokenizer/TokenizerParameters.java | 41 ---- ...izerController.java => TokenizerProcessor.java} | 61 +++-- .../flink/TransformationFlinkInit.java | 4 +- .../transformation/jvm/TransformationJvmInit.java | 56 ++--- .../jvm/processor/array/count/CountArray.java | 59 ----- .../array/count/CountArrayParameters.java | 37 --- ...rayController.java => CountArrayProcessor.java} | 39 ++- .../jvm/processor/array/split/SplitArray.java | 86 ------- .../array/split/SplitArrayParameters.java | 43 ---- ...rayController.java => SplitArrayProcessor.java} | 73 ++++-- .../booloperator/edge/SignalEdgeFilter.java | 120 ---------- .../edge/SignalEdgeFilterController.java | 85 ------- .../edge/SignalEdgeFilterParameters.java | 70 ------ .../edge/SignalEdgeFilterProcessor.java | 161 +++++++++++++ .../booloperator/state/BooleanToState.java | 70 ------ .../state/BooleanToStateParameters.java | 63 ----- ...ontroller.java => BooleanToStateProcessor.java} | 58 +++-- .../timekeeping/BooleanTimekeeping.java | 95 -------- .../timekeeping/BooleanTimekeepingParameters.java | 48 ---- ...oller.java => BooleanTimekeepingProcessor.java} | 81 +++++-- .../processor/booloperator/timer/BooleanTimer.java | 85 ------- .../booloperator/timer/BooleanTimerParameters.java | 48 ---- ...rController.java => BooleanTimerProcessor.java} | 61 ++++- .../csvmetadata/CsvMetadataEnrichment.java | 124 ---------- .../CsvMetadataEnrichmentParameters.java | 58 ----- ...er.java => CsvMetadataEnrichmentProcessor.java} | 121 ++++++++-- .../jvm/processor/state/buffer/StateBuffer.java | 93 -------- .../state/buffer/StateBufferParameters.java | 60 ----- ...erController.java => StateBufferProcessor.java} | 77 +++++- .../state/labeler/buffer/StateBufferLabeler.java | 88 ------- .../buffer/StateBufferLabelerParameters.java | 116 --------- ...oller.java => StateBufferLabelerProcessor.java} | 89 +++++-- .../state/labeler/model/StatementUtils.java | 12 +- .../state/labeler/number/NumberLabeler.java | 70 ------ .../labeler/number/NumberLabelerParameters.java | 80 ------- ...Controller.java => NumberLabelerProcessor.java} | 58 +++-- .../jvm/processor/task/TaskDuration.java | 79 ------ .../jvm/processor/task/TaskDurationParameters.java | 48 ---- ...nController.java => TaskDurationProcessor.java} | 69 +++++- .../timestampextractor/TimestampExtractor.java | 110 --------- .../TimestampExtractorParameters.java | 45 ---- ...oller.java => TimestampExtractorProcessor.java} | 96 ++++++-- .../transformtoboolean/TransformToBoolean.java | 80 ------- .../TransformToBooleanParameters.java | 37 --- ...oller.java => TransformToBooleanProcessor.java} | 75 ++++-- .../value/change/ChangedValueDetection.java | 61 ----- .../change/ChangedValueDetectionParameters.java | 41 ---- ...er.java => ChangedValueDetectionProcessor.java} | 45 +++- .../value/duration/CalculateDuration.java | 71 ------ .../duration/CalculateDurationParameters.java | 57 ----- ...roller.java => CalculateDurationProcessor.java} | 54 +++-- .../sinks/brokers/jvm/BrokersJvmInit.java | 20 +- .../sinks/brokers/jvm/bufferrest/BufferRest.java | 84 ------- .../jvm/bufferrest/BufferRestParameters.java | 51 ---- ...ontroller.java => BufferRestPublisherSink.java} | 68 +++++- .../sinks/brokers/jvm/jms/JmsParameters.java | 48 ---- .../sinks/brokers/jvm/jms/JmsPublisher.java | 70 ------ .../{JmsController.java => JmsPublisherSink.java} | 61 +++-- .../sinks/brokers/jvm/nats/NatsController.java | 76 ++++-- .../sinks/brokers/jvm/nats/NatsParameters.java | 38 --- .../sinks/brokers/jvm/nats/NatsPublisher.java | 83 ------- .../brokers/jvm/rabbitmq/RabbitMqConsumer.java | 69 ------ .../brokers/jvm/rabbitmq/RabbitMqController.java | 110 --------- .../brokers/jvm/rabbitmq/RabbitMqParameters.java | 8 +- .../jvm/rabbitmq/RabbitMqPublisherSink.java | 115 +++++++++ .../sinks/brokers/jvm/rest/RestParameters.java | 36 --- .../sinks/brokers/jvm/rest/RestPublisher.java | 71 ------ .../rest/{RestController.java => RestSink.java} | 56 ++++- .../sinks/databases/flink/DatabasesFlinkInit.java | 4 +- .../sinks/databases/jvm/DatabasesJvmInit.java | 28 ++- .../sinks/databases/jvm/couchdb/CouchDb.java | 59 ----- .../databases/jvm/couchdb/CouchDbParameters.java | 61 ----- .../{CouchDbController.java => CouchDbSink.java} | 43 +++- .../sinks/databases/jvm/ditto/DittoController.java | 81 ------- .../sinks/databases/jvm/ditto/DittoParameters.java | 75 ------ .../jvm/ditto/{Ditto.java => DittoSink.java} | 62 ++++- .../sinks/databases/jvm/iotdb/IotDbController.java | 80 ------- .../sinks/databases/jvm/iotdb/IotDbParameters.java | 87 ------- .../jvm/iotdb/{IotDb.java => IotDbSink.java} | 76 +++++- .../sinks/databases/jvm/opcua/OpcUa.java | 47 ++-- .../sinks/databases/jvm/opcua/OpcUaParameters.java | 67 ++---- .../opcua/{UpcUaController.java => OpcUaSink.java} | 33 ++- .../sinks/databases/jvm/postgresql/PostgreSql.java | 9 +- .../jvm/postgresql/PostgreSqlParameters.java | 3 - ...stgreSqlController.java => PostgreSqlSink.java} | 82 ++++--- .../sinks/databases/jvm/redis/Redis.java | 264 +++++++++++---------- .../sinks/databases/jvm/redis/RedisParameters.java | 234 +++++++++--------- .../redis/{RedisController.java => RedisSink.java} | 232 ++++++++++-------- .../databases/jvm/iotdb/TestIotDbParameters.java | 52 ---- .../sinks/internal/jvm/SinksInternalJvmInit.java | 4 +- .../jvm/SinksNotificationsJvmInit.java | 26 +- .../notifications/jvm/email/EmailParameters.java | 58 ----- .../notifications/jvm/email/EmailPublisher.java | 74 ------ .../email/{EmailController.java => EmailSink.java} | 62 ++++- .../jvm/onesignal/OneSignalController.java | 69 ------ .../jvm/onesignal/OneSignalParameters.java | 49 ---- .../{OneSignalProducer.java => OneSignalSink.java} | 47 +++- .../notifications/jvm/slack/SlackNotification.java | 99 -------- .../jvm/slack/SlackNotificationController.java | 76 ------ .../jvm/slack/SlackNotificationParameters.java | 58 ----- .../jvm/slack/SlackNotificationSink.java | 142 +++++++++++ .../jvm/telegram/TelegramController.java | 65 ----- .../jvm/telegram/TelegramParameters.java | 52 ---- .../{TelegramPublisher.java => TelegramSink.java} | 52 +++- streampipes-wrapper-python/README.md | 91 +------ streampipes-wrapper-python/setup.py | 1 + streampipes-wrapper-python/streampipes/api/rest.py | 2 + streampipes-wrapper-python/streampipes/core.py | 3 + streampipes-wrapper-python/streampipes/declarer.py | 4 +- .../streampipes/instances.py | 7 +- streampipes-wrapper-python/streampipes/manager.py | 2 + .../model/base/abstract_streampipes_entity.py | 3 + .../model/base/consumable_streampipes_entity.py | 3 + .../model/base/named_streampipes_entity.py | 3 + .../model/base/unnamed_streampipes_entity.py | 4 + .../streampipes/model/config_item.py | 2 + .../model/graph/data_processor_description.py | 2 + .../streampipes/model/pipeline_element_config.py | 2 + .../staticproperty/free_text_StaticProperty.py | 5 +- .../model/staticproperty/static_property.py | 3 + .../streampipes/submitter.py | 3 +- .../streampipes/utils/register.py | 2 + ui/cypress/support/utils/datalake/DataLakeUtils.ts | 40 +++- ui/cypress/tests/datalake/widgets/table.ts | 2 +- ui/package-lock.json | 12 +- 196 files changed, 3277 insertions(+), 7237 deletions(-) diff --cc streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/strings.en index 4032dd1d9,845edef5c..48fbfa95e --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/strings.en +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar/strings.en @@@ -28,7 -28,5 +28,3 @@@ pulsar-broker-port.description=Example pulsar-topic.title=Topic pulsar-topic.description=Example: test.topic --pulsar-subscription-name.title=Subscription Name - pulsar-subscription-name.description= - - -pulsar-subscription-name.description=Example: my-sub
