This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit d42552c82824bf67c5e447fb4c18b6d7fac03b5a Merge: 44b7dd1 0ebbb18 Author: Philipp Zehnder <[email protected]> AuthorDate: Tue Oct 27 22:08:24 2020 +0100 Merge tag 'release/0.67.0' [maven-release-plugin] copy for tag release/0.67.0 .github/PULL_REQUEST_TEMPLATE.md | 53 +++ .github/workflows/build.yml | 29 +- .gitignore | 5 +- .../all_pipeline_elements_flink.xml | 15 + .../all_pipeline_elements_jvm.xml | 21 ++ .idea/runConfigurations/connect_adapters.xml | 17 + .../processors_aggregation_flink.xml | 15 + .../processors_enricher_flink.xml | 15 + .../runConfigurations/processors_enricher_jvm.xml | 14 + .idea/runConfigurations/processors_filters_jvm.xml | 14 + .../processors_filters_siddhi.xml | 14 + .idea/runConfigurations/processors_geo_flink.xml | 15 + .idea/runConfigurations/processors_geo_jvm.xml | 14 + .../processors_imageprocessing_jvm.xml | 14 + .../processors_pattern_detection_flink.xml | 15 + .../processors_statistics_flink.xml | 15 + .../processors_textmining_flink.xml | 15 + .../processors_textmining_jvm.xml | 14 + .../processors_transformation_flink.xml | 15 + .../processors_transformation_jvm.xml | 14 + .idea/runConfigurations/sinks_brokers_jvm.xml | 14 + .idea/runConfigurations/sinks_databases_flink.xml | 16 + .idea/runConfigurations/sinks_databases_jvm.xml | 14 + .idea/runConfigurations/sinks_internal_jvm.xml | 22 ++ .../runConfigurations/sinks_notifications_jvm.xml | 23 ++ .../sources_vehicle_simulator_jvm.xml | 16 + .../sources_watertank_simulator_jvm.xml | 16 + .spignore | 9 +- .../documentation.md => CONTRIBUTING.md | 46 +-- DISCLAIMER | 5 + DISCLAIMER-WIP | 8 - NOTICE | 5 +- README.md | 67 ++-- RELEASE_NOTES.md | 40 ++- docker-compose.yml | 49 ++- pom.xml | 305 +++++++++++++++- .../{streampipes-connect-adapter => }/Dockerfile | 4 +- streampipes-connect-adapters/README.md | 90 ----- .../aarch64.Dockerfile | 4 +- .../arm.Dockerfile | 4 +- streampipes-connect-adapters/pom.xml | 174 ++++----- .../streampipes/connect/ConnectAdapterInit.java | 18 +- .../streampipes/connect/adapters/PullAdapter.java | 0 .../connect/adapters/PullRestAdapter.java | 0 .../adapters/coindesk/CoindeskBitcoinAdapter.java | 14 +- .../connect/adapters/coindesk/Currency.java | 0 .../connect/adapters/coindesk/model/Bpi.java | 0 .../adapters/coindesk/model/CoindeskRawModel.java | 0 .../connect/adapters/coindesk/model/EUR.java | 0 .../connect/adapters/coindesk/model/GBP.java | 0 .../connect/adapters/coindesk/model/Time.java | 0 .../connect/adapters/coindesk/model/USD.java | 0 .../connect/adapters/flic/FlicMQTTAdapter.java} | 49 +-- .../connect/adapters/flic/FlicOutput.java} | 48 ++- .../connect/adapters/flic/FlicUtils.java | 74 ++++ .../connect/adapters/gdelt/GdeltAdapter.java | 10 +- .../connect/adapters/iex/IexCloudAdapter.java | 7 +- .../connect/adapters/iex/IexCloudNewsAdapter.java | 13 +- .../connect/adapters/iex/IexCloudStockAdapter.java | 12 +- .../connect/adapters/iex/model/IexNewsData.java | 0 .../connect/adapters/iex/model/IexStockData.java | 0 .../connect/adapters/image/ImageZipAdapter.java | 100 ++++++ .../connect/adapters/image/ImageZipUtils.java | 23 +- .../adapters/image/ZipFileImageIterator.java | 103 ++++++ .../adapters/image/set/ImageSetAdapter.java | 99 ++++++ .../adapters/image/stream/ImageStreamAdapter.java | 97 +++++ .../connect/adapters/influxdb/InfluxDbClient.java | 0 .../adapters/influxdb/InfluxDbSetAdapter.java | 26 +- .../adapters/influxdb/InfluxDbStreamAdapter.java | 28 +- .../connect/adapters/iss/IssAdapter.java | 0 .../connect/adapters/iss/model/IssModel.java | 0 .../connect/adapters/iss/model/IssPosition.java | 0 .../streampipes/connect/adapters/mysql/Column.java | 16 +- .../connect/adapters/mysql/MySqlAdapter.java | 20 +- .../connect/adapters/mysql/MySqlClient.java | 19 +- .../connect/adapters/mysql/MySqlSetAdapter.java | 24 +- .../connect/adapters/mysql/MySqlStreamAdapter.java | 23 +- .../connect/adapters/netio/NetioMQTTAdapter.java | 0 .../connect/adapters/netio/NetioRestAdapter.java | 0 .../connect/adapters/netio/NetioUtils.java | 30 +- .../netio/model/NetioAllPowerOutputs.java} | 42 +-- .../adapters/netio/model/NetioGlobalMeasure.java | 30 +- .../adapters/netio/model/NetioPowerOutput.java | 30 +- .../trafficcamera/CameraDataHttpExecutor.java | 0 .../trafficcamera/CameraFeatureTransformer.java | 0 .../trafficcamera/CameraInfoHttpExecutor.java | 0 .../trafficcamera/NswTrafficCameraAdapter.java | 11 +- .../trafficcamera/TrafficCameraSensorNames.java | 0 .../nswaustralia/trafficcamera/model/Feature.java | 0 .../trafficcamera/model/FeatureCollection.java | 0 .../nswaustralia/trafficcamera/model/Geometry.java | 0 .../trafficcamera/model/Properties.java | 0 .../nswaustralia/trafficcamera/model/Rights.java | 0 .../connect/adapters/opcua/OpcNode.java | 0 .../streampipes/connect/adapters/opcua/OpcUa.java | 0 .../connect/adapters/opcua/OpcUaAdapter.java | 44 ++- .../connect/adapters/opcua/OpcUaTypes.java | 0 .../adapters/plc4x/modbus/ModbusConfigFile.java} | 85 ++--- .../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 343 ++++++++++++++++++ .../plc4x/passive/Plc4xPassiveAdapter.java | 0 .../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 389 +++++++++++++++++++++ .../connect/adapters/plc4x/s7/S7ConfigFile.java | 65 ++++ .../connect/adapters/ros/RosBridgeAdapter.java | 0 .../adapters/sensemap/OpenSenseMapAdapter.java | 0 .../connect/adapters/sensemap/SensorNames.java | 0 .../adapters/sensemap/model/CurrentLocation.java | 0 .../connect/adapters/sensemap/model/Geometry.java | 0 .../adapters/sensemap/model/LastMeasurement.java | 0 .../connect/adapters/sensemap/model/Loc.java | 0 .../connect/adapters/sensemap/model/SenseBox.java | 0 .../connect/adapters/sensemap/model/Sensor.java | 0 .../simulator/machine/MachineDataSimulator.java | 155 ++++++++ .../machine/MachineDataSimulatorUtils.java | 152 ++++++++ .../machine/MachineDataStreamAdapter.java | 93 +++++ .../simulator/random}/RandomDataSetAdapter.java | 16 +- .../simulator/random}/RandomDataSimulator.java | 2 +- .../random}/RandomDataSimulatorUtils.java | 2 +- .../simulator/random}/RandomDataStreamAdapter.java | 13 +- .../connect/adapters/slack/SlackAdapter.java | 10 +- .../connect/adapters/slack/SlackConsumer.java | 0 .../connect/adapters/ti/TISensorTag.java | 13 +- .../adapters/wikipedia/WikipediaAdapter.java | 0 .../wikipedia/WikipediaEditedArticlesAdapter.java | 8 +- .../wikipedia/WikipediaModelConverter.java | 0 .../wikipedia/WikipediaNewArticlesAdapter.java | 9 +- .../adapters/wikipedia/WikipediaSseConsumer.java | 0 .../connect/adapters/wikipedia/model/Length.java | 0 .../connect/adapters/wikipedia/model/Meta.java | 0 .../connect/adapters/wikipedia/model/Revision.java | 0 .../adapters/wikipedia/model/WikipediaModel.java | 0 .../streampipes/connect/config/ConfigKeys.java | 0 .../connect/config/ConnectWorkerConfig.java | 0 .../connect/protocol/set/FileProtocol.java | 72 ++-- .../connect/protocol/set/HttpProtocol.java | 9 +- .../connect/protocol/stream/BrokerProtocol.java | 0 .../protocol/stream/FileStreamProtocol.java | 93 +++-- .../connect/protocol/stream/HDFSProtocol.java | 0 .../protocol/stream/HttpStreamProtocol.java | 12 +- .../connect/protocol/stream/KafkaProtocol.java | 23 +- .../connect/protocol/stream/MqttConfig.java | 0 .../connect/protocol/stream/MqttConsumer.java | 0 .../connect/protocol/stream/MqttProtocol.java | 0 .../connect/protocol/stream/PullProtocol.java | 0 .../connect/protocol/stream/WebsocketClient.java | 0 .../connect/protocol/stream/WebsocketProtocol.java | 0 .../protocol/stream/pulsar/PulsarConsumer.java | 0 .../protocol/stream/pulsar/PulsarProtocol.java | 16 +- .../protocol/stream/pulsar/PulsarUtils.java | 0 .../connect/utils/MqttConnectUtils.java | 30 +- .../documentation.md | 20 +- .../icon.png | Bin 0 -> 17868 bytes .../strings.en | 6 + .../documentation.md | 24 +- .../icon.png | Bin 0 -> 24457 bytes .../strings.en | 4 +- .../documentation.md | 7 +- .../icon.png | Bin 0 -> 33450 bytes .../strings.en | 4 + .../documentation.md | 20 +- .../icon.png | Bin 0 -> 15675 bytes .../strings.en | 8 + .../documentation.md | 21 +- .../icon.png | Bin 0 -> 15675 bytes .../strings.en | 8 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 5332 bytes .../strings.en | 8 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 5332 bytes .../strings.en | 8 + .../documentation.md | 8 +- .../icon.png | Bin 0 -> 9982 bytes .../strings.en | 23 ++ .../documentation.md | 8 +- .../icon.png | Bin 0 -> 9982 bytes .../strings.en | 26 ++ .../documentation.md | 0 .../icon.png | Bin .../strings.en | 0 .../documentation.md | 4 +- .../icon.png | Bin 0 -> 99909 bytes .../strings.en | 23 ++ .../documentation.md | 4 +- .../icon.png | Bin 0 -> 99909 bytes .../strings.en | 24 ++ .../documentation.md | 0 .../icon.png | Bin .../strings.en | 0 .../documentation.md | 0 .../icon.png | Bin .../strings.en | 0 .../documentation.md | 4 +- .../icon.png | Bin 0 -> 3016 bytes .../strings.en | 6 + .../documentation.md | 4 +- .../icon.png | Bin 0 -> 5087 bytes .../strings.en | 28 ++ .../documentation.md | 0 .../icon.png | Bin 0 -> 46022 bytes .../strings.en | 45 +++ .../documentation.md | 0 .../icon.png | Bin 0 -> 46022 bytes .../strings.en | 38 ++ .../documentation.md | 0 .../icon.png | Bin .../strings.en | 0 .../documentation.md | 13 +- .../icon.png | Bin 0 -> 31009 bytes .../strings.en | 8 + .../documentation.md | 4 +- .../icon.png | Bin 0 -> 13079 bytes .../strings.en | 9 + .../documentation.md | 4 +- .../icon.png | Bin 0 -> 13079 bytes .../strings.en | 6 + .../documentation.md | 4 +- .../icon.png | Bin 0 -> 17473 bytes .../strings.en | 6 + .../documentation.md | 0 .../icon.png | Bin .../strings.en | 0 .../documentation.md | 4 +- .../icon.png | Bin 0 -> 65221 bytes .../strings.en | 3 + .../documentation.md | 4 +- .../icon.png | Bin 0 -> 65221 bytes .../strings.en | 3 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 12881 bytes .../strings.en | 12 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 17467 bytes .../strings.en | 10 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 9110 bytes .../strings.en | 13 + .../documentation.md | 0 .../icon.png | Bin .../strings.en | 0 .../documentation.md | 5 +- .../icon.png | Bin 0 -> 22890 bytes .../strings.en | 13 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 12881 bytes .../strings.en | 7 + .../documentation.md | 5 +- .../icon.png | Bin 0 -> 17467 bytes .../strings.en | 7 + .../connect/adapters/PullAdapterTest.java | 0 .../streampipes/connect/adapters/generic/Mock.java | 0 .../connect/adapters/generic/UtilTest.java | 0 .../generic/elements/AddTimestampTest.java | 0 .../generic/elements/DuplicateFilterTest.java | 0 .../generic/protocol/set/HttpProtocolTest.java | 0 .../generic/protocol/stream/HttpProtocolTest.java | 0 .../adapters/sensemap/OpenSenseMapAdapterTest.java | 0 .../connect/adapters/sensemap/SensorNamesTest.java | 0 .../connect/adapters/ti/TISensorTagTest.java | 35 +- .../streampipes-connect-adapter/pom.xml | 165 --------- .../adapters/netio/model/NetioAllPowerOutputs.java | 48 --- .../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 289 --------------- .../Dockerfile | 2 +- .../aarch64.Dockerfile | 5 +- .../arm.Dockerfile | 2 +- .../development/env | 4 +- .../pom.xml | 49 +-- .../pe/flink/AllFlinkPipelineElementsInit.java | 103 ++++++ .../apache/streampipes/pe/flink/config/Config.java | 60 ++-- .../streampipes/pe/flink/config/ConfigKeys.java | 15 +- streampipes-pipeline-elements-all-jvm/Dockerfile | 7 +- streampipes-pipeline-elements-all-jvm/pom.xml | 24 +- .../pe/jvm/AllPipelineElementsInit.java | 26 ++ .../pom.xml | 2 +- streampipes-pipeline-elements-shared/pom.xml | 2 +- streampipes-processors-aggregation-flink/pom.xml | 3 +- .../aggregation/AggregationController.java | 10 +- streampipes-processors-enricher-flink/pom.xml | 2 +- streampipes-processors-enricher-jvm/Dockerfile | 2 +- streampipes-processors-enricher-jvm/pom.xml | 2 +- .../processors/enricher/jvm/EnricherJvmInit.java | 33 +- .../processors/enricher/jvm/config/ConfigKeys.java | 13 +- .../enricher/jvm/config/EnricherJvmConfig.java | 14 +- .../enricher/jvm/processor/jseval/JSEval.java | 76 ++++ .../jvm/processor/jseval/JSEvalController.java | 61 ++++ .../jvm/processor/jseval/JSEvalParameters.java | 16 +- .../jvm/processor/sizemeasure/SizeMeasure.java | 29 +- .../sizemeasure/SizeMeasureController.java | 29 +- .../sizemeasure/SizeMeasureParameters.java | 29 +- .../documentation.md | 35 +- .../icon.png | Bin 0 -> 622 bytes .../strings.en | 5 + streampipes-processors-filters-jvm/pom.xml | 6 +- .../processors/filters/jvm/FiltersJvmInit.java | 4 +- .../filters/jvm/processor/limit/RateLimit.java | 75 ++++ .../jvm/processor/limit/RateLimitController.java | 108 ++++++ .../jvm/processor/limit/RateLimitParameters.java | 66 ++++ .../jvm/processor/limit/util/EventSelection.java | 9 +- .../jvm/processor/limit/util/ProcessJob.java | 15 +- .../jvm/processor/limit/util/SchedulerUtil.java | 58 +++ .../jvm/processor/limit/util/WindowFactory.java | 54 +++ .../jvm/processor/limit/util/WindowType.java | 9 +- .../jvm/processor/limit/window/CronWindow.java | 46 +++ .../jvm/processor/limit/window/LengthWindow.java | 78 +++++ .../jvm/processor/limit/window/ScheduleWindow.java | 114 ++++++ .../jvm/processor/limit/window/TimeWindow.java | 46 +++ .../filters/jvm/processor/limit/window/Window.java | 15 +- .../filters/jvm/processor/merge/StreamBuffer.java | 30 +- .../documentation.md | 64 ++++ .../icon.png | Bin 0 -> 3534 bytes .../strings.en | 32 ++ streampipes-processors-filters-siddhi/pom.xml | 2 +- .../processors/siddhi/FiltersSiddhiInit.java | 10 +- ...{NumericalOperator.java => FilterOperator.java} | 4 +- .../processors/siddhi/filter/NumericalFilter.java | 35 +- .../siddhi/filter/NumericalFilterController.java | 11 +- .../siddhi/filter/NumericalFilterParameters.java | 12 +- .../processors/siddhi/stop/StreamStop.java | 5 +- .../documentation.md | 23 +- .../strings.en | 2 +- .../siddhi/trend/TestTrendProcessor.java | 5 + streampipes-processors-geo-flink/pom.xml | 2 +- streampipes-processors-geo-jvm/development/env | 4 +- streampipes-processors-geo-jvm/pom.xml | 2 +- .../streampipes/processors/geo/jvm/GeoJvmInit.java | 20 +- .../geo/jvm/jts/helper/SpGeometryBuilder.java | 73 ++-- .../geo/jvm/jts/helper/SpTrajectoryBuilder.java | 105 ++++++ .../jvm/jts/processor/latLngToGeo/LatLngToGeo.java | 60 ++-- .../latLngToGeo/LatLngToGeoController.java | 109 +++--- .../latLngToGeo/LatLngToGeoParameter.java | 36 +- .../geo/jvm/jts/processor/setEPSG/SetEPSG.java | 33 +- .../jts/processor/setEPSG/SetEpsgController.java | 73 ++-- .../jts/processor/setEPSG/SetEpsgParameter.java | 16 +- .../trajectory/CreateTrajectoryFromPoints.java | 80 +++++ .../CreateTrajectoryFromPointsController.java | 116 ++++++ .../CreateTrajectoryFromPointsParameter.java} | 63 ++-- .../documentation.md | 12 +- .../icon.png | Bin 19124 -> 20621 bytes .../strings.en | 10 +- .../icon.png | Bin 4831 -> 8710 bytes .../strings.en | 9 +- .../documentation.md | 77 ++++ .../icon.png | Bin 0 -> 9399 bytes .../strings.en | 20 ++ .../Dockerfile | 5 +- .../pom.xml | 2 +- .../jvm/processor/commons/ImageTransformer.java | 18 +- .../jvm/processor/commons/RequiredBoxStream.java | 1 + .../GenericImageClassification.java | 7 +- .../GenericImageClassificationController.java | 2 +- .../processor/imageenrichment/BoxCoordinates.java | 28 ++ .../jvm/processor/imageenrichment/ColorUtil.java | 44 ++- .../processor/imageenrichment/ImageEnricher.java | 29 +- .../imageenrichment/ImageEnrichmentController.java | 3 +- .../imageenrichment/ImageEnrichmentParameters.java | 22 +- .../documentation.md | 5 +- .../pom.xml | 2 +- streampipes-processors-statistics-flink/pom.xml | 2 +- streampipes-processors-text-mining-flink/pom.xml | 2 +- streampipes-processors-text-mining-jvm/pom.xml | 2 +- .../Dockerfile | 4 +- .../aarch64.Dockerfile | 4 +- .../arm.Dockerfile | 4 +- .../development/env | 2 +- .../pom.xml | 2 +- .../flink/config/TransformationFlinkConfig.java | 2 +- streampipes-processors-transformation-jvm/pom.xml | 2 +- .../transformation/jvm/TransformationJvmInit.java | 18 +- .../jvm/processor/array/split/SplitArray.java | 2 +- .../array/split/SplitArrayController.java | 14 +- .../booloperator/edge/SignalEdgeFilter.java | 121 +++++++ .../edge/SignalEdgeFilterController.java | 77 ++++ .../edge/SignalEdgeFilterParameters.java | 72 ++++ .../booloperator/state/BooleanToState.java | 66 ++++ .../state/BooleanToStateController.java | 44 +-- .../state/BooleanToStateParameters.java | 32 +- .../CsvMetadataEnrichmentController.java | 11 +- .../jvm/processor/state/buffer/StateBuffer.java | 94 +++++ .../state/buffer/StateBufferController.java | 87 +++++ .../state/buffer/StateBufferParameters.java | 61 ++++ .../state/labeler/buffer/StateBufferLabeler.java | 86 +++++ .../buffer/StateBufferLabelerController.java | 131 +++++++ .../buffer/StateBufferLabelerParameters.java | 109 ++++++ .../processor/state/labeler/model/Statement.java | 43 +-- .../state/labeler/model/StatementUtils.java | 146 ++++++++ .../state/labeler/number/NumberLabeler.java | 69 ++++ .../labeler/number/NumberLabelerController.java | 118 +++++++ .../labeler/number/NumberLabelerParameters.java | 73 ++++ .../stringoperator/counter/StringCounter.java | 79 +++++ .../counter/StringCounterController.java | 71 ++++ .../counter/StringCounterParameters.java | 17 +- .../stringoperator/state/StringToState.java | 45 +-- .../state/StringToStateController.java | 40 +-- .../state/StringToStateParameters.java | 21 +- .../stringoperator/timer/StringTimer.java | 72 ++++ .../timer/StringTimerController.java | 83 +++++ .../timer/StringTimerParameters.java | 23 +- .../transformtoboolean/TransformToBoolean.java | 13 +- .../TransformToBooleanController.java | 13 +- .../TransformToBooleanParameters.java | 13 +- .../documentation.md | 2 +- .../strings.en | 3 + .../documentation.md | 33 +- .../icon.png | Bin 0 -> 7919 bytes .../strings.en | 15 + .../documentation.md | 31 +- .../icon.png | Bin 0 -> 12518 bytes .../strings.en | 14 + .../documentation.md | 32 +- .../icon.png | Bin 0 -> 9466 bytes .../strings.en | 18 + .../documentation.md | 63 ++++ .../icon.png | Bin 0 -> 10162 bytes .../strings.en | 29 ++ .../documentation.md | 30 +- .../icon.png | Bin 0 -> 8629 bytes .../strings.en | 29 ++ .../documentation.md | 29 +- .../icon.png | Bin 0 -> 12174 bytes .../strings.en | 11 + .../documentation.md | 33 +- .../icon.png | Bin 0 -> 16458 bytes .../strings.en | 16 + .../documentation.md | 30 +- .../icon.png | Bin 0 -> 14398 bytes .../strings.en | 17 + streampipes-sinks-brokers-jvm/pom.xml | 4 +- streampipes-sinks-databases-flink/pom.xml | 2 +- streampipes-sinks-databases-jvm/pom.xml | 21 +- .../sinks/databases/jvm/DatabasesJvmInit.java | 6 +- .../sinks/databases/jvm/jdbcclient/JdbcClient.java | 3 +- .../sinks/databases/jvm/mysql/Column.java | 76 ++++ .../sinks/databases/jvm/mysql/Mysql.java | 269 ++++++++++++++ .../sinks/databases/jvm/mysql/MysqlController.java | 75 ++++ .../sinks/databases/jvm/mysql/MysqlParameters.java | 66 ++++ .../sinks/databases/jvm/opcua/OpcUa.java | 18 +- .../sinks/databases/jvm/redis/Redis.java | 119 +++++++ .../sinks/databases/jvm/redis/RedisController.java | 103 ++++++ .../sinks/databases/jvm/redis/RedisParameters.java | 114 ++++++ .../documentation.md | 31 +- .../icon.png | Bin 0 -> 6477 bytes .../strings.en | 21 ++ .../documentation.md | 81 +++++ .../icon.png | Bin 0 -> 12905 bytes .../strings.en | 38 ++ streampipes-sinks-internal-jvm/pom.xml | 2 +- .../sinks/internal/jvm/config/ConfigKeys.java | 5 +- .../jvm/config/SinksInternalJvmConfig.java | 32 +- .../sinks/internal/jvm/datalake/DataLake.java | 27 +- .../internal/jvm/datalake/DataLakeController.java | 10 +- .../jvm/datalake/DataLakeInfluxDbClient.java | 33 +- streampipes-sinks-notifications-jvm/pom.xml | 6 +- .../jvm/SinksNotificationsJvmInit.java | 4 +- .../jvm/telegram/TelegramController.java | 65 ++++ .../jvm/telegram/TelegramParameters.java | 58 ++- .../jvm/telegram/TelegramPublisher.java | 94 +++++ .../documentation.md | 26 +- .../icon.png | Bin 0 -> 6844 bytes .../strings.en | 11 + streampipes-sources-vehicle-simulator/pom.xml | 4 +- streampipes-sources-watertank-simulator/pom.xml | 4 +- tools/maven/assembly.xml | 82 +++++ 461 files changed, 9251 insertions(+), 2354 deletions(-)
