This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 1612-migrate-transformation-jvm-processors
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 743c2dd2b Migrate data processors in transformation-jvm (#1612)
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 c4af15707 Merge branch 'dev' into
1612-migrate-transformation-jvm-processors
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 8 +
.../processors/enricher/jvm/EnricherJvmInit.java | 8 +-
.../enricher/jvm/processor/jseval/JSEval.java | 70 ---------
.../jvm/processor/jseval/JSEvalController.java | 61 --------
.../jvm/processor/jseval/JSEvalParameters.java | 35 -----
.../jvm/processor/jseval/JSEvalProcessor.java} | 67 +++++----
.../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 ----------
.../SentenceDetectionController.java | 74 ----------
.../SentenceDetectionParameters.java | 41 ------
.../SentenceDetectionProcessor.java} | 68 ++++++---
.../jvm/processor/tokenizer/Tokenizer.java | 76 ----------
.../processor/tokenizer/TokenizerParameters.java | 41 ------
...izerController.java => TokenizerProcessor.java} | 61 ++++++--
.../transformation/jvm/TransformationJvmInit.java | 12 +-
.../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 +++++++++++++++++++++
.../sinks/databases/jvm/DatabasesJvmInit.java | 20 +--
.../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 ++++++-----
.../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 +++++--
71 files changed, 1221 insertions(+), 3107 deletions(-)
delete mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEval.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
copy
streampipes-extensions/{streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessor.java
=>
streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalProcessor.java}
(57%)
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/SentenceDetectionController.java
delete mode 100644
streampipes-extensions/streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionParameters.java
copy
streampipes-extensions/{streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessor.java
=>
streampipes-processors-text-mining-jvm/src/main/java/org/apache/streampipes/processors/textmining/jvm/processor/sentencedetection/SentenceDetectionProcessor.java}
(57%)
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-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%)
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%)
