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