This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch SP-1713
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 7612c6e14 [#1713] Fix timestamp tests to run independent of time zone
add e5889b936 Bump guava from 31.1-jre to 32.0.1-jre (#1687)
add 235c67ca4 Bump @swimlane/ngx-charts from 20.1.2 to 20.4.1 in /ui
(#1686)
add 92f47cce5 Bump snappy-java from 1.1.7.7 to 1.1.10.1 (#1689)
add b18ad977d Bump dependency-check-maven from 6.5.1 to 8.3.1 (#1692)
add b234935fc chore: improve metadata for repository (#1694)
add 4bafdbea5 Bump pyupgrade from 3.6.0 to 3.7.0 in
/streampipes-client-python (#1697)
add b6f15d4c1 Bump @typescript-eslint/parser from 5.56.0 to 5.59.11 in /ui
(#1699)
add ff5362c5c Bump mockito-core from 5.3.1 to 5.4.0 (#1698)
add 1a2b3688e Set value for checkstyle base path in more modules.
add f9c6e2045 Merge pull request #1696 from
apache/checkstyle-header-path-for-submodules
add d8a788585 Bump mypy from 1.3.0 to 1.4.0 in /streampipes-client-python
(#1707)
add 0ae6f0a5c Use UTF_8 as the encoding when generating the label (#1701)
add 87940b25c [hotfix] Update release notes
add 6a174ec37 Maven housekeeping (#1695)
add c48d135a1 Bump autoflake from 2.1.0 to 2.2.0 in
/streampipes-client-python (#1712)
add bea143804 Bump pytest from 7.3.0 to 7.4.0 in
/streampipes-client-python (#1711)
add 1b1166757 Bump formatter-maven-plugin from 2.21.0 to 2.23.0 (#1710)
add 58d219491 fix: kafka consumer data loss promble (#1629)
add 27839afdf Harmonize OPC-UA adapter and sink, add timestamp to metadata
(#899) (#1682)
add 117af967b Support migration of adapters in data import (#1683)
add f3fd3802e Add creation of attachments for CouchDB (#1716)
add fb7493076 [hotfix] Use latest offset setting as kafka consumer default
(#1720)
add 77d7bc323 Merge branch 'dev' into SP-1713
No new revisions were added by this update.
Summary of changes:
README.md | 4 +-
RELEASE_NOTES.md | 131 ++++
.../streampipes-archetype-extensions-jvm/pom.xml | 5 +
.../pom.xml | 5 +
.../streampipes-archetype-pe-sinks-flink/pom.xml | 5 +
pom.xml | 12 +-
streampipes-client-python/README.md | 3 +
streampipes-client-python/setup.py | 9 +-
streampipes-client/pom.xml | 4 -
streampipes-commons/pom.xml | 10 +
.../streampipes/commons/resources/Resources.java | 19 +-
.../src/test/java/TestResources.java | 18 +-
streampipes-commons/src/test/resources/test.txt | 1 +
streampipes-config/pom.xml | 6 -
.../param/model/SelectClauseParams.java | 6 +-
.../writer/TestConfiguredCsvOutputWriter.java | 4 +-
.../writer/TestConfiguredJsonOutputWriter.java | 4 +-
.../export/dataimport/PerformImportGenerator.java | 4 +-
.../export/dataimport/PreviewImportGenerator.java | 18 +-
.../export/utils/ImportAdapterMigrationUtils.java | 55 ++
.../management/locales/LabelGenerator.java | 4 +-
.../iiot/protocol/stream/KafkaProtocol.java | 21 +-
.../strings.en | 12 +
.../streampipes-extensions-all-iiot/pom.xml | 5 +
.../streampipes-extensions-all-jvm/pom.xml | 5 +
.../streampipes-pipeline-elements-all-jvm/pom.xml | 5 +
.../pe/shared/config/kafka/KafkaConfig.java | 15 +-
.../pe/shared/config/kafka/KafkaConnectUtils.java | 32 +-
.../pe/shared/config/kafka/kafka/KafkaConfig.java | 13 +-
.../config/kafka/kafka/KafkaConnectUtils.java | 35 +-
.../pom.xml | 5 +
.../streampipes-processors-enricher-jvm/pom.xml | 5 +
.../streampipes-processors-filters-jvm/pom.xml | 5 +
.../streampipes-processors-filters-siddhi/pom.xml | 5 +
.../streampipes-processors-geo-jvm/pom.xml | 5 +
.../pom.xml | 5 +
.../streampipes-processors-text-mining-jvm/pom.xml | 5 +
.../streampipes-sinks-brokers-jvm/pom.xml | 5 +
.../streampipes-sinks-databases-jvm/pom.xml | 5 +
.../streampipes-sinks-internal-jvm/pom.xml | 5 +
.../streampipes-sinks-notifications-jvm/pom.xml | 5 +
.../pom.xml | 5 +
streampipes-integration-tests/pom.xml | 5 +
.../apache/streampipes/mail/utils/MailUtils.java | 7 +-
streampipes-measurement-units/pom.xml | 3 +-
.../java/com/github/jqudt/onto/UnitFactory.java | 24 -
.../java/com/github/jqudt/onto/units/AreaUnit.java | 23 -
.../github/jqudt/onto/units/ConcentrationUnit.java | 25 -
.../com/github/jqudt/onto/units/CountingUnit.java | 16 -
.../com/github/jqudt/onto/units/EnergyUnit.java | 16 -
.../com/github/jqudt/onto/units/LengthUnit.java | 19 -
.../java/com/github/jqudt/onto/units/MassUnit.java | 23 -
.../jqudt/onto/units/PressureOrStressUnit.java | 15 -
.../github/jqudt/onto/units/TemperatureUnit.java | 18 -
.../com/github/jqudt/onto/units/VolumeUnit.java | 18 -
.../AutoOffsetResetConfig.java} | 21 +-
.../kafka/config/ConsumerConfigFactory.java | 3 +-
streampipes-model/pom.xml | 17 +-
.../adapter/migration/GenericAdapterConverter.java | 94 +--
.../adapter/migration/IAdapterConverter.java | 6 +-
.../adapter/migration}/MigrationHelpers.java | 11 +-
.../migration/SpecificAdapterConverter.java | 17 +-
.../migration}/format/CsvFormatMigrator.java | 2 +-
.../migration}/format/EmptyFormatMigrator.java | 2 +-
.../adapter/migration}/format/FormatMigrator.java | 2 +-
.../migration}/format/JsonFormatMigrator.java | 12 +-
.../migration}/format/XmlFormatMigrator.java | 2 +-
.../adapter/migration/utils/AdapterModels.java | 28 +-
.../adapter/migration}/utils/DocumentKeys.java | 2 +-
.../adapter/migration}/utils/FormatIds.java | 2 +-
.../migration}/utils/GenericAdapterUtils.java | 8 +-
.../model/file/GenericStorageAttachment.java | 40 +-
.../streampipes/model/schema/EventProperty.java | 2 +-
.../streampipes/model/schema/EventSchema.java | 3 +-
.../model/{Tuple2.java => util/ListUtils.java} | 41 +-
.../manager/assets/DocumentationParser.java | 6 +-
.../manager/endpoint/EndpointItemFetcher.java | 3 +-
.../manager/endpoint/EndpointItemParser.java | 3 +-
.../manager/pipeline/PipelineManager.java | 10 +-
streampipes-sdk/pom.xml | 14 +-
.../org/apache/streampipes/sdk/helpers/Labels.java | 13 +-
streampipes-service-base/pom.xml | 4 -
.../service/core/WebSecurityConfig.java | 2 +-
.../core}/filter/TokenAuthenticationFilter.java | 2 +-
.../core/migrations/v093/AdapterBackupWriter.java | 2 +-
.../core/migrations/v093/AdapterMigration.java | 36 +-
.../v093/migrator/GenericAdapterMigrator.java | 102 +--
.../v093/migrator/SpecificAdapterMigrator.java | 11 +-
streampipes-service-discovery-consul/pom.xml | 4 -
.../streampipes/storage/api/IGenericStorage.java | 7 +
streampipes-storage-couchdb/pom.xml | 8 +-
.../couchdb/impl/ConnectionStorageImpl.java | 5 +-
.../storage/couchdb/impl/GenericStorageImpl.java | 25 +-
.../streampipes/storage/couchdb/utils/Utils.java | 11 +
.../storage/couchdb/utils/TestUrlEscapers.java} | 27 +-
streampipes-user-management/pom.xml | 4 +-
streampipes-wrapper-distributed/pom.xml | 5 +
streampipes-wrapper-flink/pom.xml | 5 +
streampipes-wrapper-kafka-streams/pom.xml | 5 +
streampipes-wrapper-python/pom.xml | 5 +
streampipes-wrapper-siddhi/pom.xml | 5 +
streampipes-wrapper/pom.xml | 5 +
ui/package-lock.json | 692 ++++++++++++---------
ui/package.json | 4 +-
104 files changed, 1181 insertions(+), 901 deletions(-)
copy
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/ParserTest.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/resources/Resources.java
(61%)
copy
streampipes-extensions-management/src/test/java/org/apache/streampipes/extensions/management/connect/adapter/parser/ParserTest.java
=> streampipes-commons/src/test/java/TestResources.java (66%)
create mode 100644 streampipes-commons/src/test/resources/test.txt
create mode 100644
streampipes-data-export/src/main/java/org/apache/streampipes/export/utils/ImportAdapterMigrationUtils.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/AreaUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/ConcentrationUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/CountingUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/EnergyUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/LengthUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/MassUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/PressureOrStressUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/TemperatureUnit.java
delete mode 100644
streampipes-measurement-units/src/main/java/com/github/jqudt/onto/units/VolumeUnit.java
copy
streampipes-messaging-kafka/src/main/java/org/apache/streampipes/messaging/kafka/{security/KafkaSecurityUnauthenticatedSSLConfig.java
=> config/AutoOffsetResetConfig.java} (63%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator/GenericAdapterMigrator.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/GenericAdapterConverter.java
(52%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/FormatMigrator.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/IAdapterConverter.java
(84%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/migrator
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/MigrationHelpers.java
(79%)
copy
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/format/EmptyFormatMigrator.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/SpecificAdapterConverter.java
(61%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/CsvFormatMigrator.java
(96%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/EmptyFormatMigrator.java
(93%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/FormatMigrator.java
(92%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/JsonFormatMigrator.java
(84%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/format/XmlFormatMigrator.java
(95%)
rename
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/utils/AdapterMigrationUtils.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration/utils/AdapterModels.java
(66%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/utils/DocumentKeys.java
(93%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/utils/FormatIds.java
(96%)
rename
{streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093
=>
streampipes-model/src/main/java/org/apache/streampipes/model/connect/adapter/migration}/utils/GenericAdapterUtils.java
(97%)
copy
streampipes-extensions/streampipes-pipeline-elements-experimental-flink/src/main/java/org/apache/streampipes/pe/flink/processor/wordcount/Word.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/file/GenericStorageAttachment.java
(59%)
copy streampipes-model/src/main/java/org/apache/streampipes/model/{Tuple2.java
=> util/ListUtils.java} (56%)
rename {streampipes-rest/src/main/java/org/apache/streampipes/rest =>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core}/filter/TokenAuthenticationFilter.java
(98%)
copy
streampipes-storage-couchdb/src/{main/java/org/apache/streampipes/storage/couchdb/utils/Filter.java
=>
test/java/org/apache/streampipes/storage/couchdb/utils/TestUrlEscapers.java}
(50%)
