This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch improve-indicator-widget
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 4f5a50f775 Add manuel font size selection to appearance config
add 2cb63ad525 fix: Properly handle optional static properties (#4212)
add 01f86e3468 chore: Cleanup some code in streampipes-rest (#4215)
add 9c18cc87dd chore(deps-dev): bump markdown from 3.8 to 3.8.1 in
/streampipes-client-python (#4226)
add bb39d07a24 fix: Remember page settings after logout (#4225)
add 05562b3e0c chore: Simplify code to verify pipeline elements (#4223)
add c0a2d74df5 test(#4229): rename DataExplorer utils and test paths to
Chart terminology (#4230)
add 3bcccda16d feat: Support refresh tokens (#4231)
add 2f87e2cccb chore: Remove migrations from v097 downwards (#4232)
add b4e7087f35 feat: Remove obsolete asset user role (#4233)
add 19351a9aeb refactor: Improve registration of available settings views
(#4234)
add b4520ca7e1 feat: Integrate Camel kamelets, add Azure sinks (#4214)
add 377b586967 fix(#4241): wait for file selection before continuing
File_Stream setup (#4243)
add 8d6f35e630 refactor(#4236): move shared enums and guards into core
domains (#4237)
add 2ce5dfceb4 chore(deps): bump docker/build-push-action from 6 to 7
(#4227)
add c1bdbe99bd chore(deps): bump docker/login-action from 3 to 4 (#4221)
add c0cced24c3 chore(deps): bump docker/setup-qemu-action from 3 to 4
(#4220)
add 038007ba62 chore(deps): bump actions/upload-artifact from 6 to 7
(#4206)
add 241c43379e chore(deps-dev): bump tornado from 6.5 to 6.5.5 in
/streampipes-client-python (#4245)
add 444028b0a9 fix(#4246): Accept full and shorthand propertyScope values
in compactadapters (#4249)
add 6a5296f321 feat(#4247): Add asset infos to resource table (#4248)
add 8e1f89965a feat: Full integration of filter feature for table widget,
excel like filte… (#4240)
add 0d679f838b feat(#4250): add csv dataset import with preview for data
sets (#4254)
add d628cd9b8a refactor: migrate pipeline element e2e cases (#4265)
add 1ebfb39f25 Add new unit tests for processing elements (#4266)
add f069bb6976 refactor: Improve StreamPipesFunction monitoring (#4269)
add a708d2f868 fix: fix cypress e2e tests (#4268)
add 75e4d76578 refactor: migrate core-ui components to signals (#4267)
add 80ae050bb7 feat(#4252): Support broker-based core-extension
communication mode (#4242)
add d02f04d242 fix: Use pinned Github actions versions
add c10c930038 Merge branch 'dev' into improve-indicator-widget
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 18 +-
.github/workflows/extensions-docs.yml | 6 +-
.github/workflows/go-client-e2e-test.yml | 2 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/mvn-integration-test.yml | 2 +-
.github/workflows/pypi-deployment.yml | 2 +-
.github/workflows/python-docs.yml | 2 +-
installer/cli/.env | 3 +
installer/cli/README.md | 8 +
.../deploy/standalone/backend/docker-compose.yml | 1 +
.../extensions-all-jvm/docker-compose.yml | 1 +
.../{nats => nats-auth}/docker-compose.dev.yml | 0
.../docker-compose.yml | 12 +-
.../.env => cli/environments/backend-nats-auth} | 12 +-
.../.env => cli/environments/basic-nats-auth} | 11 +-
.../.env => cli/environments/lite-nats-auth} | 14 +-
.../environments/pipeline-element-nats-auth} | 13 +-
installer/compose/.env | 4 +
installer/compose/README.md | 14 +-
.../{.env => docker-compose.minimal.nats-auth.yml} | 18 +-
.../compose/{.env => docker-compose.nats-auth.yml} | 18 +-
pom.xml | 108 ++-
.../apache/streampipes/client/api/IAdminApi.java | 3 -
streampipes-client-e2e/docker-compose.yml | 2 +
.../go-client-e2e/pipelines/pipelines.json | 96 +--
.../streampipes/model/pipeline/pipeline.go | 2 -
streampipes-client-python/poetry.lock | 76 +-
.../apache/streampipes/client/api/AdminApi.java | 12 -
.../apache/streampipes/commons/constants/Envs.java | 7 +
.../commons/environment/DefaultEnvironment.java | 20 +
.../commons/environment/Environment.java | 8 +
.../commons/media/ImageMimeTypeDetector.java | 60 ++
.../management/compact/AdapterGenerationSteps.java | 8 +-
.../management/compact/PersistPipelineHandler.java | 6 +-
.../management/compact/SchemaMetadataEnricher.java | 24 +-
.../management/AdapterMasterManagement.java | 58 +-
.../management/AdapterMigrationManager.java | 27 +-
.../management/AdapterUpdateManagement.java | 19 +-
.../management/DescriptionManagement.java | 22 +-
.../management/management/GuessManagement.java | 41 +-
.../management/WorkerAdministrationManagement.java | 8 +-
.../management/management/WorkerRestClient.java | 182 ++--
.../connect/management/util/WorkerPaths.java | 51 --
.../management/AdapterMasterManagementTest.java | 26 +-
streampipes-connect-shared/pom.xml | 6 -
.../streampipes/export/AssetLinkResolver.java | 12 +-
.../apache/streampipes/export/ExportManager.java | 12 +-
.../apache/streampipes/export/ImportManager.java | 12 +-
.../export/dataimport/PerformImportGenerator.java | 10 +-
.../export/dataimport/PreviewImportGenerator.java | 14 +-
.../export/generator/ExportPackageGenerator.java | 10 +-
.../export/resolver/AdapterResolver.java | 12 +-
.../export/resolver/PipelineResolver.java | 9 +-
.../export/utils/EventGroundingProcessor.java | 77 +-
.../pe/config/IPipelineElementConfiguration.java | 6 +
.../management/ExtensionAdapterManagement.java | 4 +-
.../management/connect/AdapterAssetManagement.java | 71 ++
...ider.java => AdapterDescriptionManagement.java} | 41 +-
.../connect/AdapterWorkerRequestManagement.java | 77 ++
.../AdapterWorkerSampleDataRequestManagement.java | 69 ++
.../connect/ConnectWorkerDescriptionProvider.java | 8 +-
.../HttpServerAdapterRequestManagement.java | 14 +-
.../connect/RuntimeResolvableManagement.java | 55 ++
.../elements/SendToBrokerAdapterSink.java | 15 +-
.../management/init/DeclarersSingleton.java | 31 +-
.../migration/AbstractMigrationHandler.java | 67 +-
.../migration/AdapterMigrationHandler.java | 38 +-
.../migration/DataProcessorMigrationHandler.java | 29 +-
.../migration/DataSinkMigrationHandler.java | 38 +-
.../extensions/management}/model/Description.java | 2 +-
.../management/model/SpServiceDefinition.java | 4 -
.../monitoring/HealthCheckManagement.java | 41 +-
.../monitoring/MonitoringManagement.java | 29 +-
.../monitoring/ServiceMonitorManagement.java | 27 +-
.../pe/AbstractPipelineElementManagement.java | 84 ++
.../pe/DataProcessorPipelineElementManagement.java | 19 +-
.../pe/DataSinkPipelineElementManagement.java | 18 +-
.../pe/DataStreamPipelineElementManagement.java | 28 +-
.../pe/InvocablePipelineElementManagement.java | 158 ++++
.../management/init/DeclarersSingletonTest.java | 6 +-
streampipes-extensions/pom.xml | 2 +
.../streampipes-connectors-camel-azure/pom.xml | 125 +++
.../azure/CamelAzureConnectorsModuleExport.java | 19 +-
.../azure/filter/AzureKameletTemplateFilter.java | 21 +-
.../streampipes-connectors-camel}/pom.xml | 55 +-
.../assets/KameletDocumentationGenerator.java | 103 +++
.../camel/kamelet/assets/KameletIconDecoder.java | 83 ++
.../kamelet/assets/KameletSinkAssetResolver.java | 110 +++
.../config/KameletConfigurationExtractor.java | 90 ++
.../config/KameletMessageMappingExtractor.java | 172 ++++
.../config/KameletSinkStaticPropertyProvider.java | 241 ++++++
.../config/KameletStaticPropertyGenerator.java | 164 ++++
.../discovery/KameletTemplateDiscovery.java | 467 +++++++++++
.../camel/kamelet/factory/KameletSinkFactory.java | 71 ++
.../kamelet/filter/KameletTemplateFilter.java | 19 +-
.../camel/kamelet/message/CamelMessage.java | 12 +-
.../kamelet/message/KameletEventMessageMapper.java | 108 +++
.../kamelet/message/KameletHeaderMapping.java | 5 +-
.../kamelet/message/KameletMessageMapping.java | 30 +-
.../kamelet/model/KameletPropertyDefinition.java | 51 ++
.../camel/kamelet/model/KameletTemplate.java | 25 +-
.../module/AbstractCamelKameletModuleExport.java | 81 ++
.../provider/ClasspathKameletTemplateProvider.java | 65 ++
.../kamelet/provider/KameletTemplateProvider.java | 30 +-
.../transform/KameletTransformRouteLoader.java | 178 ++++
.../camel/sink/ApacheCamelKameletSink.java | 270 ++++++
.../sink/GeneratedApacheCamelKameletSink.java | 42 +
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 2 -
.../streampipes-extensions-all-jvm/pom.xml | 20 +
.../extensions/all/jvm/AllExtensionsInit.java | 4 +-
.../pom.xml | 13 +
.../jvm/welford/WelfordChangeDetectionTest.java | 93 +++
.../jvm/processor/jseval/JSEvalProcessorTest.java | 93 +++
.../jvm/processor/math/MathOpProcessorTest.java | 62 +-
.../staticmathop/StaticMathOpProcessorTest.java | 85 ++
.../trigonometry/TrigonometryProcessorTest.java | 86 ++
.../valuechange/ValueChangeProcessorTest.java | 96 +++
.../booleanfilter/TestBooleanFilterProcessor.java | 70 ++
.../enrich/MergeByEnrichProcessorTest.java | 103 +++
.../processor/limit/RateLimitProcessorTest.java | 91 ++
.../movingaverage/MovingAverageProcessorTest.java | 92 +++
.../NumericalFilterProcessorTest.java | 35 +-
.../NumericalTextFilterProcessorTest.java | 91 ++
.../projection/TestProjectionProcessor.java | 72 +-
.../schema/MergeBySchemaProcessorTest.java | 99 +++
.../textfilter/TestTextFilterProcessor.java | 71 ++
.../threshold/TestThresholdDetectionProcessor.java | 47 +-
.../ThroughputMonitorProcessorTest.java | 83 ++
.../siddhi/trend/TestTrendProcessor.java | 2 -
.../array/count/CountArrayProcessorTest.java | 55 ++
.../array/split/SplitArrayProcessorTest.java} | 47 +-
.../counter/TestBooleanCounterProcessor.java | 207 ++---
.../edge/SignalEdgeFilterProcessorTest.java | 65 ++
.../inverter/BooleanInverterProcessorTest.java | 67 ++
.../fieldrename/FiledRenameProcessorTest.java | 68 ++
.../processor/hasher/FieldHasherProcessorTest.java | 75 ++
.../mapper/FieldMapperProcessorTest.java} | 46 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 9 +-
.../sinks/brokers/jvm}/jms/ActiveMQPublisher.java | 38 +-
.../sinks/brokers/jvm}/jms/ActiveMQUtils.java | 9 +-
.../sinks/brokers/jvm/jms/JmsPublisherSink.java | 7 +-
.../sinks/internal/jvm/datalake/DataLakeSink.java | 2 +-
.../INotificationDataSinkMigratorTest.java | 6 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 10 +-
.../health/monitoring/AdapterHealthCheck.java | 1 -
.../health/monitoring/ExtensionHealthCheck.java | 19 +-
.../ExtensionInstanceAvailabilityCheck.java | 46 +-
.../health/monitoring/PipelineHealthCheck.java | 24 +-
.../health/monitoring/ResourceProvider.java | 8 +-
.../health/monitoring/ServiceHealthCheck.java | 21 +-
.../monitoring/ServiceRegistrationManager.java | 8 +-
streampipes-integration-tests/pom.xml | 12 +
.../containers/AzureCosmosDbEmulatorContainer.java | 101 +++
.../sinks/DataSinkTestConfigurator.java | 136 +++
.../integration/sinks/SinkTesterBase.java | 107 +++
.../integration/sinks/TestDataSinkParameters.java | 106 +++
.../sinks/azure/CamelAzureCosmosDbSinkTester.java | 327 ++++++++
.../azure/CamelAzureSinksIntegrationTest.java | 14 +-
.../sinks/azure/CosmosDbEmulatorTrustStore.java | 155 ++++
.../TestAzureCosmosDbApacheCamelKameletSink.java | 106 +++
.../sinks/azure/TestAzureKameletSinkFactory.java | 51 ++
.../TestCamelAzureConnectorsModuleExport.java | 24 +-
.../service/ExtensionServiceExecutions.java | 86 --
.../service/ExtensionsServiceReportExecutor.java | 39 +-
.../smp/extractor/ExtensionsFinder.java | 3 +-
streampipes-messaging-jms/pom.xml | 54 --
.../messaging/jms/ActiveMQConnectionProvider.java | 49 --
.../messaging/jms/ActiveMQConsumer.java | 111 ---
.../messaging/kafka/SpKafkaConsumer.java | 2 +-
.../messaging/kafka/SpKafkaProducer.java | 6 +-
.../messaging/nats/AbstractNatsConnector.java | 17 +-
.../streampipes/messaging/SpProtocolManager.java | 4 -
.../streampipes/model/client/user/DefaultRole.java | 2 -
.../model/client/user/LoginRequest.java | 4 +-
.../model/client/user/RefreshToken.java | 157 ++++
.../streampipes/model/api/EndpointSelectable.java | 4 +
.../model/base/ConsumableStreamPipesEntity.java | 15 -
.../model/base/InvocableStreamPipesEntity.java | 23 +-
.../configuration/DefaultMessagingSettings.java | 71 --
.../configuration/DefaultSpCoreConfiguration.java | 1 -
.../model/configuration/MessagingSettings.java | 187 -----
.../model/configuration/SpCoreConfiguration.java | 9 -
.../model/configuration/SpProtocol.java | 1 -
.../model/connect/adapter/AdapterDescription.java | 9 +
.../model/datalake/importer/CsvImportColumn.java | 104 +++
.../datalake/importer/CsvImportConfiguration.java | 59 ++
.../datalake/importer/CsvImportPreviewRequest.java | 79 ++
.../datalake/importer/CsvImportPreviewResult.java | 100 +++
.../model/datalake/importer/CsvImportRequest.java | 89 ++
.../model/datalake/importer/CsvImportResult.java | 71 ++
.../datalake/importer/CsvImportSchemaIssue.java | 74 ++
.../importer/CsvImportSchemaIssueType.java | 8 +-
.../CsvImportSchemaValidationRequest.java} | 37 +-
.../importer/CsvImportSchemaValidationResult.java | 41 +-
.../model/datalake/importer/CsvImportTarget.java | 23 +-
.../datalake/importer/CsvImportTargetMode.java | 6 +-
.../importer/CsvImportValidationMessage.java | 33 +-
.../svcdiscovery/SpServiceTagPrefix.java | 9 -
.../ExtensionServiceBrokerErrorEnvelope.java | 32 +-
.../ExtensionServiceBrokerOperation.java} | 40 +-
.../ExtensionServiceBrokerOperations.java | 70 ++
.../ExtensionServiceBrokerRequestEnvelope.java | 72 ++
.../ExtensionServiceBrokerResponseEnvelope.java | 90 ++
.../transport/ExtensionServiceBrokerTopics.java | 158 ++++
.../ExtensionServicePipelineDetachRequest.java} | 36 +-
.../transport/ExtensionServiceTransportMode.java} | 34 +-
.../model/graph/DataProcessorDescription.java | 2 -
.../model/graph/DataProcessorInvocation.java | 3 -
.../model/graph/DataSinkDescription.java | 2 -
.../model/graph/DataSinkInvocation.java | 3 -
.../model/grounding/KafkaTransportProtocol.java | 7 +
.../model/grounding/MqttTransportProtocol.java | 7 +
.../model/grounding/NatsTransportProtocol.java | 17 +
.../model/grounding/PulsarTransportProtocol.java | 7 +
.../model/grounding/TransportProtocol.java | 3 +-
.../org/apache/streampipes/model/util/Cloner.java | 3 -
.../ExtensionServiceBrokerTopicsTest.java | 87 ++
.../ExtensionServiceTransportModeTest.java | 52 ++
streampipes-nats-extensions/README.md | 123 +++
.../pom.xml | 36 +-
.../ExtensionBrokerOperationHandler.java | 14 +-
.../extensions/ExtensionBrokerRequestContext.java | 5 +-
.../extensions/ExtensionBrokerRequestReceiver.java | 372 +++++++++
.../operation/ExtensionBrokerConstants.java | 19 +-
.../operation/ExtensionBrokerResponseFactory.java | 110 +++
.../operation/ExtensionBrokerTopicParser.java | 92 +++
.../connect/AdapterAssetOperationHandler.java | 96 +++
.../AdapterStateChangeOperationHandler.java | 92 +++
.../connect/RuntimeOptionsOperationHandler.java | 115 +++
.../connect/SampleDataOperationHandler.java | 104 +++
.../function/FunctionStopOperationHandler.java | 67 ++
.../migration/MigrationOperationHandler.java | 141 ++++
.../ExtensionInstanceHealthOperationHandler.java | 69 ++
.../monitoring/ServiceHealthOperationHandler.java | 69 ++
.../monitoring/ServiceLoadOperationHandler.java | 55 ++
.../ContainerProvidedOptionsOperationHandler.java | 136 +++
.../operation/pe/DescriptionOperationHandler.java | 125 +++
.../operation/pe/OutputSchemaOperationHandler.java | 150 ++++
.../pe/PipelineElementAssetsOperationHandler.java | 165 ++++
.../pe/PipelineElementDetachOperationHandler.java | 120 +++
.../PipelineElementInvocationOperationHandler.java | 120 +++
.../operation/ExtensionBrokerTopicParserTest.java | 88 ++
.../connect/AdapterAssetOperationHandlerTest.java | 129 +++
...r.java => ExtensionServiceOperationResult.java} | 28 +-
.../api/extensions/ExtensionServiceRequest.java | 53 ++
.../extensions/ExtensionServiceRequestManager.java | 8 +-
.../extensions/ExtensionServiceRequestMethod.java | 7 +-
.../extensions/ExtensionServiceRequestTarget.java | 94 +++
.../extensions/ExtensionServiceRequestTargets.java | 257 ++++++
.../api/extensions/ExtensionServiceRequests.java | 133 +++
.../IExtensionsServiceEndpointGenerator.java | 19 +-
.../streampipes/manager/assets/AssetFetcher.java | 34 +-
.../streampipes/manager/assets/AssetManager.java | 6 +-
.../execution/ExtensionServiceExecutions.java | 75 --
.../HttpExtensionServiceRequestManager.java | 107 +++
.../execution/PipelineExecutionTaskFactory.java | 11 +-
.../manager/execution/PipelineExecutor.java | 10 +-
.../ExtensionsServiceEndpointGenerator.java | 29 +-
.../http/BasePipelineElementSubmitter.java | 16 +-
.../execution/http/DetachExtensionRequest.java | 65 ++
.../http/DetachPipelineElementSubmitter.java | 6 +-
...ttpRequest.java => InvokeExtensionRequest.java} | 37 +-
.../http/InvokePipelineElementSubmitter.java | 9 +-
...t.java => PipelineElementExtensionRequest.java} | 46 +-
.../execution/task/DiscoverEndpointsTask.java | 12 +-
.../manager/extensions/ExtensionItemInstaller.java | 41 +-
.../extensions/ExtensionsResourceUrlProvider.java | 74 --
.../manager/function/FunctionManager.java | 34 +-
.../matching/PipelineVerificationHandlerV2.java | 8 +-
.../manager/matching/ProtocolSelector.java | 103 +--
.../CustomTransformOutputSchemaGenerator.java | 50 +-
.../matching/output/OutputSchemaFactory.java | 12 +-
.../manager/matching/v2/ElementVerification.java | 52 --
.../manager/matching/v2/GroundingMatch.java | 53 --
.../manager/matching/v2/ProtocolMatch.java | 44 -
.../manager/matching/v2/StreamMatch.java | 16 +-
.../matching/v2/pipeline/ApplyGroundingStep.java | 58 +-
.../matching/v2/pipeline/ComputeOutputStep.java | 9 +-
.../v2/pipeline/PipelineValidationSteps.java | 6 +-
.../migration/AbstractMigrationManager.java | 61 +-
.../manager/migration/MigrationUtils.java | 11 +-
.../migration/PipelineElementMigrationManager.java | 34 +-
.../pipeline/ExtensionsServiceLogExecutor.java | 74 +-
.../manager/pipeline/PipelineManager.java | 16 +-
.../compact/CompactPipelineManagement.java | 8 +-
.../manager/preview/PipelinePreview.java | 41 +-
.../manager/recommender/ElementRecommender.java | 10 +-
.../remote/ContainerProvidedOptionsHandler.java | 33 +-
.../runtime/DataStreamRuntimeInfoProvider.java | 10 +
.../manager/setup/AutoInstallation.java | 11 +-
.../manager/setup/ExtensionsInstallationTask.java | 9 +-
.../manager/setup/InstallationConfiguration.java | 11 +-
.../setup/PipelineElementInstallationStep.java | 23 +-
.../manager/setup/design/UserDesignDocument.java | 16 +
.../compact/CompactPipelineTemplateManagement.java | 8 +-
.../streampipes/manager}/util/GroundingUtils.java | 95 +--
.../manager/verification/AdapterVerifier.java | 65 --
.../verification/DataProcessorVerifier.java | 66 --
.../manager/verification/DataSinkVerifier.java | 66 --
.../manager/verification/DataStreamVerifier.java | 66 --
.../manager/verification/ElementVerifier.java | 139 ++--
.../manager/verification/TypedElementVerifier.java | 95 +++
.../verification/extractor/TypeExtractor.java | 133 ++-
.../verification/structure/AbstractVerifier.java | 44 -
.../verification/structure/GeneralVerifier.java | 48 --
.../manager/matching/v2/TestGroundingMatch.java | 78 --
.../manager/matching/v2/TestProtocolMatch.java | 55 --
.../manager/verification/TypeExtractorTest.java | 117 +++
.../resource/management/secret/SecretVisitor.java | 4 +-
streampipes-rest-extensions/pom.xml | 15 -
.../AbstractPipelineElementResource.java | 115 +--
.../streampipes/rest/extensions/WelcomePage.java | 72 --
.../extensions/connect/AdapterAssetResource.java | 66 +-
.../connect/AdapterDescriptionResource.java | 48 +-
.../extensions/connect/AdapterWorkerResource.java | 36 +-
.../connect/AdapterWorkerSampleDataResource.java | 10 +-
.../connect/HttpServerAdapterResource.java | 14 +-
.../connect/RuntimeResolvableResource.java | 31 +-
.../rest/extensions/html/HTMLGenerator.java | 82 --
.../rest/extensions/html/JSONGenerator.java | 61 --
.../extensions/html/page/WelcomePageGenerator.java | 154 ----
.../migration/AdapterMigrationResource.java | 28 +-
.../migration/DataProcessorMigrationResource.java | 28 +-
.../migration/DataSinkMigrationResource.java | 29 +-
.../extensions/monitoring/HealthCheckResource.java | 40 +-
.../extensions/monitoring/MonitoringResource.java | 18 +-
.../monitoring/ServiceMonitorResource.java | 15 +-
.../pe/DataProcessorPipelineElementResource.java | 52 +-
.../pe/DataSinkPipelineElementResource.java | 50 +-
.../pe/DataStreamPipelineElementResource.java | 20 +-
.../pe/InvocablePipelineElementResource.java | 121 +--
.../migration/MigrateExtensionsResourceTest.java | 13 +-
.../shared/exception/SpRestExceptionHandler.java | 18 +-
.../apache/streampipes/rest/ResetManagement.java | 25 +-
.../rest/impl/AbstractMonitoringResource.java | 11 +-
.../rest/impl/AdapterMonitoringResource.java | 10 +-
.../rest/impl/AssetManagementResource.java | 11 +-
.../streampipes/rest/impl/Authentication.java | 184 ++++-
.../rest/impl/CompactPipelineResource.java | 10 +-
.../rest/impl/ContainerProvidedOptions.java | 9 +-
.../rest/impl/PipelineElementAsset.java | 8 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 12 +-
.../streampipes/rest/impl/PipelineResource.java | 16 +-
.../streampipes/rest/impl/PipelineTemplate.java | 6 +-
.../streampipes/rest/impl/ResetResource.java | 21 +-
.../rest/impl/admin/DataExportResource.java | 11 +-
.../rest/impl/admin/DataImportResource.java | 15 +-
.../impl/admin/ExtensionsInstallationResource.java | 34 +-
.../admin/ExtensionsServiceEndpointResource.java | 58 +-
.../impl/admin/MessagingConfigurationResource.java | 55 --
.../rest/impl/admin/MigrationResource.java | 19 +-
.../rest/impl/connect/AdapterResource.java | 18 +-
.../rest/impl/connect/CompactAdapterResource.java | 52 +-
.../ConnectRestExceptionHandler.java} | 21 +-
.../rest/impl/connect/DescriptionResource.java | 64 +-
.../rest/impl/connect/GuessResource.java | 42 +-
.../impl/connect/RuntimeResolvableResource.java | 15 +-
.../TransformationScriptLanguageResource.java | 14 -
.../impl/datalake/AbstractDataLakeResource.java | 4 +
.../rest/impl/datalake/DataLakeDataWriter.java | 52 +-
.../importer/CsvDataLakeImportService.java | 334 ++++++++
.../impl/datalake/importer/CsvImportParser.java | 619 ++++++++++++++
.../datalake/importer/CsvImportUploadStorage.java | 130 +++
.../importer/CsvImportValidationException.java | 28 +-
.../importer/CsvImportValidationService.java | 341 ++++++++
.../datalake/importer/DataLakeImportResource.java | 145 ++++
.../rest/impl/runtime/PipelinePreviewResource.java | 10 +-
.../rest/impl/datalake/DataLakeDataWriterTest.java | 56 ++
.../importer/CsvDataLakeImportServiceTest.java | 378 +++++++++
.../datalake/importer/CsvImportParserTest.java | 120 +++
.../importer/CsvImportValidationServiceTest.java | 177 ++++
streampipes-sdk-bundle/pom.xml | 5 -
.../builder/AbstractProcessingElementBuilder.java | 37 -
.../processor/DataProcessorConfiguration.java | 19 +-
.../sdk/builder/sink/DataSinkConfiguration.java | 19 +-
.../builder/stream/DataStreamConfiguration.java | 19 +-
.../apache/streampipes/sdk/helpers/Protocols.java | 14 -
.../sdk/helpers/SupportedProtocols.java | 62 --
streampipes-service-core-minimal/pom.xml | 4 -
streampipes-service-core/pom.xml | 5 -
.../streampipes/service/core/PostStartupTask.java | 24 +-
.../service/core/StreamPipesCoreApplication.java | 98 ++-
.../service/core/UnauthenticatedInterfaces.java | 2 +
.../extensions/CoreExtensionTransportMode.java | 27 +-
.../extensions/CoreNatsRequestReplyClient.java | 111 +++
.../ExtensionServiceRequestConfiguration.java | 88 ++
.../NatsExtensionServiceRequestManager.java | 124 +++
...ansportAwareExtensionServiceRequestManager.java | 109 +++
.../core/migrations/AvailableMigrations.java | 28 +-
.../v070/CreateAssetLinkTypeMigration.java | 50 --
.../v070/CreateFileAssetTypeMigration.java | 59 --
.../v090/UpdateUsernameViewMigration.java | 62 --
.../v093/StoreEmailTemplatesMigration.java | 58 --
...MergeFilenamesAndRenameDuplicatesMigration.java | 232 ------
.../AddRefreshTokenViewsMigration.java} | 33 +-
.../v099/RemoveAssetUserRoleMigration.java | 90 ++
.../v970/AddDataLakePipelineTemplateMigration.java | 50 --
.../migrations/v970/AddLinkSettingsMigration.java | 52 --
.../v970/DataExplorerDataViewMigration.java | 125 ---
.../v970/ModifyAssetLinkTypeMigration.java | 101 ---
.../RemoveNodesFromOpcUaAdaptersMigration.java | 98 ---
...CookieOAuth2AuthorizationRequestRepository.java | 35 +-
.../oauth2/OAuth2AuthenticationSuccessHandler.java | 138 +++-
...eFilenamesAndRenameDuplicatesMigrationTest.java | 112 ---
.../RemoveNodesFromOpcUaAdaptersMigrationTest.java | 85 --
.../svcdiscovery/api/ISpServiceDiscovery.java | 12 -
.../api/model/SpServiceUrlProvider.java | 12 -
.../svcdiscovery/SpServiceDiscoveryCore.java | 14 -
streampipes-service-extensions/pom.xml | 5 +
.../service/extensions/ExtensionItemProvider.java | 7 +-
.../StreamPipesExtensionsServiceBase.java | 70 +-
.../storage/api/core/INoSqlStorage.java | 3 +
.../api/system/ISpCoreConfigurationStorage.java | 4 -
.../storage/api/user/IRefreshTokenStorage.java | 12 +-
.../storage/couchdb/CouchDbStorageManager.java | 7 +
.../impl/system/CoreConfigurationStorageImpl.java | 10 +-
.../couchdb/impl/user/RefreshTokenStorageImpl.java | 63 ++
.../executors/ProcessingElementTestExecutor.java | 64 +-
.../test/generator/InvocationGraphGenerator.java | 2 -
.../user/management/authorization/RoleManager.java | 6 -
.../management/service/RefreshTokenService.java | 132 +++
.../distributed/runtime/DistributedRuntime.java | 9 -
.../standalone/function/StreamPipesFunction.java | 22 +-
.../standalone/manager/ProtocolManager.java | 17 +-
ui/cypress/AGENTS.md | 6 +-
...hine-data-simulator-import-later-timestamps.csv | 8 +
...-data-simulator-import-mismatched-timestamp.csv | 8 +
...achine-data-simulator-import-missing-values.csv | 8 +
...hine-data-simulator-import-string-timestamp.csv | 8 +
.../datalake/machine-data-simulator-import.csv | 8 +
ui/cypress/fixtures/datalake/missingData.json | 7 -
.../enrich-jvm/math1/description.json | 20 -
.../pipelineElement/enrich-jvm/math1/expected.csv | 3 -
.../pipelineElement/enrich-jvm/math1/input.csv | 3 -
.../enrich-jvm/math2/description.json | 20 -
.../pipelineElement/enrich-jvm/math2/expected.csv | 3 -
.../pipelineElement/enrich-jvm/math2/input.csv | 3 -
.../enrich-jvm/math3/description.json | 20 -
.../pipelineElement/enrich-jvm/math3/expected.csv | 3 -
.../pipelineElement/enrich-jvm/math3/input.csv | 3 -
.../enrich-jvm/staticmath1/description.json | 20 -
.../enrich-jvm/staticmath1/expected.csv | 3 -
.../enrich-jvm/staticmath1/input.csv | 3 -
.../enrich-jvm/staticmath2/description.json | 20 -
.../enrich-jvm/staticmath2/expected.csv | 3 -
.../enrich-jvm/staticmath2/input.csv | 3 -
.../enrich-jvm/trigonometry1/description.json | 15 -
.../enrich-jvm/trigonometry1/expected.csv | 3 -
.../enrich-jvm/trigonometry1/input.csv | 3 -
.../enrich-jvm/trigonometry2/description.json | 15 -
.../enrich-jvm/trigonometry2/expected.csv | 3 -
.../enrich-jvm/trigonometry2/input.csv | 3 -
.../enrich-jvm/valueChange1/description.json | 20 -
.../enrich-jvm/valueChange1/expected.csv | 11 -
.../enrich-jvm/valueChange1/input.csv | 11 -
.../filters-jvm/booleanFilter1/description.json | 15 -
.../filters-jvm/booleanFilter1/expected.csv | 6 -
.../filters-jvm/booleanFilter1/input.csv | 11 -
.../filters-jvm/booleanFilter2/description.json | 15 -
.../filters-jvm/booleanFilter2/expected.csv | 6 -
.../filters-jvm/booleanFilter2/input.csv | 11 -
.../filters-jvm/numericalFilter1/description.json | 12 -
.../filters-jvm/numericalFilter1/expected.csv | 6 -
.../filters-jvm/numericalFilter1/input.csv | 11 -
.../filters-jvm/projection1/description.json | 15 -
.../filters-jvm/projection1/expected.csv | 6 -
.../filters-jvm/projection1/input.csv | 6 -
.../filters-jvm/rateLimit1/description.json | 25 -
.../filters-jvm/rateLimit1/expected.csv | 3 -
.../filters-jvm/rateLimit1/input.csv | 12 -
.../filters-jvm/textFilter1/description.json | 8 -
.../filters-jvm/textFilter1/expected.csv | 4 -
.../filters-jvm/textFilter1/input.csv | 11 -
.../filters-jvm/textFilter2/description.json | 8 -
.../filters-jvm/textFilter2/expected.csv | 5 -
.../filters-jvm/textFilter2/input.csv | 11 -
.../thresholdDetection1/description.json | 20 -
.../filters-jvm/thresholdDetection1/expected.csv | 11 -
.../filters-jvm/thresholdDetection1/input.csv | 11 -
.../booleanCounter1/description.json | 7 -
.../booleanCounter1/expected.csv | 6 -
.../transformation-jvm/booleanCounter1/input.csv | 11 -
.../booleanCounter2/description.json | 15 -
.../booleanCounter2/expected.csv | 8 -
.../transformation-jvm/booleanCounter2/input.csv | 11 -
.../booleanInverter1/description.json | 10 -
.../booleanInverter1/expected.csv | 11 -
.../transformation-jvm/booleanInverter1/input.csv | 11 -
.../countArray1/description.json | 6 -
.../transformation-jvm/countArray1/expected.csv | 5 -
.../transformation-jvm/countArray1/input.json | 6 -
.../fieldHasher1/description.json | 11 -
.../transformation-jvm/fieldHasher1/expected.csv | 3 -
.../transformation-jvm/fieldHasher1/input.csv | 3 -
.../fieldHasher2/description.json | 11 -
.../transformation-jvm/fieldHasher2/expected.csv | 3 -
.../transformation-jvm/fieldHasher2/input.csv | 5 -
.../fieldMapper1/description.json | 8 -
.../transformation-jvm/fieldMapper1/expected.csv | 3 -
.../transformation-jvm/fieldMapper1/input.csv | 5 -
.../fieldRenamer1/description.json | 7 -
.../transformation-jvm/fieldRenamer1/expected.csv | 11 -
.../transformation-jvm/fieldRenamer1/input.csv | 11 -
.../signalEdgeFilter1/description.json | 13 -
.../signalEdgeFilter1/expected.csv | 6 -
.../transformation-jvm/signalEdgeFilter1/input.csv | 11 -
.../splitArray1/description.json | 11 -
.../transformation-jvm/splitArray1/expected.csv | 3 -
.../transformation-jvm/splitArray1/input.json | 4 -
ui/cypress/plugins/index.ts | 7 +-
ui/cypress/support/builder/UserBuilder.ts | 2 +-
.../{DataExplorerWidget.ts => ChartWidget.ts} | 2 +-
ui/cypress/support/model/User.ts | 2 +-
.../support/utils/DataDownloadDialogUtils.ts | 6 +-
ui/cypress/support/utils/PrepareTestDataUtils.ts | 64 +-
.../support/utils/ProcessingElementTestUtils.ts | 4 +-
ui/cypress/support/utils/UserUtils.ts | 2 +-
.../DataExplorerBtns.ts => chart/ChartBtns.ts} | 18 +-
.../DataExplorerUtils.ts => chart/ChartUtils.ts} | 232 +++---
.../ChartWidgetTableUtils.ts} | 19 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 6 +
ui/cypress/support/utils/connect/ConnectUtils.ts | 9 +-
.../support/utils/dataset/DataLakeSeedUtils.ts | 309 +++++++
ui/cypress/support/utils/dataset/DatasetBtns.ts | 97 +++
ui/cypress/support/utils/dataset/DatasetUtils.ts | 125 +++
.../tests/assetManagement/assetFilterTest.spec.ts | 20 +-
.../addAssetToDashboard.smoke.spec.ts | 16 +-
.../addAssetsToDataView.smoke.spec.ts | 16 +-
.../advancedFilterExpressions.smoke.spec.ts | 60 +-
.../charts => chart/chart-types}/heatmap.spec.ts | 10 +-
.../charts => chart/chart-types}/histogram.spec.ts | 10 +-
.../charts => chart/chart-types}/indicator.spec.ts | 28 +-
.../charts => chart/chart-types}/map.spec.ts | 12 +-
.../chart-types}/scatter.smoke.spec.ts | 8 +-
.../charts => chart/chart-types}/table.spec.ts | 16 +-
.../chart-types}/timeSeriesSave.spec.ts | 16 +-
.../chartDataPreview.smoke.spec.ts | 28 +-
.../configuration.smoke.spec.ts | 38 +-
.../tests/chart/deleteViewAndDashboard.spec.ts | 76 ++
.../tests/chart/dynamicColumnFilter.smoke.spec.ts | 52 ++
.../chart/filterNumericalStringProperties.spec.ts | 85 ++
.../missingDataInDataLake.spec.ts | 32 +-
.../timeOrderDataView.spec.ts | 36 +-
.../timeRangeSelectors.spec.ts | 16 +-
.../chart/widgetDataConfiguration.smoke.spec.ts | 108 +++
ui/cypress/tests/connect/editAdapter.smoke.spec.ts | 16 +-
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 6 +-
.../tests/connect/rules/schemaRules.smoke.spec.ts | 4 +-
.../dataDownloadDialogTest.smoke.spec.ts | 8 +-
.../dataExplorer/deleteViewAndDashboard.spec.ts | 79 --
.../filterNumericalStringProperties.spec.ts | 91 --
.../widgetDataConfiguration.smoke.spec.ts | 122 ---
ui/cypress/tests/dataset/csvImport.spec.ts | 115 +++
.../restartStreamPipes/restartStreamPipes2.ts | 4 +-
.../pipeline/multiUser/pipelineMultiUserSupport.ts | 2 +-
.../tests/pipeline/pipelineMultiSelect.spec.ts | 6 +-
.../userManagement/addUserAdmin.smoke.spec.ts | 2 +-
.../testAddAssetOnResourceCreation.ts | 32 +-
.../userManagement/testGroupManagement.spec.ts | 9 +-
.../userManagement/testUserRoleAssets.spec.ts | 4 +-
.../userManagement/testUserRoleCharts.spec.ts | 32 +-
.../userManagement/testUserRoleConnect.spec.ts | 2 +-
.../userManagement/testUserRoleDashboard.spec.ts | 100 +--
.../userManagement/testUserRoleDataset.spec.ts | 53 +-
.../userManagement/testUserRolePipeline.spec.ts | 2 +-
.../testVariousUserRoles.smoke.spec.ts | 10 +-
ui/deployment/app.routes.mst | 18 +-
ui/deployment/base-navigation.component.mst | 6 +-
ui/deployment/home.service.mst | 6 +-
ui/deployment/modules.yml | 2 +-
.../src/lib/apis/datalake-rest.service.ts | 51 ++
.../src/lib/model/datalake/csv-import.model.ts | 114 +++
.../platform-services/src/public-api.ts | 1 +
.../asset-browser-toolbar.component.ts | 6 +-
.../asset-browser/asset-browser.service.ts | 10 -
.../pipeline-element/pipeline-element.component.ts | 4 +-
.../{ => sp-actions}/sp-table-actions.directive.ts | 0
.../sp-table-multi-actions.directive.ts | 0
.../sp-table-asset-context.service.ts | 178 ++++
.../components/sp-table/sp-table.component.html | 340 ++++++--
.../components/sp-table/sp-table.component.scss | 90 +-
.../lib/components/sp-table/sp-table.component.ts | 355 +++++++-
.../src/lib/components/sp-table/sp-table.model.ts | 63 ++
.../data-download-dialog.component.html | 2 +-
.../standard-dialog/standard-dialog.component.scss | 3 +-
.../lib/models/sp-configuration-section.model.ts | 21 +-
.../lib/services/configuration-sections.service.ts | 104 +++
.../lib/services/configuration-sections.token.ts | 22 +-
.../src/lib/services/jwt-token-storage.service.ts | 3 +-
.../streampipes/shared-ui/src/public-api.ts | 9 +-
ui/src/app/app.config.ts | 2 +
ui/src/app/assets/assets.routes.ts | 4 +-
.../asset-link-table/asset-link-table.component.ts | 2 +-
.../asset-overview/asset-overview.component.ts | 2 +-
.../chart-container/chart-container.component.ts | 2 +-
.../charts/table/table-widget.component.html | 371 ++++++++-
.../charts/table/table-widget.component.scss | 331 +++++++-
.../charts/table/table-widget.component.ts | 917 +++++++++++++++++----
.../chart-overview-table.component.html | 1 +
.../chart-overview-table.component.ts | 9 +-
.../chart-overview/chart-overview.component.ts | 2 +-
.../components/chart-view/chart-view.component.ts | 2 +-
.../toolbar/chart-view-toolbar.component.ts | 2 +-
.../app/configuration/configuration-route.guard.ts | 22 +-
.../configuration-section-host.component.ts | 59 ++
.../configuration-sections.providers.ts | 119 +++
.../configuration/configuration-tabs.service.ts | 100 +--
ui/src/app/configuration/configuration.routes.ts | 68 +-
.../endpoint-item/endpoint-item.component.html | 29 +-
.../endpoint-item/endpoint-item.component.scss | 122 ++-
.../endpoint-item/endpoint-item.component.ts | 27 +-
.../extensions-installation.component.html | 5 +-
.../general-configuration.component.ts | 2 +-
.../broker-config/broker-config.component.html | 44 -
.../messaging-configuration.component.html | 200 -----
.../messaging-configuration.component.scss | 70 --
.../messaging-configuration.component.ts | 116 ---
.../edit-user-dialog/edit-user-dialog.component.ts | 2 +-
.../role-configuration.component.ts | 2 +
.../sites-configuration.component.ts | 2 +-
.../start-adapter-configuration.component.ts | 2 +-
.../existing-adapters.component.html | 1 +
.../existing-adapters.component.ts | 11 +-
.../core-ui/error-hint/error-hint.component.html | 30 +-
.../app/core-ui/error-hint/error-hint.component.ts | 22 +-
.../loading-indicator.component.html | 2 +-
.../loading-indicator.component.ts | 7 +-
.../pipeline-operation-status.component.html | 2 +-
.../pipeline-operation-status.component.ts | 7 +-
.../pipeline-started-status.component.html | 26 +-
.../pipeline-started-status.component.ts | 31 +-
.../base/abstract-validated-static-property.ts | 1 +
.../static-color-picker.component.ts | 35 +-
.../static-file-input.component.html | 1 +
.../static-file-input.component.ts | 4 +-
.../static-free-input.component.ts | 54 +-
.../static-mapping-unary.component.ts | 32 +-
.../static-property-util.service.ts | 1 +
.../static-property.component.html | 1 +
.../static-runtime-resolvable-group.component.html | 15 -
.../static-secret-input.component.html | 2 +-
.../static-secret-input.component.ts | 31 +-
.../static-slide-toggle.component.ts | 4 +-
.../status-indicator.component.html | 6 +-
.../status-indicator/status-indicator.component.ts | 13 +-
.../guards}/auth.can-activate-children.guard.ts | 22 +-
.../auth/guards}/auth.can-activate.guard.ts | 14 +-
.../auth/guards/page-auth.can-activate.guard.ts} | 2 +-
.../{_enums => core/auth}/user-privilege.enum.ts | 0
ui/src/app/{_enums => core/auth}/user-role.enum.ts | 1 -
.../{_enums => core/navigation}/page-name.enum.ts | 0
.../already-configured.can-activate.guard.ts | 2 +-
.../guards}/base-configured.can-activate.guard.ts | 2 +-
.../setup/guards}/configured.can-activate.guard.ts | 2 +-
.../registration-allowed.can-activate.guard.ts | 2 +-
.../restore-password-allowed.can-activate.guard.ts | 2 +-
.../guards}/terms.can-activate-children.guard.ts | 2 +-
.../dashboard-overview-table.component.html | 1 +
.../dashboard-overview-table.component.ts | 9 +-
.../overview/dashboard-overview.component.ts | 2 +-
.../chart-selection/chart-selection.component.ts | 2 +-
.../components/panel/dashboard-panel.component.ts | 2 +-
.../edit-dashboard-dialog.component.ts | 2 +-
.../datalake-configuration.component.html | 9 +
.../datalake-configuration.component.ts | 28 +-
.../dataset-feature-card.component.html | 24 +-
.../csv-import-dialog.component.html | 324 ++++++++
.../csv-import-dialog.component.scss | 95 +++
.../csv-import-dialog.component.ts | 786 ++++++++++++++++++
.../csv-import-preview-table.component.html | 186 +++++
.../csv-import-preview-table.component.scss | 77 ++
.../csv-import-preview-table.component.ts | 102 +++
.../csv-import-upload-state.component.html | 56 ++
.../csv-import-upload-state.component.scss} | 53 +-
.../csv-import-upload-state.component.ts} | 55 +-
.../dialog/csv-import-dialog/csv-import.model.ts} | 44 +-
.../save-pipeline-settings.component.ts | 2 +-
ui/src/app/home/components/status.component.ts | 2 +-
ui/src/app/home/home.component.ts | 2 +-
ui/src/app/home/models/home.model.ts | 2 +-
.../login/components/login/login.component.html | 3 +
.../app/login/components/login/login.component.ts | 8 +-
ui/src/app/login/services/login.service.ts | 19 +-
.../pipeline-details/pipeline-details.component.ts | 2 +-
.../pipeline-overview.component.html | 1 +
.../pipeline-overview.component.ts | 12 +-
ui/src/app/pipelines/pipelines.component.ts | 7 +-
ui/src/app/services/auth.service.ts | 94 ++-
ui/src/app/services/available-roles.service.ts | 12 +-
689 files changed, 23631 insertions(+), 8984 deletions(-)
copy installer/cli/deploy/standalone/{nats =>
nats-auth}/docker-compose.dev.yml (100%)
copy installer/cli/deploy/standalone/{extensions-all-jvm =>
nats-auth}/docker-compose.yml (77%)
copy installer/{compose/.env => cli/environments/backend-nats-auth} (75%)
copy installer/{compose/.env => cli/environments/basic-nats-auth} (75%)
copy installer/{compose/.env => cli/environments/lite-nats-auth} (75%)
copy installer/{compose/.env => cli/environments/pipeline-element-nats-auth}
(75%)
copy installer/compose/{.env => docker-compose.minimal.nats-auth.yml} (72%)
copy installer/compose/{.env => docker-compose.nats-auth.yml} (73%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/media/ImageMimeTypeDetector.java
delete mode 100644
streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management/util/WorkerPaths.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/ExtensionAdapterManagement.java
(87%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterAssetManagement.java
copy
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/{ConnectWorkerDescriptionProvider.java
=> AdapterDescriptionManagement.java} (56%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerRequestManagement.java
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/AdapterWorkerSampleDataRequestManagement.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/Verifier.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/HttpServerAdapterRequestManagement.java
(71%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/connect/RuntimeResolvableManagement.java
rename
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/migration/MigrateExtensionsResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AbstractMigrationHandler.java
(59%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/MqttTransportProtocol.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/AdapterMigrationHandler.java
(54%)
rename
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocolFactory.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataProcessorMigrationHandler.java
(52%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/MqttTransportProtocol.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/migration/DataSinkMigrationHandler.java
(54%)
rename
{streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management}/model/Description.java
(98%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/HealthCheckResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/HealthCheckManagement.java
(63%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/monitoring/MonitoringResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/MonitoringManagement.java
(56%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/monitoring/ServiceMonitorManagement.java
(59%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/AbstractPipelineElementManagement.java
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataProcessorPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataProcessorPipelineElementManagement.java
(81%)
copy
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/pe/DataSinkPipelineElementResource.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataSinkPipelineElementManagement.java
(79%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
=>
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/DataStreamPipelineElementManagement.java
(51%)
create mode 100644
streampipes-extensions-management/src/main/java/org/apache/streampipes/extensions/management/pe/InvocablePipelineElementManagement.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel-azure/pom.xml
rename
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/SpJmsProtocol.java
=>
streampipes-extensions/streampipes-connectors-camel-azure/src/main/java/org/apache/streampipes/extensions/connectors/camel/azure/CamelAzureConnectorsModuleExport.java
(56%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/PipelineValidationSteps.java
=>
streampipes-extensions/streampipes-connectors-camel-azure/src/main/java/org/apache/streampipes/extensions/connectors/camel/azure/filter/AzureKameletTemplateFilter.java
(62%)
copy {streampipes-connect-shared =>
streampipes-extensions/streampipes-connectors-camel}/pom.xml (63%)
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/assets/KameletDocumentationGenerator.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/assets/KameletIconDecoder.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/assets/KameletSinkAssetResolver.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/config/KameletConfigurationExtractor.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/config/KameletMessageMappingExtractor.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/config/KameletSinkStaticPropertyProvider.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/config/KameletStaticPropertyGenerator.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/discovery/KameletTemplateDiscovery.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/factory/KameletSinkFactory.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationResult.java
=>
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/filter/KameletTemplateFilter.java
(63%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationWarning.java
=>
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/message/CamelMessage.java
(74%)
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/message/KameletEventMessageMapper.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/message/KameletHeaderMapping.java
(80%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
=>
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/message/KameletMessageMapping.java
(61%)
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/model/KameletPropertyDefinition.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/pipeline/PipelineValidationSteps.java
=>
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/model/KameletTemplate.java
(60%)
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/module/AbstractCamelKameletModuleExport.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/provider/ClasspathKameletTemplateProvider.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
=>
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/provider/KameletTemplateProvider.java
(57%)
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/kamelet/transform/KameletTransformRouteLoader.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/sink/ApacheCamelKameletSink.java
create mode 100644
streampipes-extensions/streampipes-connectors-camel/src/main/java/org/apache/streampipes/extensions/connectors/camel/sink/GeneratedApacheCamelKameletSink.java
create mode 100644
streampipes-extensions/streampipes-processors-change-detection-jvm/src/test/java/org/apache/streampipes/processors/changedetection/jvm/welford/WelfordChangeDetectionTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/jseval/JSEvalProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/math/staticmathop/StaticMathOpProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/trigonometry/TrigonometryProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/enrich/MergeByEnrichProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/movingaverage/MovingAverageProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/numericaltextfilter/NumericalTextFilterProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/schema/MergeBySchemaProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/throughputmon/ThroughputMonitorProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayProcessorTest.java
copy
streampipes-extensions/{streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/projection/TestProjectionProcessor.java
=>
streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/array/split/SplitArrayProcessorTest.java}
(50%)
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessorTest.java
copy
streampipes-extensions/{streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/projection/TestProjectionProcessor.java
=>
streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/mapper/FieldMapperProcessorTest.java}
(52%)
rename
{streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging =>
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm}/jms/ActiveMQPublisher.java
(75%)
rename
{streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging =>
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm}/jms/ActiveMQUtils.java
(77%)
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/AzureCosmosDbEmulatorContainer.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/DataSinkTestConfigurator.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/SinkTesterBase.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/TestDataSinkParameters.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/azure/CamelAzureCosmosDbSinkTester.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationError.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/azure/CamelAzureSinksIntegrationTest.java
(73%)
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/azure/CosmosDbEmulatorTrustStore.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/azure/TestAzureCosmosDbApacheCamelKameletSink.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/azure/TestAzureKameletSinkFactory.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/grounding/PulsarTransportProtocol.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/sinks/azure/TestCamelAzureConnectorsModuleExport.java
(56%)
delete mode 100644
streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance/service/ExtensionServiceExecutions.java
delete mode 100644 streampipes-messaging-jms/pom.xml
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQConnectionProvider.java
delete mode 100644
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQConsumer.java
create mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/RefreshToken.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/DefaultMessagingSettings.java
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/MessagingSettings.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportColumn.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportConfiguration.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportPreviewRequest.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportPreviewResult.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportRequest.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportResult.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaIssue.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaIssueType.java
(80%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{grounding/TransportFormat.java
=> datalake/importer/CsvImportSchemaValidationRequest.java} (56%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/GroundingSelector.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaValidationResult.java
(52%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationResult.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportTarget.java
(63%)
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportTargetMode.java
(87%)
rename
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestUtils.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportValidationMessage.java
(59%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerErrorEnvelope.java
(57%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/{grounding/TransportFormat.java
=> extensions/transport/ExtensionServiceBrokerOperation.java} (52%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerOperations.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerRequestEnvelope.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerResponseEnvelope.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopics.java
rename
streampipes-model/src/main/java/org/apache/streampipes/model/{grounding/JmsTransportProtocol.java
=> extensions/transport/ExtensionServicePipelineDetachRequest.java} (53%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{grounding/PulsarTransportProtocol.java
=> extensions/transport/ExtensionServiceTransportMode.java} (54%)
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceBrokerTopicsTest.java
create mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/extensions/transport/ExtensionServiceTransportModeTest.java
create mode 100644 streampipes-nats-extensions/README.md
copy {streampipes-rest-extensions => streampipes-nats-extensions}/pom.xml (66%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/IExtensionsResourceUrlProvider.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerOperationHandler.java
(61%)
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerRequestContext.java
(85%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/ExtensionBrokerRequestReceiver.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/IExtensionsResourceUrlProvider.java
=>
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerConstants.java
(55%)
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerResponseFactory.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParser.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterStateChangeOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/RuntimeOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/connect/SampleDataOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/function/FunctionStopOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/migration/MigrationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ExtensionInstanceHealthOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ServiceHealthOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/monitoring/ServiceLoadOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/ContainerProvidedOptionsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/DescriptionOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/OutputSchemaOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementAssetsOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementDetachOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/main/java/org/apache/streampipes/nats/extensions/operation/pe/PipelineElementInvocationOperationHandler.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/ExtensionBrokerTopicParserTest.java
create mode 100644
streampipes-nats-extensions/src/test/java/org/apache/streampipes/nats/extensions/operation/connect/AdapterAssetOperationHandlerTest.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/{IExtensionsResourceUrlProvider.java
=> ExtensionServiceOperationResult.java} (57%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequest.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestManager.java
(77%)
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/LoginRequest.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestMethod.java
(86%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTarget.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequestTargets.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/ExtensionServiceRequests.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/ExtensionServiceExecutions.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/HttpExtensionServiceRequestManager.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachExtensionRequest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{InvokeHttpRequest.java
=> InvokeExtensionRequest.java} (52%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/{PipelineElementHttpRequest.java
=> PipelineElementExtensionRequest.java} (58%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/extensions/ExtensionsResourceUrlProvider.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ElementVerification.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/GroundingMatch.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/matching/v2/ProtocolMatch.java
rename
{streampipes-load-balancer/src/main/java/org/apache/streampipes/loadbalance =>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/pipeline/ExtensionsServiceLogExecutor.java
(68%)
rename
{streampipes-connect-management/src/main/java/org/apache/streampipes/connect/management
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager}/util/GroundingUtils.java
(57%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/AdapterVerifier.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataProcessorVerifier.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataSinkVerifier.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/DataStreamVerifier.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/TypedElementVerifier.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/AbstractVerifier.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/GeneralVerifier.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestGroundingMatch.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/matching/v2/TestProtocolMatch.java
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/verification/TypeExtractorTest.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/WelcomePage.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/HTMLGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/JSONGenerator.java
delete mode 100644
streampipes-rest-extensions/src/main/java/org/apache/streampipes/rest/extensions/html/page/WelcomePageGenerator.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/MessagingConfigurationResource.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{AbstractMonitoringResource.java
=> connect/ConnectRestExceptionHandler.java} (57%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvDataLakeImportService.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportParser.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportUploadStorage.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/migration/AdapterDescriptionMigration093Provider.java
=>
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportValidationException.java
(56%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportValidationService.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/DataLakeImportResource.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/DataLakeDataWriterTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/importer/CsvDataLakeImportServiceTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportParserTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportValidationServiceTest.java
delete mode 100644
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/SupportedProtocols.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationResult.java
=>
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/CoreExtensionTransportMode.java
(64%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/CoreNatsRequestReplyClient.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/ExtensionServiceRequestConfiguration.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/NatsExtensionServiceRequestManager.java
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/extensions/TransportAwareExtensionServiceRequestManager.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v070/CreateAssetLinkTypeMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v070/CreateFileAssetTypeMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v090/UpdateUsernameViewMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v093/StoreEmailTemplatesMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v095/MergeFilenamesAndRenameDuplicatesMigration.java
rename
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/{v970/AddRolesToUserDbMigration.java
=> v099/AddRefreshTokenViewsMigration.java} (67%)
create mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v099/RemoveAssetUserRoleMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/AddDataLakePipelineTemplateMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/AddLinkSettingsMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/DataExplorerDataViewMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/ModifyAssetLinkTypeMigration.java
delete mode 100644
streampipes-service-core/src/main/java/org/apache/streampipes/service/core/migrations/v970/RemoveNodesFromOpcUaAdaptersMigration.java
delete mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/migrations/v095/MergeFilenamesAndRenameDuplicatesMigrationTest.java
delete mode 100644
streampipes-service-core/src/test/java/org/apache/streampipes/service/core/migrations/v970/RemoveNodesFromOpcUaAdaptersMigrationTest.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/structure/Verifier.java
=>
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/user/IRefreshTokenStorage.java
(69%)
create mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/user/RefreshTokenStorageImpl.java
create mode 100644
streampipes-user-management/src/main/java/org/apache/streampipes/user/management/service/RefreshTokenService.java
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-later-timestamps.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-mismatched-timestamp.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-missing-values.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-string-timestamp.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import.csv
delete mode 100644 ui/cypress/fixtures/datalake/missingData.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math3/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math3/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math3/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/valueChange1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/valueChange1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/valueChange1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/thresholdDetection1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/thresholdDetection1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/thresholdDetection1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/input.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldMapper1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldMapper1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldMapper1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/input.json
rename ui/cypress/support/model/{DataExplorerWidget.ts => ChartWidget.ts} (96%)
rename ui/cypress/support/utils/{dataExplorer/DataExplorerBtns.ts =>
chart/ChartBtns.ts} (93%)
rename ui/cypress/support/utils/{dataExplorer/DataExplorerUtils.ts =>
chart/ChartUtils.ts} (77%)
copy ui/cypress/support/utils/{dataExplorer/DataExplorerWidgetTableUtils.ts =>
chart/ChartWidgetTableUtils.ts} (72%)
create mode 100644 ui/cypress/support/utils/dataset/DataLakeSeedUtils.ts
rename ui/cypress/tests/{dataExplorer =>
chart}/addAssetToDashboard.smoke.spec.ts (84%)
rename ui/cypress/tests/{dataExplorer =>
chart}/addAssetsToDataView.smoke.spec.ts (82%)
rename ui/cypress/tests/{dataExplorer =>
chart}/advancedFilterExpressions.smoke.spec.ts (52%)
rename ui/cypress/tests/{dataExplorer/charts =>
chart/chart-types}/heatmap.spec.ts (80%)
rename ui/cypress/tests/{dataExplorer/charts =>
chart/chart-types}/histogram.spec.ts (80%)
rename ui/cypress/tests/{dataExplorer/charts =>
chart/chart-types}/indicator.spec.ts (59%)
rename ui/cypress/tests/{dataExplorer/charts => chart/chart-types}/map.spec.ts
(85%)
rename ui/cypress/tests/{dataExplorer/charts =>
chart/chart-types}/scatter.smoke.spec.ts (83%)
rename ui/cypress/tests/{dataExplorer/charts =>
chart/chart-types}/table.spec.ts (67%)
rename ui/cypress/tests/{dataExplorer/charts =>
chart/chart-types}/timeSeriesSave.spec.ts (82%)
rename ui/cypress/tests/{dataExplorer => chart}/chartDataPreview.smoke.spec.ts
(56%)
rename ui/cypress/tests/{dataExplorer => chart}/configuration.smoke.spec.ts
(63%)
create mode 100644 ui/cypress/tests/chart/deleteViewAndDashboard.spec.ts
create mode 100644 ui/cypress/tests/chart/dynamicColumnFilter.smoke.spec.ts
create mode 100644
ui/cypress/tests/chart/filterNumericalStringProperties.spec.ts
rename ui/cypress/tests/{dataExplorer => chart}/missingDataInDataLake.spec.ts
(57%)
rename ui/cypress/tests/{dataExplorer => chart}/timeOrderDataView.spec.ts (69%)
rename ui/cypress/tests/{dataExplorer => chart}/timeRangeSelectors.spec.ts
(91%)
create mode 100644 ui/cypress/tests/chart/widgetDataConfiguration.smoke.spec.ts
delete mode 100644 ui/cypress/tests/dataExplorer/deleteViewAndDashboard.spec.ts
delete mode 100644
ui/cypress/tests/dataExplorer/filterNumericalStringProperties.spec.ts
delete mode 100644
ui/cypress/tests/dataExplorer/widgetDataConfiguration.smoke.spec.ts
create mode 100644 ui/cypress/tests/dataset/csvImport.spec.ts
create mode 100644
ui/projects/streampipes/platform-services/src/lib/model/datalake/csv-import.model.ts
rename ui/projects/streampipes/shared-ui/src/lib/components/sp-table/{ =>
sp-actions}/sp-table-actions.directive.ts (100%)
rename ui/projects/streampipes/shared-ui/src/lib/components/sp-table/{ =>
sp-actions}/sp-table-multi-actions.directive.ts (100%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/sp-table/sp-asset-context/sp-table-asset-context.service.ts
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/sp-table/sp-table.model.ts
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/messages/VerificationError.java
=>
ui/projects/streampipes/shared-ui/src/lib/models/sp-configuration-section.model.ts
(70%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/services/configuration-sections.service.ts
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/api/extensions/IExtensionsResourceUrlProvider.java
=>
ui/projects/streampipes/shared-ui/src/lib/services/configuration-sections.token.ts
(63%)
create mode 100644
ui/src/app/configuration/configuration-section-host.component.ts
create mode 100644 ui/src/app/configuration/configuration-sections.providers.ts
delete mode 100644
ui/src/app/configuration/messaging-configuration/broker-config/broker-config.component.html
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.html
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.scss
delete mode 100644
ui/src/app/configuration/messaging-configuration/messaging-configuration.component.ts
rename ui/src/app/{_guards =>
core/auth/guards}/auth.can-activate-children.guard.ts (73%)
rename ui/src/app/{_guards => core/auth/guards}/auth.can-activate.guard.ts
(78%)
rename ui/src/app/{_guards/page-auth.can-active.guard.ts =>
core/auth/guards/page-auth.can-activate.guard.ts} (96%)
rename ui/src/app/{_enums => core/auth}/user-privilege.enum.ts (100%)
rename ui/src/app/{_enums => core/auth}/user-role.enum.ts (97%)
rename ui/src/app/{_enums => core/navigation}/page-name.enum.ts (100%)
rename ui/src/app/{_guards =>
core/setup/guards}/already-configured.can-activate.guard.ts (95%)
rename ui/src/app/{_guards =>
core/setup/guards}/base-configured.can-activate.guard.ts (97%)
rename ui/src/app/{_guards =>
core/setup/guards}/configured.can-activate.guard.ts (95%)
rename ui/src/app/{_guards =>
core/setup/guards}/registration-allowed.can-activate.guard.ts (96%)
rename ui/src/app/{_guards =>
core/setup/guards}/restore-password-allowed.can-activate.guard.ts (96%)
rename ui/src/app/{_guards =>
core/setup/guards}/terms.can-activate-children.guard.ts (96%)
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-dialog.component.html
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-dialog.component.scss
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-dialog.component.ts
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-preview-table/csv-import-preview-table.component.html
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-preview-table/csv-import-preview-table.component.scss
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-preview-table/csv-import-preview-table.component.ts
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-upload-state/csv-import-upload-state.component.html
rename ui/{cypress/support/utils/dataExplorer/DataExplorerWidgetTableUtils.ts
=>
src/app/dataset/dialog/csv-import-dialog/csv-import-upload-state/csv-import-upload-state.component.scss}
(55%)
rename
ui/src/app/{configuration/messaging-configuration/broker-config/broker-config.component.ts
=>
dataset/dialog/csv-import-dialog/csv-import-upload-state/csv-import-upload-state.component.ts}
(50%)
copy
ui/src/app/{configuration/extensions-installation/endpoint-item/endpoint-item.component.scss
=> dataset/dialog/csv-import-dialog/csv-import.model.ts} (59%)
