You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/03/01 12:11:09 UTC
[incubator-streampipes] 01/01: Merge branch 'dev' into
STREAMPIPES-79
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch STREAMPIPES-79
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit dc7a5915e6a9927cca2ca37a178e129f3102b556
Merge: 9416aaf 07e80d6
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sun Mar 1 13:10:52 2020 +0100
Merge branch 'dev' into STREAMPIPES-79
.github/workflows/build.yml | 84 +-
.gitlab-ci.yml | 166 +-
LICENSE | 19 +-
LICENSE-binary | 129 +-
NOTICE | 4 +-
NOTICE-binary | 318 +-
pom.xml | 186 +-
streampipes-backend/Dockerfile | 2 +-
.../{Dockerfile => aarch64.Dockerfile} | 8 +-
.../{Dockerfile.arm => arm.Dockerfile} | 4 +-
streampipes-backend/development/env | 1 +
streampipes-commons/pom.xml | 4 +
.../java/org/apache/streampipes/commons/Utils.java | 6 +-
.../{Dockerfile.arm => aarch64.Dockerfile} | 4 +-
.../{Dockerfile.arm => arm.Dockerfile} | 2 +-
.../master/init/AdapterMasterContainer.java | 0
.../init/AdapterMasterContainerResourceConfig.java | 0
.../master/management/AdapterMasterManagement.java | 0
.../AdapterTemplateMasterManagement.java | 0
.../master/management/DescriptionManagement.java | 0
.../master/management/FileManagement.java | 0
.../master/management/GuessManagement.java | 0
.../master/management/SourcesManagement.java | 0
.../master/management/UnitMasterManagement.java | 0
.../connect/container/master/management/Utils.java | 0
.../management/WorkerAdministrationManagement.java | 0
.../master/management/WorkerRestClient.java | 0
.../container/master/rest/AdapterResource.java | 0
.../master/rest/AdapterTemplateResource.java | 0
.../container/master/rest/DescriptionResource.java | 26 +-
.../container/master/rest/FileResource.java | 0
.../container/master/rest/GuessResource.java | 0
.../master/rest/RuntimeResolvableResource.java | 0
.../container/master/rest/SourcesResource.java | 0
.../container/master/rest/UnitResource.java | 0
.../container/master/rest/WelcomePageMaster.java | 0
.../master/rest/WorkerAdministrationResource.java | 0
.../master/util/AdapterEncryptionService.java | 0
.../worker/init/AdapterWorkerContainer.java | 0
.../init/AdapterWorkerContainerResourceConfig.java | 29 +-
.../worker/management/AdapterWorkerManagement.java | 0
.../worker/management/FileManagement.java | 0
.../worker/management/GuessManagement.java | 0
.../worker/management/MasterRestClient.java | 0
.../container/worker/rest/AdapterResource.java | 27 +-
.../container/worker/rest/FileResource.java | 0
.../container/worker/rest/GuessResource.java | 0
.../container/worker/rest/ProtocolResource.java | 27 +-
.../worker/rest/RuntimeResolvableResource.java | 0
.../container/worker/rest/WelcomePageWorker.java | 0
.../container/worker/rest/WorkerResource.java | 0
.../connect/container/worker/utils/Utils.java | 2 +-
.../format/json/object/JsonObjectParser.java | 5 -
.../stream/EventRateTransformationRule.java | 2 +-
.../PipelineElementContainerResourceConfig.java | 0
.../standalone/init/StandaloneModelSubmitter.java | 0
.../apache/streampipes/container/api/Element.java | 14 +-
.../container/transform/Transformer.java | 9 +-
.../dataformat/cbor/CborDataFormatDefinition.java | 0
.../dataformat/cbor/CborDataFormatFactory.java | 0
.../dataformat/fst/FstDataFormatDefinition.java | 0
.../dataformat/fst/FstDataFormatFactory.java | 0
.../dataformat/json/JsonDataFormatDefinition.java | 0
.../dataformat/json/JsonDataFormatFactory.java | 0
.../dataformat/SpDataFormatDefinition.java | 0
.../dataformat/SpDataFormatFactory.java | 0
.../dataformat/SpDataFormatManager.java | 0
streampipes-measurement-units/pom.xml | 4 +
.../src/main/java/com/github/jqudt/Multiplier.java | 17 +-
.../src/main/java/com/github/jqudt/Quantity.java | 17 +-
.../src/main/java/com/github/jqudt/Unit.java | 17 +-
.../java/com/github/jqudt/onto/OntoReader.java | 17 +-
.../src/main/java/com/github/jqudt/onto/QUDT.java | 17 +-
.../java/com/github/jqudt/onto/UnitFactory.java | 17 +-
.../java/com/github/jqudt/onto/units/AreaUnit.java | 17 +-
.../github/jqudt/onto/units/ConcentrationUnit.java | 17 +-
.../com/github/jqudt/onto/units/CountingUnit.java | 17 +-
.../com/github/jqudt/onto/units/EnergyUnit.java | 17 +-
.../com/github/jqudt/onto/units/LengthUnit.java | 17 +-
.../java/com/github/jqudt/onto/units/MassUnit.java | 17 +-
.../jqudt/onto/units/PressureOrStressUnit.java | 18 +-
.../github/jqudt/onto/units/TemperatureUnit.java | 17 +-
.../com/github/jqudt/onto/units/VolumeUnit.java | 17 +-
.../com/github/jqudt/uo/UnitOntologyFactory.java | 17 +-
.../src/main/resources/onto/dimension | 181 -
.../src/main/resources/onto/dtype | 280 -
.../src/main/resources/onto/ops.ttl | 326 -
.../src/main/resources/onto/quantity | 1544 ----
.../src/main/resources/onto/qudt | 1903 -----
.../src/main/resources/onto/qudt-quantity | 4255 ----------
.../src/main/resources/onto/unit | 8532 --------------------
.../messaging/kafka/SpKafkaConsumer.java | 8 +
.../model/client/messages/ErrorMessageLd.java | 4 +-
.../model/client/messages/MessageLd.java | 8 +-
.../model/client/messages/NotificationLd.java | 8 +-
.../model/client/messages/SuccessMessageLd.java | 4 +-
streampipes-model/pom.xml | 12 +-
.../apache/streampipes/model/ApplicationLink.java | 4 +-
.../org/apache/streampipes/model/SpDataSet.java | 4 +-
.../org/apache/streampipes/model/SpDataStream.java | 4 +-
.../streampipes/model/SpDataStreamContainer.java | 6 +-
.../model/base/AbstractStreamPipesEntity.java | 6 +-
.../model/base/ConsumableStreamPipesEntity.java | 2 +-
.../model/base/InvocableStreamPipesEntity.java | 2 +-
.../model/base/NamedStreamPipesEntity.java | 4 +-
.../model/base/StreamPipesJsonLdContainer.java | 4 +-
.../model/base/UnnamedStreamPipesEntity.java | 4 +-
.../streampipes/model/connect/ListDescription.java | 6 +-
.../model/connect/adapter/AdapterDescription.java | 6 +-
.../connect/adapter/AdapterDescriptionList.java | 6 +-
.../connect/adapter/AdapterSetDescription.java | 6 +-
.../connect/adapter/AdapterStreamDescription.java | 6 +-
.../adapter/GenericAdapterSetDescription.java | 6 +-
.../adapter/GenericAdapterStreamDescription.java | 6 +-
.../adapter/SpecificAdapterSetDescription.java | 4 +-
.../adapter/SpecificAdapterStreamDescription.java | 4 +-
.../model/connect/grounding/FormatDescription.java | 6 +-
.../connect/grounding/FormatDescriptionList.java | 6 +-
.../connect/grounding/ProtocolDescription.java | 6 +-
.../connect/grounding/ProtocolDescriptionList.java | 6 +-
.../connect/grounding/ProtocolSetDescription.java | 4 +-
.../grounding/ProtocolStreamDescription.java | 4 +-
.../connect/guess/DomainPropertyProbability.java | 6 +-
.../guess/DomainPropertyProbabilityList.java | 6 +-
.../model/connect/guess/GuessSchema.java | 6 +-
.../rules/Schema/CreateNestedRuleDescription.java | 6 +-
.../rules/Schema/DeleteRuleDescription.java | 6 +-
.../connect/rules/Schema/MoveRuleDescription.java | 6 +-
.../rules/Schema/RenameRuleDescription.java | 6 +-
.../EventRateTransformationRuleDescription.java | 6 +-
...oveDuplicatesTransformationRuleDescription.java | 6 +-
.../rules/TransformationRuleDescription.java | 4 +-
.../rules/value/AddTimestampRuleDescription.java | 6 +-
.../AddValueTransformationRuleDescription.java | 6 +-
.../TimestampTranfsformationRuleDescription.java | 6 +-
.../rules/value/UnitTransformRuleDescription.java | 6 +-
.../connect/worker/ConnectWorkerContainer.java | 6 +-
.../model/dashboard/DashboardEntity.java | 4 +-
.../model/dashboard/DashboardModel.java | 2 +-
.../model/dashboard/DashboardWidgetDataConfig.java | 85 -
.../model/dashboard/DashboardWidgetModel.java | 29 +-
.../model/dashboard/DashboardWidgetSettings.java | 4 +-
.../model/dashboard/VisualizablePipeline.java | 4 +-
.../model/datalake/DataExplorerWidgetModel.java | 5 +-
.../model/datalake/DataLakeMeasure.java | 4 +-
.../model/graph/DataProcessorDescription.java | 4 +-
.../model/graph/DataProcessorInvocation.java | 4 +-
.../model/graph/DataSinkDescription.java | 4 +-
.../model/graph/DataSinkInvocation.java | 4 +-
.../model/graph/DataSourceDescription.java | 4 +-
.../model/graph/PipelineElementContainer.java | 4 +-
.../model/grounding/EventGrounding.java | 4 +-
.../model/grounding/JmsTransportProtocol.java | 4 +-
.../model/grounding/KafkaTransportProtocol.java | 4 +-
.../model/grounding/SimpleTopicDefinition.java | 2 +-
.../model/grounding/TopicDefinition.java | 4 +-
.../model/grounding/TransportFormat.java | 4 +-
.../model/grounding/TransportProtocol.java | 4 +-
.../model/grounding/WildcardTopicDefinition.java | 4 +-
.../model/grounding/WildcardTopicMapping.java | 4 +-
.../monitoring/ElementStatusInfoSettings.java | 4 +-
.../model/output/AppendOutputStrategy.java | 4 +-
.../model/output/CustomOutputStrategy.java | 4 +-
.../output/CustomTransformOutputStrategy.java | 4 +-
.../model/output/FixedOutputStrategy.java | 4 +-
.../model/output/KeepOutputStrategy.java | 4 +-
.../model/output/ListOutputStrategy.java | 4 +-
.../streampipes/model/output/OutputStrategy.java | 4 +-
.../model/output/PropertyRenameRule.java | 4 +-
.../model/output/TransformOperation.java | 4 +-
.../model/output/TransformOutputStrategy.java | 4 +-
.../apache/streampipes/model/quality/Accuracy.java | 4 +-
.../quality/EventPropertyQualityDefinition.java | 2 +-
.../quality/EventPropertyQualityRequirement.java | 4 +-
.../quality/EventStreamQualityDefinition.java | 2 +-
.../quality/EventStreamQualityRequirement.java | 4 +-
.../streampipes/model/quality/Frequency.java | 4 +-
.../apache/streampipes/model/quality/Latency.java | 4 +-
.../model/quality/MeasurementCapability.java | 4 +-
.../model/quality/MeasurementObject.java | 4 +-
.../model/quality/MeasurementProperty.java | 2 +-
.../model/quality/MeasurementRange.java | 4 +-
.../streampipes/model/quality/Precision.java | 4 +-
.../streampipes/model/quality/Resolution.java | 4 +-
.../model/runtime/RuntimeOptionsRequest.java | 4 +-
.../model/runtime/RuntimeOptionsResponse.java | 4 +-
.../streampipes/model/schema/Enumeration.java | 4 +-
.../streampipes/model/schema/EventProperty.java | 4 +-
.../model/schema/EventPropertyList.java | 4 +-
.../model/schema/EventPropertyNested.java | 4 +-
.../model/schema/EventPropertyPrimitive.java | 4 +-
.../streampipes/model/schema/EventSchema.java | 6 +-
.../model/schema/QuantitativeValue.java | 4 +-
.../model/schema/ValueSpecification.java | 2 +-
.../model/staticproperty/AnyStaticProperty.java | 2 +-
.../staticproperty/CollectionStaticProperty.java | 4 +-
.../staticproperty/ColorPickerStaticProperty.java | 4 +-
.../model/staticproperty/DomainStaticProperty.java | 4 +-
.../model/staticproperty/FileStaticProperty.java | 4 +-
.../staticproperty/FreeTextStaticProperty.java | 4 +-
.../model/staticproperty/MappingProperty.java | 4 +-
.../model/staticproperty/MappingPropertyNary.java | 4 +-
.../model/staticproperty/MappingPropertyUnary.java | 4 +-
.../staticproperty/MatchingStaticProperty.java | 4 +-
.../model/staticproperty/OneOfStaticProperty.java | 2 +-
.../streampipes/model/staticproperty/Option.java | 4 +-
.../staticproperty/PropertyValueSpecification.java | 4 +-
.../staticproperty/RemoteOneOfStaticProperty.java | 4 +-
.../RuntimeResolvableAnyStaticProperty.java | 4 +-
.../RuntimeResolvableOneOfStaticProperty.java | 4 +-
.../model/staticproperty/SecretStaticProperty.java | 4 +-
.../staticproperty/SelectionStaticProperty.java | 4 +-
.../model/staticproperty/StaticProperty.java | 4 +-
.../staticproperty/StaticPropertyAlternative.java | 4 +-
.../staticproperty/StaticPropertyAlternatives.java | 4 +-
.../model/staticproperty/StaticPropertyGroup.java | 4 +-
.../model/staticproperty/SupportedProperty.java | 4 +-
.../model/template/BoundPipelineElement.java | 4 +-
.../template/PipelineTemplateDescription.java | 4 +-
.../PipelineTemplateDescriptionContainer.java | 4 +-
.../model/template/PipelineTemplateInvocation.java | 4 +-
.../apache/streampipes/model/util/ModelUtils.java | 6 +-
.../matching/output/ListOutputSchemaGenerator.java | 2 +-
.../matching/output/PropertyDuplicateRemover.java | 2 +-
.../runtime/PipelineElementRuntimeInfoFetcher.java | 187 +-
.../streampipes/manager/matching/v2/TestUtils.java | 2 +-
.../streampipes/rest/shared/util/JsonLdUtils.java | 2 +-
.../rest/api/dashboard/IVisualizablePipeline.java | 4 +
.../rest/impl/AbstractRestInterface.java | 2 +-
.../apache/streampipes/rest/impl/Deployment.java | 2 +-
.../rest/impl/dashboard/VisualizablePipeline.java | 29 +
streampipes-serializers/pom.xml | 4 +-
.../jsonld/CustomAnnotationProvider.java | 4 +-
.../serializers/jsonld/JsonLdTransformer.java | 16 +-
.../serializers/jsonld/RdfTransformer.java | 7 +-
.../storage/api/IVisualizablePipelineStorage.java | 2 +
.../impl/VisualizablePipelineStorageImpl.java | 5 +
streampipes-storage-rdf4j/pom.xml | 4 +-
.../streampipes/storage/Rdf4JStorageManager.java | 12 +-
.../rdf4j/impl/PipelineElementStorageRequests.java | 2 +-
ui/{Dockerfile.arm => aarch64.Dockerfile} | 36 +-
ui/angular.json | 9 +-
ui/{Dockerfile.arm => arm.Dockerfile} | 38 +-
ui/deployment/0.65.0/img/background.png | Bin 995787 -> 0 bytes
ui/deployment/app.module.mst | 2 +-
ui/deployment/apps/img/background.png | Bin 995787 -> 0 bytes
ui/deployment/dev/img/background.png | Bin 995787 -> 0 bytes
ui/deployment/prebuild.js | 2 -
ui/deployment/toolbar.controller.mst | 17 +-
ui/package.json | 16 +-
.../app/CustomMaterial/custom-material.module.ts | 36 +-
ui/src/app/NS/XS.service.spec.ts | 4 +-
ui/src/app/NS/XS.service.ts | 3 +-
.../app-asset-monitoring.module.ts | 6 +-
.../create-asset/create-asset.component.ts | 2 +-
.../dashboard-overview.component.ts | 2 +-
.../components/view-asset/view-asset.component.ts | 3 +-
.../add-pipeline/add-pipeline-dialog.component.ts | 2 +-
.../save-dashboard-dialog.component.ts | 2 +-
.../model/canvas-configuration.model.ts | 1 -
.../app/app-container/app-container.component.ts | 6 +-
ui/src/app/app-container/app-container.module.ts | 18 +-
.../app-container/shared/app-container.service.ts | 8 +-
ui/src/app/app-container/view/view.component.ts | 12 +-
ui/src/app/app-overview/app-overview.module.ts | 14 +-
.../app-transport-monitoring.module.ts | 16 +-
.../dashboard-image/dashboard-image.component.ts | 4 +-
.../dashboard-status-filled.component.ts | 2 +-
.../dashboard-status/dashboard-status.component.ts | 2 +-
.../transport-selection.component.ts | 4 +-
.../transport-summary.component.ts | 2 +-
.../app-transport-monitoring-rest.service.ts | 2 +-
.../configuration/configuration.component.spec.ts | 14 +-
.../app/configuration/configuration.component.ts | 8 +-
ui/src/app/configuration/configuration.module.ts | 12 +-
.../consul-configs-boolean.component.ts | 6 +-
.../consul-configs-number.component.ts | 6 +-
.../consul-configs-password.component.spec.ts | 28 +-
.../consul-configs-password.component.ts | 5 +-
.../consul-configs-text.component.ts | 6 +-
.../consul-configs/consul-configs.component.ts | 5 +-
.../consul-service.component.spec.ts | 24 +-
.../consul-service/consul-service.component.ts | 6 +-
.../messaging-configuration.component.ts | 2 +-
.../pipeline-element-configuration.component.ts | 4 +-
.../shared/configuration.service.spec.ts | 8 +-
.../configuration/shared/configuration.service.ts | 12 +-
.../shared/configuration.test.service.ts | 8 +-
.../shared/streampipes-pe-container.model.ts | 3 +-
ui/src/app/connect/connect.component.ts | 5 +-
ui/src/app/connect/connect.module.ts | 122 +-
ui/src/app/connect/connect.service.ts | 4 +-
.../adapter-description.component.html | 6 +-
.../adapter-description.component.ts | 8 +-
.../adapter-export-dialog.component.ts | 2 +-
.../adapter-upload-dialog.component.ts | 2 +-
.../data-marketplace/data-marketplace.component.ts | 14 +-
.../data-marketplace/data-marketplace.service.ts | 56 +-
ui/src/app/connect/data-marketplace/filter.pipe.ts | 2 +-
.../file-management/file-management.component.ts | 6 +-
.../file-management/service/filerest.service.ts | 2 +-
ui/src/app/connect/filter/timestamp.pipe.ts | 2 +-
.../connect/format-component/format.component.ts | 4 +-
.../connect/format-form/format-form.component.ts | 6 +-
.../format-list-component/format-list.component.ts | 4 +-
ui/src/app/connect/model/AnyStaticProperty.ts | 4 +-
ui/src/app/connect/model/ApplicationLink.ts | 6 +-
ui/src/app/connect/model/BoundPipelineElement.ts | 8 +-
.../app/connect/model/DataProcessorInvocation.ts | 6 +-
ui/src/app/connect/model/DataSetDescription.ts | 2 -
ui/src/app/connect/model/DataSinkInvocation.ts | 6 +-
ui/src/app/connect/model/DataStreamContainer.ts | 8 +-
ui/src/app/connect/model/FreeTextStaticProperty.ts | 1 -
.../connect/model/InvocableStreamPipesEntity.ts | 10 +-
ui/src/app/connect/model/MappingPropertyNary.ts | 1 -
ui/src/app/connect/model/NamedStreamPipesEntity.ts | 8 +-
ui/src/app/connect/model/OneOfStaticProperty.ts | 4 +-
ui/src/app/connect/model/Option.ts | 6 +-
.../connect/model/PipelineTemplateDescription.ts | 8 +-
.../model/PipelineTemplateDescriptionContainer.ts | 8 +-
.../connect/model/PipelineTemplateInvocation.ts | 8 +-
ui/src/app/connect/model/SecretStaticProperty.ts | 1 -
.../app/connect/model/SelectionStaticProperty.ts | 9 +-
ui/src/app/connect/model/StaticProperty.ts | 1 -
.../model/connect/AdapterStreamDescription.ts | 1 -
.../model/connect/GenericAdapterSetDescription.ts | 2 +-
.../connect/GenericAdapterStreamDescription.ts | 2 +-
.../model/connect/SpecificAdapterSetDescription.ts | 2 +-
.../connect/SpecificAdapterStreamDescription.ts | 2 +-
.../connect/rules/UnitTransformRuleDescription.ts | 8 +-
.../connect/runtime/RuntimeOptionsResponse.ts | 2 -
.../connect/model/output/AppendOutputStrategy.ts | 6 +-
.../connect/model/output/CustomOutputStrategy.ts | 4 +-
.../model/output/CustomTransformOutputStrategy.ts | 6 +-
.../connect/model/output/FixedOutputStrategy.ts | 6 +-
.../app/connect/model/output/KeepOutputStrategy.ts | 4 +-
.../app/connect/model/output/ListOutputStrategy.ts | 4 +-
ui/src/app/connect/model/output/OutputStrategy.ts | 2 +-
.../component/adapter-started-dialog.component.ts | 3 +-
ui/src/app/connect/new-adapter/icon.service.ts | 2 +-
.../new-adapter/new-adapter.component.spec.ts | 31 +-
.../connect/new-adapter/new-adapter.component.ts | 50 +-
.../protocol-component/protocol.component.ts | 5 +-
.../protocol-list.component.ts | 3 +-
ui/src/app/connect/rdfmapper/rdfmapper.service.ts | 5 +-
ui/src/app/connect/rest.service.ts | 31 +-
.../event-property-list.component.ts | 8 +-
.../event-property-primitive.component.ts | 24 +-
.../event-property-row.component.ts | 4 +-
.../event-property/event-property.component.ts | 2 +-
.../event-schema-preview.component.ts | 4 +-
.../event-schema/event-schema.component.ts | 28 +-
.../connect/schema-editor/model/EventProperty.ts | 6 +-
.../schema-editor/model/EventPropertyList.ts | 1 +
.../schema-editor/model/EventPropertyPrimitive.ts | 1 -
.../app/connect/schema-editor/model/ExampleNode.ts | 2 +-
.../app/connect/schema-editor/model/GuessSchema.ts | 10 +-
.../schema-editor/model/QuantitativeValue.ts | 8 +-
.../connect/schema-editor/unit-provider.service.ts | 2 +-
.../select-protocol-component/input.validator.ts | 3 +-
.../select-protocol.component.ts | 9 +-
.../select-static-properties.component.ts | 6 +-
.../static-any-input/static-any-input.component.ts | 2 +-
.../static-collection.component.ts | 1 -
.../static-file-input.component.ts | 7 +-
.../static-free-input.component.ts | 6 +-
.../static-mapping-nary.component.ts | 3 +-
.../static-mapping-unary.component.ts | 6 +-
.../static-number-input.component.ts | 13 +-
.../static-one-of-input.component.ts | 1 -
.../static-property-util.service.ts | 30 +-
.../static-properties/static-property.component.ts | 22 +-
.../static-secret-input.component.ts | 7 +-
.../static-text-input.component.ts | 8 +-
.../static-url-input/static-url-input.component.ts | 13 +-
.../connect/transformation-rule.service.spec.ts | 5 +-
ui/src/app/core-model/dashboard/DashboardWidget.ts | 8 +-
.../dashboard/DashboardWidgetDataConfig.ts | 41 -
.../core-model/dashboard/VisualizablePipeline.ts | 4 +-
ui/src/app/core/working.state.config.ts | 10 +-
.../components/grid/dashboard-grid.component.ts | 7 +-
.../overview/dashboard-overview.component.css | 1 +
.../overview/dashboard-overview.component.ts | 1 -
.../widget/dashboard-widget.component.html | 17 +-
.../widget/dashboard-widget.component.ts | 15 +-
.../widgets/base/base-ngx-line-config.ts | 2 +-
.../components/widgets/base/base-widget.ts | 8 +-
.../widgets/gauge/gauge-widget.component.ts | 2 +-
.../widgets/line/line-widget.component.ts | 5 +-
.../widgets/number/number-widget.component.ts | 2 +-
.../widgets/table/table-widget.component.ts | 2 +-
ui/src/app/dashboard-v2/dashboard.component.ts | 1 -
ui/src/app/dashboard-v2/dashboard.module.ts | 16 +-
.../add-visualization-dialog.component.ts | 3 +-
.../edit-dashboard-dialog.component.ts | 6 +-
.../app/dashboard-v2/models/multi-series.model.ts | 2 -
.../dashboard-v2/services/MockDashboard.service.ts | 48 -
.../app/dashboard-v2/services/dashboard.service.ts | 21 +-
.../dashboard/components/config-item.controller.ts | 2 -
ui/src/app/dashboard/dashboard.controller.ts | 1 -
ui/src/app/dashboard/dashboard.module.ts | 55 +-
.../socket-connection-data-model.service.ts | 2 +-
.../templates/gauge/gauge-data-model.service.ts | 2 +-
.../dashboard/templates/gauge/gauge.directive.ts | 3 +-
.../heatmap/heatmap-data-model.service.ts | 2 +-
.../templates/heatmap/heatmap.directive.ts | 3 +-
.../templates/html/html-data-model.service.ts | 2 +-
.../app/dashboard/templates/html/html.directive.ts | 3 +-
.../templates/image/image-data-model.service.ts | 2 +-
.../dashboard/templates/image/image.directive.ts | 3 +-
.../templates/line/line-data-model.service.ts | 2 +-
.../app/dashboard/templates/line/line.directive.ts | 3 +-
.../map.deprecated/map-data-model.service.ts | 2 +-
.../templates/map.deprecated/map.directive.ts | 3 +-
.../templates/map/map-data-model.service.ts | 2 +-
.../app/dashboard/templates/map/map.directive.ts | 3 +-
.../templates/number/number-data-model.service.ts | 2 +-
.../dashboard/templates/number/number.directive.ts | 3 +-
.../templates/raw/raw-data-model.service.ts | 2 +-
.../app/dashboard/templates/raw/raw.directive.ts | 3 +-
.../templates/table/table-data-model.service.ts | 2 +-
.../dashboard/templates/table/table.directive.ts | 3 +-
.../trafficlight-data-model.service.ts | 2 +-
.../trafficlight/trafficlight.directive.ts | 3 +-
.../verticalbar/verticalbar-data-model.service.ts | 2 +-
.../templates/verticalbar/verticalbar.directive.ts | 3 +-
.../datadownloadDialog/dataDownload.dialog.ts | 4 +-
.../table/table.component.ts | 2 +-
.../explorer-widget/explorer.component.ts | 2 +-
.../alternative/alternative.component.ts | 1 +
.../alternative/alternative.controller.ts | 2 -
.../components/any-remote/any-remote.component.ts | 1 +
ui/src/app/editor/components/any/any.component.ts | 1 +
ui/src/app/editor/components/any/any.controller.ts | 2 -
.../components/collection/collection.component.ts | 1 +
.../customize/customize-dialog.component.ts | 1 +
.../customoutput/customoutput.component.ts | 1 +
.../property-selection.component.ts | 1 +
.../property-selection.controller.ts | 2 -
.../domainconcept/domainconcept.component.ts | 1 +
.../components/fileupload/fileupload.component.ts | 1 +
.../components/freetext/freetext.component.ts | 1 +
.../components/freetext/freetext.controller.ts | 1 -
.../app/editor/components/group/group.component.ts | 1 +
.../mappingnary/mappingnary.component.ts | 1 +
.../mappingunary/mappingunary.component.ts | 1 +
.../matchingproperty/matchingproperty.component.ts | 1 +
.../multivalue/multiple-value-input.component.ts | 1 +
.../oneof-remote/oneof-remote.component.ts | 1 +
.../app/editor/components/oneof/oneof.component.ts | 1 +
.../pipeline-assembly.component.ts | 1 +
.../pipeline-element-documentation.component.ts | 1 +
.../pipeline-element-icon-stand.component.ts | 1 +
.../pipeline-element-options.component.ts | 1 +
.../pipeline-element-recommendation.component.ts | 1 +
.../pipeline-element/pipeline-element.component.ts | 1 +
.../components/pipeline/pipeline.component.ts | 1 +
.../components/pipeline/pipeline.controller.ts | 1 +
.../replaceoutput/replaceoutput.component.ts | 1 +
.../editor/components/secret/secret.component.ts | 1 +
.../editor/components/secret/secret.controller.ts | 2 -
.../topic/topic-selection-dialog.component.ts | 1 +
.../editor/dialog/help/help-dialog.controller.ts | 1 +
ui/src/app/editor/editor.module.ts | 6 +-
.../services/editor-dialog-manager.service.ts | 8 +-
ui/src/app/home/components/status.component.ts | 4 +-
ui/src/app/home/home.component.ts | 8 +-
ui/src/app/home/home.module.ts | 18 +-
ui/src/app/info/info.component.ts | 4 +-
ui/src/app/info/info.module.ts | 34 +-
.../info/versions/service/version-info.service.ts | 12 +-
ui/src/app/info/versions/versions.component.ts | 2 +-
ui/src/app/layout/app.controller.ts | 4 -
ui/src/app/login/login.controller.ts | 4 +-
ui/src/app/login/login.module.ts | 6 +-
ui/src/app/login/startup/startup.controller.ts | 1 -
ui/src/app/myelements/my-elements.controller.ts | 1 +
.../actions/pipeline-actions.component.ts | 1 +
.../components/edit/quickedit.component.ts | 1 +
.../elements/pipeline-elements-row.component.ts | 1 +
.../elements/pipeline-elements.component.ts | 1 +
.../preview/pipeline-preview.component.ts | 1 +
.../components/status/pipeline-status.component.ts | 1 +
.../pipeline-details/pipeline-details.component.ts | 1 +
ui/src/app/pipelines/pipelines.controller.ts | 7 +-
ui/src/app/pipelines/pipelines.module.ts | 10 +-
.../services/pipeline-operations.service.ts | 1 +
.../apis/pipeline-template.service.ts | 43 +-
ui/src/app/platform-services/platform.module.ts | 2 +-
.../platform-services/tsonld-serializer.service.ts | 71 +-
ui/src/app/platform-services/tsonld/tsonld.ts | 6 +-
.../deployment/deployment-type.component.ts | 1 +
.../components/deployment/deployment.component.ts | 1 +
.../general/advanced-settings.component.ts | 1 +
.../components/general/collapsible.component.ts | 1 +
.../components/general/options.component.ts | 1 +
.../general/value-specification.component.ts | 1 +
.../generated-element-description.component.ts | 1 +
.../generated-element-implementation.component.ts | 1 +
.../grounding/supported-grounding.component.ts | 1 +
.../grounding/transport-format.component.ts | 1 +
.../components/output/output-strategy.component.ts | 1 +
.../property/datatype-property.component.ts | 1 +
.../property/domain-concept-property.component.ts | 1 +
.../property/domain-property.component.ts | 1 +
.../property/event-properties.component.ts | 1 +
.../property/property-restriction.component.ts | 1 +
.../property/required-property-values.component.ts | 1 +
.../property/static-properties.component.ts | 1 +
.../property-quality-definitions.component.ts | 1 +
.../stream-quality-definitions.component.ts | 1 +
.../restriction/stream-restriction.component.ts | 1 +
.../components/sepa/sepa-basics.component.ts | 1 +
.../sepa/sepa-stream-detail.component.ts | 1 +
.../components/unit/measurement-unit.component.ts | 1 +
ui/src/app/services/auth-status.service.ts | 2 +-
ui/src/app/services/auth.service.ts | 1 -
ui/src/app/services/jsplumb.service.ts | 1 -
.../route-transition-interceptor.service.ts | 1 -
ui/src/app/services/services.module.ts | 46 +-
.../tour/create-pipeline-tour.constants.ts | 6 +-
ui/src/app/services/tour/shepherd.service.ts | 1 -
ui/src/app/services/tour/tour-provider.service.ts | 2 -
ui/src/app/shared/logger/log.service.ts | 2 +-
ui/src/assets/css/angular-material.css | 6 -
ui/src/assets/css/archivoRailwyRoboto.css | 109 -
ui/src/assets/css/bootstrap.min.css | 5 -
ui/src/assets/css/epoch.min.css | 1 -
ui/src/assets/css/font-awesome.min.css | 4 -
ui/src/assets/css/jquery-ui.css | 1243 ---
ui/src/assets/css/jquery.dataTables.min.css | 542 --
ui/src/assets/css/picker.min.css | 8 -
ui/src/assets/css/slick-theme.min.css | 1 -
ui/src/assets/css/slick.min.css | 1 -
ui/src/assets/css/trix.css | 304 -
ui/src/assets/dashboards.json | 38 -
ui/src/assets/fonts/KFOmCnqEu92Fr1Mu4mxK.woff2 | Bin 15344 -> 0 bytes
...materialicons.css => MaterialIcons-Regular.css} | 2 +-
.../src/assets/fonts/Roboto-Regular.css | 15 +-
ui/src/assets/fonts/Roboto-Regular.ttf | Bin 0 -> 171272 bytes
ui/src/assets/fonts/archivo.css | 90 -
.../fonts/flUhRq6tzZclQEJ-Vdg-IuiaDsNc.woff2 | Bin 49140 -> 0 bytes
ui/src/assets/fonts/raleway.css | 34 -
ui/src/assets/fonts/roboto.css | 74 -
ui/src/assets/fonts/robotodraft.css | 298 -
ui/src/assets/img/login/background.png | Bin 995787 -> 0 bytes
ui/src/assets/img/login_streampipes/background.png | Bin 2055422 -> 0 bytes
ui/src/assets/img/login_testfeld/background.jpg | Bin 409481 -> 0 bytes
ui/src/assets/img/login_testfeld/logo.png | Bin 42504 -> 0 bytes
ui/src/assets/img/test-asset-image.jpg | Bin 2278538 -> 0 bytes
ui/src/assets/lib/d3.min.js | 5 -
ui/src/assets/lib/epoch.min.js | 3 -
ui/src/assets/lib/flowtype.js | 66 -
ui/src/assets/lib/jQuery.circleMenu.js | 331 -
ui/src/assets/lib/jquery-2.2.4.min.js | 4 -
ui/src/assets/lib/jquery-touch-punch.js | 11 -
ui/src/assets/lib/jquery-ui.min.js | 13 -
ui/src/assets/lib/jquery.dataTables.min.js | 3863 ---------
ui/src/assets/lib/jquery.panzoom.min.js | 9 -
ui/src/assets/lib/jsPlumb-2.1.0-min.js | 7 -
ui/src/assets/lib/malhar-angular-dashboard.js | 1483 ----
ui/src/assets/lib/malhar-angular-widgets.js | 2094 -----
ui/src/assets/lib/mlhr-table.js | 1210 ---
ui/src/assets/lib/ng-context-menu.min.js | 4 -
ui/src/assets/lib/please-wait.min.js | 12 -
ui/src/assets/lib/stomp.js | 393 -
ui/src/assets/lib/system.js | 4 -
ui/src/assets/lib/trix.js | 20 -
ui/src/assets/templates/login.html | 4 +-
ui/src/assets/templates/setup.html | 4 +-
ui/src/index.html | 114 +-
ui/src/scss/main.scss | 45 +-
ui/src/scss/{thirdparty => sp}/colors.scss | 0
ui/src/scss/sp/loading-bar.scss | 49 +
ui/src/scss/sp/main.scss | 26 +-
ui/src/scss/{thirdparty => sp}/shepherd-new.scss | 213 +-
ui/src/scss/{thirdparty => sp}/trafficlight.scss | 0
.../thirdparty/angular-notification-icons.min.scss | 1 -
ui/src/scss/thirdparty/angular-ui-tree.min.scss | 1 -
.../scss/thirdparty/angularjs-datetime-picker.scss | 92 -
ui/src/scss/thirdparty/epoch.min.scss | 1 -
ui/src/scss/thirdparty/indigo-pink.css | 1 -
ui/src/scss/thirdparty/jsplumb.scss | 417 -
ui/src/scss/thirdparty/loading-bar.min.scss | 111 -
.../scss/thirdparty/malhar-angular-dashboard.scss | 115 -
ui/src/scss/thirdparty/mlhr-table.scss | 192 -
ui/src/scss/thirdparty/ng-prettyjson.min.scss | 7 -
ui/src/scss/thirdparty/please-wait.scss | 179 -
ui/src/scss/thirdparty/prism.scss | 229 -
ui/src/scss/thirdparty/shepherd-theme-arrows.scss | 162 -
ui/src/scss/thirdparty/shepherd-theme-default.scss | 272 -
ui/src/scss/thirdparty/signin.scss | 54 -
ui/src/scss/thirdparty/spinkit.scss | 788 --
ui/src/scss/thirdparty/toastr.scss | 198 -
594 files changed, 2467 insertions(+), 34402 deletions(-)
diff --cc streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataExplorerWidgetModel.java
index e65708d,0000000..51881de
mode 100644,000000..100644
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataExplorerWidgetModel.java
+++ b/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataExplorerWidgetModel.java
@@@ -1,73 -1,0 +1,74 @@@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ *
+ */
+
+package org.apache.streampipes.model.datalake;
+
++import io.fogsy.empire.annotations.RdfProperty;
++import io.fogsy.empire.annotations.RdfsClass;
+import org.apache.streampipes.model.dashboard.DashboardEntity;
+import org.apache.streampipes.vocabulary.StreamPipes;
- import org.streampipes.empire.annotations.RdfProperty;
- import org.streampipes.empire.annotations.RdfsClass;
+
+import javax.persistence.CascadeType;
+import javax.persistence.Entity;
+import javax.persistence.FetchType;
+import javax.persistence.OneToOne;
+
+@RdfsClass(StreamPipes.DATA_EXPLORER_WIDGET_MODEL)
+@Entity
+public class DataExplorerWidgetModel extends DashboardEntity {
+
++
+ @RdfProperty(StreamPipes.HAS_DASHBOARD_WIDGET_ID)
+ private String widgetId;
+
+ @RdfProperty(StreamPipes.HAS_MEASUREMENT_NAME)
+ private String measureName;
+
+ @OneToOne(fetch = FetchType.EAGER,
+ cascade = {CascadeType.PERSIST, CascadeType.MERGE})
+ @RdfProperty(StreamPipes.HAS_DATA_LAKE_MEASURE)
+ private DataLakeMeasure dataLakeMeasure;
+
+ public DataExplorerWidgetModel() {
+ super();
+ }
+
+ public String getWidgetId() {
+ return widgetId;
+ }
+
+ public void setWidgetId(String widgetId) {
+ this.widgetId = widgetId;
+ }
+
+ public DataLakeMeasure getDataLakeMeasure() {
+ return dataLakeMeasure;
+ }
+
+ public void setDataLakeMeasure(DataLakeMeasure dataLakeMeasure) {
+ this.dataLakeMeasure = dataLakeMeasure;
+ }
+
+ public String getMeasureName() {
+ return measureName;
+ }
+
+ public void setMeasureName(String measureName) {
+ this.measureName = measureName;
+ }
+}
diff --cc streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java
index 017e45d,8246885..9890fbf
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java
+++ b/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeMeasure.java
@@@ -18,26 -18,11 +18,26 @@@
package org.apache.streampipes.model.datalake;
++import io.fogsy.empire.annotations.RdfProperty;
++import io.fogsy.empire.annotations.RdfsClass;
import org.apache.streampipes.model.schema.EventSchema;
+import org.apache.streampipes.vocabulary.StreamPipes;
- import org.streampipes.empire.annotations.RdfProperty;
- import org.streampipes.empire.annotations.RdfsClass;
+import javax.persistence.CascadeType;
+import javax.persistence.Entity;
+import javax.persistence.FetchType;
+import javax.persistence.OneToOne;
+
+@RdfsClass(StreamPipes.DATA_LAKE_MEASURE)
+@Entity
public class DataLakeMeasure {
+ @RdfProperty(StreamPipes.HAS_MEASUREMENT_NAME)
private String measureName;
+
+ @OneToOne(fetch = FetchType.EAGER,
+ cascade = {CascadeType.PERSIST, CascadeType.MERGE})
+ @RdfProperty(StreamPipes.HAS_EVENT_SCHEMA)
private EventSchema eventSchema;
public DataLakeMeasure() {
diff --cc ui/package.json
index 7eca2e5,5215d7c..8793bd4
--- a/ui/package.json
+++ b/ui/package.json
@@@ -29,7 -29,7 +29,8 @@@
"@angular/platform-browser-dynamic": "9.0.1",
"@angular/router": "9.0.1",
"@angular/upgrade": "9.0.1",
+ "@danielmoncada/angular-datetime-picker": "^9.2.0",
+ "@fortawesome/fontawesome-free": "^5.12.1",
"@ngui/datetime-picker": "0.16.2",
"@stomp/ng2-stompjs": "^7.2.0",
"@swimlane/ngx-charts": "^13.0.2",
@@@ -69,11 -69,14 +70,14 @@@
"calendar-heatmap-graph": "^0.0.14",
"core-js": "^2.5.3",
"dagre": "^0.8.4",
++ "datatables.net": "^1.10.20",
"fast-json-patch": "^2.1.0",
"file-saver": "^1.3.8",
"jquery": "2.1.3",
+ "jquery-ui-dist": "^1.12.1",
"jquery.panzoom": "2.0.5",
- "datatables.net": "^1.10.20",
"jsonld": "0.4.12",
+ "jsplumb": "2.1.3",
"jszip": "^3.2.1",
"konva": "^3.2.4",
"lodash": "3.10.1",
@@@ -87,28 -91,30 +91,30 @@@
"ngmap": "1.18.0",
"ngx-color-picker": "^9.0.0",
"plotly.js": "^1.52.2",
- "prismjs": "^1.16.0",
- "rxjs": "^6.3.3",
- "rxjs-compat": "^6.3.3",
+ "prismjs": "^1.19.0",
+ "rxjs": "^6.5.4",
+ "rxjs-compat": "^6.5.4",
"shepherd.js": "2.4.0",
"slick-carousel": "1.6.0",
- "tslib": "^1.10.0",
+ "systemjs": "^0.21.6",
- "tslib": "^1.10.0",
+ "trix": "0.10.1",
++ "tslib": "^1.11.1",
"zone.js": "~0.10.2"
},
"devDependencies": {
"@angular-builders/custom-webpack": "^8.4.1",
-- "@angular-devkit/build-angular": "~0.900.2",
++ "@angular-devkit/build-angular": "^0.900.4",
"@angular/cli": "9.0.2",
"@angular/compiler-cli": "9.0.1",
"@ngtools/webpack": "9.0.2",
"@types/angular": "^1.6.43",
"@types/jasmine": "~2.8.3",
- "@types/jqueryui": "^1.12.7",
- "@types/node": "^12.11.1",
+ "@types/jqueryui": "^1.12.10",
- "@types/node": "^12.11.1",
++ "@types/node": "^12.12.29",
"@types/rx": "^4.1.1",
"codelyzer": "^5.1.2",
+ "compression-webpack-plugin": "^3.1.0",
"copy-webpack-plugin": "^5.0.2",
- "compression-webpack-plugin": "^3.0.0",
"css-loader": "^0.28.11",
"extract-text-webpack-plugin": "^3.0.2",
"file-loader": "^1.1.6",
diff --cc ui/src/app/dashboard-v2/dialogs/add-widget/add-visualization-dialog.component.ts
index 9156c91,58ec6ad..b0a5361
--- a/ui/src/app/dashboard-v2/dialogs/add-widget/add-visualization-dialog.component.ts
+++ b/ui/src/app/dashboard-v2/dialogs/add-widget/add-visualization-dialog.component.ts
@@@ -138,9 -138,10 +138,10 @@@ export class AddVisualizationDialogComp
} else if (this.page == 'select-widget') {
this.page = 'configure-widget';
} else {
- let configuredWidget: DashboardWidget = new DashboardWidget();
+ const configuredWidget: DashboardWidget = new DashboardWidget();
configuredWidget.dashboardWidgetSettings = this.selectedWidget;
- configuredWidget.dashboardWidgetDataConfig = this.selectedPipeline;
+ configuredWidget.visualizablePipelineId = this.selectedPipeline._id;
+ configuredWidget.visualizablePipelineTopic = this.selectedPipeline.topic;
if (!this.data) {
this.dashboardService.saveWidget(configuredWidget).subscribe(response => {
this.dialogRef.close(response);
diff --cc ui/src/app/data-explorer/explorer-widget/explorer-visualisations/table/table.component.ts
index 62f3e30,9cd40d6..00d4784
--- a/ui/src/app/data-explorer/explorer-widget/explorer-visualisations/table/table.component.ts
+++ b/ui/src/app/data-explorer/explorer-widget/explorer-visualisations/table/table.component.ts
@@@ -16,11 -16,11 +16,11 @@@
*
*/
- import { Component, EventEmitter, Input, Output } from '@angular/core';
-import {Component} from '@angular/core';
-import {MatTableDataSource} from '@angular/material/table';
-import {BaseChartComponent} from '../chart/baseChart.component';
-import {DataResult} from '../../core-model/datalake/DataResult';
-import {GroupedDataResult} from '../../core-model/datalake/GroupedDataResult';
++import { Component } from '@angular/core';
+import { MatTableDataSource } from '@angular/material/table';
+import { DataResult } from '../../../../core-model/datalake/DataResult';
+import { GroupedDataResult } from '../../../../core-model/datalake/GroupedDataResult';
+import { BaseVisualisationComponent } from '../base/baseVisualisation.component';
@Component({
selector: 'sp-table',
diff --cc ui/src/app/data-explorer/explorer-widget/explorer.component.ts
index 99208aa,8320614..741d8eb
--- a/ui/src/app/data-explorer/explorer-widget/explorer.component.ts
+++ b/ui/src/app/data-explorer/explorer-widget/explorer.component.ts
@@@ -16,18 -16,18 +16,18 @@@
*
*/
-import {Component, OnInit} from '@angular/core';
-import {DatalakeRestService} from '../../core-services/datalake/datalake-rest.service';
-import {InfoResult} from '../../core-model/datalake/InfoResult';
-import {Observable} from 'rxjs/Observable';
-import {FormControl} from '@angular/forms';
-import {map, startWith} from 'rxjs/operators';
-import {MatDialog} from '@angular/material/dialog';
-import {MatSnackBar} from '@angular/material/snack-bar';
-import {DataDownloadDialog} from './datadownloadDialog/dataDownload.dialog';
-import {timer} from 'rxjs/internal/observable/timer';
-import {DataResult} from '../../core-model/datalake/DataResult';
-import {GroupedDataResult} from '../../core-model/datalake/GroupedDataResult';
+import { Component, OnInit } from '@angular/core';
- import { FormControl, FormGroup } from '@angular/forms';
++import { FormControl } from '@angular/forms';
+import { MatDialog } from '@angular/material/dialog';
+import { MatSnackBar } from '@angular/material/snack-bar';
+import { timer } from 'rxjs/internal/observable/timer';
+import { Observable } from 'rxjs/Observable';
+import { map, startWith } from 'rxjs/operators';
+import { DataResult } from '../../core-model/datalake/DataResult';
+import { GroupedDataResult } from '../../core-model/datalake/GroupedDataResult';
+import { InfoResult } from '../../core-model/datalake/InfoResult';
+import { DatalakeRestService } from '../../core-services/datalake/datalake-rest.service';
+import { DataDownloadDialog } from './datadownloadDialog/dataDownload.dialog';
@Component({
selector: 'sp-explorer',