This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch
dependabot/pip/streampipes-client-python/confluent-kafka-2.12.0
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from f5f9bc1d25 chore(deps): bump confluent-kafka in
/streampipes-client-python
add 5f235e2ff0 Edit Assets links for adapter while editing (#3817)
add 567f7caaa3 fix: Fix test createAdapterWithoutStarting (#3827)
add 39e891de80 Fix(#3828): Fix translation for extension
installation/uninstallation (#3830)
add 0477476a8a feat: Improve handling of label colors (#3831)
add b25e5b16fe fix: Avoid flickering of data explorer tables in live
refresh mode (#3832)
add 8e51d30779 Data Retention Export to s3 based object storage (#3824)
add de17d06866 fix(#3833): Add handling for duplicate keys (#3834)
add fe1ef7b4d6 Tests for PR #3829 and #3817 (#3835)
add 38c981fb6c Fix: changed import for export provider service in shared
ui (#3839)
add cb5d5739e5 fix(#3837): Remove delete preview rest endpoint (#3838)
add e0371882b3 refactor: Update some German labels in connect view (#3840)
add 8697becca0 chore(deps): bump actions/setup-node from 5 to 6 (#3836)
add 23be7b9999 Merge branch 'dev' into
dependabot/pip/streampipes-client-python/confluent-kafka-2.12.0
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 2 +-
.github/workflows/cypress-test.yml | 2 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/pr-validation.yml | 4 +-
.../apache/streampipes/commons/constants/Envs.java | 2 +
.../commons/environment/DefaultEnvironment.java | 4 +
.../commons/environment/Environment.java | 1 +
streampipes-data-explorer-export/pom.xml | 31 ++
.../export/ObjectStorge/ExportProviderFactory.java | 19 +-
.../export/ObjectStorge/LocalFolder.java | 7 +-
.../dataexplorer/export/ObjectStorge/S3.java | 86 ++++++
...tings.java => DefaultExportProviderConfig.java} | 21 +-
.../configuration/DefaultSpCoreConfiguration.java | 1 +
.../configuration/ExportProviderSettings.java | 115 +++++++
.../{JwtSigningMode.java => ProviderType.java} | 6 +-
.../model/configuration/SpCoreConfiguration.java | 12 +
.../model/datalake/DataLakeMeasure.java | 4 +
.../model/datalake/ExportProviderSettings.java | 22 --
.../model/datalake/RetentionExportConfig.java | 28 +-
.../model/datalake/RetentionTimeConfig.java | 35 ++-
.../manager/preview/PipelinePreview.java | 71 +++--
.../manager/runtime/ClientDisconnectCallback.java | 8 +-
.../runtime/RateLimitedRuntimeInfoProvider.java | 7 +-
.../admin/ExportProviderConfigurationResource.java | 105 +++++++
.../rest/impl/datalake/DataLakeResource.java | 15 +
.../PipelinePreviewResource.java} | 23 +-
.../StreamPreviewResource.java} | 9 +-
streampipes-service-core/pom.xml | 1 +
.../service/core/scheduler/DataLakeScheduler.java | 106 +++++--
ui/cypress/support/utils/GeneralUtils.ts | 1 +
ui/cypress/support/utils/asset/AssetBtns.ts | 4 +
ui/cypress/support/utils/asset/AssetUtils.ts | 42 ++-
ui/cypress/support/utils/connect/ConnectUtils.ts | 53 ++++
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 55 +++-
.../tests/connect/adapterWithAssets.smoke.spec.ts | 106 +++++++
.../connect/createAdapterWithoutStarting.spec.ts | 3 +-
.../tests/pipeline/pipelineAsset.smoke.spec.ts | 97 ++++++
ui/deployment/i18n/de.json | 91 ++++--
ui/deployment/i18n/en.json | 97 ++++--
.../src/lib/apis/datalake-rest.service.ts | 6 +-
...icate.service.ts => export-provider.service.ts} | 38 ++-
.../apis/pipeline-element-runtime-info.service.ts | 2 +-
.../src/lib/model/assets/asset.model.ts | 1 +
.../src/lib/model/gen/streampipes-model-client.ts | 5 +-
.../src/lib/model/gen/streampipes-model.ts | 35 ++-
.../platform-services/src/public-api.ts | 1 +
.../asset-link-configuration.component.html | 72 +++++
.../asset-link-configuration.component.scss} | 5 +
.../asset-link-configuration.component.ts} | 83 ++++-
.../lib/services/asset-configuration.service.ts | 337 +++++++++++++++++++++
.../src/lib/services/colorization.service.ts | 107 ++++++-
.../shared-ui/src/lib/shared-ui.module.ts | 3 +
.../streampipes/shared-ui/src/public-api.ts | 2 +
.../create-asset-dialog.component.html | 2 +-
ui/src/app/configuration/configuration.module.ts | 4 +
.../datalake-configuration.component.html | 197 ++++++++++++
.../datalake-configuration.component.ts | 80 ++++-
.../select-export/select-format.component.html | 91 ++++--
.../select-export/select-format.component.scss | 19 ++
.../select-export/select-format.component.ts | 93 +++++-
.../data-retention-dialog.component.html | 10 +
.../data-retention-dialog.component.ts | 54 +++-
.../delete-export-provider-dialog.component.html} | 34 +--
.../delete-export-provider-dialog.component.ts} | 34 ++-
.../export-provider-dialog.component.html | 121 ++++++++
.../export-provider-dialog.component.ts | 133 ++++++++
.../edit-label/edit-label.component.html | 2 +-
.../edit-label/edit-label.component.ts | 21 +-
.../adapter-asset-configuration.component.html | 64 ----
.../start-adapter-configuration.component.html | 11 +-
.../start-adapter-configuration.component.ts | 32 +-
ui/src/app/connect/connect.module.ts | 2 -
.../adapter-started-dialog.component.html | 1 +
.../adapter-started-dialog.component.ts | 115 ++++---
.../adapter-started-success.component.html | 22 ++
.../adapter-started-success.component.ts | 3 +
.../adapter-asset-configuration.service.ts | 205 ++++++++++++-
.../data-explorer-chart-container.component.html | 36 ++-
.../data-explorer-chart-container.component.scss | 9 -
.../charts/table/table-widget.component.ts | 5 +-
.../data-explorer-chart-view.component.html | 1 +
.../pipeline-assembly-drawing-area.component.ts | 48 +--
.../save-pipeline-settings.component.html | 19 ++
.../save-pipeline-settings.component.ts | 43 ++-
.../save-pipeline/save-pipeline.component.html | 3 +
.../save-pipeline/save-pipeline.component.ts | 96 +++++-
ui/src/app/editor/editor.module.ts | 1 +
ui/src/app/editor/services/editor.service.ts | 6 +-
88 files changed, 3101 insertions(+), 511 deletions(-)
create mode 100644
streampipes-data-explorer-export/src/main/java/org/apache/streampipes/dataexplorer/export/ObjectStorge/S3.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/{DefaultLinkSettings.java
=> DefaultExportProviderConfig.java} (75%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/ExportProviderSettings.java
copy
streampipes-model/src/main/java/org/apache/streampipes/model/configuration/{JwtSigningMode.java
=> ProviderType.java} (94%)
delete mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/ExportProviderSettings.java
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/environment/variable/EnvResolver.java
=>
streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/runtime/ClientDisconnectCallback.java
(85%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExportProviderConfigurationResource.java
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{PipelineElementPreview.java
=> runtime/PipelinePreviewResource.java} (82%)
rename
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/{PipelineElementRuntimeInfo.java
=> runtime/StreamPreviewResource.java} (91%)
create mode 100644 ui/cypress/tests/connect/adapterWithAssets.smoke.spec.ts
create mode 100644 ui/cypress/tests/pipeline/pipelineAsset.smoke.spec.ts
copy
ui/projects/streampipes/platform-services/src/lib/apis/{certificate.service.ts
=> export-provider.service.ts} (53%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/asset-link-configuration/asset-link-configuration.component.html
rename
ui/{src/app/connect/components/adapter-configuration/adapter-asset-configuration/adapter-asset-configuration.component.scss
=>
projects/streampipes/shared-ui/src/lib/components/asset-link-configuration/asset-link-configuration.component.scss}
(95%)
rename
ui/{src/app/connect/components/adapter-configuration/adapter-asset-configuration/adapter-asset-configuration.component.ts
=>
projects/streampipes/shared-ui/src/lib/components/asset-link-configuration/asset-link-configuration.component.ts}
(61%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/services/asset-configuration.service.ts
copy
ui/src/app/configuration/dialog/{delete-datalake-index/delete-datalake-index-dialog.component.html
=> delete-export-provider/delete-export-provider-dialog.component.html} (72%)
copy
ui/src/app/configuration/dialog/{certificate-details/certificate-details-dialog.component.ts
=> delete-export-provider/delete-export-provider-dialog.component.ts} (52%)
create mode 100644
ui/src/app/configuration/dialog/export-provider-dialog/export-provider-dialog.component.html
create mode 100644
ui/src/app/configuration/dialog/export-provider-dialog/export-provider-dialog.component.ts
delete mode 100644
ui/src/app/connect/components/adapter-configuration/adapter-asset-configuration/adapter-asset-configuration.component.html
