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/03 20:20:59 UTC
[streampipes] branch remove-set-adapters updated (795acd574 -> 888d4b363)
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch remove-set-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 795acd574 [#1289] Fix minor bug
add c307a7bd2 [hotfix] Temporarily revert to snakeyaml 1.33
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 888d4b363 Merge branch 'dev' into remove-set-adapters
No new revisions were added by this update.
Summary of changes:
pom.xml | 17 +-
.../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 | 148 +++++++++++++
.../DataLakeInfluxQueryBuilder.java} | 138 +++++++-----
.../DeleteQueryParams.java} | 45 ++--
.../param/ProvidedRestQueryParamConverter.java | 147 +++++++++++++
.../ProvidedRestQueryParams.java} | 12 +-
.../dataexplorer/param/SelectQueryParams.java | 132 +++++++++++
.../SupportedRestQueryParams.java} | 4 +-
.../model/AggregationFunction.java} | 8 +-
.../model/FillClauseParams.java} | 20 +-
.../model/GroupByTagsClauseParams.java} | 24 +-
.../model/GroupByTimeClauseParams.java} | 19 +-
.../model/ItemClauseParams.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 | 105 +++++++++
.../{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 ++++++++
.../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/package-lock.json | 14 +-
ui/package.json | 2 +-
86 files changed, 1950 insertions(+), 2205 deletions(-)
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
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/query/elements/QueryElement.java => api/IDataExplorerSchemaManagement.java} (62%)
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4/params/QueryParamsV4.java => api/IQueryStatement.java} (76%)
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/{v4/params/TimeBoundaryParams.java => param/DeleteQueryParams.java} (50%)
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%)
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/FillStatement.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/ItemClauseParams.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 (68%)
create mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/query/DataExplorerQueryExecutor.java
rename streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/{v4 => }/query/QueryResultProvider.java (61%)
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/DataLakeQueryConstants.java
delete mode 100644 streampipes-data-explorer/src/main/java/org/apache/streampipes/dataexplorer/sdk/IDataLakeQueryBuilder.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/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/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/Offset.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/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%)
create mode 100644 streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/utils/ProvidedQueryParameterBuilder.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