This is an automated email from the ASF dual-hosted git repository. riemer pushed a commit to branch STREAMPIPES-319 in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit 1b6daa0064c77721ead41812509f8132edfa3383 Merge: 8677093 0403ea4 Author: Dominik Riemer <[email protected]> AuthorDate: Wed Jul 7 22:36:42 2021 +0200 Merge branch 'dev' into STREAMPIPES-319 NOTICE | 4 +- README.md | 2 +- RELEASE_NOTES.md | 30 +- pom.xml | 19 +- streampipes-connect-adapters/pom.xml | 2 +- .../connect/adapters/opcua/OpcUaAdapter.java | 18 + .../connect/adapters/opcua/utils/OpcUaUtil.java | 18 + .../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 5 +- streampipes-extensions-all-jvm/pom.xml | 11 +- streampipes-pipeline-elements-all-flink/pom.xml | 2 +- streampipes-pipeline-elements-all-jvm/pom.xml | 2 +- .../pom.xml | 2 +- streampipes-pipeline-elements-shared/pom.xml | 2 +- streampipes-processors-aggregation-flink/pom.xml | 2 +- .../pom.xml | 6 +- streampipes-processors-enricher-flink/pom.xml | 2 +- streampipes-processors-enricher-jvm/pom.xml | 2 +- streampipes-processors-filters-jvm/pom.xml | 2 +- streampipes-processors-filters-siddhi/pom.xml | 2 +- streampipes-processors-geo-flink/pom.xml | 2 +- streampipes-processors-geo-jvm/pom.xml | 2 +- .../pom.xml | 14 +- .../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 | 6 +- .../pom.xml | 2 +- streampipes-processors-transformation-jvm/pom.xml | 2 +- .../jvm/processor/state/StateUtils.java | 18 + .../jvm/processor/state/labeler/LabelerUtils.java | 19 +- streampipes-sinks-brokers-jvm/pom.xml | 4 +- streampipes-sinks-databases-flink/pom.xml | 2 +- streampipes-sinks-databases-jvm/pom.xml | 6 +- .../databases/jvm/influxdb/InfluxDbClient.java | 2 +- .../sinks/databases/jvm/iotdb/IotDb.java | 81 ++-- .../sinks/databases/jvm/iotdb/IotDbController.java | 1 + .../sinks/databases/jvm/iotdb/IotDbParameters.java | 49 +- .../sinks/databases/jvm/jdbcclient/JdbcClient.java | 515 ++++----------------- .../jvm/jdbcclient/model/DbDataTypeFactory.java | 231 +++++++++ .../jvm/jdbcclient/model/DbDataTypes.java | 56 +++ .../jvm/jdbcclient/model/DbDescription.java | 80 ++++ .../jdbcclient/model/JdbcConnectionParameters.java | 94 ++++ .../jvm/jdbcclient/model/ParameterInformation.java | 38 ++ .../jvm/jdbcclient/model/StatementHandler.java | 176 +++++++ .../jvm/jdbcclient/model/SupportedDbEngines.java | 47 ++ .../jvm/jdbcclient/model/TableDescription.java | 164 +++++++ .../jvm/jdbcclient/utils/SQLStatementUtils.java | 101 ++++ .../jvm/jdbcclient/utils/StatementUtils.java | 68 +++ .../sinks/databases/jvm/mysql/Column.java | 76 --- .../sinks/databases/jvm/mysql/Mysql.java | 209 +-------- .../sinks/databases/jvm/mysql/MysqlController.java | 3 +- .../sinks/databases/jvm/mysql/MysqlParameters.java | 61 +-- .../sinks/databases/jvm/postgresql/PostgreSql.java | 34 +- .../jvm/postgresql/PostgreSqlParameters.java | 58 +-- streampipes-sinks-internal-jvm/pom.xml | 2 +- streampipes-sinks-notifications-jvm/pom.xml | 2 +- streampipes-sources-vehicle-simulator/pom.xml | 2 +- streampipes-sources-watertank-simulator/pom.xml | 2 +- 58 files changed, 1440 insertions(+), 928 deletions(-) diff --cc streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/utils/OpcUaUtil.java index 839d22a,1296025..e2231e1 --- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/utils/OpcUaUtil.java +++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/utils/OpcUaUtil.java @@@ -1,7 -1,25 +1,25 @@@ + /* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + * + */ + package org.apache.streampipes.connect.adapters.opcua.utils; -import org.apache.streampipes.connect.adapter.exception.AdapterException; -import org.apache.streampipes.connect.adapter.exception.ParseException; +import org.apache.streampipes.connect.api.exception.AdapterException; +import org.apache.streampipes.connect.api.exception.ParseException; import org.apache.streampipes.connect.adapters.opcua.OpcNode; import org.apache.streampipes.connect.adapters.opcua.OpcUa; import org.apache.streampipes.model.connect.adapter.SpecificAdapterStreamDescription;
