This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch remove-supported-grounding
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from f61a43f364 feat: Add broker communication mode (#4255)
add 377b586967 fix(#4241): wait for file selection before continuing
File_Stream setup (#4243)
add 8d6f35e630 refactor(#4236): move shared enums and guards into core
domains (#4237)
add 2ce5dfceb4 chore(deps): bump docker/build-push-action from 6 to 7
(#4227)
add c1bdbe99bd chore(deps): bump docker/login-action from 3 to 4 (#4221)
add c0cced24c3 chore(deps): bump docker/setup-qemu-action from 3 to 4
(#4220)
add 038007ba62 chore(deps): bump actions/upload-artifact from 6 to 7
(#4206)
add 241c43379e chore(deps-dev): bump tornado from 6.5 to 6.5.5 in
/streampipes-client-python (#4245)
add 444028b0a9 fix(#4246): Accept full and shorthand propertyScope values
in compactadapters (#4249)
add 6a5296f321 feat(#4247): Add asset infos to resource table (#4248)
add 8e1f89965a feat: Full integration of filter feature for table widget,
excel like filte⦠(#4240)
add 0d679f838b feat(#4250): add csv dataset import with preview for data
sets (#4254)
add d628cd9b8a refactor: migrate pipeline element e2e cases (#4265)
add b61a4247b4 Merge branch 'dev' into remove-supported-grounding
No new revisions were added by this update.
Summary of changes:
.github/workflows/build.yml | 16 +-
.github/workflows/extensions-docs.yml | 6 +-
.github/workflows/go-docs.yml | 2 +-
.github/workflows/pypi-deployment.yml | 2 +-
.github/workflows/python-docs.yml | 2 +-
streampipes-client-python/poetry.lock | 28 +-
.../management/compact/SchemaMetadataEnricher.java | 24 +-
.../jvm/processor/math/MathOpProcessorTest.java | 62 +-
.../staticmathop/StaticMathOpProcessorTest.java | 85 ++
.../trigonometry/TrigonometryProcessorTest.java | 86 ++
.../valuechange/ValueChangeProcessorTest.java | 69 ++
.../booleanfilter/TestBooleanFilterProcessor.java | 70 ++
.../processor/limit/RateLimitProcessorTest.java | 64 ++
.../NumericalFilterProcessorTest.java | 35 +-
.../projection/TestProjectionProcessor.java | 51 +-
.../textfilter/TestTextFilterProcessor.java | 71 ++
.../threshold/TestThresholdDetectionProcessor.java | 47 +-
.../array/count/CountArrayProcessorTest.java | 55 ++
.../split/SplitArrayProcessorTest.java} | 49 +-
.../counter/TestBooleanCounterProcessor.java | 205 ++---
.../edge/SignalEdgeFilterProcessorTest.java | 65 ++
.../inverter/BooleanInverterProcessorTest.java | 67 ++
.../fieldrename/FiledRenameProcessorTest.java | 68 ++
.../processor/hasher/FieldHasherProcessorTest.java | 75 ++
.../mapper/FieldMapperProcessorTest.java} | 46 +-
.../model/datalake/importer/CsvImportColumn.java | 104 +++
.../datalake/importer/CsvImportConfiguration.java | 43 +-
.../CsvImportPreviewRequest.java} | 63 +-
.../datalake/importer/CsvImportPreviewResult.java | 100 +++
.../model/datalake/importer/CsvImportRequest.java | 89 ++
.../model/datalake/importer/CsvImportResult.java | 71 ++
.../datalake/importer/CsvImportSchemaIssue.java | 74 ++
.../importer/CsvImportSchemaIssueType.java | 11 +-
.../importer/CsvImportSchemaValidationRequest.java | 45 +-
.../importer/CsvImportSchemaValidationResult.java | 45 +-
.../importer/CsvImportTarget.java} | 22 +-
.../datalake/importer/CsvImportTargetMode.java | 6 +-
.../importer/CsvImportValidationMessage.java} | 20 +-
.../impl/datalake/AbstractDataLakeResource.java | 4 +
.../rest/impl/datalake/DataLakeDataWriter.java | 52 +-
.../importer/CsvDataLakeImportService.java | 325 ++++++++
.../impl/datalake/importer/CsvImportParser.java | 619 ++++++++++++++
.../datalake/importer/CsvImportUploadStorage.java | 130 +++
.../importer/CsvImportValidationException.java | 19 +-
.../importer/CsvImportValidationService.java | 339 ++++++++
.../datalake/importer/DataLakeImportResource.java | 145 ++++
.../rest/impl/datalake/DataLakeDataWriterTest.java | 56 ++
.../importer/CsvDataLakeImportServiceTest.java | 326 ++++++++
.../datalake/importer/CsvImportParserTest.java | 120 +++
.../importer/CsvImportValidationServiceTest.java | 169 ++++
.../executors/ProcessingElementTestExecutor.java | 24 +-
...hine-data-simulator-import-later-timestamps.csv | 8 +
...-data-simulator-import-mismatched-timestamp.csv | 8 +
...achine-data-simulator-import-missing-values.csv | 8 +
...hine-data-simulator-import-string-timestamp.csv | 8 +
.../datalake/machine-data-simulator-import.csv | 8 +
.../enrich-jvm/math1/description.json | 20 -
.../pipelineElement/enrich-jvm/math1/expected.csv | 3 -
.../pipelineElement/enrich-jvm/math1/input.csv | 3 -
.../enrich-jvm/math2/description.json | 20 -
.../pipelineElement/enrich-jvm/math2/expected.csv | 3 -
.../pipelineElement/enrich-jvm/math2/input.csv | 3 -
.../enrich-jvm/math3/description.json | 20 -
.../pipelineElement/enrich-jvm/math3/expected.csv | 3 -
.../pipelineElement/enrich-jvm/math3/input.csv | 3 -
.../enrich-jvm/staticmath1/description.json | 20 -
.../enrich-jvm/staticmath1/expected.csv | 3 -
.../enrich-jvm/staticmath1/input.csv | 3 -
.../enrich-jvm/staticmath2/description.json | 20 -
.../enrich-jvm/staticmath2/expected.csv | 3 -
.../enrich-jvm/staticmath2/input.csv | 3 -
.../enrich-jvm/trigonometry1/description.json | 15 -
.../enrich-jvm/trigonometry1/expected.csv | 3 -
.../enrich-jvm/trigonometry1/input.csv | 3 -
.../enrich-jvm/trigonometry2/description.json | 15 -
.../enrich-jvm/trigonometry2/expected.csv | 3 -
.../enrich-jvm/trigonometry2/input.csv | 3 -
.../enrich-jvm/valueChange1/description.json | 20 -
.../enrich-jvm/valueChange1/expected.csv | 11 -
.../enrich-jvm/valueChange1/input.csv | 11 -
.../filters-jvm/booleanFilter1/description.json | 15 -
.../filters-jvm/booleanFilter1/expected.csv | 6 -
.../filters-jvm/booleanFilter1/input.csv | 11 -
.../filters-jvm/booleanFilter2/description.json | 15 -
.../filters-jvm/booleanFilter2/expected.csv | 6 -
.../filters-jvm/booleanFilter2/input.csv | 11 -
.../filters-jvm/numericalFilter1/description.json | 12 -
.../filters-jvm/numericalFilter1/expected.csv | 6 -
.../filters-jvm/numericalFilter1/input.csv | 11 -
.../filters-jvm/projection1/description.json | 15 -
.../filters-jvm/projection1/expected.csv | 6 -
.../filters-jvm/projection1/input.csv | 6 -
.../filters-jvm/rateLimit1/description.json | 25 -
.../filters-jvm/rateLimit1/expected.csv | 3 -
.../filters-jvm/rateLimit1/input.csv | 12 -
.../filters-jvm/textFilter1/description.json | 8 -
.../filters-jvm/textFilter1/expected.csv | 4 -
.../filters-jvm/textFilter1/input.csv | 11 -
.../filters-jvm/textFilter2/description.json | 8 -
.../filters-jvm/textFilter2/expected.csv | 5 -
.../filters-jvm/textFilter2/input.csv | 11 -
.../thresholdDetection1/description.json | 20 -
.../filters-jvm/thresholdDetection1/expected.csv | 11 -
.../filters-jvm/thresholdDetection1/input.csv | 11 -
.../booleanCounter1/description.json | 7 -
.../booleanCounter1/expected.csv | 6 -
.../transformation-jvm/booleanCounter1/input.csv | 11 -
.../booleanCounter2/description.json | 15 -
.../booleanCounter2/expected.csv | 8 -
.../transformation-jvm/booleanCounter2/input.csv | 11 -
.../booleanInverter1/description.json | 10 -
.../booleanInverter1/expected.csv | 11 -
.../transformation-jvm/booleanInverter1/input.csv | 11 -
.../countArray1/description.json | 6 -
.../transformation-jvm/countArray1/expected.csv | 5 -
.../transformation-jvm/countArray1/input.json | 6 -
.../fieldHasher1/description.json | 11 -
.../transformation-jvm/fieldHasher1/expected.csv | 3 -
.../transformation-jvm/fieldHasher1/input.csv | 3 -
.../fieldHasher2/description.json | 11 -
.../transformation-jvm/fieldHasher2/expected.csv | 3 -
.../transformation-jvm/fieldHasher2/input.csv | 5 -
.../fieldMapper1/description.json | 8 -
.../transformation-jvm/fieldMapper1/expected.csv | 3 -
.../transformation-jvm/fieldMapper1/input.csv | 5 -
.../fieldRenamer1/description.json | 7 -
.../transformation-jvm/fieldRenamer1/expected.csv | 11 -
.../transformation-jvm/fieldRenamer1/input.csv | 11 -
.../signalEdgeFilter1/description.json | 13 -
.../signalEdgeFilter1/expected.csv | 6 -
.../transformation-jvm/signalEdgeFilter1/input.csv | 11 -
.../splitArray1/description.json | 11 -
.../transformation-jvm/splitArray1/expected.csv | 3 -
.../transformation-jvm/splitArray1/input.json | 4 -
ui/cypress/plugins/index.ts | 7 +-
ui/cypress/support/builder/UserBuilder.ts | 2 +-
ui/cypress/support/model/User.ts | 2 +-
ui/cypress/support/utils/PrepareTestDataUtils.ts | 64 +-
ui/cypress/support/utils/UserUtils.ts | 2 +-
ui/cypress/support/utils/chart/ChartBtns.ts | 16 +
ui/cypress/support/utils/chart/ChartUtils.ts | 85 +-
.../support/utils/chart/ChartWidgetTableUtils.ts | 15 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 6 +
ui/cypress/support/utils/connect/ConnectUtils.ts | 5 +
.../support/utils/dataset/DataLakeSeedUtils.ts | 275 ++++++
ui/cypress/support/utils/dataset/DatasetBtns.ts | 97 +++
ui/cypress/support/utils/dataset/DatasetUtils.ts | 108 +++
ui/cypress/tests/chart/configuration.smoke.spec.ts | 2 -
...e.spec.ts => dynamicColumnFilter.smoke.spec.ts} | 42 +-
.../chart/filterNumericalStringProperties.spec.ts | 32 +-
ui/cypress/tests/dataset/csvImport.spec.ts | 113 +++
.../pipeline/multiUser/pipelineMultiUserSupport.ts | 2 +-
.../userManagement/addUserAdmin.smoke.spec.ts | 2 +-
.../testAddAssetOnResourceCreation.ts | 2 +-
.../userManagement/testGroupManagement.spec.ts | 2 +-
.../userManagement/testUserRoleAssets.spec.ts | 2 +-
.../userManagement/testUserRoleCharts.spec.ts | 2 +-
.../userManagement/testUserRoleConnect.spec.ts | 2 +-
.../userManagement/testUserRoleDashboard.spec.ts | 14 +-
.../userManagement/testUserRoleDataset.spec.ts | 19 +-
.../userManagement/testUserRolePipeline.spec.ts | 2 +-
.../testVariousUserRoles.smoke.spec.ts | 2 +-
ui/deployment/app.routes.mst | 18 +-
ui/deployment/base-navigation.component.mst | 6 +-
ui/deployment/home.service.mst | 6 +-
.../src/lib/apis/datalake-rest.service.ts | 51 ++
.../src/lib/model/datalake/csv-import.model.ts | 114 +++
.../platform-services/src/public-api.ts | 1 +
.../{ => sp-actions}/sp-table-actions.directive.ts | 0
.../sp-table-multi-actions.directive.ts | 0
.../sp-table-asset-context.service.ts | 178 ++++
.../components/sp-table/sp-table.component.html | 340 ++++++--
.../components/sp-table/sp-table.component.scss | 90 +-
.../lib/components/sp-table/sp-table.component.ts | 355 +++++++-
.../src/lib/components/sp-table/sp-table.model.ts | 63 ++
.../data-download-dialog.component.html | 2 +-
.../standard-dialog/standard-dialog.component.scss | 3 +-
.../streampipes/shared-ui/src/public-api.ts | 6 +-
ui/src/app/assets/assets.routes.ts | 4 +-
.../asset-link-table/asset-link-table.component.ts | 2 +-
.../asset-overview/asset-overview.component.ts | 2 +-
.../chart-container/chart-container.component.ts | 2 +-
.../charts/table/table-widget.component.html | 371 ++++++++-
.../charts/table/table-widget.component.scss | 331 +++++++-
.../charts/table/table-widget.component.ts | 917 +++++++++++++++++----
.../chart-overview-table.component.html | 1 +
.../chart-overview-table.component.ts | 6 +
.../chart-overview/chart-overview.component.ts | 2 +-
.../components/chart-view/chart-view.component.ts | 2 +-
.../toolbar/chart-view-toolbar.component.ts | 2 +-
.../general-configuration.component.ts | 2 +-
.../edit-user-dialog/edit-user-dialog.component.ts | 2 +-
.../sites-configuration.component.ts | 2 +-
.../start-adapter-configuration.component.ts | 2 +-
.../existing-adapters.component.html | 1 +
.../existing-adapters.component.ts | 6 +
.../static-file-input.component.html | 1 +
.../guards}/auth.can-activate-children.guard.ts | 2 +-
.../auth/guards}/auth.can-activate.guard.ts | 2 +-
.../auth/guards/page-auth.can-activate.guard.ts} | 2 +-
.../{_enums => core/auth}/user-privilege.enum.ts | 0
ui/src/app/{_enums => core/auth}/user-role.enum.ts | 0
.../{_enums => core/navigation}/page-name.enum.ts | 0
.../already-configured.can-activate.guard.ts | 2 +-
.../guards}/base-configured.can-activate.guard.ts | 2 +-
.../setup/guards}/configured.can-activate.guard.ts | 2 +-
.../registration-allowed.can-activate.guard.ts | 2 +-
.../restore-password-allowed.can-activate.guard.ts | 2 +-
.../guards}/terms.can-activate-children.guard.ts | 2 +-
.../dashboard-overview-table.component.html | 1 +
.../dashboard-overview-table.component.ts | 6 +
.../overview/dashboard-overview.component.ts | 2 +-
.../chart-selection/chart-selection.component.ts | 2 +-
.../components/panel/dashboard-panel.component.ts | 2 +-
.../edit-dashboard-dialog.component.ts | 2 +-
.../datalake-configuration.component.html | 9 +
.../datalake-configuration.component.ts | 28 +-
.../csv-import-dialog.component.html | 324 ++++++++
.../csv-import-dialog.component.scss | 95 +++
.../csv-import-dialog.component.ts | 786 ++++++++++++++++++
.../csv-import-preview-table.component.html | 186 +++++
.../csv-import-preview-table.component.scss | 77 ++
.../csv-import-preview-table.component.ts | 102 +++
.../csv-import-upload-state.component.html | 56 ++
.../csv-import-upload-state.component.scss} | 41 +-
.../csv-import-upload-state.component.ts} | 31 +-
.../dialog/csv-import-dialog/csv-import.model.ts} | 28 +-
.../save-pipeline-settings.component.ts | 2 +-
ui/src/app/home/components/status.component.ts | 2 +-
ui/src/app/home/home.component.ts | 2 +-
ui/src/app/home/models/home.model.ts | 2 +-
.../pipeline-details/pipeline-details.component.ts | 2 +-
.../pipeline-overview.component.html | 1 +
.../pipeline-overview.component.ts | 12 +-
ui/src/app/pipelines/pipelines.component.ts | 4 +-
235 files changed, 9087 insertions(+), 1661 deletions(-)
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/math/staticmathop/StaticMathOpProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/trigonometry/TrigonometryProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-enricher-jvm/src/test/java/org/apache/streampipes/processors/enricher/jvm/processor/valuechange/ValueChangeProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/limit/RateLimitProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/array/count/CountArrayProcessorTest.java
copy
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/{transformtoboolean/TransformToBooleanProcessorTest.java
=> array/split/SplitArrayProcessorTest.java} (52%)
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/edge/SignalEdgeFilterProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/fieldrename/FiledRenameProcessorTest.java
create mode 100644
streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/hasher/FieldHasherProcessorTest.java
copy
streampipes-extensions/{streampipes-processors-filters-jvm/src/test/java/org/apache/streampipes/processors/filters/jvm/processor/projection/TestProjectionProcessor.java
=>
streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/mapper/FieldMapperProcessorTest.java}
(52%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportColumn.java
copy
streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/state/labeler/model/Statement.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportConfiguration.java
(52%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/{DataSeries.java
=> importer/CsvImportPreviewRequest.java} (54%)
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportPreviewResult.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportRequest.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportResult.java
create mode 100644
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaIssue.java
copy
streampipes-client-api/src/main/java/org/apache/streampipes/client/api/INotificationsApi.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaIssueType.java
(80%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/FixedSizeList.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaValidationRequest.java
(56%)
copy
streampipes-extensions-api/src/main/java/org/apache/streampipes/extensions/api/monitoring/FixedSizeList.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportSchemaValidationResult.java
(53%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{NotificationCount.java
=> datalake/importer/CsvImportTarget.java} (64%)
copy
streampipes-connect-transformer-api/src/main/java/org/apache/streampipes/connect/transformer/api/Context.java
=>
streampipes-model/src/main/java/org/apache/streampipes/model/datalake/importer/CsvImportTargetMode.java
(88%)
copy
streampipes-model/src/main/java/org/apache/streampipes/model/{extensions/transport/ExtensionServiceBrokerErrorEnvelope.java
=> datalake/importer/CsvImportValidationMessage.java} (70%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvDataLakeImportService.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportParser.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportUploadStorage.java
copy
streampipes-model-client/src/main/java/org/apache/streampipes/model/client/exception/InvalidConnectionException.java
=>
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportValidationException.java
(56%)
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportValidationService.java
create mode 100644
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/importer/DataLakeImportResource.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/DataLakeDataWriterTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/importer/CsvDataLakeImportServiceTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportParserTest.java
create mode 100644
streampipes-rest/src/test/java/org/apache/streampipes/rest/impl/datalake/importer/CsvImportValidationServiceTest.java
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-later-timestamps.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-mismatched-timestamp.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-missing-values.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import-string-timestamp.csv
create mode 100644
ui/cypress/fixtures/datalake/machine-data-simulator-import.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math3/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math3/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/math3/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/staticmath2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/trigonometry2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/valueChange1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/valueChange1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/enrich-jvm/valueChange1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/booleanFilter2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/numericalFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/projection1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/rateLimit1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/textFilter2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/thresholdDetection1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/thresholdDetection1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/filters-jvm/thresholdDetection1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanCounter2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/booleanInverter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/countArray1/input.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher2/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher2/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldHasher2/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldMapper1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldMapper1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldMapper1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/fieldRenamer1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/signalEdgeFilter1/input.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/description.json
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/expected.csv
delete mode 100644
ui/cypress/fixtures/pipelineElement/transformation-jvm/splitArray1/input.json
create mode 100644 ui/cypress/support/utils/dataset/DataLakeSeedUtils.ts
copy ui/cypress/tests/chart/{missingDataInDataLake.spec.ts =>
dynamicColumnFilter.smoke.spec.ts} (50%)
create mode 100644 ui/cypress/tests/dataset/csvImport.spec.ts
create mode 100644
ui/projects/streampipes/platform-services/src/lib/model/datalake/csv-import.model.ts
rename ui/projects/streampipes/shared-ui/src/lib/components/sp-table/{ =>
sp-actions}/sp-table-actions.directive.ts (100%)
rename ui/projects/streampipes/shared-ui/src/lib/components/sp-table/{ =>
sp-actions}/sp-table-multi-actions.directive.ts (100%)
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/sp-table/sp-asset-context/sp-table-asset-context.service.ts
create mode 100644
ui/projects/streampipes/shared-ui/src/lib/components/sp-table/sp-table.model.ts
rename ui/src/app/{_guards =>
core/auth/guards}/auth.can-activate-children.guard.ts (95%)
rename ui/src/app/{_guards => core/auth/guards}/auth.can-activate.guard.ts
(95%)
rename ui/src/app/{_guards/page-auth.can-active.guard.ts =>
core/auth/guards/page-auth.can-activate.guard.ts} (96%)
rename ui/src/app/{_enums => core/auth}/user-privilege.enum.ts (100%)
rename ui/src/app/{_enums => core/auth}/user-role.enum.ts (100%)
rename ui/src/app/{_enums => core/navigation}/page-name.enum.ts (100%)
rename ui/src/app/{_guards =>
core/setup/guards}/already-configured.can-activate.guard.ts (95%)
rename ui/src/app/{_guards =>
core/setup/guards}/base-configured.can-activate.guard.ts (97%)
rename ui/src/app/{_guards =>
core/setup/guards}/configured.can-activate.guard.ts (95%)
rename ui/src/app/{_guards =>
core/setup/guards}/registration-allowed.can-activate.guard.ts (96%)
rename ui/src/app/{_guards =>
core/setup/guards}/restore-password-allowed.can-activate.guard.ts (96%)
rename ui/src/app/{_guards =>
core/setup/guards}/terms.can-activate-children.guard.ts (96%)
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-dialog.component.html
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-dialog.component.scss
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-dialog.component.ts
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-preview-table/csv-import-preview-table.component.html
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-preview-table/csv-import-preview-table.component.scss
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-preview-table/csv-import-preview-table.component.ts
create mode 100644
ui/src/app/dataset/dialog/csv-import-dialog/csv-import-upload-state/csv-import-upload-state.component.html
copy
ui/src/app/dataset/dialog/{data-retention-dialog/components/select-retention/select-data.component.scss
=>
csv-import-dialog/csv-import-upload-state/csv-import-upload-state.component.scss}
(59%)
copy
ui/{projects/streampipes/shared-ui/src/lib/components/pipeline-element-runtime-info/live-preview-loading/live-preview-loading.component.ts
=>
src/app/dataset/dialog/csv-import-dialog/csv-import-upload-state/csv-import-upload-state.component.ts}
(55%)
copy
ui/src/app/{chart-shared/components/charts/image/model/image-widget.model.ts =>
dataset/dialog/csv-import-dialog/csv-import.model.ts} (62%)