This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch fix-function-output-timestamp in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 184cf5dd397e33b9e18e175986423a032e3ba2df Merge: ae64f3f7ad bfdf3dfff4 Author: bossenti <[email protected]> AuthorDate: Wed Mar 13 14:33:41 2024 +0100 Merge remote-tracking branch 'origin/dev' into fix-function-output-timestamp pom.xml | 48 +-- streampipes-client/pom.xml | 4 +- .../client/util/StreamPipesApiPathTest.java | 13 +- streampipes-commons/pom.xml | 5 +- .../commons/parser/BooleanParserTest.java | 16 +- .../commons/parser/FloatParserTest.java | 12 +- .../commons/parser/IntegerParserTest.java | 12 +- .../commons/parser/StringParserTest.java | 4 +- .../prometheus/adapter/AdapterMetricsTest.java | 13 +- .../commons/resources/TestResources.java | 7 +- streampipes-connect-management/pom.xml | 4 +- .../management/health/AdapterHealthCheckTest.java | 17 +- .../management/AdapterMasterManagementTest.java | 25 +- .../management/SourcesManagementTest.java | 16 +- streampipes-connect-shared/pom.xml | 6 +- .../connect/shared/preprocessing/UtilsTest.java | 11 +- .../convert/ToOriginalSchemaConverterTest.java | 25 +- .../convert/ToTransformedSchemaConverterTest.java | 30 +- .../AdapterTransformationPipelineElementTest.java | 14 +- .../preprocessing/transform/DatatypeUtilsTest.java | 31 +- .../schema/CreateNestedTransformationRuleTest.java | 21 +- .../schema/DeleteTransformationRuleTest.java | 11 +- .../schema/MoveTransformationRuleTest.java | 28 +- .../schema/RenameTransformationRuleTest.java | 18 +- .../schema/SchemaEventTransformerTest.java | 23 +- .../transform/value/CorrectionValueTest.java | 38 +- .../transform/value/UnitTransformRuleTest.java | 36 +- .../transform/value/ValueEventTransformerTest.java | 7 +- streampipes-data-explorer-commons/pom.xml | 4 +- .../commons/influx/InfluxClientProviderTest.java | 17 +- .../commons/influx/InfluxStoreTest.java | 13 +- .../influx/serializer/TestRawFieldSerializer.java | 6 +- .../sanitizer/MeasureNameSanitizerTest.java | 11 +- streampipes-data-explorer/pom.xml | 17 +- .../param/ProvidedRestQueryParams.java | 2 +- .../DataExplorerSchemaManagementTest.java | 12 +- .../dataexplorer/param/SelectQueryParamsTest.java | 4 +- .../param/WhereStatementParamsTest.java | 4 +- .../writer/TestConfiguredCsvOutputWriter.java | 4 +- .../writer/TestConfiguredJsonOutputWriter.java | 4 +- .../query/writer/TestConfiguredOutputWriter.java | 4 +- .../query/writer/item/TestCsvItemWriter.java | 4 +- .../query/writer/item/TestItemWriter.java | 4 +- .../query/writer/item/TestJsonItemWriter.java | 4 +- .../dataexplorer/sdk/DataLakeQueryBuilderTest.java | 4 +- streampipes-extensions-management/pom.xml | 19 +- .../connect/AdapterWorkerManagementTest.java | 8 +- .../ConnectWorkerDescriptionProviderTest.java | 19 +- .../management/connect/GuessManagementTest.java | 10 +- .../management/connect/adapter/TestUtils.java | 9 - .../connect/adapter/parser/CsvParserTest.java | 14 +- .../connect/adapter/parser/XmlParserTest.java | 4 +- .../adapter/parser/json/GeoJsonParserTest.java | 9 +- .../parser/json/JsonArrayKeyParserTest.java | 21 +- .../adapter/parser/json/JsonArrayParserTest.java | 9 +- .../adapter/parser/json/JsonObjectParsersTest.java | 17 +- .../management/init/DeclarersSingletonTest.java | 9 +- .../management/locales/LabelGeneratorTest.java | 10 +- .../model/SpServiceDefinitionBuilderTest.java | 27 +- .../management/util/EventSchemaUtilsTest.java | 17 +- .../streampipes-connect-adapters-iiot/pom.xml | 31 +- .../adapters/iolink/sensor/SensorVVB001Test.java | 24 +- .../RosBridgeAdapterMigrationV1Test.java | 10 +- .../streampipes-connect-adapters/pom.xml | 27 +- .../streampipes-connectors-opcua/pom.xml | 8 +- .../adapter/OpcUaNodeMetadataExtractorTest.java | 69 ++-- .../migration/OpcUaAdapterMigrationV2Test.java | 10 +- .../connectors/opcua/utils/OpcUaUtilTest.java | 9 +- .../streampipes-connectors-plc/pom.xml | 4 +- .../migration/Plc4xModbusAdapterMigrationTest.java | 8 +- .../adapter/s7/config/ConfigurationParserTest.java | 11 +- .../streampipes-connectors-pulsar/pom.xml | 6 +- .../connectors/pulsar/TestPulsarParameters.java | 25 +- .../connectors/pulsar/TestPulsarPublisherSink.java | 44 ++- .../streampipes-connectors-rocketmq/pom.xml | 5 +- .../rocketmq/TestRocketMQPublisherSink.java | 2 +- .../streampipes-processors-enricher-jvm/pom.xml | 12 + .../sizemeasure/TestSizeMeasureProcessor.java | 221 +++++------ .../streampipes-processors-filters-jvm/pom.xml | 17 + .../booleanfilter/BooleanFilterProcessor.java | 8 +- .../booleanfilter/TestBooleanFilterProcessor.java | 140 +++---- .../processor/compose/TestComposeProcessor.java | 257 ++++++------- .../processor/merge/TestMergeByTimeProcessor.java | 312 +++++++-------- .../TestSwingingDoorTrendingFilterProcessor.java | 287 +++++++------- .../textfilter/TestTextFilterProcessor.java | 220 +++++------ .../streampipes-processors-filters-siddhi/pom.xml | 4 +- .../siddhi/trend/TestTrendProcessor.java | 302 +++++++-------- .../pom.xml | 4 +- .../counter/TestBooleanCounterProcessor.java | 279 ++++++-------- .../inverter/TestBooleanInverterProcessor.java | 244 ++++++------ .../datetime/TestDateTimeFromStringProcessor.java | 423 ++++++++++----------- .../StaticMetaDataEnrichmentProcessorTest.java | 10 +- .../counter/TestStringCounterProcessor.java | 288 +++++++------- .../state/TestStringToStateProcessor.java | 339 ++++++++--------- .../timer/TestStringTimerProcessor.java | 349 ++++++++--------- .../change/TestChangedValueDetectionProcessor.java | 17 +- .../streampipes-sinks-databases-jvm/pom.xml | 4 +- .../streampipes-sinks-internal-jvm/pom.xml | 4 +- .../migrations/DataLakeSinkMigrationV1Test.java | 19 +- .../streampipes-sinks-notifications-jvm/pom.xml | 5 + .../notifications/jvm/msteams/TestMSTeamsSink.java | 28 +- streampipes-integration-tests/pom.xml | 37 +- .../integration/adapters/AdapterTesterBase.java | 4 +- .../integration/adapters/AdaptersTest.java | 2 +- .../integration/client/ClientLiveDataTest.java | 2 +- .../client/ClientLiveDataTesterBase.java | 4 +- streampipes-maven-plugin/pom.xml | 32 +- .../smp/generator/TestMarkdownTitleRemover.java | 2 +- .../smp/parser/TestDocumentationParser.java | 4 +- streampipes-measurement-units/pom.xml | 5 +- .../streampipes/units/test/TestUnitProvider.java | 9 +- streampipes-model/pom.xml | 6 +- .../model/assets/AssetLinkBuilderTest.java | 27 +- .../model/builder/TestStreamBuilder.java | 23 -- .../connect/adapter/AdapterDescriptionTest.java | 18 +- .../model/datalake/DataLakeMeasureTest.java | 11 +- .../model/datalake/DataSeriesBuilderTest.java | 33 +- .../model/datalake/SpQueryResultBuilderTest.java | 41 +- .../model/migration/ModelMigratorConfigTest.java | 33 +- .../streampipes/model/runtime/TestEvent.java | 48 +-- .../model/runtime/TestEventConverter.java | 24 +- .../model/runtime/TestEventFactory.java | 25 +- .../model/runtime/TestFieldAddition.java | 17 +- .../streampipes/model/runtime/TestListField.java | 13 +- .../model/runtime/TestPropertyRenaming.java | 25 +- .../streampipes/model/runtime/TestSubset.java | 28 +- streampipes-pipeline-management/pom.xml | 19 +- .../manager/assets/TestImagePathReplacer.java | 7 +- .../streampipes/manager/file/TestFileManager.java | 11 +- .../manager/matching/v2/ListPropertyMatchTest.java | 9 +- .../manager/matching/v2/TestDatatypeMatch.java | 12 +- .../matching/v2/TestDomainPropertyMatch.java | 10 +- .../manager/matching/v2/TestFormatMatch.java | 10 +- .../manager/matching/v2/TestGroundingMatch.java | 14 +- .../matching/v2/TestMeasurementUnitMatch.java | 7 +- .../matching/v2/TestPrimitivePropertyMatch.java | 12 +- .../manager/matching/v2/TestProtocolMatch.java | 10 +- .../manager/matching/v2/TestSchemaMatch.java | 14 +- .../manager/migration/MigrationUtilsTest.java | 28 +- .../manager/pipeline/TestPipelineManager.java | 80 ---- .../manager/selector/TestPropertyRenaming.java | 7 +- .../streampipes/manager/selector/TestSelector.java | 38 +- .../manager/selector/TestSelectorGenerator.java | 10 +- .../apache/streampipes/ps/DataLakeResourceV4.java | 3 +- streampipes-resource-management/pom.xml | 4 +- .../management/AdapterResourceManagerTest.java | 2 +- .../management/DataStreamResourceManagerTest.java | 2 +- streampipes-rest-extensions/pom.xml | 7 + .../migration/MigrateExtensionsResourceTest.java | 31 +- streampipes-rest-shared/pom.xml | 4 +- streampipes-rest/pom.xml | 14 +- streampipes-sdk/pom.xml | 4 +- .../streampipes/sdk/StaticPropertiesTest.java | 11 +- .../sdk/builder/NestedPropertyBuilderTest.java | 38 +- .../adapter/AdapterConfigurationBuilderTest.java | 23 +- .../builder/adapter/AdapterConfigurationTest.java | 7 +- .../extractor/AdapterParameterExtractorTest.java | 6 +- .../apache/streampipes/sdk/helpers/LabelsTest.java | 9 +- streampipes-serializers-json/pom.xml | 4 +- .../serializers/json/TestJacksonSerializer.java | 27 +- streampipes-service-core/pom.xml | 10 +- ...eFilenamesAndRenameDuplicatesMigrationTest.java | 28 +- streampipes-storage-couchdb/pom.xml | 4 +- .../couchdb/serializer/TestGsonSerializer.java | 27 +- .../storage/couchdb/utils/TestUrlEscapers.java | 9 +- streampipes-test-utils/pom.xml | 13 +- streampipes-user-management/pom.xml | 4 +- .../user/management/util/TestPasswordUtil.java | 12 +- .../user/management/util/TestTokenUtil.java | 23 +- 169 files changed, 2734 insertions(+), 3264 deletions(-)
