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 2023/02/01 22:34:43 UTC
[streampipes] branch sp-1157-upgrade-third-party-services updated (e392f547c -> 5f2b6fbf7)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch sp-1157-upgrade-third-party-services
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from e392f547c Migrate endpoint to delete data lake resources (#1157)
add 5f2b6fbf7 Refactor InfluxDB adapters and sinks, fix smoke test (#1200)
No new revisions were added by this update.
Summary of changes:
pom.xml | 1 +
.../commons/influx/InfluxAuthMode.java | 7 +-
.../commons/influx/InfluxClientProvider.java | 26 ++-
...uxNameSanitizer.java => InfluxClientUtils.java} | 27 ++-
.../commons/influx/InfluxConnectionSettings.java | 61 ++++++-
...nfluxNameSanitizer.java => InfluxRequests.java} | 29 +++-
.../dataexplorer/commons/influx/InfluxStore.java | 14 +-
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../connect/iiot/ConnectAdapterIiotInit.java | 4 -
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 178 -------------------
.../documentation.md | 35 ----
.../strings.en | 41 -----
.../pom.xml | 37 ++--
.../connectors/influx/InfluxConnectorsInit.java} | 21 ++-
.../connectors/influx/adapter}/InfluxDbClient.java | 75 ++------
.../influx/adapter}/InfluxDbStreamAdapter.java | 59 +++----
.../connectors/influx/shared/InfluxConfigs.java | 84 +++++++++
.../connectors/influx/shared/InfluxKeys.java | 38 ++++
.../influx/shared/SharedInfluxClient.java | 53 ++++++
.../connectors/influx/sink/InfluxDbClient.java | 129 ++++++++++++++
.../connectors/influx/sink/InfluxDbSink.java | 110 ++++++++++++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 42 +++--
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 20 ++-
.../streampipes-extensions-all-iiot/pom.xml | 5 +
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 2 +
.../streampipes-pipeline-elements-all-jvm/pom.xml | 5 +
.../pe/jvm/AllPipelineElementsInit.java | 26 +--
.../streampipes-sinks-databases-jvm/pom.xml | 4 -
.../sinks/databases/jvm/DatabasesJvmInit.java | 2 -
.../sinks/databases/jvm/influxdb/InfluxDb.java | 69 --------
.../databases/jvm/influxdb/InfluxDbClient.java | 193 ---------------------
.../databases/jvm/influxdb/InfluxDbController.java | 97 -----------
.../databases/jvm/influxdb/InfluxDbParameters.java | 94 ----------
.../icon.png | Bin 9982 -> 0 bytes
.../support/utils/DataDownloadDialogUtils.ts | 4 +-
ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts | 19 +-
40 files changed, 690 insertions(+), 925 deletions(-)
copy streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java => streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/InfluxAuthMode.java (87%)
copy streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/{InfluxNameSanitizer.java => InfluxClientUtils.java} (58%)
copy streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/{InfluxNameSanitizer.java => InfluxRequests.java} (53%)
delete mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/influxdb/InfluxDbSetAdapter.java
delete mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set/documentation.md
delete mode 100644 streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set/strings.en
copy streampipes-extensions/{streampipes-processors-text-mining-jvm => streampipes-connectors-influx}/pom.xml (73%)
copy streampipes-extensions/{streampipes-processors-change-detection-jvm/src/main/java/org/apache/streampipes/processors/changedetection/jvm/ChangeDetectionJvmInit.java => streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/InfluxConnectorsInit.java} (80%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/influxdb => streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter}/InfluxDbClient.java (80%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/influxdb => streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter}/InfluxDbStreamAdapter.java (77%)
create mode 100644 streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/shared/InfluxConfigs.java
create mode 100644 streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/shared/InfluxKeys.java
create mode 100644 streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/shared/SharedInfluxClient.java
create mode 100644 streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/sink/InfluxDbClient.java
create mode 100644 streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/sink/InfluxDbSink.java
rename streampipes-extensions/{streampipes-connect-adapters-iiot => streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/documentation.md (100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set => streampipes-connectors-influx/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream}/icon.png (100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot => streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/strings.en (55%)
rename streampipes-extensions/{streampipes-sinks-databases-jvm => streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb/documentation.md (100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream => streampipes-connectors-influx/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb}/icon.png (100%)
rename streampipes-extensions/{streampipes-sinks-databases-jvm => streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb/strings.en (78%)
delete mode 100644 streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDb.java
delete mode 100644 streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java
delete mode 100644 streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java
delete mode 100644 streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbParameters.java
delete mode 100644 streampipes-extensions/streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb/icon.png