You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by oe...@apache.org on 2026/07/27 14:22:54 UTC
(streampipes) 01/01: Merge branch 'dev' of https://github.com/apache/streampipes into fix-schema-handling-of-postresql-sink
This is an automated email from the ASF dual-hosted git repository.
SvenO3 pushed a commit to branch fix-schema-handling-of-postresql-sink
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit b1ca4c1234a6951f0bf3278c1e0032c4b0de7275
Merge: 1ae6ce4731 6092b88907
Author: Sven Oehler <oe...@web.de>
AuthorDate: Mon Jul 27 16:22:39 2026 +0200
Merge branch 'dev' of https://github.com/apache/streampipes into fix-schema-handling-of-postresql-sink
.github/workflows/build.yml | 24 +-
.github/workflows/cypress-test.yml | 6 +-
.github/workflows/extensions-docs.yml | 4 +-
.github/workflows/go-client-e2e-test.yml | 6 +-
.github/workflows/go-client.yml | 2 +-
.github/workflows/go-docs.yml | 4 +-
.github/workflows/java-client-e2e-test.yml | 6 +-
.github/workflows/mvn-integration-test.yml | 6 +-
.github/workflows/pr-labeler.yml | 2 +-
.github/workflows/pr-validation.yml | 20 +-
.github/workflows/pypi-deployment.yml | 2 +-
.github/workflows/python-docs.yml | 2 +-
.github/workflows/stale-bot.yml | 2 +-
streampipes-client-go/docs/package-lock.json | 20 +-
streampipes-client-python/poetry.lock | 599 +-
streampipes-client-python/pyproject.toml | 42 +-
.../compact/generator/AdapterSchemaGenerator.java | 31 +-
.../management/AdapterMasterManagement.java | 1 +
.../AdapterTransformationConfigDefaults.java | 17 +-
.../management/AdapterUpdateManagement.java | 53 +-
.../transformer/js/GraalJsScriptEngine.java | 2 +-
.../transformer/js/GraalJsScriptEngineTest.java | 20 +
.../api/monitoring/SpMonitoringManager.java | 18 +-
.../connect/AdapterWorkerManagement.java | 53 +-
.../management/connect/PullAdapterScheduler.java | 19 +-
.../connect/adapter/model/EventCollector.java | 11 +-
.../adapter/model/pipeline/AdapterPipeline.java | 14 +-
.../elements/SendToBrokerAdapterSink.java | 7 +-
.../management/init/RunningAdapterInstance.java | 19 +-
.../management/init/RunningAdapterInstances.java | 25 +-
.../management/init/RunningInstances.java | 4 +-
.../pe/DataProcessorPipelineElementManagement.java | 4 +-
.../pe/DataSinkPipelineElementManagement.java | 4 +-
.../pe/InvocablePipelineElementManagement.java | 6 +-
.../connect/AdapterWorkerManagementTest.java | 41 +
.../connect/PullAdapterSchedulerTest.java | 55 +
.../iiot/protocol/stream/FileReplayAdapter.java | 31 +-
.../protocol/stream/FileReplayAdapterTest.java | 26 +
.../connectors/opcua/adapter/OpcUaAdapter.java | 13 +-
.../opcua/alarms/OpcUaAlarmEventSubscriber.java | 32 +-
.../opcua/client/ConnectedOpcUaClient.java | 37 +
.../alarms/OpcUaAlarmEventSubscriberTest.java | 68 +
.../opcua/client/ConnectedOpcUaClientTest.java | 66 +
.../connection/ContinuousPlcRequestReader.java | 10 +-
.../plc/adapter/modbus/Plc4xModbusAdapter.java | 5 +
.../connectors/plc/adapter/s7/Plc4xS7Adapter.java | 5 +
.../plc/cache/SpLeasedPlcConnection.java | 26 +-
.../documentation.md | 3 +
.../documentation.md | 4 +
.../plc/adapter/ConnectionContainerReproTest.java | 108 +
.../notifications/jvm/msteams/MSTeamsSink.java | 518 +-
.../documentation.md | 21 +-
.../notifications/jvm/msteams/TestMSTeamsSink.java | 230 +-
.../health/monitoring/ExtensionHealthCheck.java | 27 +-
.../health/monitoring/PipelineHealthCheck.java | 150 +-
.../health/monitoring/PipelineRecoveryBackoff.java | 107 +
.../health/monitoring/utils/HealthCheckUtils.java | 6 +
.../health/monitoring/PipelineHealthCheckTest.java | 256 +
.../monitoring/PipelineRecoveryBackoffTest.java | 100 +
.../OpcUaAdapterReadTimeoutReproductionTest.java | 177 +
.../adapters/opcua/OpcUaAdapterTestHarness.java | 34 +-
.../containers/OpcUaDemoServerContainer.java | 7 +-
.../messaging/kafka/SpKafkaProducer.java | 28 +-
.../model/connect/TransformationConfig.java | 22 +
.../datalake/importer/CsvImportJobStartResult.java | 21 +-
.../model/datalake/importer/CsvImportJobState.java | 7 +-
.../datalake/importer/CsvImportJobStatus.java | 89 +
.../datalake/importer/CsvImportPreviewResult.java | 9 +
.../http/InvokePipelineElementSubmitter.java | 2 +-
.../http/PipelineElementExtensionRequest.java | 5 +-
.../pipeline/update}/DataStreamDeletedEvent.java | 2 +-
.../update/DataStreamUpdateManagement.java | 10 +-
.../pipeline/update}/DataStreamUpdatedEvent.java | 2 +-
.../pipeline/update/PipelineUpdateCoordinator.java | 26 +-
.../http/PipelineElementRollbackTest.java | 136 +
.../update/PipelineUpdateCoordinatorTest.java | 139 +-
.../rest/impl/connect/AdapterResource.java | 28 +-
.../rest/impl/connect/CompactAdapterResource.java | 14 +-
.../rest/impl/datalake/DataLakeResource.java | 10 +-
.../importer/CsvDataLakeImportService.java | 71 +-
.../datalake/importer/CsvImportJobManager.java | 162 +
.../impl/datalake/importer/CsvImportParser.java | 29 +-
.../datalake/importer/CsvImportUploadStorage.java | 20 +-
.../datalake/importer/DataLakeImportResource.java | 21 +-
.../rest/impl/pe/DataStreamResource.java | 20 +-
.../rest/impl/datalake/DataLakeResourceTest.java | 17 +
.../importer/CsvDataLakeImportServiceTest.java | 65 +
.../datalake/importer/CsvImportParserTest.java | 1 +
.../streampipes/service/core/PostStartupTask.java | 7 +-
.../service/core/StreamPipesCoreApplication.java | 23 +-
.../core/migrations/AvailableMigrations.java | 2 +
.../v099/connect/MigrateAdaptersToUseScript.java | 44 +-
.../MigratePlc4xS7AdaptersToGenericAdapter.java | 443 +
.../v099/MigrateAdaptersToUseScriptTest.java | 86 +
...MigratePlc4xS7AdaptersToGenericAdapterTest.java | 294 +
.../standalone/manager/ProtocolManager.java | 32 +-
.../runtime/StandaloneEventProcessorRuntime.java | 57 +-
.../runtime/StandaloneEventSinkRuntime.java | 45 +-
.../runtime/StandalonePipelineElementRuntime.java | 77 +-
ui/STYLEGUIDE.md | 90 +
ui/angular.json | 35 +-
...aLakeFilterConfig.ts => DatasetFilterConfig.ts} | 2 +-
ui/cypress/support/utils/PrepareTestDataUtils.ts | 6 +-
ui/cypress/support/utils/chart/ChartUtils.ts | 10 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 24 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 19 +-
.../{DataLakeSeedUtils.ts => DatasetSeedUtils.ts} | 73 +-
ui/cypress/support/utils/dataset/DatasetUtils.ts | 4 +-
ui/cypress/support/utils/pipeline/PipelineBtns.ts | 39 +-
ui/cypress/support/utils/pipeline/PipelineUtils.ts | 69 +-
ui/cypress/support/utils/user/PermissionUtils.ts | 16 +-
ui/cypress/tests/chart/autoAggregateTable.spec.ts | 4 +-
ui/cypress/tests/chart/configuration.smoke.spec.ts | 4 +-
.../chart/filterNumericalStringProperties.spec.ts | 10 +-
.../tests/chart/missingDataInDataLake.spec.ts | 4 +-
ui/cypress/tests/chart/publicDashboardLink.spec.ts | 4 +-
.../chart/widgetDataConfiguration.smoke.spec.ts | 12 +-
ui/cypress/tests/connect/adapterWithAssets.spec.ts | 10 +-
.../tests/connect/compact/uiConfiguration.spec.ts | 9 +-
ui/cypress/tests/connect/editAdapter.spec.ts | 10 +-
...c.ts => editAdapterDatasetSchemaUpdate.spec.ts} | 3 +-
.../editAdapterSettingsAndPipeline.smoke.spec.ts | 4 +-
.../restartStreamPipes/restartStreamPipes2.ts | 2 +-
ui/cypress/tests/pipeline/pipelineAsset.spec.ts | 58 +-
...spec.ts => pipelineDatasetSchemaUpdate.spec.ts} | 18 +-
.../tests/pipeline/renamePipelineTest.spec.ts | 19 +-
.../pipeline/updatePipelineTest.smoke.spec.ts | 14 +-
.../userManagement/testUserRoleDashboard.spec.ts | 4 +-
.../userManagement/testUserRoleDataset.spec.ts | 4 +-
ui/deployment/i18n/de.json | 32 +-
ui/deployment/i18n/en.json | 24 +-
ui/deployment/i18n/pl.json | 30 +-
ui/karma.conf.js | 66 -
ui/package-lock.json | 10914 ++++++++-----------
ui/package.json | 51 +-
.../streampipes/platform-services/README.md | 4 -
.../streampipes/platform-services/karma.conf.js | 60 -
.../streampipes/platform-services/package.json | 15 +-
.../src/lib/apis/datalake-rest.service.ts | 18 +-
.../src/lib/model/datalake/csv-import.model.ts | 16 +
.../streampipes/platform-services/src/test.ts | 50 -
.../platform-services/tsconfig.spec.json | 10 -
ui/projects/streampipes/shared-ui/README.md | 2 +-
ui/projects/streampipes/shared-ui/karma.conf.js | 61 -
ui/projects/streampipes/shared-ui/package.json | 12 +-
.../progress-bar/progress-bar.component.html} | 31 +-
.../progress-bar/progress-bar.component.scss} | 37 +-
.../progress-bar/progress-bar.component.ts | 57 +
.../search-select-template.directive.ts} | 24 +-
.../search-select/search-select.component.html | 141 +
.../search-select/search-select.component.scss | 104 +
.../search-select/search-select.component.ts | 304 +
.../sp-spinner/sp-spinner.component.html} | 17 +-
.../sp-spinner/sp-spinner.component.scss | 9 +-
.../components/sp-spinner/sp-spinner.component.ts} | 23 +-
.../lib/components/sp-table/sp-table.component.ts | 39 +-
.../services/file-name.service.spec.ts | 2 +
.../object-manage-dialog.component.html | 168 +-
.../object-manage-dialog.component.ts | 135 +-
.../object-permission-dialog.component.html | 139 +-
.../object-permission-dialog.component.ts | 141 +-
.../src/lib/services/keyboard-shortcut.service.ts | 8 +-
.../streampipes/shared-ui/src/public-api.ts | 4 +
.../streampipes/shared-ui/tsconfig.spec.json | 3 +-
ui/src/app/apidocs/apidocs.component.ts | 2 +-
.../asset-details-labels.component.html | 81 +-
.../asset-details-labels.component.ts | 112 +-
.../asset-details-links.component.html | 21 +-
.../edit-asset/asset-details.component.ts | 116 +-
.../asset-link-table.component.html | 201 +-
.../asset-link-table/asset-link-table.component.ts | 5 +
.../view-asset-links.component.html | 6 +-
.../view-asset-links/view-asset-links.component.ts | 2 +
.../asset-link-table.component.html | 387 +-
.../asset-link-table/asset-link-table.component.ts | 5 +
.../manage-asset-links-dialog.component.html | 1 +
.../manage-asset-links-dialog.component.ts | 2 +
.../chart-container/chart-container.component.html | 8 +-
.../chart-container/chart-container.component.ts | 19 +-
.../base/base-data-explorer-widget.directive.ts | 7 +-
.../models/dataview-dashboard.model.ts | 2 +
.../chart-overview-table.component.html | 35 +-
.../chart-overview-table.component.ts | 4 +-
.../chart-overview/chart-overview.component.scss | 5 -
.../chart-data-settings.component.html | 84 +-
.../data-settings/chart-data-settings.component.ts | 160 +-
...service-running-instances-dialog.component.html | 2 +-
...s-service-running-instances-dialog.component.ts | 4 +-
.../email-configuration.component.html | 4 +-
.../email-configuration.component.ts | 4 +-
.../data-export-dialog.component.html | 8 +-
.../export-dialog/data-export-dialog.component.ts | 4 +-
.../data-import-dialog.component.html | 8 +-
.../import-dialog/data-import-dialog.component.ts | 4 +-
.../extensions-installation.component.html | 16 +-
.../extensions-installation.component.ts | 4 +-
.../service-configs-password.component.spec.ts | 44 +-
.../shared/configuration.service.spec.ts | 15 +-
.../adapter-catalog/adapter-catalog.component.html | 14 +-
.../adapter-catalog/adapter-catalog.component.ts | 4 +-
.../adapter-configuration.component.html | 36 +-
.../adapter-configuration.component.ts | 144 +-
.../adapter-deployment-settings.component.html | 45 +-
.../adapter-deployment-settings.component.ts | 109 +-
...configure-fields-loading-message.component.html | 2 +-
.../configure-fields-loading-message.component.ts | 4 +-
.../adapter-result-preview.component.html | 2 +-
.../adapter-result-preview.component.ts | 4 +-
.../adapter-sample-preview.component.html | 2 +-
.../adapter-sample-preview.component.ts | 4 +-
.../start-adapter-configuration.component.html | 179 +-
.../start-adapter-configuration.component.ts | 13 +-
.../existing-adapters.component.html | 21 +-
.../existing-adapters.component.ts | 110 +-
.../adapter-code-dialog.component.html} | 38 +-
.../adapter-code-dialog.component.ts} | 35 +-
.../adapter-started-dialog.component.html | 27 +-
.../adapter-started-dialog.component.ts | 147 +-
.../adapter-started-loading.component.html | 8 +-
.../adapter-started-loading.component.ts | 4 +-
.../delete-adapter-dialog.component.html | 6 +-
.../delete-adapter-dialog.component.ts | 5 +-
.../loading-indicator.component.html | 3 +-
.../loading-indicator.component.scss | 5 -
.../loading-indicator.component.ts | 4 +-
.../multi-step-status-indicator.component.html | 5 +-
.../multi-step-status-indicator.component.ts | 4 +-
.../pipeline-operation-status.component.html | 93 +-
.../pipeline-operation-status.component.scss | 119 +-
.../pipeline-operation-status.component.ts | 31 +-
.../pipeline-started-status.component.html | 2 +-
.../add-to-collection.component.spec.ts | 36 +-
...tic-runtime-resolvable-any-input.component.html | 6 +-
...tatic-runtime-resolvable-any-input.component.ts | 4 +-
...c-runtime-resolvable-oneof-input.component.html | 6 +-
...tic-runtime-resolvable-oneof-input.component.ts | 8 +-
.../static-tree-input-button-menu.component.html | 6 +-
.../static-tree-input-button-menu.component.ts | 4 +-
.../chart-selection/chart-selection.component.html | 10 +-
.../chart-selection/chart-selection.component.scss | 5 -
.../chart-selection/chart-selection.component.ts | 4 +-
.../clone-dashboard-dialog.component.html | 2 +-
.../clone-dashboard-dialog.component.ts | 9 +-
.../dataset-details-events.component.html | 7 +-
.../dataset-details-events.component.ts | 4 +-
.../dataset-details-metrics.component.html | 7 +-
.../dataset-details-metrics.component.ts | 8 +-
.../dataset-last-event-label.component.html} | 0
.../dataset-last-event-label.component.scss} | 0
.../dataset-last-event-label.component.ts} | 8 +-
.../dataset-overview-entry.ts} | 3 +-
.../dataset-overview.component.html} | 18 +-
.../dataset-overview.component.scss} | 0
.../dataset-overview.component.ts} | 169 +-
ui/src/app/dataset/dataset.routes.ts | 4 +-
.../csv-import-dialog.component.html | 4 +-
.../csv-import-dialog.component.ts | 96 +-
.../csv-import-upload-state.component.html | 19 +-
.../csv-import-upload-state.component.scss | 19 +-
.../csv-import-upload-state.component.ts | 10 +-
.../data-retention-now-dialog.component.html | 6 +-
.../data-retention-now-dialog.component.ts | 9 +-
.../delete-dataset-dialog.component.html} | 5 +-
.../delete-dataset-dialog.component.ts} | 23 +-
.../delete-export-provider-dialog.component.html | 5 +-
.../delete-export-provider-dialog.component.ts | 5 +-
.../export-provider-connection-test.component.html | 6 +-
.../export-provider-connection-test.component.ts | 9 +-
.../user-defined-output.component.html | 75 +-
.../user-defined-output.component.ts | 5 +-
...-assembly-options-pipeline-cache.component.html | 6 +-
...ne-assembly-options-pipeline-cache.component.ts | 4 +-
.../pipeline-assembly-options.component.html | 51 +-
.../pipeline-assembly-options.component.ts | 42 +-
.../pipeline-assembly.component.html | 5 +-
.../pipeline-assembly.component.ts | 312 +-
.../pipeline-element-preview.component.html | 8 +-
.../pipeline-element-preview.component.ts | 4 +-
.../dropped-pipeline-element.component.html | 6 +-
.../dropped-pipeline-element.component.ts | 8 +-
.../save-pipeline-settings.component.html | 177 -
.../save-pipeline-settings.component.scss | 21 -
.../save-pipeline-settings.component.ts | 181 -
.../save-pipeline/save-pipeline.component.html | 118 +-
.../save-pipeline/save-pipeline.component.scss | 18 -
.../save-pipeline/save-pipeline.component.ts | 476 +-
ui/src/app/editor/editor.component.html | 9 +-
ui/src/app/editor/editor.component.ts | 9 +-
.../welcome-tour/welcome-tour.component.html | 8 +-
.../dialog/welcome-tour/welcome-tour.component.ts | 4 +-
.../login/components/login/login.component.html | 5 +-
.../app/login/components/login/login.component.ts | 4 +-
.../components/register/register.component.html | 6 +-
.../components/register/register.component.ts | 4 +-
.../set-new-password.component.html | 6 +-
.../set-new-password/set-new-password.component.ts | 4 +-
.../login/components/setup/setup.component.html | 5 +-
.../app/login/components/setup/setup.component.ts | 4 +-
.../pipeline-overview.component.html | 26 +-
.../delete-pipeline-dialog.component.html | 6 +-
.../delete-pipeline-dialog.component.ts | 5 +-
.../pipeline-notifications.component.html | 2 +-
.../pipeline-notifications.component.ts | 5 +-
.../pipeline-status-dialog.component.html | 17 +-
.../pipeline-status-dialog.component.ts | 5 +-
ui/src/app/pipelines/pipelines.component.html | 1 +
ui/src/app/pipelines/pipelines.component.ts | 1 -
.../services/pipeline-operations.service.ts | 127 +-
ui/src/scss/sp/_variables.scss | 1 +
ui/src/scss/sp/main.scss | 2 +-
.../src/test-setup.ts | 16 +-
ui/src/test.ts | 41 -
ui/src/tsconfig.spec.json | 11 -
ui/tsconfig.eslint.json | 2 +-
ui/tsconfig.spec.json | 5 +-
315 files changed, 12365 insertions(+), 11263 deletions(-)