You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/10/27 21:08:46 UTC
[incubator-streampipes-extensions] 01/01: Merge tag 'release/0.67.0'
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 <ze...@fzi.de>
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(-)