This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch STREAMPIPES-245
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git.
from 6a82830 [STREAMPIPES-245] Add initial version of pipeline monitoring
feature
add 6543820 Fix CSV export for missing columns in database
add 1973024 Add grouping to maps dashboard widget
add 161d5b0 Fix table of content link
add 8a53355 Add release notes for upcoming version
add b762769 [STREAMPIPES-246] Remove obsolete module
streampipes-app-file-export
add 0821dae [STREAMPIPES-247] Fix bug that caused alternative static
properties to be validated incorrectly
add 5714f20 [hotfix] Properly reload pipeline element recommendations
add d4bfb14 [maven-release-plugin] rollback the release of
streampipes-parent-0.67.1
add b75e4fd Revert "[maven-release-plugin] rollback the release of
streampipes-parent-0.67.1"
add 6ddd4ed [STREAMPIPES-249] Add classes for more compact data processor
and sink definition
add b27be36 [STREAMPIPES-243] Configuration of And Processor is broken
add 7a82857 [STREAMPIPES-231] Images are not shown in Data Explorer
add 58c6c5c Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add 4491819 Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add c7a41ba Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add bc87abc Activate image labeling app
add 36c86b8 Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add 6cdeb31 [STREAMPIPES-250] Refactor Siddhi wrapper
add 6e1c9ef [STREAMPIPES-249] Add compact data sink
add 8c5beb8 [STREAMPIPES-250] Refactor Siddhi Wrapper
add da995b5 [STREAMPIPES-250] Improve Siddhi wrapper
add a6ac30a Update Jenkinsfile
add 8d79f57 Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add 8617c35 [STREAMPIPES-250] Add Siddhi EPL object model for select
statements
add 16388c1 [hotfix] use correct build-args in CI
add f015efc Merge branch 'dev' of github.com:apache/incubator-streampipes
into dev
add 563a3a7 [STREAMPIPES-250] Extend Siddhi object model
add 4b6e64b [hotfix] Fix bug in static mapping property renderer
add f4dcb7d [hotfix] Consider alternatives for mapping property
calculation
add 84ed1cc [hotfix] Fix wrong property access in property selector
service
add b01ce7c [STREAMPIPES-252] add mqtt transport protocol
add 4d3cdcd [STREAMPIPES-252] add SP_PRIORITIZED_PROTOCOL env variable
add f18f90d [STREAMPIPES-253] add property scope HEADER_PROPERTY
add f97f0bb [hotfix] use adoptopenjdk/openjdk8-openj9:alpine base image
add 9eaea79 [STREAMPIPES-254] add correction value rule to preprocessing
pipeline in connect adapters
add a9fe97a Move line chart labeling to data explorer module
add a66efe6 [STREAMPIPES-234] Integrated label component of image labeling
add abc7f8c Merge branch 'dev' into STREAMPIPES-234
add cd7559b Merge branch 'dev' into STREAMPIPES-234
add 3000e99 [STREAMPIPES-234] Labeled time intervals can now be changed
add d3fde33 Merge branch 'dev' into STREAMPIPES-234
add 4332e1e Merge branch 'dev' into STREAMPIPES-234
add edbc416 Move labels component
add 70cc1b1 Create configure labels component
add 6d5a4a4 Barebone impl of Label-API
add e28b4f8 Merge branch 'timeseries-labeling' into STREAMPIPES-234
add d0294a4 Added Category class
add df03e79 Merge pull request #26 from heymarco/STREAMPIPES-234
add e6bf2a4 Add label model to ui
add c80b35c Add color picker to configure label component
add 69cbceb Enable to add and delete labels
add 46cc9c9 Edit categories in label configuration
add 420c1c3 Add delete functionality for label categories
add 0ae7c55 Labeling api WIP
add 3207736 Adapted routing for labeling api and changed category class
add 820b546 Merge pull request #27 from heymarco/STREAMPIPES-234
add 958f50f Store categories and label in db
add c4635da Finish first version that persists labels and categories
add c7fff83 Refactor line chart
add acd61fe Time-series explorer supports now new label colors
add bdd73c3 Merge branch 'dev' into STREAMPIPES-234
add d28ecfd Rework image labeling
add 0cf97fd Image labeling works now with new label model
add 80396a8 Fix image labeling component
add 440ef73 Merge branch 'STREAMPIPES-234' into dev
add d8b77ee Add headers to fix build
add 8a4109a Add missing header to label service in ui
add e19a2cc Merge remote-tracking branch 'refs/remotes/origin/dev' into
dev
add a87727b [hotfix] add missing fields
add 72fbcf0 [STREAMPIPES-254] fix ClassCastException from long to double
add 7ded342 [STREAMPIPES-254] additional changes to ClassCastException
add b0b157a [hotfix] use adoptopenjdk/openjdk8-openj9:alpine base image
for all Dockerfiles
add 8f1e08b Merge branch 'dev' into STREAMPIPES-252
add 2c4324f [STREAMPIPES-252] add SP_PRIORITIZED_PROTOCOL to .idea run
config
add 007bd04 [STREAMPIPES-252] add mqtt transport protocol to flink wrapper
add e994228 [STREAMPIPES-252] remove prioritizedProtocol helper from sdk,
fixed typo
add fbaeb08 [STREAMPIPES-252] add mqtt transport protocol to archetypes
add a4940fc [hotfix] temporary commented tess in GroundingServiceTest
add 30b937d [hotfix] update to new syntax to set env files in github
actions
add afa6a18 [STREAMPIPES-252] add activemq as default hostname for mqtt
add 1040204 [STREAMPIPES-253] use event schema from adapter description
if exists
add 3f3233e Started to merger connect master REST api into backed
add 292b6e6 Start to harmonize connect REST API
add a7347e9 First minimal version of the new connect master API is working
add 4f535a7 [STREAMPIPES-257] finish integration of connect master API
into backend
add c52a297 [STREAMPIPES-257] Remove connect master container
add 3bedfc1 Remove spring boot plugin from connect master container
add 427a7ef Change connect master route in nginx config
add 591efa4 Fix route to register connect worker
add bbfddd9 Change route of connect master
add 30f2eec Remove consul route from nginx
add 8b2d617 [STREAMPIPES-260] add connection retry option for config and
service registration
add b1a7af8 [STREAMPIPES-252] add mqtt transport protocol support to
dataset adapters
add a31b87f [STREAMPIPES-252] clean up comments
add 5cec898 [STREAMPIPES-263] add ExtensionsModelSubmitter for bundled
extensions module
add ccdf2ae Add missing license headers to a few files
add f5587f8 Add UI config for release 0.66.0
add d6e81e0 Update settings to configure release validation
add 737029e add license header
add ffd8b65 Fix bug in prebuild script
add 3bbe273 Explicitly add dist subdirectories to gitignore to avoid
problems with rat plugin
add 3d5e33e [STREAMPIPES-110] Temporarily disable dependency-check maven
plugin
add 8cf6f46 Modify docker-compose version
add cef2d67 Fix bug in prebuild script
add 7617b2b Use 0.66.0-SNAPSHOT as sp.version in archetypes
add edb43f6 Set sp.version in archetypes to 0.66.0
add 73a3272 Set streampipes version to 0.66.0
add d606f2c Perform some cleanup
add 72f394a Modify release settings in pom
add 5a989fc [maven-release-plugin] prepare release release/0.66.0
add 5444d20 [maven-release-plugin] prepare for next development iteration
add 81e8693 Revert to development version 0.66.0-SNAPSHOT
add 7aada08 Cleanup properties files
add 09775ad Update package.json
add ebac9f4 Fix bug in app overview module
add 71cc882 Add NotificationCount view to installation process
add 60c697e Import Roboto font in angular.json
add 47e22d7 Add assembly profile
add b8c23e6 [maven-release-plugin] prepare release release/0.66.0
add cf18d51 Kafka producer and consumer
add 8b69d44 Merge branch 'dev' of github.com:apache/incubator-streampipes
into kafka-auth
add ab864f4 Merge branch 'dev' into kafka-auth
add 99fcb8e Removed legacy ui code
add 999cc60 Removed legacy ui code
add 499ef66 Merge branch 'dev' into kafka-auth
add 1324b37 Fix v1-api route
add fe213d1 Deleted streampipes-app-file-export/
add 82b79fd Merge remote-tracking branch 'main/dev' into kafka-auth
add df9e394 Removed DISCLAIMER-WIP
add a18e426 Merge pull request #28 from heymarco/kafka-auth
add cc29299 Merge branch 'dev' into bundle
add 24c7699 [hotfix] add configuration option for RDF4J storage dir
add b8f46b6 [hotfix] minor renaming of config option
add 67940fc [STREAMPIPES-263] add logging message for adapter
registration process
add 284ec2c [STREAMPIPES-174] add debug init for model submitter
add bba1ac8 [STREAMPIPES-268] Bump Spring Boot version to 2.4.1 and
Spring version to 5.3.2
add 919486f [STREAMPIPES-269] Use JSON for container-core serialization
add 3914cf4 [STREAMPIPES-269] Split streampipes-serializers into separate
modules for JSON and JSON-LD serialization
add f020e2a [STREAMPIPES-269] Remove JSON-LD serializer from container
modules
add 806a674 [STREAMPIPES-269] Isolate empire dependencies, bump empire
version to 1.9.14
add fbef2f7 [STREAMPIPES-268] Bump dependencies for Kafka and ActiveMQ
add addedc3 [STREAMPIPES-270] Update Angular to version 11
add b0b48ce [STREAMPIPES-271] Fix unit transformation dialog, add rest
interface to receive measurement units
add 7abe048 [STREAMPIPES-248] Auto-restart pipelines that are still
running when system is stopped
add 631c078 [STREAMPIPES-273] Remove DataSource concept
add 8e464df [STREAMPIPES-274] Add new modules for StreamPipes Client and
API
add 97f8af3 [STREAMPIPES-272] Clean up Rest API
add 118526e [STREAMPIPES-275] Add basic functionality to support pipeline
element templates
add d723e61 [STREAMPIPES-275] Minor bug fix
add 87a47b5 [STREAMPIPES-276] Add simple token-based API authentication
add b33e3f4 [STREAMPIPES-272] Add initial version of StreamPipes client
add 81fddb0 [STREAMPIPES-280] Extract data explorer queries into own
module and individual classes
add 97fad9e [STREAMPIPES-268] Bump Influxdb version
add f2ca5f5 [STREAMPIPES-272] Improve client API
add 6fcb15b [STREAMPIPES-275] Add support for pipeline element templates
in UI
add cbe9e3f [STREAMPIPES-287] Support group by clause in Siddhi wrapper
add 84beedd [STREAMPIPES-293] Extend Siddhi wrapper with additional
concepts
add 2502059 [STREAMPIPES-293] Bump Siddhi version
add 1b767af [hotfix] Change logging level of Kafka dependencies
add 613bb88 [STREAMPIPES-294] Add initial version of wordcloud
visualization
add 9b02888 [STREAMPIPES-295] Add HTTP endpoint adapter to connect worker
add 8d089b7 [hotfix] Fix bug in adapter deletion
add 19d16a3 [STREAMPIPES-294] Finish wordcloud visualization
add cd9b5c7 [STREAMPIPES-296] Add status visualization to live dashboard
add b968ff6 [STREAMPIPES-279] Add bar race chart
add b1ddbc7 [STREAMPIPES-279] Add stacked line chart visualization
add 4ff1ceb [hotfix] Extend SDK
add 7003535 [STREAMPIPES-272] Add subscription feature to data processor
api
add 6ad2c30 [STREAMPIPES-279] Add minor layout improvements to dashboard
add 8b31fe7 [STREAMPIPES-272] Add API documentation
add e2823ab Fixes broken installer links
add 5efd810 Merge pull request #31 from pcnfernando/patch-1
add 0226d59 [STREAMPIPES-269] Refactor serializer of runtime options
endpoint
add 7d8509d Merge branch 'dev' into STREAMPIPES-272
add fe20530 [hotfix] Add missing license headers
add d3b8199 [hotfix] Remove StreamPipes logs resource
add b382ca7 [hotfix] Remove StreamPipes logs resource from core
add e50deb0 [STREAMPIPES-268] Update Jackson dependencies
add 4ca541f [STREAMPIPES-272] Modify path to OpenAPI configuration
add eb6b9f8 [STREAMPIPES-268] Resolve dependency convergence issue
add d9a991e [STREAMPIPES-272] Add javadoc to StreamPipes Client API
new 9383b70 Merge branch 'dev' into STREAMPIPES-245
new 74e1492 [STREAMPIPES-245] Refactor pipeline monitoring feature
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:
.github/workflows/build.yml | 53 +-
.gitlab-ci.yml | 2 +-
.../all_pipeline_elements_jvm.xml | 11 +
.idea/runConfigurations/backend.xml | 3 +
.idea/runConfigurations/connect_adapters.xml | 2 +-
.idea/runConfigurations/connect_master.xml | 16 -
.idea/runConfigurations/sinks_internal_jvm.xml | 2 +-
Jenkinsfile | 6 +-
README.md | 8 +-
RELEASE_NOTES.md | 95 +++
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../archetype-resources/src/main/java/Init.java | 1 +
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 5 +
.../archetype-resources/src/main/java/Init.java | 1 +
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../archetype-resources/src/main/java/Init.java | 1 +
.../main/resources/archetype-resources/Dockerfile | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 5 +
.../archetype-resources/src/main/java/Init.java | 1 +
.../main/resources/archetype-resources/Dockerfile | 2 +-
docker-compose.yml | 25 +-
pom.xml | 95 ++-
streampipes-app-file-export/pom.xml | 79 ---
.../app/file/export/ElasticsearchAppData.java | 83 ---
.../app/file/export/ElasticsearchConfig.java | 60 --
.../app/file/export/converter/JsonConverter.java | 65 ---
.../app/file/export/impl/Elasticsearch.java | 320 ----------
streampipes-backend/Dockerfile | 2 +-
streampipes-backend/pom.xml | 38 +-
.../backend/StreamPipesBackendApplication.java | 59 +-
.../backend/StreamPipesResourceConfig.java | 37 +-
.../src/main/resources/openapi.yaml | 34 ++
streampipes-backend/src/main/resources/shiro.ini | 18 +-
.../pom.xml | 39 +-
.../streampipes/client/StreamPipesClient.java | 155 +++++
.../streampipes/client/StreamPipesCredentials.java | 61 +-
.../client/annotation/NotYetImplemented.java | 10 +-
.../streampipes/client/api/AbstractClientApi.java | 77 +++
.../org/apache/streampipes/client/api/CRUDApi.java | 14 +-
.../streampipes/client/api/DataProcessorApi.java | 83 +++
.../apache/streampipes/client/api/DataSinkApi.java | 75 +++
.../streampipes/client/api/DataStreamApi.java | 99 ++++
.../apache/streampipes/client/api/PipelineApi.java | 108 ++++
.../client/api/PipelineElementTemplateApi.java | 63 ++
.../client/api/SupportsDataProcessorApi.java | 6 +-
.../client/api/SupportsDataSinkApi.java | 6 +-
.../client/api/SupportsDataStreamApi.java | 6 +-
.../client/api/SupportsPipelineApi.java | 6 +-
.../api/SupportsPipelineElementTemplateApi.java | 6 +-
.../streampipes/client/http/DeleteRequest.java | 51 ++
.../apache/streampipes/client/http/GetRequest.java | 51 ++
.../streampipes/client/http/HttpRequest.java | 115 ++++
.../streampipes/client/http/PostRequest.java | 64 ++
.../http/PostRequestWithPayloadResponse.java | 52 ++
.../http/PostRequestWithoutPayloadResponse.java | 47 ++
.../streampipes/client/http/header/Headers.java | 47 ++
.../streampipes/client/live/EventProcessor.java | 7 +-
.../streampipes/client/live/KafkaConfig.java | 27 +-
.../client/live/SubscriptionManager.java | 107 ++++
.../client/model/StreamPipesClientConfig.java | 76 +++
.../client/serializer/ListSerializer.java | 41 +-
.../client/serializer/ObjectSerializer.java | 22 +-
.../streampipes/client/serializer/Serializer.java | 28 +-
.../client/util/StreamPipesApiPath.java | 59 ++
.../streampipes/client/TestStreamPipesClient.java | 80 +++
streampipes-code-generation/pom.xml | 9 +
streampipes-commons/pom.xml | 8 -
.../java/org/apache/streampipes/commons/Utils.java | 36 --
.../commons/exceptions/SpException.java | 2 +-
streampipes-commons/src/main/resources/logback.xml | 3 +-
.../streampipes/config/backend/BackendConfig.java | 16 +-
.../config/backend/BackendConfigKeys.java | 4 +
.../config/backend/MessagingSettings.java | 45 +-
.../streampipes/config/backend/SpProtocol.java | 26 +-
.../streampipes/config/consul/ConsulSpConfig.java | 79 ++-
.../aarch64.Dockerfile | 26 -
.../arm.Dockerfile | 26 -
.../development/env | 20 -
streampipes-connect-container-master/pom.xml | 32 +-
.../master/init/AdapterMasterContainer.java | 48 --
.../init/AdapterMasterContainerResourceConfig.java | 46 --
.../master/management/AdapterMasterManagement.java | 84 +--
.../master/management/SourcesManagement.java | 25 +-
.../container/master/rest/AdapterResource.java | 2 +-
.../master/rest/AdapterTemplateResource.java | 2 +-
.../container/master/rest/DescriptionResource.java | 2 +-
.../container/master/rest/GuessResource.java | 2 +-
.../master/rest/RuntimeResolvableResource.java | 2 +-
.../container/master/rest/SourcesResource.java | 52 +-
.../container/master/rest/UnitResource.java | 2 +-
.../container/master/rest/WelcomePageMaster.java | 2 +-
.../master/rest/WorkerAdministrationResource.java | 2 +-
.../master/management/SourcesManagementTest.java | 30 +-
.../init/AdapterWorkerContainerResourceConfig.java | 1 +
.../management/HttpServerAdapterManagement.java | 50 ++
.../worker/management/MasterRestClient.java | 2 +-
.../worker/rest/HttpServerAdapterResource.java | 27 +-
.../connect/container/worker/utils/Utils.java | 38 +-
streampipes-connect-container/pom.xml | 2 +-
.../streampipes/connect/config/ConfigKeys.java | 4 +-
.../connect/config/ConnectContainerConfig.java | 19 +-
.../connect/init/AdapterContainerConfig.java | 4 +-
.../connect/management/AdapterDeserializer.java | 41 --
.../connect/management/AdapterUtilsTest.java | 2 +-
.../utils/ConnectContainerResourceTest.java | 175 ------
streampipes-connect/pom.xml | 12 +-
.../streampipes/connect/adapter/Adapter.java | 70 ++-
.../connect/adapter/GroundingService.java | 93 ++-
.../model/pipeline/AdapterPipelineElement.java | 2 +-
.../elements/SendToBrokerAdapterSink.java | 103 ++++
...ink.java => SendToBrokerReplayAdapterSink.java} | 25 +-
.../elements/SendToJmsAdapterSink.java | 34 +-
.../elements/SendToKafkaAdapterSink.java | 57 +-
.../elements/SendToMqttAdapterSink.java | 39 +-
.../TransformValueAdapterPipelineElement.java | 7 +-
.../value/CorrectionValueTransformationRule.java | 93 +++
.../transform/value/ValueEventTransformer.java | 38 +-
.../connect/adapter/GroundingServiceTest.java | 101 ++--
.../pom.xml | 22 +-
.../extensions/ExtensionsModelSubmitter.java | 162 ++++++
.../extensions/ExtensionsResourceConfig.java | 48 ++
.../src/main/resources/banner.txt | 2 +-
.../PipelineElementContainerResourceConfig.java | 19 +-
.../standalone/init/StandaloneModelSubmitter.java | 2 +-
streampipes-container/pom.xml | 8 +-
...t.java => AbstractPipelineElementResource.java} | 157 ++---
...a => DataProcessorPipelineElementResource.java} | 10 +-
...t.java => DataSinkPipelineElementResource.java} | 50 +-
.../api/DataStreamPipelineElementResource.java | 103 ++++
....java => InvocablePipelineElementResource.java} | 60 +-
...eElement.java => PipelineTemplateResource.java} | 5 +-
.../streampipes/container/api/SepElement.java | 151 -----
.../container/declarer/DataStreamDeclarer.java | 5 +-
.../declarer/SemanticEventProducerDeclarer.java | 1 +
.../streampipes/container/html/JSONGenerator.java | 1 +
.../container/html/model/Description.java | 9 +
.../html/page/EventConsumerWelcomePage.java | 98 ++--
.../html/page/EventProcessingAgentWelcomePage.java | 98 ++--
.../html/page/EventProducerWelcomePage.java | 126 ++--
.../html/page/WelcomePageGeneratorImpl.java | 129 ++--
.../container/init/DeclarersSingleton.java | 56 +-
.../streampipes/container/init/ModelSubmitter.java | 6 +-
.../ExtensionsConfig.java} | 13 +-
.../consul/ConsulServiceRegistrationBody.java | 90 +++
.../model/consul/HealthCheckConfiguration.java | 44 +-
.../container/transform/Transformer.java | 49 --
.../streampipes/container/util/ConsulUtil.java | 302 ++++++----
.../streampipes/container/util/DeclarerUtils.java | 46 --
.../apache/streampipes/container/util/Util.java | 13 -
.../html/page/WelcomePageGeneratorImplTest.java | 133 -----
.../pom.xml | 22 +-
.../dataexplorer/DataLakeManagementV3.java | 297 ++++++++++
.../dataexplorer}/DataLakeNoUserManagementV3.java | 17 +-
.../autoagg/AbstractAutoAggregationQuery.java | 70 +++
.../autoagg/FromNowAutoAggregationQuery.java | 49 ++
.../autoagg/GroupedAutoAggregationQuery.java | 48 ++
.../autoagg/TimeBoundAutoAggregationQuery.java | 49 ++
.../streampipes/dataexplorer/model/Order.java | 21 +-
.../param/AggregatedTimeBoundQueryParams.java | 50 ++
.../param/AggregatedTimeUnitQueryParams.java | 51 ++
.../dataexplorer/param/CountQueryParams.java | 5 +-
.../GroupedAggregatedTimeBoundQueryParams.java | 46 ++
.../dataexplorer/param/GroupedQueryParams.java | 35 +-
.../dataexplorer/param/PagingQueryParams.java | 95 +++
.../dataexplorer/param/QueryParams.java | 18 +-
.../dataexplorer/param/TimeBoundQueryParams.java | 33 +-
.../dataexplorer/param/TimeUnitQueryParams.java | 31 +-
.../dataexplorer/query/DataExplorerQuery.java | 84 +++
.../query/DataExplorerQueryBuilder.java | 61 ++
.../dataexplorer/query/DeleteDataQuery.java | 24 +-
.../query/GetAggregatedEventsFromNowQuery.java | 47 ++
.../query/GetAggregatedEventsQuery.java | 45 ++
.../query/GetDateFromSortedTableRecord.java | 69 +++
.../query/GetEventsAutoAggregationQuery.java | 6 +-
.../dataexplorer/query/GetEventsFromNowQuery.java | 44 ++
.../dataexplorer/query/GetEventsQuery.java | 31 +-
.../query/GetGroupedAggregatedEventsQuery.java | 45 ++
.../dataexplorer/query/GetGroupedEventsQuery.java | 43 ++
.../query/GetHeadersWithTypesQuery.java | 45 +-
.../dataexplorer/query/GetMaxPagesQuery.java | 36 +-
.../query/GetNumberOfRecordsByTimeUnitQuery.java | 52 ++
.../query/GetNumberOfRecordsQuery.java | 51 ++
.../dataexplorer/query/GetPagingEventsQuery.java | 71 +++
.../query/ParameterizedDataExplorerQuery.java | 15 +-
.../dataexplorer/template/QueryTemplates.java | 31 +-
.../dataexplorer/utils/DataExplorerUtils.java | 47 ++
.../messaging/jms/ActiveMQConsumer.java | 3 +-
.../messaging/jms/ActiveMQPublisher.java | 18 +-
.../streampipes/messaging/jms/ActiveMQUtils.java | 14 +-
.../messaging/kafka/SpKafkaConsumer.java | 43 +-
.../messaging/kafka/SpKafkaProducer.java | 18 +-
.../kafka/config/AbstractConfigFactory.java | 2 +
.../kafka/config/ConsumerConfigFactory.java | 17 +-
.../kafka/config/ProducerConfigFactory.java | 17 +
streampipes-messaging-mqtt/pom.xml | 4 +
.../streampipes/messaging/mqtt/MqttConsumer.java | 43 +-
streampipes-model-client/pom.xml | 8 +-
.../apache/streampipes/model/client/Category.java | 3 +-
.../model/client/endpoint/RdfEndpointItem.java | 12 +-
.../model/client/user/RawUserApiToken.java | 65 +++
.../apache/streampipes/model/client/user/User.java | 32 +
.../model/client/user/UserApiToken.java | 62 ++
streampipes-model/pom.xml | 18 +-
.../org/apache/streampipes/model/Response.java | 30 +-
.../org/apache/streampipes/model/SpDataStream.java | 12 +
.../java/org/apache/streampipes/model/Tuple2.java | 30 +-
.../model/base/AbstractStreamPipesEntity.java | 30 +-
.../model/base/NamedStreamPipesEntity.java | 26 +-
.../model/base/UnnamedStreamPipesEntity.java | 17 -
.../model/connect/adapter/AdapterDescription.java | 19 +-
.../connect/adapter/AdapterStreamDescription.java | 4 +-
.../rules/TransformationRuleDescription.java | 10 +-
...rrectionValueTransformationRuleDescription.java | 80 +++
.../value/ValueTransformationRuleDescription.java | 1 +
.../streampipes/model/datalake}/DataResult.java | 2 +-
.../model/datalake}/GroupedDataResult.java | 3 +-
.../streampipes/model/datalake}/PageResult.java | 3 +-
.../model/graph/DataSourceDescription.java | 1 +
.../streampipes/model/labeling/Category.java | 67 +++
.../apache/streampipes/model/labeling/Label.java | 73 +++
...entTopicInfo.java => ConsumedMessagesInfo.java} | 50 +-
...lineElementTopicInfo.java => MessagesInfo.java} | 43 +-
...ElementTopicInfo.java => MessagesMetaInfo.java} | 39 +-
.../monitoring/PipelineElementMonitoringInfo.java | 43 +-
...entTopicInfo.java => ProducedMessagesInfo.java} | 48 +-
.../streampipes/model/pipeline/Pipeline.java | 10 +
.../model/pipeline/PipelineElementStatus.java | 23 +-
.../model/staticproperty/AnyStaticProperty.java | 5 +
.../staticproperty/CodeInputStaticProperty.java | 5 +
.../staticproperty/CollectionStaticProperty.java | 5 +
.../staticproperty/ColorPickerStaticProperty.java | 5 +
.../model/staticproperty/DomainStaticProperty.java | 8 +-
.../model/staticproperty/FileStaticProperty.java | 5 +
.../staticproperty/FreeTextStaticProperty.java | 5 +
.../model/staticproperty/MappingPropertyNary.java | 5 +
.../model/staticproperty/MappingPropertyUnary.java | 5 +
.../staticproperty/MatchingStaticProperty.java | 5 +
.../model/staticproperty/OneOfStaticProperty.java | 5 +
.../staticproperty/RemoteOneOfStaticProperty.java | 10 +-
.../model/staticproperty/SecretStaticProperty.java | 5 +
.../model/staticproperty/StaticProperty.java | 2 +
.../staticproperty/StaticPropertyAlternative.java | 5 +
.../staticproperty/StaticPropertyAlternatives.java | 5 +
.../model/staticproperty/StaticPropertyGroup.java | 5 +
.../staticproperty/StaticPropertyVisitor.java | 53 ++
.../model/template/PipelineElementTemplate.java | 102 ++++
.../template/PipelineElementTemplateConfig.java | 44 +-
.../org/apache/streampipes/model/util/Cloner.java | 17 +-
.../apache/streampipes/model/util/ModelUtils.java | 14 -
.../org/apache/streampipes/model/ResponseTest.java | 45 --
streampipes-pipeline-management/pom.xml | 10 +
.../manager/endpoint/EndpointFetcher.java | 2 +-
.../manager/endpoint/EndpointItemFetcher.java | 14 +-
.../manager/endpoint/EndpointItemParser.java | 20 +-
.../manager/execution/http/HttpRequestBuilder.java | 27 +-
.../manager/execution/http/PipelineExecutor.java | 9 -
.../execution/status/SepMonitoringManager.java | 50 --
.../manager/matching/DataSetGroundingSelector.java | 83 ++-
.../matching/PipelineVerificationHandler.java | 3 +
.../manager/matching/ProtocolSelector.java | 37 +-
.../matching/output/ListOutputSchemaGenerator.java | 4 +-
.../matching/output/PropertyDuplicateRemover.java | 8 +-
.../manager/monitoring/job/JobManager.java | 64 --
.../manager/monitoring/job/MonitoringJob.java | 81 ---
.../monitoring/job/MonitoringJobExecutor.java | 46 --
.../manager/monitoring/job/MonitoringUtils.java | 39 --
.../manager/monitoring/job/SecMonitoringJob.java | 36 --
.../manager/monitoring/job/SepaMonitoringJob.java | 36 --
.../monitoring/pipeline/TopicInfoCollector.java | 108 ++--
.../manager/monitoring/runtime/EventGenerator.java | 72 ---
.../monitoring/runtime/PipelineObserver.java | 92 ---
.../monitoring/runtime/PipelineStreamReplacer.java | 109 ----
.../monitoring/runtime/RandomDataGenerator.java | 74 ---
.../monitoring/runtime/RandomEventGenerator.java | 56 --
.../monitoring/runtime/SchemaGenerator.java | 46 --
.../monitoring/runtime/SepStoppedMonitoring.java | 178 ------
.../SepStoppedMonitoringPipelineBuilder.java | 191 ------
.../monitoring/runtime/SimilarStreamFinder.java | 112 ----
.../monitoring/task/CompareDescriptionTask.java | 23 -
.../monitoring/task/GetDescriptionTask.java | 71 ---
.../manager/monitoring/task/InvokeRuntimeTask.java | 23 -
.../manager/monitoring/task/RemoveRuntimeTask.java | 23 -
.../manager/monitoring/task/TaskDefinition.java | 53 --
.../manager/monitoring/task/VerifySchemaTask.java | 23 -
.../remote/ContainerProvidedOptionsHandler.java | 9 +-
.../runtime/PipelineElementRuntimeInfoFetcher.java | 87 ++-
.../manager/setup/CouchDbInstallationStep.java | 27 +
.../template/DataProcessorTemplateHandler.java | 24 +-
.../manager/template/DataSinkTemplateHandler.java | 17 +-
.../template/PipelineElementTemplateHandler.java | 49 ++
.../template/PipelineElementTemplateVisitor.java | 142 +++++
...epaVerifier.java => DataProcessorVerifier.java} | 4 +-
.../{SecVerifier.java => DataSinkVerifier.java} | 4 +-
.../{SepVerifier.java => DataStreamVerifier.java} | 30 +-
.../manager/verification/ElementVerifier.java | 46 +-
.../verification/extractor/TypeExtractor.java | 69 +--
.../streampipes/manager/matching/v2/TestUtils.java | 20 +-
.../manager/pipeline/TestSerializer.java | 48 --
.../pom.xml | 35 +-
.../apache/streampipes/ps}/DataLakeResourceV3.java | 75 ++-
.../ps/PipelineElementTemplateResource.java | 197 +++++++
streampipes-rest-shared/pom.xml | 2 +-
.../rest/shared/annotation/JsonLdSerialized.java | 30 -
.../rest/shared/annotation/RdfRootElement.java | 32 -
.../streampipes/rest/shared/api/CRUDResource.java | 14 +-
.../shared/impl/AbstractSharedRestInterface.java | 61 ++
.../streampipes/rest/shared/util/SpMediaType.java | 5 +-
streampipes-rest/pom.xml | 21 +-
.../streampipes/rest/api/IAssetDashboard.java | 41 --
.../streampipes/rest/api/IAuthentication.java | 37 --
.../apache/streampipes/rest/api/IConsulConfig.java | 37 --
.../rest/api/IMeasurementUnitResource.java | 24 -
.../apache/streampipes/rest/api/INotification.java | 34 --
.../streampipes/rest/api/IOntologyKnowledge.java | 70 ---
.../org/apache/streampipes/rest/api/IPipeline.java | 43 --
.../streampipes/rest/api/IPipelineCache.java | 30 -
.../rest/api/IPipelineElementAsset.java | 29 -
.../streampipes/rest/api/IPipelineElementFile.java | 33 --
.../rest/api/IPipelineElementRuntimeInfo.java | 27 -
.../streampipes/rest/api/IPipelineTemplate.java | 33 --
.../apache/streampipes/rest/api/IRdfEndpoint.java | 34 --
.../org/apache/streampipes/rest/api/ISetup.java | 34 --
.../org/apache/streampipes/rest/api/IUser.java | 30 -
.../org/apache/streampipes/rest/api/IVersion.java | 27 -
.../streampipes/rest/api/IVirtualSensor.java | 29 -
.../streampipes/rest/api/IVisualization.java | 26 -
.../streampipes/rest/api/dashboard/IDashboard.java | 36 --
.../rest/api/dashboard/IDashboardWidget.java | 36 --
.../rest/api/dashboard/IVisualizablePipeline.java | 32 -
.../rest/api/dataexplorer/IDataExplorerWidget.java | 36 --
.../rest/impl/AbstractRestInterface.java | 56 +-
.../streampipes/rest/impl/ApplicationLink.java | 79 ---
.../streampipes/rest/impl/AssetDashboard.java | 23 +-
.../streampipes/rest/impl/Authentication.java | 24 +-
.../streampipes/rest/impl/CategoryResource.java | 110 ++++
.../apache/streampipes/rest/impl/ConsulConfig.java | 28 +-
.../org/apache/streampipes/rest/impl/Couchdb.java | 6 +-
.../apache/streampipes/rest/impl/Deployment.java | 32 +-
.../rest/impl/InternalPipelineTemplates.java | 31 +-
.../streampipes/rest/impl/LabelResource.java | 137 +++++
.../rest/impl/MeasurementUnitResource.java | 12 +-
.../apache/streampipes/rest/impl/Notification.java | 16 +-
.../streampipes/rest/impl/OntologyContext.java | 23 +-
.../streampipes/rest/impl/OntologyKnowledge.java | 45 +-
.../rest/impl/OntologyMeasurementUnit.java | 10 +-
.../rest/impl/OntologyPipelineElement.java | 21 +-
.../streampipes/rest/impl/PipelineCache.java | 17 +-
.../rest/impl/PipelineElementAsset.java | 9 +-
.../rest/impl/PipelineElementCategory.java | 15 +-
.../streampipes/rest/impl/PipelineElementFile.java | 4 +-
.../rest/impl/PipelineElementImport.java | 10 +-
.../rest/impl/PipelineElementRuntimeInfo.java | 5 +-
.../streampipes/rest/impl/PipelineTemplate.java | 87 +--
.../rest/impl/PipelineWithUserResource.java | 386 ++++++------
.../apache/streampipes/rest/impl/RdfEndpoint.java | 27 +-
.../rest/impl/SemanticEventProducer.java | 33 +-
.../org/apache/streampipes/rest/impl/Setup.java | 24 +-
.../streampipes/rest/impl/StreamPipesLogs.java | 147 -----
.../org/apache/streampipes/rest/impl/User.java | 35 +-
.../org/apache/streampipes/rest/impl/Version.java | 5 +-
.../streampipes/rest/impl/VirtualSensor.java | 5 +-
.../streampipes/rest/impl/Visualization.java | 4 +-
.../impl/dashboard/AbstractDashboardResource.java | 16 +-
.../rest/impl/dashboard/DashboardWidget.java | 8 +-
.../rest/impl/dashboard/VisualizablePipeline.java | 7 +-
...shboard.java => DataLakeDashboardResource.java} | 2 +-
.../rest/impl/datalake/DataLakeManagementV3.java | 648 ---------------------
.../impl/datalake/DataLakeNoUserResourceV3.java | 1 +
.../rest/impl/datalake/DataLakeWidgetResource.java | 8 +-
.../impl/nouser/PipelineElementImportNoUser.java | 4 +-
.../AbstractNotificationSubscriber.java | 2 +-
.../rest}/serializer/JsonLdProvider.java | 4 +-
.../apache/streampipes/rest}/util/JsonLdUtils.java | 7 +-
.../datalake/DataLakeNoUserManagementV3Test.java | 3 +-
.../streampipes/rest}/util/JsonLdUtilsTest.java | 4 +-
.../sdk/builder/StreamRequirementsBuilder.java | 8 +
.../sdk/extractor/AbstractParameterExtractor.java | 39 ++
.../streampipes/sdk/helpers/EpProperties.java | 1 -
.../streampipes/sdk/helpers/EpRequirements.java | 18 +
.../apache/streampipes/sdk/helpers/Protocols.java | 21 +-
.../sdk/helpers/SupportedProtocols.java | 10 +
.../apache/streampipes/sdk/utils/Datatypes.java | 8 +
.../pom.xml | 22 +-
.../serializers/json/AdapterSerializer.java | 0
.../serializers/json/AdapterTypeAdapter.java | 0
.../serializers/json/EcTypeAdapter.java | 0
.../serializers/json/EpaTypeAdapter.java | 0
.../serializers/json/GsonSerializer.java | 8 +-
.../serializers/json/JacksonSerializer.java | 0
.../serializers/json/JsonLdSerializer.java | 0
.../serializers/json/PeTypeAdapter.java | 0
.../json/ProcessingElementSerializer.java | 0
.../serializers/json/RangeSerializer.java | 34 +-
.../json/RuntimeTypeAdapterFactory.java | 0
.../json/TransformationRuleSerializer.java | 0
.../serializers/json/UriSerializer.java | 0
.../apache/streampipes/serializers/json/Utils.java | 0
.../serializers/json/TestGsonSerializer.java | 40 +-
.../serializers/json/TestJacksonSerializer.java | 42 ++
.../utils/PipelineElementTemplateHelpers.java | 52 ++
.../pom.xml | 20 +-
.../jsonld/CustomAnnotationProvider.java | 7 +-
.../serializers/jsonld/JsonLdTransformer.java | 0
.../serializers/jsonld/JsonLdUtils.java | 52 +-
.../serializers/jsonld/RdfTransformer.java | 0
streampipes-storage-api/pom.xml | 8 +
.../streampipes/storage/api/CRUDStorage.java | 15 +-
.../streampipes/storage/api/ICategoryStorage.java | 19 +-
.../streampipes/storage/api/ILabelStorage.java | 24 +-
.../streampipes/storage/api/INoSqlStorage.java | 7 +
.../api/IPipelineElementDescriptionStorage.java | 31 +-
.../api/IPipelineElementTemplateStorage.java | 10 +-
streampipes-storage-couchdb/pom.xml | 2 +-
.../storage/couchdb/CouchDbStorageManager.java | 11 +
.../storage/couchdb/dao/AbstractDao.java | 6 +-
.../storage/couchdb/dao/PersistCommand.java | 8 +-
.../storage/couchdb/impl/CategoryStorageImpl.java | 57 ++
.../storage/couchdb/impl/LabelStorageImpl.java | 76 +++
.../impl/PipelineElementTemplateStorageImpl.java | 67 +++
.../storage/couchdb/impl/UserStorage.java | 16 +-
.../streampipes/storage/couchdb/utils/Utils.java | 18 +
streampipes-storage-rdf4j/pom.xml | 2 +-
.../storage/rdf4j/config/ConfigKeys.java | 10 +-
.../storage/rdf4j/config/Rdf4JConfig.java | 13 +-
.../rdf4j/impl/PipelineElementInMemoryStorage.java | 114 ++--
.../rdf4j/impl/PipelineElementStorageRequests.java | 58 +-
.../storage/rdf4j/sparql/QueryBuilder.java | 25 +-
streampipes-user-management/pom.xml | 11 +-
.../authentication/StreamPipesRealm.java | 40 +-
.../user/management/service/TokenService.java | 61 ++
.../user/management/util/TokenUtil.java | 62 ++
.../user/management/util/TestTokenUtil.java | 57 ++
.../apache/streampipes/vocabulary/StreamPipes.java | 8 +-
streampipes-wrapper-distributed/pom.xml | 5 +
.../distributed/runtime/DistributedRuntime.java | 21 +-
.../wrapper/flink/FlinkDataProcessorRuntime.java | 10 +-
.../streampipes/wrapper/flink/FlinkRuntime.java | 22 +-
.../{JmsConsumer.java => JmsFlinkConsumer.java} | 6 +-
.../{JmsConsumer.java => MqttFlinkConsumer.java} | 26 +-
...FlinkJmsProducer.java => JmsFlinkProducer.java} | 4 +-
...linkJmsProducer.java => MqttFlinkProducer.java} | 14 +-
streampipes-wrapper-python/setup.py | 4 +-
.../streampipes/instances.py | 33 +-
.../streampipes/model/__init__.py | 2 +-
.../streampipes/submitter.py | 13 +-
.../streampipes/utils/__init__.py | 2 +-
streampipes-wrapper-siddhi/pom.xml | 6 +
.../wrapper/siddhi/SiddhiAppConfig.java | 70 +++
.../wrapper/siddhi/SiddhiAppConfigBuilder.java | 61 ++
.../wrapper/siddhi/SiddhiQueryBuilder.java | 96 +++
.../wrapper/siddhi/constants/SiddhiConstants.java | 55 ++
.../siddhi/constants/SiddhiStreamSelector.java | 16 +-
.../siddhi/definition/SiddhiDefinition.java | 9 +-
.../siddhi/definition/StreamDefinition.java | 13 +-
.../siddhi/definition/WindowDefinition.java | 9 +-
.../wrapper/siddhi/engine/SiddhiEngine.java | 130 +++++
.../wrapper/siddhi/engine/SiddhiEventEngine.java | 274 +--------
...Callback.java => SiddhiStatementGenerator.java} | 8 +-
.../siddhi/engine/StreamPipesSiddhiProcessor.java | 59 ++
.../engine/{ => callback}/SiddhiDebugCallback.java | 6 +-
.../callback/SiddhiOutputStreamCallback.java | 77 +++
.../callback/SiddhiOutputStreamDebugCallback.java | 54 ++
.../engine/generator/EventTypeGenerator.java | 77 +++
.../engine/generator/InputStreamNameGenerator.java | 44 +-
.../engine/generator/SiddhiAppGenerator.java | 88 +++
.../generator/SiddhiInvocationConfigGenerator.java | 64 ++
.../wrapper/siddhi/model/EventPropertyDef.java | 29 +-
.../siddhi/model/SiddhiProcessorParams.java | 100 ++++
.../siddhi/output/SiddhiFirstOutputConfig.java | 12 +-
.../siddhi/output/SiddhiListOutputConfig.java | 16 +-
.../wrapper/siddhi/output/SiddhiOutputConfig.java | 24 +-
.../wrapper/siddhi/output/SiddhiOutputType.java | 7 +-
.../siddhi/query/AbstractQueryGenerator.java | 23 +-
.../wrapper/siddhi/query/FromClause.java | 48 ++
.../wrapper/siddhi/query/GroupByClause.java | 52 ++
.../wrapper/siddhi/query/HavingClause.java | 10 +-
.../wrapper/siddhi/query/InsertIntoClause.java | 46 ++
.../wrapper/siddhi/query/LimitClause.java | 22 +-
.../wrapper/siddhi/query/OrderByClause.java | 48 ++
.../wrapper/siddhi/query/SelectClause.java | 78 +++
.../wrapper/siddhi/query/SiddhiQuery.java | 126 ++++
.../wrapper/siddhi/query/SiddhiStatement.java | 8 +-
.../siddhi/query/expression/EqualsExpression.java | 16 +-
.../siddhi/query/expression/Expression.java | 63 ++
.../siddhi/query/expression/Expressions.java | 179 ++++++
.../query/expression/GreaterEqualsExpression.java | 16 +-
.../query/expression/GreaterThanExpression.java | 16 +-
.../query/expression/LesserEqualsExpression.java | 16 +-
.../query/expression/LesserThanExpression.java | 16 +-
.../query/expression/PropertyExpression.java | 48 ++
.../query/expression/PropertyExpressionBase.java | 5 +-
.../query/expression/PropertyRenameExpression.java | 32 +-
.../query/expression/RelationalOperator.java | 21 +-
.../expression/RelationalOperatorExpression.java | 42 +-
.../query/expression/SequenceExpression.java | 18 +-
.../siddhi/query/expression/SiddhiTimeUnit.java | 17 +-
.../siddhi/query/expression/StreamExpression.java | 58 ++
.../query/expression/StreamFilterExpression.java | 57 ++
.../siddhi/query/expression/WithinExpression.java | 24 +-
.../expression/aggregation/CountExpression.java | 37 +-
.../expression/list/CollectListExpression.java | 37 +-
.../expression/list/ContainsListExpression.java | 52 ++
.../query/expression/math/MathAddExpression.java | 13 +-
.../expression/math/MathDivideExpression.java | 13 +-
.../query/expression/math/MathExpression.java | 36 +-
.../expression/math/MathMultiplyExpression.java | 13 +-
.../siddhi/query/expression/math/MathOperator.java | 23 +-
.../expression/math/MathSubtractExpression.java | 13 +-
.../expression/orderby/OrderByExpression.java | 36 +-
.../query/expression/pattern/EveryExpression.java | 19 +-
.../expression/pattern/PatternCountExpression.java | 54 ++
.../expression/pattern/PatternCountOperator.java | 8 +-
.../expression/pattern/PatternExpression.java | 60 ++
.../expression/window/BatchWindowExpression.java | 16 +-
.../expression/window/SortWindowExpression.java | 44 ++
.../window/TimeBatchWindowExpression.java | 23 +-
.../expression/window/TimeWindowExpression.java | 23 +-
.../query/expression/window/WindowExpression.java | 32 +-
.../wrapper/siddhi/utils/SiddhiUtils.java | 108 ++++
.../wrapper/standalone/ProcessorParams.java | 31 +-
.../streampipes/wrapper/standalone/SinkParams.java | 22 +-
.../standalone/StreamPipesDataProcessor.java | 27 +-
.../wrapper/standalone/StreamPipesDataSink.java | 26 +-
ui/angular.json | 4 +-
ui/deployment/app-routing.module.mst | 8 +-
ui/deployment/appng5.module.mst | 6 +-
ui/nginx_config/default.conf | 30 +-
ui/nginx_config/ssl.conf | 30 +-
ui/package.json | 76 +--
ui/src/app/add/add.component.html | 3 +-
ui/src/app/add/add.component.ts | 4 +-
.../endpoint-item/endpoint-item.component.html | 23 +-
.../endpoint-item/endpoint-item.component.ts | 14 +-
.../apidocs.component.html} | 11 +-
.../apidocs.component.scss} | 0
.../src/app/apidocs/apidocs.component.ts | 31 +-
.../Annotation.ts => apidocs/apidocs.module.ts} | 42 +-
.../app/app-overview/app-overview.component.html | 4 +-
ui/src/app/app-overview/app-overview.component.ts | 13 +-
ui/src/app/app-routing.module.ts | 8 +-
.../configuration/configuration.component.spec.ts | 8 +-
.../consul-configs-password.component.spec.ts | 10 +-
.../consul-service.component.spec.ts | 20 +-
.../messaging-configuration.component.html | 20 +
.../messaging-configuration.component.ts | 4 +
.../shared/messaging-settings.model.ts | 1 +
.../data-marketplace/data-marketplace.component.ts | 25 +-
.../event-schema/event-schema.component.ts | 3 +-
ui/src/app/connect/connect.module.ts | 4 +-
.../edit-correction-value.component.css} | 0
.../edit-correction-value.component.html | 39 ++
.../edit-correction-value.component.ts | 55 ++
.../edit-event-property-primitive.component.html | 1 +
.../edit-event-property-primitive.component.ts | 9 +-
.../edit-unit-transformation.component.css | 4 -
.../edit-unit-transformation.component.html | 2 +-
.../edit-event-property.component.html | 11 +-
.../edit-event-property.component.ts | 29 +-
.../connect/services/data-marketplace.service.ts | 11 +-
ui/src/app/connect/services/rest.service.ts | 28 +-
.../services/transformation-rule.service.ts | 41 ++
ui/src/app/core-model/coco/Annotation.ts | 2 +
ui/src/app/core-model/coco/Category.ts | 10 +-
.../app/core-model/gen/streampipes-model-client.ts | 94 ++-
ui/src/app/core-model/gen/streampipes-model.ts | 227 ++++++--
.../datalake/datalake-rest.service.ts | 6 +-
.../semantic-type/semantic-type-utils.service.ts | 5 +
ui/src/app/core-ui/core-ui.module.ts | 257 ++++----
.../image-annotations.component.html | 16 +-
.../image-annotations.component.ts | 21 +-
.../image-labels/image-labels.component.html | 39 --
.../image-labels/image-labels.component.ts | 73 ---
.../image-categorize.component.html | 5 +-
.../image-categorize/image-categorize.component.ts | 4 +-
.../image-labeling/image-labeling.component.html | 5 +-
.../image-labeling/image-labeling.component.ts | 45 +-
.../image/services/BrushLabeling.service.ts | 5 +-
.../core-ui/image/services/CocoFormat.service.ts | 22 +-
.../image/services/PolygonLabeling.service.ts | 7 +-
.../image/services/ReactLabeling.service.ts | 9 +-
.../configure-labels.component.css} | 0
.../configure-labels.component.html | 66 +++
.../configure-labels/configure-labels.component.ts | 120 ++++
.../label-list-item/label-list-item.component.css} | 0
.../label-list-item.component.html} | 27 +-
.../label-list-item/label-list-item.component.ts | 59 ++
.../select-label/select-label.component.css} | 0
.../select-label/select-label.component.html | 43 ++
.../select-label/select-label.component.ts | 81 +++
.../app/core-ui/labels/services/label.service.ts | 94 +++
.../label-selection/label-selection.component.html | 32 -
.../label-selection/label-selection.component.ts | 61 --
.../change-chartmode/change-chartmode.dialog.css | 29 -
.../change-chartmode/change-chartmode.dialog.ts | 35 --
.../dialogs/labeling/labeling.dialog.css | 36 --
.../dialogs/labeling/labeling.dialog.html | 36 --
.../dialogs/labeling/labeling.dialog.ts | 52 --
.../labeling-tool/labeling-tool.module.ts | 90 ---
.../filter/display-recommended.pipe.ts | 2 +-
.../static-alternatives.component.html | 4 +-
.../static-alternatives.component.ts | 1 -
.../static-mapping-unary.component.ts | 2 -
.../static-mapping/static-mapping.ts | 1 +
.../runtime-resolvable.service.ts | 2 +-
.../core/components/toolbar/toolbar.component.html | 10 +-
.../core/components/toolbar/toolbar.component.scss | 13 +-
.../core/components/toolbar/toolbar.component.ts | 11 +-
.../components/grid/dashboard-grid.component.html | 6 +-
.../components/grid/dashboard-grid.component.ts | 12 +-
.../overview/dashboard-overview.component.css | 15 +-
.../overview/dashboard-overview.component.html | 19 +-
.../components/panel/dashboard-panel.component.css | 13 +
.../panel/dashboard-panel.component.html | 39 +-
.../components/panel/dashboard-panel.component.ts | 4 +-
.../widget/dashboard-widget.component.html | 28 +-
.../widget/dashboard-widget.component.ts | 3 +-
.../components/widgets/bar-race/bar-race-config.ts | 45 ++
.../bar-race/bar-race-widget.component.html} | 16 +-
.../bar-race-widget.component.scss} | 51 +-
.../widgets/bar-race/bar-race-widget.component.ts | 165 ++++++
.../components/widgets/base/base-echarts-widget.ts | 59 ++
.../dashboard/components/widgets/map/map-config.ts | 48 +-
.../widgets/map/map-widget.component.html | 3 +-
.../components/widgets/map/map-widget.component.ts | 75 ++-
.../widgets/number/number-widget.component.css | 4 +-
.../stacked-line-chart-config.ts | 45 ++
.../stacked-line-chart-widget.component.html} | 16 +-
.../stacked-line-chart-widget.component.scss} | 51 +-
.../stacked-line-chart-widget.component.ts | 122 ++++
.../components/widgets/status/status-config.ts | 43 ++
.../widgets/status/status-widget.component.html} | 16 +-
.../status-widget.component.scss} | 51 +-
.../widgets/status/status-widget.component.ts | 67 +++
.../widgets/wordcloud/wordcloud-config.ts | 48 ++
.../wordcloud/wordcloud-widget.component.html} | 17 +-
.../wordcloud/wordcloud-widget.component.scss} | 37 +-
.../wordcloud/wordcloud-widget.component.ts | 139 +++++
ui/src/app/dashboard/dashboard.module.ts | 17 +
ui/src/app/dashboard/registry/widget-registry.ts | 37 +-
ui/src/app/dashboard/sdk/ep-requirements.ts | 120 ++--
.../{property-match.ts => list-property-match.ts} | 22 +-
.../app/dashboard/sdk/matching/property-match.ts | 8 +-
...data-explorer-dashboard-overview.component.html | 7 +-
.../data-explorer-dashboard-overview.component.ts | 7 +
.../data-explorer-dashboard-widget.component.html | 2 +-
.../data-explorer-dashboard-widget.component.ts | 2 +
.../widgets/base/base-data-explorer-widget.ts | 14 +-
.../point-selection-info.component.css | 0
.../point-selection-info.component.html | 0
.../point-selection-info.component.ts | 2 +-
.../line-chart/line-chart-widget.component.css | 5 +-
.../line-chart/line-chart-widget.component.html | 35 +-
.../line-chart/line-chart-widget.component.ts | 596 ++++++++++---------
.../widgets/line-chart}/services/color.service.ts | 0
ui/src/app/data-explorer/data-explorer.module.ts | 96 +--
.../custom-output-strategy.component.html | 2 +-
.../pipeline-element-recommendation.component.ts | 26 +-
...pipeline-element-template-config.component.html | 60 ++
...ipeline-element-template-config.component.scss} | 15 +
.../pipeline-element-template-config.component.ts | 79 +++
.../pipeline-element-template-generator.ts} | 33 +-
.../dialog/customize/customize.component.html | 76 ++-
.../dialog/customize/customize.component.scss | 11 +
.../editor/dialog/customize/customize.component.ts | 96 ++-
ui/src/app/editor/editor.component.ts | 8 +-
ui/src/app/editor/editor.module.ts | 4 +-
ui/src/app/home/components/status.component.ts | 15 +-
.../login/components/login/login.component.html | 1 +
ui/src/app/login/login.module.ts | 2 +
.../actions/pipeline-actions.component.ts | 4 +-
.../monitoring/pipeline-monitoring.component.html | 15 +-
.../monitoring/pipeline-monitoring.component.scss | 9 +-
.../monitoring/pipeline-monitoring.component.ts | 39 +-
.../pipeline-element-statistics.component.ts | 26 +-
.../preview/pipeline-preview.component.html | 2 +-
.../pipeline-details.component.html | 4 +-
.../pipeline-overview.component.html | 4 +-
.../pipeline-overview.component.ts | 4 +-
.../services/pipeline-operations.service.ts | 16 +-
.../apis/measurement-units.service.ts} | 38 +-
.../apis/pipeline-element-template.service.ts | 69 +++
.../apis/pipeline-element.service.ts | 20 +-
ui/src/app/platform-services/platform.module.ts | 6 +-
.../profile/components/basic-profile-settings.ts | 58 ++
.../general-profile-settings.component.html | 51 ++
.../general-profile-settings.component.scss} | 20 +-
.../general/general-profile-settings.component.ts | 33 +-
.../token/token-management-settings.component.html | 90 +++
.../token-management-settings.component.scss} | 62 +-
.../token/token-management-settings.component.ts | 70 +++
ui/src/app/profile/profile.component.html | 42 ++
.../profile.component.scss} | 4 +-
.../src/app/profile/profile.component.ts | 19 +-
ui/src/app/profile/profile.module.ts | 62 ++
ui/src/app/profile/profile.service.ts | 53 ++
ui/src/app/services/property-selector.service.ts | 3 +-
ui/src/scss/main.scss | 1 +
ui/src/scss/sp/main.scss | 29 +-
ui/src/scss/sp/sp-dialog.scss | 2 +-
ui/src/tsconfig.app.json | 2 +-
ui/src/tsconfig.spec.json | 2 +-
ui/tsconfig.base.json | 26 -
ui/tsconfig.json | 39 +-
ui/tsconfig.spec.json | 2 +-
ui/webpack.partial.dev.js | 4 +-
706 files changed, 15663 insertions(+), 10484 deletions(-)
delete mode 100644 .idea/runConfigurations/connect_master.xml
delete mode 100644 streampipes-app-file-export/pom.xml
delete mode 100644
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/ElasticsearchAppData.java
delete mode 100644
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/ElasticsearchConfig.java
delete mode 100644
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/converter/JsonConverter.java
delete mode 100644
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/impl/Elasticsearch.java
create mode 100644 streampipes-backend/src/main/resources/openapi.yaml
copy {streampipes-storage-couchdb => streampipes-client}/pom.xml (69%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/StreamPipesClient.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model/PageResult.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/StreamPipesCredentials.java
(54%)
copy ui/src/app/dashboard/components/overview/dashboard-overview.component.css
=>
streampipes-client/src/main/java/org/apache/streampipes/client/annotation/NotYetImplemented.java
(89%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/AbstractClientApi.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/ILogs.java =>
streampipes-client/src/main/java/org/apache/streampipes/client/api/CRUDApi.java
(79%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/DataProcessorApi.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/DataSinkApi.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/DataStreamApi.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineApi.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/api/PipelineElementTemplateApi.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/JsonFormatGenerator.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataProcessorApi.java
(87%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/StreamGenerator.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataSinkApi.java
(88%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/JsonFormatGenerator.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsDataStreamApi.java
(87%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/ThriftFormatGenerator.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineApi.java
(88%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/JsonFormatGenerator.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/api/SupportsPipelineElementTemplateApi.java
(83%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/DeleteRequest.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/GetRequest.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/HttpRequest.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/PostRequest.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/PostRequestWithPayloadResponse.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/PostRequestWithoutPayloadResponse.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/http/header/Headers.java
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiDebugCallback.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/live/EventProcessor.java
(86%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/live/KafkaConfig.java
(62%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/live/SubscriptionManager.java
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/model/StreamPipesClientConfig.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model/PageResult.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/serializer/ListSerializer.java
(54%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/serializer/ObjectSerializer.java
(61%)
copy
streampipes-serializers/src/main/java/org/apache/streampipes/serializers/json/JacksonSerializer.java
=>
streampipes-client/src/main/java/org/apache/streampipes/client/serializer/Serializer.java
(55%)
create mode 100644
streampipes-client/src/main/java/org/apache/streampipes/client/util/StreamPipesApiPath.java
create mode 100644
streampipes-client/src/test/java/org/apache/streampipes/client/TestStreamPipesClient.java
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-config/src/main/java/org/apache/streampipes/config/backend/SpProtocol.java
(58%)
delete mode 100644 streampipes-connect-container-master/aarch64.Dockerfile
delete mode 100644 streampipes-connect-container-master/arm.Dockerfile
delete mode 100644 streampipes-connect-container-master/development/env
delete mode 100644
streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/init/AdapterMasterContainer.java
delete mode 100644
streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/init/AdapterMasterContainerResourceConfig.java
create mode 100644
streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/HttpServerAdapterManagement.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IOntologyContext.java
=>
streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/rest/HttpServerAdapterResource.java
(55%)
delete mode 100644
streampipes-connect-container/src/main/java/org/apache/streampipes/connect/management/AdapterDeserializer.java
delete mode 100644
streampipes-connect-container/src/test/java/org/streampipes/connect/utils/ConnectContainerResourceTest.java
create mode 100644
streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/SendToBrokerAdapterSink.java
rename
streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/{SendToKafkaReplayAdapterSink.java
=> SendToBrokerReplayAdapterSink.java} (80%)
copy
streampipes-sdk/src/main/java/org/apache/streampipes/sdk/helpers/SupportedProtocols.java
=>
streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/SendToJmsAdapterSink.java
(52%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model/PageResult.java
=>
streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/elements/SendToMqttAdapterSink.java
(51%)
create mode 100644
streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/preprocessing/transform/value/CorrectionValueTransformationRule.java
copy {streampipes-wrapper-distributed =>
streampipes-container-extensions}/pom.xml (67%)
create mode 100644
streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/ExtensionsModelSubmitter.java
create mode 100644
streampipes-container-extensions/src/main/java/org/apache/streampipes/container/extensions/ExtensionsResourceConfig.java
rename {streampipes-connect-container-master =>
streampipes-container-extensions}/src/main/resources/banner.txt (89%)
rename
streampipes-container/src/main/java/org/apache/streampipes/container/api/{Element.java
=> AbstractPipelineElementResource.java} (58%)
rename
streampipes-container/src/main/java/org/apache/streampipes/container/api/{SepaElement.java
=> DataProcessorPipelineElementResource.java} (91%)
rename
streampipes-container/src/main/java/org/apache/streampipes/container/api/{SecElement.java
=> DataSinkPipelineElementResource.java} (54%)
create mode 100644
streampipes-container/src/main/java/org/apache/streampipes/container/api/DataStreamPipelineElementResource.java
rename
streampipes-container/src/main/java/org/apache/streampipes/container/api/{InvocableElement.java
=> InvocablePipelineElementResource.java} (65%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/{PipelineTemplateElement.java
=> PipelineTemplateResource.java} (92%)
delete mode 100644
streampipes-container/src/main/java/org/apache/streampipes/container/api/SepElement.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/{init/ModelSubmitter.java
=> model/ExtensionsConfig.java} (78%)
create mode 100644
streampipes-container/src/main/java/org/apache/streampipes/container/model/consul/ConsulServiceRegistrationBody.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model/PageResult.java
=>
streampipes-container/src/main/java/org/apache/streampipes/container/model/consul/HealthCheckConfiguration.java
(51%)
delete mode 100644
streampipes-container/src/main/java/org/apache/streampipes/container/transform/Transformer.java
delete mode 100644
streampipes-container/src/main/java/org/apache/streampipes/container/util/DeclarerUtils.java
delete mode 100644
streampipes-container/src/test/java/de/fzi/cep/sepa/html/page/WelcomePageGeneratorImplTest.java
copy {streampipes-wrapper-distributed => streampipes-data-explorer}/pom.xml
(71%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/DataLakeManagementV3.java
rename
{streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake =>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer}/DataLakeNoUserManagementV3.java
(85%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/AbstractAutoAggregationQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/FromNowAutoAggregationQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/GroupedAutoAggregationQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/autoagg/TimeBoundAutoAggregationQuery.java
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/model/Order.java
(78%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/AggregatedTimeBoundQueryParams.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/AggregatedTimeUnitQueryParams.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/connect/SpConnect.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/CountQueryParams.java
(90%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/GroupedAggregatedTimeBoundQueryParams.java
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/GroupedQueryParams.java
(51%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/PagingQueryParams.java
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/QueryParams.java
(72%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/TimeBoundQueryParams.java
(56%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/TimeUnitQueryParams.java
(57%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQueryBuilder.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DeleteDataQuery.java
(59%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetAggregatedEventsFromNowQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetAggregatedEventsQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetDateFromSortedTableRecord.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/JsonFormatGenerator.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsAutoAggregationQuery.java
(89%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsFromNowQuery.java
copy
streampipes-connect-container/src/main/java/org/apache/streampipes/connect/init/AdapterContainerConfig.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetEventsQuery.java
(50%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetGroupedAggregatedEventsQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetGroupedEventsQuery.java
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model/GroupedDataResult.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetHeadersWithTypesQuery.java
(50%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java =>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetMaxPagesQuery.java
(52%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetNumberOfRecordsByTimeUnitQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetNumberOfRecordsQuery.java
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/GetPagingEventsQuery.java
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ParameterizedDataExplorerQuery.java
(75%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/template/QueryTemplates.java
(59%)
create mode 100644
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/utils/DataExplorerUtils.java
copy
streampipes-connect/src/main/java/org/apache/streampipes/connect/adapter/model/pipeline/AdapterPipelineElement.java
=>
streampipes-messaging-jms/src/main/java/org/apache/streampipes/messaging/jms/ActiveMQUtils.java
(65%)
create mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/RawUserApiToken.java
create mode 100644
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/user/UserApiToken.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=> streampipes-model/src/main/java/org/apache/streampipes/model/Tuple2.java
(60%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/connect/rules/value/CorrectionValueTransformationRuleDescription.java
copy
{streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake}/DataResult.java
(96%)
rename
{streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake}/GroupedDataResult.java
(94%)
rename
{streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake}/PageResult.java
(94%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/labeling/Category.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/labeling/Label.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{PipelineElementTopicInfo.java
=> ConsumedMessagesInfo.java} (50%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{PipelineElementTopicInfo.java
=> MessagesInfo.java} (58%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{PipelineElementTopicInfo.java
=> MessagesMetaInfo.java} (60%)
rename
streampipes-model/src/main/java/org/apache/streampipes/model/monitoring/{PipelineElementTopicInfo.java
=> ProducedMessagesInfo.java} (50%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/staticproperty/StaticPropertyVisitor.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/template/PipelineElementTemplate.java
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/template/PipelineElementTemplateConfig.java
(51%)
delete mode 100644
streampipes-model/src/test/java/org/apache/streampipes/model/ResponseTest.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/status/SepMonitoringManager.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/job/JobManager.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/job/MonitoringJob.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/job/MonitoringJobExecutor.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/job/MonitoringUtils.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/job/SecMonitoringJob.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/job/SepaMonitoringJob.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/EventGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/PipelineObserver.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/PipelineStreamReplacer.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/RandomDataGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/RandomEventGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/SchemaGenerator.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/SepStoppedMonitoring.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/SepStoppedMonitoringPipelineBuilder.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/SimilarStreamFinder.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/task/CompareDescriptionTask.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/task/GetDescriptionTask.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/task/InvokeRuntimeTask.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/task/RemoveRuntimeTask.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/task/TaskDefinition.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/task/VerifySchemaTask.java
copy
streampipes-serializers/src/main/java/org/apache/streampipes/serializers/json/PeTypeAdapter.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/DataProcessorTemplateHandler.java
(57%)
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/InternalPipelineTemplate.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/DataSinkTemplateHandler.java
(59%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineElementTemplateHandler.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/template/PipelineElementTemplateVisitor.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/{SepaVerifier.java
=> DataProcessorVerifier.java} (95%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/{SecVerifier.java
=> DataSinkVerifier.java} (95%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/verification/{SepVerifier.java
=> DataStreamVerifier.java} (73%)
delete mode 100644
streampipes-pipeline-management/src/test/java/org/apache/streampipes/manager/pipeline/TestSerializer.java
copy {streampipes-storage-couchdb => streampipes-platform-services}/pom.xml
(65%)
rename
{streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake =>
streampipes-platform-services/src/main/java/org/apache/streampipes/ps}/DataLakeResourceV3.java
(75%)
create mode 100644
streampipes-platform-services/src/main/java/org/apache/streampipes/ps/PipelineElementTemplateResource.java
delete mode 100644
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/annotation/JsonLdSerialized.java
delete mode 100644
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/annotation/RdfRootElement.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineElementCategory.java
=>
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/api/CRUDResource.java
(78%)
create mode 100644
streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared/impl/AbstractSharedRestInterface.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IAssetDashboard.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IAuthentication.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IConsulConfig.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IMeasurementUnitResource.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/INotification.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IOntologyKnowledge.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipeline.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineCache.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineElementAsset.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineElementFile.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineElementRuntimeInfo.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IPipelineTemplate.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IRdfEndpoint.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/ISetup.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IUser.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IVersion.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IVirtualSensor.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IVisualization.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/dashboard/IDashboard.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/dashboard/IDashboardWidget.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/dashboard/IVisualizablePipeline.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/dataexplorer/IDataExplorerWidget.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ApplicationLink.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CategoryResource.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/LabelResource.java
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/StreamPipesLogs.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/{DataLakeDashboard.java
=> DataLakeDashboardResource.java} (94%)
delete mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeManagementV3.java
rename
{streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared =>
streampipes-rest/src/main/java/org/apache/streampipes/rest}/serializer/JsonLdProvider.java
(96%)
rename
{streampipes-rest-shared/src/main/java/org/apache/streampipes/rest/shared =>
streampipes-rest/src/main/java/org/apache/streampipes/rest}/util/JsonLdUtils.java
(91%)
rename
{streampipes-rest-shared/src/test/java/org/apache/streampipes/rest/shared =>
streampipes-rest/src/test/java/org/apache/streampipes/rest}/util/JsonLdUtilsTest.java
(97%)
copy {streampipes-serializers => streampipes-serializers-json}/pom.xml (80%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/AdapterSerializer.java
(100%)
copy {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/AdapterTypeAdapter.java
(100%)
copy {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/EcTypeAdapter.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/EpaTypeAdapter.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/GsonSerializer.java
(95%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/JacksonSerializer.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/JsonLdSerializer.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/PeTypeAdapter.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/ProcessingElementSerializer.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/RangeSerializer.java
(67%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/RuntimeTypeAdapterFactory.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/TransformationRuleSerializer.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/UriSerializer.java
(100%)
rename {streampipes-serializers =>
streampipes-serializers-json}/src/main/java/org/apache/streampipes/serializers/json/Utils.java
(100%)
rename
streampipes-container/src/test/java/org/streampipes/container/util/UtilTest.java
=>
streampipes-serializers-json/src/test/java/org/apache/streampipes/serializers/json/TestGsonSerializer.java
(54%)
create mode 100644
streampipes-serializers-json/src/test/java/org/apache/streampipes/serializers/json/TestJacksonSerializer.java
create mode 100644
streampipes-serializers-json/src/test/java/org/apache/streampipes/serializers/utils/PipelineElementTemplateHelpers.java
rename {streampipes-serializers => streampipes-serializers-jsonld}/pom.xml
(72%)
rename {streampipes-serializers =>
streampipes-serializers-jsonld}/src/main/java/org/apache/streampipes/serializers/jsonld/CustomAnnotationProvider.java
(95%)
rename {streampipes-serializers =>
streampipes-serializers-jsonld}/src/main/java/org/apache/streampipes/serializers/jsonld/JsonLdTransformer.java
(100%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/Utils.java =>
streampipes-serializers-jsonld/src/main/java/org/apache/streampipes/serializers/jsonld/JsonLdUtils.java
(74%)
rename {streampipes-serializers =>
streampipes-serializers-jsonld}/src/main/java/org/apache/streampipes/serializers/jsonld/RdfTransformer.java
(100%)
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IOntologyMeasurementUnit.java
=>
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/CRUDStorage.java
(76%)
rename
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/api/IElasticsearch.java
=>
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/ICategoryStorage.java
(66%)
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IOntologyPipelineElement.java
=>
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/ILabelStorage.java
(65%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/declarer/SemanticEventProducerDeclarer.java
=>
streampipes-storage-api/src/main/java/org/apache/streampipes/storage/api/IPipelineElementTemplateStorage.java
(73%)
create mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/CategoryStorageImpl.java
create mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/LabelStorageImpl.java
create mode 100644
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/impl/PipelineElementTemplateStorageImpl.java
rename
streampipes-connect-container/src/main/java/org/apache/streampipes/connect/init/Config.java
=>
streampipes-storage-rdf4j/src/main/java/org/apache/streampipes/storage/rdf4j/config/ConfigKeys.java
(75%)
create mode 100644
streampipes-user-management/src/main/java/org/apache/streampipes/user/management/service/TokenService.java
create mode 100644
streampipes-user-management/src/main/java/org/apache/streampipes/user/management/util/TokenUtil.java
create mode 100644
streampipes-user-management/src/test/java/org/apache/streampipes/user/management/util/TestTokenUtil.java
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/consumer/{JmsConsumer.java
=> JmsFlinkConsumer.java} (89%)
rename
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/consumer/{JmsConsumer.java
=> MqttFlinkConsumer.java} (74%)
copy
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/{FlinkJmsProducer.java
=> JmsFlinkProducer.java} (94%)
rename
streampipes-wrapper-flink/src/main/java/org/apache/streampipes/wrapper/flink/sink/{FlinkJmsProducer.java
=> MqttFlinkProducer.java} (78%)
rename streampipes-connect-container-master/Dockerfile =>
streampipes-wrapper-python/streampipes/instances.py (50%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/SiddhiAppConfig.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/SiddhiAppConfigBuilder.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/SiddhiQueryBuilder.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/constants/SiddhiConstants.java
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/constants/SiddhiStreamSelector.java
(69%)
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/ICouchdb.java =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/definition/SiddhiDefinition.java
(81%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/FormatGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/definition/StreamDefinition.java
(81%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/JsonFormatGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/definition/WindowDefinition.java
(81%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/SiddhiEngine.java
copy
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/{SiddhiDebugCallback.java
=> SiddhiStatementGenerator.java} (67%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/StreamPipesSiddhiProcessor.java
rename
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/{
=> callback}/SiddhiDebugCallback.java (88%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/callback/SiddhiOutputStreamCallback.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/callback/SiddhiOutputStreamDebugCallback.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/EventTypeGenerator.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/model/DataResult.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/InputStreamNameGenerator.java
(51%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/SiddhiAppGenerator.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/engine/generator/SiddhiInvocationConfigGenerator.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/model/EventPropertyDef.java
(59%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/model/SiddhiProcessorParams.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/EpRuntimeMonitoring.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/output/SiddhiFirstOutputConfig.java
(79%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/output/SiddhiListOutputConfig.java
(67%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/output/SiddhiOutputConfig.java
(60%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/StaticPropertyGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/output/SiddhiOutputType.java
(88%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/AbstractQueryGenerator.java
(61%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/FromClause.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/GroupByClause.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/JsonFormatGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/HavingClause.java
(82%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/InsertIntoClause.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/LimitClause.java
(63%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/OrderByClause.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SelectClause.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SiddhiQuery.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/api/IApplicationLink.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/SiddhiStatement.java
(81%)
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/EqualsExpression.java
(74%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/Expression.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/Expressions.java
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/GreaterEqualsExpression.java
(73%)
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/GreaterThanExpression.java
(73%)
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/LesserEqualsExpression.java
(73%)
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/LesserThanExpression.java
(74%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyExpression.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/StaticPropertyGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyExpressionBase.java
(86%)
rename
streampipes-serializers/src/main/java/org/apache/streampipes/serializers/json/EcTypeAdapter.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/PropertyRenameExpression.java
(52%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/RelationalOperator.java
(68%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/RelationalOperatorExpression.java
(51%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/declarer/SemanticEventProducerDeclarer.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/SequenceExpression.java
(58%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/SiddhiTimeUnit.java
(71%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/StreamExpression.java
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/StreamFilterExpression.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/WithinExpression.java
(58%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/aggregation/CountExpression.java
(52%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/list/CollectListExpression.java
(51%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/list/ContainsListExpression.java
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathAddExpression.java
(70%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathDivideExpression.java
(70%)
rename
streampipes-serializers/src/main/java/org/apache/streampipes/serializers/json/AdapterTypeAdapter.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathExpression.java
(50%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathMultiplyExpression.java
(69%)
copy ui/src/app/core-model/coco/Category.ts =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathOperator.java
(72%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathSubtractExpression.java
(69%)
copy
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java =>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/orderby/OrderByExpression.java
(51%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/EveryExpression.java
(58%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/PatternCountExpression.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/StaticPropertyGenerator.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/PatternCountOperator.java
(85%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/pattern/PatternExpression.java
rename
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/application/AppFileExportApplication.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/BatchWindowExpression.java
(64%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/SortWindowExpression.java
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/TimeBatchWindowExpression.java
(54%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/TimeWindowExpression.java
(54%)
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/window/WindowExpression.java
(53%)
create mode 100644
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/utils/SiddhiUtils.java
copy
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/ProcessorParams.java
(56%)
copy
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/SinkParams.java
(58%)
copy
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/dao/PersistCommand.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataProcessor.java
(51%)
copy
streampipes-storage-couchdb/src/main/java/org/apache/streampipes/storage/couchdb/dao/PersistCommand.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/StreamPipesDataSink.java
(55%)
rename
ui/src/app/{core-ui/linechart/labeling-tool/dialogs/change-chartmode/change-chartmode.dialog.html
=> apidocs/apidocs.component.html} (72%)
copy
ui/src/app/{editor/components/pipeline-element-recommendation/pipeline-element-recommendation.component.scss
=> apidocs/apidocs.component.scss} (100%)
rename
streampipes-container/src/main/java/org/apache/streampipes/container/api/PipelineTemplateElement.java
=> ui/src/app/apidocs/apidocs.component.ts (58%)
copy ui/src/app/{core-model/coco/Annotation.ts => apidocs/apidocs.module.ts}
(57%)
copy ui/src/app/{editor/components/pipeline/pipeline.component.css =>
connect/dialog/edit-event-property/components/edit-correction-value/edit-correction-value.component.css}
(100%)
create mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-correction-value/edit-correction-value.component.html
create mode 100644
ui/src/app/connect/dialog/edit-event-property/components/edit-correction-value/edit-correction-value.component.ts
delete mode 100644
ui/src/app/core-ui/image/components/image-labels/image-labels.component.html
delete mode 100644
ui/src/app/core-ui/image/components/image-labels/image-labels.component.ts
copy ui/src/app/{editor/components/pipeline/pipeline.component.css =>
core-ui/labels/components/configure-labels/configure-labels.component.css}
(100%)
create mode 100644
ui/src/app/core-ui/labels/components/configure-labels/configure-labels.component.html
create mode 100644
ui/src/app/core-ui/labels/components/configure-labels/configure-labels.component.ts
copy ui/src/app/{editor/components/pipeline/pipeline.component.css =>
core-ui/labels/components/label-list-item/label-list-item.component.css} (100%)
copy
ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.html
=> core-ui/labels/components/label-list-item/label-list-item.component.html}
(55%)
create mode 100644
ui/src/app/core-ui/labels/components/label-list-item/label-list-item.component.ts
rename
ui/src/app/core-ui/{image/components/image-labels/image-labels.component.css =>
labels/components/select-label/select-label.component.css} (100%)
create mode 100644
ui/src/app/core-ui/labels/components/select-label/select-label.component.html
create mode 100644
ui/src/app/core-ui/labels/components/select-label/select-label.component.ts
create mode 100644 ui/src/app/core-ui/labels/services/label.service.ts
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/components/label-selection/label-selection.component.html
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/components/label-selection/label-selection.component.ts
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/dialogs/change-chartmode/change-chartmode.dialog.css
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/dialogs/change-chartmode/change-chartmode.dialog.ts
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/dialogs/labeling/labeling.dialog.css
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/dialogs/labeling/labeling.dialog.html
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/dialogs/labeling/labeling.dialog.ts
delete mode 100644
ui/src/app/core-ui/linechart/labeling-tool/labeling-tool.module.ts
create mode 100644
ui/src/app/dashboard/components/widgets/bar-race/bar-race-config.ts
copy
ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.html
=> dashboard/components/widgets/bar-race/bar-race-widget.component.html} (66%)
copy
ui/src/app/dashboard/components/widgets/{number/number-widget.component.css =>
bar-race/bar-race-widget.component.scss} (57%)
create mode 100644
ui/src/app/dashboard/components/widgets/bar-race/bar-race-widget.component.ts
create mode 100644
ui/src/app/dashboard/components/widgets/base/base-echarts-widget.ts
create mode 100644
ui/src/app/dashboard/components/widgets/stacked-line-chart/stacked-line-chart-config.ts
copy
ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.html
=>
dashboard/components/widgets/stacked-line-chart/stacked-line-chart-widget.component.html}
(66%)
copy
ui/src/app/dashboard/components/widgets/{number/number-widget.component.css =>
stacked-line-chart/stacked-line-chart-widget.component.scss} (57%)
create mode 100644
ui/src/app/dashboard/components/widgets/stacked-line-chart/stacked-line-chart-widget.component.ts
create mode 100644
ui/src/app/dashboard/components/widgets/status/status-config.ts
copy
ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.html
=> dashboard/components/widgets/status/status-widget.component.html} (67%)
copy
ui/src/app/dashboard/components/widgets/{number/number-widget.component.css =>
status/status-widget.component.scss} (57%)
create mode 100644
ui/src/app/dashboard/components/widgets/status/status-widget.component.ts
create mode 100644
ui/src/app/dashboard/components/widgets/wordcloud/wordcloud-config.ts
copy
ui/src/app/{pipeline-details/components/preview/pipeline-preview.component.html
=> dashboard/components/widgets/wordcloud/wordcloud-widget.component.html} (66%)
copy ui/src/{scss/sp/sp-dialog.scss =>
app/dashboard/components/widgets/wordcloud/wordcloud-widget.component.scss}
(69%)
create mode 100644
ui/src/app/dashboard/components/widgets/wordcloud/wordcloud-widget.component.ts
copy ui/src/app/dashboard/sdk/matching/{property-match.ts =>
list-property-match.ts} (70%)
rename ui/src/app/{core-ui/linechart/labeling-tool =>
data-explorer/components/widgets/line-chart}/components/point-selection-info/point-selection-info.component.css
(100%)
rename ui/src/app/{core-ui/linechart/labeling-tool =>
data-explorer/components/widgets/line-chart}/components/point-selection-info/point-selection-info.component.html
(100%)
rename ui/src/app/{core-ui/linechart/labeling-tool =>
data-explorer/components/widgets/line-chart}/components/point-selection-info/point-selection-info.component.ts
(96%)
rename ui/src/app/{core-ui/linechart/labeling-tool =>
data-explorer/components/widgets/line-chart}/services/color.service.ts (100%)
create mode 100644
ui/src/app/editor/components/pipeline-element-template-config/pipeline-element-template-config.component.html
copy ui/src/app/editor/{dialog/customize/customize.component.scss =>
components/pipeline-element-template-config/pipeline-element-template-config.component.scss}
(79%)
create mode 100644
ui/src/app/editor/components/pipeline-element-template-config/pipeline-element-template-config.component.ts
copy ui/src/app/{dashboard/sdk/matching/property-match.ts =>
editor/components/pipeline-element-template-config/pipeline-element-template-generator.ts}
(52%)
copy ui/src/app/{core-services/semantic-type/semantic-type-utils.service.ts =>
platform-services/apis/measurement-units.service.ts} (53%)
create mode 100644
ui/src/app/platform-services/apis/pipeline-element-template.service.ts
create mode 100644 ui/src/app/profile/components/basic-profile-settings.ts
create mode 100644
ui/src/app/profile/components/general/general-profile-settings.component.html
copy ui/src/app/{dashboard/components/panel/dashboard-panel.component.css =>
profile/components/general/general-profile-settings.component.scss} (79%)
rename
streampipes-app-file-export/src/main/java/org/apache/streampipes/app/file/export/model/IndexInfo.java
=> ui/src/app/profile/components/general/general-profile-settings.component.ts
(55%)
create mode 100644
ui/src/app/profile/components/token/token-management-settings.component.html
copy
ui/src/app/{pipeline-details/components/monitoring/pipeline-monitoring.component.scss
=> profile/components/token/token-management-settings.component.scss} (56%)
create mode 100644
ui/src/app/profile/components/token/token-management-settings.component.ts
create mode 100644 ui/src/app/profile/profile.component.html
rename
ui/src/app/{core-ui/linechart/labeling-tool/components/label-selection/label-selection.component.css
=> profile/profile.component.scss} (94%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/monitoring/runtime/ProtocolHandler.java
=> ui/src/app/profile/profile.component.ts (69%)
create mode 100644 ui/src/app/profile/profile.module.ts
create mode 100644 ui/src/app/profile/profile.service.ts
delete mode 100644 ui/tsconfig.base.json
