[incubator-streampipes-extensions] branch dev updated (03728cd -> 1c93069)

[ze...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.


    from 03728cd  Merge pull request #31 from bossenti/improvement_opua
     new 868afa3  Cusum change detector with welford algorithm to estimate std online
     new 368a12f  Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into kafka-auth
     new 4245ad4  Kafka Sasl/Plain authentication for connect adapter and kafka-sink
     new 9eab86d  Use secretValue for password
     new d513698  Merge branch 'dev' of github.com:heymarco/incubator-streampipes-extensions into cusum
     new c8b77cb  Adapted Cusum
     new 868f57d  Changed strings
     new 2e4c15d  Added documentation
     new cb58be9  Merge branch 'cusum' of github.com:heymarco/incubator-streampipes-extensions into kafka-auth
     new cace087  Merge branch 'dev' into kafka-auth
     new 09a2fa6  Cleanup
     new 9cff6e0  Reimport alternatives
     new 8da08e1  Merge branch 'dev' into kafka-auth
     new acab439  Removed print statement
     new c658f37  Added license headers
     new 2f68e4a  Merge remote-tracking branch 'upstream/dev' into kafka-auth
     new 1c93069  Merge pull request #32 from heymarco/kafka-auth

The 1146 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:
 pom.xml                                            |   1 +
 .../connect/protocol/stream/KafkaConfig.java       |  42 +++++---
 .../connect/protocol/stream/KafkaProtocol.java     |  95 ++++++++++++++----
 .../connect/utils/KafkaConnectUtils.java           | 111 +++++++++++++++++++++
 .../strings.en                                     |  24 ++++-
 streampipes-pipeline-elements-all-jvm/pom.xml      |  12 +++
 .../pe/jvm/AllPipelineElementsInit.java            |   2 +
 .../documentation.md                               |   2 +-
 .../development/env                                |   4 +-
 .../pom.xml                                        |  57 +++++++++++
 .../jvm/ChangeDetectionJvmInit.java                |  36 ++++---
 .../jvm/config/ChangeDetectionJvmConfig.java       |  17 ++--
 .../changedetection}/jvm/config/ConfigKeys.java    |   2 +-
 .../changedetection/jvm/cusum/Cusum.java           | 104 +++++++++++++++++++
 .../changedetection/jvm/cusum/CusumController.java |  78 +++++++++++++++
 .../jvm/cusum/CusumEventFields.java                |  11 +-
 .../changedetection/jvm/cusum/CusumParameters.java |  23 +++--
 .../jvm/cusum/WelfordAggregate.java                |  43 ++++----
 .../documentation.md                               |  59 +++++++++++
 .../strings.en                                     |  11 ++
 .../sinks/brokers/jvm/kafka/KafkaController.java   |  45 +++++++--
 .../sinks/brokers/jvm/kafka/KafkaParameters.java   |  16 ++-
 .../sinks/brokers/jvm/kafka/KafkaPublisher.java    |  13 ++-
 .../strings.en                                     |  16 +++
 24 files changed, 713 insertions(+), 111 deletions(-)
 copy streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt/MqttParameters.java => streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/stream/KafkaConfig.java (53%)
 create mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/utils/KafkaConnectUtils.java
 copy {streampipes-processors-geo-jvm => streampipes-processors-change-detection-jvm}/development/env (96%)
 create mode 100644 streampipes-processors-change-detection-jvm/pom.xml
 copy streampipes-processors-geo-flink/src/main/java/org/apache/streampipes/processor/geo/flink/GeoFlinkInit.java => streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/ChangeDetectionJvmInit.java (58%)
 copy streampipes-processors-filters-jvm/src/main/java/org/apache/streampipes/processors/filters/jvm/config/FiltersJvmConfig.java => streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/config/ChangeDetectionJvmConfig.java (81%)
 copy {streampipes-processors-image-processing-jvm/src/main/java/org/apache/streampipes/processors/imageprocessing => streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection}/jvm/config/ConfigKeys.java (93%)
 create mode 100644 streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/Cusum.java
 create mode 100644 streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/CusumController.java
 copy streampipes-connect-adapters/src/test/java/org/apache/streampipes/connect/adapters/generic/Mock.java => streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/CusumEventFields.java (70%)
 copy streampipes-processors-enricher-jvm/src/main/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalParameters.java => streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/CusumParameters.java (60%)
 copy streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/Statement.java => streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/cusum/WelfordAggregate.java (50%)
 create mode 100644 streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.cusum/documentation.md
 create mode 100644 streampipes-processors-change-detection-jvm/src/main/resources/org.apache.streampipes.processors.changedetection.jvm.cusum/strings.en