You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2023/04/09 13:17:16 UTC
[iotdb] branch lmh/FixIntoMem updated (e2901f458d -> 0227b20370)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/FixIntoMem
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e2901f458d add UTs
add 661430f00c Update Jenkinsfile for nightly build
add 69f2693995 Fix Context release source NPE
add e6f0355d45 docker deploy for v1.1.0, update docs and docker-compose files (#9528)
add 6a146449fc [IOTDB-5466] Refactor RaftLog disk monitor to avoid unnecessary snapshots (#9515)
add d7d493e5c2 [IOTDB-5757] Fix Not Supported Exception when use like 's3 || false' in where even Type of s3 is Boolean
add 7787399aa2 [IOTDB-5756] NPE when where predicate is NotEqualExpression and one of subExpression is not exist
add 2b77bd4fcd Fix mlnode CI error (#9552)
add 33843b6e2a [IOTDB-5742][UserGuide]Modify the output type of the mode function in userguide
add 6bec16ff55 [IOTDB-5204 ] Add last task rather than first task to timeoutQueue
add ad04cbaaf0 [IOTDB-5638] Support CASE WHEN expression
add c6fad19e9d [IOTDB-5761] Open channel of ShuffleSinkHandle after the drivertask begins
add aa00056ec0 Adapt insert data by 0.13 client (#9557)
add e6ec5fcd14 [IOTDB-5760] Query is blocked because of no memory
add 947dc773ef Bump httpcore from 4.4.15 to 4.4.16 (#9498)
add 0c0ae29a5c Fix NPE when abort fragment instance (#9560)
add 0227b20370 Merge remote-tracking branch 'upstream/master' into lmh/FixIntoMem
No new revisions were added by this update.
Summary of changes:
Jenkinsfile | 6 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 5 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 15 +
.../org/apache/iotdb/consensus/common/Utils.java | 32 -
.../iot/logdispatcher/IndexController.java | 2 +-
.../ratis/ApplicationStateMachineProxy.java | 1 +
.../iotdb/consensus/ratis/RatisConsensus.java | 35 +-
.../iotdb/consensus/ratis/ResponseMessage.java | 1 +
.../iotdb/consensus/ratis/SnapshotStorage.java | 1 +
.../ratis/metrics/IoTDBMetricRegistry.java | 2 +-
.../consensus/ratis/utils/RatisLogMonitor.java | 87 ++
.../iotdb/consensus/ratis/{ => utils}/Utils.java | 2 +-
.../iot/logdispatcher/IndexControllerTest.java | 2 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 1 +
.../apache/iotdb/consensus/ratis/UtilsTest.java | 1 +
.../DockerCompose/docker-compose-cluster-1c2d.yml | 6 +-
.../DockerCompose/docker-compose-host-3c3d.yml | 4 +-
.../DockerCompose/docker-compose-standalone.yml | 3 +-
docker/src/main/Dockerfile-1.0.0-datanode | 3 +-
docs/UserGuide/Operators-Functions/Aggregation.md | 30 +-
docs/UserGuide/Operators-Functions/Conditional.md | 351 +++++++++
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 13 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 9 +
.../UserGuide/Operators-Functions/Aggregation.md | 30 +-
.../UserGuide/Operators-Functions/Conditional.md | 347 ++++++++
docs/zh/UserGuide/Operators-Functions/Overview.md | 8 +
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 11 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 9 +
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 5 +
.../iotdb/db/it/query/IoTDBCaseWhenThenIT.java | 876 +++++++++++++++++++++
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 3 +
mlnode/requirements_dev.txt | 4 +-
.../resources/conf/iotdb-common.properties | 5 +
pom.xml | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../apache/iotdb/db/mpp/common/SessionInfo.java | 14 +
.../db/mpp/execution/driver/DriverContext.java | 18 +
.../iotdb/db/mpp/execution/driver/IDriver.java | 2 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 12 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 12 +-
.../fragment/FragmentInstanceContext.java | 19 +-
.../fragment/FragmentInstanceExecution.java | 5 +
.../operator/process/FilterAndProjectOperator.java | 22 +
.../operator/source/ExchangeOperator.java | 13 +
.../db/mpp/execution/schedule/DriverScheduler.java | 45 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 18 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 101 ++-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 49 ++
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 26 +
.../db/mpp/plan/execution/QueryExecution.java | 7 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 10 +
.../db/mpp/plan/expression/ExpressionFactory.java | 15 +
.../db/mpp/plan/expression/ExpressionType.java | 4 +
.../plan/expression/binary/BinaryExpression.java | 3 +-
.../WhenThenExpression.java} | 49 +-
.../expression/other/CaseWhenThenExpression.java | 172 ++++
.../visitor/CartesianProductVisitor.java | 27 +
.../plan/expression/visitor/CollectVisitor.java | 7 +
.../visitor/ColumnTransformerVisitor.java | 44 ++
.../visitor/ExpressionAnalyzeVisitor.java | 2 +-
.../plan/expression/visitor/ExpressionVisitor.java | 10 +
.../visitor/IntermediateLayerVisitor.java | 7 +
.../expression/visitor/ReconstructVisitor.java | 9 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 43 +
.../plan/planner/LocalExecutionPlanContext.java | 4 +
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 1 +
.../db/mpp/plan/planner/PipelineDriverFactory.java | 15 +-
.../dag/column/CaseWhenThenColumnTransformer.java | 132 ++++
.../binary/CompareNonEqualColumnTransformer.java | 2 +-
.../binary/LogicBinaryColumnTransformer.java | 4 +-
.../iotdb/db/query/control/SessionManager.java | 6 +-
.../execution/schedule/DriverSchedulerTest.java | 21 +-
.../other/CaseWhenThenExpressionTest.java | 73 ++
75 files changed, 2745 insertions(+), 214 deletions(-)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/utils/RatisLogMonitor.java
rename consensus/src/main/java/org/apache/iotdb/consensus/ratis/{ => utils}/Utils.java (99%)
create mode 100644 docs/UserGuide/Operators-Functions/Conditional.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Conditional.md
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBCaseWhenThenIT.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/{unary/LogicNotExpression.java => binary/WhenThenExpression.java} (57%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/other/CaseWhenThenExpression.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/CaseWhenThenColumnTransformer.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/expression/other/CaseWhenThenExpressionTest.java