You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by gi...@apache.org on 2022/12/21 22:10:21 UTC
[streampipes] branch dependabot/maven/org.springframework-spring-web-6.0.0 updated (30edf385c -> 08517f0ed)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/org.springframework-spring-web-6.0.0
in repository https://gitbox.apache.org/repos/asf/streampipes.git
discard 30edf385c Merge branch 'dev' into dependabot/maven/org.springframework-spring-web-6.0.0
discard 56d903e06 Merge branch 'dev' into dependabot/maven/org.springframework-spring-web-6.0.0
discard fe750a657 Bump spring-web from 5.3.20 to 6.0.0
add 92272c8ae [#854] First implementation of the StreamPipesFunctions in python (#855)
add 638b1fac4 add checkstyle to streampipes-connect-api
add b770bca77 add checkstyle to streampipes-sdk
add c77d1b0f6 add checkstyle to streampipes-rest-shared
add 87cf8c1e1 add checkstyle to streampipes-rest-core-base
add c1924181a add checkstyle to streampipes-container
add d483ca166 [hotfix] Fix checkstyle problems
add fd7a8c3ee Merge pull request #867 from apache/add-checkstyle
add f15a17d86 [hotfix] Support offset intervals in query builder
add 5581d907d [#820] Activate checkstyle for streampipes-measurement-units
add a581707ad [#820] Activate checkstyle for streampipes-pipeline-management
add ac0094de6 [#820] Activate checkstyle for streampipes-data-export
add d90d0aecf [#820] Activate checkstyle for streampipes-connect
add fc9c0a191 Bump snakeyaml from 1.31 to 1.32
add 225cfce42 Merge pull request #870 from apache/dependabot/maven/org.yaml-snakeyaml-1.32
add f4ac91c4d [hotfix] Change method name in DataExportResource
add 8f5d2aa5f Further checkstyle configurations (#869)
add 24980676a [#820] add checkstyle to streampipes-security-jwt
add d40042d84 Merge pull request #868 from apache/activate-checkstyle
add 9cac37bf2 Merge branch 'dev' into activatecheckstyle
add 1dbc92b38 Merge pull request #871 from apache/activatecheckstyle
add 5fb5c11c5 feat: [apache/streampipes#771] add husky pre commit hook for linting
add 7da1f61ef fix: [apache/streampipes#771] add missing apache header
add b1691b794 docs: [apache/streampipes#771] add README for ui
add 05d2ff652 Add checkstyle configuration for four more modules (#874)
add 08517f0ed Bump spring-web from 5.3.20 to 6.0.0
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (30edf385c)
\
N -- N -- N refs/heads/dependabot/maven/org.springframework-spring-web-6.0.0 (08517f0ed)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
pom.xml | 2 +-
streampipes-backend/pom.xml | 7 +-
.../backend/StreamPipesBackendApplication.java | 82 +-
.../streampipes/backend/StreamPipesEnvChecker.java | 23 +-
.../backend/StreamPipesPasswordEncoder.java | 9 +-
.../backend/StreamPipesResourceConfig.java | 224 ++-
.../backend/UnauthenticatedInterfaces.java | 42 +-
.../streampipes/backend/WebSecurityConfig.java | 31 +-
.../backend/migrations/AvailableMigrations.java | 8 +-
.../v070/CreateAssetLinkTypeMigration.java | 3 +-
.../v070/CreateDefaultAssetMigration.java | 3 +-
.../v070/CreateFileAssetTypeMigration.java | 12 +-
.../v090/UpdateUsernameViewMigration.java | 1 +
.../src/main/resources/application.properties | 1 -
.../src/main/resources/openapi.yaml | 2 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 613 +++++++
streampipes-client-python/setup.py | 1 +
.../streampipes_client/{ => functions}/__init__.py | 0
.../{ => functions/broker}/__init__.py | 0
.../streampipes_client/functions/broker/broker.py | 103 ++
.../functions/broker/nats_broker.py | 76 +
.../functions/function_handler.py | 201 +++
.../streampipes_client/functions/registration.py | 50 +
.../functions/streampipes_function.py | 90 +
.../{ => functions/utils}/__init__.py | 0
.../functions/utils/async_iter_handler.py | 67 +
.../functions/utils/data_stream_context.py | 54 +
.../functions/utils/function_context.py | 60 +
.../streampipes_client/model/common.py | 17 +-
.../model/resource/data_stream.py | 31 +-
.../tests/client/test_client.py | 2 +-
.../tests/client/test_endpoint.py | 16 +-
.../functions}/__init__.py | 0
.../tests/functions/test_function_handler.py | 303 ++++
streampipes-client/pom.xml | 12 +-
.../streampipes/client/StreamPipesClient.java | 77 +-
.../streampipes/client/StreamPipesCredentials.java | 9 +-
.../client/annotation/NotYetImplemented.java | 4 +-
.../streampipes/client/api/AbstractClientApi.java | 32 +-
.../apache/streampipes/client/api/AdminApi.java | 8 +-
.../org/apache/streampipes/client/api/CRUDApi.java | 12 +-
.../streampipes/client/api/DataLakeMeasureApi.java | 3 +-
.../streampipes/client/api/DataProcessorApi.java | 35 +-
.../apache/streampipes/client/api/DataSinkApi.java | 25 +-
.../streampipes/client/api/DataStreamApi.java | 14 +-
.../org/apache/streampipes/client/api/FileApi.java | 44 +-
.../streampipes/client/api/NotificationsApi.java | 2 +-
.../apache/streampipes/client/api/PipelineApi.java | 10 +-
.../client/api/PipelineElementTemplateApi.java | 4 +-
.../credentials/StreamPipesApiKeyCredentials.java | 9 +-
.../credentials/StreamPipesTokenCredentials.java | 3 +-
.../streampipes/client/http/BinaryGetRequest.java | 36 +-
.../streampipes/client/http/DeleteRequest.java | 31 +-
.../apache/streampipes/client/http/GetRequest.java | 21 +-
.../streampipes/client/http/HttpRequest.java | 36 +-
.../streampipes/client/http/PostRequest.java | 23 +-
.../http/PostRequestWithPayloadResponse.java | 19 +-
.../http/PostRequestWithoutPayloadResponse.java | 15 +-
.../apache/streampipes/client/http/PutRequest.java | 19 +-
.../streampipes/client/http/header/Headers.java | 8 +-
.../streampipes/client/live/KafkaConfig.java | 8 +-
.../client/live/SubscriptionManager.java | 30 +-
.../model/ClientConnectionConfigResolver.java | 4 +-
.../client/model/StreamPipesClientConfig.java | 3 +-
.../apache/streampipes/client/paths/ApiPath.java | 3 +-
.../client/serializer/ListSerializer.java | 9 +-
.../client/serializer/ObjectSerializer.java | 7 +-
.../streampipes/client/serializer/Serializer.java | 11 +-
.../client/util/StreamPipesApiPath.java | 16 +-
.../streampipes/config/backend/SpDataFormat.java | 8 +-
streampipes-connect-api/pom.xml | 12 +-
.../streampipes/connect/api/EmitBinaryEvent.java | 2 +-
.../connect/api/IAdapterPipelineElement.java | 2 +-
.../apache/streampipes/connect/api/IFormat.java | 28 +-
.../connect/api/exception/AdapterException.java | 16 +-
.../connect/api/exception/ParseException.java | 18 +-
.../api/exception/WorkerAdapterException.java | 27 +-
streampipes-connect-container-master/pom.xml | 9 +-
.../master/health/AdapterHealthCheck.java | 1 +
.../master/health/AdapterOperationLock.java | 1 +
.../master/management/AdapterMasterManagement.java | 3 +-
.../master/management/DescriptionManagement.java | 81 +-
.../master/management/GuessManagement.java | 66 +-
.../master/management/SourcesManagement.java | 35 +-
.../master/management/UnitMasterManagement.java | 59 +-
.../management/WorkerAdministrationManagement.java | 3 +-
.../master/management/WorkerRestClient.java | 357 ++--
.../master/management/WorkerUrlProvider.java | 3 +-
.../connect/container/master/util/WorkerPaths.java | 2 +-
.../master/health/AdapterHealthCheckTest.java | 116 +-
.../management/AdapterMasterManagementTest.java | 75 +-
.../management/DescriptionManagementTest.java | 29 +-
.../master/management/SourcesManagementTest.java | 1 +
.../management/UnitMasterManagementTest.java | 172 +-
.../master/management/WorkerRestClientTest.java | 146 +-
streampipes-connect/pom.xml | 12 +-
.../org/apache/streampipes/connect/GetNEvents.java | 30 +-
.../connect/RunningAdapterInstances.java | 40 +-
.../apache/streampipes/connect/SendToPipeline.java | 26 +-
.../streampipes/connect/adapter/Adapter.java | 143 +-
.../connect/adapter/AdapterPipelineGenerator.java | 63 +-
.../connect/adapter/GroundingService.java | 190 +--
.../connect/adapter/format/csv/CsvFormat.java | 173 +-
.../connect/adapter/format/csv/CsvParser.java | 236 +--
.../adapter/format/geojson/GeoJsonFormat.java | 162 +-
.../adapter/format/geojson/GeoJsonParser.java | 198 ++-
.../connect/adapter/format/image/ImageFormat.java | 46 +-
.../connect/adapter/format/image/ImageParser.java | 43 +-
.../adapter/format/json/AbstractJsonFormat.java | 4 +-
.../adapter/format/json/arraykey/JsonFormat.java | 37 +-
.../adapter/format/json/arraykey/JsonParser.java | 15 +-
.../format/json/arraynokey/JsonArrayFormat.java | 39 +-
.../format/json/arraynokey/JsonArrayParser.java | 15 +-
.../format/json/object/JsonObjectParser.java | 117 +-
.../adapter/format/util/JsonEventProperty.java | 128 +-
.../connect/adapter/format/xml/XmlFormat.java | 83 +-
.../connect/adapter/format/xml/XmlParser.java | 21 +-
.../connect/adapter/guess/SchemaGuesser.java | 20 +-
.../adapter/model/generic/GenericAdapter.java | 91 +-
.../model/generic/GenericDataSetAdapter.java | 83 +-
.../model/generic/GenericDataStreamAdapter.java | 79 +-
.../connect/adapter/model/generic/Parser.java | 28 +-
.../connect/adapter/model/generic/Protocol.java | 31 +-
.../pipeline/AdapterEventPreviewPipeline.java | 13 +-
.../adapter/model/pipeline/AdapterPipeline.java | 76 +-
.../adapter/model/specific/SpecificAdapter.java | 20 +-
.../model/specific/SpecificDataSetAdapter.java | 18 +-
.../model/specific/SpecificDataStreamAdapter.java | 18 +-
.../connect/adapter/preprocessing/Util.java | 44 +-
.../elements/AddTimestampPipelineElement.java | 18 +-
.../elements/AddValuePipelineElement.java | 22 +-
.../preprocessing/elements/DebugAdapterSink.java | 33 +-
.../elements/SendToBrokerAdapterSink.java | 14 +-
.../elements/SendToBrokerReplayAdapterSink.java | 120 +-
.../elements/SendToJmsAdapterSink.java | 16 +-
.../elements/SendToKafkaAdapterSink.java | 18 +-
.../elements/SendToMqttAdapterSink.java | 16 +-
.../elements/SendToNatsAdapterSink.java | 3 +-
.../TransformSchemaAdapterPipelineElement.java | 82 +-
.../elements/TransformStreamAdapterElement.java | 60 +-
.../TransformValueAdapterPipelineElement.java | 89 +-
.../transform/TransformationRule.java | 2 +-
.../schema/CreateNestedTransformationRule.java | 44 +-
.../transform/schema/DeleteTransformationRule.java | 52 +-
.../transform/schema/MoveTransformationRule.java | 122 +-
.../transform/schema/RenameTransformationRule.java | 62 +-
.../transform/schema/SchemaEventTransformer.java | 142 +-
.../stream/DuplicateFilterPipelineElement.java | 72 +-
.../stream/EventRateTransformationRule.java | 37 +-
.../transform/stream/StreamEventTransformer.java | 42 +-
.../value/CorrectionValueTransformationRule.java | 116 +-
.../value/DatatypeTransformationRule.java | 1 +
.../value/TimestampTranformationRule.java | 102 +-
.../value/TimestampTranformationRuleMode.java | 6 +-
.../transform/value/UnitTransformationRule.java | 77 +-
.../transform/value/ValueEventTransformer.java | 72 +-
.../connect/adapter/sdk/ParameterExtractor.java | 231 +--
.../connect/adapter/util/DatatypeUtils.java | 27 +-
.../adapter/util/TransportFormatGenerator.java | 10 +-
.../adapter/util/TransportFormatSelector.java | 8 +-
.../connect/adapter/GroundingServiceTest.java | 96 +-
.../streampipes/connect/adapter/TestUtils.java | 6 +-
.../format/json/arraykey/JsonParserTest.java | 13 +-
.../json/arraynokey/JsonArrayParserTest.java | 4 +-
.../adapter/format/json/geojson/GeoJsonTest.java | 545 +++---
.../format/json/object/JsonObjectParserTest.java | 45 +-
.../connect/adapter/format/json/xml/XmlTest.java | 599 +++----
.../schema/CreateNestedTransformationRuleTest.java | 49 +-
.../schema/DeleteTransformationRuleTest.java | 42 +-
.../schema/MoveTransformationRuleTest.java | 88 +-
.../schema/RenameTransformationRuleTest.java | 56 +-
.../schema/SchemaEventTransformerTest.java | 78 +-
.../value/TimestampTransformRuleTest.java | 12 +-
.../transform/value/UnitTransformRuleTest.java | 223 +--
.../transform/value/ValueEventTransformerTest.java | 46 +-
streampipes-container/pom.xml | 161 +-
.../api/AbstractPipelineElementResource.java | 18 +-
.../api/DataProcessorPipelineElementResource.java | 49 +-
.../api/DataSinkPipelineElementResource.java | 49 +-
.../api/DataStreamPipelineElementResource.java | 29 +-
.../api/InvocablePipelineElementResource.java | 76 +-
.../container/api/PipelineTemplateResource.java | 1 +
.../api/ResolvesContainerProvidedOptions.java | 4 +-
.../ResolvesContainerProvidedOutputStrategy.java | 6 +-
.../api/RuntimeResolvableRequestHandler.java | 22 +-
.../streampipes/container/api/WelcomePage.java | 10 +-
.../container/assets/AssetZipGenerator.java | 2 +-
.../container/config/ConfigExtractor.java | 8 +-
.../streampipes/container/declarer/Declarer.java | 4 +-
.../container/declarer/InvocableDeclarer.java | 10 +-
.../declarer/PipelineTemplateDeclarer.java | 2 +-
.../SemanticEventProcessingAgentDeclarer.java | 5 +-
.../declarer/SemanticEventProducerDeclarer.java | 2 +-
.../streampipes/container/html/HTMLGenerator.java | 48 +-
.../streampipes/container/html/JSONGenerator.java | 5 +-
.../html/model/DataSourceDescriptionHtml.java | 28 +-
.../container/html/model/Description.java | 229 +--
.../container/html/page/WelcomePageGenerator.java | 14 +-
.../container/init/DeclarersSingleton.java | 77 +-
.../PipelineElementServiceResourceProvider.java | 16 +-
.../container/init/RunningInstances.java | 68 +-
.../container/locales/LabelGenerator.java | 45 +-
.../container/model/ExtensionsConfig.java | 17 +-
.../streampipes/container/model/PeConfig.java | 11 +-
.../container/model/SpServiceDefinition.java | 6 +-
.../model/SpServiceDefinitionBuilder.java | 18 +-
.../streampipes/container/util/AssetsUtil.java | 18 +-
.../streampipes/container/util/ElementInfo.java | 38 +-
.../streampipes/container/util/LocalesUtil.java | 4 +-
.../container/util/ServiceDefinitionUtil.java | 18 +-
.../container/util/StandardTransportFormat.java | 45 +-
.../apache/streampipes/container/util/Util.java | 37 +-
.../dataexplorer/commons/influx/InfluxStore.java | 10 +-
.../dataexplorer/sdk/DataLakeQueryBuilder.java | 12 +
streampipes-data-export/pom.xml | 9 +
.../streampipes/export/AssetLinkResolver.java | 23 +-
.../apache/streampipes/export/ExportManager.java | 8 +-
.../export/dataimport/ImportGenerator.java | 33 +-
.../export/dataimport/PerformImportGenerator.java | 32 +-
.../export/dataimport/PreviewImportGenerator.java | 24 +-
.../export/generator/ExportPackageGenerator.java | 68 +-
.../export/generator/ZipFileBuilder.java | 8 +-
.../export/resolver/AbstractResolver.java | 15 +-
.../export/resolver/AdapterResolver.java | 3 +-
.../export/resolver/DashboardResolver.java | 3 +-
.../export/resolver/DashboardWidgetResolver.java | 3 +-
.../export/resolver/DataSourceResolver.java | 3 +-
.../export/resolver/DataViewResolver.java | 3 +-
.../export/resolver/DataViewWidgetResolver.java | 5 +-
.../streampipes/export/resolver/FileResolver.java | 3 +-
.../export/resolver/MeasurementResolver.java | 3 +-
.../export/resolver/PipelineResolver.java | 15 +-
.../export/utils/SerializationUtils.java | 3 +-
.../dataformat/cbor/CborDataFormatFactory.java | 2 +-
.../dataformat/fst/FstDataFormatFactory.java | 2 +-
.../dataformat/json/JsonDataFormatFactory.java | 2 +-
.../dataformat/smile/SmileDataFormatFactory.java | 2 +-
.../iiot/adapters/influxdb/InfluxDbClient.java | 4 +-
.../machine/MachineDataSimulatorUtils.java | 16 +-
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 2 +-
.../connect/adapters/iex/IexCloudNewsAdapter.java | 16 +-
.../connect/adapters/iex/IexCloudStockAdapter.java | 4 +-
.../connect/adapters/iss/IssAdapter.java | 4 +-
.../adapters/sensemap/OpenSenseMapAdapter.java | 2 +-
.../simulator/random/RandomDataSimulatorUtils.java | 6 +-
.../connect/adapters/slack/SlackAdapter.java | 6 +-
.../connect/adapters/ti/TISensorTag.java | 24 +-
.../aggregation/AggregationController.java | 2 +-
.../changedetection/jvm/cusum/CusumController.java | 8 +-
.../jvm/welford/WelfordChangeDetection.java | 8 +-
.../processor/timestamp/TimestampController.java | 2 +-
.../UrlDereferencingController.java | 2 +-
.../jvm/processor/math/MathOpProcessor.java | 2 +-
.../trigonometry/TrigonometryProcessor.java | 2 +-
.../valuechange/ValueChangeProcessor.java | 2 +-
.../movingaverage/MovingAverageProcessor.java | 2 +-
.../threshold/ThresholdDetectionProcessor.java | 2 +-
.../throughputmon/ThroughputMonitorProcessor.java | 10 +-
.../streampipes/processors/siddhi/topk/TopK.java | 2 +-
.../siddhi/trend/TestTrendProcessor.java | 8 +-
.../SpatialGridEnrichmentController.java | 26 +-
.../latlngtogeo/LatLngToGeoController.java | 4 +-
.../CreateTrajectoryFromPointsController.java | 2 +-
.../DistanceCalculatorController.java | 10 +-
.../geocoder/GoogleMapsGeocodingController.java | 4 +-
.../revgeocoder/ReverseGeocodingController.java | 4 +-
.../processor/speed/SpeedCalculatorController.java | 6 +-
.../StaticDistanceCalculatorController.java | 6 +-
.../StaticGoogleMapsGeocodingController.java | 4 +-
.../flink/processor/converter/FieldConverter.java | 8 +-
.../converter/FieldConverterController.java | 16 +-
.../array/count/CountArrayController.java | 2 +-
.../csvmetadata/CsvMetadataEnrichment.java | 6 +-
.../state/buffer/StateBufferController.java | 2 +-
.../TimestampExtractorController.java | 14 +-
.../duration/CalculateDurationController.java | 2 +-
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 10 +-
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 2 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 12 +-
.../simulator/vehicle/streams/VehicleStream.java | 4 +-
.../simulator/vocabulary/WaterTankVocabulary.java | 14 +-
streampipes-mail/pom.xml | 11 +-
.../apache/streampipes/mail/AbstractMailer.java | 12 +-
.../org/apache/streampipes/mail/MailSender.java | 37 +-
.../org/apache/streampipes/mail/MailTester.java | 9 +-
.../mail/config/MailConfigurationBuilder.java | 22 +-
.../mail/template/AbstractMailTemplate.java | 16 +-
.../template/AccountActiviationMailTemplate.java | 19 +-
.../mail/template/InitialPasswordMailTemplate.java | 9 +-
.../template/PasswordRecoveryMailTemplate.java | 9 +-
.../mail/template/TestMailTemplate.java | 2 +-
.../generation/MailPlaceholderBuilder.java | 8 +-
.../template/generation/MailTemplateBuilder.java | 15 +-
.../apache/streampipes/mail/utils/MailUtils.java | 5 +-
.../src/main/resources/mail-template-footer.html | 5 +-
.../main/resources/mail-template-inner-button.html | 6 +-
.../main/resources/mail-template-inner-plain.html | 16 +-
.../src/main/resources/mail-template-outer.html | 16 +-
streampipes-measurement-units/pom.xml | 92 +-
.../apache/streampipes/units/UnitCollector.java | 203 +--
.../org/apache/streampipes/units/UnitProvider.java | 84 +-
.../streampipes/units/test/TestUnitProvider.java | 42 +-
streampipes-pipeline-management/pom.xml | 9 +
.../streampipes/manager/assets/AssetExtractor.java | 4 +-
.../streampipes/manager/assets/AssetFetcher.java | 13 +-
.../streampipes/manager/assets/AssetManager.java | 5 +-
.../streampipes/manager/data/PipelineGraph.java | 7 +-
.../manager/data/PipelineGraphBuilder.java | 78 +-
.../manager/data/PipelineGraphHelpers.java | 28 +-
.../manager/endpoint/EndpointItemFetcher.java | 56 +-
.../manager/endpoint/EndpointItemParser.java | 14 +-
.../ExtensionsServiceEndpointGenerator.java | 9 +-
.../manager/execution/http/GraphSubmitter.java | 10 +-
.../manager/execution/http/HttpRequestBuilder.java | 32 +-
.../manager/execution/http/PipelineExecutor.java | 85 +-
.../execution/http/PipelineStorageService.java | 16 +-
.../execution/status/PipelineStatusManager.java | 66 +-
.../streampipes/manager/file/FileConstants.java | 1 -
.../streampipes/manager/file/FileHandler.java | 2 +-
.../streampipes/manager/file/FileManager.java | 30 +-
.../health/PipelineElementEndpointHealthCheck.java | 3 +-
.../manager/health/PipelineHealthCheck.java | 48 +-
.../manager/info/SystemInfoProvider.java | 58 +-
.../manager/info/VersionInfoProvider.java | 8 +-
.../manager/matching/ConnectionStorageHandler.java | 6 +-
.../manager/matching/DataSetGroundingSelector.java | 62 +-
.../manager/matching/FormatSelector.java | 68 +-
.../manager/matching/GroundingBuilder.java | 44 +-
.../manager/matching/GroundingSelector.java | 32 +-
.../matching/PipelineModificationGenerator.java | 25 +-
.../matching/PipelineVerificationHandlerV2.java | 8 +-
.../manager/matching/ProtocolSelector.java | 22 +-
.../EmptyRequirementsSelectorGenerator.java | 8 +-
.../mapping/MappingPropertyCalculator.java | 2 +-
.../mapping/RequirementsSelectorGenerator.java | 18 +-
.../RequirementsSelectorGeneratorFactory.java | 11 +-
.../output/AppendOutputSchemaGenerator.java | 24 +-
.../output/CustomOutputSchemaGenerator.java | 12 +-
.../CustomTransformOutputSchemaGenerator.java | 23 +-
.../output/FixedOutputSchemaGenerator.java | 2 +-
.../matching/output/ListOutputSchemaGenerator.java | 2 +-
.../matching/output/OutputSchemaFactory.java | 10 +-
.../matching/output/OutputSchemaGenerator.java | 2 +-
.../matching/output/PropertyDuplicateRemover.java | 7 +-
.../output/RenameOutputSchemaGenerator.java | 2 +-
.../output/TransformOutputSchemaGenerator.java | 83 +-
.../output/UserDefinedOutputSchemaGenerator.java | 6 +-
.../manager/matching/v2/AbstractMatcher.java | 50 +-
.../manager/matching/v2/DatatypeMatch.java | 62 +-
.../manager/matching/v2/DomainPropertyMatch.java | 51 +-
.../manager/matching/v2/ElementVerification.java | 52 +-
.../manager/matching/v2/FormatMatch.java | 4 +-
.../manager/matching/v2/GroundingMatch.java | 28 +-
.../manager/matching/v2/ListPropertyMatch.java | 6 +-
.../streampipes/manager/matching/v2/Matcher.java | 8 +-
.../manager/matching/v2/MeasurementUnitMatch.java | 16 +-
.../manager/matching/v2/NestedPropertyMatch.java | 24 +-
.../matching/v2/PrimitivePropertyMatch.java | 66 +-
.../manager/matching/v2/PropertyMatch.java | 12 +-
.../manager/matching/v2/ProtocolMatch.java | 4 +-
.../manager/matching/v2/SchemaMatch.java | 51 +-
.../manager/matching/v2/StreamMatch.java | 90 +-
.../manager/matching/v2/StreamQualityMatch.java | 30 +-
.../matching/v2/pipeline/ApplyGroundingStep.java | 16 +-
.../v2/pipeline/CheckCompletedVisitor.java | 30 +-
.../matching/v2/pipeline/ComputeOutputStep.java | 18 +-
.../v2/pipeline/PipelineValidationSteps.java | 14 +-
.../v2/pipeline/SpValidationException.java | 3 +-
.../v2/pipeline/UpdateOutputStrategiesStep.java | 28 +-
.../v2/pipeline/UpdateStaticPropertiesVisitor.java | 27 +-
.../manager/matching/v2/utils/MatchingUtils.java | 30 +-
.../monitoring/pipeline/ExtensionsLogProvider.java | 12 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 8 +-
.../streampipes/manager/operations/Operations.java | 20 +-
.../manager/permission/PermissionManager.java | 4 +-
.../manager/pipeline/PipelineCacheManager.java | 22 +-
.../PipelineCanvasMetadataCacheManager.java | 22 +-
.../manager/pipeline/PipelineManager.java | 10 +-
.../manager/preview/ActivePipelinePreviews.java | 8 +-
.../manager/preview/PipelinePreview.java | 28 +-
.../manager/recommender/AllElementsProvider.java | 18 +-
.../manager/recommender/ElementRecommender.java | 83 +-
.../remote/ContainerProvidedOptionsHandler.java | 13 +-
.../runtime/PipelineElementRuntimeInfoFetcher.java | 30 +-
.../runtime/SpDataFormatConverterGenerator.java | 8 +-
.../manager/selector/PropertyFinder.java | 2 +-
.../selector/PropertyRequirementSelector.java | 4 +-
.../manager/selector/PropertySelector.java | 49 +-
.../selector/PropertySelectorGenerator.java | 12 +-
.../manager/setup/AutoInstallation.java | 21 +-
.../manager/setup/CouchDbInstallationStep.java | 69 +-
.../manager/setup/InstallationConfiguration.java | 76 +-
.../manager/setup/InstallationStep.java | 36 +-
.../setup/PipelineElementInstallationStep.java | 6 +-
.../setup/UserRegistrationInstallationStep.java | 98 +-
.../manager/setup/design/DesignDocumentUtils.java | 1 +
.../manager/setup/design/UserDesignDocument.java | 16 +-
.../setup/tasks/CreateAssetLinkTypeTask.java | 19 +-
.../streampipes/manager/storage/UserService.java | 8 +-
.../manager/template/AdapterTemplateHandler.java | 14 +-
.../template/PipelineElementTemplateHandler.java | 3 +-
.../template/PipelineElementTemplateVisitor.java | 26 +-
.../manager/template/PipelineGenerator.java | 16 +-
.../template/PipelineTemplateGenerator.java | 22 +-
.../PipelineTemplateInvocationGenerator.java | 16 +-
.../PipelineTemplateInvocationHandler.java | 27 +-
.../instances/DataLakePipelineTemplate.java | 19 +-
.../template/instances/PipelineTemplate.java | 2 +-
.../manager/topic/WildcardTopicGenerator.java | 12 +-
.../streampipes/manager/util/AuthTokenUtils.java | 8 +-
.../manager/util/PipelineVerificationUtils.java | 6 +-
.../streampipes/manager/util/TopicGenerator.java | 3 +-
.../apache/streampipes/manager/util/TreeUtils.java | 5 +-
.../verification/DataProcessorVerifier.java | 4 +-
.../manager/verification/DataSinkVerifier.java | 75 +-
.../manager/verification/DataStreamVerifier.java | 2 +-
.../manager/verification/ElementVerifier.java | 25 +-
.../manager/verification/StorageState.java | 2 +-
.../verification/extractor/TypeExtractor.java | 95 +-
.../verification/messages/VerificationError.java | 11 +-
.../verification/messages/VerificationResult.java | 21 +-
.../verification/messages/VerificationWarning.java | 6 +-
.../runtime/HeartbeatMessageGenerator.java | 23 +-
.../verification/runtime/SourceSchemaVerifier.java | 26 +-
.../verification/structure/AbstractVerifier.java | 35 +-
.../verification/structure/GeneralVerifier.java | 31 +-
.../verification/structure/StreamVerifier.java | 29 +-
.../manager/verification/structure/Verifier.java | 6 +-
.../streampipes/manager/ThrowableCaptor.java | 22 +-
.../manager/assets/TestImagePathReplacer.java | 34 +-
.../streampipes/manager/file/TestFileManager.java | 58 +-
.../matching/TestPipelineValidationHandler.java | 58 +-
.../streampipes/manager/matching/TestRdfId.java | 6 +-
.../manager/matching/v2/ListPropertyMatchTest.java | 45 +-
.../manager/matching/v2/TestDatatypeMatch.java | 85 +-
.../matching/v2/TestDomainPropertyMatch.java | 63 +-
.../matching/v2/TestElementVerification.java | 24 +-
.../manager/matching/v2/TestFormatMatch.java | 55 +-
.../manager/matching/v2/TestGroundingMatch.java | 174 +-
.../matching/v2/TestMeasurementUnitMatch.java | 3 +-
.../matching/v2/TestPrimitivePropertyMatch.java | 75 +-
.../manager/matching/v2/TestProtocolMatch.java | 57 +-
.../manager/matching/v2/TestSchemaMatch.java | 163 +-
.../streampipes/manager/matching/v2/TestUtils.java | 123 +-
.../manager/pipeline/TestPipelineManager.java | 3 +-
.../pipeline/TestPipelinesContainingElements.java | 1 +
.../manager/selector/TestPropertyRenaming.java | 13 +-
.../streampipes/manager/selector/TestSelector.java | 15 +-
.../manager/selector/TestSelectorGenerator.java | 12 +-
.../manager/selector/TestSelectorUtils.java | 56 +-
streampipes-platform-services/pom.xml | 11 +-
.../streampipes/ps/DataLakeImageResource.java | 3 +-
.../streampipes/ps/DataLakeMeasureResourceV3.java | 40 +-
.../streampipes/ps/DataLakeMeasureResourceV4.java | 101 +-
.../apache/streampipes/ps/DataLakeResourceV3.java | 1 +
.../apache/streampipes/ps/DataLakeResourceV4.java | 583 ++++---
.../ps/PipelineElementTemplateResource.java | 212 +--
streampipes-resource-management/pom.xml | 12 +-
.../AbstractDashboardResourceManager.java | 3 +-
.../AbstractPipelineElementResourceManager.java | 23 +-
.../management/AdapterResourceManager.java | 2 +
.../management/DataProcessorResourceManager.java | 3 +-
.../management/DataSinkResourceManager.java | 3 +-
.../management/PermissionResourceManager.java | 6 +-
.../resource/management/UserResourceManager.java | 7 +-
.../resource/management/secret/SecretService.java | 2 +-
.../resource/management/secret/SecretVisitor.java | 20 +-
.../management/AdapterResourceManagerTest.java | 29 +-
.../management/DataStreamResourceManagerTest.java | 25 +-
streampipes-rest-core-base/pom.xml | 12 +-
.../base/impl/AbstractAuthGuardedRestResource.java | 23 +-
.../rest/core/base/impl/AbstractRestResource.java | 28 +-
streampipes-rest-shared/pom.xml | 149 +-
.../rest/shared/annotation/JacksonSerialized.java | 1 +
.../streampipes/rest/shared/api/CRUDResource.java | 12 +-
.../shared/impl/AbstractSharedRestInterface.java | 10 +-
.../serializer/JacksonSerializationProvider.java | 6 +-
.../rest/shared/serializer/JsonJerseyProvider.java | 137 +-
.../rest/impl/admin/DataExportResource.java | 2 +-
streampipes-sdk/pom.xml | 13 +-
.../apache/streampipes/sdk/StaticProperties.java | 65 +-
...AbstractConfigurablePipelineElementBuilder.java | 606 ++++---
.../builder/AbstractPipelineElementBuilder.java | 21 +-
.../builder/AbstractProcessingElementBuilder.java | 105 +-
.../sdk/builder/BoundPipelineElementBuilder.java | 37 +-
.../streampipes/sdk/builder/DataSetBuilder.java | 6 +-
.../streampipes/sdk/builder/DataSinkBuilder.java | 11 +-
.../streampipes/sdk/builder/DataSourceBuilder.java | 14 +-
.../streampipes/sdk/builder/DataStreamBuilder.java | 198 +--
.../sdk/builder/PipelineTemplateBuilder.java | 3 +-
.../sdk/builder/PrimitivePropertyBuilder.java | 242 +--
.../sdk/builder/ProcessingElementBuilder.java | 12 +-
.../sdk/builder/PropertyRequirementsBuilder.java | 25 +-
.../sdk/builder/StreamRequirementsBuilder.java | 50 +-
.../sdk/builder/WildcardTopicBuilder.java | 2 +-
.../builder/adapter/AdapterDescriptionBuilder.java | 20 +-
.../builder/adapter/FormatDescriptionBuilder.java | 9 +-
.../sdk/builder/adapter/GuessSchemaBuilder.java | 5 +-
.../adapter/ProtocolDescriptionBuilder.java | 17 +-
.../adapter/SpecificDataSetAdapterBuilder.java | 11 +-
.../adapter/SpecificDataStreamAdapterBuilder.java | 12 +-
.../sdk/extractor/AbstractParameterExtractor.java | 333 ++--
.../sdk/extractor/DataSinkParameterExtractor.java | 8 +-
.../ProcessingElementParameterExtractor.java | 32 +-
.../sdk/extractor/StaticPropertyExtractor.java | 2 +-
.../streampipes/sdk/helpers/Alternatives.java | 7 +-
.../streampipes/sdk/helpers/CodeLanguage.java | 19 +-
.../sdk/helpers/CollectedStreamRequirements.java | 3 +-
.../streampipes/sdk/helpers/EpProperties.java | 60 +-
.../streampipes/sdk/helpers/EpRequirements.java | 23 +-
.../apache/streampipes/sdk/helpers/Formats.java | 15 +-
.../apache/streampipes/sdk/helpers/Groundings.java | 24 +-
.../org/apache/streampipes/sdk/helpers/Labels.java | 25 +-
.../apache/streampipes/sdk/helpers/Locales.java | 4 +-
.../apache/streampipes/sdk/helpers/Options.java | 3 +-
.../streampipes/sdk/helpers/OutputStrategies.java | 184 ++-
.../apache/streampipes/sdk/helpers/Protocols.java | 34 +-
.../streampipes/sdk/helpers/StreamIdentifier.java | 5 +-
.../streampipes/sdk/helpers/SupportedFormats.java | 15 +-
.../sdk/helpers/SupportedProtocols.java | 3 +
.../sdk/helpers/TransformOperations.java | 44 +-
.../org/apache/streampipes/sdk/helpers/Tuple2.java | 30 +-
.../org/apache/streampipes/sdk/helpers/Tuple3.java | 34 +-
.../streampipes/sdk/stream/SchemaBuilder.java | 57 +-
.../streampipes/sdk/stream/StreamBuilder.java | 90 +-
.../apache/streampipes/sdk/utils/Datatypes.java | 50 +-
.../GenericDataStreamAdapterBuilderTest.java | 25 +-
streampipes-security-jwt/pom.xml | 11 +-
.../security/jwt/JwtTokenGenerator.java | 17 +-
.../streampipes/security/jwt/JwtTokenUtils.java | 8 +-
.../security/jwt/JwtTokenValidator.java | 6 +-
.../streampipes/security/jwt/KeyGenerator.java | 9 +-
.../apache/streampipes/security/jwt/KeyUtils.java | 12 +-
.../test/generator/EventStreamGenerator.java | 2 +-
streampipes-user-management/pom.xml | 11 +-
.../StreamPipesCredentialsMatcher.java | 1 +
.../encryption/SecretEncryptionManager.java | 1 +
.../user/management/jwt/JwtTokenProvider.java | 162 +-
.../user/management/jwt/SpKeyResolver.java | 7 +-
.../management/model/PrincipalUserDetails.java | 3 +-
.../management/service/SpUserDetailsService.java | 4 +-
.../user/management/service/TokenService.java | 10 +-
.../user/management/service/UserService.java | 3 +-
.../management/util/GrantedAuthoritiesBuilder.java | 3 +-
.../management/util/GrantedPermissionsBuilder.java | 8 +-
.../user/management/util/PasswordUtil.java | 7 +-
.../user/management/util/TokenUtil.java | 5 +-
.../user/management/util/UserInfoUtil.java | 6 +-
.../user/management/util/TestTokenUtil.java | 5 +-
streampipes-vocabulary/pom.xml | 15 +-
.../org/apache/streampipes/vocabulary/FOAF.java | 57 +-
.../java/org/apache/streampipes/vocabulary/GR.java | 86 +-
.../org/apache/streampipes/vocabulary/Geo.java | 12 +-
.../apache/streampipes/vocabulary/Geonames.java | 35 +-
.../streampipes/vocabulary/MessageFormat.java | 14 +-
.../org/apache/streampipes/vocabulary/RDF.java | 2 +-
.../java/org/apache/streampipes/vocabulary/SO.java | 1742 ++++++++++----------
.../apache/streampipes/vocabulary/SPSensor.java | 16 +-
.../org/apache/streampipes/vocabulary/SSN.java | 2 +-
.../vocabulary/SemanticTypeRegistry.java | 6 +-
.../org/apache/streampipes/vocabulary/XSD.java | 283 ++--
tools/maven/suppressions.xml | 1 +
.../client/__init__.py => ui/.husky/pre-commit | 9 +-
ui/.lintstagedrc.json | 4 +
.../documentation.md => ui/README.md | 43 +-
ui/package.json | 16 +-
566 files changed, 13189 insertions(+), 10127 deletions(-)
create mode 100644 streampipes-client-python/docs/examples/3-getting-live-data-from-the-streampipes-data-stream.ipynb
copy streampipes-client-python/streampipes_client/{ => functions}/__init__.py (100%)
copy streampipes-client-python/streampipes_client/{ => functions/broker}/__init__.py (100%)
create mode 100644 streampipes-client-python/streampipes_client/functions/broker/broker.py
create mode 100644 streampipes-client-python/streampipes_client/functions/broker/nats_broker.py
create mode 100644 streampipes-client-python/streampipes_client/functions/function_handler.py
create mode 100644 streampipes-client-python/streampipes_client/functions/registration.py
create mode 100644 streampipes-client-python/streampipes_client/functions/streampipes_function.py
copy streampipes-client-python/streampipes_client/{ => functions/utils}/__init__.py (100%)
create mode 100644 streampipes-client-python/streampipes_client/functions/utils/async_iter_handler.py
create mode 100644 streampipes-client-python/streampipes_client/functions/utils/data_stream_context.py
create mode 100644 streampipes-client-python/streampipes_client/functions/utils/function_context.py
copy streampipes-client-python/{streampipes_client => tests/functions}/__init__.py (100%)
create mode 100644 streampipes-client-python/tests/functions/test_function_handler.py
copy streampipes-client-python/streampipes_client/client/__init__.py => ui/.husky/pre-commit (90%)
mode change 100644 => 100755
create mode 100644 ui/.lintstagedrc.json
copy streampipes-extensions/streampipes-processors-geo-jvm/src/main/resources/org.apache.streampipes.processor.geo.jvm.staticgeocoding/documentation.md => ui/README.md (51%)