You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2023/04/06 15:24:37 UTC
[streampipes] 01/02: Merge branch 'dev' into SP-1367
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch SP-1367
in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 3603a27e3674f9414495c7e6682c69e4c47f708a
Merge: 4c282c8d1 07494bf59
Author: Philipp Zehnder <te...@users.noreply.github.com>
AuthorDate: Thu Apr 6 16:06:02 2023 +0200
Merge branch 'dev' into SP-1367
installer/cli/environments/pipeline-element | 2 -
installer/cli/environments/pipeline-element-nats | 2 -
pom.xml | 28 +-
streampipes-client-python/setup.py | 4 +-
.../apache/streampipes/client/api/PipelineApi.java | 5 +-
.../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 | 245 ---------------
.../api/IDataExplorerQueryManagement.java | 47 +++
.../IDataExplorerSchemaManagement.java} | 25 +-
.../IQueryStatement.java} | 14 +-
.../influx/DataExplorerInfluxQueryExecutor.java | 169 +++++++++++
.../DataLakeInfluxQueryBuilder.java} | 138 +++++----
.../DeleteQueryParams.java} | 45 ++-
.../param/ProvidedRestQueryParamConverter.java | 147 +++++++++
.../ProvidedRestQueryParams.java} | 12 +-
.../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 | 53 ++--
.../query/DataExplorerQueryExecutor.java | 106 +++++++
.../{v4 => }/query/QueryResultProvider.java | 28 +-
.../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/DataLakeQueryConstants.java | 30 --
.../dataexplorer/sdk/IDataLakeQueryBuilder.java | 74 -----
.../dataexplorer/{v4 => }/utils/TimeParser.java | 2 +-
.../v4/params/DeleteFromStatementParams.java | 31 --
.../dataexplorer/v4/params/FillParams.java | 35 ---
.../v4/params/WhereStatementParams.java | 122 --------
.../dataexplorer/v4/query/DataExplorerQueryV4.java | 234 --------------
.../dataexplorer/v4/query/QueryBuilder.java | 64 ----
.../v4/query/elements/DeleteFromStatement.java | 33 --
.../v4/query/elements/GroupingByTags.java | 43 ---
.../v4/query/elements/GroupingByTime.java | 34 ---
.../v4/query/elements/ItemLimitation.java | 34 ---
.../dataexplorer/v4/query/elements/Offset.java | 34 ---
.../v4/query/elements/OrderingByTime.java | 34 ---
.../v4/query/elements/SelectFromStatement.java | 51 ----
.../v4/query/elements/TimeBoundary.java | 40 ---
.../v4/query/elements/WhereStatement.java | 39 ---
.../dataexplorer/v4/template/QueryTemplatesV4.java | 63 ----
.../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 +-
.../dataexplorer/sdk/DataLakeQueryBuilderTest.java | 6 +-
.../utils/ProvidedQueryParameterBuilder.java | 92 ++++++
.../streampipes-connect-adapters-iiot/pom.xml | 4 -
.../streampipes-connect-adapters/pom.xml | 4 -
.../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 | 130 ++++++++
.../sinks/brokers/jvm/kafka/KafkaPublisher.java | 86 ------
.../sinks/internal/jvm/SinksInternalJvmInit.java | 4 -
.../streampipes/ps/DataLakeMeasureResourceV3.java | 57 ----
.../streampipes/ps/DataLakeMeasureResourceV4.java | 23 +-
.../apache/streampipes/ps/DataLakeResourceV4.java | 70 +++--
.../apache/streampipes/rest/ResetManagement.java | 14 +-
streampipes-service-core/pom.xml | 1 -
.../service/core/StreamPipesResourceConfig.java | 2 -
ui/cypress/support/utils/PrepareTestDataUtils.ts | 8 +-
.../tests/datalake/configuration.smoke.spec.ts | 7 +-
ui/package-lock.json | 335 +++++++++++----------
ui/package.json | 8 +-
.../widgets/table/table-widget.component.html | 1 +
94 files changed, 2160 insertions(+), 2395 deletions(-)