This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch IOTDB-3348
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e6af88e001 [IOTDB-3348] Miss some data while using or value filter
add 39ad58c811 [IOTDB-3348] null cases
add 48256e44f3 [IOTDB-3341] Fix timeseries id is not right while doing
last query (#6082)
add 3918bf6992 [IOTDB-3346] Clear DriverTask when any RuntimeException is
thrown (#6086)
add d26fa83c5d Make DataNode start DataNodeTSIServiceImpl RPC service
(#6090)
add d9d2465f0d [IOTDB-3343] Aggregate existing and non-exsit timeseries
together failure in AlignByDevice (#6084)
add f0fd1f5b40 [IOTDB-3165] Implement delete data (#6072)
add 1a18def1fc [IOTDB-3065]show lastest timeseries (#6063)
add ecbea664df optimize. (#6073)
add b940a652dd [IOTDB-3316] Add 'SHOW CLUSTER' implementation for IoTDB
cluster mode (#6062)
add 9d420fd0f9 [IOTDB-3229] Apache IoTDB UDF Management in MPP Cluster:
SHOW FUNCTIONS (#6098)
add 0b98a8cd5c [IOTDB-3358] Fix error message of insert wrong type of data
by sql is meaningless (#6099)
add 96f4504e76 [IOTDB-3337] return error which insert wrong type of data
(#6089)
add 7cc235fe64 Merge branch 'master' of github.com:apache/iotdb into
iotdb-3348
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 7 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../executor/ConfigRequestExecutor.java | 5 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 20 +++
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 28 ++++
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../iotdb/commons/partition/DataPartition.java | 5 +-
.../commons/partition/DataPartitionQueryParam.java | 16 ++
.../apache/iotdb/commons/partition/Partition.java | 4 +
.../commons/partition/RegionReplicaSetInfo.java | 16 +-
.../iotdb/commons/partition/SchemaPartition.java | 5 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 +++
.../statemachine/visitor/DataExecutionVisitor.java | 19 ++-
.../apache/iotdb/db/engine/StorageEngineV2.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 97 ++++++++++++-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 40 +++++
.../operator/schema/SchemaQueryMergeOperator.java | 2 -
.../schema/SchemaQueryOrderByHeatOperator.java | 161 +++++++++++++++++++++
.../execution/schedule/AbstractDriverThread.java | 8 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 34 +++--
.../schedule/FragmentInstanceAbortedException.java | 1 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 154 +++++++++++---------
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 7 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 4 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 10 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 6 +
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 3 +
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 6 +
.../plan/execution/config/ConfigTaskVisitor.java | 14 ++
...tStorageGroupTask.java => ShowClusterTask.java} | 102 ++++++++-----
.../plan/execution/config/ShowFunctionsTask.java | 153 ++++++++++++++++++++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 92 ++++++++++++
.../db/mpp/plan/parser/StatementGenerator.java | 15 ++
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 23 ++-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 38 ++---
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 49 ++++---
.../planner/distribution/ExchangeNodeAdder.java | 37 +----
.../plan/planner/distribution/SourceRewriter.java | 85 -----------
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../node/metedata/read/SchemaQueryMergeNode.java | 4 +
...ntNode.java => SchemaQueryOrderByHeatNode.java} | 51 ++++---
.../metedata/read/TimeSeriesSchemaScanNode.java | 7 +
.../planner/plan/node/write/DeleteDataNode.java | 110 ++++++++++----
.../db/mpp/plan/statement/StatementVisitor.java | 15 ++
.../DeleteDataStatement.java} | 49 ++++---
...oupStatement.java => ShowClusterStatement.java} | 16 +-
...pStatement.java => ShowFunctionsStatement.java} | 14 +-
.../transformer/binary/LogicBinaryTransformer.java | 21 ++-
.../java/org/apache/iotdb/db/service/DataNode.java | 9 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 32 +++-
.../org/apache/iotdb/db/utils/CommonUtils.java | 30 +++-
.../db/engine/storagegroup/DataRegionTest.java | 12 +-
...erTest.java => DefaultDriverSchedulerTest.java} | 2 +-
.../execution/schedule/DriverSchedulerTest.java | 2 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 43 ++++++
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 6 +-
.../plan/distribution/DeleteTimeseriesTest.java | 71 ---------
.../plan/node/write/DeleteDataNodeSerdeTest.java | 21 +--
.../src/main/thrift/confignode.thrift | 10 ++
60 files changed, 1323 insertions(+), 508 deletions(-)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/SchemaQueryOrderByHeatOperator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/{CountStorageGroupTask.java
=> ShowClusterTask.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/ShowFunctionsTask.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{NodePathsCountNode.java
=> SchemaQueryOrderByHeatNode.java} (61%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/LastPointFetchStatement.java
=> crud/DeleteDataStatement.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CountStorageGroupStatement.java
=> ShowClusterStatement.java} (80%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{CountStorageGroupStatement.java
=> ShowFunctionsStatement.java} (81%)
rename
server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/{DefaultTaskSchedulerTest.java
=> DefaultDriverSchedulerTest.java} (99%)
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/DeleteTimeseriesTest.java
