This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch SP-1132
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 73422d4a4 [#1132] Remove set adapters from e2e tests
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
new ec9ee297e Merge branch 'dev' into SP-1132
new 6b826b28c [#1132] Fix preprocessing rule e2e tests
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
pom.xml | 6 -
streampipes-client-python/README.md | 13 +-
streampipes-client-python/mkdocs.yml | 2 +-
streampipes-client-python/setup.py | 2 +-
.../apache/streampipes/client/api/AdminApi.java | 12 +
.../streampipes/client/api/DataStreamApi.java | 9 +-
streampipes-config/pom.xml | 5 +
.../streampipes/config/backend/BackendConfig.java | 3 +-
...Settings.java => DefaultMessagingSettings.java} | 83 +---
.../connect/management/util/GroundingUtils.java | 2 +-
...sFunctionDeclarer.java => IFunctionConfig.java} | 11 +-
.../api/declarer/IStreamPipesFunctionDeclarer.java | 4 +-
.../connect/adapter/AdapterPipelineGenerator.java | 2 +-
.../adapter/util/TransportFormatGenerator.java | 2 +-
.../management/init/DeclarersSingleton.java | 2 +-
.../streampipes-sinks-databases-jvm/pom.xml | 4 -
.../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 +-
.../manager/execution/PipelineExecutionInfo.java | 106 +++++
.../execution/PipelineExecutionTaskFactory.java | 60 +++
.../manager/execution/PipelineExecutor.java | 57 +++
.../ExtensionsServiceEndpointProvider.java | 62 +++
.../manager/execution/http/DetachHttpRequest.java | 24 +-
.../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 | 15 +-
.../task/SecretEncryptionTask.java} | 24 +-
.../execution/task/StorePipelineStatusTask.java | 80 ++++
.../manager/execution/task/SubmitRequestTask.java | 51 +++
.../manager/execution/task/UpdateGroupIdTask.java | 46 ++
.../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 -----
.../AbstractPipelineElementResourceManager.java | 12 +
.../rest/core/base/impl/AbstractRestResource.java | 5 -
.../streampipes/rest/impl/admin/ConsulConfig.java | 2 +-
.../rest/impl/pe/DataStreamResource.java | 17 +
.../streampipes/rest/security/AuthConstants.java | 4 +
.../function/StreamPipesFunctionHandler.java | 36 +-
.../standalone/function/FunctionConfig.java | 46 +-
.../standalone/function/FunctionConfigBuilder.java | 25 +-
.../standalone/function/FunctionContext.java | 9 +
.../function/FunctionContextGenerator.java | 10 +-
.../standalone/function/StreamPipesFunction.java | 64 ++-
ui/.eslintignore | 4 -
ui/.prettierignore | 4 -
.../fixtures/connect/aggregationRules/expected.csv | 2 -
ui/cypress/support/utils/connect/ConnectUtils.ts | 9 +-
ui/cypress/tests/adapter/rules/streamRules.spec.ts | 2 +-
.../_guards/auth.can-activate-children.guard.ts | 4 +-
.../configuration-group.component.html | 4 +-
.../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 +-
.../add-visualization-dialog.component.html | 4 +-
.../dialog/customize/customize.component.html | 8 +-
.../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 +-
283 files changed, 8344 insertions(+), 6081 deletions(-)
copy
streampipes-config/src/main/java/org/apache/streampipes/config/backend/{MessagingSettings.java
=> DefaultMessagingSettings.java} (52%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/declarer/{IStreamPipesFunctionDeclarer.java
=> IFunctionConfig.java} (80%)
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%)
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-service-extensions/src/main/java/org/apache/streampipes/service/extensions/function/FunctionRegistrationHandler.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/DetachHttpRequest.java
(55%)
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%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{util/TemporaryGraphStorage.java
=> execution/provider/PipelineElementProvider.java} (73%)
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
streampipes-wrapper-siddhi/src/main/java/org/apache/streampipes/wrapper/siddhi/query/expression/math/MathSubtractExpression.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/task/PipelineExecutionTask.java
(71%)
copy
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/{permission/PermissionManager.java
=> execution/task/SecretEncryptionTask.java} (58%)
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-model/src/main/java/org/apache/streampipes/model/datalake/DataSeries.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%)
