You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ho...@apache.org on 2026/08/28 13:34:30 UTC
(streampipes) 01/02: Merge branch '4735-update-rest-endpoints-to-dataset-naming' into 4736-add-dataset-oriented-java-python-go-and-typescript-client-apis
This is an automated email from the ASF dual-hosted git repository.
JHoelli pushed a commit to branch 4736-add-dataset-oriented-java-python-go-and-typescript-client-apis
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit d70becbb773e0731871bc92f846d7dd979c6f66d
Merge: df9b791600 c5f85e24a8
Author: Jacqueline Höllig <j....@gmx.net>
AuthorDate: Fri Aug 28 15:09:21 2026 +0200
Merge branch '4735-update-rest-endpoints-to-dataset-naming' into 4736-add-dataset-oriented-java-python-go-and-typescript-client-apis
create-client-model.sh | 9 +
.../client/api/IDataLakeResourceApi.java | 17 +-
...LakeMeasureApi.java => IDatasetMeasureApi.java} | 14 +-
...keResourceApi.java => IDatasetResourceApi.java} | 6 +-
.../streampipes/client/api/IStreamPipesClient.java | 14 +-
.../streampipes/data_lake_dashboard_api.go | 6 +-
.../streampipes/data_lake_measure_api.go | 14 +-
.../streampipes/data_lake_widget_api.go | 6 +-
.../streampipes/endpoint/api/data_lake_measure.py | 2 +-
.../tests/client/test_data_lake_series.py | 2 +-
.../streampipes/client/StreamPipesClient.java | 21 +-
.../client/api/DataLakeResourceApi.java | 50 +---
...aLakeMeasureApi.java => DatasetMeasureApi.java} | 22 +-
...akeResourceApi.java => DatasetResourceApi.java} | 11 +-
.../client/serializer/SpQuerySerializer.java | 4 +-
.../management/compact/PersistPipelineHandler.java | 20 +-
.../dataexplorer/api/IDataExplorerManager.java | 24 +-
.../api/IDataExplorerQueryManagement.java | 14 +-
.../api/IDataExplorerSchemaManagement.java | 12 +-
...ounter.java => IDatasetMeasurementCounter.java} | 4 +-
...izer.java => IDatasetMeasurementSanitizer.java} | 24 +-
...QueryBuilder.java => IDatasetQueryBuilder.java} | 52 ++--
.../dataexplorer/api/IQueryStatement.java | 2 +-
.../export/ConfiguredCsvOutputWriter.java | 10 +-
.../export/ConfiguredExcelOutputWriter.java | 10 +-
.../export/ConfiguredJsonOutputWriter.java | 6 +-
.../export/ConfiguredOutputWriter.java | 8 +-
.../export/ConfiguredOutputWriterFactory.java | 6 +-
.../export/TestConfiguredCsvOutputWriter.java | 4 +-
.../export/TestConfiguredJsonOutputWriter.java | 2 +-
.../influx/DataExplorerInfluxQueryExecutor.java | 14 +-
.../influx/DataExplorerManagerInflux.java | 28 +-
.../influx/DataExplorerQueryManagementInflux.java | 32 +--
...Builder.java => DatasetInfluxQueryBuilder.java} | 68 ++---
...x.java => DatasetMeasurementCounterInflux.java} | 18 +-
.../dataexplorer/influx/DeleteDataQuery.java | 6 +-
.../influx/TimeSeriesStorageInflux.java | 6 +-
...java => DatasetMeasurementSanitizerInflux.java} | 12 +-
...ilderTest.java => DatasetQueryBuilderTest.java} | 10 +-
.../dataexplorer/influx/SelectQueryParamsTest.java | 56 ++--
.../influx/TimeSeriesStorageInfluxTest.java | 4 +-
... => DatasetMeasurementSanitizerInfluxTest.java} | 22 +-
.../utils/ProvidedQueryParameterBuilder.java | 4 +-
.../iotdb/DataExplorerIotDbQueryExecutor.java | 6 +-
.../iotdb/DataExplorerManagerIotDb.java | 26 +-
.../iotdb/DataExplorerQueryManagementIotDb.java | 4 +-
...Db.java => DatasetMeasurementCounterIotDb.java} | 16 +-
.../dataexplorer/iotdb/TimeSeriesStorageIotDb.java | 4 +-
....java => DatasetMeasurementSanitizerIotDb.java} | 12 +-
...a => DatasetMeasurementSanitizerIotDbTest.java} | 12 +-
.../dataexplorer/AutoAggregationHandler.java | 12 +-
.../dataexplorer/DataExplorerSchemaManagement.java | 72 ++---
...tizer.java => DatasetMeasurementSanitizer.java} | 54 ++--
.../streampipes/dataexplorer/ImageStore.java | 4 +-
.../streampipes/dataexplorer/ImageStoreUtils.java | 4 +-
.../dataexplorer/QueryResultProvider.java | 6 +-
.../dataexplorer/StreamedQueryResultProvider.java | 12 +-
.../dataexplorer/TimeSeriesStorage.java | 6 +-
.../streampipes/dataexplorer/TimeSeriesStore.java | 4 +-
.../param/ProvidedRestQueryParamConverter.java | 6 +-
.../dataexplorer/param/SelectQueryParams.java | 6 +-
.../dataexplorer/param/model/FillClauseParams.java | 4 +-
.../param/model/GroupByTagsClauseParams.java | 4 +-
.../param/model/GroupByTimeClauseParams.java | 4 +-
.../param/model/LimitClauseParams.java | 4 +-
.../param/model/OffsetClauseParams.java | 4 +-
.../param/model/OrderByClauseParams.java | 8 +-
.../param/model/SelectClauseParams.java | 10 +-
.../dataexplorer/param/model/SelectColumn.java | 6 +-
.../param/model/WhereClauseParams.java | 12 +-
.../query/DataExplorerQueryExecutor.java | 10 +-
...Counter.java => DatasetMeasurementCounter.java} | 34 +--
.../dataexplorer/AutoAggregationHandlerTest.java | 8 +-
.../DataExplorerSchemaManagementTest.java | 66 ++---
.../param/WhereStatementParamsTest.java | 2 +-
...est.java => DatasetMeasurementCounterTest.java} | 20 +-
...java => DatasetMeasurementCounterTestImpl.java} | 10 +-
.../streampipes/export/AssetLinkResolver.java | 2 +-
...xportManager.java => DatasetExportManager.java} | 78 +++---
.../export/dataimport/ImportGenerator.java | 6 +-
.../export/dataimport/PerformImportGenerator.java | 16 +-
.../export/dataimport/PreviewImportGenerator.java | 8 +-
.../export/generator/ExportPackageGenerator.java | 2 +-
.../streampipes/export/resolver/ChartResolver.java | 2 +-
.../export/resolver/MeasurementResolver.java | 24 +-
.../jvm/InternalSinksExtensionModuleExports.java | 12 +-
.../DatasetDimensionProvider.java} | 4 +-
.../DataLakeSink.java => dataset/DatasetSink.java} | 32 +--
.../migrations/DatasetSinkMigrationV1.java} | 12 +-
.../migrations/DatasetSinkMigrationV2.java} | 14 +-
.../migrations/DatasetSinkMigrationV1Test.java} | 14 +-
.../migrations/DatasetSinkMigrationV2Test.java} | 12 +-
.../model/dashboard/CompositeDashboardModel.java | 6 +-
.../model/dashboard/DashboardEntity.java | 2 +-
.../{datalake => dataset}/AggregationFunction.java | 2 +-
.../{datalake => dataset}/ChartSummaryDto.java | 2 +-
.../CriticalMeasurementFieldChange.java | 2 +-
.../{datalake => dataset}/CustomMapSerializer.java | 2 +-
.../DataExplorerWidgetHealthStatus.java | 2 +-
.../DataExplorerWidgetModel.java | 2 +-
.../{datalake => dataset}/DataRetentionConfig.java | 2 +-
.../model/{datalake => dataset}/DataSeries.java | 2 +-
.../{datalake => dataset}/DataSeriesBuilder.java | 2 +-
.../DatasetMeasure.java} | 20 +-
.../DatasetMeasureSchemaUpdateStrategy.java} | 12 +-
.../DatasetQueryOrdering.java} | 4 +-
.../{datalake => dataset}/DatasetSummaryDto.java | 2 +-
.../model/{datalake => dataset}/ExportConfig.java | 2 +-
.../{datalake => dataset}/FilterCondition.java | 2 +-
.../FilterExpressionCondition.java | 2 +-
.../FilterExpressionGroup.java | 2 +-
.../FilterExpressionLogicalOperator.java | 2 +-
.../FilterExpressionNode.java | 2 +-
.../MeasurementUpdateInfo.java | 2 +-
.../{datalake => dataset}/RetentionAction.java | 2 +-
.../RetentionExportConfig.java | 2 +-
.../{datalake => dataset}/RetentionInterval.java | 2 +-
.../model/{datalake => dataset}/RetentionLog.java | 2 +-
.../{datalake => dataset}/RetentionTimeConfig.java | 2 +-
.../model/{datalake => dataset}/SpQueryResult.java | 2 +-
.../SpQueryResultBuilder.java | 2 +-
.../model/{datalake => dataset}/SpQueryStatus.java | 2 +-
.../importer/CsvImportColumn.java | 2 +-
.../importer/CsvImportConfiguration.java | 2 +-
.../importer/CsvImportJobStartResult.java | 2 +-
.../importer/CsvImportJobState.java | 2 +-
.../importer/CsvImportJobStatus.java | 2 +-
.../importer/CsvImportPreviewRequest.java | 2 +-
.../importer/CsvImportPreviewResult.java | 2 +-
.../importer/CsvImportRequest.java | 2 +-
.../importer/CsvImportResult.java | 2 +-
.../importer/CsvImportSchemaIssue.java | 2 +-
.../importer/CsvImportSchemaIssueType.java | 2 +-
.../importer/CsvImportSchemaValidationRequest.java | 2 +-
.../importer/CsvImportSchemaValidationResult.java | 2 +-
.../importer/CsvImportTarget.java | 2 +-
.../importer/CsvImportTargetMode.java | 2 +-
.../importer/CsvImportValidationMessage.java | 2 +-
.../param/ProvidedRestQueryParams.java | 2 +-
.../param/SupportedRestQueryParams.java | 2 +-
.../DataSeriesBuilderTest.java | 2 +-
.../DatasetMeasureTest.java} | 20 +-
.../SpQueryResultBuilderTest.java | 2 +-
.../v2/pipeline/MeasurementChangeDetector.java | 2 +-
.../pipeline/MeasurementChangeValidationStep.java | 4 +-
...nManager.java => DatasetPermissionManager.java} | 14 +-
.../update/ChartSchemaUpdateCoordinator.java | 26 +-
.../update/MeasurementUpdateManagement.java | 8 +-
.../pipeline/update/MeasurementUpdateUtils.java | 12 +-
.../manager/setup/CouchDbInstallationStep.java | 4 +-
.../setup/tasks/AddAssetManagementViewTask.java | 6 +-
...iewTask.java => AddDatasetMeasureViewTask.java} | 12 +-
.../tasks/AddDefaultPipelineTemplatesTask.java | 4 +-
...te.java => PersistDatasetPipelineTemplate.java} | 30 +-
.../MeasurementChangeValidationStepTest.java | 10 +-
.../update/ChartSchemaUpdateCoordinatorTest.java | 10 +-
.../update/MeasurementUpdateManagementTest.java | 14 +-
.../update/PipelineUpdateCoordinatorTest.java | 6 +-
.../resource/management/ChartResourceManager.java | 4 +-
.../management/DashboardResourceManager.java | 14 +-
...ger.java => DatasetMeasureResourceManager.java} | 16 +-
.../resource/management/SpResourceManager.java | 10 +-
streampipes-rest/AGENTS.md | 2 +-
.../apache/streampipes/rest/ResetManagement.java | 20 +-
.../streampipes/rest/impl/PipelineResource.java | 2 +-
...Resource.java => DatasetDashboardResource.java} | 6 +-
.../AbstractDatasetResource.java} | 24 +-
.../DatasetDataWriter.java} | 32 +--
.../DatasetImageResource.java} | 6 +-
.../DatasetMeasureResource.java} | 46 ++--
.../DatasetResource.java} | 116 ++++----
.../DatasetWidgetResource.java} | 12 +-
.../KioskDashboardDatasetResource.java} | 16 +-
.../PersistedDatasetResource.java} | 28 +-
.../importer/CsvDatasetImportService.java} | 60 ++--
.../importer/CsvImportColumnMapper.java | 4 +-
.../importer/CsvImportJobManager.java | 20 +-
.../importer/CsvImportParser.java | 22 +-
.../importer/CsvImportUploadStorage.java | 2 +-
.../importer/CsvImportValidationException.java | 4 +-
.../importer/CsvImportValidationService.java | 26 +-
.../importer/DatasetImportResource.java} | 38 +--
.../DatasetDataWriterTest.java} | 10 +-
.../DatasetLatestEventsBenchmarkTest.java} | 14 +-
.../DatasetResourceTest.java} | 20 +-
.../importer/CsvDatasetImportServiceTest.java} | 112 ++++----
.../importer/CsvImportParserTest.java | 8 +-
.../importer/CsvImportValidationServiceTest.java | 20 +-
.../ExtensionServiceRequestConfiguration.java | 4 +-
.../core/migrations/AvailableMigrations.java | 10 +-
...on.java => AddDatasetMeasureViewMigration.java} | 12 +-
.../v099/CreateDatasetPermissionMigration.java | 16 +-
...ataLakeScheduler.java => DatasetScheduler.java} | 24 +-
.../service/core/storage/CachedChartStorage.java | 2 +-
...orage.java => CachedDatasetMeasureStorage.java} | 26 +-
.../core/storage/StorageApiConfiguration.java | 20 +-
.../src/main/resources/application.properties | 2 +-
.../core/storage/CachedChartStorageTest.java | 2 +-
...t.java => CachedDatasetMeasureStorageTest.java} | 20 +-
.../core/storage/StorageApiConfigurationTest.java | 6 +-
.../storage/api/explorer/IChartStorage.java | 2 +-
...ureStorage.java => IDatasetMeasureStorage.java} | 6 +-
.../couchdb/impl/explorer/ChartStorageImpl.java | 2 +-
...sureStorage.java => DatasetMeasureStorage.java} | 18 +-
ui/cypress/support/utils/chart/ChartBtns.ts | 2 +-
ui/cypress/support/utils/chart/ChartUtils.ts | 4 +-
ui/cypress/support/utils/connect/ConnectUtils.ts | 4 +-
ui/cypress/support/utils/dataset/DatasetBtns.ts | 20 +-
.../support/utils/dataset/DatasetSeedUtils.ts | 6 +-
ui/cypress/support/utils/dataset/DatasetUtils.ts | 16 +-
.../tests/assetManagement/assetFilterTest.spec.ts | 16 +-
ui/cypress/tests/chart/autoAggregateTable.spec.ts | 2 +-
ui/cypress/tests/chart/configuration.smoke.spec.ts | 8 +-
.../restartStreamPipes/restartStreamPipes2.ts | 2 +-
ui/deployment/i18n/de.json | 2 +-
ui/deployment/i18n/en.json | 2 +-
ui/deployment/i18n/pl.json | 2 +-
.../src/lib/apis/chart.service.ts | 16 +-
.../src/lib/apis/dashboard-kiosk.service.ts | 6 +-
.../src/lib/apis/dashboard.service.ts | 14 +-
...ake-rest.service.ts => dataset-rest.service.ts} | 92 +++----
.../src/lib/apis/shared-dashboard.service.ts | 2 +-
.../src/lib/model/dashboard/dashboard.model.ts | 6 +-
.../DatasetQueryParameters.ts} | 4 +-
.../lib/model/{datalake => dataset}/DateRange.ts | 0
.../{datalake => dataset}/csv-import.model.ts | 0
.../dataset-query-config.model.ts} | 4 +-
.../src/lib/model/gen/streampipes-model-client.ts | 14 +-
.../src/lib/model/gen/streampipes-model.ts | 302 +++++++++------------
...rBuilder.ts => DatasetQueryParameterBuilder.ts} | 38 +--
.../dashboard-data-request-coordinator.service.ts | 34 +--
.../lib/query/data-view-query-generator.service.ts | 36 +--
.../platform-services/src/public-api.ts | 12 +-
.../services/data-export.service.ts | 12 +-
.../assets/dialog/base-asset-links.directive.ts | 6 +-
.../chart-container/chart-container.component.ts | 6 +-
.../charts/image/image-widget.component.ts | 6 +-
.../chart-view/chart-view.component.html | 4 +-
.../components/chart-view/chart-view.component.ts | 10 +-
.../chart-designer-panel.component.html | 2 +-
.../chart-designer-panel.component.ts | 10 +-
.../data-settings/chart-data-settings.component.ts | 32 +--
.../filter-selection-panel.component.ts | 6 +-
.../configuration/shared/configuration.service.ts | 2 +-
.../start-adapter-configuration.component.html | 8 +-
.../start-adapter-configuration.component.ts | 14 +-
.../adapter-started-dialog.component.html | 2 +-
.../adapter-started-dialog.component.ts | 24 +-
.../adapter-started-success.component.html | 2 +-
.../adapter-started-success.component.ts | 2 +-
.../chart-view/abstract-chart-view.directive.ts | 8 +-
.../grid-view/dashboard-grid-view.component.html | 4 +-
.../slide-view/dashboard-slide-view.component.html | 2 +-
.../slide-view/dashboard-slide-view.component.ts | 6 +-
.../components/panel/dashboard-panel.component.ts | 4 +-
.../abstract-dataset-details.directive.ts | 12 +-
.../dataset-details-events.component.ts | 2 +-
.../dataset-details-metrics.component.ts | 6 +-
.../dataset-feature-card.component.ts | 14 +-
.../dataset-overview.component.html | 14 +-
.../dataset-overview/dataset-overview.component.ts | 10 +-
.../csv-import-dialog.component.ts | 12 +-
.../data-retention-dialog.component.ts | 14 +-
.../data-retention-log-dialog.component.ts | 4 +-
.../data-retention-now-dialog.component.ts | 10 +-
.../delete-dataset-dialog.component.ts | 14 +-
.../delete-export-provider-dialog.component.html | 2 +-
.../delete-export-provider-dialog.component.ts | 4 +-
.../export-provider-connection-test.component.ts | 4 +-
.../save-pipeline/save-pipeline.component.ts | 4 +-
270 files changed, 1739 insertions(+), 1813 deletions(-)