You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2023/01/23 14:47:48 UTC

[streampipes] 01/01: Merge branch 'dev' of github.com:apache/streampipes into dev

This is an automated email from the ASF dual-hosted git repository.

zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit a7276c291780860690477cb801f98d2fb6d6bd2e
Merge: ddb280fcf 468032654
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Mon Jan 23 15:47:37 2023 +0100

    Merge branch 'dev' of github.com:apache/streampipes into dev

 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  |  33 +-
 .../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      |  21 +-
 .../execution/task/SecretEncryptionTask.java       |  25 +-
 .../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        |  30 +-
 .../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 -
 .../_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 +-
 280 files changed, 8344 insertions(+), 6068 deletions(-)