This is an automated email from the ASF dual-hosted git repository.
micklich pushed a change to branch SP-584
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 6b659970d [STREAMPIPES-584] pom files adjustments
add d6a7e94d9 [hotfix] Remove isDebug from `IAdapter`
add d74a8353a Merge pull request #1112 from
apache/hotfix-remove-debug-from-adapter
add 2d338cfc7 [hotfix] Remove performance module
add 222f60dc8 Merge pull request #1111 from
apache/hotfix-remove-performance-module
add dce34337a Reduce warnings at startup, improve structure of resource
configs (#1091)
add 9e00f0d6e Bump graalvm.js.version from 21.3.0 to 22.3.1
add f582f869c Merge pull request #1118 from
apache/dependabot/maven/graalvm.js.version-22.3.1
add ecbc43024 [#1121] Add replay once option to FileStreamProtocol
add b5abec08c [#1114] Adapters can now be added without starting them
add 88981773c [hotfix] Undo mark baseUrl method as static
add d305616ec [hotfix] Do not start set adpaters when instantiated
add 619361120 [hotfix] Fix import of AdapterDescription models
add c1ac05a14 Merge pull request #1117 from apache/SP-1114
add acf446d8c Merge branch 'dev' into SP-1121
add 62bf0927b [#1121] First start persistence pipeline before starting
adapter
add dd6c07535 [wip] Remove set adapters from e2e tests
add 37be222bb [#1121] Add option to fast replay a file to
FileStreamProtocol
add 469513753 [#1121] Handle cases where timestamp is not part of
FileStreamProtocol events
add 716e98ddf Merge branch 'SP-1121' into SP-1132
add ddb280fcf [#1132] Fix preprocessing adapter rules
add 4d9c7aff8 Bump jcl-over-slf4j from 1.7.30 to 2.0.6
add 289990ea3 [hotfix] Remove dependency jcl-over-slf4j from pom file
add bc9fa1dc1 Merge pull request #1123 from
apache/dependabot/maven/org.slf4j-jcl-over-slf4j-2.0.6
add f01988656 [hotfix] use logo link from homepage for python docs
add 2a2d06f62 Bump mkdocstrings[python] in /streampipes-client-python
(#1127)
add 7be2b887d Improve structure of pipeline execution management (#1096)
add ec5e75171 Fix checkstyle issues (#1096)
add 7d091ba95 Fix checkstyle issue (#1096)
add d19b7e042 Add comments to intefaces (#1096)
add 38074381c [hotfix] Add some comments and a log message
add db127e959 [hotfix] update disclaimer for the Python client
add d91c98f80 Redirect to previous view after successful login (#1140)
add d77c48802 [#877] Format and lint core-ui module
add e8fc55e28 [#877] Remove commented code
add 371a29765 Merge pull request #1120 from
aamirxshaikh/STREAMPIPES-877-core-ui
add 4db932538 [#877] apply formatting and linting to login module (#1134)
add cd26f1f37 [#877] apply formatting and linting to info module (#1136)
add 4655a9add [#877] apply formatting and linting to files module (#1137)
add f6406e08d Merge branch 'dev' into SP-1140
add aa2e1c53c Merge pull request #1141 from apache/SP-1140
add ad423278c Improve structure of pipeline execution management (#1096)
add 9dd1a91f6 Fix checkstyle issues (#1096)
add 473a4a023 Fix checkstyle issue (#1096)
add 7acee1454 Add comments to intefaces (#1096)
add 96ee8cce0 Support output data streams in functions (#1133)
add 109ea0263 Extend client API to add data streams (#1133)
add 7a57d3003 Fix endpoint path (#1133)
add 5ad116436 Minor improvements to code style (#1133)
add cc3ef284f Merge branch 'dev' into SP-1133
add 468032654 Merge pull request #1135 from apache/SP-1133
add a7276c291 Merge branch 'dev' of github.com:apache/streampipes into dev
add a6146e53c Fix path in stream resource
add 0dc12d794 Bump @angular-eslint/template-parser from 15.1.0 to 15.2.0
in /ui (#1145)
add 3cb8b7b74 refactor: introduce messaging endpoint for python client
(#1126)
add 3a15af353 Bump blacken-docs from 1.12.1 to 1.13.0 in
/streampipes-client-python (#1150)
add 407f1dcc1 [#877] Format and lint CustomMaterial module
add 6a5b00d7b Merge pull request #1144 from
aamirxshaikh/STREAMPIPES-877-CustomMaterial
add 694b84759 [hotfix] Improve echarts import
add 73422d4a4 [#1132] Remove set adapters from e2e tests
add ec9ee297e Merge branch 'dev' into SP-1132
add 6b826b28c [#1132] Fix preprocessing rule e2e tests
add 62c2ea4c6 Merge branch 'dev' into SP-1132
add 4a97d1229 [#1132] Add wait to fix processing element tests
add 09e70845e [hotfix] Extract string into a variable
add 8b079f028 Merge pull request #1153 from apache/SP-1132
add dc3aa010b [hotfix] Fix processing element e2e tests
add 8e2a4c3ed Bump proton-j from 0.30.0 to 0.34.0
add 8a4f9df82 Merge pull request #1130 from
apache/dependabot/maven/org.apache.qpid-proton-j-0.34.0
add d1df87d77 Bump javapoet from 1.6.1 to 1.13.0
add 6270a449d remove javapoet
add 21ebe64ef Merge branch 'dev' into
dependabot/maven/com.squareup-javapoet-1.13.0
add 4b0636995 Merge pull request #1131 from
apache/dependabot/maven/com.squareup-javapoet-1.13.0
add 10e0e720c Bump ua-parser-js from 0.7.32 to 0.7.33 in /ui
add 09ff63830 Merge pull request #1156 from
apache/dependabot/npm_and_yarn/ui/ua-parser-js-0.7.33
add a43b05635 Bump @angular-eslint/eslint-plugin from 15.1.0 to 15.2.0 in
/ui (#1152)
add 381465a10 [#877] apply formatting and linting to data-explorer module
(#1139)
add b89ab89ab [#877] Format and lint dashboard module (#1154)
add f38b07910 [#877] apply formatting and linting to editor module (#1138)
add ede2fff0b add rest endpoint to query a function definition by it's id
(#1149)
add 51ba6d871 Bump pre-commit from 2.21.0 to 3.0.0 in
/streampipes-client-python (#1151)
add 569421cd8 refactor: further clean up python data model & introduce
function definition (#1147)
add a5f44f65e Bump lz4-java from 1.7.1 to 1.8.0 (#1160)
add a23795b43 Bump @angular-eslint/eslint-plugin-template from 15.1.0 to
15.2.0 in /ui (#1161)
add 9e71a2809 Update GitHub notification settings (#1162)
add ebfd339fb remove outdated README files (#1167)
add 22182a9a1 Bump simple-java-mail from 7.6.0 to 7.8.0
add b18285738 Merge pull request #1170 from
apache/dependabot/maven/org.simplejavamail-simple-java-mail-7.8.0
add 679e61517 Bump maven-dependency-plugin from 3.2.0 to 3.5.0
add 540650aa0 Merge pull request #1159 from
apache/dependabot/maven/org.apache.maven.plugins-maven-dependency-plugin-3.5.0
add b7c3e5ebf [#1146] Session based implementation of IoTDB sink
add f57039132 [#1146] Fix onEvent() implementation
add 9340f7f2f [#1146] add tests
add 0120fd201 [#1146] update iotdb docker-compose files in installer/cli
add 56f464c03 [#1146] using SessionPool instead of Session to handle
connection dies
add 3abfd88fe Merge pull request #1166 from
SteveYurongSu/iotdb-session-client
add e02d3bf5e Replace consul-client with consul-api library (#1158)
add bac4d45e6 Remove obsolete class (#1158)
add 19f525019 Fix checkstyle (#1158)
add ca9d9b33b Bump consul version to 1.14.3 (#1157)
add 00a043c3f [hotfix] Update Consul version in root docker-compose.yml
add f1d93f668 Bump isort from 5.11.4 to 5.12.0 in
/streampipes-client-python (#1175)
add a022fec09 Bump @typescript-eslint/eslint-plugin from 5.48.0 to 5.49.0
in /ui (#1179)
add 9450fcc97 [hotfix] Extend CustomRequestApi with new get request (#1180)
add 03118eda5 Bump checkstyle from 9.2.1 to 10.6.0 (#1177)
add 801c4166f [#792] rename python client to `streampipes-client` (#1168)
add 1442808e4 Bump tslib from 2.4.1 to 2.5.0 in /ui (#1188)
add cefb2363d Bump jna from 5.8.0 to 5.13.0
add cb5b3d482 Bump plotly.js from 2.17.0 to 2.18.0 in /ui (#1194)
add 2b256ee30 [#1104] add GitHub workflow to label PRs automatically
(#1142)
add 6232b22be [hotfix] fix file endings of labeler workflow
add ceecccad2 Bump eslint from 8.31.0 to 8.33.0 in /ui (#1203)
add 5fbcb0349 Bump http-cache-semantics from 4.1.0 to 4.1.1 in /ui (#1204)
add 99b67f90d Use latest CouchDB version 3.3.1 (#1157)
add 530bac0c3 Refactor code to support Influx 2 (#1157)
add c50fae6d4 Bump influx version to 2.6 in compose files (#1157)
add 15d71e53e Bump influx version to 2.6 in helm charts (#1157)
add 592c59ecc Use latest CouchDB version 3.3.1 (#1157)
add b1eac7409 Merge branch 'sp-1157-upgrade-third-party-services' of
github.com:apache/streampipes into sp-1157-upgrade-third-party-services
add 72f11f133 Add authentication to raw CouchDB requests (#1157)
add 1696d4771 Make influx init mode configurable (#1157)
add 08ecbf2c1 Modify influx init mode in validation compose file (#1157)
add e392f547c Migrate endpoint to delete data lake resources (#1157)
add 5f2b6fbf7 Refactor InfluxDB adapters and sinks, fix smoke test (#1200)
add 39d8023ad Fix test
add 72217f30e Merge pull request #1174 from
apache/sp-1157-upgrade-third-party-services
add 81a898842 add github-actions to denpendabot config (#1205)
add c7eb4c138 Bump docker/setup-buildx-action from 1 to 2
add 2596047b4 Bump actions/checkout from 1 to 3
add 6d53a3d97 Bump actions/setup-java from 2 to 3
add 3695a0854 Bump docker/build-push-action from 2 to 4
add 1898c4482 Bump @typescript-eslint/eslint-plugin from 5.49.0 to 5.50.0
in /ui (#1214)
add 849e431c0 [#1190] Apache TubeMQ (InLong) Adapter & Sink (#1191)
add b22cdaa87 Dependabot/maven/bcprov.version 1.70 (#1198)
add 4f4385444 Bump black from 22.12.0 to 23.1.0 in
/streampipes-client-python (#1201)
add 813fc71ff Merge branch 'dev' into SP-584
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 14 +
.github/dependabot.yml | 6 +-
.github/pr-labeler-config.yml | 62 ++
.github/workflows/build.yml | 24 +-
.github/workflows/cypress-test.yml | 4 +-
.asf.yaml => .github/workflows/pr-labeler.yml | 39 +-
.github/workflows/pr-validation.yml | 16 +-
docker-compose.yml | 19 +-
installer/README.md | 78 --
installer/cli/.env | 5 +
.../deploy/standalone/consul/docker-compose.yml | 6 +-
.../deploy/standalone/couchdb/docker-compose.yml | 5 +-
.../deploy/standalone/influxdb/docker-compose.yml | 10 +-
.../deploy/standalone/iotdb/docker-compose.dev.yml | 5 +-
.../cli/deploy/standalone/iotdb/docker-compose.yml | 5 +-
.../{iotdb => tubemq}/docker-compose.dev.yml | 9 +-
.../{iotdb => tubemq}/docker-compose.yml | 8 +-
installer/compose/.env | 4 +
installer/compose/docker-compose.full.yml | 17 +-
installer/compose/docker-compose.nats.yml | 17 +-
installer/compose/docker-compose.yml | 17 +-
.../external/consul/consul-deployment.yaml | 2 +-
.../external/couchdb/couchdb-deployment.yaml | 5 +
.../external/influxdb/influxdb-deployment.yaml | 19 +-
.../templates/external/influxdb/influxdb2-pvc.yaml | 46 +-
installer/k8s/values.yaml | 17 +-
pom.xml | 54 +-
streampipes-client-python/.pre-commit-config.yaml | 7 +
streampipes-client-python/Makefile | 2 -
streampipes-client-python/README.md | 13 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 2 +-
streampipes-client-python/mkdocs.yml | 2 +-
streampipes-client-python/setup.py | 14 +-
.../streampipes_client/__version__.py | 2 +-
.../streampipes_client/client/client.py | 2 +-
.../streampipes_client/endpoint/__init__.py | 9 +-
.../endpoint/{ => api}/__init__.py | 1 +
.../endpoint/{ => api}/data_lake_measure.py | 0
.../endpoint/{ => api}/data_stream.py | 0
.../streampipes_client/endpoint/endpoint.py | 94 +-
.../streampipes_client/endpoint/exceptions.py | 52 +
.../{ => endpoint/messaging}/__init__.py | 0
.../functions/broker/__init__.py | 8 +
.../functions/function_handler.py | 7 +-
.../functions/streampipes_function.py | 25 +-
.../streampipes_client/model/common.py | 33 +-
.../model/container/resource_container.py | 12 +-
.../streampipes_client/model/resource/__init__.py | 2 +
.../model/resource/data_lake_measure.py | 1 +
.../model/resource/data_stream.py | 1 +
.../model/resource/function_definition.py | 71 ++
.../streampipes_client/model/resource/resource.py | 22 +-
.../tests/client/test_client.py | 2 +-
.../tests/client/test_credential_provider.py | 2 -
.../tests/client/test_endpoint.py | 37 +-
.../tests/functions/test_function_handler.py | 8 +-
streampipes-client/pom.xml | 7 +
.../apache/streampipes/client/api/AdminApi.java | 12 +
.../streampipes/client/api/CustomRequestApi.java | 9 +
.../streampipes/client/api/DataStreamApi.java | 9 +-
.../client/util/StreamPipesApiPath.java | 33 +-
.../client/util/StreamPipesApiPathTest.java | 80 ++
.../apache/streampipes/commons/constants/Envs.java | 83 +-
.../commons/environment/DefaultEnvironment.java | 101 ++
.../commons/environment/Environment.java | 63 ++
.../commons/environment/Environments.java | 8 +-
.../variable/BooleanEnvironmentVariable.java | 15 +-
.../commons/environment/variable/EnvResolver.java | 10 +-
.../environment/variable/EnvironmentVariable.java | 68 ++
.../variable/IntEnvironmentVariable.java | 17 +-
.../variable/StringEnvironmentVariable.java | 20 +-
streampipes-config/pom.xml | 5 +
.../streampipes/config/backend/BackendConfig.java | 7 +-
...Settings.java => DefaultMessagingSettings.java} | 83 +-
.../management/AdapterMasterManagement.java | 31 +-
.../connect/management/util/GroundingUtils.java | 2 +-
.../dataexplorer/commons/DataExplorerWriter.java | 67 --
.../dataexplorer/commons/TimeSeriesStore.java | 8 +-
.../dataexplorer/commons/auth/AuthInterceptor.java | 34 +-
.../dataexplorer/commons/image/ImageStore.java | 20 +-
.../commons/influx/InfluxAuthMode.java | 7 +-
.../commons/influx/InfluxClientProvider.java | 64 ++
.../commons/influx/InfluxClientUtils.java | 28 +-
.../commons/influx/InfluxConnectionSettings.java | 90 +-
.../commons/influx/InfluxRequests.java | 34 +-
.../dataexplorer/commons/influx/InfluxStore.java | 28 +-
streampipes-data-explorer/pom.xml | 5 +
.../dataexplorer/DataLakeManagementV4.java | 5 +-
.../dataexplorer/query/DataExplorerQuery.java | 4 +-
.../dataexplorer/utils/DataExplorerUtils.java | 15 -
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 6 +-
.../extensions/api/connect/IAdapter.java | 3 +-
.../extensions/api/declarer/IFunctionConfig.java | 14 +-
.../api/declarer/IStreamPipesFunctionDeclarer.java | 4 +-
.../management/config/ConfigExtractor.java | 4 +-
.../management/connect/adapter/Adapter.java | 22 +-
.../connect/adapter/AdapterPipelineGenerator.java | 2 +-
.../adapter/model/generic/GenericAdapter.java | 6 +-
.../model/generic/GenericDataSetAdapter.java | 12 -
.../model/generic/GenericDataStreamAdapter.java | 15 +-
.../adapter/model/specific/SpecificAdapter.java | 3 -
.../model/specific/SpecificDataSetAdapter.java | 3 -
.../model/specific/SpecificDataStreamAdapter.java | 4 -
.../TransformValueAdapterPipelineElement.java | 4 +
.../transform/value/ValueEventTransformer.java | 11 +-
.../adapter/util/TransportFormatGenerator.java | 2 +-
.../management/init/DeclarersSingleton.java | 2 +-
streampipes-extensions/README.md | 110 --
.../streampipes-connect-adapters-iiot/pom.xml | 10 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 6 +-
.../iiot/adapters/influxdb/InfluxDbSetAdapter.java | 178 ----
.../iiot/protocol/stream/FileStreamProtocol.java | 146 ++-
.../iiot/protocol/stream/TubeMQProtocol.java | 210 ++++
.../strings.en | 41 -
.../strings.en | 18 +-
.../documentation.md | 17 +-
.../icon.png | Bin 0 -> 22024 bytes
.../strings.en | 17 +-
.../streampipes-connect-adapters/pom.xml | 2 +-
.../streampipes-connectors-influx}/pom.xml | 32 +-
.../connectors/influx/InfluxConnectorsInit.java} | 29 +-
.../connectors/influx/adapter}/InfluxDbClient.java | 75 +-
.../influx/adapter}/InfluxDbStreamAdapter.java | 59 +-
.../connectors/influx/shared/InfluxConfigs.java | 84 ++
.../connectors/influx/shared/InfluxKeys.java | 38 +
.../influx/shared/SharedInfluxClient.java | 53 +
.../connectors/influx/sink/InfluxDbClient.java | 129 +++
.../connectors/influx/sink/InfluxDbSink.java | 110 ++
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 42 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 20 +-
.../streampipes-extensions-all-iiot/pom.xml | 5 +
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 2 +
.../streampipes-pipeline-elements-all-jvm/pom.xml | 5 +
.../pe/jvm/AllPipelineElementsInit.java | 26 +-
.../streampipes-sinks-brokers-jvm/pom.xml | 4 +
.../sinks/brokers/jvm/BrokersJvmInit.java | 2 +
.../sinks/brokers/jvm/tubemq/TubeMQParameters.java | 46 +
.../brokers/jvm/tubemq/TubeMQPublisherSink.java | 106 ++
.../documentation.md | 25 +-
.../icon.png | Bin 0 -> 22024 bytes
.../strings.en | 17 +-
.../streampipes-sinks-databases-jvm/pom.xml | 21 +-
.../sinks/databases/jvm/DatabasesJvmInit.java | 2 -
.../sinks/databases/jvm/influxdb/InfluxDb.java | 69 --
.../databases/jvm/influxdb/InfluxDbClient.java | 193 ----
.../databases/jvm/influxdb/InfluxDbController.java | 97 --
.../databases/jvm/influxdb/InfluxDbParameters.java | 94 --
.../sinks/databases/jvm/iotdb/IotDb.java | 214 ++--
.../sinks/databases/jvm/iotdb/IotDbController.java | 66 +-
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 70 +-
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 21 -
.../jvm/jdbcclient/model/DbDataTypes.java | 5 -
.../jvm/jdbcclient/model/SupportedDbEngines.java | 1 -
.../icon.png | Bin 9982 -> 0 bytes
.../documentation.md | 31 +-
.../strings.en | 15 +-
.../databases/jvm/iotdb/TestIotDbParameters.java | 52 +
.../sinks/internal/jvm/datalake/DataLakeSink.java | 3 +-
.../pom.xml | 2 +-
streampipes-integration-tests/pom.xml | 11 +
.../svcdiscovery/AbstractConsulTest.java | 74 ++
.../svcdiscovery/ConsulKvManagementTest.java | 63 ++
.../svcdiscovery/ConsulSpConfigTest.java | 71 ++
.../svcdiscovery/ConsulSpServiceDiscoveryTest.java | 105 ++
.../src/test/resources/logback-test.xml | 33 +-
.../org/apache/streampipes/model/SpDataSet.java | 15 +-
.../streampipes/model/api/EndpointSelectable.java | 69 ++
.../model/base/InvocableStreamPipesEntity.java | 18 +-
.../model/config}/MessagingSettings.java | 32 +-
.../streampipes/model/config}/SpDataFormat.java | 2 +-
.../streampipes/model/config}/SpProtocol.java | 2 +-
.../model/message/PipelineStatusMessage.java | 9 +-
.../model/pipeline/PipelineOperationStatus.java | 10 +-
.../performance/PipelinePerformanceTest.java | 57 -
.../performance/dataprovider/JsonDataProvider.java | 110 --
.../dataprovider/SimpleSchemaProvider.java | 53 -
.../performance/model/PerformanceTestSettings.java | 79 --
.../pipeline/PipelineDescriptionFetcher.java | 21 -
.../pipeline/PipelineDescriptionParser.java | 21 -
.../performance/producer/DataSimulator.java | 74 --
.../simulation/DataReplayStatusNotifier.java | 24 -
.../performance/simulation/SimulationManager.java | 69 --
.../tests/serializer/JsonSerializerTest.java | 71 --
.../performance/util/ParameterTool.java | 36 -
.../manager/execution/PipelineExecutionInfo.java | 106 ++
.../execution/PipelineExecutionTaskFactory.java | 60 ++
.../manager/execution/PipelineExecutor.java | 57 +
.../ExtensionsServiceEndpointProvider.java | 62 ++
.../manager/execution/http/DetachHttpRequest.java | 51 +-
.../http/DetachPipelineElementSubmitter.java | 53 +
.../manager/execution/http/GraphSubmitter.java | 132 ---
.../manager/execution/http/HttpRequestBuilder.java | 98 --
.../manager/execution/http/InvokeHttpRequest.java | 54 +
.../http/InvokePipelineElementSubmitter.java | 81 ++
.../execution/http/PipelineElementHttpRequest.java | 73 ++
.../execution/http/PipelineElementSubmitter.java | 82 ++
.../manager/execution/http/PipelineExecutor.java | 243 -----
.../provider/CurrentPipelineElementProvider.java} | 21 +-
.../provider/PipelineElementProvider.java | 12 +-
.../provider/StoredPipelineElementProvider.java} | 22 +-
.../execution/task/AfterInvocationTask.java | 65 ++
.../execution/task/DiscoverEndpointsTask.java | 88 ++
.../execution/task/PipelineExecutionTask.java | 17 +-
.../execution/task/SecretEncryptionTask.java | 39 +-
.../execution/task/StorePipelineStatusTask.java | 80 ++
.../manager/execution/task/SubmitRequestTask.java | 51 +
.../manager/execution/task/UpdateGroupIdTask.java | 46 +
.../function/FunctionRegistrationService.java | 4 +
.../manager/health/PipelineHealthCheck.java | 13 +-
.../manager/matching/DataSetGroundingSelector.java | 2 +-
.../manager/matching/FormatSelector.java | 2 +-
.../manager/matching/ProtocolSelector.java | 2 +-
.../streampipes/manager/operations/Operations.java | 22 +-
.../manager/preview/PipelinePreview.java | 10 +-
.../http => storage}/PipelineStorageService.java | 2 +-
.../RunningPipelineElementStorage.java} | 8 +-
.../streampipes/manager/storage/UserService.java | 101 --
.../streampipes/ps/DataLakeMeasureResourceV4.java | 1 -
.../AbstractPipelineElementResourceManager.java | 12 +
.../rest/core/base/impl/AbstractRestResource.java | 5 -
.../streampipes/rest/impl/FunctionsResource.java | 7 +
.../streampipes/rest/impl/PipelineResource.java | 1 -
.../streampipes/rest/impl/admin/ConsulConfig.java | 2 +-
.../rest/impl/pe/DataStreamResource.java | 17 +-
.../streampipes/rest/security/AuthConstants.java | 4 +
streampipes-sdk/pom.xml | 6 +-
.../service/base/rest/BaseResourceConfig.java | 20 +-
.../service/core/StreamPipesResourceConfig.java | 167 +--
.../svcdiscovery/api/ISpKvManagement.java | 2 -
.../svcdiscovery/api/model/ConfigItem.java | 24 +
streampipes-service-discovery-consul/pom.xml | 9 +-
.../svcdiscovery/consul/AbstractConsulService.java | 14 +-
.../consul/ConsulHealthServiceManager.java | 82 +-
.../svcdiscovery/consul/ConsulProvider.java | 79 +-
.../svcdiscovery/consul/ConsulSpConfig.java | 63 +-
.../svcdiscovery/consul/SpConsulKvManagement.java | 55 +-
.../consul/SpConsulServiceDiscovery.java | 95 +-
.../svcdiscovery/SpServiceDiscovery.java | 21 +-
.../extensions/ExtensionsResourceConfig.java | 40 +-
.../function/StreamPipesFunctionHandler.java | 36 +-
streampipes-storage-couchdb/pom.xml | 4 +
.../couchdb/utils/CouchDbViewGenerator.java | 7 +-
.../streampipes/storage/couchdb/utils/Utils.java | 39 +-
.../standalone/function/FunctionConfig.java | 34 +-
.../standalone/function/FunctionConfigBuilder.java | 25 +-
.../standalone/function/FunctionContext.java | 9 +
.../function/FunctionContextGenerator.java | 10 +-
.../standalone/function/StreamPipesFunction.java | 64 +-
ui/.eslintignore | 11 -
ui/.prettierignore | 11 -
.../fixtures/connect/aggregationRules/expected.csv | 2 -
.../connect/removeDuplicateRules/expected.csv | 11 +-
.../connect/removeDuplicateRules/input.csv | 20 +-
.../support/builder/GenericAdapterBuilder.ts | 7 +-
.../support/builder/SpecificAdapterBuilder.ts | 5 +
ui/cypress/support/model/AdapterInput.ts | 3 +
.../support/utils/DataDownloadDialogUtils.ts | 2 -
ui/cypress/support/utils/PrepareTestDataUtils.ts | 23 +-
.../support/utils/ProcessingElementTestUtils.ts | 20 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 14 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 81 +-
ui/cypress/support/utils/datalake/DataLakeUtils.ts | 16 +-
...pec.ts => createAdapterWithoutStarting.spec.ts} | 31 +-
ui/cypress/tests/adapter/editAdapter.smoke.spec.ts | 18 +-
ui/cypress/tests/adapter/fileStream.smoke.spec.ts | 1 -
ui/cypress/tests/adapter/formats/format.spec.ts | 2 +-
.../tests/adapter/persistInDataLake.smoke.spec.ts | 1 -
ui/cypress/tests/adapter/rules/streamRules.spec.ts | 4 +-
ui/cypress/tests/adapter/rules/valueRules.ts | 1 +
.../dataDownloadDialogTest.smoke.spec.ts | 1 +
ui/cypress/tests/datalake/deleteWidget.ts | 1 -
.../datalake/widgetDataConfiguration.smoke.spec.ts | 2 -
ui/cypress/tests/datalake/widgets/table.ts | 2 +-
ui/cypress/tests/thirdparty/InfluxDb.smoke.spec.ts | 19 +-
ui/deployment/appng5.module.mst | 4 +
ui/package-lock.json | 711 +++++++------
ui/package.json | 14 +-
.../src/lib/apis/adapter.service.ts | 6 +-
.../app/CustomMaterial/custom-material.module.ts | 11 +-
.../_guards/auth.can-activate-children.guard.ts | 4 +-
.../adapter-options-panel.component.html | 1 +
.../adapter-options-panel.component.ts | 5 +-
.../start-adapter-configuration.component.html | 12 +-
.../start-adapter-configuration.component.ts | 3 +
.../configuration-group.component.html | 4 +-
.../pipeline-element-runtime-info.component.html | 7 +-
.../adapter-started-dialog.component.html | 4 +-
.../adapter-started-dialog.component.ts | 140 ++-
.../adapter-template-dialog.component.html | 4 +-
ui/src/app/core-ui/core-ui.module.ts | 256 +++--
.../components/download/download.component.html | 34 +-
.../components/download/download.component.scss | 1 -
.../components/download/download.component.ts | 57 +-
.../select-data-missing-values.component.html | 29 +-
.../select-data-missing-values.component.scss | 2 -
.../select-data-missing-values.component.ts | 24 +-
.../select-data-range.component.html | 128 ++-
.../select-data-range.component.scss | 1 -
.../select-data-range.component.ts | 59 +-
.../select-data/select-data.component.html | 14 +-
.../select-data/select-data.component.scss | 11 +-
.../select-data/select-data.component.ts | 26 +-
.../select-format/select-format.component.html | 64 +-
.../select-format/select-format.component.scss | 1 -
.../select-format/select-format.component.ts | 23 +-
.../data-download-dialog.component.html | 116 +-
.../data-download-dialog.component.scss | 12 +-
.../data-download-dialog.component.ts | 92 +-
.../model/data-download-dialog.model.ts | 17 +-
.../model/data-export-config.model.ts | 9 +-
.../model/download-progress.model.ts | 4 +-
.../model/export-config.model.ts | 5 +-
.../model/format-export-config.model.ts | 8 +-
.../services/data-export.service.ts | 203 ++--
.../services/file-name.service.spec.ts | 170 +--
.../services/file-name.service.ts | 55 +-
.../core-ui/error-hint/error-hint.component.html | 49 +-
.../core-ui/error-hint/error-hint.component.scss | 4 +-
.../app/core-ui/error-hint/error-hint.component.ts | 30 +-
.../image-annotations.component.css | 6 +-
.../image-annotations.component.html | 35 +-
.../image-annotations.component.ts | 54 +-
.../image-bar-preview.component.html | 7 +-
.../image-bar-preview.component.scss | 9 +-
.../image-bar-preview.component.ts | 47 +-
.../components/image-bar/image-bar.component.css | 2 -
.../components/image-bar/image-bar.component.html | 75 +-
.../components/image-bar/image-bar.component.ts | 106 +-
.../image-container/image-container.component.css | 3 +-
.../image-container/image-container.component.html | 14 +-
.../image-container/image-container.component.ts | 68 +-
.../image-labeling/image-labeling.component.css | 2 +-
.../image-labeling/image-labeling.component.html | 169 ++-
.../image-labeling/image-labeling.component.ts | 492 +++++----
.../image/image-viewer/image-viewer.component.css | 2 +-
.../image/image-viewer/image-viewer.component.html | 32 +-
.../image/image-viewer/image-viewer.component.ts | 41 +-
ui/src/app/core-ui/image/image.component.css | 2 +-
ui/src/app/core-ui/image/image.component.html | 10 +-
ui/src/app/core-ui/image/image.component.ts | 25 +-
ui/src/app/core-ui/image/model/coordinates.ts | 4 +-
ui/src/app/core-ui/image/model/labeling-mode.ts | 8 +-
.../image/services/BrushLabeling.service.ts | 255 +++--
.../core-ui/image/services/CocoFormat.service.ts | 208 ++--
.../core-ui/image/services/LabelingMode.service.ts | 86 +-
.../image/services/PolygonLabeling.service.ts | 482 +++++----
.../image/services/ReactLabeling.service.ts | 375 ++++---
ui/src/app/core-ui/image/services/color.service.ts | 28 +-
ui/src/app/core-ui/image/util/color.util.ts | 28 +-
.../core-ui/image/util/imageTranslation.util.ts | 39 +-
.../classification/imageClassification.ts | 57 +-
.../configure-labels.component.css | 2 +-
.../configure-labels.component.html | 49 +-
.../configure-labels/configure-labels.component.ts | 170 +--
.../label-list-item/label-list-item.component.css | 2 +-
.../label-list-item/label-list-item.component.html | 34 +-
.../label-list-item/label-list-item.component.ts | 54 +-
.../select-label/select-label.component.css | 6 +-
.../select-label/select-label.component.html | 54 +-
.../select-label/select-label.component.ts | 97 +-
.../app/core-ui/labels/services/label.service.ts | 135 +--
.../simple-logs/simple-logs.component.html | 33 +-
.../simple-logs/simple-logs.component.ts | 15 +-
.../simple-metrics/simple-metrics.component.html | 40 +-
.../simple-metrics/simple-metrics.component.ts | 27 +-
.../object-permission-dialog.component.html | 122 ++-
.../object-permission-dialog.component.scss | 5 +-
.../object-permission-dialog.component.ts | 416 ++++----
...pipeline-element-template-config.component.html | 77 +-
...pipeline-element-template-config.component.scss | 12 +-
.../pipeline-element-template-config.component.ts | 128 +--
.../pipeline-element-template-generator.ts | 146 +--
.../pipeline-element-template.pipe.ts | 29 +-
.../pipeline-started-status.component.html | 92 +-
.../pipeline-started-status.component.scss | 8 +-
.../pipeline-started-status.component.ts | 43 +-
.../split-section/split-section.component.html | 4 +-
.../split-section/split-section.component.scss | 18 +-
.../split-section/split-section.component.ts | 16 +-
.../base/abstract-static-property.ts | 56 +-
.../base/abstract-validated-static-property.ts | 65 +-
.../filter/display-recommended.pipe.ts | 45 +-
.../core-ui/static-properties/input.validator.ts | 36 +-
.../static-alternatives.component.css | 17 +-
.../static-alternatives.component.html | 98 +-
.../static-alternatives.component.ts | 23 +-
.../static-any-input.component.css | 1 -
.../static-any-input.component.html | 24 +-
.../static-any-input/static-any-input.component.ts | 31 +-
.../static-code-input.component.html | 43 +-
.../static-code-input.component.scss | 5 +-
.../static-code-input.component.ts | 136 +--
.../add-to-collection.component.css | 2 +-
.../add-to-collection.component.html | 36 +-
.../add-to-collection.component.spec.ts | 25 +-
.../add-to-collection.component.ts | 258 +++--
.../static-collection.component.css | 2 +-
.../static-collection.component.html | 46 +-
.../static-collection.component.ts | 64 +-
.../static-color-picker.component.css | 2 +-
.../static-color-picker.component.html | 21 +-
.../static-color-picker.component.ts | 44 +-
.../static-file-input.component.css | 2 +-
.../static-file-input.component.html | 113 +-
.../static-file-input.component.ts | 101 +-
.../static-free-input.component.html | 80 +-
.../static-free-input.component.scss | 7 +-
.../static-free-input.component.ts | 175 ++--
.../static-group/static-group.component.css | 2 +-
.../static-group/static-group.component.html | 61 +-
.../static-group/static-group.component.ts | 15 +-
.../static-mapping-nary.component.html | 41 +-
.../static-mapping-nary.component.scss | 3 +-
.../static-mapping-nary.component.ts | 39 +-
.../static-mapping-unary.component.css | 9 +-
.../static-mapping-unary.component.html | 26 +-
.../static-mapping-unary.component.ts | 24 +-
.../static-mapping/static-mapping.ts | 46 +-
.../static-one-of-input.component.css | 4 +-
.../static-one-of-input.component.html | 32 +-
.../static-one-of-input.component.ts | 71 +-
.../static-property-util.service.ts | 88 +-
.../static-property.component.css | 20 +-
.../static-property.component.html | 323 +++---
.../static-properties/static-property.component.ts | 215 ++--
...tic-runtime-resolvable-any-input.component.html | 49 +-
...tatic-runtime-resolvable-any-input.component.ts | 25 +-
.../base-runtime-resolvable-input.ts | 186 ++--
.../base-runtime-resolvable-selection-input.ts | 35 +-
.../runtime-resolvable.service.ts | 63 +-
...ic-runtime-resolvable-oneof-input.component.css | 6 +-
...c-runtime-resolvable-oneof-input.component.html | 46 +-
...tic-runtime-resolvable-oneof-input.component.ts | 43 +-
.../static-tree-input.component.html | 69 +-
.../static-tree-input.component.scss | 16 +-
.../static-tree-input.component.ts | 198 ++--
.../static-secret-input.component.css | 1 -
.../static-secret-input.component.html | 22 +-
.../static-secret-input.component.ts | 27 +-
.../static-slide-toggle.component.html | 13 +-
.../static-slide-toggle.component.ts | 46 +-
.../app/core-ui/status/status-widget.component.css | 10 +-
.../core-ui/status/status-widget.component.html | 18 +-
.../app/core-ui/status/status-widget.component.ts | 21 +-
.../components/grid/dashboard-grid.component.css | 2 +-
.../components/grid/dashboard-grid.component.html | 32 +-
.../components/grid/dashboard-grid.component.ts | 255 ++---
.../overview/dashboard-overview.component.css | 4 +-
.../overview/dashboard-overview.component.html | 262 +++--
.../overview/dashboard-overview.component.ts | 240 +++--
.../components/panel/dashboard-panel.component.css | 6 +-
.../panel/dashboard-panel.component.html | 81 +-
.../components/panel/dashboard-panel.component.ts | 136 ++-
.../standalone/standalone-dashboard.component.css | 2 +-
.../standalone/standalone-dashboard.component.html | 10 +-
.../standalone/standalone-dashboard.component.ts | 20 +-
.../widget/dashboard-widget.component.css | 17 +-
.../widget/dashboard-widget.component.html | 385 ++++---
.../widget/dashboard-widget.component.ts | 311 +++---
.../components/widgets/area/area-config.ts | 3 -
.../widgets/area/area-widget.component.css | 6 +-
.../widgets/area/area-widget.component.html | 49 +-
.../widgets/area/area-widget.component.ts | 15 +-
.../components/widgets/bar-race/bar-race-config.ts | 49 +-
.../bar-race/bar-race-widget.component.html | 26 +-
.../bar-race/bar-race-widget.component.scss | 30 +-
.../widgets/bar-race/bar-race-widget.component.ts | 276 ++---
.../components/widgets/base/base-config.ts | 1 -
.../components/widgets/base/base-echarts-widget.ts | 40 +-
.../widgets/base/base-ngx-charts-widget.ts | 27 +-
.../widgets/base/base-ngx-line-charts-widget.ts | 46 +-
.../widgets/base/base-ngx-line-config.ts | 60 +-
.../components/widgets/base/base-widget.ts | 437 ++++----
.../components/widgets/gauge/gauge-config.ts | 33 +-
.../widgets/gauge/gauge-widget.component.css | 10 +-
.../widgets/gauge/gauge-widget.component.html | 38 +-
.../widgets/gauge/gauge-widget.component.ts | 26 +-
.../components/widgets/html/html-config.ts | 21 +-
.../widgets/html/html-widget.component.css | 10 +-
.../widgets/html/html-widget.component.html | 17 +-
.../widgets/html/html-widget.component.ts | 20 +-
.../components/widgets/image/image-config.ts | 16 +-
.../widgets/image/image-widget.component.css | 6 +-
.../widgets/image/image-widget.component.html | 4 +-
.../widgets/image/image-widget.component.ts | 25 +-
.../components/widgets/line/line-config.ts | 13 +-
.../widgets/line/line-widget.component.css | 10 +-
.../widgets/line/line-widget.component.html | 49 +-
.../widgets/line/line-widget.component.ts | 16 +-
.../dashboard/components/widgets/map/map-config.ts | 66 +-
.../widgets/map/map-widget.component.css | 8 +-
.../widgets/map/map-widget.component.html | 29 +-
.../components/widgets/map/map-widget.component.ts | 90 +-
.../components/widgets/number/number-config.ts | 21 +-
.../widgets/number/number-widget.component.css | 15 +-
.../widgets/number/number-widget.component.html | 16 +-
.../widgets/number/number-widget.component.ts | 105 +-
.../dashboard/components/widgets/raw/raw-config.ts | 33 +-
.../widgets/raw/raw-widget.component.css | 10 +-
.../widgets/raw/raw-widget.component.html | 23 +-
.../components/widgets/raw/raw-widget.component.ts | 30 +-
.../stacked-line-chart-config.ts | 42 +-
.../stacked-line-chart-widget.component.html | 26 +-
.../stacked-line-chart-widget.component.scss | 30 +-
.../stacked-line-chart-widget.component.ts | 203 ++--
.../components/widgets/status/status-config.ts | 34 +-
.../widgets/status/status-widget.component.html | 19 +-
.../widgets/status/status-widget.component.scss | 42 +-
.../widgets/status/status-widget.component.ts | 94 +-
.../components/widgets/table/table-config.ts | 43 +-
.../widgets/table/table-widget.component.css | 10 +-
.../widgets/table/table-widget.component.html | 50 +-
.../widgets/table/table-widget.component.ts | 52 +-
.../widgets/trafficlight/traffic-light-config.ts | 48 +-
.../traffic-light-widget.component.css | 14 +-
.../traffic-light-widget.component.html | 54 +-
.../trafficlight/traffic-light-widget.component.ts | 52 +-
.../widgets/wordcloud/wordcloud-config.ts | 57 +-
.../wordcloud/wordcloud-widget.component.html | 22 +-
.../wordcloud/wordcloud-widget.component.scss | 32 +-
.../wordcloud/wordcloud-widget.component.ts | 245 +++--
.../dashboard/dashboard.can-deactivate.guard.ts | 28 +-
ui/src/app/dashboard/dashboard.module.ts | 156 ++-
ui/src/app/dashboard/dashboard.routes.ts | 9 +-
.../add-visualization-dialog.component.html | 118 ++-
.../add-visualization-dialog.component.scss | 8 +-
.../add-visualization-dialog.component.ts | 476 +++++----
.../edit-dashboard-dialog.component.html | 71 +-
.../edit-dashboard-dialog.component.scss | 4 +-
.../edit-dashboard-dialog.component.ts | 17 +-
.../dashboard/registry/widget-config-builder.ts | 190 +++-
ui/src/app/dashboard/registry/widget-registry.ts | 20 +-
.../dashboard/sdk/collected-schema-requirements.ts | 14 +-
ui/src/app/dashboard/sdk/ep-requirements.ts | 182 ++--
.../sdk/extractor/static-property-extractor.ts | 54 +-
.../app/dashboard/sdk/matching/datatype-match.ts | 20 +-
.../sdk/matching/domain-property-match.ts | 15 +-
.../dashboard/sdk/matching/list-property-match.ts | 16 +-
.../sdk/matching/mapping-property-generator.ts | 15 +-
.../sdk/matching/primitive-property-match.ts | 13 +-
.../app/dashboard/sdk/matching/property-match.ts | 13 +-
ui/src/app/dashboard/sdk/matching/schema-match.ts | 11 +-
ui/src/app/dashboard/sdk/model/datatypes.ts | 10 +-
ui/src/app/dashboard/sdk/model/vocabulary.ts | 1 -
.../dashboard/sdk/schema-requirements-builder.ts | 55 +-
ui/src/app/dashboard/services/edit-mode.service.ts | 9 +-
.../services/refresh-dashboard.service.ts | 1 -
.../dashboard/services/reload-pipeline.service.ts | 9 +-
ui/src/app/dashboard/services/resize.service.ts | 1 -
...lorer-widget-appearance-settings.component.html | 41 +-
...xplorer-widget-appearance-settings.component.ts | 60 +-
.../data-explorer-designer-panel.component.html | 136 ++-
.../data-explorer-designer-panel.component.scss | 10 +-
.../data-explorer-designer-panel.component.ts | 119 ++-
...ta-explorer-widget-data-settings.component.html | 259 +++--
...ta-explorer-widget-data-settings.component.scss | 43 +-
...data-explorer-widget-data-settings.component.ts | 375 ++++---
.../field-selection-panel.component.html | 77 +-
.../field-selection-panel.component.scss | 11 +-
.../field-selection-panel.component.ts | 188 ++--
.../field-selection/field-selection.component.html | 27 +-
.../field-selection/field-selection.component.scss | 2 +-
.../field-selection/field-selection.component.ts | 44 +-
.../filter-selection-panel.component.html | 125 ++-
.../filter-selection-panel.component.ts | 150 +--
.../group-selection-panel.component.html | 45 +-
.../group-selection-panel.component.scss | 2 +-
.../group-selection-panel.component.ts | 108 +-
...-explorer-visualisation-settings.component.html | 80 +-
...ta-explorer-visualisation-settings.component.ts | 33 +-
...data-explorer-dashboard-overview.component.html | 244 +++--
...data-explorer-dashboard-overview.component.scss | 4 +-
.../data-explorer-dashboard-overview.component.ts | 224 ++--
.../data-explorer-dashboard-panel.component.css | 8 +-
.../data-explorer-dashboard-panel.component.html | 276 +++--
.../data-explorer-dashboard-panel.component.ts | 617 +++++------
.../time-selector/timeRangeSelector.component.html | 81 +-
.../time-selector/timeRangeSelector.component.scss | 6 +-
.../time-selector/timeRangeSelector.component.ts | 267 ++---
.../widget-view/abstract-widget-view.directive.ts | 252 +++--
.../data-explorer-dashboard-grid.component.html | 41 +-
.../data-explorer-dashboard-grid.component.scss | 7 +-
.../data-explorer-dashboard-grid.component.ts | 136 +--
...ta-explorer-dashboard-slide-view.component.html | 88 +-
...ta-explorer-dashboard-slide-view.component.scss | 32 +-
...data-explorer-dashboard-slide-view.component.ts | 163 +--
.../data-explorer-dashboard-widget.component.html | 220 ++--
.../data-explorer-dashboard-widget.component.scss | 14 +-
.../data-explorer-dashboard-widget.component.ts | 379 +++----
.../components/widget/widget.directive.ts | 4 +-
.../base/base-data-explorer-widget.directive.ts | 513 +++++----
.../components/widgets/base/base-widget-config.ts | 272 ++---
.../widgets/base/data-explorer-widget-data.ts | 33 +-
.../correlation-chart-widget-config.component.html | 46 +-
.../correlation-chart-widget-config.component.ts | 75 +-
.../correlation-chart-widget.component.html | 40 +-
.../correlation-chart-widget.component.ts | 426 ++++----
.../model/correlation-chart-widget.model.ts | 16 +-
...distribution-chart-widget-config.component.html | 115 +-
.../distribution-chart-widget-config.component.ts | 97 +-
.../distribution-chart-widget.component.html | 55 +-
.../distribution-chart-widget.component.ts | 371 +++----
.../model/distribution-chart-widget.model.ts | 19 +-
.../value-heatmap/value-heatmap.component.html | 14 +-
.../value-heatmap/value-heatmap.component.ts | 300 +++---
.../config/heatmap-widget-config.component.html | 20 +-
.../config/heatmap-widget-config.component.ts | 72 +-
.../widgets/heatmap/heatmap-widget.component.html | 40 +-
.../widgets/heatmap/heatmap-widget.component.scss | 6 +-
.../widgets/heatmap/heatmap-widget.component.ts | 500 +++++----
.../widgets/heatmap/model/heatmap-widget.model.ts | 14 +-
.../config/image-widget-config.component.html | 12 +-
.../image/config/image-widget-config.component.ts | 65 +-
.../widgets/image/image-widget.component.css | 10 +-
.../widgets/image/image-widget.component.html | 31 +-
.../widgets/image/image-widget.component.ts | 160 +--
.../widgets/image/model/image-widget.model.ts | 12 +-
.../indicator-chart-widget-config.component.html | 25 +-
.../indicator-chart-widget-config.component.ts | 63 +-
.../indicator-chart-widget.component.html | 36 +-
.../indicator/indicator-chart-widget.component.ts | 218 ++--
.../model/indicator-chart-widget.model.ts | 16 +-
.../map/config/map-widget-config.component.html | 100 +-
.../map/config/map-widget-config.component.ts | 114 +-
.../widgets/map/map-widget.component.html | 31 +-
.../widgets/map/map-widget.component.scss | 8 +-
.../components/widgets/map/map-widget.component.ts | 401 ++++---
.../widgets/map/model/map-widget.model.ts | 25 +-
.../config/table-widget-config.component.html | 25 +-
.../table/config/table-widget-config.component.ts | 75 +-
.../widgets/table/model/table-widget.model.ts | 16 +-
.../widgets/table/table-widget.component.html | 111 +-
.../widgets/table/table-widget.component.scss | 7 +-
.../widgets/table/table-widget.component.ts | 201 ++--
.../time-series-chart-widget-config.component.html | 19 +-
.../time-series-chart-widget-config.component.ts | 277 ++---
.../model/time-series-chart-widget.model.ts | 39 +-
.../time-series-chart/services/color.service.ts | 1 -
.../time-series-chart-widget.component.html | 49 +-
.../time-series-chart-widget.component.scss | 12 +-
.../time-series-chart-widget.component.ts | 968 +++++++++--------
.../aggregate-configuration.component.css | 1 -
.../aggregate-configuration.component.html | 27 +-
.../aggregate-configuration.component.ts | 43 +-
.../components/widgets/utils/color-utils.ts | 35 +-
.../group-configuration.component.css | 1 -
.../group-configuration.component.html | 39 +-
.../group-configuration.component.ts | 63 +-
.../load-data-spinner.component.ts | 17 +-
.../no-data/no-data-in-date-range.component.html | 15 +-
.../no-data/no-data-in-date-range.component.ts | 21 +-
.../select-color-properties.component.html | 167 ++-
.../select-color-properties.component.scss | 14 +-
.../select-color-properties.component.ts | 133 ++-
.../select-properties.component.css | 3 +-
.../select-properties.component.html | 39 +-
.../select-properties.component.ts | 81 +-
.../select-property/select-property.component.html | 25 +-
.../select-property/select-property.component.ts | 31 +-
.../too-much-data/too-much-data.component.html | 33 +-
.../too-much-data/too-much-data.component.scss | 3 +-
.../utils/too-much-data/too-much-data.component.ts | 33 +-
.../data-explorer-panel.can-deactivate.guard.ts | 28 +-
ui/src/app/data-explorer/data-explorer.module.ts | 286 ++---
ui/src/app/data-explorer/data-explorer.routes.ts | 9 +-
...a-explorer-edit-data-view-dialog.component.html | 54 +-
...a-explorer-edit-data-view-dialog.component.scss | 4 +-
...ata-explorer-edit-data-view-dialog.component.ts | 64 +-
.../models/dataview-dashboard.model.ts | 45 +-
.../app/data-explorer/models/multi-series.model.ts | 1 -
.../registry/data-explorer-widget-registry.ts | 1 -
.../registry/data-explorer-widgets.ts | 112 +-
.../data-explorer-field-provider-service.ts | 314 +++---
.../services/refresh-dashboard.service.ts | 1 -
.../app/data-explorer/services/resize.service.ts | 1 -
.../services/time-selection.service.ts | 10 +-
.../services/widget-configuration.service.ts | 10 +-
.../data-explorer/services/widget-type.service.ts | 12 +-
.../output-strategy/base/BaseOutputStrategy.ts | 26 +-
.../custom-output-strategy.component.html | 86 +-
.../custom-output-strategy.component.scss | 1 -
.../custom-output-strategy.component.ts | 101 +-
.../output-strategy/output-strategy.component.html | 44 +-
.../output-strategy/output-strategy.component.scss | 10 +-
.../output-strategy/output-strategy.component.ts | 43 +-
.../property-selection.component.html | 37 +-
.../property-selection.component.scss | 4 +-
.../property-selection.component.ts | 90 +-
.../user-defined-output.component.html | 85 +-
.../user-defined-output.component.scss | 1 -
.../user-defined-output.component.ts | 137 +--
.../pipeline-assembly.component.html | 156 ++-
.../pipeline-assembly.component.scss | 11 +-
.../pipeline-assembly.component.ts | 226 ++--
.../pipeline-element-documentation.component.html | 8 +-
.../pipeline-element-documentation.component.scss | 2 +-
.../pipeline-element-documentation.component.ts | 52 +-
.../pipeline-element-icon-stand-row.component.html | 58 +-
.../pipeline-element-icon-stand-row.component.scss | 84 +-
.../pipeline-element-icon-stand-row.component.ts | 59 +-
.../pipeline-element-icon-stand.component.html | 244 +++--
.../pipeline-element-icon-stand.component.scss | 89 +-
.../pipeline-element-icon-stand.component.ts | 306 +++---
.../pipeline-element-options.component.html | 142 ++-
.../pipeline-element-options.component.ts | 338 +++---
.../pipeline-element-preview.component.html | 17 +-
.../pipeline-element-preview.component.scss | 32 +-
.../pipeline-element-preview.component.ts | 76 +-
.../pipeline-element-recommendation.component.html | 35 +-
.../pipeline-element-recommendation.component.ts | 290 ++---
.../pipeline-element.component.html | 9 +-
.../pipeline-element/pipeline-element.component.ts | 38 +-
.../components/pipeline/pipeline.component.html | 116 +-
.../components/pipeline/pipeline.component.ts | 1107 ++++++++++++--------
ui/src/app/editor/constants/editor.constants.ts | 13 +-
.../compatible-elements.component.html | 41 +-
.../compatible-elements.component.scss | 13 +-
.../compatible-elements.component.ts | 138 +--
.../dialog/customize/customize.component.html | 182 +++-
.../dialog/customize/customize.component.scss | 7 +-
.../editor/dialog/customize/customize.component.ts | 365 ++++---
ui/src/app/editor/dialog/help/help.component.html | 88 +-
ui/src/app/editor/dialog/help/help.component.scss | 8 +-
ui/src/app/editor/dialog/help/help.component.ts | 157 +--
.../matching-error/matching-error.component.html | 39 +-
.../matching-error/matching-error.component.scss | 2 +-
.../matching-error/matching-error.component.ts | 31 +-
.../missing-elements-for-tutorial.component.html | 24 +-
.../missing-elements-for-tutorial.component.scss | 2 +-
.../missing-elements-for-tutorial.component.ts | 24 +-
.../pipeline-element-discovery.component.html | 41 +-
.../pipeline-element-discovery.component.scss | 4 +-
.../pipeline-element-discovery.component.ts | 124 +--
.../save-pipeline/save-pipeline.component.html | 144 ++-
.../save-pipeline/save-pipeline.component.scss | 20 +-
.../save-pipeline/save-pipeline.component.ts | 306 +++---
.../welcome-tour/welcome-tour.component.html | 45 +-
.../welcome-tour/welcome-tour.component.scss | 28 +-
.../dialog/welcome-tour/welcome-tour.component.ts | 69 +-
ui/src/app/editor/editor.component.html | 47 +-
ui/src/app/editor/editor.component.scss | 10 +-
ui/src/app/editor/editor.component.ts | 272 ++---
ui/src/app/editor/editor.module.ts | 19 +-
.../filter/enabled-pipeline-element.filter.ts | 17 +-
ui/src/app/editor/model/editor.model.ts | 86 +-
ui/src/app/editor/model/jsplumb.model.ts | 12 +-
ui/src/app/editor/services/editor.service.ts | 228 ++--
.../app/editor/services/jsplumb-bridge.service.ts | 32 +-
.../app/editor/services/jsplumb-config.service.ts | 314 +++---
.../editor/services/jsplumb-endpoint.service.ts | 80 +-
.../app/editor/services/jsplumb-factory.service.ts | 43 +-
ui/src/app/editor/services/jsplumb.service.ts | 695 +++++++-----
.../app/editor/services/object-provider.service.ts | 74 +-
.../services/pipeline-canvas-scrolling.service.ts | 19 +-
.../app/editor/services/pipeline-editor.service.ts | 23 +-
.../services/pipeline-element-dragged.service.ts | 12 +-
.../services/pipeline-element-group-filter.pipe.ts | 29 +-
.../services/pipeline-element-name-filter.pipe.ts | 28 +-
.../pipeline-element-recommendation.service.ts | 43 +-
.../services/pipeline-element-type-filter.pipe.ts | 25 +-
.../services/pipeline-positioning.service.ts | 362 ++++---
.../app/editor/services/pipeline-style.service.ts | 114 +-
.../editor/services/pipeline-validation.service.ts | 119 ++-
ui/src/app/editor/utils/editor.utils.ts | 127 ++-
ui/src/app/editor/utils/style-sanitizer.ts | 13 +-
.../file-overview/file-overview.component.html | 54 +-
.../file-overview/file-overview.component.scss | 16 +-
.../file-overview/file-overview.component.ts | 95 +-
.../file-upload/file-upload-dialog.component.html | 94 +-
.../file-upload/file-upload-dialog.component.scss | 2 +-
.../file-upload/file-upload-dialog.component.ts | 108 +-
ui/src/app/files/files.component.html | 34 +-
ui/src/app/files/files.component.scss | 12 +-
ui/src/app/files/files.component.ts | 56 +-
ui/src/app/files/files.module.ts | 82 +-
ui/src/app/files/files.routes.ts | 10 +-
ui/src/app/info/about/about.component.css | 10 +-
ui/src/app/info/about/about.component.html | 87 +-
ui/src/app/info/about/about.component.ts | 10 +-
ui/src/app/info/info.component.css | 4 +-
ui/src/app/info/info.component.html | 17 +-
ui/src/app/info/info.component.ts | 25 +-
ui/src/app/info/info.module.ts | 9 +-
ui/src/app/info/license/license.component.css | 2 +-
ui/src/app/info/license/license.component.html | 348 +++---
ui/src/app/info/license/license.component.ts | 10 +-
.../info/versions/service/version-info.model.ts | 12 +-
ui/src/app/info/versions/versions.component.css | 8 +-
ui/src/app/info/versions/versions.component.html | 91 +-
ui/src/app/info/versions/versions.component.ts | 26 +-
.../activate-account.component.html | 13 +-
.../activate-account/activate-account.component.ts | 61 +-
.../components/auth-box/auth-box.component.ts | 23 +-
.../login/components/login/login.component.html | 82 +-
.../login/components/login/login.component.scss | 20 +-
.../app/login/components/login/login.component.ts | 84 +-
ui/src/app/login/components/login/login.model.ts | 4 +-
.../components/register/register.component.html | 62 +-
.../components/register/register.component.ts | 95 +-
.../components/register/registration.model.ts | 4 +-
.../restore-password.component.html | 41 +-
.../restore-password/restore-password.component.ts | 72 +-
.../set-new-password.component.html | 61 +-
.../set-new-password/set-new-password.component.ts | 131 ++-
.../login/components/setup/setup.component.html | 165 ++-
.../login/components/setup/setup.component.scss | 54 +-
.../app/login/components/setup/setup.component.ts | 113 +-
.../components/startup/startup.component.html | 40 +-
.../components/startup/startup.component.scss | 5 +-
.../login/components/startup/startup.component.ts | 40 +-
ui/src/app/login/login.module.ts | 11 +-
.../login/services/account-activation.service.ts | 18 +-
ui/src/app/login/services/login.service.ts | 69 +-
.../app/login/services/restore-password.service.ts | 30 +-
ui/src/app/login/utils/check-password.ts | 16 +-
.../components/edit/quickedit.component.html | 4 +-
.../elements/pipeline-elements-row.component.html | 4 +-
.../preview/pipeline-preview.component.html | 4 +-
822 files changed, 29077 insertions(+), 21041 deletions(-)
create mode 100644 .github/pr-labeler-config.yml
copy .asf.yaml => .github/workflows/pr-labeler.yml (57%)
delete mode 100644 installer/README.md
copy installer/cli/deploy/standalone/{iotdb => tubemq}/docker-compose.dev.yml
(85%)
copy installer/cli/deploy/standalone/{iotdb => tubemq}/docker-compose.yml (92%)
copy .asf.yaml => installer/k8s/templates/external/influxdb/influxdb2-pvc.yaml
(56%)
copy streampipes-client-python/streampipes_client/endpoint/{ =>
api}/__init__.py (99%)
rename streampipes-client-python/streampipes_client/endpoint/{ =>
api}/data_lake_measure.py (100%)
rename streampipes-client-python/streampipes_client/endpoint/{ =>
api}/data_stream.py (100%)
create mode 100644
streampipes-client-python/streampipes_client/endpoint/exceptions.py
copy streampipes-client-python/streampipes_client/{ =>
endpoint/messaging}/__init__.py (100%)
create mode 100644
streampipes-client-python/streampipes_client/model/resource/function_definition.py
create mode 100644
streampipes-client/src/test/java/org/apache/streampipes/client/util/StreamPipesApiPathTest.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/DefaultEnvironment.java
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environment.java
rename
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/PerformanceTest.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/Environments.java
(83%)
copy ui/src/app/editor/utils/style-sanitizer.ts =>
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/BooleanEnvironmentVariable.java
(68%)
copy
ui/src/app/core-ui/static-properties/static-secret-input/static-secret-input.component.css
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
(88%)
create mode 100644
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvironmentVariable.java
copy
streampipes-service-discovery-consul/src/main/java/org/apache/streampipes/svcdiscovery/consul/AbstractConsulService.java
=>
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/IntEnvironmentVariable.java
(69%)
copy ui/src/app/login/components/auth-box/auth-box.component.ts =>
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/StringEnvironmentVariable.java
(70%)
copy
streampipes-config/src/main/java/org/apache/streampipes/config/backend/{MessagingSettings.java
=> DefaultMessagingSettings.java} (52%)
delete mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/DataExplorerWriter.java
copy
ui/src/app/data-explorer/components/widgets/utils/too-much-data/too-much-data.component.ts
=>
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/auth/AuthInterceptor.java
(57%)
rename
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/SimulationStatusNotifier.java
=>
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/InfluxAuthMode.java
(87%)
create mode 100644
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/InfluxClientProvider.java
copy
streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/utils/DataExplorerUtils.java
=>
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/InfluxClientUtils.java
(57%)
copy ui/src/app/editor/services/pipeline-element-group-filter.pipe.ts =>
streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/influx/InfluxRequests.java
(51%)
rename
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/StreamProvider.java
=>
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/IFunctionConfig.java
(72%)
delete mode 100644 streampipes-extensions/README.md
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/influxdb/InfluxDbSetAdapter.java
create mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/TubeMQProtocol.java
delete mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set/strings.en
copy
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.adapters.influxdb.set
=>
org.apache.streampipes.connect.iiot.protocol.stream.tubemq}/documentation.md
(72%)
create mode 100644
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.tubemq/icon.png
copy
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/{org.apache.streampipes.connect.iiot.protocol.stream.file
=> org.apache.streampipes.connect.iiot.protocol.stream.tubemq}/strings.en (55%)
rename {streampipes-performance-tests =>
streampipes-extensions/streampipes-connectors-influx}/pom.xml (65%)
copy
streampipes-extensions/{streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/DatabasesJvmInit.java
=>
streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/InfluxConnectorsInit.java}
(68%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/influxdb
=>
streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter}/InfluxDbClient.java
(80%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/influxdb
=>
streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter}/InfluxDbStreamAdapter.java
(77%)
create mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/shared/InfluxConfigs.java
create mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/shared/InfluxKeys.java
create mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/shared/SharedInfluxClient.java
create mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/sink/InfluxDbClient.java
create mode 100644
streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/sink/InfluxDbSink.java
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/documentation.md
(100%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set
=>
streampipes-connectors-influx/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream}/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream/strings.en
(55%)
rename streampipes-extensions/{streampipes-sinks-databases-jvm =>
streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb/documentation.md
(100%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.stream
=>
streampipes-connectors-influx/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb}/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-databases-jvm =>
streampipes-connectors-influx}/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb/strings.en
(78%)
create mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/tubemq/TubeMQParameters.java
create mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/tubemq/TubeMQPublisherSink.java
copy
streampipes-extensions/{streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.iotdb
=>
streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.tubemq}/documentation.md
(70%)
create mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.tubemq/icon.png
copy
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.file
=>
streampipes-sinks-brokers-jvm/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.tubemq}/strings.en
(62%)
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDb.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbClient.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbController.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/influxdb/InfluxDbParameters.java
delete mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/resources/org.apache.streampipes.sinks.databases.jvm.influxdb/icon.png
create mode 100644
streampipes-extensions/streampipes-sinks-databases-jvm/src/test/java/org/apache/streampipes/sinks/databases/jvm/iotdb/TestIotDbParameters.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/AbstractConsulTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/ConsulKvManagementTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/ConsulSpConfigTest.java
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/svcdiscovery/ConsulSpServiceDiscoveryTest.java
rename
streampipes-extensions/streampipes-connect-adapters-iiot/src/main/resources/org.apache.streampipes.connect.iiot.adapters.influxdb.set/documentation.md
=> streampipes-integration-tests/src/test/resources/logback-test.xml (62%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/api/EndpointSelectable.java
rename {streampipes-config/src/main/java/org/apache/streampipes/config/backend
=>
streampipes-model/src/main/java/org/apache/streampipes/model/config}/MessagingSettings.java
(66%)
rename {streampipes-config/src/main/java/org/apache/streampipes/config/backend
=>
streampipes-model/src/main/java/org/apache/streampipes/model/config}/SpDataFormat.java
(96%)
rename {streampipes-config/src/main/java/org/apache/streampipes/config/backend
=>
streampipes-model/src/main/java/org/apache/streampipes/model/config}/SpProtocol.java
(96%)
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/PipelinePerformanceTest.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/JsonDataProvider.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/SimpleSchemaProvider.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/model/PerformanceTestSettings.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/pipeline/PipelineDescriptionFetcher.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/pipeline/PipelineDescriptionParser.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/producer/DataSimulator.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/DataReplayStatusNotifier.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/simulation/SimulationManager.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/tests/serializer/JsonSerializerTest.java
delete mode 100644
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/util/ParameterTool.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionInfo.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutionTaskFactory.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/PipelineExecutor.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/endpoint/ExtensionsServiceEndpointProvider.java
copy
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
(51%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachPipelineElementSubmitter.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/GraphSubmitter.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/HttpRequestBuilder.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/InvokeHttpRequest.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/InvokePipelineElementSubmitter.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineElementHttpRequest.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineElementSubmitter.java
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/PipelineExecutor.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> execution/provider/CurrentPipelineElementProvider.java} (61%)
rename
streampipes-performance-tests/src/main/java/org/apache/streampipes/performance/dataprovider/DataProvider.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/provider/PipelineElementProvider.java
(64%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> execution/provider/StoredPipelineElementProvider.java} (55%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/AfterInvocationTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/DiscoverEndpointsTask.java
copy
ui/src/app/data-explorer/components/widgets/utils/load-data-spinner/load-data-spinner.component.ts
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/PipelineExecutionTask.java
(66%)
copy
streampipes-extensions/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/SecretEncryptionTask.java
(56%)
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/StorePipelineStatusTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/SubmitRequestTask.java
create mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/UpdateGroupIdTask.java
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{execution/http
=> storage}/PipelineStorageService.java (98%)
rename
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> storage/RunningPipelineElementStorage.java} (78%)
delete mode 100644
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/storage/UserService.java
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/function/FunctionRegistrationService.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/FunctionConfig.java
(51%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/IStreamPipesFunctionDeclarer.java
=>
streampipes-wrapper-standalone/src/main/java/org/apache/streampipes/wrapper/standalone/function/FunctionConfigBuilder.java
(56%)
copy ui/cypress/tests/adapter/{persistInDataLake.smoke.spec.ts =>
createAdapterWithoutStarting.spec.ts} (52%)
