This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch 1406-cleanup-data-explorer-query-management
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 7a8edc1b1 Fix checkstyle issue (#1406)
add 403fdb2cd Refactor data explorer module (#1406)
No new revisions were added by this update.
Summary of changes:
.../dataexplorer/DataExplorerQueryManagement.java | 24 +--
.../api/IDataExplorerQueryManagement.java | 8 +-
.../IQueryStatement.java} | 14 +-
.../influx/DataExplorerInfluxQueryExecutor.java | 149 +++++++++++++
.../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} | 21 +-
.../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 | 35 +--
.../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 +-
.../DataLakeQueryConstants.java | 2 +-
.../DataLakeQueryOrdering.java | 2 +-
.../FilterCondition.java} | 24 +--
.../querybuilder/IDataLakeQueryBuilder.java | 84 ++++++++
.../dataexplorer/sdk/IDataLakeQueryBuilder.java | 74 -------
.../dataexplorer/{v4 => }/utils/TimeParser.java | 2 +-
.../v4/params/DeleteFromStatementParams.java | 31 ---
.../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/FillStatement.java | 32 ---
.../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/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 | 63 ------
.../v4/utils/DataLakeManagementUtils.java | 163 --------------
.../dataexplorer/param/SelectQueryParamsTest.java | 203 ++++++++++++++++++
.../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 +-
.../utils/ProvidedQueryParameterBuilder.java | 92 ++++++++
.../apache/streampipes/ps/DataLakeResourceV4.java | 50 ++---
64 files changed, 1444 insertions(+), 1508 deletions(-)
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/params/FillParams.java
=> param/model/FillClauseParams.java} (63%)
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 (77%)
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}/DataLakeQueryConstants.java (94%)
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
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/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/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/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%)
create mode 100644
streampipes-data-explorer/src/test/java/org/apache/streampipes/dataexplorer/utils/ProvidedQueryParameterBuilder.java
