This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/align_by_time_topk
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c157281aa6e aggregation + order based on time, use
MergeSortNode/TopKNode
add 04e23d1b692 add order by expression test
add 29c721a79cb add more it
add 4338d20edec add more test for AlignByTimeOrderByLimitOffsetTest
add 914ed16e14a Fix timeout doesn't take effect in schema fetch bug
(#11823)
add f920cdc8e86 Print Exception only when encountering unexpected TSStatus
(#11827)
add 9aedab88e12 PBTree: Fix deadlock when segment deleted (#11828)
add 9dece729fa9 Imporve some log printing of Storage engine (#11829)
add 34000269fa1 Pipe: reduce log when reporting pipe meta via heartbeat
(#11830)
add c29c46a4c60 feat(logback): change config (#11825)
add 8e9ef0aa4a9 PBTree: Prevent Concurrent Read With Stale Page (#11831)
add bcbe84ec51e Pipe: fix PipeDataRegionPluginAgent initialization order &
avoid instantiating meta source and sink (#11821)
add f42debd7e92 [IOTDB-6285] Alter Procedure timeout (#11836)
add 121c60b5936 Optimize log according to real scenarios after checking
(#11835)
add 05c7ed990c1 Add disk space log in cluster heartbeat (#11833)
add d0eed0ce738 Add error logs for NotEnoughDataNodeException and
DatabaseNotExistsException (#11832)
add 491246db1fc fix insert&delete cases dead data
add 7595a1a52bd Pipe: append logs generated by org.apache.iotdb.pipe.api.*
and org.apache.iotdb.commons.pipe.* into PIPE appender (#11845)
add 9fdeb95b6f6 Optimized wal file deletion algorithm (#11682)
add 42ea2cd3733 Fix aligned timeseries query error after delete some data
in memtable
add 712f4c4671a Return when leader election waiting is interrupted (#11842)
add 2f19b1a75e0 Reduce stack message of known compaction exceptions in log
(#11716)
add f077a18567f [IOTDB-6281] Enhance Procedure metrics (#11798)
add 4953d6fd3a0 fix the error of writing metrics (#11846)
add 01a0f6325e6 fix lose data when recover data dir onto a new iotdb
(#11848)
add a7f6d755482 Optimize InsertRecords performance by reducing record
metrics (#11723)
add 755c5d55e24 PBTree: fix deed lock in ReleaseFlushMonitor and Scheduler
(#11849)
add 463e23271c2 Revert "Optimized wal file deletion algorithm (#11682)"
(#11852)
add 20bdc070098 change ExitOnOutOfMemoryError to CrashOnOutOfMemoryError
add 31c65b3706b [IOTDB-6281] Enhance Procedure metrics (#11857)
add dae1fadc408 [IOTDB-6288] Alter default disk_space_warning_threshold in
ClusterIT environment (#11854)
add b4aafb21087 [IOTDB-6289] Add leader election wait when start
SeedConfigNode
add 39cd8180bc8 [IOTDB-6287] Load: Add Progress Index for the Second Phase
of Load TsFile (#11851)
add fe815cdc6ca Feture collection iotdb info (#11816)
add 32872277746 fix compaction log is not deleted after exception (#11855)
add 50789004d35 PBTree: Prevent SchemaFile deadlock when check read page
(#11858)
add 9bcef1c22f8 Support InnerTimeJoin & LeftOuterTimeJoin distribution
planner (#11860)
add dff87437e88 Update client-cpp.yml to fix cpp build error on Windows
(#11863)
add e1370838190 set default config item
'enableInsertionCrossSpaceCompaction' to true (#11861)
add 4af1bf8c4a0 Pipe: fix constructor of `PipeTsFileInsertionEvent` &
filter out empty events on sender side (#11862)
add 8e567c5c979 Bump follow-redirects in /iotdb-connector/grafana-plugin
(#11864)
add 20957f7d116 Merge branch 'master' into beyyes/align_by_time_topk
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp.yml | 6 +-
.../it/env/cluster/config/MppCommonConfig.java | 5 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 2 +-
.../confignode/it/utils/ConfigNodeTestUtils.java | 2 +-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 31 ++
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 28 ++
.../apache/iotdb/pipe/it/IoTDBPipeExtractorIT.java | 22 ++
.../assembly/resources/tools/collection-info.bat | 275 ++++++++++++++
.../assembly/resources/tools/collection-info.sh | 268 +++++++++++++
iotdb-connector/grafana-plugin/yarn.lock | 6 +-
.../src/assembly/resources/conf/confignode-env.sh | 2 +-
.../assembly/resources/conf/logback-confignode.xml | 52 +--
.../iotdb/confignode/manager/ConfigManager.java | 2 +
.../iotdb/confignode/manager/ProcedureManager.java | 24 +-
.../manager/consensus/ConsensusManager.java | 37 +-
.../confignode/manager/load/cache/LoadCache.java | 1 +
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../manager/partition/PartitionManager.java | 10 +-
.../manager/pipe/agent/PipeConfigNodeAgent.java | 2 +-
.../agent/plugin/PipePluginConfigNodeAgent.java | 14 +-
.../iotdb/confignode/procedure/Procedure.java | 46 ++-
.../confignode/procedure/ProcedureExecutor.java | 25 +-
.../confignode/procedure/ProcedureMetrics.java | 184 +++++++++
.../impl/statemachine/StateMachineProcedure.java | 2 +-
.../iotdb/confignode/service/ConfigNode.java | 25 +-
.../procedure/TestProcedureExecutor.java | 2 +-
.../procedure/entity/StuckProcedure.java | 4 +-
.../src/test/resources/confignode1conf/logback.xml | 52 +--
.../src/test/resources/confignode2conf/logback.xml | 52 +--
.../src/test/resources/confignode3conf/logback.xml | 52 +--
.../src/assembly/resources/conf/datanode-env.sh | 2 +-
.../assembly/resources/conf/logback-datanode.xml | 122 +++---
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 19 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 5 +
.../dataregion/DataExecutionVisitor.java | 3 +
.../pipe/agent/plugin/PipePluginDataNodeAgent.java | 8 +-
.../dataregion/PipeDataRegionPluginAgent.java | 23 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 14 +-
.../db/pipe/agent/runtime/PipeRuntimeAgent.java | 16 +-
.../db/pipe/agent/task/PipeTaskDataNodeAgent.java | 4 +-
.../protocol/airgap/IoTDBAirGapConnector.java | 7 +
.../thrift/async/IoTDBThriftAsyncConnector.java | 7 +
.../thrift/sync/IoTDBThriftSyncConnector.java | 7 +
.../protocol/writeback/WriteBackConnector.java | 7 +
.../event/common/heartbeat/PipeHeartbeatEvent.java | 1 +
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../tablet/TabletInsertionDataContainer.java | 12 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 9 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 4 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 18 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 5 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 25 +-
.../db/queryengine/common/MPPQueryContext.java | 10 +
.../execution/executor/RegionWriteExecutor.java | 9 +-
.../fragment/FragmentInstanceContext.java | 15 +-
.../execution/load/LoadTsFileManager.java | 14 +-
.../process/join/InnerTimeJoinOperator.java | 26 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 8 +-
.../db/queryengine/plan/analyze/Analysis.java | 19 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 27 +-
.../analyze/cache/schema/DataNodeSchemaCache.java | 44 +++
.../plan/analyze/schema/ClusterSchemaFetcher.java | 9 +
.../plan/optimization/ColumnInjectionPushDown.java | 8 +
.../plan/optimization/LimitOffsetPushDown.java | 15 +
.../OrderByExpressionWithLimitChangeToTopK.java | 27 ++
.../plan/planner/LocalExecutionPlanContext.java | 16 +
.../plan/planner/LocalExecutionPlanner.java | 24 +-
.../plan/planner/OperatorTreeGenerator.java | 33 +-
.../planner/distribution/ExchangeNodeAdder.java | 78 ++++
.../plan/planner/distribution/SourceRewriter.java | 180 +++++++++
.../plan/planner/plan/node/PlanGraphPrinter.java | 47 ++-
.../plan/node/load/LoadSingleTsFileNode.java | 8 -
.../plan/planner/plan/node/process/OffsetNode.java | 5 +
.../plan/node/process/join/InnerTimeJoinNode.java | 116 +++++-
.../planner/plan/node/write/DeleteDataNode.java | 2 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 37 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 93 +++--
.../mtree/impl/pbtree/CachedMTreeStore.java | 13 +-
.../mtree/impl/pbtree/flush/Scheduler.java | 74 ++--
.../impl/pbtree/memory/ReleaseFlushMonitor.java | 77 ++--
.../schemafile/pagemgr/BTreePageManager.java | 69 +++-
.../pbtree/schemafile/pagemgr/PageManager.java | 17 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 21 +-
.../iotdb/db/storageengine/StorageEngine.java | 10 +-
.../db/storageengine/dataregion/DataRegion.java | 196 ++++++++--
.../dataregion/IDataRegionForQuery.java | 3 +-
.../dataregion/VirtualDataRegion.java | 3 +-
.../CompactionFileCountExceededException.java | 5 +
.../CompactionLastTimeCheckFailedException.java | 5 +
.../CompactionMemoryNotEnoughException.java | 5 +
.../CompactionValidationFailedException.java | 5 +
.../performer/impl/FastCompactionPerformer.java | 4 +
.../execute/task/AbstractCompactionTask.java | 11 +-
.../execute/task/CrossSpaceCompactionTask.java | 3 +-
.../execute/task/InnerSpaceCompactionTask.java | 3 +-
.../compaction/schedule/CompactionWorker.java | 2 +-
.../dataregion/flush/CompressionRatio.java | 3 -
.../dataregion/flush/MemTableFlushTask.java | 24 --
.../memtable/AlignedWritableMemChunk.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 42 +--
.../dataregion/tsfile/TsFileManager.java | 21 +-
.../dataregion/utils/TsFileResourceUtils.java | 2 -
.../storageengine/dataregion/wal/node/WALNode.java | 4 +-
.../dataregion/wal/recover/WALRecoverManager.java | 11 +-
.../dataregion/wal/utils/WALFileUtils.java | 14 +
.../db/utils/datastructure/AlignedTVList.java | 6 +-
.../db/metadata/mtree/schemafile/MonitorTest.java | 13 +-
.../db/pipe/extractor/PipeRealtimeExtractTest.java | 60 +--
.../db/queryengine/execution/DataDriverTest.java | 3 +-
.../process/join/InnerTimeJoinOperatorTest.java | 417 ++++++++++++++++++++-
.../AlignByTimeOrderByLimitOffsetTest.java | 119 ------
.../plan/{plan => planner}/ExpressionTest.java | 2 +-
.../{plan => planner}/FragmentInstanceIdTest.java | 2 +-
.../FragmentInstanceSerdeTest.java | 2 +-
.../plan/{plan => planner}/LogicalPlannerTest.java | 9 +-
.../{plan => planner}/PipelineBuilderTest.java | 4 +-
.../{plan => planner}/QueryLogicalPlanUtil.java | 2 +-
.../plan/{plan => planner}/QueryPlannerTest.java | 2 +-
.../distribution/AggregationDistributionTest.java | 3 +-
.../AlignByDeviceOrderByLimitOffsetTest.java | 346 ++++++++++++++++-
.../AlignByTimeOrderByLimitOffsetTest.java | 242 ++++++++++++
.../distribution/AlignedByDeviceTest.java | 3 +-
.../distribution/DistributionPlannerBasicTest.java | 3 +-
.../distribution/DistributionPlannerCycleTest.java | 3 +-
.../distribution/LastQueryTest.java | 3 +-
.../distribution/NoDataRegionPlanningTest.java | 3 +-
.../distribution/SplitTimePartitionTest.java | 273 ++++++++++++++
.../plan/{plan => planner}/distribution/Util.java | 2 +-
.../plan/{plan => planner}/distribution/Util2.java | 2 +-
.../node/PlanGraphPrinterTest.java | 2 +-
.../node/PlanNodeDeserializeHelper.java | 2 +-
.../node/load/LoadTsFileNodeTest.java | 2 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 4 +-
.../NodeManagementMemoryMergeNodeSerdeTest.java | 4 +-
.../read/PathsUsingTemplateScanNodeTest.java | 2 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 4 +-
.../metadata/read/SchemaFetchMergeNodeTest.java | 2 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 2 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 4 +-
.../metadata/write/MetadataWriteNodeSerDeTest.java | 2 +-
.../node/process/AggregationNodeSerdeTest.java | 4 +-
.../node/process/DeviceViewNodeSerdeTest.java | 4 +-
.../node/process/ExchangeNodeSerdeTest.java | 4 +-
.../node/process/FillNodeSerdeTest.java | 4 +-
.../node/process/FilterNodeSerdeTest.java | 4 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 4 +-
.../node/process/GroupByTagNodeSerdeTest.java | 4 +-
.../node/process/IntoNodeSerdeTest.java | 4 +-
.../node/process/LimitNodeSerdeTest.java | 4 +-
.../node/process/OffsetNodeSerdeTest.java | 4 +-
.../process/SingleDeviceViewNodeSerdeTest.java | 4 +-
.../node/process/SortNodeSerdeTest.java | 4 +-
.../node/process/TimeJoinNodeSerdeTest.java | 4 +-
.../node/sink/IdentitySinkNodeSerdeTest.java | 4 +-
.../node/sink/ShuffleSinkHandleNodeSerdeTest.java | 4 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 4 +-
.../node/source/SeriesScanNodeSerdeTest.java | 4 +-
.../node/write/DeleteDataNodeSerdeTest.java | 2 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 2 +-
.../node/write/InsertRowNodeSerdeTest.java | 2 +-
.../node/write/InsertRowsNodeSerdeTest.java | 2 +-
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 2 +-
.../node/write/InsertTabletNodeSerdeTest.java | 2 +-
.../node/write/WritePlanNodeSplitTest.java | 2 +-
.../statement/sys/pipe/PipeStatementTest.java | 2 +-
.../storageengine/dataregion/DataRegionTest.java | 12 +
.../iotdb/db/storageengine/dataregion/TTLTest.java | 3 +
.../compaction/ReadChunkInnerCompactionTest.java | 49 +++
.../cross/CrossSpaceCompactionExceptionTest.java | 79 ++++
.../dataregion/memtable/TsFileProcessorTest.java | 16 +-
.../src/test/resources/datanode1conf/logback.xml | 122 +++---
.../src/test/resources/datanode2conf/logback.xml | 122 +++---
.../src/test/resources/datanode3conf/logback.xml | 122 +++---
.../resources/conf/iotdb-common.properties | 2 +-
.../iotdb/commons/partition/DataPartition.java | 77 +++-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 18 +-
.../iotdb/commons/pipe/task/meta/PipeMeta.java | 29 ++
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 8 +
.../iotdb/commons/service/metric/enums/Metric.java | 6 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 3 -
.../src/main/thrift/datanode.thrift | 1 +
182 files changed, 4166 insertions(+), 1221 deletions(-)
create mode 100644
iotdb-client/cli/src/assembly/resources/tools/collection-info.bat
create mode 100644
iotdb-client/cli/src/assembly/resources/tools/collection-info.sh
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/ProcedureMetrics.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/plan/distribution/AlignByTimeOrderByLimitOffsetTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/ExpressionTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/FragmentInstanceIdTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/FragmentInstanceSerdeTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/LogicalPlannerTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/PipelineBuilderTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/QueryLogicalPlanUtil.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/QueryPlannerTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/AggregationDistributionTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/AlignByDeviceOrderByLimitOffsetTest.java (63%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AlignByTimeOrderByLimitOffsetTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/AlignedByDeviceTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/DistributionPlannerBasicTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/DistributionPlannerCycleTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/LastQueryTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/NoDataRegionPlanningTest.java (93%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/SplitTimePartitionTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/Util.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/distribution/Util2.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/PlanGraphPrinterTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/PlanNodeDeserializeHelper.java (95%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/load/LoadTsFileNodeTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/NodeManagementMemoryMergeNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/PathsUsingTemplateScanNodeTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/SchemaCountNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/SchemaFetchMergeNodeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/SchemaFetchScanNodeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/metadata/write/MetadataWriteNodeSerDeTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/AggregationNodeSerdeTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/DeviceViewNodeSerdeTest.java (94%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/ExchangeNodeSerdeTest.java (95%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/FillNodeSerdeTest.java (93%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/FilterNodeSerdeTest.java (94%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/GroupByLevelNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/GroupByTagNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/IntoNodeSerdeTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/LimitNodeSerdeTest.java (93%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/OffsetNodeSerdeTest.java (93%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/SingleDeviceViewNodeSerdeTest.java (93%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/SortNodeSerdeTest.java (94%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/process/TimeJoinNodeSerdeTest.java (96%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/sink/IdentitySinkNodeSerdeTest.java (94%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/sink/ShuffleSinkHandleNodeSerdeTest.java (94%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/source/SeriesAggregationScanNodeSerdeTest.java (95%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/source/SeriesScanNodeSerdeTest.java (93%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/DeleteDataNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/InsertMultiTabletsNodeSerdeTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/InsertRowNodeSerdeTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/InsertRowsNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/InsertRowsOfOneDeviceNodeSerdeTest.java (97%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/InsertTabletNodeSerdeTest.java (98%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/node/write/WritePlanNodeSplitTest.java (99%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/{plan =>
planner}/statement/sys/pipe/PipeStatementTest.java (98%)
