You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2021/10/13 08:24:46 UTC
[incubator-streampipes-extensions] branch STREAMPIPES-426 updated
(8e8d7f5 -> bcc2fa0)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch STREAMPIPES-426
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 8e8d7f5 [STREAMPIPES-441] Refactor email sink to send mails over StreamPipes API
add d7672ad [hotfix] Add more datatypes to MySQL adapter
add 36f2cc3 Splitting streampipes-connect-adapters
add 8d7ddc5 [STEAMPIPES-438] Remove adapter Id form backend
add 75fb6ce Update adapter descriptions
add 329713c [hotfix] Enable manual trigger for github build
add 7508138 [hotfix] Change failing tests
add 3ca26f6 Merge branch 'dev' into dev
add 1519b01 Refactor streampipes-connect-adapters
add 27a3773 [STREAMPIPES-387] Split StreamPipes Connect worker into two different services
add e29de52 [STREAMPIPES-387] Split StreamPipes Connect worker into two different services
new bcc2fa0 Merge branch 'dev' into STREAMPIPES-426
The 1 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:
.github/workflows/build.yml | 31 ++-
.idea/runConfigurations/connect_adapters.xml | 1 +
.idea/runConfigurations/connect_adapters_iiot.xml | 15 ++
pom.xml | 1 +
.../.idea/workspace.xml | 65 ++++++
.../Dockerfile | 4 +-
.../aarch64.Dockerfile | 4 +-
.../arm.Dockerfile | 4 +-
.../development/env | 1 +
streampipes-connect-adapters-iiot/pom.xml | 247 +++++++++++++++++++++
.../connect/iiot/ConnectAdapterIiotInit.java | 72 ++++++
.../connect/iiot}/adapters/PullAdapter.java | 8 +-
.../connect/iiot}/adapters/PullRestAdapter.java | 2 +-
.../iiot}/adapters/influxdb/InfluxDbClient.java | 2 +-
.../adapters/influxdb/InfluxDbSetAdapter.java | 4 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 10 +-
.../connect/iiot}/adapters/mysql/Column.java | 2 +-
.../connect/iiot}/adapters/mysql/MySqlAdapter.java | 2 +-
.../connect/iiot}/adapters/mysql/MySqlClient.java | 2 +-
.../iiot}/adapters/mysql/MySqlSetAdapter.java | 4 +-
.../iiot}/adapters/mysql/MySqlStreamAdapter.java | 4 +-
.../iiot}/adapters/netio/NetioMQTTAdapter.java | 14 +-
.../iiot}/adapters/netio/NetioRestAdapter.java | 10 +-
.../connect/iiot}/adapters/netio/NetioUtils.java | 7 +-
.../adapters/netio/model/NetioAllPowerOutputs.java | 2 +-
.../adapters/netio/model/NetioGlobalMeasure.java | 2 +-
.../adapters/netio/model/NetioPowerOutput.java | 2 +-
.../connect/iiot}/adapters/opcua/OpcNode.java | 2 +-
.../connect/iiot}/adapters/opcua/OpcUa.java | 12 +-
.../connect/iiot}/adapters/opcua/OpcUaAdapter.java | 10 +-
.../adapters/opcua/utils/OpcUaNodeVariants.java | 2 +-
.../iiot}/adapters/opcua/utils/OpcUaTypes.java | 2 +-
.../iiot}/adapters/opcua/utils/OpcUaUtil.java | 6 +-
.../adapters/plc4x/modbus/ModbusConfigFile.java | 2 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 7 +-
.../plc4x/passive/Plc4xPassiveAdapter.java | 5 +-
.../iiot}/adapters/plc4x/s7/Plc4xS7Adapter.java | 7 +-
.../iiot}/adapters/ros/RosBridgeAdapter.java | 5 +-
.../simulator/machine/MachineDataSimulator.java | 2 +-
.../machine/MachineDataSimulatorUtils.java | 2 +-
.../machine/MachineDataStreamAdapter.java | 4 +-
.../connect/iiot}/protocol/set/FileProtocol.java | 6 +-
.../connect/iiot}/protocol/set/HttpProtocol.java | 6 +-
.../iiot}/protocol/stream/BrokerProtocol.java | 4 +-
.../iiot}/protocol/stream/FileStreamProtocol.java | 6 +-
.../protocol/stream/HttpServerEventReceiver.java | 2 +-
.../iiot}/protocol/stream/HttpServerProtocol.java | 4 +-
.../iiot}/protocol/stream/HttpStreamProtocol.java | 7 +-
.../connect/iiot}/protocol/stream/KafkaConfig.java | 2 +-
.../iiot}/protocol/stream/KafkaProtocol.java | 6 +-
.../connect/iiot}/protocol/stream/MqttConfig.java | 2 +-
.../iiot}/protocol/stream/MqttConsumer.java | 2 +-
.../iiot}/protocol/stream/MqttProtocol.java | 6 +-
.../iiot}/protocol/stream/PullProtocol.java | 2 +-
.../protocol/stream/pulsar/PulsarConsumer.java | 2 +-
.../protocol/stream/pulsar/PulsarProtocol.java | 6 +-
.../iiot}/protocol/stream/pulsar/PulsarUtils.java | 2 +-
.../connect/iiot}/utils/KafkaConnectUtils.java | 4 +-
.../connect/iiot}/utils/MqttConnectUtils.java | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 11 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 8 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 10 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 7 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 10 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 6 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
streampipes-connect-adapters/Dockerfile | 2 +-
streampipes-connect-adapters/aarch64.Dockerfile | 2 +-
streampipes-connect-adapters/arm.Dockerfile | 4 +-
streampipes-connect-adapters/development/env | 1 +
streampipes-connect-adapters/pom.xml | 51 +----
.../streampipes/connect/ConnectAdapterInit.java | 61 ++---
.../connect/adapters/flic/FlicUtils.java | 1 -
.../connect/adapters/gdelt/GdeltAdapter.java | 1 -
.../trafficcamera/CameraDataHttpExecutor.java | 39 ----
.../trafficcamera/CameraFeatureTransformer.java | 66 ------
.../trafficcamera/CameraInfoHttpExecutor.java | 47 ----
.../trafficcamera/NswTrafficCameraAdapter.java | 153 -------------
.../trafficcamera/TrafficCameraSensorNames.java | 42 ----
.../nswaustralia/trafficcamera/model/Feature.java | 69 ------
.../trafficcamera/model/FeatureCollection.java | 62 ------
.../nswaustralia/trafficcamera/model/Geometry.java | 52 -----
.../trafficcamera/model/Properties.java | 80 -------
.../nswaustralia/trafficcamera/model/Rights.java | 50 -----
.../adapters/sensemap/OpenSenseMapAdapter.java | 1 -
.../connect/protocol/stream/HDFSProtocol.java | 2 +-
.../connect/protocol/stream/MqttConsumer.java | 2 +-
.../connect/protocol/stream/WebsocketClient.java | 92 --------
.../connect/protocol/stream/WebsocketProtocol.java | 101 ---------
.../documentation.md | 33 ---
.../icon.png | Bin 3016 -> 0 bytes
.../strings.en | 6 -
.../strings.en | 11 -
.../strings.en | 8 -
.../strings.en | 10 -
.../strings.en | 10 -
.../strings.en | 7 -
.../connect/adapters/generic/UtilTest.java | 19 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 2 +
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 5 +-
.../jvm/jdbcclient/model/DbDataTypes.java | 5 +-
151 files changed, 651 insertions(+), 1213 deletions(-)
create mode 100644 .idea/runConfigurations/connect_adapters_iiot.xml
create mode 100644 streampipes-connect-adapters-iiot/.idea/workspace.xml
copy {streampipes-sinks-brokers-jvm => streampipes-connect-adapters-iiot}/Dockerfile (83%)
copy {streampipes-extensions-all-jvm => streampipes-connect-adapters-iiot}/aarch64.Dockerfile (85%)
copy {streampipes-extensions-all-jvm => streampipes-connect-adapters-iiot}/arm.Dockerfile (85%)
copy {streampipes-connect-adapters => streampipes-connect-adapters-iiot}/development/env (98%)
create mode 100644 streampipes-connect-adapters-iiot/pom.xml
create mode 100644 streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/ConnectAdapterIiotInit.java
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/PullAdapter.java (98%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/PullRestAdapter.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/influxdb/InfluxDbClient.java (99%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/influxdb/InfluxDbSetAdapter.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/influxdb/InfluxDbStreamAdapter.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/mysql/Column.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/mysql/MySqlAdapter.java (99%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/mysql/MySqlClient.java (99%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/mysql/MySqlSetAdapter.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/mysql/MySqlStreamAdapter.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/netio/NetioMQTTAdapter.java (92%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/netio/NetioRestAdapter.java (95%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/netio/NetioUtils.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/netio/model/NetioAllPowerOutputs.java (95%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/netio/model/NetioGlobalMeasure.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/netio/model/NetioPowerOutput.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/opcua/OpcNode.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/opcua/OpcUa.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/opcua/OpcUaAdapter.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/opcua/utils/OpcUaNodeVariants.java (95%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/opcua/utils/OpcUaTypes.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/opcua/utils/OpcUaUtil.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/plc4x/modbus/ModbusConfigFile.java (95%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/plc4x/modbus/Plc4xModbusAdapter.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/plc4x/passive/Plc4xPassiveAdapter.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/plc4x/s7/Plc4xS7Adapter.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/ros/RosBridgeAdapter.java (98%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/simulator/machine/MachineDataSimulator.java (98%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/simulator/machine/MachineDataSimulatorUtils.java (98%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/adapters/simulator/machine/MachineDataStreamAdapter.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/set/FileProtocol.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/set/HttpProtocol.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/BrokerProtocol.java (94%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/FileStreamProtocol.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/HttpServerEventReceiver.java (95%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/HttpServerProtocol.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/HttpStreamProtocol.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/KafkaConfig.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/KafkaProtocol.java (98%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/MqttConfig.java (96%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/MqttConsumer.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/MqttProtocol.java (96%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/PullProtocol.java (98%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/pulsar/PulsarConsumer.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/pulsar/PulsarProtocol.java (97%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/protocol/stream/pulsar/PulsarUtils.java (94%)
rename {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/utils/KafkaConnectUtils.java (97%)
copy {streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect => streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot}/utils/MqttConnectUtils.java (96%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.set => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.stream => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.set => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set}/strings.en (78%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.stream => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.set => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.influxdb.stream => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream}/strings.en (81%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.set => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.set}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.stream => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.set}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.set => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.set}/strings.en (70%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.stream => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.stream}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.set => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.stream}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.mysql.stream => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.mysql.stream}/strings.en (69%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.netio.mqtt}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.netio.mqtt}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.netio.mqtt}/strings.en (75%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.netio.rest}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.netio.rest}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.netio.rest}/strings.en (69%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.opcua => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.opcua}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.opcua => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.opcua}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.opcua => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.opcua}/strings.en (88%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.s7 => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.s7 => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.modbus => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.modbus}/strings.en (87%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.modbus => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.s7}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.modbus => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.s7}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.plc4x.s7 => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.plc4x.s7}/strings.en (76%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ros => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.ros}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ros => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.ros}/icon.png (100%)
create mode 100644 streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.ros/strings.en
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.machine => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.simulator.machine}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.machine => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.simulator.machine}/icon.png (100%)
create mode 100644 streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.simulator.machine/strings.en
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.file => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.file}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.file => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.file}/icon.png (100%)
create mode 100644 streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.file/strings.en
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.http => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.http}/documentation.md (100%)
copy {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.http => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.http}/icon.png (100%)
create mode 100644 streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.set.http/strings.en
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.file => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.file}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.file => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.file}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.file => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.file}/strings.en (59%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.http => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.http}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.http => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.http}/icon.png (100%)
create mode 100644 streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.http/strings.en
copy {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.httpserver => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.httpserver}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.http => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.httpserver}/icon.png (100%)
copy {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.httpserver => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.httpserver}/strings.en (75%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.kafka => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.kafka}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.kafka => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.kafka}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.kafka => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.kafka}/strings.en (71%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt}/strings.en (70%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.pulsar => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar}/documentation.md (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.pulsar => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar}/icon.png (100%)
rename {streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.pulsar => streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.pulsar}/strings.en (57%)
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraDataHttpExecutor.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraFeatureTransformer.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraInfoHttpExecutor.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/NswTrafficCameraAdapter.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/TrafficCameraSensorNames.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Feature.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/FeatureCollection.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Geometry.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Properties.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Rights.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/stream/WebsocketClient.java
delete mode 100644 streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/protocol/stream/WebsocketProtocol.java
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/documentation.md
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/icon.png
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.nswaustralia.trafficcamera/strings.en
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.ros/strings.en
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.adapters.simulator.machine/strings.en
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.connect.protocol.stream.http/strings.en
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.file/strings.en
delete mode 100644 streampipes-connect-adapters/src/main/resources/org.apache.streampipes.protocol.set.http/strings.en
[incubator-streampipes-extensions] 01/01: Merge branch 'dev' into
STREAMPIPES-426
Posted by ri...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch STREAMPIPES-426
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit bcc2fa0ddf0e05fbcf97e9e9fdcae1558aebaa85
Merge: 8e8d7f5 e29de52
Author: Dominik Riemer <ri...@fzi.de>
AuthorDate: Wed Oct 13 10:24:16 2021 +0200
Merge branch 'dev' into STREAMPIPES-426
.github/workflows/build.yml | 31 ++-
.idea/runConfigurations/connect_adapters.xml | 1 +
.idea/runConfigurations/connect_adapters_iiot.xml | 15 ++
pom.xml | 1 +
.../.idea/workspace.xml | 65 ++++++
.../Dockerfile | 6 +-
.../aarch64.Dockerfile | 6 +-
.../arm.Dockerfile | 4 +-
.../development/env | 1 +
streampipes-connect-adapters-iiot/pom.xml | 247 +++++++++++++++++++++
.../connect/iiot/ConnectAdapterIiotInit.java | 72 ++++++
.../connect/iiot/adapters/PullAdapter.java | 100 +++++++++
.../connect/iiot/adapters/PullRestAdapter.java | 71 ++++++
.../iiot}/adapters/influxdb/InfluxDbClient.java | 2 +-
.../adapters/influxdb/InfluxDbSetAdapter.java | 4 +-
.../adapters/influxdb/InfluxDbStreamAdapter.java | 10 +-
.../connect/iiot}/adapters/mysql/Column.java | 2 +-
.../connect/iiot}/adapters/mysql/MySqlAdapter.java | 2 +-
.../connect/iiot}/adapters/mysql/MySqlClient.java | 2 +-
.../iiot}/adapters/mysql/MySqlSetAdapter.java | 4 +-
.../iiot}/adapters/mysql/MySqlStreamAdapter.java | 4 +-
.../iiot}/adapters/netio/NetioMQTTAdapter.java | 14 +-
.../iiot}/adapters/netio/NetioRestAdapter.java | 10 +-
.../connect/iiot}/adapters/netio/NetioUtils.java | 7 +-
.../adapters/netio/model/NetioAllPowerOutputs.java | 2 +-
.../adapters/netio/model/NetioGlobalMeasure.java | 2 +-
.../adapters/netio/model/NetioPowerOutput.java | 2 +-
.../connect/iiot}/adapters/opcua/OpcNode.java | 2 +-
.../connect/iiot}/adapters/opcua/OpcUa.java | 12 +-
.../connect/iiot}/adapters/opcua/OpcUaAdapter.java | 10 +-
.../adapters/opcua/utils/OpcUaNodeVariants.java | 2 +-
.../iiot}/adapters/opcua/utils/OpcUaTypes.java | 2 +-
.../iiot}/adapters/opcua/utils/OpcUaUtil.java | 6 +-
.../adapters/plc4x/modbus/ModbusConfigFile.java | 2 +-
.../adapters/plc4x/modbus/Plc4xModbusAdapter.java | 7 +-
.../plc4x/passive/Plc4xPassiveAdapter.java | 5 +-
.../iiot}/adapters/plc4x/s7/Plc4xS7Adapter.java | 7 +-
.../iiot}/adapters/ros/RosBridgeAdapter.java | 5 +-
.../simulator/machine/MachineDataSimulator.java | 157 +++++++++++++
.../machine/MachineDataSimulatorUtils.java | 152 +++++++++++++
.../machine/MachineDataStreamAdapter.java | 93 ++++++++
.../connect/iiot}/protocol/set/FileProtocol.java | 6 +-
.../connect/iiot}/protocol/set/HttpProtocol.java | 6 +-
.../iiot}/protocol/stream/BrokerProtocol.java | 4 +-
.../iiot}/protocol/stream/FileStreamProtocol.java | 6 +-
.../protocol/stream/HttpServerEventReceiver.java | 2 +-
.../iiot}/protocol/stream/HttpServerProtocol.java | 4 +-
.../iiot}/protocol/stream/HttpStreamProtocol.java | 7 +-
.../connect/iiot}/protocol/stream/KafkaConfig.java | 2 +-
.../iiot}/protocol/stream/KafkaProtocol.java | 6 +-
.../connect/iiot/protocol/stream/MqttConfig.java | 61 +++++
.../iiot}/protocol/stream/MqttConsumer.java | 2 +-
.../iiot}/protocol/stream/MqttProtocol.java | 6 +-
.../iiot}/protocol/stream/PullProtocol.java | 2 +-
.../protocol/stream/pulsar/PulsarConsumer.java | 2 +-
.../protocol/stream/pulsar/PulsarProtocol.java | 6 +-
.../iiot}/protocol/stream/pulsar/PulsarUtils.java | 2 +-
.../connect/iiot}/utils/KafkaConnectUtils.java | 4 +-
.../connect/iiot/utils/MqttConnectUtils.java | 97 ++++++++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 11 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 8 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 10 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 7 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 10 +
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 30 +++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 6 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 4 +-
streampipes-connect-adapters/Dockerfile | 2 +-
streampipes-connect-adapters/aarch64.Dockerfile | 2 +-
streampipes-connect-adapters/arm.Dockerfile | 4 +-
streampipes-connect-adapters/development/env | 1 +
streampipes-connect-adapters/pom.xml | 51 +----
.../streampipes/connect/ConnectAdapterInit.java | 61 ++---
.../connect/adapters/flic/FlicUtils.java | 1 -
.../connect/adapters/gdelt/GdeltAdapter.java | 1 -
.../trafficcamera/CameraDataHttpExecutor.java | 39 ----
.../trafficcamera/CameraFeatureTransformer.java | 66 ------
.../trafficcamera/CameraInfoHttpExecutor.java | 47 ----
.../trafficcamera/NswTrafficCameraAdapter.java | 153 -------------
.../trafficcamera/TrafficCameraSensorNames.java | 42 ----
.../nswaustralia/trafficcamera/model/Feature.java | 69 ------
.../trafficcamera/model/FeatureCollection.java | 62 ------
.../nswaustralia/trafficcamera/model/Geometry.java | 52 -----
.../trafficcamera/model/Properties.java | 80 -------
.../nswaustralia/trafficcamera/model/Rights.java | 50 -----
.../adapters/sensemap/OpenSenseMapAdapter.java | 1 -
.../connect/protocol/stream/HDFSProtocol.java | 2 +-
.../connect/protocol/stream/MqttConsumer.java | 2 +-
.../connect/protocol/stream/WebsocketClient.java | 92 --------
.../connect/protocol/stream/WebsocketProtocol.java | 101 ---------
.../documentation.md | 33 ---
.../icon.png | Bin 3016 -> 0 bytes
.../strings.en | 6 -
.../strings.en | 11 -
.../strings.en | 8 -
.../strings.en | 10 -
.../strings.en | 10 -
.../strings.en | 7 -
.../connect/adapters/generic/UtilTest.java | 19 +-
.../sinks/brokers/jvm/BrokersJvmInit.java | 2 +
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 5 +-
.../jvm/jdbcclient/model/DbDataTypes.java | 5 +-
151 files changed, 1400 insertions(+), 1201 deletions(-)