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:47:37 UTC
[streampipes] branch dependabot/maven/org.codehaus.mojo-animal-sniffer-annotations-1.23 updated (e46c7ed6b -> fcb73fbdb)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch dependabot/maven/org.codehaus.mojo-animal-sniffer-annotations-1.23
in repository https://gitbox.apache.org/repos/asf/streampipes.git
discard e46c7ed6b Bump animal-sniffer-annotations from 1.22 to 1.23
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 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 b66c6dd93 Bump rdf4j.version from 3.5.0 to 4.2.3 (#1472)
add fcb73fbdb Bump animal-sniffer-annotations from 1.22 to 1.23
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 (e46c7ed6b)
\
N -- N -- N refs/heads/dependabot/maven/org.codehaus.mojo-animal-sniffer-annotations-1.23 (fcb73fbdb)
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:
pom.xml | 19 +-
streampipes-client-python/setup.py | 4 +-
.../streampipes/model/resource/data_lake_series.py | 2 +-
.../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 ++++++++
.../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 | 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 | 152 ++++++-------
ui/package.json | 4 +-
.../widgets/table/table-widget.component.html | 1 +
92 files changed, 2055 insertions(+), 2286 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/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 (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