This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch STREAMPIPES-349
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from ef5be85 [STREAMPIPES-349] Refactor data retrieval and download
endpoint to support selection of specified columns
add af1a6ff Merge pull request #41 from anushkrishnav/anushkrishnav
add ade3c68 [STREAMPIPES-340] Support of offset clause in Siddhi
wrapper/processors
add 6557658 Merge pull request #39 from sndp2693/STREAMPIPES-340
add 3e444d3 [STREAMPIPES-323] Added equals to SchemaInfo
add f4dfc23 Added equals to SchemaInfo
add 341eb8a Used list1.equals.list2
add 7c8eaa4 Spacing fixed
add 67ddf91 Spacing fixed
add e93e4d5 Used ListUtils.isEqualList
add 2e4b2fe Used single imports instead of import *
add 7bfb1c9 [STREAMPIPES-323] Added equals to Schemainfo
add 735c08c Merge branch 'dev' of
https://github.com/Samarth08/incubator-streampipes into dev
add 32223d1 [STREAMPIPES-323] Added equals to schemainfo
add e21a592 Merge pull request #34 from Samarth08/dev
add df3cf9b Remove invalid dependency entry
add 22e98b2 Merge pull request #42 from mohanvive/dev
add 9ca4b29 [hotfix] Remove wso2 maven repo from pom
add ec5f27c [STREAMPIPES-360] Improve adapter management
add eedcf48 [hotfix] Avoid selection of internally managed adapters in
installation overview
add d04a5b7 [STREAMPIPES-74] Initiate multiple attempts to start
pipelines upon startup
add e3a10e8 [STREAMPIPES-360] Remove obsolete tests
add 80b3ef3 [STREAMPIPES-360] Minor improvements in WorkerRestClient
add 1434f3f [STREAMPIPES-248] Fix document conflict when restarting
orphaned pipelines
add 6dde10a [STREAMPIPES-282] Remove empty path annotation
add a022ad0 [STREAMPIPES-361] Prevent running pipelines to be updated
add a14b76f [STREAMPIPES-362] Add live preview feature to pipeline editor
add 6c91340 [hotfix] Fix bug that prevented pipeline cached to be deleted
add 4f4a4ed [hotfix] Fix bug causing exception when building pipelines
with multiple elements of same type
add 3dc36f4 [STREAMPIPES-362] Disable preview button for empty pipelines
add a3021bb [STREAMPIPES-365] Fix bug in pipeline validation
add c040a5a [STREAMPIPES-368] Avoid duplication of visualizable pipelines
in dashboard
add 5fe0cf8 [STREAMPIPES-369] Improve user guidance in live dashboard
add 31cefac [STREAMPIPES-370] Improve modification of existing dashboard
widgets
add 40dbfd4 [STREAMPIPES-369] Improve reloading of widgets after updates
add 18aa6e6 [STREAMPIPES-370] Remove widget type from DashboardItem
add 3a18374 [STREAMPIPES-245] Avoid NullPointerException in production
config
add 49d4178 [hotfix] Show pipeline status in pipeline overview
add d04faac [STREAMPIPES-367] Allow forced stop of pipelines that fail to
be gracefully stopped
add 0310faf [STREAMPIPES-371] Fix wrong selection of pipelineId in start
pipeline dialog
add 62260ca [STREAMPIPES-372] Add pipeline health check and restore
feature
add 184bc66 [STREAMPIPES-374] Improve management of SecretStaticProperty
values
add 7538b9a [STREAMPIPES-373] Modify expected input stream for dashboard
sinks
add db0c2d4 [hotfix] Remove failed pipeline element invocations from
running instance map
add 5dcd9ef [hotfix] Do not change original pipeline name in save dialog
add bd07903 [STREAMPIPES-375] Persist position of pipeline elements on
pipeline canvas
add f7945db [STREAMPIPES-272] Allow client to subscribe to processors and
sinks
add 2a8a74c [hotfix] Sort visualizable pipeline by pipeline name
add 31cd40d [hotfix] Change widgetType reference in data explorer widget
add 17aacf9 [hotfix] Reduce logging frequency in WorkerRestClient
add 461e165 [STREAMPIPES-372] Fix pipeline health check
add 2869672 [hotfix] Remove logging output of health check
add 2115359 [STREAMPIPES-372] Update health status of pipelines in
notifications dialog
add 4ef85a3 [STREAMPIPES-374] Fix bug in secrets visitor
add 4a3da0c [hotfix] Remove redundant call to display pipeline
add 53010ee [STREAMPIPES-377] Remove obsolete code from storage-rdf4j
module and corresponding REST interfaces
add 8845a64 [STREAMPIPES-378] Fix incorrect assignment of property
selectors
add 1af6ed8 [hotfix] Fix issue where force stop button appeared with
empty text
add b474327 [hotfix] Set initial size of status widget
add abc4413 Remove bom in csv files
add 72c4692 Change header in TestFileManager
add 34884f5 [STREAMPIPES-379] Runtime name is not shown in PLC4X S7
adapter
add a952973 [hotfix] Add files module to release config of ui
add 008b30e [hotfix] Add release notes for upcoming version 0.68.0
add 631fd1f [hotfix] Fixes broken links
add 1922e88 Merge pull request #44 from vesense/patch-1
add e2e0e87 [hotfix] Remove unused imports
add 68748fd Merge pull request #46 from vesense/patch-3
add 2fcc855 Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add bd5394e [maven-release-plugin] prepare branch rel/0.68.0
add 55e3137 [maven-release-plugin] prepare for next development iteration
add 3888ecf [hotfix] Bump sp.version in archetypes to next development
version
add 4219942 [hotfix] Extract visualizable pipelines independent from
current user
add 62ade4d [hotfix] Increase space between buttons in data explorer
overview
add 4c5554b [STREAMPIPES-299] Avoid null values of unselected static
property alternatives
add 8ab792d [STREAMPIPES-275] Deactivate yet unsupported options of
pipeline element template builder
add cb8bc23 [hotfix] Add mqtt transport dependency to Maven archetype poms
add 6662d21 [hotfix] Update Spring Boot version in archetypes
add de0eef9 [hotfix] Update Maven archetype for data streams
add b57ac75 [hotfix] Remove unused imports
add bd2735c Merge pull request #45 from vesense/patch-2
new 9f18861 Merge branch 'dev' into STREAMPIPES-349
new ddb7ba4 Remove old code
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
README.md | 2 +-
RELEASE_NOTES.md | 95 ++++-
.../pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 9 +-
.../archetype-resources/src/main/java/Init.java | 1 +
.../pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 4 +-
.../archetype-resources/src/main/java/Init.java | 1 +
.../streampipes-archetype-pe-sinks-flink/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 9 +-
.../archetype-resources/src/main/java/Init.java | 2 +
.../streampipes-archetype-pe-sinks-jvm/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 4 +-
.../archetype-resources/src/main/java/Init.java | 2 +
.../streampipes-archetype-pe-sources/pom.xml | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 9 +-
.../archetype-resources/src/main/java/Init.java | 3 +-
.../java/pe/source.__packageName__/DataSource.java | 41 --
.../__classNamePrefix__Stream.java | 2 +-
docker-compose.yml | 1 -
pom.xml | 2 +-
streampipes-backend/pom.xml | 14 +-
.../backend/StreamPipesBackendApplication.java | 117 ++++--
.../backend/StreamPipesResourceConfig.java | 8 +-
streampipes-client/pom.xml | 20 +-
.../streampipes/client/api/DataProcessorApi.java | 41 ++
.../apache/streampipes/client/api/DataSinkApi.java | 28 ++
.../streampipes/client/model/InputStreamIndex.java | 19 +-
streampipes-code-generation/pom.xml | 10 +-
streampipes-commons/pom.xml | 2 +-
streampipes-config/pom.xml | 4 +-
streampipes-connect-container-master/pom.xml | 10 +-
.../master/management/AdapterMasterManagement.java | 65 ++-
.../management/WorkerAdministrationManagement.java | 4 +-
.../master/management/WorkerRestClient.java | 123 ++----
.../master/rest/AbstractAdapterResource.java | 18 +-
.../container/master/rest/AdapterResource.java | 93 ++--
.../master/rest/AdapterTemplateResource.java | 19 +-
.../container/master/rest/DescriptionResource.java | 59 ++-
.../container/master/rest/GuessResource.java | 32 +-
.../master/rest/RuntimeResolvableResource.java | 8 +-
.../container/master/rest/SourcesResource.java | 33 +-
.../container/master/rest/UnitResource.java | 17 +-
.../container/master/rest/WelcomePageMaster.java | 46 +-
.../master/util/AdapterEncryptionService.java | 33 +-
.../management}/AdapterMasterManagementTest.java | 31 +-
.../AdapterTemplateMasterManagementTest.java | 14 +-
.../management}/DescriptionManagementTest.java | 19 +-
.../master/management/SourcesManagementTest.java | 0
.../management/UnitMasterManagementTest.java | 0
.../master/management/WorkerRestClientTest.java | 35 +-
streampipes-connect-container-worker/pom.xml | 4 +-
streampipes-connect-container/pom.xml | 12 +-
streampipes-connect/pom.xml | 30 +-
streampipes-container-base/pom.xml | 2 +-
streampipes-container-embedded/pom.xml | 4 +-
streampipes-container-extensions/pom.xml | 12 +-
streampipes-container-standalone/pom.xml | 6 +-
streampipes-container/pom.xml | 12 +-
.../api/InvocablePipelineElementResource.java | 13 +
.../container/init/RunningInstances.java | 14 +
streampipes-data-explorer/pom.xml | 12 +-
streampipes-dataformat-cbor/pom.xml | 6 +-
streampipes-dataformat-fst/pom.xml | 6 +-
streampipes-dataformat-json/pom.xml | 6 +-
streampipes-dataformat-smile/pom.xml | 6 +-
streampipes-dataformat/pom.xml | 4 +-
streampipes-logging/pom.xml | 2 +-
streampipes-maven-plugin/pom.xml | 2 +-
streampipes-measurement-units/pom.xml | 4 +-
streampipes-messaging-jms/pom.xml | 4 +-
streampipes-messaging-kafka/pom.xml | 4 +-
streampipes-messaging-mqtt/pom.xml | 4 +-
streampipes-messaging/pom.xml | 4 +-
streampipes-model-client/pom.xml | 4 +-
.../model/client/messages/AutocompleteItem.java | 52 ---
.../model/client/messages/AutocompleteResult.java | 51 ---
streampipes-model-shared/pom.xml | 2 +-
streampipes-model/pom.xml | 14 +-
.../model/base/AbstractStreamPipesEntity.java | 9 +
.../streampipes/model/canvas/CanvasPosition.java | 25 +-
.../model/canvas/PipelineCanvasComment.java | 31 +-
.../PipelineCanvasMetadata.java} | 64 +--
.../model/canvas/PipelineElementMetadata.java | 30 +-
.../model/connect/adapter/AdapterDescription.java | 13 +
.../connect/adapter/AdapterStreamDescription.java | 11 +
.../model/dashboard/DashboardEntity.java | 1 -
.../streampipes/model/dashboard/DashboardItem.java | 11 +-
.../model/dashboard/DashboardWidgetModel.java | 47 +--
.../model/dashboard/VisualizablePipeline.java | 20 +-
.../streampipes/model/pipeline/Pipeline.java | 22 +
.../model/pipeline/PipelineHealthStatus.java | 9 +-
.../PipelinePreviewModel.java} | 44 +-
.../quality/EventPropertyQualityRequirement.java | 10 +
.../streampipes/model/runtime/SchemaInfo.java | 9 +
.../streampipes/model/schema/EventProperty.java | 21 +
.../streampipes/model/schema/EventSchema.java | 8 +
.../staticproperty/StaticPropertyAlternative.java | 2 +-
streampipes-performance-tests/pom.xml | 10 +-
streampipes-pipeline-management/pom.xml | 36 +-
.../manager/execution/http/GraphSubmitter.java | 9 +-
.../manager/execution/http/PipelineExecutor.java | 63 ++-
.../execution/http/PipelineStorageService.java | 88 ++--
.../streampipes/manager/file/FileManager.java | 29 ++
.../health/PipelineElementEndpointHealthCheck.java | 35 +-
.../manager/health/PipelineHealthCheck.java | 193 +++++++++
.../matching/PipelineVerificationHandler.java | 21 +-
.../monitoring/pipeline/TopicInfoCollector.java | 5 +-
.../streampipes/manager/operations/Operations.java | 20 +-
.../manager/preview/ActivePipelinePreviews.java | 63 +++
.../manager/preview/PipelinePreview.java | 125 ++++++
.../streampipes/manager/secret/ISecretHandler.java | 7 +-
.../manager/secret/SecretDecrypter.java | 32 +-
.../manager/secret/SecretEncrypter.java | 34 +-
.../streampipes/manager/secret/SecretProvider.java | 19 +-
.../SecretService.java} | 43 +-
.../streampipes/manager/secret/SecretVisitor.java | 118 ++++++
.../manager/setup/CouchDbInstallationStep.java | 1 -
.../streampipes/manager/file/TestFileManager.java | 64 +++
.../streampipes/manager/pipeline/StopPipeline.java | 33 --
streampipes-platform-services/pom.xml | 16 +-
streampipes-rest-shared/pom.xml | 6 +-
streampipes-rest/pom.xml | 24 +-
.../rest/impl/AbstractRestResource.java | 10 -
.../apache/streampipes/rest/impl/AutoComplete.java | 46 +-
.../streampipes/rest/impl/OntologyContext.java | 75 ----
.../streampipes/rest/impl/OntologyKnowledge.java | 270 ------------
...Cache.java => PipelineCanvasMetadataCache.java} | 22 +-
.../rest/impl/PipelineCanvasMetadataResource.java | 106 +++++
.../rest/impl/PipelineElementPreview.java | 64 +++
.../streampipes/rest/impl/PipelineResource.java | 20 +-
.../rest/impl/dashboard/VisualizablePipeline.java | 90 ++--
.../impl/nouser/PipelineElementImportNoUser.java | 12 +-
.../rest/impl/nouser/PipelineNoUserResource.java | 2 +-
.../rest/management/PipelineManagement.java | 5 +-
streampipes-sdk/pom.xml | 8 +-
.../sdk/extractor/AbstractParameterExtractor.java | 3 +-
streampipes-serializers-json/pom.xml | 10 +-
.../serializers/json/AdapterSerializer.java | 14 +-
streampipes-serializers-jsonld/pom.xml | 10 +-
streampipes-sources/pom.xml | 4 +-
streampipes-storage-api/pom.xml | 6 +-
.../streampipes/storage/api/IAdapterStorage.java | 2 +-
.../streampipes/storage/api/INoSqlStorage.java | 8 +-
...ge.java => IPipelineCanvasMetadataStorage.java} | 14 +-
.../streampipes/storage/api/ITripleStorage.java | 2 -
.../storage/api/IVisualizablePipelineStorage.java | 30 --
streampipes-storage-couchdb/pom.xml | 12 +-
.../storage/couchdb/CouchDbStorageManager.java | 20 +-
.../storage/couchdb/impl/AdapterStorageImpl.java | 7 +-
...java => PipelineCanvasMetadataStorageImpl.java} | 38 +-
.../impl/VisualizablePipelineStorageImpl.java | 43 --
.../streampipes/storage/couchdb/utils/Utils.java | 113 ++---
streampipes-storage-management/pom.xml | 8 +-
.../storage/management/StorageManager.java | 14 +-
streampipes-storage-rdf4j/pom.xml | 12 +-
.../streampipes/storage/Rdf4JStorageManager.java | 38 +-
.../storage/rdf4j/config/Rdf4JConfig.java | 4 -
.../rdf4j/filter/BackgroundKnowledgeFilter.java | 84 ----
.../streampipes/storage/rdf4j/filter/Filter.java | 15 +-
.../rdf4j/impl/BackgroundKnowledgeStorageImpl.java | 467 ---------------------
.../storage/rdf4j/impl/ContextStorageImpl.java | 131 ------
.../rdf4j/ontology/ClassHierarchyExecutor.java | 116 -----
.../rdf4j/ontology/ConceptUpdateExecutor.java | 52 ---
.../rdf4j/ontology/InstanceUpdateExecutor.java | 51 ---
.../rdf4j/ontology/PropertyUpdateExecutor.java | 48 ---
.../storage/rdf4j/ontology/QueryExecutor.java | 62 ---
.../storage/rdf4j/ontology/RangeQueryExecutor.java | 149 -------
.../storage/rdf4j/ontology/UpdateExecutor.java | 37 --
.../storage/rdf4j/sparql/QueryBuilder.java | 294 +------------
.../rdf4j/util/BackgroundKnowledgeUtils.java | 92 ----
streampipes-test-utils/pom.xml | 4 +-
streampipes-user-management/pom.xml | 6 +-
streampipes-vocabulary/pom.xml | 2 +-
streampipes-wrapper-distributed/pom.xml | 10 +-
streampipes-wrapper-flink/pom.xml | 4 +-
.../wrapper/flink/consumer/MqttFlinkConsumer.java | 2 -
.../wrapper/flink/sink/MqttFlinkProducer.java | 2 -
streampipes-wrapper-kafka-streams/pom.xml | 4 +-
streampipes-wrapper-python/pom.xml | 2 +-
streampipes-wrapper-siddhi/pom.xml | 21 +-
.../wrapper/siddhi/SiddhiQueryBuilder.java | 9 +
.../wrapper/siddhi/constants/SiddhiConstants.java | 1 +
.../query/{LimitClause.java => OffsetClause.java} | 14 +-
.../wrapper/siddhi/query/SiddhiQuery.java | 15 +
streampipes-wrapper-spark/pom.xml | 8 +-
streampipes-wrapper-standalone/pom.xml | 4 +-
streampipes-wrapper/pom.xml | 10 +-
ui/deployment/rel/config.yml | 3 +-
ui/src/app/add/add.component.ts | 22 +-
.../endpoint-item/endpoint-item.component.html | 2 +-
.../adapter-description.component.html | 15 +-
.../adapter-description.component.ts | 10 -
.../data-marketplace.component.html | 62 ++-
.../data-marketplace/data-marketplace.component.ts | 16 +-
.../existing-adapters.component.html | 126 ++++++
.../existing-adapters.component.scss} | 19 +-
.../existing-adapters.component.ts | 96 +++++
ui/src/app/connect/connect.module.ts | 2 +
.../delete-adapter-dialog.component.html} | 0
.../delete-adapter-dialog.component.ts} | 20 +-
.../delete-pipeline-dialog.component.scss | 0
.../connect/services/data-marketplace.service.ts | 37 +-
ui/src/app/core-model/gen/streampipes-model.ts | 125 +++++-
.../datalake/datalake-rest.service.ts | 43 +-
.../image-categorize/image-categorize.component.ts | 4 +-
.../static-mapping-nary.component.ts | 17 +-
.../static-mapping-unary.component.ts | 14 +-
.../static-mapping/static-mapping.ts | 28 +-
.../components/grid/dashboard-grid.component.ts | 2 -
.../widget/dashboard-widget.component.css | 3 +-
.../widget/dashboard-widget.component.html | 51 ++-
.../widget/dashboard-widget.component.ts | 147 ++++---
.../widgets/status/status-widget.component.ts | 5 +
ui/src/app/dashboard/dashboard.component.ts | 9 +-
ui/src/app/dashboard/dashboard.module.ts | 4 +
.../add-visualization-dialog.component.html | 5 +-
.../add-visualization-dialog.component.ts | 66 +--
ui/src/app/dashboard/services/dashboard.service.ts | 19 +-
.../{resize.service.ts => edit-mode.service.ts} | 14 +-
.../services/refresh-dashboard.service.ts | 6 +-
...esize.service.ts => reload-pipeline.service.ts} | 14 +-
ui/src/app/dashboard/services/resize.service.ts | 6 +-
...data-explorer-dashboard-overview.component.html | 4 +-
...data-explorer-dashboard-overview.component.scss | 6 +-
.../data-explorer-dashboard-widget.component.html | 8 +-
.../pipeline-assembly.component.html | 19 +-
.../pipeline-assembly.component.scss | 10 +
.../pipeline-assembly.component.ts | 77 +++-
.../pipeline-element-options.component.html | 7 +-
.../pipeline-element-preview.component.html} | 20 +-
.../pipeline-element-preview.component.scss} | 27 +-
.../pipeline-element-preview.component.ts | 68 +++
...pipeline-element-template-config.component.html | 16 +-
.../components/pipeline/pipeline.component.html | 11 +-
.../components/pipeline/pipeline.component.ts | 125 ++++--
.../save-pipeline/save-pipeline.component.html | 4 +-
.../save-pipeline/save-pipeline.component.ts | 43 +-
ui/src/app/editor/editor.component.html | 2 +-
ui/src/app/editor/editor.component.scss | 4 +-
ui/src/app/editor/editor.module.ts | 2 +
ui/src/app/editor/services/editor.service.ts | 41 +-
ui/src/app/editor/services/jsplumb.service.ts | 24 +-
.../services/pipeline-positioning.service.ts | 76 +++-
.../actions/pipeline-actions.component.html | 3 +-
.../pipeline-overview.component.html | 19 +
.../pipeline-overview.component.scss | 43 +-
.../pipeline-overview.component.ts | 7 +-
.../pipeline-notifications.component.html} | 19 +-
.../pipeline-notifications.component.scss} | 16 +-
.../pipeline-notifications.component.ts} | 48 ++-
.../pipeline-status-dialog.component.html | 65 ++-
.../pipeline-status-dialog.component.scss | 34 +-
.../pipeline-status-dialog.component.ts | 68 ++-
.../model/pipeline-model.ts} | 6 +-
ui/src/app/pipelines/pipelines.component.html | 6 +
ui/src/app/pipelines/pipelines.module.ts | 4 +-
.../services/pipeline-operations.service.ts | 77 ++--
.../apis/pipeline-canvas-metadata.service.ts | 65 +++
.../app/platform-services/apis/pipeline.service.ts | 13 +-
ui/src/app/platform-services/platform.module.ts | 2 +
ui/src/scss/sp/pipeline-element-options.scss | 14 +-
262 files changed, 3802 insertions(+), 4067 deletions(-)
delete mode 100644
archetypes/streampipes-archetype-pe-sources/src/main/resources/archetype-resources/src/main/java/pe/source.__packageName__/DataSource.java
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/model/InputStreamIndex.java
(77%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java
=>
streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/rest/AbstractAdapterResource.java
(66%)
rename
streampipes-connect-container-master/src/test/java/org/{streampipes/connect/container/master
=>
apache/streampipes/connect/container/master/management}/AdapterMasterManagementTest.java
(86%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/AdapterTemplateMasterManagementTest.java
(99%)
rename
streampipes-connect-container-master/src/test/java/org/{streampipes/connect/container/master
=>
apache/streampipes/connect/container/master/management}/DescriptionManagementTest.java
(94%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/SourcesManagementTest.java
(100%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/UnitMasterManagementTest.java
(100%)
rename streampipes-connect-container-master/src/test/java/org/{ =>
apache}/streampipes/connect/container/master/management/WorkerRestClientTest.java
(86%)
delete mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/messages/AutocompleteItem.java
delete mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/messages/AutocompleteResult.java
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/QueryParams.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/canvas/CanvasPosition.java
(72%)
copy
ui/src/app/core-ui/image/components/image-container/image-container.component.css
=>
streampipes-model/src/main/java/org/apache/streampipes/model/canvas/PipelineCanvasComment.java
(65%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{dashboard/DashboardEntity.java
=> canvas/PipelineCanvasMetadata.java} (55%)
copy
streampipes-dataformat-fst/src/main/java/org/apache/streampipes/dataformat/fst/FstDataFormatFactory.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/canvas/PipelineElementMetadata.java
(65%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineApi.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/pipeline/PipelineHealthStatus.java
(87%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{message/SuccessMessage.java
=> preview/PipelinePreviewModel.java} (59%)
copy
streampipes-client/src/main/java/org/apache/streampipes/client/serializer/Serializer.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineElementEndpointHealthCheck.java
(53%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/ActivePipelinePreviews.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/preview/PipelinePreview.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/messaging/IMessageListener.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/ISecretHandler.java
(81%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/notifications/NotificationListener.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretDecrypter.java
(54%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/notifications/NotificationListener.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretEncrypter.java
(53%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/exceptions/ElementNotFoundException.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretProvider.java
(69%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{matching/GroundingSelector.java
=> secret/SecretService.java} (51%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/secret/SecretVisitor.java
create mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/file/TestFileManager.java
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/StopPipeline.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyContext.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyKnowledge.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{PipelineCache.java
=> PipelineCanvasMetadataCache.java} (63%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCanvasMetadataResource.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementPreview.java
copy
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/{CRUDStorage.java
=> IPipelineCanvasMetadataStorage.java} (77%)
delete mode 100644
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IVisualizablePipelineStorage.java
copy
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/{PipelineElementTemplateStorageImpl.java
=> PipelineCanvasMetadataStorageImpl.java} (50%)
delete mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/VisualizablePipelineStorageImpl.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/filter/BackgroundKnowledgeFilter.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/impl/BackgroundKnowledgeStorageImpl.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/impl/ContextStorageImpl.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/ClassHierarchyExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/ConceptUpdateExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/InstanceUpdateExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/PropertyUpdateExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/QueryExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/RangeQueryExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/ontology/UpdateExecutor.java
delete mode 100644
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/util/BackgroundKnowledgeUtils.java
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/{LimitClause.java
=> OffsetClause.java} (75%)
create mode 100644
ui/src/app/connect/components/data-marketplace/existing-adapters/existing-adapters.component.html
copy ui/src/app/{files/components/file-overview/file-overview.component.scss
=>
connect/components/data-marketplace/existing-adapters/existing-adapters.component.scss}
(88%)
create mode 100644
ui/src/app/connect/components/data-marketplace/existing-adapters/existing-adapters.component.ts
copy
ui/src/app/{pipelines/dialog/delete-pipeline/delete-pipeline-dialog.component.html
=> connect/dialog/delete-adapter-dialog/delete-adapter-dialog.component.html}
(100%)
copy
ui/src/app/{pipelines/dialog/delete-pipeline/delete-pipeline-dialog.component.ts
=> connect/dialog/delete-adapter-dialog/delete-adapter-dialog.component.ts}
(81%)
copy ui/src/app/{pipelines/dialog/delete-pipeline =>
connect/dialog/delete-adapter-dialog}/delete-pipeline-dialog.component.scss
(100%)
copy ui/src/app/dashboard/services/{resize.service.ts => edit-mode.service.ts}
(78%)
copy ui/src/app/dashboard/services/{resize.service.ts =>
reload-pipeline.service.ts} (78%)
copy
ui/src/app/{dashboard/components/widgets/bar-race/bar-race-widget.component.html
=>
editor/components/pipeline-element-preview/pipeline-element-preview.component.html}
(60%)
copy ui/src/app/{add/components/endpoint-item/endpoint-item.component.scss =>
editor/components/pipeline-element-preview/pipeline-element-preview.component.scss}
(75%)
create mode 100644
ui/src/app/editor/components/pipeline-element-preview/pipeline-element-preview.component.ts
copy ui/src/app/{connect/dialog/adapter-export/adapter-export-dialog.html =>
pipelines/dialog/pipeline-notifications/pipeline-notifications.component.html}
(75%)
copy
ui/src/app/pipelines/dialog/{pipeline-status/pipeline-status-dialog.component.scss
=> pipeline-notifications/pipeline-notifications.component.scss} (85%)
copy
ui/src/app/{pipeline-details/components/status/pipeline-status.component.ts =>
pipelines/dialog/pipeline-notifications/pipeline-notifications.component.ts}
(51%)
copy ui/src/app/{platform-services/contants/platform-services.constants.ts =>
pipelines/model/pipeline-model.ts} (94%)
create mode 100644
ui/src/app/platform-services/apis/pipeline-canvas-metadata.service.ts
