You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ri...@apache.org on 2021/08/17 20:53:28 UTC
[incubator-streampipes] branch dev updated (91b7ff6 -> 6961276)
This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 91b7ff6 Merge pull request #48 from yangdh1225/dev
add fe00648 [STREAMPIPES-319] Remove URL from pipeline element descriptions, dynamically resolve pipeline element host via Consul
add c121c68 [STREAMPIPES-319] Refactor environment variable provider
add 52b6f07 Merge branch 'dev' into STREAMPIPES-319
add 8189b40 [STREAMPIPES-319] Refactor config definition
add 6a569a9 [STREAMPIPES-319] Add config extraction feature to onInvocation method
add 0d8ae17 Merge branch 'dev' into STREAMPIPES-319
add 8e6ddcf [STREAMPIPES-319] Add class to provide service tags
add 523925e Merge branch 'dev' into STREAMPIPES-319
add 2f4a23b Merge branch 'dev' into STREAMPIPES-319
add e2f6286 [STREAMPIPES-376] Store pipeline element descriptions in NoSQL storage
add 3aff7b6 [STREAMPIPES-376] Remove Empire annotations from model classes
add 9185535 [STREAMPIPES-376] Clean up StreamPipes vocabulary
add 3821431 [STREAMPIPES-383] Add StreamPipesServiceBase to centralize web server management
add 3eb1933 [STREAMPIPES-319] Add merge feature to ServiceDefinitionBuilder
add f1d3aaa [STREAMPIPES-319] Fetch assets dynamically based on available endpoints
add fec7ff0 [STREAMPIPES-384] Show pipeline element icons in installation view
add 20de08b [STREAMPIPES-385] Remove connect-container module
add 11b0832 [STREAMPIPES-385] Remove obsolete container-embedded module
add 1bb56a2 [STREAMPIPES-386] Use the same declarer for pipeline elements and adapters
add 4b12163 [STREAMPIPES-386] Add base service for extensions
add 492a822 [STREAMPIPES-386] Harmonize extension services
add 045e0b6 [hotfix] Add missing license headers
add b741330 [STREAMPIPES-319] Add tag registration and service deregistration to all services
add adefce4 [STREAMPIPES-319] Improve service discovery for Connect worker and pipelines
add e70dc70 [STREAMPIPES-319] Align pipeline health check with service discovery
add d6a4b78 [STREAMPIPES-319] Improve update of service endpoints
add 0776c30 [STREAMPIPES-319] Use human-readable serviceId, improve Consul connection
add f9dd77f [STREAMPIPES-395] Avoid duplicate definition of frequently used CSS classes
add ec4b362 [STREAMPIPES-395] Extract colors from components to theme
add e668aca [STREAMPIPES-395] Further harmonize colors in UI
add 94288b3 [STREAMPIPES-398] Allow to inject custom theme settings into prebuild script
add b3157b9 [STREAMPIPES-397] Remove obsolete module configs from UI prebuild
add 8ca270e [STREAMPIPES-395] Harmonize colors in UI components
add 46bf66f Start refactoring connect ui code
add 4e49be0 Remove format form component
add 79997ae Move format related code into select format component
add 44f9891 Change select format component
add a5ec617 Fix linting in connect.module
add e0e29f0 Add component for specific and generic adapters
add 9cf8681 Prepare code to create configuration component
add f215e30 Create configuration group
add 14588a6 Refactored configurations for adapters
add 663ba72 Add error and loading message component
add 921bd50 Add header for schema editor
add 3879bb3 WIP refactor start adapter
add 8365737 Create start adapter configuration component
add 0432889 Move buttons into components
add de605f2 Remove stepper variable from sub components
add 49c8f5c WIP refactor connect ui
add 7621adc Add cypress ids for automated end2end tests
add 7db8135 [STREAMPIPES-380] Add ids for cypress tests
add 2d29fd7 Add pipeline element selection dialog
add 3acc0e2 Merge branch 'STREAMPIPES-380' of github.com:apache/incubator-streampipes into STREAMPIPES-380
add 9800515 [STREAMPIPES-380] Change minor settings to ease automated testing
add b14e084 [STREAMPIPES-380] Fix add pipeline element for data sets
add 0b2eccc [STREAMPIPES-380] Add tags to html for automated tests
add 52ec1ee [STREAMPIPES-380] Initial commit with new e2e test framework
add 6d2a9f8 [STREAMPIPES-380] Add apache headers and fix linting issues
add e25ac3d [STREAMPIPES-380] Add cypress test to install system
add 0315e60 [STREAMPIPES-380] Create builder for processer cypress tests
add 1b377db [STREAMPIPES-380] Ensure that event schema contains a timestamp
add 8257e14 [STREAMPIPES-380] Add error message in connect when no timestamp is available
add f2e9be4 [STREAMPIPES-380] Add check to cypress when no timestamp is available in event schema
add 8d85c86 [STREAMPIPES-380] Rename CSS to SCSS in connect
add 855c712 [STREAMPIPES-380] Add cypress test for boolean inverter
add 6024036 Add test description json to define pe tests
add efe45c1 [STREAMPIPES-380] Add output strategy to tests and two new pe test cases
add 71221c1 Add descriptions for automated processor tests
add 3963dc4 Merge branch 'dev' into STREAMPIPES-380
add 9f18f70 [STREAMPIPES-380] Adding support for json data files in automated tests
add b0ce598 [STREAMPIPES-380] Fix signal edge filter test
add 31fc1b4 [STREAMPIPES-380] Add confirmation dialog when adapter is deleted
add 152237e [STREAMPIPES-396] Data Set Adapter does not work with JSON Array
add ea02ac9 Merge branch 'STREAMPIPES-380' into STREAMPIPES-319
add 1db24fb [STREAMPIPES-319] Update pom files of newly created modules
add f91b800 [STREAMPIPES-395] Harmonize colors of pipeline element customization components
add d8d5c35 [STREAMPIPES-395] Harmonize colors in CSS module
add 627dbad [STREAMPIPES-395] Harmonize colors in connect module
add c76d9b8 [hotfix] Avoid that adapter deletion requests are fired twice
add 7b36074 [STREAMPIPES-395] Harmonize css in configuration module
add 951ed47 [STREAMPIPES-319] Refactor configuration management
add 89c8764 [STREAMPIPES-319] Add config extractor to data stream declarer
add 2f0f29d [STREAMPIPES-319] Automatically start existing adapters of service group
add 38a998e [STREAMPIPES-395] Harmonize colors in navigation bars
add 9cc577b [STREAMPIPES-399] Use new Apache StreamPipes logo
add fd2d7e4 [STREAMPIPES-395] Remove obsolete svg icons
add 0495203 [STREAMPIPES-395] Replace logo and modify prebuild script
add 479f2ee [STREAMPIPES-398] Extract string constants to separate class
add 0258c9a [STREAMPIPES-398] Add missing dependency injection
add b179928 [STREAMPIPES-398] Modify logo path in prebuild script
add a3d1389 [STREAMPIPES-349] Add skeleton of the revised REST API
add d4e35f3 [STREAMPIPES-349] Add implementation of endpoint for 'getting all stored measurement series'
add a066b5d [STREAMPIPES-349] Rename method as well as list containing all stored measurement series
add 3e303a8 [STREAMPIPES-349] Add implementation of endpoint for 'removing all stored measurement series'
add 00767ef [STREAMPIPES-349] Add data lake configuration and retention policy defining classes
add b5bc9f8 [STREAMPIPES-349] Add label definition for data lake
add f3ced17 [STREAMPIPES-349] Add query defining classes for changes at the retention policies
add 3c30237 [STREAMPIPES-349] Update definition of configuration endpoints and add implementation
add f7cb766 [STREAMPIPES-349] Add first implementation of methods for getting and setting data lake configuration
add 3c3d74d [STREAMPIPES-349] Add abstract query element class and query parameter class
add de0279a [STREAMPIPES-349] Add query template class (includes database specific templates for various query statements)
add 84f16a6 [STREAMPIPES-349] Add query element 'Select From Statement' and corresponding parameter class
add a79e5eb [STREAMPIPES-349] Add query element 'Time Boundary' and corresponding parameter class
add 303b6e6 [STREAMPIPES-349] Add query element 'Ordering By Time' and corresponding parameter class
add 0268537 [STREAMPIPES-349] Add query element 'Grouping By Tags' and corresponding parameter class
add 12ed200 [STREAMPIPES-349] Add query element 'Grouping By Time' and corresponding parameter class
add 32e6b79 [STREAMPIPES-349] Add query element 'Item Limitation' and corresponding parameter class
add 756e42b [STREAMPIPES-349] Add query element 'Offset' and corresponding parameter class
add 5c0d435 [STREAMPIPES-349] Add query element 'Delete From Statement' and corresponding parameter class
add 6091bce [STREAMPIPES-349] Add Query Builder class
add b130424 [STREAMPIPES-349] Add Data Explorer Query class
add 9026b67 [STREAMPIPES-349] Add implementation of endpoint for removing data from a single measurement series
add 92cf0bf [STREAMPIPES-349] Add implementation of endpoint for getting data from data lake
add 2e87543 [STREAMPIPES-349] Add endpoint definition for downloading data from data lake (as csv- or json-file)
add cf1ea0b [STREAMPIPES-349] Add implementation of endpoint for downloading data from data lake
add fcf79b3 [STREAMPIPES-349] Add endpoint definition for dropping entire measurement series from data lake and removing related event property
add 0fbaef5 [STREAMPIPES-349] Add implementation of endpoint for removing entire measurement series and related event property
add da1e9c8 [STREAMPIPES-349] Add DataLakeResourceV4 to StreamPipesResourceConfig
add 89a48d3 [STREAMPIPES-349] Add DataLakeResourceV4 to openapi.yaml
add 4af58fc [STREAMPIPES-349] Refactoring of Query Params Extraction: enhanced decoupling of data lake management class and database-specific statements
add ef5be85 [STREAMPIPES-349] Refactor data retrieval and download endpoint to support selection of specified columns
add 9f18861 Merge branch 'dev' into STREAMPIPES-349
add ddb7ba4 Remove old code
add d901119 Merge branch 'STREAMPIPES-349' into STREAMPIPES-319
add a8143fe [STREAMPIPES-319] Refactor data set invocation to support service discovery
add 74fb762 [STREAMPIPES-395] Harmonize colors in data explorer module
add 65e4fff [STREAMPIPES-395] Improve layout of data explorer module
add 1d042b3 [STREAMPIPES-395] Decrease toolbar height
add 47ca256 [STREAMPIPES-395] Move version info to bottom of iconbar
add ebf0fa6 [STREAMPIPES-395] Harmonize css of info module
add 1a15e48 [STREAMPIPES-395] Add user-level configuration option to select color scheme
add 2410895 [STREAMPIPES-395] Modify layout of toolbar
add eb7c177 [STREAMPIPES-319] Change auto-generated element id of generic adapters
add 2af797b Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add 954bc1c Fix adapter set tests
add 0b055ad [STREAMPIPES-319] Refactor custom output strategy to support service discovery
add f005cd9 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add f4a1278 Mfogsyio/erge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add f7724bb [STREAMPIPES-319] Fix bug in pipeline element recommendation
add 055b4a7 [STREAMPIPES-395] Wait for version info to be loaded
add 238f9e2 [hotfix] Remove logging output
add 81dcb71 Add parameter and method for new REST API in ui client code
add e4edeb6 [STREAMPIPES-319] Started to refactor client for datalake REST API
add 914a1ca [STREAMPIPES-395] Change color in pipeline deletion dialog
add a9b9108 [hotfix] Add missing license headers
add c2d37b1 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add c478686 [hotfix] Exclude csv files from rat check
add e352135 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add 966ebcf [STREAMPIPES-319] Remove unused services from data explorer
add 79d7083 [STREAMPIPES-395] Use correct accent color in light mode
add 088682e [STREAMPIPES-402] Add sidebar to manage data explorer widget config
add e007ee5 [STREAMPIPES-319] Add skeleton of DatalakeRestService class
add 531ab7f [STREAMPIPES-319] Add base url and datalake url definitions to DatalakeRestService class
add 8c39daa [STREAMPIPES-319] Fix type declaration
add 635d12e [STREAMPIPES-319] Add basic functionalities to Datalake REST Service
add 3695f41 [STREAMPIPES-402] Add new panel to configure data explorer widgets
add 174bdcc [STREAMPIPES-402] Store measurement info in widget config
add b1c387d [STREAMPIPES-402] Remove unused widget config builder
add 3a903bd [STREAMPIPES-402] Remove unsused widget config classes
add af51f55 [STREAMPIPES-402] Move table widget config to config panel
add 5ac4ae0 [hotfix] Bump Gson version
add 31837fa [STREAMPIPES-402] Refactor widget configs
add 2c4a16f [STREAMPIPES-402] Move line chart config to widget panel
add e5ba500 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add e9ccefc [STREAMPIPES-319] Remove unused component
add 7047da6 [STREAMPIPES-401] Persist time settings in data explorer
add 9c1003e Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add a05dde4 [STREAMPIPES-402] Harmonize dashboard model of data explorer and dashboard
add 262bbd9 [STREAMPIPES-401] Use default time range in time selector
add 8ba6809 [hotfix] Harmonize options bar layout of data explorer component
add dffe6fa [hotfix] Remove beta badge from data explorer
add 8e836d6 [STREAMPIPES-402] Improve widget management in data explorer
add cc11279 [STREAMPIPES-402] Properly reload widgets when different dashboards are selected
add 0436983 [STREAMPIPES-395] Use custom colors in data explorer widgets
add a81054e [STREAMPIPES-402] Fix wrong sizing of widgets
add c1d9e4f [STREAMPIPES-404] Refactor pipeline managent endpoint
add ea2f6ef Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add d2041a5 [STREAMPIPES-404] Add REST endpoint to reset StreamPipes instance
add 4b1dab4 [STREAMPIPES-404] Add functionality to reset streampipes before each e2e test
add 6354270 [STREAMPIPES-404] Update all tests to reset system in before
add c1e3b9c Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add c16e680 [STREAMPIPES-402] Refactor line chart config, bump plotly version
add 165743e [STREAMPIPES-402] Refactor data view dialog to use global dialog template
add da8c421 [STREAMPIPES-404] Prepare cypress tests to use the cypress dashboard
add 656b3a7 [STREAMPIPES-404] Clean pipeline assembly on reset
add 6a11f10 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add 0ca5207 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add 39a957b [STREAMPIPES-402] Properly resize grid in edit mode
add 8bce471 [STREAMPIPES-402] Extend widget designer panel to support creation of new widgets
add c5d22ff [STREAMPIPES-402] Remove obsolete AddWidget dialog in data explorer
add 7f4376e [STREAMPIPES-319] Add wait to the installation cypress test
add 9ec7eb7 MFix cypress tests erge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add 01d7224 Merge branch 'STREAMPIPES-319' of github.com:apache/incubator-streampipes into STREAMPIPES-319
add 8f206f8 [STREAMPIPES-402] Remove widget dialog import
add ba1e42f [STREAMPIPES-319] Fix tests
add 75cc0ae [hotfix] Add missing license header
add ebe9cff [STREAMPIPES-319] Update tess for worker rest client
add 96f9339 Merge branch 'dev' into STREAMPIPES-319
add 6961276 [hotfix] Resolve merge conflict in pipeline executor
No new revisions were added by this update.
Summary of changes:
pom.xml | 33 +-
streampipes-backend/pom.xml | 8 +-
.../backend/StreamPipesBackendApplication.java | 39 ++-
.../backend/StreamPipesResourceConfig.java | 162 ++++-----
.../src/main/resources/openapi.yaml | 1 +
streampipes-backend/src/main/resources/shiro.ini | 2 +-
.../streampipes/commons/constants/CustomEnvs.java | 37 +++
.../apache/streampipes/commons/constants/Envs.java | 48 +++
.../constants/GlobalStreamPipesConstants.java | 2 +
.../commons/constants/InstanceIdExtractor.java | 27 ++
.../NoServiceEndpointsAvailableException.java | 25 ++
.../streampipes/commons/networking/Networking.java | 42 +++
streampipes-config/pom.xml | 24 +-
.../org/apache/streampipes/config/SpConfig.java | 81 -----
.../streampipes/config/SpConfigChangeCallback.java | 24 --
.../streampipes/config/backend/BackendConfig.java | 9 +-
.../config/backend/MessagingSettings.java | 8 +-
.../streampipes/config/consul/ConsulSpConfig.java | 310 -----------------
.../streampipes/config/consul/MockSpConfig.java | 125 -------
.../streampipes/config/model/ConfigItem.java | 81 -----
.../config/model/ConfigurationScope.java | 24 --
.../apache/streampipes/config/model/PeConfig.java | 62 ----
streampipes-connect-api/pom.xml | 44 +++
.../apache/streampipes/connect/api/Connector.java | 25 ++
.../streampipes/connect/api/EmitBinaryEvent.java | 23 ++
.../apache/streampipes/connect/api/IAdapter.java | 42 +++
.../streampipes/connect/api/IAdapterPipeline.java | 34 ++
.../connect/api/IAdapterPipelineElement.java | 27 ++
.../apache/streampipes/connect/api/IFormat.java | 49 +++
.../apache/streampipes/connect/api/IParser.java | 42 +++
.../apache/streampipes/connect/api/IProtocol.java | 51 +++
.../connect/api/exception/AdapterException.java | 32 ++
.../connect/api/exception/ParseException.java | 28 ++
.../api/exception/WorkerAdapterException.java | 40 +++
streampipes-connect-container-master/pom.xml | 2 +-
.../container/master/general/ResetManagement.java | 85 +++++
.../master/management/AdapterMasterManagement.java | 54 ++-
.../AdapterTemplateMasterManagement.java | 2 +-
.../master/management/DescriptionManagement.java | 31 +-
.../master/management/GuessManagement.java | 27 +-
.../master/management/SourcesManagement.java | 26 +-
.../master/management/UnitMasterManagement.java | 2 +-
.../connect/container/master/management/Utils.java | 58 ----
.../management/WorkerAdministrationManagement.java | 34 +-
.../master/management/WorkerRestClient.java | 79 ++---
.../master/management/WorkerUrlProvider.java | 98 ++++++
.../master/rest/AbstractAdapterResource.java | 4 +-
.../container/master/rest/AdapterResource.java | 34 +-
.../master/rest/AdapterTemplateResource.java | 2 +-
.../container/master/rest/DescriptionResource.java | 43 +--
.../container/master/rest/GuessResource.java | 10 +-
.../master/rest/RuntimeResolvableResource.java | 18 +-
.../container/master/rest/SourcesResource.java | 16 +-
.../container/master/rest/UnitResource.java | 2 +-
.../container/master/rest/WelcomePageMaster.java | 2 +-
.../master/rest/WorkerAdministrationResource.java | 6 +-
.../connect/container/master/util/Utils.java | 29 ++
.../connect/container/master/util/WorkerPaths.java | 68 ++++
.../management/AdapterMasterManagementTest.java | 2 +-
.../AdapterTemplateMasterManagementTest.java | 2 +-
.../management/DescriptionManagementTest.java | 6 +-
.../master/management/SourcesManagementTest.java | 5 +-
.../management/UnitMasterManagementTest.java | 4 +-
.../master/management/WorkerRestClientTest.java | 24 +-
streampipes-connect-container-worker/pom.xml | 45 ++-
.../init/AdapterServiceResourceProvider.java | 40 +++
.../worker/init/AdapterWorkerContainer.java | 98 ++----
.../init/AdapterWorkerContainerResourceConfig.java | 28 +-
.../init/ConnectWorkerDescriptionProvider.java | 68 ++++
.../init/ConnectWorkerRegistrationService.java | 65 ++++
.../worker/init/ConnectWorkerTagProvider.java | 43 +++
.../worker/management/AdapterWorkerManagement.java | 58 ++--
.../worker/management/GuessManagement.java | 14 +-
.../worker/management/MasterRestClient.java | 1 +
.../worker/management/RuntimeResovable.java | 58 ++++
.../container/worker/rest/AdapterResource.java | 13 +-
.../container/worker/rest/GuessResource.java | 18 +-
.../worker/rest/HttpServerAdapterResource.java | 2 +-
.../container/worker/rest/ProtocolResource.java | 13 +-
.../worker/rest/RuntimeResolvableResource.java | 8 +-
.../container/worker/rest/WelcomePageWorker.java | 20 +-
.../container/worker/rest/WorkerResource.java | 8 +-
.../container/worker/utils/AdapterUtils.java | 92 ++++++
.../management/AdapterWorkerManagementTest.java | 4 +-
.../connect/container/worker/management/Mock.java | 26 ++
.../container/worker/utils/AdapterUtilsTest.java | 60 ++++
streampipes-connect-container/development/env | 20 --
streampipes-connect-container/pom.xml | 82 -----
.../streampipes/connect/config/ConfigKeys.java | 33 --
.../connect/config/ConnectContainerConfig.java | 73 ----
.../connect/init/AdapterContainerConfig.java | 33 --
.../connect/init/AdapterDeclarerSingleton.java | 97 ------
.../connect/management/AdapterUtils.java | 90 -----
.../connect/management/RuntimeResovable.java | 59 ----
.../connect/rest/AbstractContainerResource.java | 62 ----
.../streampipes/connect/rest/SpConnectUtils.java | 23 --
.../src/test/SpConnectResourceTest.java | 146 --------
.../src/test/SpConnectTest.java | 188 -----------
.../test/java/org/streampipes/connect/Mock.java | 26 --
.../management/AdapterDeserializerTest.java | 195 -----------
.../connect/management/AdapterUtilsTest.java | 61 ----
.../connect/utils/TestAdapterSerializer.java | 73 ----
streampipes-connect/pom.xml | 4 +-
.../streampipes/connect/EmitBinaryEvent.java | 23 --
.../org/apache/streampipes/connect/GetNEvents.java | 8 +-
.../connect/RunningAdapterInstances.java | 10 +-
.../apache/streampipes/connect/SendToPipeline.java | 13 +-
.../streampipes/connect/adapter/Adapter.java | 42 +--
.../connect/adapter/AdapterRegistry.java | 12 +-
.../adapter/exception/AdapterException.java | 32 --
.../connect/adapter/exception/ParseException.java | 28 --
.../adapter/exception/WorkerAdapterException.java | 40 ---
.../connect/adapter/format/csv/CsvFormat.java | 8 +-
.../connect/adapter/format/csv/CsvParser.java | 6 +-
.../adapter/format/geojson/GeoJsonFormat.java | 8 +-
.../adapter/format/geojson/GeoJsonParser.java | 4 +-
.../connect/adapter/format/image/ImageFormat.java | 8 +-
.../connect/adapter/format/image/ImageParser.java | 8 +-
.../adapter/format/json/AbstractJsonFormat.java | 6 +-
.../adapter/format/json/arraykey/JsonFormat.java | 4 +-
.../adapter/format/json/arraykey/JsonParser.java | 6 +-
.../format/json/arraynokey/JsonArrayFormat.java | 4 +-
.../format/json/arraynokey/JsonArrayParser.java | 6 +-
.../format/json/object/JsonObjectFormat.java | 4 +-
.../format/json/object/JsonObjectParser.java | 6 +-
.../connect/adapter/format/xml/XmlFormat.java | 8 +-
.../connect/adapter/format/xml/XmlParser.java | 4 +-
.../connect/adapter/model/Connector.java | 21 --
.../connect/adapter/model/generic/Format.java | 49 ---
.../adapter/model/generic/GenericAdapter.java | 37 ++-
.../model/generic/GenericDataSetAdapter.java | 9 +-
.../model/generic/GenericDataStreamAdapter.java | 3 +-
.../connect/adapter/model/generic/Parser.java | 19 +-
.../connect/adapter/model/generic/Protocol.java | 37 +--
.../adapter/model/pipeline/AdapterPipeline.java | 28 +-
.../model/pipeline/AdapterPipelineElement.java | 27 --
.../elements/AddTimestampPipelineElement.java | 4 +-
.../elements/AddValuePipelineElement.java | 4 +-
.../elements/DuplicateFilterPipelineElement.java | 4 +-
.../elements/SendToBrokerAdapterSink.java | 5 +-
.../elements/SendToBrokerReplayAdapterSink.java | 4 +-
.../elements/SendToJmsAdapterSink.java | 4 +-
.../elements/SendToKafkaAdapterSink.java | 4 +-
.../elements/SendToMqttAdapterSink.java | 4 +-
.../TransformSchemaAdapterPipelineElement.java | 4 +-
.../elements/TransformStreamAdapterElement.java | 4 +-
.../TransformValueAdapterPipelineElement.java | 4 +-
.../stream/EventRateTransformationRule.java | 5 -
.../connect/adapter/GroundingServiceTest.java | 23 +-
.../format/json/arraykey/JsonParserTest.java | 4 +-
.../json/arraynokey/JsonArrayParserTest.java | 4 +-
.../adapter/format/json/geojson/GeoJsonTest.java | 2 +-
.../format/json/object/JsonObjectParserTest.java | 4 +-
.../connect/adapter/format/json/xml/XmlTest.java | 2 +-
streampipes-container-base/pom.xml | 32 +-
.../container/base/StreamPipesServiceBase.java | 89 +++++
.../container/base/rest/BaseResourceConfig.java | 33 ++
streampipes-container-embedded/pom.xml | 45 ---
.../embedded/init/ContainerModelSubmitter.java | 55 ---
.../src/main/webapp/WEB-INF/web.xml | 35 --
streampipes-container-extensions/pom.xml | 21 +-
.../extensions/ExtensionsModelSubmitter.java | 141 ++------
.../extensions/ExtensionsResourceConfig.java | 39 +--
streampipes-container-standalone/pom.xml | 4 +-
.../PipelineElementContainerResourceConfig.java | 25 +-
.../PipelineElementServiceShutdownHandler.java | 42 +++
.../init/PipelineElementServiceTagProvider.java | 38 +++
.../standalone/init/StandaloneModelSubmitter.java | 59 ++--
streampipes-container/pom.xml | 21 +-
.../api/AbstractPipelineElementResource.java | 63 ++--
.../api/DataProcessorPipelineElementResource.java | 7 +-
.../api/DataSinkPipelineElementResource.java | 8 +-
.../api/DataStreamPipelineElementResource.java | 3 +-
.../api/InvocablePipelineElementResource.java | 9 +-
.../streampipes/container/api/WelcomePage.java | 19 +-
.../container/config/ConfigExtractor.java | 38 +++
.../container/declarer/InvocableDeclarer.java | 7 +-
.../streampipes/container/html/HTMLGenerator.java | 8 +-
.../streampipes/container/html/JSONGenerator.java | 7 +-
.../container/html/model/AgentDescription.java | 36 --
.../html/model/DataSourceDescriptionHtml.java | 5 +-
.../container/html/model/Description.java | 51 ++-
.../html/page/EventConsumerWelcomePage.java | 49 ---
.../html/page/EventProcessingAgentWelcomePage.java | 49 ---
.../html/page/EventProducerWelcomePage.java | 63 ----
.../container/html/page/WelcomePageGenerator.java | 86 ++++-
.../html/page/WelcomePageGeneratorImpl.java | 105 ------
.../BaseExtensionsServiceResourceProvider.java | 31 ++
.../container/init/DeclarersSingleton.java | 134 +++++++-
.../container/init/ExtensionsResourceProvider.java | 26 ++
.../streampipes/container/init/ModelSubmitter.java | 25 --
.../PipelineElementServiceResourceProvider.java | 35 ++
.../container/model/SpServiceDefinition.java | 174 ++++++++++
.../model/SpServiceDefinitionBuilder.java | 143 ++++++++
.../consul/ConsulServiceRegistrationBody.java | 90 -----
.../model/consul/HealthCheckConfiguration.java | 57 ----
.../streampipes/container/util/ConsulUtil.java | 330 ------------------
.../container/util/ServiceDefinitionUtil.java | 68 ++++
streampipes-data-explorer/pom.xml | 4 +
.../dataexplorer/DataLakeManagementV4.java | 294 +++++++++++++++++
.../param/RetentionPolicyQueryParams.java | 38 +++
.../query/EditRetentionPolicyQuery.java | 74 +++++
.../query/ShowRetentionPolicyQuery.java | 56 ++++
.../v4/params/DeleteFromStatementParams.java | 31 ++
.../dataexplorer/v4/params/FillParams.java | 34 ++
.../v4/params/GroupingByTagsParams.java | 42 +++
.../v4/params/GroupingByTimeParams.java | 36 ++
.../v4/params/ItemLimitationParams.java | 37 +++
.../dataexplorer/v4/params/OffsetParams.java | 37 +++
.../v4/params/OrderingByTimeParams.java | 36 ++
.../dataexplorer/v4/params/QueryParamsV4.java | 36 ++
.../v4/params/SelectFromStatementParams.java | 57 ++++
.../dataexplorer/v4/params/TimeBoundaryParams.java | 43 +++
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 137 ++++++++
.../dataexplorer/v4/query/QueryBuilder.java | 54 +++
.../v4/query/elements/DeleteFromStatement.java | 33 ++
.../v4/query/elements/FillStatement.java | 32 ++
.../v4/query/elements/GroupingByTags.java | 43 +++
.../v4/query/elements/GroupingByTime.java | 34 ++
.../v4/query/elements/ItemLimitation.java | 34 ++
.../dataexplorer/v4/query/elements/Offset.java | 34 ++
.../v4/query/elements/OrderingByTime.java | 34 ++
.../v4/query/elements/QueryElement.java | 33 ++
.../v4/query/elements/SelectFromStatement.java | 37 +++
.../v4/query/elements/TimeBoundary.java | 40 +++
.../dataexplorer/v4/template/QueryTemplatesV4.java | 79 +++++
.../v4/utils/DataLakeManagementUtils.java | 103 ++++++
streampipes-measurement-units/pom.xml | 8 +-
.../client/endpoint/ExtensionsServiceEndpoint.java | 61 ++++
.../endpoint/ExtensionsServiceEndpointItem.java | 143 ++++++++
.../model/client/endpoint/RdfEndpoint.java | 61 ----
.../model/client/endpoint/RdfEndpointItem.java | 103 ------
.../apache/streampipes/model/client/user/User.java | 9 +
streampipes-model/pom.xml | 12 -
.../apache/streampipes/model/ApplicationLink.java | 13 -
.../apache/streampipes/model/ErrorMessageLd.java | 6 -
.../org/apache/streampipes/model/MessageLd.java | 21 +-
.../apache/streampipes/model/NotificationLd.java | 15 -
.../org/apache/streampipes/model/SpDataSet.java | 23 +-
.../org/apache/streampipes/model/SpDataStream.java | 23 --
.../streampipes/model/SpDataStreamContainer.java | 14 -
.../model/base/AbstractStreamPipesEntity.java | 34 +-
.../model/base/ConsumableStreamPipesEntity.java | 15 -
.../model/base/InvocableStreamPipesEntity.java | 36 +-
.../model/base/NamedStreamPipesEntity.java | 38 +--
.../apache/streampipes/model/base/Namespaces.java | 8 +-
.../model/base/StreamPipesJsonLdContainer.java | 59 ----
.../model/base/UnnamedStreamPipesEntity.java | 4 +-
.../model/connect/adapter/AdapterDescription.java | 75 ++---
.../connect/adapter/AdapterDescriptionList.java | 14 +-
.../connect/adapter/AdapterSetDescription.java | 10 -
.../connect/adapter/AdapterStreamDescription.java | 10 -
.../adapter/GenericAdapterSetDescription.java | 15 +-
.../adapter/GenericAdapterStreamDescription.java | 14 +-
.../adapter/SpecificAdapterSetDescription.java | 7 -
.../adapter/SpecificAdapterStreamDescription.java | 7 -
.../model/connect/grounding/FormatDescription.java | 13 -
.../connect/grounding/FormatDescriptionList.java | 14 -
.../connect/grounding/ProtocolDescription.java | 18 -
.../connect/grounding/ProtocolDescriptionList.java | 15 -
.../connect/grounding/ProtocolSetDescription.java | 6 -
.../grounding/ProtocolStreamDescription.java | 6 -
.../connect/guess/DomainPropertyProbability.java | 11 -
.../guess/DomainPropertyProbabilityList.java | 14 -
.../model/connect/guess/GuessSchema.java | 15 -
.../rules/TransformationRuleDescription.java | 8 -
.../rules/schema/CreateNestedRuleDescription.java | 12 +-
.../rules/schema/DeleteRuleDescription.java | 12 +-
.../connect/rules/schema/MoveRuleDescription.java | 12 -
.../rules/schema/RenameRuleDescription.java | 12 -
.../SchemaTransformationRuleDescription.java | 1 -
.../EventRateTransformationRuleDescription.java | 12 -
...oveDuplicatesTransformationRuleDescription.java | 12 -
.../rules/value/AddTimestampRuleDescription.java | 11 -
.../AddValueTransformationRuleDescription.java | 12 -
...rrectionValueTransformationRuleDescription.java | 13 -
.../TimestampTranfsformationRuleDescription.java | 14 -
.../rules/value/UnitTransformRuleDescription.java | 13 -
.../connect/worker/ConnectWorkerContainer.java | 54 ++-
.../model/dashboard/DashboardEntity.java | 14 +-
.../model/dashboard/DashboardModel.java | 31 +-
.../model/dashboard/DashboardWidgetSettings.java | 16 -
.../model/datalake/CustomMapSerializer.java | 42 +++
.../model/datalake/DataExplorerWidgetModel.java | 86 +++--
.../model/datalake/DataLakeConfiguration.java | 78 +++++
.../model/datalake/DataLakeMeasure.java | 35 +-
.../model/datalake/DataLakeRetentionPolicy.java | 80 +++++
.../model/datalake/LabelDefinition.java | 46 +++
.../model/datalake/PersistedDataStream.java | 71 ++++
.../model/graph/DataProcessorDescription.java | 15 -
.../model/graph/DataProcessorInvocation.java | 19 +-
.../model/graph/DataSinkDescription.java | 14 +-
.../model/graph/DataSinkInvocation.java | 16 +-
.../model/graph/DataSourceDescription.java | 14 +-
.../model/graph/PipelineElementContainer.java | 12 -
.../model/grounding/EventGrounding.java | 16 +-
.../model/grounding/JmsTransportProtocol.java | 11 +-
.../model/grounding/KafkaTransportProtocol.java | 18 -
.../model/grounding/MqttTransportProtocol.java | 9 -
.../model/grounding/SimpleTopicDefinition.java | 7 -
.../model/grounding/TopicDefinition.java | 10 -
.../model/grounding/TransportFormat.java | 16 +-
.../model/grounding/TransportProtocol.java | 11 -
.../model/grounding/WildcardTopicDefinition.java | 14 -
.../model/grounding/WildcardTopicMapping.java | 10 -
.../apache/streampipes/model/labeling/Label.java | 1 -
.../monitoring/ElementStatusInfoSettings.java | 12 -
.../model/output/AppendOutputStrategy.java | 13 -
.../model/output/CustomOutputStrategy.java | 17 +-
.../output/CustomTransformOutputStrategy.java | 13 -
.../model/output/FixedOutputStrategy.java | 15 +-
.../model/output/KeepOutputStrategy.java | 10 -
.../model/output/ListOutputStrategy.java | 9 -
.../streampipes/model/output/OutputStrategy.java | 11 -
.../model/output/PropertyRenameRule.java | 9 -
.../model/output/TransformOperation.java | 11 -
.../model/output/TransformOutputStrategy.java | 13 -
.../model/output/UserDefinedOutputStrategy.java | 12 -
.../model/pipeline/ElementComposition.java | 5 -
.../streampipes/model/pipeline/Pipeline.java | 6 -
.../apache/streampipes/model/quality/Accuracy.java | 12 +-
.../quality/EventPropertyQualityDefinition.java | 8 -
.../quality/EventPropertyQualityRequirement.java | 14 -
.../quality/EventStreamQualityDefinition.java | 10 +-
.../quality/EventStreamQualityRequirement.java | 15 -
.../streampipes/model/quality/Frequency.java | 10 -
.../apache/streampipes/model/quality/Latency.java | 12 +-
.../model/quality/MeasurementCapability.java | 10 +-
.../model/quality/MeasurementObject.java | 10 +-
.../model/quality/MeasurementProperty.java | 6 -
.../model/quality/MeasurementRange.java | 11 -
.../streampipes/model/quality/Precision.java | 12 +-
.../streampipes/model/quality/Resolution.java | 12 +-
.../model/runtime/RuntimeOptionsRequest.java | 17 -
.../model/runtime/RuntimeOptionsResponse.java | 12 -
.../streampipes/model/schema/Enumeration.java | 25 +-
.../streampipes/model/schema/EventProperty.java | 25 --
.../model/schema/EventPropertyList.java | 12 -
.../model/schema/EventPropertyNested.java | 15 +-
.../model/schema/EventPropertyPrimitive.java | 14 -
.../streampipes/model/schema/EventSchema.java | 15 -
.../model/schema/QuantitativeValue.java | 13 +-
.../model/schema/ValueSpecification.java | 8 -
.../model/staticproperty/AnyStaticProperty.java | 7 -
.../staticproperty/CodeInputStaticProperty.java | 11 -
.../staticproperty/CollectionStaticProperty.java | 18 -
.../staticproperty/ColorPickerStaticProperty.java | 9 -
.../model/staticproperty/DomainStaticProperty.java | 13 -
.../model/staticproperty/FileStaticProperty.java | 10 -
.../staticproperty/FreeTextStaticProperty.java | 22 --
.../model/staticproperty/MappingProperty.java | 14 -
.../model/staticproperty/MappingPropertyNary.java | 13 -
.../model/staticproperty/MappingPropertyUnary.java | 9 -
.../staticproperty/MatchingStaticProperty.java | 12 +-
.../model/staticproperty/OneOfStaticProperty.java | 6 -
.../streampipes/model/staticproperty/Option.java | 12 +-
.../staticproperty/PropertyValueSpecification.java | 16 +-
.../staticproperty/RemoteOneOfStaticProperty.java | 16 -
.../RuntimeResolvableAnyStaticProperty.java | 13 -
.../RuntimeResolvableOneOfStaticProperty.java | 13 -
.../model/staticproperty/SecretStaticProperty.java | 10 -
.../staticproperty/SelectionStaticProperty.java | 11 -
.../model/staticproperty/StaticProperty.java | 17 -
.../staticproperty/StaticPropertyAlternative.java | 16 -
.../staticproperty/StaticPropertyAlternatives.java | 14 -
.../model/staticproperty/StaticPropertyGroup.java | 15 -
.../model/staticproperty/SupportedProperty.java | 11 -
.../model/template/BoundPipelineElement.java | 13 -
.../template/PipelineTemplateDescription.java | 12 -
.../PipelineTemplateDescriptionContainer.java | 12 -
.../model/template/PipelineTemplateInvocation.java | 12 -
.../streampipes/model/util/ElementIdGenerator.java | 44 +++
.../streampipes/model/util/RdfIdGenerator.java | 32 --
streampipes-pipeline-management/pom.xml | 23 +-
.../streampipes/manager/assets/AssetFetcher.java | 16 +-
.../streampipes/manager/assets/AssetManager.java | 7 +-
.../manager/endpoint/EndpointFetcher.java | 24 +-
.../manager/endpoint/EndpointItemFetcher.java | 20 +-
.../ExtensionsServiceEndpointGenerator.java | 71 ++++
.../endpoint/ExtensionsServiceEndpointUtils.java | 34 ++
.../manager/execution/http/GraphSubmitter.java | 37 ++-
.../manager/execution/http/HttpRequestBuilder.java | 20 +-
.../manager/execution/http/PipelineExecutor.java | 104 +++++-
.../streampipes/manager/file/FileManager.java | 20 ++
.../manager/health/PipelineHealthCheck.java | 31 +-
.../manager/matching/InvocationGraphBuilder.java | 4 +-
.../CustomTransformOutputSchemaGenerator.java | 5 +-
.../streampipes/manager/operations/Operations.java | 6 +-
.../manager/pipeline/PipelineCacheManager.java | 39 +++
.../PipelineCanvasMetadataCacheManager.java | 39 +++
.../manager/pipeline/PipelineManager.java | 108 ++++++
.../runtime/PipelineElementRuntimeInfoFetcher.java | 12 +-
.../setup/CacheInitializationInstallationStep.java | 45 ---
.../manager/setup/CouchDbInstallationStep.java | 10 +-
.../setup/EmpireInitializerInstallationStep.java | 39 ---
.../manager/setup/InstallationConfiguration.java | 7 +-
.../setup/PipelineElementInstallationStep.java | 12 +-
.../manager/template/PipelineGenerator.java | 11 +-
.../template/PipelineTemplateGenerator.java | 11 +-
.../verification/DataProcessorVerifier.java | 8 +-
.../manager/verification/DataSinkVerifier.java | 8 +-
.../manager/verification/DataStreamVerifier.java | 8 +-
.../manager/verification/ElementVerifier.java | 15 +-
.../verification/extractor/StatementBuilder.java | 52 ---
.../verification/structure/GeneralVerifier.java | 9 +-
.../manager/pipeline/TestPipelineExecution.java | 33 --
.../manager/pipeline/TestPipelineManager.java | 148 +++++++++
.../manager/pipeline/TestPipelineStorage.java | 42 ---
.../manager/template/TestTemplateGenerator.java | 28 --
.../apache/streampipes/ps/DataLakeResourceV4.java | 219 ++++++++++++
.../shared/impl/AbstractSharedRestInterface.java | 12 +-
streampipes-rest/pom.xml | 7 +-
.../streampipes/rest/api/IPipelineElement.java | 2 -
.../rest/impl/AbstractRestResource.java | 43 +--
.../apache/streampipes/rest/impl/ConsulConfig.java | 23 +-
.../apache/streampipes/rest/impl/Deployment.java | 60 +---
.../impl/ExtensionsServiceEndpointResource.java | 184 +++++++++++
.../rest/impl/InternalPipelineTemplates.java | 4 +-
.../streampipes/rest/impl/PipelineCache.java | 20 +-
.../rest/impl/PipelineCanvasMetadataCache.java | 14 +-
.../streampipes/rest/impl/PipelineElementFile.java | 14 +-
.../rest/impl/PipelineElementImport.java | 35 +-
.../streampipes/rest/impl/PipelineResource.java | 40 +--
.../streampipes/rest/impl/PipelineTemplate.java | 25 +-
.../apache/streampipes/rest/impl/RdfEndpoint.java | 161 ---------
.../streampipes/rest/impl/ResetResource.java | 50 +++
.../rest/impl/SemanticEventConsumer.java | 25 +-
.../rest/impl/SemanticEventProcessingAgent.java | 19 +-
.../rest/impl/SemanticEventProducer.java | 20 +-
.../org/apache/streampipes/rest/impl/User.java | 16 +
.../AbstractPipelineExtractionResource.java | 88 +++++
.../rest/impl/dashboard/VisualizablePipeline.java | 124 -------
.../dashboard/VisualizablePipelineResource.java | 82 +++++
.../rest/impl/datalake/DataLakeWidgetResource.java | 2 +-
.../impl/datalake/PersistedDataStreamResource.java | 71 ++++
.../rest/management/PipelineManagement.java | 1 +
.../rest/serializer/JsonLdProvider.java | 81 -----
.../apache/streampipes/rest/util/JsonLdUtils.java | 79 -----
.../streampipes/rest/impl/ConsulConfigTest.java | 77 -----
.../streampipes/rest/util/JsonLdUtilsTest.java | 109 ------
.../builder/AbstractPipelineElementBuilder.java | 3 +-
.../serializers/json/GsonSerializer.java | 2 +
streampipes-serializers-jsonld/pom.xml | 62 ----
.../jsonld/CustomAnnotationProvider.java | 192 -----------
.../serializers/jsonld/JsonLdTransformer.java | 143 --------
.../serializers/jsonld/JsonLdUtils.java | 65 ----
.../serializers/jsonld/RdfTransformer.java | 38 ---
streampipes-service-discovery-api/pom.xml | 33 ++
.../svcdiscovery/api/ISpKvManagement.java | 32 ++
.../svcdiscovery/api/ISpServiceDiscovery.java | 78 +++++
.../streampipes/svcdiscovery/api/SpConfig.java | 64 ++++
.../svcdiscovery/api/model/ConfigItem.java | 119 +++++++
.../svcdiscovery/api/model/ConfigItemUtils.java | 33 ++
.../svcdiscovery/api/model/ConfigurationScope.java | 24 ++
.../api/model/DefaultSpServiceGroups.java | 25 ++
.../api/model/DefaultSpServiceTags.java | 27 ++
.../svcdiscovery/api/model/PeConfig.java | 62 ++++
.../api/model/SpServicePathPrefix.java | 29 ++
.../api/model/SpServiceRegistrationRequest.java | 109 ++++++
.../svcdiscovery/api/model/SpServiceTag.java | 40 +++
.../svcdiscovery/api/model/SpServiceTagPrefix.java | 39 +++
.../api/model/SpServiceUrlProvider.java | 87 +++++
streampipes-service-discovery-consul/pom.xml | 59 ++++
.../svcdiscovery/consul/AbstractConsulService.java | 33 ++
.../consul/ConsulHealthServiceManager.java | 121 +++++++
.../svcdiscovery/consul/ConsulProvider.java | 98 ++++++
.../svcdiscovery/consul/ConsulSpConfig.java | 220 ++++++++++++
.../svcdiscovery/consul/SpConsulKvManagement.java | 96 ++++++
.../consul/SpConsulServiceDiscovery.java | 134 ++++++++
streampipes-service-discovery/pom.xml | 46 +++
.../svcdiscovery/SpServiceDiscovery.java | 41 +++
streampipes-service-extensions-base/pom.xml | 50 +++
.../base/StreamPipesExtensionsServiceBase.java | 94 ++++++
.../sources/AbstractAdapterIncludedStream.java | 7 +-
.../sources/AbstractAlreadyExistingStream.java | 6 +
streampipes-storage-api/pom.xml | 12 +-
.../storage/api/IBackgroundKnowledgeStorage.java | 75 -----
.../storage/api/IDataProcessorStorage.java | 25 ++
.../streampipes/storage/api/IDataSinkStorage.java | 25 ++
.../storage/api/IDataStreamStorage.java | 25 ++
.../api/IExtensionsServiceEndpointStorage.java | 32 ++
.../streampipes/storage/api/INoSqlStorage.java | 4 +-
.../storage/api/IRdfEndpointStorage.java | 32 --
.../streampipes/storage/api/ITripleStorage.java | 30 --
streampipes-storage-couchdb/pom.xml | 4 +-
.../storage/couchdb/CouchDbStorageManager.java | 9 +-
.../storage/couchdb/dao/AbstractDao.java | 2 +-
.../couchdb/impl/DataProcessorStorageImpl.java | 73 ++++
.../storage/couchdb/impl/DataSinkStorageImpl.java | 73 ++++
.../couchdb/impl/DataStreamStorageImpl.java | 72 ++++
.../impl/ExtensionsServiceEndpointStorageImpl.java | 49 +++
.../PipelineElementDescriptionStorageImpl.java | 245 ++++++++++++++
.../couchdb/impl/RdfEndpointStorageImpl.java | 50 ---
.../storage/couchdb/utils/CouchDbConfig.java | 5 +-
.../streampipes/storage/couchdb/utils/Filter.java | 35 ++
.../streampipes/storage/couchdb/utils/Utils.java | 12 +
streampipes-storage-management/pom.xml | 7 +-
.../storage/management/StorageDispatcher.java | 6 -
.../storage/management/StorageManager.java | 8 +-
streampipes-storage-rdf4j/pom.xml | 88 -----
.../streampipes/storage/Rdf4JStorageManager.java | 117 -------
.../storage/rdf4j/config/ConfigKeys.java | 23 --
.../storage/rdf4j/config/Rdf4JConfig.java | 64 ----
.../streampipes/storage/rdf4j/filter/Filter.java | 35 --
.../rdf4j/impl/PipelineElementInMemoryStorage.java | 315 ------------------
.../rdf4j/impl/PipelineElementStorageRequests.java | 294 -----------------
.../storage/rdf4j/sparql/QueryBuilder.java | 58 ----
.../storage/rdf4j/util/Transformer.java | 34 --
streampipes-user-management/pom.xml | 5 +
.../apache/streampipes/vocabulary/StreamPipes.java | 367 ---------------------
.../distributed/runtime/DistributedRuntime.java | 1 -
.../wrapper/flink/FlinkDataProcessorRuntime.java | 3 +-
.../wrapper/flink/FlinkDataSinkRuntime.java | 3 +-
.../wrapper/spark/AbstractSparkDeclarer.java | 4 +-
.../StandaloneEventProcessingDeclarer.java | 13 +-
.../StandaloneEventProcessorDeclarerSingleton.java | 12 +-
.../declarer/StandaloneEventSinkDeclarer.java | 10 +-
.../StandaloneEventSinkDeclarerSingleton.java | 10 +-
.../StandaloneExternalEventProcessingDeclarer.java | 8 +-
.../StandaloneExternalEventSinkDeclarer.java | 8 +-
streampipes-wrapper/pom.xml | 7 +-
.../wrapper/context/RuntimeContext.java | 8 +
.../context/SpEventProcessorRuntimeContext.java | 9 +-
.../wrapper/context/SpEventSinkRuntimeContext.java | 8 +-
.../wrapper/context/SpRuntimeContext.java | 20 +-
.../wrapper/declarer/EventProcessorDeclarer.java | 4 +-
.../wrapper/declarer/EventSinkDeclarer.java | 4 +-
.../wrapper/declarer/PipelineElementDeclarer.java | 24 +-
.../runtime/EventProcessorRuntimeParams.java | 11 +-
.../params/runtime/EventSinkRuntimeParams.java | 11 +-
.../wrapper/params/runtime/RuntimeParams.java | 11 +-
ui/.gitignore | 7 +
ui/cypress.json | 10 +
ui/cypress/README.md | 49 +++
ui/cypress/fixtures/fileTest/random.csv | 11 +
ui/cypress/fixtures/fileTest/test.csv | 4 +
.../filters-jvm/numericalFilter1/description.json | 8 +
.../filters-jvm/numericalFilter1/expected.csv | 6 +
.../filters-jvm/numericalFilter1/input.csv | 11 +
.../filters-jvm/projection1/description.json | 6 +
.../filters-jvm/projection1/expected.csv | 6 +
.../filters-jvm/projection1/input.csv | 6 +
.../filters-jvm/textFilter1/description.json | 8 +
.../filters-jvm/textFilter1/expected.csv | 4 +
.../filters-jvm/textFilter1/input.csv | 11 +
.../booleanCounter1/description.json | 7 +
.../booleanCounter1/expected.csv | 6 +
.../transformation-jvm/booleanCounter1/input.csv | 11 +
.../booleanInverter1/description.json | 6 +
.../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 | 4 +
.../fieldRenamer1/description.json | 7 +
.../transformation-jvm/fieldRenamer1/expected.csv | 11 +
.../transformation-jvm/fieldRenamer1/input.csv | 11 +
.../signalEdgeFilter1/description.json | 9 +
.../signalEdgeFilter1/expected.csv | 6 +
.../transformation-jvm/signalEdgeFilter1/input.csv | 11 +
.../splitArray1/description.json | 7 +
.../transformation-jvm/splitArray1/expected.csv | 3 +
.../transformation-jvm/splitArray1/input.json | 2 +
ui/cypress/plugins/index.ts | 70 ++++
.../support/builder/GenericAdapterBuilder.ts | 76 +++++
ui/cypress/support/builder/PipelineBuilder.ts | 61 ++++
.../support/builder/PipelineElementBuilder.ts | 50 +++
ui/cypress/support/builder/ProcessorTestBuilder.ts | 46 +++
.../support/builder/SpecificAdapterBuilder.ts | 61 ++++
ui/cypress/support/general/InitStreamPipesTest.ts | 47 +++
ui/cypress/support/general/dataCy.ts | 36 ++
ui/cypress/support/general/login.ts | 42 +++
ui/cypress/support/general/logout.ts | 38 +++
ui/cypress/support/general/readDir.ts | 43 +++
ui/cypress/support/general/resetStreamPipes.ts | 31 ++
ui/cypress/support/index.ts | 35 ++
ui/cypress/support/model/AdapterInput.ts | 23 ++
ui/cypress/support/model/GenericAdapterInput.ts | 26 ++
ui/cypress/support/model/PipelineElementInput.ts | 24 ++
ui/cypress/support/model/PipelineInput.ts | 29 ++
ui/cypress/support/model/ProcessorTest.ts | 26 ++
ui/cypress/support/model/SpecificAdapterInput.ts | 24 ++
ui/cypress/support/model/UserInput.ts | 23 ++
ui/cypress/support/utils/AdapterUtils.ts | 177 ++++++++++
ui/cypress/support/utils/DataLakeUtils.ts | 51 +++
ui/cypress/support/utils/FileManagementUtils.ts | 44 +++
ui/cypress/support/utils/PipelineUtils.ts | 101 ++++++
.../support/utils/ProcessingElementTestUtils.ts | 80 +++++
ui/cypress/support/utils/StaticPropertyUtils.ts | 38 +++
ui/cypress/support/utils/UserUtils.ts | 22 ++
ui/cypress/tests/adapter/fileStream.ts | 45 +++
ui/cypress/tests/adapter/machineDataSimulator.ts | 38 +++
.../adapter/randomDataSimulatorStream.spec.ts | 36 ++
.../tests/fileManagement/testFileManagement.ts | 31 ++
ui/cypress/tests/installation/installation.ts | 48 +++
ui/cypress/tests/pipeline/pipelineTest.ts | 50 +++
.../tests/pipelineElement/AllPipelineElements.ts | 38 +++
.../tests/pipelineElement/SinglePipelineElement.ts | 41 +++
ui/cypress/tsconfig.json | 11 +
ui/deployment/0.65.0/config.yml | 27 --
ui/deployment/0.65.0/img/logo.png | Bin 14358 -> 0 bytes
ui/deployment/0.65.0/img/sp-logo-right-white.png | Bin 21453 -> 0 bytes
ui/deployment/apps/config.yml | 29 --
ui/deployment/apps/img/logo.png | Bin 14358 -> 0 bytes
ui/deployment/apps/img/sp-logo-right-white.png | Bin 21453 -> 0 bytes
ui/deployment/dev/config.yml | 2 +-
ui/deployment/dev/img/logo-navigation.png | Bin 0 -> 19196 bytes
ui/deployment/dev/img/logo.png | Bin 14358 -> 24942 bytes
ui/deployment/dev/img/sp-logo-right-white.png | Bin 21453 -> 0 bytes
ui/deployment/prebuild.js | 21 +-
ui/package.json | 12 +-
ui/src/app/add/add.component.html | 32 +-
ui/src/app/add/add.component.scss | 7 +-
ui/src/app/add/add.component.ts | 8 +-
.../endpoint-item/endpoint-item.component.html | 19 +-
.../endpoint-item/endpoint-item.component.scss | 18 +-
.../endpoint-item/endpoint-item.component.ts | 37 ++-
.../add-endpoint/add-endpoint.component.html | 8 +-
.../endpoint-installation.component.html | 4 +-
.../endpoint-installation.component.ts | 4 +-
ui/src/app/add/services/add.service.ts | 18 +-
.../app-asset-monitoring.component.html | 8 +-
.../app/app-overview/app-overview.component.html | 10 +-
.../app/configuration/configuration.component.html | 6 +-
.../consul-configs/consul-configs.component.html | 2 +-
.../datalake-configuration.component.html | 6 +-
.../messaging-configuration.component.css | 10 +-
.../messaging-configuration.component.html | 10 +-
.../pipeline-element-configuration.component.css | 7 +-
.../pipeline-element-configuration.component.html | 5 +-
.../configuration-group.component.html | 33 ++
.../configuration-group.component.scss} | 0
.../configuration-group.component.ts | 48 +++
.../adapter-description.component.css | 65 ----
.../adapter-description.component.scss | 73 ++++
.../adapter-description.component.ts | 6 +-
.../data-marketplace.component.css | 84 -----
.../data-marketplace.component.html | 22 +-
.../data-marketplace.component.scss | 84 +++++
.../data-marketplace/data-marketplace.component.ts | 4 +-
.../existing-adapters.component.html | 10 +-
.../existing-adapters.component.scss | 7 +-
.../existing-adapters.component.ts | 42 ++-
.../format-component/format.component.html | 21 --
.../format-component/format.component.ts | 72 ----
.../format-configuration.component.html | 65 ++++
.../format-configuration.component.scss | 21 ++
.../format-configuration.component.ts | 129 ++++++++
ui/src/app/connect/components/format-form/csv.ts | 34 --
.../format-form/format-form.component.css | 22 --
.../format-form/format-form.component.html | 22 --
.../format-form/format-form.component.ts | 81 -----
.../app/connect/components/format-form/format.ts | 25 --
ui/src/app/connect/components/format-form/json.ts | 31 --
.../format-item/format-item.component.html | 21 ++
.../format-item.component.scss} | 0
.../format-item/format-item.component.ts | 71 ++++
.../format-list.component.html | 27 --
.../format-list-component/format-list.component.ts | 59 ----
.../format-list/format-list.component.html | 27 ++
.../format-list.component.scss} | 0
.../format-list/format-list.component.ts | 56 ++++
.../generic-adapter-configuration.component.html | 41 +++
.../generic-adapter-configuration.component.scss | 21 ++
.../generic-adapter-configuration.component.ts | 83 +++++
.../new-adapter/new-adapter.component.css | 54 ---
.../new-adapter/new-adapter.component.html | 236 +++----------
.../new-adapter/new-adapter.component.scss | 57 ++++
.../new-adapter/new-adapter.component.ts | 200 +++--------
.../pipeline-element-runtime-info.component.html | 8 +-
.../pipeline-element-runtime-info.component.scss | 9 +
.../error-message/error-message.component.html | 39 +++
.../error-message.component.scss} | 0
.../error-message/error-message.component.ts | 38 +++
.../event-property-row.component.css | 30 --
.../event-property-row.component.html | 9 +-
.../event-property-row.component.scss | 30 ++
.../event-property-row.component.ts | 2 +-
.../event-schema-preview.component.scss} | 0
.../event-schema-preview.component.ts | 8 +-
.../event-schema/event-schema.component.css | 176 ----------
.../event-schema/event-schema.component.html | 106 +++---
.../event-schema/event-schema.component.scss | 173 ++++++++++
.../event-schema/event-schema.component.ts | 96 ++++--
.../loading-message/loading-message.component.html | 26 ++
.../loading-message.component.scss} | 0
.../loading-message/loading-message.component.ts | 30 ++
.../schema-editor-header.component.html | 53 +++
.../schema-editor-header.component.scss | 21 ++
.../schema-editor-header.component.ts | 69 ++++
.../specific-adapter-configuration.component.html | 41 +++
.../specific-adapter-configuration.component.scss | 21 ++
.../specific-adapter-configuration.component.ts | 69 ++++
.../start-adapter-configuration.component.html | 111 +++++++
.../start-adapter-configuration.component.scss} | 0
.../start-adapter-configuration.component.ts | 150 +++++++++
ui/src/app/connect/connect.component.ts | 4 +-
ui/src/app/connect/connect.module.ts | 126 ++++---
.../adapter-started-dialog.component.html | 4 +-
.../delete-adapter-dialog.component.html | 20 +-
...t.scss => delete-adapter-dialog.component.scss} | 0
.../delete-adapter-dialog.component.ts | 42 +--
.../edit-correction-value.component.css | 17 -
.../edit-correction-value.component.html | 6 +-
.../edit-correction-value.component.scss} | 0
.../edit-correction-value.component.ts | 2 +-
.../edit-data-type/edit-data-type.component.html | 2 +-
...component.css => edit-data-type.component.scss} | 0
.../edit-data-type/edit-data-type.component.ts | 2 +-
.../edit-event-property-list.component.scss} | 0
.../edit-event-property-list.component.ts | 2 +-
...> edit-event-property-primitive.component.scss} | 0
.../edit-event-property-primitive.component.ts | 2 +-
.../edit-timestamp-property.component.html | 6 +-
....css => edit-timestamp-property.component.scss} | 0
.../edit-timestamp-property.component.ts | 2 +-
.../edit-unit-transformation.component.html | 8 +-
...css => edit-unit-transformation.component.scss} | 0
.../edit-unit-transformation.component.ts | 2 +-
.../edit-event-property.component.html | 20 +-
...nent.css => edit-event-property.component.scss} | 0
.../edit-event-property.component.ts | 2 +-
.../connect/services/data-marketplace.service.ts | 8 +-
ui/src/app/core-model/base/UserErrorMessage.ts | 27 ++
ui/src/app/core-model/dashboard/Dashboard.ts | 21 --
ui/src/app/core-model/datalake/DateRange.ts | 18 +-
.../app/core-model/gen/streampipes-model-client.ts | 39 ++-
ui/src/app/core-model/gen/streampipes-model.ts | 97 +++---
.../datalake/DatalakeQueryParameters.ts | 31 ++
.../datalake/datalake-rest.service.ts | 289 +++++++++++-----
ui/src/app/core-ui/core-ui.module.ts | 13 +-
.../confirm-dialog/confirm-dialog.component.html | 2 +-
.../panel-dialog/panel-dialog.component.scss | 7 +-
.../standard-dialog/standard-dialog.component.scss | 7 +-
.../core-ui/error-hint/error-hint.component.html | 46 +++
.../core-ui/error-hint/error-hint.component.scss | 25 ++
.../app/core-ui/error-hint/error-hint.component.ts | 45 +++
.../image-categorize.component.html | 58 ----
.../image-categorize/image-categorize.component.ts | 166 ----------
.../static-any-input.component.html | 11 +-
.../static-code-input.component.html | 4 +-
.../static-color-picker.component.html | 2 +-
.../static-file-input.component.css | 4 +-
.../static-file-input.component.html | 18 +-
.../static-file-input.component.ts | 99 +++---
.../static-free-input.component.html | 12 +-
.../static-mapping-nary.component.html | 20 +-
.../static-mapping-unary.component.html | 4 +-
.../static-one-of-input.component.html | 13 +-
.../static-property.component.html | 11 +-
...tic-runtime-resolvable-any-input.component.html | 6 +-
...c-runtime-resolvable-oneof-input.component.html | 2 +-
.../components/feedback/feedback.component.html | 8 +-
.../core/components/feedback/feedback.component.ts | 8 +-
.../core/components/iconbar/iconbar.component.html | 17 +-
.../core/components/iconbar/iconbar.component.scss | 23 ++
.../core/components/iconbar/iconbar.component.ts | 4 +-
.../streampipes/streampipes.component.html | 21 +-
.../streampipes/streampipes.component.scss | 13 +-
.../streampipes/streampipes.component.ts | 6 +-
.../core/components/toolbar/toolbar.component.html | 36 +-
.../core/components/toolbar/toolbar.component.scss | 22 ++
.../core/components/toolbar/toolbar.component.ts | 38 ++-
ui/src/app/core/core.module.ts | 9 +-
.../overview/dashboard-overview.component.css | 1 -
.../overview/dashboard-overview.component.html | 18 +-
.../components/panel/dashboard-panel.component.css | 7 +-
.../panel/dashboard-panel.component.html | 14 +-
.../widget/dashboard-widget.component.css | 6 +-
.../widget/dashboard-widget.component.html | 10 +-
.../widgets/area/area-widget.component.html | 2 +-
.../widgets/image/image-widget.component.html | 4 +-
.../widgets/line/line-widget.component.html | 2 +-
ui/src/app/dashboard/dashboard.component.html | 8 +-
.../add-visualization-dialog.component.html | 6 +-
.../add-visualization-dialog.component.scss | 8 +-
.../edit-dashboard-dialog.component.css | 2 +-
.../edit-dashboard-dialog.component.html | 2 +-
ui/src/app/dashboard/models/dashboard.model.ts | 10 +-
.../datadownloadDialog/dataDownload.dialog.css | 22 +-
.../datadownloadDialog/dataDownload.dialog.html | 8 +-
.../datadownloadDialog/dataDownload.dialog.ts | 4 +-
...lorer-widget-appearance-settings.component.html | 56 ++++
...orer-widget-appearance-settings.component.scss} | 0
...xplorer-widget-appearance-settings.component.ts | 49 +++
.../data-explorer-designer-panel.component.html | 96 ++++++
.../data-explorer-designer-panel.component.scss | 35 ++
.../data-explorer-designer-panel.component.ts | 64 ++++
...ta-explorer-widget-data-settings.component.html | 58 ++++
...ta-explorer-widget-data-settings.component.scss | 35 ++
...data-explorer-widget-data-settings.component.ts | 103 ++++++
.../data-explorer-dashboard-grid.component.html | 12 +-
.../data-explorer-dashboard-grid.component.scss | 16 +-
.../grid/data-explorer-dashboard-grid.component.ts | 97 ++++--
...data-explorer-dashboard-overview.component.html | 47 ++-
...data-explorer-dashboard-overview.component.scss | 11 +-
.../data-explorer-dashboard-overview.component.ts | 43 +--
.../data-explorer-dashboard-panel.component.css | 12 +
.../data-explorer-dashboard-panel.component.html | 34 +-
.../data-explorer-dashboard-panel.component.ts | 90 ++---
.../time-selector/timeRangeSelector.component.html | 16 +-
.../time-selector/timeRangeSelector.component.scss | 12 +-
.../time-selector/timeRangeSelector.component.ts | 51 +--
.../data-explorer-dashboard-widget.component.html | 54 +--
.../data-explorer-dashboard-widget.component.scss | 33 +-
.../data-explorer-dashboard-widget.component.ts | 62 ++--
.../components/widgets/base/base-config.ts | 26 --
.../widgets/base/base-data-explorer-widget.ts | 163 ++++-----
.../components/widgets/base/base-widget-config.ts | 156 +++++++++
.../config/image-widget-config.component.html | 17 +
.../config/image-widget-config.component.scss} | 0
.../image/config/image-widget-config.component.ts | 37 +++
.../components/widgets/image/image-config.ts | 42 ---
.../widgets/image/image-widget.component.html | 4 +-
.../widgets/image/image-widget.component.ts | 44 ++-
.../widgets/image/model/image-widget.model.ts | 34 ++
.../point-selection-info.component.css | 19 --
.../point-selection-info.component.html | 26 --
.../point-selection-info.component.ts | 51 ---
.../config/line-chart-widget-config.component.html | 73 ++++
.../line-chart-widget-config.component.scss} | 0
.../config/line-chart-widget-config.component.ts | 80 +++++
.../widgets/line-chart/line-chart-config.ts | 41 ---
.../line-chart/line-chart-widget.component.css | 6 +-
.../line-chart/line-chart-widget.component.html | 62 +---
.../line-chart/line-chart-widget.component.ts | 280 ++++++++--------
.../line-chart/model/line-chart-widget.model.ts | 45 +++
.../config/table-widget-config.component.html | 35 ++
.../config/table-widget-config.component.scss} | 0
.../table/config/table-widget-config.component.ts | 66 ++++
.../widgets/table/model/table-widget.model.ts | 33 ++
.../components/widgets/table/table-config.ts | 41 ---
.../widgets/table/table-widget.component.html | 51 ++-
.../widgets/table/table-widget.component.scss | 29 +-
.../widgets/table/table-widget.component.ts | 67 ++--
.../aggregate-configuration.component.html | 4 +-
.../no-data/no-data-in-date-range.component.css | 10 +
.../no-data/no-data-in-date-range.component.html | 5 +-
.../no-data/no-data-in-date-range.component.ts | 4 +-
.../select-properties.component.html | 4 +-
.../select-properties.component.ts | 15 +-
.../app/data-explorer/data-explorer.component.css | 2 -
.../app/data-explorer/data-explorer.component.html | 54 +--
.../app/data-explorer/data-explorer.component.ts | 166 +++++-----
ui/src/app/data-explorer/data-explorer.module.ts | 24 +-
...explorer-add-visualization-dialog.component.css | 71 ----
...xplorer-add-visualization-dialog.component.html | 78 -----
...-explorer-add-visualization-dialog.component.ts | 165 ---------
...ta-explorer-edit-data-view-dialog.component.css | 55 ---
...a-explorer-edit-data-view-dialog.component.html | 55 ++-
...a-explorer-edit-data-view-dialog.component.scss | 32 ++
...ata-explorer-edit-data-view-dialog.component.ts | 25 +-
.../models/dataview-dashboard.model.ts | 29 +-
.../registry/widget-config-builder.ts | 124 -------
.../sdk/collected-schema-requirements.ts | 39 ---
ui/src/app/data-explorer/sdk/ep-requirements.ts | 68 ----
.../sdk/extractor/static-property-extractor.ts | 78 -----
.../data-explorer/sdk/matching/datatype-match.ts | 44 ---
.../sdk/matching/domain-property-match.ts | 32 --
.../sdk/matching/mapping-property-generator.ts | 46 ---
.../sdk/matching/primitive-property-match.ts | 33 --
.../data-explorer/sdk/matching/property-match.ts | 34 --
ui/src/app/data-explorer/sdk/model/datatypes.ts | 40 ---
ui/src/app/data-explorer/sdk/model/vocabulary.ts | 23 --
.../sdk/schema-requirements-builder.ts | 70 ----
.../data-explorer/services/data-lake.service.ts | 28 --
.../services/data-view-data-explorer.service.ts | 59 ++--
.../services/refresh-dashboard.service.ts | 6 +-
.../app/data-explorer/services/resize.service.ts | 4 +-
.../services/widget-configuration.service.ts | 33 ++
.../property-selection.component.html | 3 +-
.../pipeline-assembly.component.html | 40 +--
.../pipeline-assembly.component.scss | 14 +-
.../pipeline-assembly.component.ts | 147 +++++----
.../pipeline-element-icon-stand.component.html | 12 +-
.../pipeline-element-icon-stand.component.scss | 12 +-
.../pipeline-element-options.component.html | 7 +-
.../pipeline-element-options.component.ts | 17 +-
.../pipeline-element-preview.component.html | 4 +-
.../pipeline-element-preview.component.scss | 11 +-
.../components/pipeline/pipeline.component.html | 7 +-
.../compatible-elements.component.html | 3 +-
.../compatible-elements.component.ts | 8 +-
.../dialog/customize/customize.component.html | 15 +-
ui/src/app/editor/dialog/help/help.component.html | 10 +-
ui/src/app/editor/dialog/help/help.component.scss | 11 +-
.../pipeline-element-discovery.component.html | 47 +++
.../pipeline-element-discovery.component.scss | 24 ++
.../pipeline-element-discovery.component.ts | 98 ++++++
.../save-pipeline/save-pipeline.component.html | 28 +-
.../welcome-tour/welcome-tour.component.html | 8 +-
.../dialog/welcome-tour/welcome-tour.component.ts | 4 +-
ui/src/app/editor/editor.component.html | 37 ++-
ui/src/app/editor/editor.component.scss | 9 +-
ui/src/app/editor/editor.module.ts | 2 +
ui/src/app/editor/services/jsplumb.service.ts | 134 ++++++--
.../editor/services/pipeline-validation.service.ts | 78 +++--
.../file-overview/file-overview.component.html | 6 +-
.../file-overview/file-overview.component.scss | 10 +-
.../file-upload/file-upload-dialog.component.html | 13 +-
ui/src/app/files/files.component.html | 14 +-
ui/src/app/files/files.component.scss | 5 +-
ui/src/app/home/components/status.component.css | 4 +-
ui/src/app/home/home.component.html | 11 +-
ui/src/app/home/home.component.scss | 14 +-
ui/src/app/home/home.component.ts | 6 +-
ui/src/app/info/about/about.component.html | 17 +-
ui/src/app/info/info.component.html | 8 +-
.../login/components/login/login.component.html | 14 +-
.../login/components/setup/setup.component.html | 21 +-
.../app/login/components/setup/setup.component.ts | 4 +-
.../components/startup/startup.component.html | 6 +-
.../login/components/startup/startup.component.ts | 6 +-
.../app/notifications/notifications.component.html | 8 +-
.../app/notifications/notifications.component.scss | 2 +-
.../actions/pipeline-actions.component.html | 8 +-
.../components/edit/quickedit.component.html | 2 +-
.../monitoring/pipeline-monitoring.component.html | 4 +-
.../monitoring/pipeline-monitoring.component.scss | 4 +-
.../pipeline-details.component.html | 6 +-
.../pipeline-overview.component.html | 13 +-
.../pipeline-overview.component.scss | 7 +-
.../delete-pipeline-dialog.component.html | 12 +-
.../pipeline-categories-dialog.component.html | 24 +-
.../pipeline-status-dialog.component.html | 11 +-
ui/src/app/pipelines/pipelines.component.html | 12 +-
.../apis/datalake-rest.service.ts | 193 +++++++++++
.../profile/components/basic-profile-settings.ts | 4 +-
.../general-profile-settings.component.html | 23 +-
.../general-profile-settings.component.scss | 10 +
.../general/general-profile-settings.component.ts | 30 +-
.../token/token-management-settings.component.html | 8 +-
.../token/token-management-settings.component.scss | 6 +-
ui/src/app/profile/profile.component.html | 6 +-
ui/src/app/profile/profile.service.ts | 6 +
ui/src/app/services/app.constants.ts | 26 ++
ui/src/app/services/auth-status.service.ts | 1 +
ui/src/app/services/services.module.ts | 2 +
ui/src/assets/img/Recognition_Icon.png | Bin 7985 -> 0 bytes
ui/src/assets/img/favicon/android-icon-144x144.png | Bin 0 -> 8497 bytes
ui/src/assets/img/favicon/android-icon-192x192.png | Bin 0 -> 11184 bytes
ui/src/assets/img/favicon/android-icon-36x36.png | Bin 0 -> 1955 bytes
ui/src/assets/img/favicon/android-icon-48x48.png | Bin 0 -> 2770 bytes
ui/src/assets/img/favicon/android-icon-72x72.png | Bin 0 -> 3979 bytes
ui/src/assets/img/favicon/android-icon-96x96.png | Bin 0 -> 5353 bytes
ui/src/assets/img/favicon/apple-icon-114x114.png | Bin 0 -> 6420 bytes
ui/src/assets/img/favicon/apple-icon-120x120.png | Bin 0 -> 6796 bytes
ui/src/assets/img/favicon/apple-icon-144x144.png | Bin 0 -> 8497 bytes
ui/src/assets/img/favicon/apple-icon-152x152.png | Bin 0 -> 9015 bytes
ui/src/assets/img/favicon/apple-icon-180x180.png | Bin 0 -> 11368 bytes
ui/src/assets/img/favicon/apple-icon-57x57.png | Bin 0 -> 3200 bytes
ui/src/assets/img/favicon/apple-icon-60x60.png | Bin 0 -> 3330 bytes
ui/src/assets/img/favicon/apple-icon-72x72.png | Bin 0 -> 3979 bytes
ui/src/assets/img/favicon/apple-icon-76x76.png | Bin 0 -> 4169 bytes
.../assets/img/favicon/apple-icon-precomposed.png | Bin 0 -> 11620 bytes
ui/src/assets/img/favicon/apple-icon.png | Bin 0 -> 11620 bytes
.../img/favicon/apple-touch-icon-114x114.png | Bin 12731 -> 0 bytes
.../img/favicon/apple-touch-icon-120x120.png | Bin 12215 -> 0 bytes
.../img/favicon/apple-touch-icon-144x144.png | Bin 9514 -> 0 bytes
.../img/favicon/apple-touch-icon-152x152.png | Bin 21383 -> 0 bytes
.../assets/img/favicon/apple-touch-icon-57x57.png | Bin 3780 -> 0 bytes
.../assets/img/favicon/apple-touch-icon-60x60.png | Bin 4004 -> 0 bytes
.../assets/img/favicon/apple-touch-icon-72x72.png | Bin 3230 -> 0 bytes
.../assets/img/favicon/apple-touch-icon-76x76.png | Bin 5680 -> 0 bytes
ui/src/assets/img/favicon/favicon-128.png | Bin 3329 -> 0 bytes
ui/src/assets/img/favicon/favicon-16x16.png | Bin 471 -> 1229 bytes
ui/src/assets/img/favicon/favicon-196x196.png | Bin 34049 -> 0 bytes
ui/src/assets/img/favicon/favicon-32x32.png | Bin 864 -> 1810 bytes
ui/src/assets/img/favicon/favicon-96x96.png | Bin 4246 -> 5353 bytes
ui/src/assets/img/favicon/favicon.ico | Bin 34494 -> 1150 bytes
ui/src/assets/img/favicon/ms-icon-144x144.png | Bin 0 -> 8497 bytes
ui/src/assets/img/favicon/ms-icon-150x150.png | Bin 0 -> 8893 bytes
ui/src/assets/img/favicon/ms-icon-310x310.png | Bin 0 -> 24839 bytes
ui/src/assets/img/favicon/ms-icon-70x70.png | Bin 0 -> 3871 bytes
ui/src/assets/img/favicon/mstile-144x144.png | Bin 9514 -> 0 bytes
ui/src/assets/img/favicon/mstile-150x150.png | Bin 51834 -> 0 bytes
ui/src/assets/img/favicon/mstile-310x150.png | Bin 90271 -> 0 bytes
ui/src/assets/img/favicon/mstile-310x310.png | Bin 214934 -> 0 bytes
ui/src/assets/img/favicon/mstile-70x70.png | Bin 3329 -> 0 bytes
ui/src/assets/img/login/logo.png | Bin 14358 -> 24942 bytes
ui/src/assets/img/sp/logo-navigation.png | Bin 0 -> 19196 bytes
ui/src/assets/img/sp/sp-logo-center-white.png | Bin 29781 -> 0 bytes
ui/src/assets/img/sp/sp-logo-right-white.png | Bin 21453 -> 0 bytes
ui/src/assets/img/svg/avatar-icons.svg | 240 --------------
ui/src/assets/img/svg/svg-sprite-action.svg | 1 -
ui/src/assets/img/svg/svg-sprite-alert.svg | 1 -
ui/src/assets/img/svg/svg-sprite-av.svg | 1 -
ui/src/assets/img/svg/svg-sprite-communication.svg | 1 -
ui/src/assets/img/svg/svg-sprite-content.svg | 1 -
ui/src/assets/img/svg/svg-sprite-device.svg | 1 -
ui/src/assets/img/svg/svg-sprite-editor.svg | 1 -
ui/src/assets/img/svg/svg-sprite-file.svg | 1 -
ui/src/assets/img/svg/svg-sprite-hardware.svg | 1 -
ui/src/assets/img/svg/svg-sprite-image.svg | 1 -
ui/src/assets/img/svg/svg-sprite-maps.svg | 1 -
ui/src/assets/img/svg/svg-sprite-navigation.svg | 1 -
ui/src/assets/img/svg/svg-sprite-notification.svg | 1 -
ui/src/assets/img/svg/svg-sprite-social.svg | 1 -
ui/src/assets/img/svg/svg-sprite-toggle.svg | 1 -
ui/src/index.html | 39 +--
ui/src/scss/_variables.scss | 4 +-
ui/src/scss/main.scss | 2 +
ui/src/scss/sp/buttons.ng1.scss | 19 +-
ui/src/scss/sp/buttons.scss | 36 +-
ui/src/scss/sp/colors.scss | 47 ++-
ui/src/scss/sp/dialog.scss | 4 +-
ui/src/scss/sp/feedback.ng1.scss | 7 +-
ui/src/scss/sp/layout.scss | 129 ++++++++
ui/src/scss/sp/main.scss | 36 +-
ui/src/scss/sp/pipeline-element-loading.scss | 4 +-
ui/src/scss/sp/pipeline-element-options.scss | 4 +-
ui/src/scss/sp/pipeline-validation.scss | 6 +-
ui/src/scss/sp/sp-theme.scss | 153 ++++++++-
ui/src/scss/sp/widgets.scss | 5 +-
1014 files changed, 18322 insertions(+), 14640 deletions(-)
create mode 100644 streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/CustomEnvs.java
create mode 100644 streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/Envs.java
create mode 100644 streampipes-commons/src/main/java/org/apache/streampipes/commons/constants/InstanceIdExtractor.java
create mode 100644 streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/NoServiceEndpointsAvailableException.java
create mode 100644 streampipes-commons/src/main/java/org/apache/streampipes/commons/networking/Networking.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/SpConfig.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/SpConfigChangeCallback.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/consul/ConsulSpConfig.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/consul/MockSpConfig.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/model/ConfigItem.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/model/ConfigurationScope.java
delete mode 100644 streampipes-config/src/main/java/org/apache/streampipes/config/model/PeConfig.java
create mode 100644 streampipes-connect-api/pom.xml
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/Connector.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/EmitBinaryEvent.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapter.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapterPipeline.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IAdapterPipelineElement.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IFormat.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IParser.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/IProtocol.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/AdapterException.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/ParseException.java
create mode 100644 streampipes-connect-api/src/main/java/org/apache/streampipes/connect/api/exception/WorkerAdapterException.java
create mode 100644 streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/general/ResetManagement.java
delete mode 100644 streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/Utils.java
create mode 100644 streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/WorkerUrlProvider.java
create mode 100644 streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/util/Utils.java
create mode 100644 streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/util/WorkerPaths.java
create mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/AdapterServiceResourceProvider.java
create mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerDescriptionProvider.java
create mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerRegistrationService.java
create mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/init/ConnectWorkerTagProvider.java
create mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/RuntimeResovable.java
create mode 100644 streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtils.java
create mode 100644 streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/management/Mock.java
create mode 100644 streampipes-connect-container-worker/src/test/java/org/apache/streampipes/connect/container/worker/utils/AdapterUtilsTest.java
delete mode 100644 streampipes-connect-container/development/env
delete mode 100644 streampipes-connect-container/pom.xml
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/config/ConfigKeys.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/config/ConnectContainerConfig.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/init/AdapterContainerConfig.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/init/AdapterDeclarerSingleton.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/management/AdapterUtils.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/management/RuntimeResovable.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/rest/AbstractContainerResource.java
delete mode 100644 streampipes-connect-container/src/main/java/org/apache/streampipes/connect/rest/SpConnectUtils.java
delete mode 100644 streampipes-connect-container/src/test/SpConnectResourceTest.java
delete mode 100644 streampipes-connect-container/src/test/SpConnectTest.java
delete mode 100644 streampipes-connect-container/src/test/java/org/streampipes/connect/Mock.java
delete mode 100644 streampipes-connect-container/src/test/java/org/streampipes/connect/management/AdapterDeserializerTest.java
delete mode 100644 streampipes-connect-container/src/test/java/org/streampipes/connect/management/AdapterUtilsTest.java
delete mode 100644 streampipes-connect-container/src/test/java/org/streampipes/connect/utils/TestAdapterSerializer.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/EmitBinaryEvent.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/exception/AdapterException.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/exception/ParseException.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/exception/WorkerAdapterException.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/model/Connector.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/model/generic/Format.java
delete mode 100644 streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/model/pipeline/AdapterPipelineElement.java
create mode 100644 streampipes-container-base/src/main/java/org/apache/streampipes/container/base/StreamPipesServiceBase.java
create mode 100644 streampipes-container-base/src/main/java/org/apache/streampipes/container/base/rest/BaseResourceConfig.java
delete mode 100644 streampipes-container-embedded/pom.xml
delete mode 100644 streampipes-container-embedded/src/main/java/org/apache/streampipes/container/embedded/init/ContainerModelSubmitter.java
delete mode 100644 streampipes-container-embedded/src/main/webapp/WEB-INF/web.xml
create mode 100644 streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementServiceShutdownHandler.java
create mode 100644 streampipes-container-standalone/src/main/java/org/apache/streampipes/container/standalone/init/PipelineElementServiceTagProvider.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/config/ConfigExtractor.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/html/model/AgentDescription.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/html/page/EventConsumerWelcomePage.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/html/page/EventProcessingAgentWelcomePage.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/html/page/EventProducerWelcomePage.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/html/page/WelcomePageGeneratorImpl.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/BaseExtensionsServiceResourceProvider.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/ExtensionsResourceProvider.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/ModelSubmitter.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/init/PipelineElementServiceResourceProvider.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/model/SpServiceDefinition.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/model/SpServiceDefinitionBuilder.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/model/consul/ConsulServiceRegistrationBody.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/model/consul/HealthCheckConfiguration.java
delete mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/util/ConsulUtil.java
create mode 100644 streampipes-container/src/main/java/org/apache/streampipes/container/util/ServiceDefinitionUtil.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/DataLakeManagementV4.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/RetentionPolicyQueryParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/EditRetentionPolicyQuery.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ShowRetentionPolicyQuery.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/DeleteFromStatementParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/FillParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/GroupingByTagsParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/GroupingByTimeParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/ItemLimitationParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/OffsetParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/OrderingByTimeParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/QueryParamsV4.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/SelectFromStatementParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/TimeBoundaryParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/DataExplorerQueryV4.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/QueryBuilder.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/DeleteFromStatement.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/FillStatement.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/GroupingByTags.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/GroupingByTime.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/ItemLimitation.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/Offset.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/OrderingByTime.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/QueryElement.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/SelectFromStatement.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/TimeBoundary.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/template/QueryTemplatesV4.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/utils/DataLakeManagementUtils.java
create mode 100644 streampipes-model-client/src/main/java/org/apache/streampipes/model/client/endpoint/ExtensionsServiceEndpoint.java
create mode 100644 streampipes-model-client/src/main/java/org/apache/streampipes/model/client/endpoint/ExtensionsServiceEndpointItem.java
delete mode 100644 streampipes-model-client/src/main/java/org/apache/streampipes/model/client/endpoint/RdfEndpoint.java
delete mode 100644 streampipes-model-client/src/main/java/org/apache/streampipes/model/client/endpoint/RdfEndpointItem.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/base/StreamPipesJsonLdContainer.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/datalake/CustomMapSerializer.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeConfiguration.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/datalake/DataLakeRetentionPolicy.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/datalake/LabelDefinition.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/datalake/PersistedDataStream.java
create mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/util/ElementIdGenerator.java
delete mode 100644 streampipes-model/src/main/java/org/apache/streampipes/model/util/RdfIdGenerator.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointGenerator.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointUtils.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/PipelineCacheManager.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/PipelineCanvasMetadataCacheManager.java
create mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/pipeline/PipelineManager.java
delete mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/CacheInitializationInstallationStep.java
delete mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/setup/EmpireInitializerInstallationStep.java
delete mode 100644 streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/extractor/StatementBuilder.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/TestPipelineExecution.java
create mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/TestPipelineManager.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/TestPipelineStorage.java
delete mode 100644 streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/template/TestTemplateGenerator.java
create mode 100644 streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV4.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ExtensionsServiceEndpointResource.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/RdfEndpoint.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ResetResource.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/AbstractPipelineExtractionResource.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipelineResource.java
create mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/PersistedDataStreamResource.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/serializer/JsonLdProvider.java
delete mode 100644 streampipes-rest/src/main/java/org/apache/streampipes/rest/util/JsonLdUtils.java
delete mode 100644 streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/ConsulConfigTest.java
delete mode 100644 streampipes-rest/src/test/java/org/apache/streampipes/rest/util/JsonLdUtilsTest.java
delete mode 100644 streampipes-serializers-jsonld/pom.xml
delete mode 100644 streampipes-serializers-jsonld/src/main/java/org/apache/streampipes/serializers/jsonld/CustomAnnotationProvider.java
delete mode 100644 streampipes-serializers-jsonld/src/main/java/org/apache/streampipes/serializers/jsonld/JsonLdTransformer.java
delete mode 100644 streampipes-serializers-jsonld/src/main/java/org/apache/streampipes/serializers/jsonld/JsonLdUtils.java
delete mode 100644 streampipes-serializers-jsonld/src/main/java/org/apache/streampipes/serializers/jsonld/RdfTransformer.java
create mode 100644 streampipes-service-discovery-api/pom.xml
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/ISpKvManagement.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/ISpServiceDiscovery.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/SpConfig.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/ConfigItem.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/ConfigItemUtils.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/ConfigurationScope.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/DefaultSpServiceGroups.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/DefaultSpServiceTags.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/PeConfig.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/SpServicePathPrefix.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/SpServiceRegistrationRequest.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/SpServiceTag.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/SpServiceTagPrefix.java
create mode 100644 streampipes-service-discovery-api/src/main/java/org/apache/streampipes/svcdiscovery/api/model/SpServiceUrlProvider.java
create mode 100644 streampipes-service-discovery-consul/pom.xml
create mode 100644 streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/AbstractConsulService.java
create mode 100644 streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/ConsulHealthServiceManager.java
create mode 100644 streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/ConsulProvider.java
create mode 100644 streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/ConsulSpConfig.java
create mode 100644 streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/SpConsulKvManagement.java
create mode 100644 streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/SpConsulServiceDiscovery.java
create mode 100644 streampipes-service-discovery/pom.xml
create mode 100644 streampipes-service-discovery/src/main/java/org/apache/streampipes/svcdiscovery/SpServiceDiscovery.java
create mode 100644 streampipes-service-extensions-base/pom.xml
create mode 100644 streampipes-service-extensions-base/src/main/java/org/apache/streampipes/service/extensions/base/StreamPipesExtensionsServiceBase.java
delete mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IBackgroundKnowledgeStorage.java
create mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataProcessorStorage.java
create mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataSinkStorage.java
create mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IDataStreamStorage.java
create mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IExtensionsServiceEndpointStorage.java
delete mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IRdfEndpointStorage.java
delete mode 100644 streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/ITripleStorage.java
create mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataProcessorStorageImpl.java
create mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataSinkStorageImpl.java
create mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/DataStreamStorageImpl.java
create mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/ExtensionsServiceEndpointStorageImpl.java
create mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/PipelineElementDescriptionStorageImpl.java
delete mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/RdfEndpointStorageImpl.java
create mode 100644 streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/utils/Filter.java
delete mode 100644 streampipes-storage-rdf4j/pom.xml
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/Rdf4JStorageManager.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/config/ConfigKeys.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/config/Rdf4JConfig.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/filter/Filter.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/impl/PipelineElementInMemoryStorage.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/impl/PipelineElementStorageRequests.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/sparql/QueryBuilder.java
delete mode 100644 streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/util/Transformer.java
create mode 100644 ui/cypress.json
create mode 100644 ui/cypress/README.md
create mode 100644 ui/cypress/fixtures/fileTest/random.csv
create mode 100644 ui/cypress/fixtures/fileTest/test.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/input.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/input.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/description.json
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/expected.csv
create mode 100644 ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/input.json
create mode 100644 ui/cypress/plugins/index.ts
create mode 100644 ui/cypress/support/builder/GenericAdapterBuilder.ts
create mode 100644 ui/cypress/support/builder/PipelineBuilder.ts
create mode 100644 ui/cypress/support/builder/PipelineElementBuilder.ts
create mode 100644 ui/cypress/support/builder/ProcessorTestBuilder.ts
create mode 100644 ui/cypress/support/builder/SpecificAdapterBuilder.ts
create mode 100644 ui/cypress/support/general/InitStreamPipesTest.ts
create mode 100644 ui/cypress/support/general/dataCy.ts
create mode 100644 ui/cypress/support/general/login.ts
create mode 100644 ui/cypress/support/general/logout.ts
create mode 100644 ui/cypress/support/general/readDir.ts
create mode 100644 ui/cypress/support/general/resetStreamPipes.ts
create mode 100644 ui/cypress/support/index.ts
create mode 100644 ui/cypress/support/model/AdapterInput.ts
create mode 100644 ui/cypress/support/model/GenericAdapterInput.ts
create mode 100644 ui/cypress/support/model/PipelineElementInput.ts
create mode 100644 ui/cypress/support/model/PipelineInput.ts
create mode 100644 ui/cypress/support/model/ProcessorTest.ts
create mode 100644 ui/cypress/support/model/SpecificAdapterInput.ts
create mode 100644 ui/cypress/support/model/UserInput.ts
create mode 100644 ui/cypress/support/utils/AdapterUtils.ts
create mode 100644 ui/cypress/support/utils/DataLakeUtils.ts
create mode 100644 ui/cypress/support/utils/FileManagementUtils.ts
create mode 100644 ui/cypress/support/utils/PipelineUtils.ts
create mode 100644 ui/cypress/support/utils/ProcessingElementTestUtils.ts
create mode 100644 ui/cypress/support/utils/StaticPropertyUtils.ts
create mode 100644 ui/cypress/support/utils/UserUtils.ts
create mode 100644 ui/cypress/tests/adapter/fileStream.ts
create mode 100644 ui/cypress/tests/adapter/machineDataSimulator.ts
create mode 100644 ui/cypress/tests/adapter/randomDataSimulatorStream.spec.ts
create mode 100644 ui/cypress/tests/fileManagement/testFileManagement.ts
create mode 100644 ui/cypress/tests/installation/installation.ts
create mode 100644 ui/cypress/tests/pipeline/pipelineTest.ts
create mode 100644 ui/cypress/tests/pipelineElement/AllPipelineElements.ts
create mode 100644 ui/cypress/tests/pipelineElement/SinglePipelineElement.ts
create mode 100644 ui/cypress/tsconfig.json
delete mode 100644 ui/deployment/0.65.0/config.yml
delete mode 100644 ui/deployment/0.65.0/img/logo.png
delete mode 100644 ui/deployment/0.65.0/img/sp-logo-right-white.png
delete mode 100644 ui/deployment/apps/config.yml
delete mode 100644 ui/deployment/apps/img/logo.png
delete mode 100644 ui/deployment/apps/img/sp-logo-right-white.png
create mode 100644 ui/deployment/dev/img/logo-navigation.png
delete mode 100644 ui/deployment/dev/img/sp-logo-right-white.png
create mode 100644 ui/src/app/connect/components/configuration-group/configuration-group.component.html
rename ui/src/app/connect/{dialog/edit-event-property/components/edit-event-property-list/edit-event-property-list.component.css => components/configuration-group/configuration-group.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/configuration-group/configuration-group.component.ts
delete mode 100644 ui/src/app/connect/components/data-marketplace/adapter-description/adapter-description.component.css
create mode 100644 ui/src/app/connect/components/data-marketplace/adapter-description/adapter-description.component.scss
delete mode 100644 ui/src/app/connect/components/data-marketplace/data-marketplace.component.css
create mode 100644 ui/src/app/connect/components/data-marketplace/data-marketplace.component.scss
delete mode 100644 ui/src/app/connect/components/format-component/format.component.html
delete mode 100644 ui/src/app/connect/components/format-component/format.component.ts
create mode 100644 ui/src/app/connect/components/format-configuration/format-configuration.component.html
create mode 100644 ui/src/app/connect/components/format-configuration/format-configuration.component.scss
create mode 100644 ui/src/app/connect/components/format-configuration/format-configuration.component.ts
delete mode 100644 ui/src/app/connect/components/format-form/csv.ts
delete mode 100644 ui/src/app/connect/components/format-form/format-form.component.css
delete mode 100644 ui/src/app/connect/components/format-form/format-form.component.html
delete mode 100644 ui/src/app/connect/components/format-form/format-form.component.ts
delete mode 100644 ui/src/app/connect/components/format-form/format.ts
delete mode 100644 ui/src/app/connect/components/format-form/json.ts
create mode 100644 ui/src/app/connect/components/format-item/format-item.component.html
rename ui/src/app/connect/components/{format-component/format.component.css => format-item/format-item.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/format-item/format-item.component.ts
delete mode 100644 ui/src/app/connect/components/format-list-component/format-list.component.html
delete mode 100644 ui/src/app/connect/components/format-list-component/format-list.component.ts
create mode 100644 ui/src/app/connect/components/format-list/format-list.component.html
rename ui/src/app/connect/components/{format-list-component/format-list.component.css => format-list/format-list.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/format-list/format-list.component.ts
create mode 100644 ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.html
create mode 100644 ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.scss
create mode 100644 ui/src/app/connect/components/generic-adapter-configuration/generic-adapter-configuration.component.ts
delete mode 100644 ui/src/app/connect/components/new-adapter/new-adapter.component.css
create mode 100644 ui/src/app/connect/components/new-adapter/new-adapter.component.scss
create mode 100644 ui/src/app/connect/components/schema-editor/error-message/error-message.component.html
rename ui/src/app/connect/components/schema-editor/{event-schema-preview/event-schema-preview.component.css => error-message/error-message.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/schema-editor/error-message/error-message.component.ts
delete mode 100644 ui/src/app/connect/components/schema-editor/event-property-row/event-property-row.component.css
create mode 100644 ui/src/app/connect/components/schema-editor/event-property-row/event-property-row.component.scss
copy ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.scss => connect/components/schema-editor/event-schema-preview/event-schema-preview.component.scss} (100%)
delete mode 100644 ui/src/app/connect/components/schema-editor/event-schema/event-schema.component.css
create mode 100644 ui/src/app/connect/components/schema-editor/event-schema/event-schema.component.scss
create mode 100644 ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.html
copy ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.scss => connect/components/schema-editor/loading-message/loading-message.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/schema-editor/loading-message/loading-message.component.ts
create mode 100644 ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.html
create mode 100644 ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.scss
create mode 100644 ui/src/app/connect/components/schema-editor/schema-editor-header/schema-editor-header.component.ts
create mode 100644 ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.html
create mode 100644 ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.scss
create mode 100644 ui/src/app/connect/components/specific-adapter-configuration/specific-adapter-configuration.component.ts
create mode 100644 ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.html
copy ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.scss => connect/components/start-adapter-configuration/start-adapter-configuration.component.scss} (100%)
create mode 100644 ui/src/app/connect/components/start-adapter-configuration/start-adapter-configuration.component.ts
rename ui/src/app/connect/dialog/delete-adapter-dialog/{delete-pipeline-dialog.component.scss => delete-adapter-dialog.component.scss} (100%)
delete mode 100644 ui/src/app/connect/dialog/edit-event-property/components/edit-correction-value/edit-correction-value.component.css
rename ui/src/app/{core-ui/image/image-categorize/image-categorize.component.css => connect/dialog/edit-event-property/components/edit-correction-value/edit-correction-value.component.scss} (100%)
rename ui/src/app/connect/dialog/edit-event-property/components/edit-data-type/{edit-data-type.component.css => edit-data-type.component.scss} (100%)
copy ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.scss => connect/dialog/edit-event-property/components/edit-event-property-list/edit-event-property-list.component.scss} (100%)
rename ui/src/app/connect/dialog/edit-event-property/components/edit-event-property-primitive/{edit-event-property-primitive.component.css => edit-event-property-primitive.component.scss} (100%)
rename ui/src/app/connect/dialog/edit-event-property/components/edit-timestamp-property/{edit-timestamp-property.component.css => edit-timestamp-property.component.scss} (100%)
rename ui/src/app/connect/dialog/edit-event-property/components/edit-unit-transformation/{edit-unit-transformation.component.css => edit-unit-transformation.component.scss} (100%)
rename ui/src/app/connect/dialog/edit-event-property/{edit-event-property.component.css => edit-event-property.component.scss} (100%)
create mode 100644 ui/src/app/core-model/base/UserErrorMessage.ts
delete mode 100644 ui/src/app/core-model/dashboard/Dashboard.ts
create mode 100644 ui/src/app/core-services/datalake/DatalakeQueryParameters.ts
create mode 100644 ui/src/app/core-ui/error-hint/error-hint.component.html
create mode 100644 ui/src/app/core-ui/error-hint/error-hint.component.scss
create mode 100644 ui/src/app/core-ui/error-hint/error-hint.component.ts
delete mode 100644 ui/src/app/core-ui/image/image-categorize/image-categorize.component.html
delete mode 100644 ui/src/app/core-ui/image/image-categorize/image-categorize.component.ts
create mode 100644 ui/src/app/core/components/iconbar/iconbar.component.scss
create mode 100644 ui/src/app/data-explorer/components/designer-panel/appearance-settings/data-explorer-widget-appearance-settings.component.html
copy ui/src/app/{editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.scss => data-explorer/components/designer-panel/appearance-settings/data-explorer-widget-appearance-settings.component.scss} (100%)
create mode 100644 ui/src/app/data-explorer/components/designer-panel/appearance-settings/data-explorer-widget-appearance-settings.component.ts
create mode 100644 ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.html
create mode 100644 ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.scss
create mode 100644 ui/src/app/data-explorer/components/designer-panel/data-explorer-designer-panel.component.ts
create mode 100644 ui/src/app/data-explorer/components/designer-panel/data-settings/data-explorer-widget-data-settings.component.html
create mode 100644 ui/src/app/data-explorer/components/designer-panel/data-settings/data-explorer-widget-data-settings.component.scss
create mode 100644 ui/src/app/data-explorer/components/designer-panel/data-settings/data-explorer-widget-data-settings.component.ts
delete mode 100644 ui/src/app/data-explorer/components/widgets/base/base-config.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/base/base-widget-config.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/image/config/image-widget-config.component.html
copy ui/src/app/{editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.scss => data-explorer/components/widgets/image/config/image-widget-config.component.scss} (100%)
create mode 100644 ui/src/app/data-explorer/components/widgets/image/config/image-widget-config.component.ts
delete mode 100644 ui/src/app/data-explorer/components/widgets/image/image-config.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/image/model/image-widget.model.ts
delete mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/components/point-selection-info/point-selection-info.component.css
delete mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/components/point-selection-info/point-selection-info.component.html
delete mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/components/point-selection-info/point-selection-info.component.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/config/line-chart-widget-config.component.html
copy ui/src/app/{editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.scss => data-explorer/components/widgets/line-chart/config/line-chart-widget-config.component.scss} (100%)
create mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/config/line-chart-widget-config.component.ts
delete mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/line-chart-config.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/line-chart/model/line-chart-widget.model.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/table/config/table-widget-config.component.html
copy ui/src/app/{editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.scss => data-explorer/components/widgets/table/config/table-widget-config.component.scss} (100%)
create mode 100644 ui/src/app/data-explorer/components/widgets/table/config/table-widget-config.component.ts
create mode 100644 ui/src/app/data-explorer/components/widgets/table/model/table-widget.model.ts
delete mode 100644 ui/src/app/data-explorer/components/widgets/table/table-config.ts
delete mode 100644 ui/src/app/data-explorer/dialogs/add-widget/data-explorer-add-visualization-dialog.component.css
delete mode 100644 ui/src/app/data-explorer/dialogs/add-widget/data-explorer-add-visualization-dialog.component.html
delete mode 100644 ui/src/app/data-explorer/dialogs/add-widget/data-explorer-add-visualization-dialog.component.ts
delete mode 100644 ui/src/app/data-explorer/dialogs/edit-dashboard/data-explorer-edit-data-view-dialog.component.css
create mode 100644 ui/src/app/data-explorer/dialogs/edit-dashboard/data-explorer-edit-data-view-dialog.component.scss
delete mode 100644 ui/src/app/data-explorer/registry/widget-config-builder.ts
delete mode 100644 ui/src/app/data-explorer/sdk/collected-schema-requirements.ts
delete mode 100644 ui/src/app/data-explorer/sdk/ep-requirements.ts
delete mode 100644 ui/src/app/data-explorer/sdk/extractor/static-property-extractor.ts
delete mode 100644 ui/src/app/data-explorer/sdk/matching/datatype-match.ts
delete mode 100644 ui/src/app/data-explorer/sdk/matching/domain-property-match.ts
delete mode 100644 ui/src/app/data-explorer/sdk/matching/mapping-property-generator.ts
delete mode 100644 ui/src/app/data-explorer/sdk/matching/primitive-property-match.ts
delete mode 100644 ui/src/app/data-explorer/sdk/matching/property-match.ts
delete mode 100644 ui/src/app/data-explorer/sdk/model/datatypes.ts
delete mode 100644 ui/src/app/data-explorer/sdk/model/vocabulary.ts
delete mode 100644 ui/src/app/data-explorer/sdk/schema-requirements-builder.ts
delete mode 100644 ui/src/app/data-explorer/services/data-lake.service.ts
create mode 100644 ui/src/app/data-explorer/services/widget-configuration.service.ts
create mode 100644 ui/src/app/editor/dialog/pipeline-element-discovery/pipeline-element-discovery.component.html
create mode 100644 ui/src/app/editor/dialog/pipeline-element-discovery/pipeline-element-discovery.component.scss
create mode 100644 ui/src/app/editor/dialog/pipeline-element-discovery/pipeline-element-discovery.component.ts
create mode 100644 ui/src/app/platform-services/apis/datalake-rest.service.ts
create mode 100644 ui/src/app/services/app.constants.ts
delete mode 100644 ui/src/assets/img/Recognition_Icon.png
create mode 100644 ui/src/assets/img/favicon/android-icon-144x144.png
create mode 100644 ui/src/assets/img/favicon/android-icon-192x192.png
create mode 100644 ui/src/assets/img/favicon/android-icon-36x36.png
create mode 100644 ui/src/assets/img/favicon/android-icon-48x48.png
create mode 100644 ui/src/assets/img/favicon/android-icon-72x72.png
create mode 100644 ui/src/assets/img/favicon/android-icon-96x96.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-114x114.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-120x120.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-144x144.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-152x152.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-180x180.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-57x57.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-60x60.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-72x72.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-76x76.png
create mode 100644 ui/src/assets/img/favicon/apple-icon-precomposed.png
create mode 100644 ui/src/assets/img/favicon/apple-icon.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-114x114.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-120x120.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-144x144.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-152x152.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-57x57.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-60x60.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-72x72.png
delete mode 100644 ui/src/assets/img/favicon/apple-touch-icon-76x76.png
delete mode 100644 ui/src/assets/img/favicon/favicon-128.png
delete mode 100644 ui/src/assets/img/favicon/favicon-196x196.png
create mode 100644 ui/src/assets/img/favicon/ms-icon-144x144.png
create mode 100644 ui/src/assets/img/favicon/ms-icon-150x150.png
create mode 100644 ui/src/assets/img/favicon/ms-icon-310x310.png
create mode 100644 ui/src/assets/img/favicon/ms-icon-70x70.png
delete mode 100644 ui/src/assets/img/favicon/mstile-144x144.png
delete mode 100644 ui/src/assets/img/favicon/mstile-150x150.png
delete mode 100644 ui/src/assets/img/favicon/mstile-310x150.png
delete mode 100644 ui/src/assets/img/favicon/mstile-310x310.png
delete mode 100644 ui/src/assets/img/favicon/mstile-70x70.png
create mode 100644 ui/src/assets/img/sp/logo-navigation.png
delete mode 100644 ui/src/assets/img/sp/sp-logo-center-white.png
delete mode 100644 ui/src/assets/img/sp/sp-logo-right-white.png
delete mode 100644 ui/src/assets/img/svg/avatar-icons.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-action.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-alert.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-av.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-communication.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-content.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-device.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-editor.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-file.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-hardware.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-image.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-maps.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-navigation.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-notification.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-social.svg
delete mode 100644 ui/src/assets/img/svg/svg-sprite-toggle.svg
create mode 100644 ui/src/scss/sp/layout.scss