This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch STREAMPIPES-319
in repository
https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 8677093 [STREAMPIPES-319] Refactor adapters and pipeline elements to
support service builder
add e2a7e6e Change encoding for configuration csv file
add 7f9fbb9 Change extractor type for csv file in S7 adapter
add d1a4ff4 [STREAMPIPES-320] Rework SQL clients
add e1c550b adaptions to changes in ObjectDetection
add c31ab87 [STREANPIPES-334] add UI option for label name
add a725730 [STREANPIPES-334] implement changes for Buffer Labeler as well
add 280d390 [STREAMPIPES-320] create enum for supported sql engines
add 9989f6e [STREAMPIPES-320] create class for data types of different
SupportedSQLEngines
add 7d958fe [STREAMPIPES-320] renaming
add d1bf8bc [STREAMPIPES-320] model supported data base engines
add 74f2366 [STREAMPIPES-320] model data types of the several db engines
add 32fb1f3 [STREAMPIPES-320] create separate class for
ParameterInformation
add a5451c8 [STREAMPIPES-320] create util class for statements
add 4f629e2 [STREAMPIPES-320] adapt JdbcClient to new model
add fd450ab [STREAMPIPES-320] adapt sinks to changes in JdbcClient
add 47a9ecb [STREAMPIPES-320] remove DataTypeNames.java
add b1bb5b4 [STREAMPIPES-320] change from EventProperties to EventSchema
add b9fb58b [STREAMPIPES-320] refactor ensureDatabaseExists
add bec1327 [STREAMPIPES-320] introduce JDBCConnectionParameters
add d829f8c [STREAMPIPES-320] fix PostgreSqlParameters
add dfdcbf0 [STREAMPIPES-320] implement table validation
add 3deaf97 [STREAMPIPES-320] harmonize createTable()
add d968b83 [STREAMPIPES-320] make sslFactory SQL dialect specific
add dc76354 [STREAMPIPES-320] move quotedColumn parameter to
JdbcConnectionParameters
add de9888d [STREAMPIPES-320] harmonize save() method
add 7a4bf0e [STREAMPIPES-320] restructure JdbcClient
add 046a276 [STREAMPIPES-320] restructure JdbcClient
add 27915f9 [STREAMPIPES-320] adapt IoT DB client
add 62d9c47 Revert "[STREANPIPES-334] implement changes for Buffer
Labeler as well"
add f591f8b Revert "[STREANPIPES-334] add UI option for label name"
add fd236f7 Revert "adaptions to changes in ObjectDetection"
add 76151b5 Merge remote-tracking branch 'origin/STREAMPIPES-320' into
STREAMPIPES-320
add d8dc190 Merge pull request #40 from apache/STREAMPIPES-320
add 4d1be21 Merge branch 'dev' of
github.com:apache/incubator-streampipes-extensions into dev
add bc97f85 Add support for strings in PLC4x S7 adapter
add 57aaee4 [hotfix] Fixes broken links
add 0b42645 Merge pull request #48 from vesense/patch-1
add 0aa0f6b [maven-release-plugin] prepare branch rel/0.68.0
add e2803aa [maven-release-plugin] prepare for next development iteration
add dcfb43a [hotfix] Bump sp.version to next development version
add 3013879 [hotfix] Remove dependency version from mqtt module
add 5f45d89 [hotfix] Change year in NOTICE file
add fd2b12f [hotfix] Remove explicit dependency version from SP core
dependency
add d72776c [STREAMPIPES-393] Update IOTDB version
add 999461f [hotfix] Resolve dependency conflict
add 172e741 [hotfix] Enforce slf4j dependency version
add 2411f28 [hotfix] Bump StreamPipes core version to 0.69.0-SNAPSHOT
add 52f3c96 [STREAMPIPES-394] Fix wrong timestamp extractionin Influx sink
add 6471b85 [Release] Add release notes for upcoming version 0.68.0
add 3dd3721 [hotfix] Add missing license headers
add 0403ea4 [hotfix] Add missing license headers
new 1b6daa0 Merge branch 'dev' into STREAMPIPES-319
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:
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 | 44 +-
.../jvm/jdbcclient/model/DbDescription.java | 80 ++++
.../jdbcclient/model/JdbcConnectionParameters.java | 94 ++++
.../jvm/jdbcclient/model/ParameterInformation.java | 21 +-
.../jvm/jdbcclient/model/StatementHandler.java | 176 +++++++
.../jvm/jdbcclient/model/SupportedDbEngines.java | 49 +-
.../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, 1360 insertions(+), 981 deletions(-)
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java
copy
streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/timestampextractor/OutputFields.java
=>
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
(58%)
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDescription.java
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/JdbcConnectionParameters.java
copy
streampipes-processors-enricher-flink/src/main/java/org/apache/streampipes/processors/enricher/flink/processor/math/operation/OperationDivide.java
=>
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/ParameterInformation.java
(65%)
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/StatementHandler.java
copy
streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java
=>
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/SupportedDbEngines.java
(51%)
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/TableDescription.java
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/utils/SQLStatementUtils.java
create mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/utils/StatementUtils.java
delete mode 100644
streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/Column.java
