You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/05/23 08:23:48 UTC
[iotdb] branch xingtanzjr/agg_distribution_plan updated (a45cef65fa -> 7892749e02)
This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/agg_distribution_plan
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a45cef65fa fix some issues
add a7a8e0aecd [IOTDB-3109]Fix wrong sender IP shown in receiver (#5950)
add 51e9703aa6 fix PartialPath deserialize by using PathDeserializeUtil (#5972)
add 4c13c078d2 [IOTDB-3072] add measurement syntax check in TSServiceImpl and DataNodeTSIServiceImpl (#5951)
add c053a2a766 [IOTDB-3069] unescape string in IoTDBSqlVisitor and ASTVisitor (#5952)
add c6c4ba398d [IOTDB-3244] Add PlanNodes related to last query (#5987)
add ec0ca1044d fixed grafana connector sql inject (#5990)
add b921f79749 add tokens in gitignore (#5971)
add 107dbda6a1 [IOTDB-3250] Reactor UDF related services for mpp cluster (#5981)
add efabe983c5 Merge branch 'master' into xingtanzjr/agg_distribution_plan
add 7892749e02 spotless
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 6 +-
.../resources/conf/iotdb-confignode.properties | 21 ++
.../iotdb/confignode/conf/ConfigNodeConf.java | 12 ++
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../confignode/conf/ConfigNodeDescriptor.java | 2 +
.../request/read/GetChildNodesPartitionReq.java | 3 +-
.../request/read/GetChildPathsPartitionReq.java | 3 +-
.../confignode/persistence/PartitionInfo.java | 6 +-
.../controller/DatabaseConnectController.java | 2 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 2 +-
.../iotdb/db/integration/IoTDBFuzzyQueryIT.java | 4 +-
.../IoTDBSyntaxConventionStringLiteralIT.java | 16 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 12 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 2 +-
.../session/IoTDBSessionSyntaxConventionIT.java | 237 +++++++++++++++++++++
.../org/apache/iotdb/commons/path/PartialPath.java | 7 +
.../commons/udf/api/exception/UDFException.java | 2 +-
.../api}/exception/UDFRegistrationException.java | 6 +-
.../udf/builtin/BuiltinAggregationFunction.java | 59 +++++
...va => BuiltinTimeSeriesGeneratingFunction.java} | 4 +-
.../iotdb/commons}/udf/service/UDFClassLoader.java | 4 +-
.../udf/service/UDFClassLoaderManager.java | 29 +--
.../iotdb/commons}/udf/service/UDFLogWriter.java | 2 +-
.../udf/service/UDFRegistrationInformation.java | 2 +-
.../udf/service/UDFRegistrationService.java | 90 ++++----
.../operator/process/TransformOperator.java | 4 +-
.../plan/expression/multi/FunctionExpression.java | 8 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 29 ++-
.../db/mpp/plan/planner/DistributionPlanner.java | 11 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 14 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 14 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 15 ++
.../{OffsetNode.java => LastQueryMergeNode.java} | 87 ++++----
.../plan/node/source/AlignedLastQueryScanNode.java | 171 +++++++++++++++
.../source/AlignedSeriesAggregationScanNode.java | 6 +-
.../plan/node/source/AlignedSeriesScanNode.java | 13 +-
.../plan/node/source/LastQueryScanNode.java | 173 +++++++++++++++
.../node/source/SeriesAggregationScanNode.java | 11 +-
.../planner/plan/node/source/SeriesScanNode.java | 13 +-
.../db/mpp/transformation/dag/udf/UDTFContext.java | 2 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 2 +-
.../transformation/dag/udf/UDTFTypeInferrer.java | 2 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 31 +--
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 32 ++-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 29 ++-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 16 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 16 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 63 ++++++
.../db/service/thrift/impl/TSServiceImpl.java | 82 ++++++-
.../db/sync/sender/service/TransportHandler.java | 33 ++-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 9 -
.../node/process/AggregationNodeSerdeTest.java | 6 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 10 +-
.../plan/plan/node/process/LimitNodeSerdeTest.java | 7 +-
.../plan/node/process/OffsetNodeSerdeTest.java | 7 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 7 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 10 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 6 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 7 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 2 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 5 +-
63 files changed, 1149 insertions(+), 343 deletions(-)
rename {server/src/main/java/org/apache/iotdb/db => node-commons/src/main/java/org/apache/iotdb/commons/udf/api}/exception/UDFRegistrationException.java (85%)
create mode 100644 node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/BuiltinAggregationFunction.java
rename node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/{BuiltinFunction.java => BuiltinTimeSeriesGeneratingFunction.java} (96%)
rename {server/src/main/java/org/apache/iotdb/db/query => node-commons/src/main/java/org/apache/iotdb/commons}/udf/service/UDFClassLoader.java (95%)
rename {server/src/main/java/org/apache/iotdb/db/query => node-commons/src/main/java/org/apache/iotdb/commons}/udf/service/UDFClassLoaderManager.java (85%)
rename {server/src/main/java/org/apache/iotdb/db/query => node-commons/src/main/java/org/apache/iotdb/commons}/udf/service/UDFLogWriter.java (97%)
rename {server/src/main/java/org/apache/iotdb/db/query => node-commons/src/main/java/org/apache/iotdb/commons}/udf/service/UDFRegistrationInformation.java (97%)
rename {server/src/main/java/org/apache/iotdb/db/query => node-commons/src/main/java/org/apache/iotdb/commons}/udf/service/UDFRegistrationService.java (84%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{OffsetNode.java => LastQueryMergeNode.java} (57%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/AlignedLastQueryScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/LastQueryScanNode.java