This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch remove-set-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from f7cf2600a [hotfix] Fix checkstyle
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 b2839e0dc Merge branch 'dev' into remove-set-adapters
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 8 +
pom.xml | 2 +-
.../processors/enricher/jvm/EnricherJvmInit.java | 8 +-
.../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 ++++-
.../textmining/jvm/TextMiningJvmInit.java | 24 +-
.../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 +++--
.../transformation/jvm/TransformationJvmInit.java | 52 ++--
.../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 | 16 +-
.../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/RestController.java | 64 -----
.../sinks/brokers/jvm/rest/RestParameters.java | 36 ---
.../jvm/rest/{RestPublisher.java => RestSink.java} | 59 +++--
.../sinks/databases/jvm/DatabasesJvmInit.java | 24 +-
.../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 ----
.../jvm/SinksNotificationsJvmInit.java | 16 +-
.../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 +++-
127 files changed, 2652 insertions(+), 5963 deletions(-)
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-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/RestController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rest/RestParameters.java
rename
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/rest/{RestPublisher.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%)
