This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch query_plan_visualization
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 312a82b9c6 complete plan visualization
add 31e5893900 [IOTDB-3315] Make unset of ttl in cluster mode same as
0.13.0 version. (#6061)
add 23bb94e2e5 [IOTDB-3271] Wrong multi IP for one sender in receiver
(#6037)
add bb1a88540d [ISSUES-6057] Add a method(getAllDataRegionID) to
StorageEngineV2 (#6059)
add fcb27a8449 [IOTDB-3228] UDF Management in MPP Cluster: DROP FUNCTION
(#6064)
add 4f101d8acf [IOTDB-3246]Improve Validation tool (#6066)
add e1dfec58e3 [IOTDB-3320] Don't return data which are not satisfied with
time filter in last query (#6068)
add 88426aa3e3 [IOTDB-3319] fix IndexOutOfBoundsException when executing
linear fill in group by query (#6070)
add 8500eb9cd1 Fix aligned data in memory query bug (#6065)
add c84095d093 [IOTDB-3325] Thrown an exception when using group by in raw
data query (#6077)
add c01b1e1504 [IOTDB-3335] Redundant data recovered by wal in
multi-leader consensus (#6076)
add 7fcb1044e7 [IOTDB-3306] Use rpc port check to avoid starting same
IoTDB twice (#6069)
add 88adfbea69 [IOTDB-3229] Field is 0 rather than null when query two
series in one device (#6071)
add b343478a41 [IOTDB-3339] Fix index out of bound while doing raw query
(#6079)
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)
new f2521616cf Merge branch 'master' into query_plan_visualization
new 9d9c09f41d add more box printer for PlanNodes
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../confignode/client/AsyncDataNodeClientPool.java | 19 ++-
...Handler.java => FunctionManagementHandler.java} | 6 +-
.../consensus/request/ConfigRequest.java | 4 +
.../consensus/request/ConfigRequestType.java | 1 +
...eleteProcedureReq.java => DropFunctionReq.java} | 38 ++---
.../iotdb/confignode/manager/ConfigManager.java | 8 +
.../apache/iotdb/confignode/manager/Manager.java | 2 +
.../iotdb/confignode/manager/UDFManager.java | 59 +++++++-
.../iotdb/confignode/persistence/UDFInfo.java | 25 +++-
.../executor/ConfigRequestExecutor.java | 8 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../db/integration/sync/IoTDBSyncReceiverIT.java | 5 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../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 +-
.../service/AbstractThriftServiceThread.java | 38 +----
.../udf/service/UDFRegistrationService.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 17 +++
.../statemachine/visitor/DataExecutionVisitor.java | 17 +++
.../apache/iotdb/db/engine/StorageEngineV2.java | 11 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 7 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 87 ++++++++++-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../SmoothQueueSlidingWindowAggregator.java | 1 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 4 +-
.../execution/operator/process/FilterOperator.java | 80 +++++-----
.../operator/process/LinearFillOperator.java | 3 +-
.../operator/process/TransformOperator.java | 70 +++++----
.../operator/process/UpdateLastCacheOperator.java | 5 +
.../operator/process/merge/SingleColumnMerger.java | 4 +-
.../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 | 144 +++++++++---------
.../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 | 7 +
...eateFunctionTask.java => DropFunctionTask.java} | 38 ++---
.../execution/config/ShowStorageGroupTask.java | 7 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 5 +-
.../memory/StatementMemorySourceVisitor.java | 33 +++--
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 86 ++++++++++-
.../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 -----------
.../plan/planner/plan/node/PlanGraphPrinter.java | 109 ++++++++++++++
.../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 | 10 ++
.../DeleteDataStatement.java} | 49 ++++---
.../db/mpp/plan/statement/crud/QueryStatement.java | 4 +
...onStatement.java => DropFunctionStatement.java} | 21 +--
.../query/reader/chunk/MemAlignedPageReader.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 18 ++-
.../java/org/apache/iotdb/db/service/IoTDB.java | 9 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 56 +++++--
.../service/thrift/impl/InternalServiceImpl.java | 12 ++
.../db/sync/sender/service/TransportHandler.java | 5 +-
.../db/sync/transport/client/TransportClient.java | 21 +--
.../db/tools/validate/TsFileValidationTool.java | 13 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 15 +-
.../allocation/AbstractNodeAllocationStrategy.java | 9 ++
.../db/wal/allocation/FirstCreateStrategy.java | 4 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 4 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 40 +++--
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 1 -
.../apache/iotdb/db/wal/io/CheckpointReader.java | 22 ++-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 7 +-
.../db/wal/recover/CheckpointRecoverUtils.java | 32 +++-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 34 ++++-
.../iotdb/db/wal/utils/CheckpointFileUtils.java | 3 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 30 ++--
.../iotdb/db/engine/StorageEngineV2Test.java | 71 +++++++++
.../execution/operator/LinearFillOperatorTest.java | 113 ++++++++++++++-
...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 +--
.../db/sync/transport/TransportServiceTest.java | 8 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 2 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 6 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 12 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 14 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 +-
.../src/main/thrift/confignode.thrift | 8 +-
thrift/src/main/thrift/mpp.thrift | 11 ++
.../iotdb/tsfile/read/common/block/TsBlock.java | 3 +-
106 files changed, 1719 insertions(+), 795 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/{CreateFunctionHandler.java
=> FunctionManagementHandler.java} (89%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{DeleteProcedureReq.java
=> DropFunctionReq.java} (62%)
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/{CreateFunctionTask.java
=> DropFunctionTask.java} (69%)
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/{CreateFunctionStatement.java
=> DropFunctionStatement.java} (76%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/engine/StorageEngineV2Test.java
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
