This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit 68f917e7c88a079d1df07c5fd47a63f9f1d5af73 Merge: d91ed20 da1afa4 Author: bossenti <[email protected]> AuthorDate: Wed Feb 17 14:55:30 2021 +0100 Merge remote-tracking branch 'origin/dev' into dev .../streampipes/connect/ConnectAdapterInit.java | 7 +- .../protocol/stream/HttpServerEventReceiver.java | 40 ++--- .../protocol/stream/HttpServerProtocol.java | 173 +++++++++++++++++++++ .../documentation.md | 27 +--- .../icon.png | Bin 0 -> 17467 bytes .../strings.en | 30 ++++ .../extensions/all/jvm/AllExtensionsInit.java | 6 +- .../pe/jvm/AllPipelineElementsInit.java | 6 +- .../processors/siddhi/FiltersSiddhiInit.java | 4 +- .../processors/siddhi/count/CountAggregation.java | 36 +++-- .../processors/siddhi/filter/NumericalFilter.java | 38 +++-- .../processors/siddhi/frequency/Frequency.java | 33 ++-- .../siddhi/frequencychange/FrequencyChange.java | 22 ++- .../siddhi/listcollector/ListCollector.java | 58 +++---- .../processors/siddhi/listfilter/ListFilter.java | 30 ++-- .../processors/siddhi/sequence/Sequence.java | 33 ++-- .../processors/siddhi/stop/StreamStop.java | 27 +++- .../streampipes/processors/siddhi/topk/TopK.java | 121 ++++++++++++++ .../streampipes/processors/siddhi/trend/Trend.java | 28 +++- .../documentation.md | 21 +-- .../strings.en | 17 ++ .../siddhi/trend/TestTrendProcessor.java | 15 +- streampipes-sinks-brokers-jvm/pom.xml | 4 + .../sinks/brokers/jvm/BrokersJvmInit.java | 6 +- .../sinks/brokers/jvm/mqtt/MqttClient.java | 163 +++++++++++++++++++ .../sinks/brokers/jvm/mqtt/MqttController.java | 78 ---------- .../sinks/brokers/jvm/mqtt/MqttPublisher.java | 86 ---------- .../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 149 ++++++++++++++++++ .../sinks/brokers/jvm/mqtt/common/MqttOptions.java | 162 +++++++++++++++++++ .../sinks/brokers/jvm/mqtt/common/MqttUtils.java | 68 ++++++++ .../sinks/brokers/jvm/websocket/SocketServer.java | 72 +++++++++ .../brokers/jvm/websocket/WebsocketServerSink.java | 77 +++++++++ .../documentation.md | 2 +- .../strings.en | 77 +++++++-- .../documentation.md | 21 +-- .../strings.en | 5 + .../jvm/dashboard/DashboardController.java | 6 +- .../vehicle/simulator/VehicleSimulatorInit.java | 4 +- .../vehicle/simulator/vehicle/VehicleSource.java | 42 ----- .../simulator/vehicle/streams/VehicleStream.java | 3 +- .../simulator/WatertankSimulatorInit.java | 8 +- .../simulator/watertank/WaterTankSource.java | 45 ------ .../watertank/streams/FlowRate1Stream.java | 5 +- .../watertank/streams/FlowRate2Stream.java | 3 +- .../watertank/streams/PressureTankStream.java | 3 +- .../watertank/streams/WaterLevel1Stream.java | 3 +- .../watertank/streams/WaterLevel2Stream.java | 5 +- 47 files changed, 1389 insertions(+), 480 deletions(-)
