This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch SP-1592
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from b04ae11e9 [#1592] Add first version for an io link adapter
add a432b9db7 add sample configuration of pulsar subscription-name (#1589)
add f564e07db Bump pytest-cov from 4.0.0 to 4.1.0 in
/streampipes-client-python (#1591)
add 8387080a9 [#1583] Remove deprecated processor Cusum (#1586)
add d902dcb41 Migrate JsEval and SizeMeasure processors (#1598)(#1599)
(#1600)
add 1750704e6 dd custom subjects for discussions (#1616)
add 7464ef1a0 Merge pull request #1617 from
apache/1616-modify-asfyaml-to-better-organize-github-discussions-on-mailing-list
add c2122f8a7 Migrate text mining processors (#1601) (#1602)
add 24820925c Migrate count array, split array and signal edge filters
(#1608)(#1609)(#1610) (#1611)
add 09488d862 Migrate data sinks in databases-jvm module (#1618) (#1619)
add 86675e1d7 Migrate data sinks in notifications-jvm module (#1620)
(#1621)
add 956df5d09 Bump postgresql from 42.4.3 to 42.6.0 (#1578)
add 58fbb1412 Migrate data processors in transformation-jvm (#1612) (#1613)
add 4ae1f863e Migrate data sinks in brokers-jvm module (#1614) (#1615)
add 2e29e3770 Migrate Redis Sink in databases-jvm (#1622)
add 4fcc17fc5 Bump socket.io-parser from 4.2.1 to 4.2.3 in /ui (#1587)
add d072af709 Migrate processors in siddhi module (#1624) (#1625)
add bed05dd73 chore: mark streampipes-wrapper-python as deprecated (#1623)
add 3ac670bc5 Bump types-requests in /streampipes-client-python (#1588)
add b15ed1023 Bump mkdocstrings[python] in /streampipes-client-python
(#1631)
add 36ee46f2a chore: add missing support of NATS as messaging protocol
(#1628)
add 77a34d567 Bump spring-boot.version from 3.0.6 to 3.1.0 (#1595)
add 0a471ab7f [hotfix] Add proper time selection to another cypress test
(#1641)
new 5468a1db4 Merge branch 'dev' into SP-1592
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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(-)
delete mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/Cusum.java
delete mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/CusumController.java
delete mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/CusumEventFields.java
delete mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/CusumParameters.java
delete mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/WelfordAggregate.java
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalController.java
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalParameters.java
rename
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/{JSEval.java
=> JSEvalProcessor.java} (54%)
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/SizeMeasure.java
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/SizeMeasureParameters.java
rename
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/sizemeasure/{SizeMeasureController.java
=> SizeMeasureProcessor.java} (60%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalFilter.java
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/NumericalFilterParameters.java
rename
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/filter/{NumericalFilterController.java
=> NumericalFilterSiddhiProcessor.java} (57%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/Frequency.java
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/FrequencyParameters.java
rename
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequency/{FrequencyController.java
=> FrequencySiddhiProcessor.java} (59%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/FrequencyChange.java
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/FrequencyChangeParameters.java
rename
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/frequencychange/{FrequencyChangeController.java
=> FrequencyChangeSiddhiProcessor.java} (61%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/Sequence.java
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/SequenceParameters.java
rename
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/sequence/{SequenceController.java
=> SequenceSiddhiProcessor.java} (58%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/StreamStop.java
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/StreamStopParameters.java
rename
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/stop/{StreamStopController.java
=> StreamStopSiddhiProcessor.java} (59%)
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/TrendController.java
delete mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/TrendParameters.java
rename
streampipes-extensions/streampipes-processors-filters-siddhi/src/main/java/org/apache/streampipes/processors/siddhi/trend/{Trend.java
=> TrendProcessor.java} (55%)
create mode 100644
streampipes-extensions/streampipes-processors-filters-siddhi/src/test/java/org/apache/streampipes/processors/siddhi/trend/TrendConfigurationVisitor.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/Chunker.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/ChunkerParameters.java
rename
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/chunker/{ChunkerController.java
=> ChunkerProcessor.java} (54%)
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/LanguageDetection.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/LanguageDetectionParameters.java
rename
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/language/{LanguageDetectionController.java
=> LanguageDetectionProcessor.java} (56%)
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/NameFinder.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/NameFinderParameters.java
rename
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/namefinder/{NameFinderController.java
=> NameFinderProcessor.java} (52%)
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/PartOfSpeech.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/PartOfSpeechParameters.java
rename
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/partofspeech/{PartOfSpeechController.java
=> PartOfSpeechProcessor.java} (58%)
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetection.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionParameters.java
rename
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/{SentenceDetectionController.java
=> SentenceDetectionProcessor.java} (54%)
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/Tokenizer.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/TokenizerParameters.java
rename
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/tokenizer/{TokenizerController.java
=> TokenizerProcessor.java} (58%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArray.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/{CountArrayController.java
=> CountArrayProcessor.java} (65%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArray.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArrayParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/{SplitArrayController.java
=> SplitArrayProcessor.java} (66%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilter.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterController.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterParameters.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessor.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToState.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/BooleanToStateParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/state/{BooleanToStateController.java
=> BooleanToStateProcessor.java} (70%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/BooleanTimekeeping.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/BooleanTimekeepingParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timekeeping/{BooleanTimekeepingController.java
=> BooleanTimekeepingProcessor.java} (61%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/BooleanTimer.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/BooleanTimerParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/timer/{BooleanTimerController.java
=> BooleanTimerProcessor.java} (67%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/CsvMetadataEnrichment.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/CsvMetadataEnrichmentParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/csvmetadata/{CsvMetadataEnrichmentController.java
=> CsvMetadataEnrichmentProcessor.java} (65%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBuffer.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/StateBufferParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/buffer/{StateBufferController.java
=> StateBufferProcessor.java} (54%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabeler.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/StateBufferLabelerParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/buffer/{StateBufferLabelerController.java
=> StateBufferLabelerProcessor.java} (70%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabeler.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/NumberLabelerParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/number/{NumberLabelerController.java
=> NumberLabelerProcessor.java} (76%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/TaskDuration.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/TaskDurationParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/task/{TaskDurationController.java
=> TaskDurationProcessor.java} (61%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractor.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/TimestampExtractorParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/{TimestampExtractorController.java
=> TimestampExtractorProcessor.java} (63%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBoolean.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/TransformToBooleanParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/transformtoboolean/{TransformToBooleanController.java
=> TransformToBooleanProcessor.java} (67%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetection.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/ChangedValueDetectionParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/change/{ChangedValueDetectionController.java
=> ChangedValueDetectionProcessor.java} (61%)
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDuration.java
delete mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/CalculateDurationParameters.java
rename
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/value/duration/{CalculateDurationController.java
=> CalculateDurationProcessor.java} (61%)
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/bufferrest/BufferRest.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/bufferrest/BufferRestParameters.java
rename
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/bufferrest/{BufferRestController.java
=> BufferRestPublisherSink.java} (50%)
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/jms/JmsParameters.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/jms/JmsPublisher.java
rename
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/jms/{JmsController.java
=> JmsPublisherSink.java} (57%)
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsParameters.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsPublisher.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rabbitmq/RabbitMqConsumer.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rabbitmq/RabbitMqController.java
create mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rabbitmq/RabbitMqPublisherSink.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rest/RestParameters.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rest/RestPublisher.java
rename
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rest/{RestController.java
=> RestSink.java} (51%)
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/couchdb/CouchDb.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/couchdb/CouchDbParameters.java
rename
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/couchdb/{CouchDbController.java
=> CouchDbSink.java} (70%)
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/ditto/DittoController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/ditto/DittoParameters.java
rename
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/ditto/{Ditto.java
=> DittoSink.java} (60%)
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/iotdb/IotDbController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/iotdb/IotDbParameters.java
rename
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/iotdb/{IotDb.java
=> IotDbSink.java} (55%)
rename
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/opcua/{UpcUaController.java
=> OpcUaSink.java} (79%)
rename
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/{PostgreSqlController.java
=> PostgreSqlSink.java} (58%)
rename
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/redis/{RedisController.java
=> RedisSink.java} (82%)
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/test/java/org/apache/streampipes/sinks/databases/jvm/iotdb/TestIotDbParameters.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/email/EmailParameters.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/email/EmailPublisher.java
rename
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/email/{EmailController.java
=> EmailSink.java} (56%)
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/onesignal/OneSignalController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/onesignal/OneSignalParameters.java
rename
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/onesignal/{OneSignalProducer.java
=> OneSignalSink.java} (56%)
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/slack/SlackNotification.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/slack/SlackNotificationController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/slack/SlackNotificationParameters.java
create mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/slack/SlackNotificationSink.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/telegram/TelegramController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/telegram/TelegramParameters.java
rename
streampipes-extensions/streampipes-sinks-notifications-jvm/src/main/java/org/apache/streampipes/sinks/notifications/jvm/telegram/{TelegramPublisher.java
=> TelegramSink.java} (62%)
