This is an automated email from the ASF dual-hosted git repository. gomm pushed a commit to branch edge-extensions in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit f589462bd3f7375e71eb4de2115031e103227f07 Merge: a340cd0 889d9a0 Author: Daniel Gomm <[email protected]> AuthorDate: Thu Feb 18 15:50:57 2021 +0100 Merge remote-tracking branch 'upstream/edge-extensions' into edge-extensions # Conflicts: # streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java .../all_pipeline_elements_jvm.xml | 10 + NOTICE | 4 +- pom.xml | 59 +- streampipes-backend/pom.xml | 26 +- .../backend/StreamPipesResourceConfig.java | 23 +- .../src/main/resources/openapi.yaml | 34 ++ streampipes-backend/src/main/resources/shiro.ini | 6 +- .../pom.xml | 57 +- .../streampipes/client/StreamPipesClient.java | 155 +++++ .../streampipes/client/StreamPipesCredentials.java | 61 +- .../client/annotation/NotYetImplemented.java | 6 +- .../streampipes/client/api/AbstractClientApi.java | 77 +++ .../org/apache/streampipes/client/api/CRUDApi.java | 14 +- .../streampipes/client/api/DataProcessorApi.java | 83 +++ .../apache/streampipes/client/api/DataSinkApi.java | 75 +++ .../streampipes/client/api/DataStreamApi.java | 99 ++++ .../apache/streampipes/client/api/PipelineApi.java | 108 ++++ .../client/api/PipelineElementTemplateApi.java | 63 ++ .../client/api/SupportsDataProcessorApi.java | 6 +- .../client/api/SupportsDataSinkApi.java | 7 +- .../client/api/SupportsDataStreamApi.java | 6 +- .../client/api/SupportsPipelineApi.java | 6 +- .../api/SupportsPipelineElementTemplateApi.java | 6 +- .../streampipes/client/http/DeleteRequest.java | 51 ++ .../apache/streampipes/client/http/GetRequest.java | 51 ++ .../streampipes/client/http/HttpRequest.java | 115 ++++ .../streampipes/client/http/PostRequest.java | 64 ++ .../http/PostRequestWithPayloadResponse.java | 52 ++ .../http/PostRequestWithoutPayloadResponse.java | 47 ++ .../streampipes/client/http/header/Headers.java | 47 ++ .../streampipes/client/live/EventProcessor.java | 7 +- .../streampipes/client/live/KafkaConfig.java | 29 +- .../client/live/SubscriptionManager.java | 107 ++++ .../client/model/StreamPipesClientConfig.java | 76 +++ .../client/serializer/ListSerializer.java | 42 +- .../client/serializer/ObjectSerializer.java | 21 +- .../streampipes/client/serializer/Serializer.java | 32 +- .../client/util/StreamPipesApiPath.java | 59 ++ streampipes-commons/src/main/resources/logback.xml | 3 +- streampipes-connect-container-master/pom.xml | 7 +- .../master/management/AdapterMasterManagement.java | 61 +- .../master/management/SourcesManagement.java | 22 +- .../container/master/rest/SourcesResource.java | 7 +- .../master/management/SourcesManagementTest.java | 30 +- .../init/AdapterWorkerContainerResourceConfig.java | 1 + .../management/HttpServerAdapterManagement.java | 50 ++ .../worker/rest/HttpServerAdapterResource.java | 29 +- .../elements/SendToBrokerReplayAdapterSink.java | 9 +- .../extensions/ExtensionsResourceConfig.java | 4 +- .../PipelineElementContainerResourceConfig.java | 4 +- .../api/AbstractPipelineElementResource.java | 60 +- .../api/DataSourcePipelineElementResource.java | 136 ----- .../api/DataStreamPipelineElementResource.java | 103 ++++ .../api/InvocablePipelineElementResource.java | 4 + ...Resource.java => PipelineTemplateResource.java} | 2 +- .../container/declarer/DataStreamDeclarer.java | 5 +- .../declarer/SemanticEventProducerDeclarer.java | 1 + .../streampipes/container/html/JSONGenerator.java | 1 + .../container/html/model/Description.java | 9 + .../html/page/EventConsumerWelcomePage.java | 98 ++-- .../html/page/EventProcessingAgentWelcomePage.java | 98 ++-- .../html/page/EventProducerWelcomePage.java | 126 ++-- .../html/page/WelcomePageGeneratorImpl.java | 129 ++-- .../container/init/DeclarersSingleton.java | 44 +- .../html/page/WelcomePageGeneratorImplTest.java | 133 ----- .../pom.xml | 19 +- .../dataexplorer/DataLakeManagementV3.java | 297 ++++++++++ .../dataexplorer}/DataLakeNoUserManagementV3.java | 17 +- .../autoagg/AbstractAutoAggregationQuery.java | 70 +++ .../autoagg/FromNowAutoAggregationQuery.java | 49 ++ .../autoagg/GroupedAutoAggregationQuery.java | 48 ++ .../autoagg/TimeBoundAutoAggregationQuery.java | 49 ++ .../streampipes/dataexplorer/model/Order.java | 18 +- .../param/AggregatedTimeBoundQueryParams.java | 50 ++ .../param/AggregatedTimeUnitQueryParams.java | 51 ++ .../dataexplorer/param/CountQueryParams.java | 5 +- .../GroupedAggregatedTimeBoundQueryParams.java | 46 ++ .../dataexplorer/param/GroupedQueryParams.java | 31 +- .../dataexplorer/param/PagingQueryParams.java | 95 +++ .../dataexplorer/param/QueryParams.java | 18 +- .../dataexplorer/param/TimeBoundQueryParams.java | 29 +- .../dataexplorer/param/TimeUnitQueryParams.java | 27 +- .../dataexplorer/query/DataExplorerQuery.java | 84 +++ .../query/DataExplorerQueryBuilder.java | 61 ++ .../dataexplorer/query/DeleteDataQuery.java | 25 +- .../query/GetAggregatedEventsFromNowQuery.java | 47 ++ .../query/GetAggregatedEventsQuery.java | 45 ++ .../query/GetDateFromSortedTableRecord.java | 69 +++ .../query/GetEventsAutoAggregationQuery.java | 6 +- .../dataexplorer/query/GetEventsFromNowQuery.java | 44 ++ .../dataexplorer/query/GetEventsQuery.java | 37 +- .../query/GetGroupedAggregatedEventsQuery.java | 45 ++ .../dataexplorer/query/GetGroupedEventsQuery.java | 43 ++ .../query/GetHeadersWithTypesQuery.java | 45 +- .../dataexplorer/query/GetMaxPagesQuery.java | 36 +- .../query/GetNumberOfRecordsByTimeUnitQuery.java | 52 ++ .../query/GetNumberOfRecordsQuery.java | 51 ++ .../dataexplorer/query/GetPagingEventsQuery.java | 71 +++ .../query/ParameterizedDataExplorerQuery.java | 8 +- .../dataexplorer/template/QueryTemplates.java | 33 +- .../dataexplorer/utils/DataExplorerUtils.java | 47 ++ .../kafka/config/ConsumerConfigFactory.java | 2 +- streampipes-model-client/pom.xml | 8 +- .../model/client/endpoint/RdfEndpointItem.java | 12 +- .../model/client/user/RawUserApiToken.java | 65 ++ .../apache/streampipes/model/client/user/User.java | 32 + .../model/client/user/UserApiToken.java | 62 ++ streampipes-model/pom.xml | 4 +- .../org/apache/streampipes/model/SpDataStream.java | 12 + .../model/base/AbstractStreamPipesEntity.java | 3 + .../model/base/NamedStreamPipesEntity.java | 11 + .../connect/adapter/AdapterStreamDescription.java | 4 +- .../streampipes/model/datalake}/DataResult.java | 2 +- .../model/datalake}/GroupedDataResult.java | 3 +- .../streampipes/model/datalake}/PageResult.java | 3 +- .../model/graph/DataSourceDescription.java | 1 + .../model/monitoring/ConsumedMessagesInfo.java | 67 +++ .../streampipes/model/monitoring/MessagesInfo.java | 37 +- .../model/monitoring/MessagesMetaInfo.java | 33 +- .../monitoring/PipelineElementMonitoringInfo.java | 86 +++ .../model/monitoring/PipelineMonitoringInfo.java | 67 +++ .../model/monitoring/ProducedMessagesInfo.java | 47 ++ .../model/pipeline/PipelineElementStatus.java | 23 +- .../model/staticproperty/AnyStaticProperty.java | 5 + .../staticproperty/CodeInputStaticProperty.java | 5 + .../staticproperty/CollectionStaticProperty.java | 5 + .../staticproperty/ColorPickerStaticProperty.java | 5 + .../model/staticproperty/DomainStaticProperty.java | 8 +- .../model/staticproperty/FileStaticProperty.java | 5 + .../staticproperty/FreeTextStaticProperty.java | 5 + .../model/staticproperty/MappingPropertyNary.java | 5 + .../model/staticproperty/MappingPropertyUnary.java | 5 + .../staticproperty/MatchingStaticProperty.java | 5 + .../model/staticproperty/OneOfStaticProperty.java | 5 + .../staticproperty/RemoteOneOfStaticProperty.java | 10 +- .../model/staticproperty/SecretStaticProperty.java | 5 + .../model/staticproperty/StaticProperty.java | 2 + .../staticproperty/StaticPropertyAlternative.java | 5 + .../staticproperty/StaticPropertyAlternatives.java | 5 + .../model/staticproperty/StaticPropertyGroup.java | 5 + .../staticproperty/StaticPropertyVisitor.java | 53 ++ .../model/template/PipelineElementTemplate.java | 102 ++++ .../template/PipelineElementTemplateConfig.java | 44 +- .../org/apache/streampipes/model/util/Cloner.java | 6 +- .../manager/execution/http/PipelineExecutor.java | 35 +- .../execution/status/SepMonitoringManager.java | 50 -- .../manager/matching/DataSetGroundingSelector.java | 2 - .../manager/monitoring/job/JobManager.java | 64 -- .../manager/monitoring/job/MonitoringJob.java | 81 --- .../monitoring/job/MonitoringJobExecutor.java | 46 -- .../pipeline/PipelineExecutionStatusCollector.java | 37 ++ .../monitoring/pipeline/TopicInfoCollector.java | 258 ++++++++ .../manager/monitoring/runtime/EventGenerator.java | 72 --- .../monitoring/runtime/PipelineObserver.java | 92 --- .../monitoring/runtime/PipelineStreamReplacer.java | 109 ---- .../monitoring/runtime/RandomDataGenerator.java | 74 --- .../monitoring/runtime/RandomEventGenerator.java | 56 -- .../monitoring/runtime/SchemaGenerator.java | 46 -- .../monitoring/runtime/SepStoppedMonitoring.java | 178 ------ .../SepStoppedMonitoringPipelineBuilder.java | 191 ------ .../monitoring/runtime/SimilarStreamFinder.java | 112 ---- .../monitoring/task/CompareDescriptionTask.java | 23 - .../monitoring/task/GetDescriptionTask.java | 71 --- .../manager/monitoring/task/InvokeRuntimeTask.java | 23 - .../manager/monitoring/task/RemoveRuntimeTask.java | 23 - .../manager/monitoring/task/TaskDefinition.java | 53 -- .../manager/monitoring/task/VerifySchemaTask.java | 23 - .../remote/ContainerProvidedOptionsHandler.java | 9 +- .../manager/setup/CouchDbInstallationStep.java | 5 +- .../template/DataProcessorTemplateHandler.java | 19 +- .../manager/template/DataSinkTemplateHandler.java | 17 +- .../template/PipelineElementTemplateHandler.java | 49 ++ .../template/PipelineElementTemplateVisitor.java | 142 +++++ ...epaVerifier.java => DataProcessorVerifier.java} | 4 +- .../{SecVerifier.java => DataSinkVerifier.java} | 4 +- .../{SepVerifier.java => DataStreamVerifier.java} | 27 +- .../manager/verification/ElementVerifier.java | 24 +- .../verification/extractor/TypeExtractor.java | 43 +- .../streampipes/manager/matching/v2/TestUtils.java | 4 +- .../manager/pipeline/TestSerializer.java | 48 -- .../pom.xml | 28 +- .../apache/streampipes/ps}/DataLakeResourceV3.java | 74 ++- .../ps/PipelineElementTemplateResource.java | 197 +++++++ .../streampipes/rest/shared/api/CRUDResource.java | 14 +- .../shared/impl/AbstractSharedRestInterface.java | 61 ++ streampipes-rest/pom.xml | 11 +- .../streampipes/rest/api/IAssetDashboard.java | 41 -- .../rest/api/IMeasurementUnitResource.java | 26 - .../apache/streampipes/rest/api/INotification.java | 34 -- .../streampipes/rest/api/IOntologyKnowledge.java | 70 --- .../rest/api/IOntologyPipelineElement.java | 37 -- .../org/apache/streampipes/rest/api/IPipeline.java | 47 -- .../streampipes/rest/api/IPipelineCache.java | 30 - .../rest/api/IPipelineElementAsset.java | 29 - .../streampipes/rest/api/IPipelineElementFile.java | 33 -- .../rest/api/IPipelineElementRuntimeInfo.java | 27 - ...plicationLink.java => IPipelineMonitoring.java} | 8 +- .../streampipes/rest/api/IPipelineTemplate.java | 33 -- .../apache/streampipes/rest/api/IRdfEndpoint.java | 34 -- .../org/apache/streampipes/rest/api/ISetup.java | 34 -- .../org/apache/streampipes/rest/api/IVersion.java | 27 - .../streampipes/rest/api/IVirtualSensor.java | 29 - .../streampipes/rest/api/IVisualization.java | 26 - .../streampipes/rest/api/dashboard/IDashboard.java | 36 -- .../rest/api/dashboard/IDashboardWidget.java | 36 -- .../rest/api/dashboard/IVisualizablePipeline.java | 32 - .../rest/api/dataexplorer/IDataExplorerWidget.java | 36 -- .../AbstractAuthGuardedRestResource.java} | 23 +- ...estInterface.java => AbstractRestResource.java} | 40 +- .../streampipes/rest/impl/ApplicationLink.java | 79 --- .../streampipes/rest/impl/AssetDashboard.java | 23 +- .../streampipes/rest/impl/Authentication.java | 24 +- .../apache/streampipes/rest/impl/AutoComplete.java | 4 +- .../streampipes/rest/impl/CategoryResource.java | 8 +- .../apache/streampipes/rest/impl/ConsulConfig.java | 27 +- .../rest/impl/ContainerProvidedOptions.java | 2 +- .../org/apache/streampipes/rest/impl/Couchdb.java | 6 +- .../apache/streampipes/rest/impl/DataStream.java | 2 +- .../apache/streampipes/rest/impl/Deployment.java | 2 +- .../rest/impl/InternalPipelineTemplates.java | 31 +- .../streampipes/rest/impl/LabelResource.java | 9 +- .../rest/impl/MeasurementUnitResource.java | 5 +- .../org/apache/streampipes/rest/impl/Node.java | 2 +- .../apache/streampipes/rest/impl/Notification.java | 16 +- .../streampipes/rest/impl/OntologyContext.java | 23 +- .../streampipes/rest/impl/OntologyKnowledge.java | 45 +- .../rest/impl/OntologyMeasurementUnit.java | 10 +- .../rest/impl/OntologyPipelineElement.java | 21 +- .../streampipes/rest/impl/PipelineCache.java | 17 +- .../streampipes/rest/impl/PipelineCategory.java | 2 +- .../rest/impl/PipelineElementAsset.java | 9 +- .../rest/impl/PipelineElementCategory.java | 15 +- .../streampipes/rest/impl/PipelineElementFile.java | 4 +- .../rest/impl/PipelineElementImport.java | 12 +- .../rest/impl/PipelineElementRuntimeInfo.java | 5 +- ...rovidedOptions.java => PipelineMonitoring.java} | 23 +- .../streampipes/rest/impl/PipelineResource.java | 289 +++++++++ .../streampipes/rest/impl/PipelineTemplate.java | 87 +-- .../rest/impl/PipelineWithUserResource.java | 268 --------- .../apache/streampipes/rest/impl/RdfEndpoint.java | 27 +- .../rest/impl/SemanticEventConsumer.java | 2 +- .../rest/impl/SemanticEventProcessingAgent.java | 2 +- .../rest/impl/SemanticEventProducer.java | 35 +- .../org/apache/streampipes/rest/impl/Setup.java | 24 +- .../streampipes/rest/impl/StreamPipesLogs.java | 147 ----- .../org/apache/streampipes/rest/impl/User.java | 35 +- .../org/apache/streampipes/rest/impl/Version.java | 5 +- .../streampipes/rest/impl/VirtualSensor.java | 5 +- .../streampipes/rest/impl/Visualization.java | 4 +- .../impl/dashboard/AbstractDashboardResource.java | 18 +- .../rest/impl/dashboard/DashboardWidget.java | 10 +- .../rest/impl/dashboard/VisualizablePipeline.java | 9 +- ...shboard.java => DataLakeDashboardResource.java} | 2 +- .../rest/impl/datalake/DataLakeManagementV3.java | 652 --------------------- .../impl/datalake/DataLakeNoUserResourceV3.java | 5 +- .../rest/impl/datalake/DataLakeWidgetResource.java | 10 +- .../rest/impl/nouser/FileServingResource.java | 4 +- .../impl/nouser/PipelineElementImportNoUser.java | 8 +- .../rest/impl/nouser/PipelineNoUserResource.java | 4 +- .../rest/management/PipelineManagement.java | 4 +- .../datalake/DataLakeNoUserManagementV3Test.java | 3 +- .../sdk/builder/StreamRequirementsBuilder.java | 8 + .../streampipes/sdk/helpers/Alternatives.java | 15 + .../streampipes/sdk/helpers/EpRequirements.java | 18 + streampipes-serializers-json/pom.xml | 9 +- .../serializers/json/TestGsonSerializer.java | 23 +- .../serializers/json/TestJacksonSerializer.java | 42 ++ .../utils/PipelineElementTemplateHelpers.java | 52 ++ .../streampipes/storage/api/CRUDStorage.java | 16 +- .../streampipes/storage/api/INoSqlStorage.java | 2 + .../api/IPipelineElementDescriptionStorage.java | 31 +- .../api/IPipelineElementTemplateStorage.java | 10 +- .../storage/couchdb/CouchDbStorageManager.java | 5 + .../impl/PipelineElementTemplateStorageImpl.java | 67 +++ .../storage/couchdb/impl/UserStorage.java | 16 +- .../streampipes/storage/couchdb/utils/Utils.java | 6 + .../rdf4j/impl/PipelineElementInMemoryStorage.java | 114 ++-- .../rdf4j/impl/PipelineElementStorageRequests.java | 58 +- .../storage/rdf4j/sparql/QueryBuilder.java | 25 +- streampipes-user-management/pom.xml | 11 +- .../authentication/StreamPipesRealm.java | 40 +- .../user/management/service/TokenService.java | 61 ++ .../user/management/util/TokenUtil.java | 62 ++ .../user/management/util/TestTokenUtil.java | 57 ++ .../apache/streampipes/vocabulary/StreamPipes.java | 5 +- .../wrapper/siddhi/SiddhiAppConfig.java | 70 +++ .../wrapper/siddhi/SiddhiAppConfigBuilder.java | 61 ++ .../wrapper/siddhi/SiddhiQueryBuilder.java | 96 +++ .../siddhi/definition/SiddhiDefinition.java | 9 +- .../siddhi/definition/StreamDefinition.java | 13 +- .../siddhi/definition/WindowDefinition.java | 13 +- .../wrapper/siddhi/engine/SiddhiEngine.java | 9 +- .../wrapper/siddhi/engine/SiddhiEventEngine.java | 2 +- .../siddhi/engine/SiddhiStatementGenerator.java | 5 +- .../siddhi/engine/StreamPipesSiddhiProcessor.java | 4 +- .../engine/callback/SiddhiDebugCallback.java | 4 + .../callback/SiddhiOutputStreamCallback.java | 39 +- .../callback/SiddhiOutputStreamDebugCallback.java | 20 +- .../engine/generator/SiddhiAppGenerator.java | 38 +- .../generator/SiddhiInvocationConfigGenerator.java | 29 +- .../siddhi/output/SiddhiFirstOutputConfig.java | 12 +- .../siddhi/output/SiddhiListOutputConfig.java | 18 +- .../wrapper/siddhi/output/SiddhiOutputConfig.java | 25 +- .../wrapper/siddhi/output/SiddhiOutputType.java | 6 +- .../wrapper/siddhi/query/FromClause.java | 2 +- .../query/{FromClause.java => GroupByClause.java} | 28 +- .../wrapper/siddhi/query/HavingClause.java | 10 +- .../{FromClause.java => InsertIntoClause.java} | 28 +- .../TimeWindowExpression.java => LimitClause.java} | 20 +- .../query/{FromClause.java => OrderByClause.java} | 28 +- .../wrapper/siddhi/query/SelectClause.java | 2 +- .../wrapper/siddhi/query/SiddhiQuery.java | 126 ++++ .../wrapper/siddhi/query/SiddhiStatement.java | 20 +- .../siddhi/query/expression/Expressions.java | 26 +- .../CountExpression.java} | 20 +- .../orderby/OrderByExpression.java} | 29 +- ...owExpression.java => SortWindowExpression.java} | 22 +- ...ression.java => TimeBatchWindowExpression.java} | 7 +- .../expression/window/TimeWindowExpression.java | 1 + .../wrapper/siddhi/utils/SiddhiUtils.java | 27 +- ui/angular.json | 4 +- ui/deployment/app-routing.module.mst | 8 +- ui/deployment/appng5.module.mst | 6 +- ui/package.json | 6 + ui/src/app/add/add.component.html | 3 +- ui/src/app/add/add.component.ts | 4 +- .../endpoint-item/endpoint-item.component.html | 23 +- .../endpoint-item/endpoint-item.component.ts | 14 +- .../apidocs.component.html} | 9 +- .../apidocs.component.scss} | 2 - .../src/app/apidocs/apidocs.component.ts | 32 +- .../src/app/apidocs/apidocs.module.ts | 38 +- ui/src/app/app-routing.module.ts | 8 +- .../app-transport-monitoring.module.ts | 4 +- .../outgoing/outgoing-view.component.html | 12 +- .../transport-summary.component.html | 14 +- .../data-marketplace/data-marketplace.component.ts | 1 + ui/src/app/connect/services/rest.service.ts | 2 +- .../app/core-model/gen/streampipes-model-client.ts | 95 ++- ui/src/app/core-model/gen/streampipes-model.ts | 143 ++++- ui/src/app/core-ui/core-ui.module.ts | 12 +- .../static-any-input/static-any-input.component.ts | 3 - .../static-free-input.component.html | 1 - .../barchart/barchart-widget.component.html} | 20 +- .../barchart/barchart-widget.component.scss} | 4 +- .../widget/barchart/barchart-widget.component.ts | 41 +- .../widget/status/status-widget.component.css} | 0 .../widget/status/status-widget.component.html} | 7 +- .../widget/status/status-widget.component.ts} | 13 +- .../core/components/toolbar/toolbar.component.html | 10 +- .../core/components/toolbar/toolbar.component.scss | 13 +- .../core/components/toolbar/toolbar.component.ts | 11 +- .../components/grid/dashboard-grid.component.html | 6 +- .../components/grid/dashboard-grid.component.ts | 12 +- .../overview/dashboard-overview.component.css | 15 +- .../overview/dashboard-overview.component.html | 19 +- .../components/panel/dashboard-panel.component.css | 13 + .../panel/dashboard-panel.component.html | 39 +- .../components/panel/dashboard-panel.component.ts | 4 +- .../widget/dashboard-widget.component.html | 28 +- .../widget/dashboard-widget.component.ts | 3 +- .../components/widgets/bar-race/bar-race-config.ts | 45 ++ .../bar-race/bar-race-widget.component.html} | 16 +- .../bar-race-widget.component.scss} | 51 +- .../widgets/bar-race/bar-race-widget.component.ts | 165 ++++++ .../components/widgets/base/base-echarts-widget.ts | 59 ++ .../widgets/number/number-widget.component.css | 4 +- .../stacked-line-chart-config.ts | 45 ++ .../stacked-line-chart-widget.component.html} | 16 +- .../stacked-line-chart-widget.component.scss} | 51 +- .../stacked-line-chart-widget.component.ts | 122 ++++ .../components/widgets/status/status-config.ts | 43 ++ .../widgets/status/status-widget.component.html} | 16 +- .../status-widget.component.scss} | 51 +- .../widgets/status/status-widget.component.ts | 67 +++ .../widgets/wordcloud/wordcloud-config.ts | 48 ++ .../wordcloud/wordcloud-widget.component.html} | 17 +- .../wordcloud/wordcloud-widget.component.scss} | 37 +- .../wordcloud/wordcloud-widget.component.ts | 139 +++++ ui/src/app/dashboard/dashboard.module.ts | 17 + ui/src/app/dashboard/registry/widget-registry.ts | 37 +- ui/src/app/dashboard/sdk/ep-requirements.ts | 120 ++-- .../dashboard/sdk/matching/list-property-match.ts | 24 +- .../app/dashboard/sdk/matching/property-match.ts | 8 +- ...pipeline-element-template-config.component.html | 60 ++ ...ipeline-element-template-config.component.scss} | 15 + .../pipeline-element-template-config.component.ts | 79 +++ .../pipeline-element-template-generator.ts} | 33 +- .../dialog/customize/customize.component.html | 76 ++- .../dialog/customize/customize.component.scss | 11 + .../editor/dialog/customize/customize.component.ts | 96 ++- ui/src/app/editor/editor.component.ts | 8 +- ui/src/app/editor/editor.module.ts | 4 +- ui/src/app/home/components/status.component.ts | 15 +- .../login/components/login/login.component.html | 1 + ui/src/app/login/login.module.ts | 2 + .../actions/pipeline-actions.component.ts | 4 +- .../elements/pipeline-elements-row.component.html | 4 +- .../elements/pipeline-elements-row.component.ts | 3 + .../components/model/pipeline-details.model.ts} | 6 +- .../monitoring/pipeline-monitoring.component.html | 69 +++ .../monitoring/pipeline-monitoring.component.scss | 38 +- .../monitoring/pipeline-monitoring.component.ts | 112 ++++ .../pipeline-element-statistics.component.html | 64 ++ .../pipeline-element-statistics.component.scss | 9 +- .../pipeline-element-statistics.component.ts | 140 +++++ .../preview/pipeline-preview.component.html | 2 +- .../pipeline-details.component.html | 7 +- .../pipeline-details/pipeline-details.module.ts | 6 + .../pipeline-overview.component.html | 4 +- .../pipeline-overview.component.ts | 4 +- .../services/pipeline-operations.service.ts | 16 +- .../apis/pipeline-element-template.service.ts | 69 +++ .../apis/pipeline-element.service.ts | 20 +- .../apis/pipeline-monitoring.service.ts | 38 +- ui/src/app/platform-services/platform.module.ts | 6 +- .../profile/components/basic-profile-settings.ts | 58 ++ .../general-profile-settings.component.html | 51 ++ .../general-profile-settings.component.scss} | 20 +- .../general/general-profile-settings.component.ts | 29 +- .../token/token-management-settings.component.html | 90 +++ .../token-management-settings.component.scss} | 65 +- .../token/token-management-settings.component.ts | 70 +++ ui/src/app/profile/profile.component.html | 42 ++ .../profile.component.scss} | 4 +- .../src/app/profile/profile.component.ts | 23 +- .../profile.module.ts} | 45 +- ui/src/app/profile/profile.service.ts | 53 ++ ui/src/scss/main.scss | 1 + ui/src/scss/sp/colors.scss | 4 + ui/src/scss/sp/main.scss | 29 +- ui/src/scss/sp/sp-dialog.scss | 2 +- 432 files changed, 10125 insertions(+), 5970 deletions(-)
