You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2023/04/07 08:31:20 UTC
[streampipes] branch 1353-geo-create-derived-polygon-of-input-geometry-processor updated (2c859999b -> 79c571b37)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch 1353-geo-create-derived-polygon-of-input-geometry-processor
in repository https://gitbox.apache.org/repos/asf/streampipes.git
omit 2c859999b [#1353] fix double processor entry in init
omit 31234778b [#1353] finish polygon processor, adjust documentation and variables
omit 17ef0a90f [#1353] Implement Basic derived polygon processor
add ae234aed7 Add environment variable for manually specifying file storage in backend (#1383) (#1384)
add 29b8ea921 Migrate boolean counter #1366 (#1382)
add 90b62ba0d Migrate boolean inverter (#1388)
add ec51de356 Bump @typescript-eslint/parser from 5.52.0 to 5.54.0 in /ui (#1393)
add cf85c2aa6 Remove obsolete features from data explorer module (#1385) (#1386)
add 67d727919 Bump swagger-ui from 4.16.1 to 4.17.1 in /ui (#1396)
add c830543a2 Bump mypy from 1.0.0 to 1.1.1 in /streampipes-client-python (#1395)
add ea5e9acbf Bump swagger-ui from 4.17.1 to 4.18.0 in /ui
add f50510727 1391 data explorer filter doesnt work for boolean and false value (#1399)
add c530d55bb [#1375] add versioning to python docs (#1397)
add 25bf66f6a #1261 Modified release.yml file to include Python changes to release notes (#1404)
add 7fe524e47 Add support for the Kafka broker in Python (#1363)
add 5b6529efc docs: add matomo tracking to python docs (#1409)
add 1e5fb25b5 [hotfix] refine changelog structure
add 60d3f8153 [hotfix] always set alias for python docs
add bd3e014ab [hotfix] overwrite alias for python docs
add 73819a0cf [hotfix] provide latest as default in python docs
add 420336fb0 miscellaneous improvements for Python docs (#1410)
add 1521545f5 Search For Python DOC (#1408)
add 74a816d23 Bump mkdocs-jupyter from 0.22.0 to 0.23.0 in /streampipes-client-python (#1413)
add ee51abb2e [doc](readme)Enhancement in some Hyperlinks. (#1415)
add 3ee724c9d Bump mkdocs-material from 9.0.8 to 9.1.3 in /streampipes-client-python (#1416)
add 157417eee Bump webpack from 5.75.0 to 5.76.0 in /ui (#1418)
add 622261a44 Bump cypress from 12.6.0 to 12.8.1 in /ui (#1420)
add ad8c8de2f Bump @typescript-eslint/eslint-plugin from 5.53.0 to 5.55.0 in /ui (#1421)
add 25f40ce89 Bump mkdocs-jupyter from 0.23.0 to 0.24.0 in /streampipes-client-python (#1429)
add ed5b074e0 Bump pre-commit from 3.1.0 to 3.2.0 in /streampipes-client-python (#1431)
add 67727505f Bump lint-staged from 13.1.0 to 13.2.0 in /ui (#1430)
add 09327f56b docs: spring cleaning for Python docs (#1419)
add f9c0c67da Maintain the same directory structure for source and test (#1428)
add c7c1a301b Migrate StringCounter processing elements (#1427)
add d8583b155 1423 update archetypes (#1425)
add 7a0650810 Bump @angular-eslint/builder from 15.1.0 to 15.2.1 in /ui (#1432)
add a42fe29c7 update archetypes template (#1433)
add 94716b87e Bump eslint-config-prettier from 8.6.0 to 8.8.0 in /ui (#1437)
add cd38a4bde fix repeated past data (#1440)
add 586666ca4 Bump eslint from 8.35.0 to 8.36.0 in /ui
add d9dea34bc Bump json-smart from 2.4.8 to 2.4.9
add 7cc4e0209 Improve Log info in Processor Test (#1445)
add 83b50d6b0 Migrate StringToState processing elements (#1444)
add a99f0cd44 Migrate StringTimer processing elements (#1453)
add 435171490 Python docs with dark mode (#1454)
add ce1d95f6e [#1113] Added buttons to start and stop all adapters (#1441)
add de73be881 [hotfix] Add test for DataLakeQueryBuilder (#1459)
add 5000139e0 Bump error_prone_annotations from 2.2.0 to 2.18.0 (#1403)
add 3ca5f9b21 Bump @typescript-eslint/parser from 5.54.0 to 5.56.0 in /ui
add 792f2d108 Bump eslint from 8.36.0 to 8.37.0 in /ui
add c8fd621db Bump kafka.version from 3.3.1 to 3.4.0
add 45b27818e Bump black from 23.1.0 to 23.3.0 in /streampipes-client-python
add 004422938 Bump boofcv-core from 0.33 to 0.42
add 4f74f9428 [hotfix] Remove duplicate declaration of snakeyaml dependency version
add c307a7bd2 [hotfix] Temporarily revert to snakeyaml 1.33
add c33607da7 [hotfix] Fix configuration for pipeline element development (#1465)
add 89d183d9c Merge branch 'dev' of github.com:apache/streampipes into dev
add 8503549cf Implement create method in Java PipelineApi (#1467)
add dac406332 Bump activemq-client from 5.17.3 to 5.18.0
add 51db2ee3f Bump spring-core from 6.0.3 to 6.0.7
add a201c5c05 Bump spring boot version
add a771e9f1b Bump Guava version, Bump spring-security version
add adc1d62af Add properties-migrator to dependency management
add c18643663 Improve data explorer query management (#1406) (#1407)
add eb4b9cbc2 Migrate KafkaPublisher (#1473)
add c627add09 Bump jasmine-core from 4.5.0 to 4.6.0 in /ui (#1474)
add 49c2f53b2 Bump @typescript-eslint/eslint-plugin from 5.55.0 to 5.57.1 in /ui
add fa69191b5 Provide database name in query object (#1479)
add cdcd83ea2 [#1289] Fix cypress test for data lake configuration (#1480)
add 1dcc11b5b [hotfix] Improve handling of count queries, improve table widget (#1484)
add 07494bf59 Bump mkdocstrings[python] in /streampipes-client-python (#1487)
add 50ddf52e4 [SP-1367] fix typo
add b0d235fb2 Bump mypy from 1.1.1 to 1.2.0 in /streampipes-client-python (#1494)
add 3e5e57a62 Refactor method name in Kafka messaging layer (#1490)
add 94fceac13 [#1353] Implement Basic derived polygon processor
add 3dd73e30e [#1353] finish polygon processor, adjust documentation and variables
add 79c571b37 [#1353] fix double processor entry in init
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (2c859999b)
\
N -- N -- N refs/heads/1353-geo-create-derived-polygon-of-input-geometry-processor (79c571b37)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/release.yml | 20 +-
.github/workflows/pypi-deployment.yml | 21 +-
.github/workflows/python-docs.yml | 13 +-
README.md | 4 +-
.../src/main/resources/archetype-resources/pom.xml | 12 +-
.../archetype-resources/src/main/java/Init.java | 36 +-
.../__classNamePrefix__DataProcessor.java | 39 +-
.../__classNamePrefix__DataSink.java | 25 +-
.../src/main/resources/archetype-resources/pom.xml | 61 +-
.../archetype-resources/src/main/java/Init.java | 10 +-
.../__classNamePrefix__Controller.java | 2 +-
.../__classNamePrefix__Program.java | 2 +-
.../src/main/resources/archetype-resources/pom.xml | 56 +-
.../archetype-resources/src/main/java/Init.java | 52 +-
.../src/main/java/config/Config.java | 76 -
.../src/main/java/config/ConfigKeys.java | 15 +-
.../__classNamePrefix__Controller.java | 11 +-
.../__classNamePrefix__Program.java | 23 +-
installer/cli/environments/pipeline-element | 2 -
installer/cli/environments/pipeline-element-nats | 2 -
pom.xml | 30 +-
streampipes-client-python/.pre-commit-config.yaml | 2 +-
streampipes-client-python/README.md | 14 +-
.../docs/getting-started/developing.md | 18 +-
.../docs/getting-started/first-steps.md | 28 +-
.../docs/getting-started/quickstart.md | 59 +-
.../docs/img/streampipes-python-dark.png | Bin 0 -> 116009 bytes
streampipes-client-python/docs/index.md | 26 +-
.../partials/integrations/analytics/matomo.html | 36 +
...introduction-to-streampipes-python-client.ipynb | 34 +-
...cting-data-from-the-streampipes-data-lake.ipynb | 17 +-
...ive-data-from-the-streampipes-data-stream.ipynb | 27 +-
...ine-learning-on-a-streampipes-data-stream.ipynb | 6 +-
streampipes-client-python/mkdocs.yml | 62 +-
streampipes-client-python/setup.py | 25 +-
.../streampipes/client/client.py | 90 +-
.../streampipes/client/config.py | 10 +-
.../streampipes/client/credential_provider.py | 17 +-
.../streampipes/endpoint/api/data_lake_measure.py | 102 +-
.../streampipes/endpoint/api/data_stream.py | 45 +-
.../streampipes/endpoint/endpoint.py | 48 +-
.../streampipes/function_zoo/river_function.py | 43 +-
.../streampipes/functions/broker/__init__.py | 2 +
.../streampipes/functions/broker/broker.py | 21 +-
.../streampipes/functions/broker/broker_handler.py | 23 +-
.../broker/{nats_broker.py => kafka_broker.py} | 34 +-
.../{__init__.py => kafka_message_fetcher.py} | 41 +-
.../streampipes/functions/broker/nats_broker.py | 10 +-
.../functions/broker/output_collector.py | 28 +-
.../streampipes/functions/function_handler.py | 16 +-
.../streampipes/functions/registration.py | 17 +-
.../streampipes/functions/streampipes_function.py | 19 +-
.../functions/utils/async_iter_handler.py | 23 +-
.../functions/utils/data_stream_context.py | 4 +-
.../functions/utils/data_stream_generator.py | 21 +-
.../functions/utils/function_context.py | 9 +-
.../streampipes/model/common.py | 27 +-
.../model/container/data_lake_measures.py | 9 +-
.../streampipes/model/container/data_streams.py | 9 +-
.../model/container/resource_container.py | 17 +-
.../model/resource/data_lake_measure.py | 14 +-
.../streampipes/model/resource/data_lake_series.py | 12 +-
.../streampipes/model/resource/data_stream.py | 7 +-
.../model/resource/function_definition.py | 79 +-
.../streampipes/model/resource/resource.py | 11 +-
.../apache/streampipes/client/api/PipelineApi.java | 5 +-
.../apache/streampipes/commons/constants/Envs.java | 2 +
.../commons/environment/DefaultEnvironment.java | 5 +
.../commons/environment/Environment.java | 2 +
.../streampipes/config/backend/BackendConfig.java | 15 +-
.../commons/configs/CouchDbConfigurations.java | 35 -
.../commons/configs/CouchDbEnvKeys.java | 25 -
.../configs/DataExplorerConfigurations.java | 46 -
.../commons/configs/DataExplorerEnvKeys.java | 28 -
.../dataexplorer/DataExplorerQueryManagement.java | 142 ++
...ntV3.java => DataExplorerSchemaManagement.java} | 93 +-
.../dataexplorer/DataLakeManagementV4.java | 296 ---
.../api/IDataExplorerQueryManagement.java | 47 +
.../api/IDataExplorerSchemaManagement.java} | 24 +-
.../{model/Order.java => api/IQueryStatement.java} | 16 +-
.../influx/DataExplorerInfluxQueryExecutor.java | 169 ++
.../DataLakeInfluxQueryBuilder.java} | 138 +-
...licyQueryParams.java => DeleteQueryParams.java} | 40 +-
.../param/ProvidedRestQueryParamConverter.java | 147 ++
.../ProvidedRestQueryParams.java} | 12 +-
.../dataexplorer/param/QueryParams.java | 36 -
.../dataexplorer/param/SelectQueryParams.java | 140 ++
.../SupportedRestQueryParams.java} | 4 +-
.../model/AggregationFunction.java} | 8 +-
.../model/FillClauseParams.java} | 20 +-
.../model/GroupByTagsClauseParams.java} | 24 +-
.../model/GroupByTimeClauseParams.java} | 19 +-
.../model/LimitClauseParams.java} | 19 +-
.../model/OffsetClauseParams.java} | 19 +-
.../model/OrderByClauseParams.java} | 20 +-
.../model/SelectClauseParams.java} | 73 +-
.../{v4/params => param/model}/SelectColumn.java | 58 +-
.../param/model/WhereClauseParams.java | 122 +
.../{v4 => query}/AutoAggregationHandler.java | 69 +-
.../dataexplorer/query/DataExplorerQuery.java | 94 -
.../query/DataExplorerQueryBuilder.java | 61 -
.../query/DataExplorerQueryExecutor.java | 106 +
.../dataexplorer/query/DeleteDataQuery.java | 28 +-
.../query/EditRetentionPolicyQuery.java | 77 -
.../query/ParameterizedDataExplorerQuery.java | 28 -
.../{v4 => }/query/QueryResultProvider.java | 28 +-
.../query/ShowRetentionPolicyQuery.java | 58 -
.../query/StreamedQueryResultProvider.java | 18 +-
.../query/writer/ConfiguredCsvOutputWriter.java | 10 +-
.../query/writer/ConfiguredJsonOutputWriter.java | 10 +-
.../query/writer/ConfiguredOutputWriter.java | 8 +-
.../{v4 => }/query/writer/OutputFormat.java | 2 +-
.../{v4 => }/query/writer/item/CsvItemWriter.java | 2 +-
.../{v4 => }/query/writer/item/ItemGenerator.java | 4 +-
.../{v4 => }/query/writer/item/JsonItemWriter.java | 2 +-
.../DataLakeQueryOrdering.java | 2 +-
.../FilterCondition.java} | 24 +-
.../querybuilder/IDataLakeQueryBuilder.java | 84 +
.../dataexplorer/sdk/IDataLakeQueryBuilder.java | 74 -
.../dataexplorer/template/QueryTemplates.java | 40 -
.../dataexplorer/{v4 => }/utils/TimeParser.java | 2 +-
.../v4/params/DeleteFromStatementParams.java | 31 -
.../dataexplorer/v4/params/FillParams.java | 35 -
.../dataexplorer/v4/params/QueryParamsV4.java | 32 -
.../dataexplorer/v4/params/TimeBoundaryParams.java | 43 -
.../v4/params/WhereStatementParams.java | 119 -
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 234 --
.../dataexplorer/v4/query/QueryBuilder.java | 64 -
.../v4/query/elements/DeleteFromStatement.java | 33 -
.../v4/query/elements/FillStatement.java | 32 -
.../v4/query/elements/GroupingByTags.java | 43 -
.../v4/query/elements/GroupingByTime.java | 34 -
.../v4/query/elements/ItemLimitation.java | 34 -
.../v4/query/elements/OrderingByTime.java | 34 -
.../v4/query/elements/QueryElement.java | 35 -
.../v4/query/elements/SelectFromStatement.java | 51 -
.../v4/query/elements/TimeBoundary.java | 40 -
.../v4/query/elements/WhereStatement.java | 39 -
.../dataexplorer/v4/template/QueryTemplatesV4.java | 89 -
.../v4/utils/DataLakeManagementUtils.java | 163 --
.../dataexplorer/param/SelectQueryParamsTest.java | 208 ++
.../param}/WhereStatementParamsTest.java | 27 +-
.../writer/TestConfiguredCsvOutputWriter.java | 7 +-
.../writer/TestConfiguredJsonOutputWriter.java | 7 +-
.../query/writer/TestConfiguredOutputWriter.java | 2 +-
.../query/writer/item/TestCsvItemWriter.java | 4 +-
.../query/writer/item/TestItemWriter.java | 2 +-
.../query/writer/item/TestJsonItemWriter.java | 4 +-
.../sdk/DataLakeQueryBuilderTest.java} | 26 +-
.../utils/ProvidedQueryParameterBuilder.java | 92 +
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../streampipes-connect-adapters/pom.xml | 4 -
.../pom.xml | 6 +
.../transformation/jvm/TransformationJvmInit.java | 20 +-
.../booloperator/counter/BooleanCounter.java | 92 -
.../counter/BooleanCounterController.java | 88 -
.../counter/BooleanCounterParameters.java | 48 -
.../counter/BooleanCounterProcessor.java | 140 ++
.../booloperator/inverter/BooleanInverter.java | 54 -
.../inverter/BooleanInverterParameters.java | 35 -
...ntroller.java => BooleanInverterProcessor.java} | 40 +-
.../stringoperator/counter/StringCounter.java | 79 -
.../counter/StringCounterParameters.java | 36 -
...Controller.java => StringCounterProcessor.java} | 201 +-
.../stringoperator/state/StringToState.java | 59 -
.../state/StringToStateParameters.java | 42 -
...Controller.java => StringToStateProcessor.java} | 172 +-
.../stringoperator/timer/StringTimer.java | 79 -
.../timer/StringTimerParameters.java | 48 -
...erController.java => StringTimerProcessor.java} | 252 +-
.../counter/TestBooleanCounterProcessor.java | 177 ++
.../inverter/TestBooleanInverterProcessor.java | 159 ++
.../counter/TestStringCounterProcessor.java | 182 ++
.../state/TestStringToStateProcessor.java | 207 ++
.../timer/TestStringTimerProcessor.java | 213 ++
.../sinks/brokers/jvm/BrokersJvmInit.java | 4 +-
.../sinks/brokers/jvm/kafka/KafkaController.java | 91 -
.../sinks/brokers/jvm/kafka/KafkaParameters.java | 56 +-
.../sinks/brokers/jvm/kafka/KafkaPublishSink.java | 118 +
.../sinks/brokers/jvm/kafka/KafkaPublisher.java | 86 -
.../sinks/internal/jvm/SinksInternalJvmInit.java | 4 -
.../messaging/kafka/SpKafkaProducer.java | 4 +-
.../streampipes/ps/DataLakeMeasureResourceV3.java | 57 -
.../streampipes/ps/DataLakeMeasureResourceV4.java | 23 +-
.../apache/streampipes/ps/DataLakeResourceV4.java | 100 +-
.../apache/streampipes/rest/ResetManagement.java | 14 +-
streampipes-service-base/pom.xml | 4 +
streampipes-service-core/pom.xml | 1 -
.../service/core/StreamPipesResourceConfig.java | 2 -
ui/cypress/support/utils/PrepareTestDataUtils.ts | 8 +-
ui/cypress/support/utils/connect/ConnectBtns.ts | 8 +
ui/cypress/support/utils/connect/ConnectUtils.ts | 9 +
.../tests/adapter/allAdapterActions.smoke.spec.ts | 40 +
.../tests/datalake/configuration.smoke.spec.ts | 7 +-
ui/package-lock.json | 2561 ++++++++++++++++----
ui/package.json | 20 +-
.../existing-adapters.component.html | 28 +-
.../existing-adapters.component.ts | 34 +
ui/src/app/connect/connect.module.ts | 2 +
.../all-adapter-actions-dialog.component.html | 81 +
.../all-adapter-actions-dialog.component.scss} | 0
.../all-adapter-actions-dialog.component.ts | 120 +
.../dashboard/components/widgets/raw/raw-config.ts | 1 -
.../data-explorer-dashboard-widget.component.ts | 4 +-
.../base/base-data-explorer-widget.directive.ts | 6 +-
.../widgets/table/table-widget.component.html | 11 +-
.../widgets/table/table-widget.component.ts | 36 +-
.../time-series-chart-widget.component.ts | 202 +-
208 files changed, 7026 insertions(+), 5071 deletions(-)
delete mode 100644 archetypes/streampipes-archetype-pe-sinks-flink/src/main/resources/archetype-resources/src/main/java/config/Config.java
create mode 100644 streampipes-client-python/docs/img/streampipes-python-dark.png
create mode 100644 streampipes-client-python/docs/overrides/partials/integrations/analytics/matomo.html
rename streampipes-client-python/docs/{examples => tutorials}/1-introduction-to-streampipes-python-client.ipynb (90%)
rename streampipes-client-python/docs/{examples => tutorials}/2-extracting-data-from-the-streampipes-data-lake.ipynb (99%)
rename streampipes-client-python/docs/{examples => tutorials}/3-getting-live-data-from-the-streampipes-data-stream.ipynb (98%)
rename streampipes-client-python/docs/{examples => tutorials}/4-using-online-machine-learning-on-a-streampipes-data-stream.ipynb (94%)
copy streampipes-client-python/streampipes/functions/broker/{nats_broker.py => kafka_broker.py} (70%)
copy streampipes-client-python/streampipes/functions/broker/{__init__.py => kafka_message_fetcher.py} (53%)
delete mode 100644 streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/CouchDbConfigurations.java
delete mode 100644 streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/CouchDbEnvKeys.java
delete mode 100644 streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/DataExplorerConfigurations.java
delete mode 100644 streampipes-data-explorer-commons/src/main/java/org/apache/streampipes/dataexplorer/commons/configs/DataExplorerEnvKeys.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/DataExplorerQueryManagement.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{DataLakeNoUserManagementV3.java => DataExplorerSchemaManagement.java} (54%)
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/DataLakeManagementV4.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/api/IDataExplorerQueryManagement.java
copy streampipes-data-explorer/src/{test/java/org/apache/streampipesdataexplorer/v4/query/writer/item/TestItemWriter.java => main/java/org/apache/streampipes/dataexplorer/api/IDataExplorerSchemaManagement.java} (64%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{model/Order.java => api/IQueryStatement.java} (78%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/influx/DataExplorerInfluxQueryExecutor.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{sdk/DataLakeQueryBuilder.java => influx/DataLakeInfluxQueryBuilder.java} (55%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/{RetentionPolicyQueryParams.java => DeleteQueryParams.java} (52%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/ProvidedRestQueryParamConverter.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/ProvidedQueryParams.java => param/ProvidedRestQueryParams.java} (86%)
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/QueryParams.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/SelectQueryParams.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/SupportedDataLakeQueryParameters.java => param/SupportedRestQueryParams.java} (96%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/ColumnFunction.java => param/model/AggregationFunction.java} (86%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/query/elements/Offset.java => param/model/FillClauseParams.java} (62%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/GroupingByTagsParams.java => param/model/GroupByTagsClauseParams.java} (56%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/GroupingByTimeParams.java => param/model/GroupByTimeClauseParams.java} (61%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/ItemLimitationParams.java => param/model/LimitClauseParams.java} (64%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/OffsetParams.java => param/model/OffsetClauseParams.java} (64%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/OrderingByTimeParams.java => param/model/OrderByClauseParams.java} (58%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/SelectFromStatementParams.java => param/model/SelectClauseParams.java} (50%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params => param/model}/SelectColumn.java (53%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/param/model/WhereClauseParams.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => query}/AutoAggregationHandler.java (64%)
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQueryBuilder.java
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQueryExecutor.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/EditRetentionPolicyQuery.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ParameterizedDataExplorerQuery.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/QueryResultProvider.java (61%)
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/ShowRetentionPolicyQuery.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/StreamedQueryResultProvider.java (84%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/ConfiguredCsvOutputWriter.java (86%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/ConfiguredJsonOutputWriter.java (85%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/ConfiguredOutputWriter.java (89%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/OutputFormat.java (95%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/item/CsvItemWriter.java (94%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/item/ItemGenerator.java (92%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/writer/item/JsonItemWriter.java (95%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{sdk => querybuilder}/DataLakeQueryOrdering.java (93%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/WhereCondition.java => querybuilder/FilterCondition.java} (70%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/querybuilder/IDataLakeQueryBuilder.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/IDataLakeQueryBuilder.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/template/QueryTemplates.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/utils/TimeParser.java (97%)
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/DeleteFromStatementParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/FillParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/QueryParamsV4.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/TimeBoundaryParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/params/WhereStatementParams.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/DataExplorerQueryV4.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/QueryBuilder.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/DeleteFromStatement.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/FillStatement.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/GroupingByTags.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/GroupingByTime.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/ItemLimitation.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/OrderingByTime.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/QueryElement.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/SelectFromStatement.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/TimeBoundary.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/query/elements/WhereStatement.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/template/QueryTemplatesV4.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/v4/utils/DataLakeManagementUtils.java
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/param/SelectQueryParamsTest.java
rename {streampipes-rest/src/test/java/org/apache/streampipes/dataexplorer/v4/params => streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/param}/WhereStatementParamsTest.java (53%)
rename streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4 => streampipes/dataexplorer}/query/writer/TestConfiguredCsvOutputWriter.java (85%)
rename streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4 => streampipes/dataexplorer}/query/writer/TestConfiguredJsonOutputWriter.java (85%)
rename streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4 => streampipes/dataexplorer}/query/writer/TestConfiguredOutputWriter.java (95%)
rename streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4 => streampipes/dataexplorer}/query/writer/item/TestCsvItemWriter.java (91%)
rename streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4 => streampipes/dataexplorer}/query/writer/item/TestItemWriter.java (94%)
rename streampipes-data-explorer/src/test/java/org/apache/{streampipesdataexplorer/v4 => streampipes/dataexplorer}/query/writer/item/TestJsonItemWriter.java (89%)
rename streampipes-data-explorer/src/{main/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryConstants.java => test/java/org/apache/streampipes/dataexplorer/sdk/DataLakeQueryBuilderTest.java} (59%)
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/utils/ProvidedQueryParameterBuilder.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterController.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterParameters.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/BooleanCounterProcessor.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/BooleanInverterParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/{BooleanInverterController.java => BooleanInverterProcessor.java} (62%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounter.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/StringCounterParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/{StringCounterController.java => StringCounterProcessor.java} (57%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToState.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/StringToStateParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/{StringToStateController.java => StringToStateProcessor.java} (61%)
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimer.java
delete mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/StringTimerParameters.java
rename streampipes-extensions/streampipes-processors-transformation-jvm/src/main/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/{StringTimerController.java => StringTimerProcessor.java} (55%)
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/counter/TestBooleanCounterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/booloperator/inverter/TestBooleanInverterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/counter/TestStringCounterProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/state/TestStringToStateProcessor.java
create mode 100644 streampipes-extensions/streampipes-processors-transformation-jvm/src/test/java/org/apache/streampipes/processors/transformation/jvm/processor/stringoperator/timer/TestStringTimerProcessor.java
delete mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka/KafkaController.java
create mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka/KafkaPublishSink.java
delete mode 100644 streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/kafka/KafkaPublisher.java
delete mode 100644 streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeMeasureResourceV3.java
create mode 100644 ui/cypress/tests/adapter/allAdapterActions.smoke.spec.ts
create mode 100644 ui/src/app/connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.html
copy ui/src/app/{add/dialogs/add-endpoint/add-endpoint.component.scss => connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.scss} (100%)
create mode 100644 ui/src/app/connect/dialog/start-all-adapters/all-adapter-actions-dialog.component.ts