You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/04/30 15:31:35 UTC
[iotdb] branch timep_v2 updated (6166288b3c -> 24178c49ea)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch timep_v2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6166288b3c Move time partition calculation from StorageEngine to StorageEngineV2
add 9cc21e1dfb Fix Sesssion InsertRecord bug (#5712)
add 63586ba2cc [IOTDB-2948] ConfigNode supports ClientPool (#5704)
add 6d89eed024 Fix bugs of batch insert (#5714)
add 83c59ef43c [IOTDB-3033] Completing the query and writing interface compared to java (#5713)
add 01d81e78f7 [IOTDB-3028] Fix PartitionCache when there are ** in path (#5709)
add 245621ca3b [IOTDB-3032]Fix storage group cache (#5711)
add 4c1abdd894 [IOTDB-3021] Fix sink/source handle memory leak (#5692)
add 3d028a7817 fix root.**.* (#5715)
add 2c1ef036ea ConfignodeClient reconnect without random pick (#5717)
add e438189fa6 [IOTDB-2994] Remove eclipse collection to reduce package size (#5720)
add d8c06a80d3 [IOTDB-3036][Partition Cache] Add auto create judge when get deviceToStorageGroupMap (#5719)
add eadc582377 [IOTDB-3030] delete storage group with ** error (#5718)
add 8f8dfa281a Fix NPE (#5722)
add c8d7d8144e [IOTDB-3037] Define all PlanNode in the query logical plan (#5716)
add d75e5081e4 Predict data type for auto creating timeseries (#5724)
add 8f7fb57661 [IOTDB-3029] The prefix path generated by the select into target sequence contains * and ** currently unchecked (#5723)
add f1ffc0a054 Support Create aligned timeseries (#5727)
add 5eb2308198 [IOTDB-3027] Feature/count storage group (#5728)
add 2cef18fb9b Fix some bugs (#5725)
add 1ddc50b749 Support order by time desc (#5729)
add be72769252 Add outputColumnNames in ExchangeNode (#5730)
add 8c6b8f82dc [IOTDB-2285] IoTDB Grafana Plugin: Grafana Connector Input Style (#5661)
add 685ea15ed6 [IOTDB-3025] add permission check (#5699)
add 7cf013bff3 [IOTDB-3046] Fix port binding error in ClientManagerTest (#5736)
add 76a4e43955 [IOTDB-3018] Fix compation bugs on handling deleted target file and service shutdown deadlock (#5693)
add 20c527ffd3 [IOTDB-3026] fix cannot load tsfile correctly after restart iotdb (#5702)
add 512f2ffd54 [IOTDB-3039] Add standalone recovery (#5731)
add 5b045e4864 [IOTDB-2993] Support IN, LIKE, and REGEXP expressions in Transform Operator (#5739)
add d4647beaef [IOTDB-2803] support AlterTimeseries sql (#5735)
add 2e7812282f [IoTDB-2991] Equal size bucket sampling UDFs: EQUAL_SIZE_BUCKET_OUTLIER_SAMPLE (#5682)
add b5d79f1e4a Merge branch 'master' of https://github.com/apache/iotdb into timep_v2
add 24178c49ea merge master
No new revisions were added by this update.
Summary of changes:
LICENSE | 9 +
README.md | 2 +-
README_ZH.md | 2 +-
client-py/SessionAlignedTimeseriesExample.py | 18 +
client-py/SessionExample.py | 30 +
client-py/iotdb/Session.py | 132 +++-
client-py/tests/tablet_performance_comparison.py | 4 +-
client-py/tests/test_one_device.py | 152 ++++
.../cluster/log/snapshot/FileSnapshotTest.java | 20 +-
.../log/snapshot/PartitionedSnapshotTest.java | 6 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 2 +-
.../iotdb/confignode/cli/TemporaryClient.java | 202 -----
.../iotdb/confignode/client/AsyncClientPool.java | 113 +++
.../client/handlers/InitRegionHandler.java | 56 ++
.../consensus/request/ConfigRequest.java | 29 +-
.../consensus/request/ConfigRequestType.java | 1 +
...rageGroupReq.java => CountStorageGroupReq.java} | 19 +-
...aPartitionReq.java => GetDataPartitionReq.java} | 10 +-
.../request/read/GetOrCreateDataPartitionReq.java | 119 +--
.../read/GetOrCreateSchemaPartitionReq.java | 76 +-
...artitionReq.java => GetSchemaPartitionReq.java} | 10 +-
.../consensus/request/read/GetStorageGroupReq.java | 21 +-
.../consensus/request/write/CreateRegionsReq.java | 20 +-
...tStorageGroupReq.java => DeleteRegionsReq.java} | 48 +-
.../request/write/DeleteStorageGroupReq.java | 36 +-
.../request/write/SetStorageGroupReq.java | 4 -
.../confignode/manager/ClusterSchemaManager.java | 128 +++-
.../iotdb/confignode/manager/ConfigManager.java | 35 +-
.../iotdb/confignode/manager/DataNodeManager.java | 4 +
.../apache/iotdb/confignode/manager/Manager.java | 22 +-
.../iotdb/confignode/manager/PartitionManager.java | 6 +-
.../confignode/manager/PermissionManager.java | 11 +
.../iotdb/confignode/persistence/AuthorInfo.java | 128 +++-
.../confignode/persistence/ClusterSchemaInfo.java | 34 +-
.../confignode/persistence/PartitionInfo.java | 57 +-
.../service/executor/ConfigRequestExecutor.java | 21 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 29 +-
.../consensus/request/ConfigRequestSerDeTest.java | 89 ++-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 22 +
.../consensus/standalone/StandAloneConsensus.java | 50 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 94 +++
.../standalone/StandAloneConsensusTest.java | 4 +-
docs/UserGuide/Process-Data/Select-Into.md | 6 +-
docs/UserGuide/Query-Data/Select-Expression.md | 74 ++
docs/zh/UserGuide/Process-Data/Select-Into.md | 8 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 76 ++
grafana-plugin/pkg/plugin/plugin.go | 77 +-
grafana-plugin/src/QueryEditor.tsx | 295 +++++++-
.../{WhereValue.tsx => AggregateFun.tsx} | 40 +-
.../componments/{WhereValue.tsx => FillValue.tsx} | 8 +-
grafana-plugin/src/componments/GroupBy.tsx | 58 ++
grafana-plugin/src/componments/SelectValue.tsx | 1 +
grafana-plugin/src/componments/TimeSeries.tsx | 82 ++
grafana-plugin/src/componments/WhereValue.tsx | 1 +
grafana-plugin/src/datasource.ts | 66 +-
grafana-plugin/src/functions.ts | 3 +-
grafana-plugin/src/types.ts | 30 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 25 +
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 6 +-
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 138 ++++
.../iotdb/commons/partition/DataPartition.java | 2 +-
.../iotdb/commons/partition/SchemaPartition.java | 2 +-
.../apache/iotdb/commons/ClientManagerTest.java | 7 +-
openapi/src/main/openapi3/iotdb-rest.yaml | 23 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 138 +++-
.../db/auth/authorizer/AuthorizerManager.java | 44 ++
.../db/auth/authorizer/ClusterAuthorizer.java | 61 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 54 +-
.../engine/compaction/CompactionTaskManager.java | 45 +-
.../compaction/cross/CrossSpaceCompactionTask.java | 2 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 34 +-
.../impl/ReadPointCompactionPerformer.java | 5 +-
.../compaction/task/AbstractCompactionTask.java | 19 +-
.../compaction/task/CompactionTaskSummary.java} | 16 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 4 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 7 +-
.../mtree/store/disk/CachedMNodeContainer.java | 12 +-
.../db/metadata/tree/AbstractTreeVisitor.java | 62 +-
.../iotdb/db/mpp/buffer/DataBlockManager.java | 14 +-
.../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 19 +-
.../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 13 +-
.../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 104 ++-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 114 ++-
.../iotdb/db/mpp/common/header/HeaderConstant.java | 10 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 2 +-
.../org/apache/iotdb/db/mpp/execution/Driver.java | 2 +-
.../db/mpp/execution/FragmentInstanceManager.java | 1 +
.../iotdb/db/mpp/execution/QueryExecution.java | 4 +-
.../db/mpp/execution/config/ConfigTaskVisitor.java | 14 +
.../execution/config/CountStorageGroupTask.java | 97 +++
.../scheduler/SimpleFragInstanceDispatcher.java | 3 +
.../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 25 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 17 +-
.../process/merge/AscTimeComparator.java} | 18 +-
.../process/merge/DescTimeComparator.java} | 18 +-
.../operator/process/merge/SingleColumnMerger.java | 37 +-
.../process/merge/TimeComparator.java} | 14 +-
.../db/mpp/operator/source/ExchangeOperator.java | 2 +-
.../db/mpp/operator/source/SeriesScanUtil.java | 6 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 10 +
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 28 +-
.../mpp/sql/analyze/ClusterPartitionFetcher.java | 179 +++--
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 28 +-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 2 +
.../iotdb/db/mpp/sql/analyze/SchemaValidator.java | 14 +-
.../iotdb/db/mpp/sql/analyze/TypeProvider.java | 77 ++
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 4 +-
.../db/mpp/sql/parser/StatementGenerator.java | 3 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 11 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 99 ++-
.../db/mpp/sql/planner/LogicalPlanBuilder.java | 226 ++++++
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 194 +++--
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 364 ---------
.../sql/planner/SimpleFragmentParallelPlanner.java | 1 +
.../db/mpp/sql/planner/plan/PlanFragment.java | 25 +-
.../db/mpp/sql/planner/plan/node/PlanNode.java | 6 -
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 33 +-
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 33 +-
.../metedata/read/AbstractSchemaMergeNode.java | 18 -
.../plan/node/metedata/read/DevicesCountNode.java | 12 -
.../node/metedata/read/DevicesSchemaScanNode.java | 18 -
.../metedata/read/LevelTimeSeriesCountNode.java | 12 -
.../plan/node/metedata/read/SchemaFetchNode.java | 16 +-
.../node/metedata/read/TimeSeriesCountNode.java | 12 -
.../metedata/read/TimeSeriesSchemaScanNode.java | 12 -
.../node/metedata/write/AlterTimeSeriesNode.java | 38 +-
.../write/CreateAlignedTimeSeriesNode.java | 41 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 11 -
.../planner/plan/node/process/AggregateNode.java | 199 -----
.../planner/plan/node/process/AggregationNode.java | 186 +++++
.../planner/plan/node/process/DeviceMergeNode.java | 160 ++--
.../planner/plan/node/process/DeviceViewNode.java | 166 ++++
.../planner/plan/node/process/ExchangeNode.java | 42 +-
.../sql/planner/plan/node/process/FillNode.java | 71 +-
.../sql/planner/plan/node/process/FilterNode.java | 103 +--
.../planner/plan/node/process/FilterNullNode.java | 57 +-
.../plan/node/process/GroupByLevelNode.java | 170 ++---
.../planner/plan/node/process/GroupByTimeNode.java | 165 ++++
.../sql/planner/plan/node/process/LimitNode.java | 59 +-
.../sql/planner/plan/node/process/OffsetNode.java | 35 +-
.../process/{OffsetNode.java => ProjectNode.java} | 93 +--
.../sql/planner/plan/node/process/SortNode.java | 61 +-
.../planner/plan/node/process/TimeJoinNode.java | 156 +---
.../planner/plan/node/sink/FragmentSinkNode.java | 14 +-
.../source/AlignedSeriesAggregationScanNode.java | 267 +++++++
...iesScanNode.java => AlignedSeriesScanNode.java} | 269 +++----
...canNode.java => SeriesAggregationScanNode.java} | 251 ++++---
.../planner/plan/node/source/SeriesScanNode.java | 239 +++---
.../plan/node/write/BatchInsertNode.java} | 9 +-
.../plan/node/write/InsertMultiTabletsNode.java | 15 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 19 +-
.../planner/plan/node/write/InsertRowsNode.java | 21 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 111 ++-
.../planner/plan/node/write/InsertTabletNode.java | 11 -
.../sql/planner/plan/parameter/Aggregation.java | 43 --
.../plan/parameter/AggregationDescriptor.java | 102 +++
.../planner/plan/parameter/AggregationStep.java | 24 +
.../sql/planner/plan/parameter/FillDescriptor.java | 69 ++
.../plan/parameter/FilterNullParameter.java | 15 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 8 +-
.../iotdb/db/mpp/sql/statement/Statement.java | 9 +
.../db/mpp/sql/statement/StatementVisitor.java | 10 +-
.../db/mpp/sql/statement/component/FillPolicy.java | 4 +-
.../db/mpp/sql/statement/component/OrderBy.java | 4 +-
.../statement/crud/AggregationQueryStatement.java | 2 +
.../mpp/sql/statement/crud/FillQueryStatement.java | 1 +
.../statement/crud/GroupByFillQueryStatement.java | 1 +
.../sql/statement/crud/GroupByQueryStatement.java | 2 +
.../sql/statement/crud/InsertBaseStatement.java | 8 +
.../crud/InsertMultiTabletsStatement.java | 9 +
.../mpp/sql/statement/crud/InsertRowStatement.java | 13 +
.../crud/InsertRowsOfOneDeviceStatement.java | 11 +
.../sql/statement/crud/InsertRowsStatement.java | 9 +
.../db/mpp/sql/statement/crud/InsertStatement.java | 11 +
.../sql/statement/crud/InsertTabletStatement.java | 11 +
.../mpp/sql/statement/crud/LastQueryStatement.java | 2 +
.../db/mpp/sql/statement/crud/QueryStatement.java | 5 +
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 1 +
.../mpp/sql/statement/crud/UDTFQueryStatement.java | 1 +
.../metadata/AlterTimeSeriesStatement.java | 7 +
.../mpp/sql/statement/metadata/CountStatement.java | 8 +
.../metadata/CountStorageGroupStatement.java | 16 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 20 +
.../metadata/CreateTimeSeriesStatement.java | 7 +
.../statement/metadata/SchemaFetchStatement.java | 8 +
.../metadata/SetStorageGroupStatement.java | 10 +
.../statement/metadata/ShowDevicesStatement.java | 8 +
.../mpp/sql/statement/metadata/ShowStatement.java | 9 +
.../metadata/ShowStorageGroupStatement.java | 8 +
.../db/mpp/sql/statement/sys/AuthorStatement.java | 63 +-
.../protocol/rest/handler/QueryDataSetHandler.java | 14 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 41 +
.../db/qp/logical/crud/SelectIntoOperator.java | 15 +
.../expression/binary/AdditionExpression.java | 4 +-
.../query/expression/binary/BinaryExpression.java | 2 +-
.../expression/binary/DivisionExpression.java | 4 +-
.../query/expression/binary/EqualToExpression.java | 4 +-
.../expression/binary/GreaterEqualExpression.java | 4 +-
.../expression/binary/GreaterThanExpression.java | 4 +-
.../expression/binary/LessEqualExpression.java | 4 +-
.../expression/binary/LessThanExpression.java | 4 +-
.../expression/binary/LogicAndExpression.java | 4 +-
.../query/expression/binary/LogicOrExpression.java | 4 +-
.../query/expression/binary/ModuloExpression.java | 4 +-
.../binary/MultiplicationExpression.java | 4 +-
.../expression/binary/NonEqualExpression.java | 4 +-
.../expression/binary/SubtractionExpression.java | 4 +-
.../query/expression/multi/FunctionExpression.java | 8 +-
.../db/query/expression/unary/LikeExpression.java | 80 +-
.../query/expression/unary/LogicNotExpression.java | 2 +-
.../query/expression/unary/NegationExpression.java | 2 +-
.../query/expression/unary/RegularExpression.java | 5 +-
.../query/reader/chunk/MemAlignedPageReader.java | 2 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 4 +-
.../db/query/udf/builtin/BuiltinFunction.java | 4 +-
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 8 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 834 +++++++++++++++++++++
.../transformer/ArithmeticNegationTransformer.java | 80 --
.../db/query/udf/core/transformer/Transformer.java | 2 +-
.../core/transformer/TransparentTransformer.java | 93 ---
.../ArithmeticAdditionTransformer.java | 2 +-
.../{ => binary}/ArithmeticBinaryTransformer.java | 2 +-
.../ArithmeticDivisionTransformer.java | 2 +-
.../{ => binary}/ArithmeticModuloTransformer.java | 2 +-
.../ArithmeticMultiplicationTransformer.java | 2 +-
.../ArithmeticSubtractionTransformer.java | 2 +-
.../{ => binary}/BinaryTransformer.java | 3 +-
.../{ => binary}/CompareBinaryTransformer.java | 2 +-
.../{ => binary}/CompareEqualToTransformer.java | 2 +-
.../CompareGreaterEqualTransformer.java | 2 +-
.../CompareGreaterThanTransformer.java | 2 +-
.../{ => binary}/CompareLessEqualTransformer.java | 2 +-
.../{ => binary}/CompareLessThanTransformer.java | 2 +-
.../{ => binary}/CompareNonEqualTransformer.java | 2 +-
.../{ => binary}/LogicAndTransformer.java | 2 +-
.../{ => binary}/LogicBinaryTransformer.java | 2 +-
.../{ => binary}/LogicOrTransformer.java | 2 +-
.../{ => multi}/UDFQueryRowTransformer.java | 2 +-
.../{ => multi}/UDFQueryRowWindowTransformer.java | 2 +-
.../{ => multi}/UDFQueryTransformer.java | 3 +-
.../ArithmeticNegationTransformer.java} | 36 +-
.../udf/core/transformer/unary/InTransformer.java | 149 ++++
.../LogicNotTransformer.java} | 25 +-
.../RegularTransformer.java} | 35 +-
.../transformer/unary/TransparentTransformer.java | 70 ++
.../UnaryTransformer.java} | 34 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 79 +-
.../service/thrift/impl/InternalServiceImpl.java | 2 +-
.../compaction/CompactionTaskManagerTest.java | 2 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 89 +++
.../compaction/inner/InnerCompactionTest.java | 63 +-
.../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 69 +-
.../iotdb/db/mpp/buffer/SourceHandleTest.java | 76 +-
.../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 20 +-
.../mpp/common/schematree/PathPatternTreeTest.java | 4 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 51 ++
.../iotdb/db/mpp/execution/DataDriverTest.java | 6 +-
.../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 25 +
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 6 +-
.../db/mpp/operator/SingleColumnMergerTest.java | 11 +-
.../db/mpp/operator/TimeJoinOperatorTest.java | 132 +++-
.../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 39 +-
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 228 ------
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 2 -
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 631 ++++++++++------
.../plan/node/process/AggregateNodeSerdeTest.java | 69 --
...erdeTest.java => AggregationNodeSerdeTest.java} | 82 +-
.../DeviceViewNodeSerdeTest.java} | 44 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 53 +-
.../sql/plan/node/process/FillNodeSerdeTest.java | 60 +-
.../sql/plan/node/process/FilterNodeSerdeTest.java | 66 +-
.../plan/node/process/FilterNullNodeSerdeTest.java | 74 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 119 ++-
.../sql/plan/node/process/LimitNodeSerdeTest.java | 86 +--
.../sql/plan/node/process/OffsetNodeSerdeTest.java | 154 +---
.../sql/plan/node/process/SortNodeSerdeTest.java | 95 +--
.../plan/node/process/TimeJoinNodeSerdeTest.java | 118 +--
...ava => SeriesAggregationScanNodeSerdeTest.java} | 43 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 15 +-
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 19 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
.../src/main/thrift/confignode.thrift | 8 +
tsfile/pom.xml | 5 -
.../iotdb/tsfile/read/common/block/TsBlock.java | 7 +
.../read/common/block/column/BinaryColumn.java | 16 +
.../read/common/block/column/BooleanColumn.java | 16 +
.../tsfile/read/common/block/column/Column.java | 3 +
.../read/common/block/column/DoubleColumn.java | 16 +
.../read/common/block/column/FloatColumn.java | 16 +
.../tsfile/read/common/block/column/IntColumn.java | 16 +
.../read/common/block/column/LongColumn.java | 16 +
.../block/column/RunLengthEncodedColumn.java | 5 +
.../read/common/block/column/TimeColumn.java | 9 +
.../iotdb/tsfile/read/reader/IPageReader.java | 2 +-
.../tsfile/read/reader/page/AlignedPageReader.java | 2 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 3 +-
.../apache/iotdb/tsfile/utils/BitConstructor.java | 3 -
.../apache/iotdb/tsfile/utils/ByteArrayList.java | 135 ++++
298 files changed, 8342 insertions(+), 5165 deletions(-)
create mode 100644 client-py/tests/test_one_device.py
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/cli/TemporaryClient.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/AsyncClientPool.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/InitRegionHandler.java
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetOrCountStorageGroupReq.java => CountStorageGroupReq.java} (80%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetOrCreateDataPartitionReq.java => GetDataPartitionReq.java} (95%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetOrCreateSchemaPartitionReq.java => GetSchemaPartitionReq.java} (92%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/BatchInsert.java => confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetStorageGroupReq.java (66%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{SetStorageGroupReq.java => DeleteRegionsReq.java} (55%)
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/standalone/RecoveryTest.java
copy grafana-plugin/src/componments/{WhereValue.tsx => AggregateFun.tsx} (56%)
copy grafana-plugin/src/componments/{WhereValue.tsx => FillValue.tsx} (86%)
create mode 100644 grafana-plugin/src/componments/GroupBy.tsx
create mode 100644 grafana-plugin/src/componments/TimeSeries.tsx
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/metadata/CountStorageGroupStatement.java => engine/compaction/task/CompactionTaskSummary.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/config/CountStorageGroupTask.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{sql/statement/crud/UDTFQueryStatement.java => operator/process/merge/AscTimeComparator.java} (67%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{sql/statement/crud/UDTFQueryStatement.java => operator/process/merge/DescTimeComparator.java} (67%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{sql/statement/metadata/CountStorageGroupStatement.java => operator/process/merge/TimeComparator.java} (70%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/analyze/TypeProvider.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/LogicalPlanBuilder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/QueryPlanBuilder.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/AggregateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/AggregationNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/DeviceViewNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/GroupByTimeNode.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/process/{OffsetNode.java => ProjectNode.java} (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/AlignedSeriesAggregationScanNode.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/{SeriesScanNode.java => AlignedSeriesScanNode.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/source/{SeriesAggregateScanNode.java => SeriesAggregationScanNode.java} (56%)
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/{statement/crud/BatchInsert.java => planner/plan/node/write/BatchInsertNode.java} (82%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/Aggregation.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/AggregationDescriptor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/parameter/FillDescriptor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFEqualSizeBucketOutlierSample.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/ArithmeticNegationTransformer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/TransparentTransformer.java
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/ArithmeticAdditionTransformer.java (95%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/ArithmeticBinaryTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/ArithmeticDivisionTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/ArithmeticModuloTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/ArithmeticMultiplicationTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/ArithmeticSubtractionTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/BinaryTransformer.java (97%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareBinaryTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareEqualToTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareGreaterEqualTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareGreaterThanTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareLessEqualTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareLessThanTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/CompareNonEqualTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/LogicAndTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/LogicBinaryTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => binary}/LogicOrTransformer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => multi}/UDFQueryRowTransformer.java (96%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => multi}/UDFQueryRowWindowTransformer.java (96%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ => multi}/UDFQueryTransformer.java (96%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticBinaryTransformer.java => unary/ArithmeticNegationTransformer.java} (50%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/InTransformer.java
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{CompareBinaryTransformer.java => unary/LogicNotTransformer.java} (62%)
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticBinaryTransformer.java => unary/RegularTransformer.java} (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/unary/TransparentTransformer.java
rename server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{LogicNotTransformer.java => unary/UnaryTransformer.java} (60%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/inner/InnerCompactionEmptyTsFileTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/AggregateNodeSerdeTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/process/{DeviceMergeNodeSerdeTest.java => AggregationNodeSerdeTest.java} (50%)
copy server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/{source/SeriesScanNodeSerdeTest.java => process/DeviceViewNodeSerdeTest.java} (52%)
rename server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/node/source/{SeriesAggregateScanNodeSerdeTest.java => SeriesAggregationScanNodeSerdeTest.java} (68%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/utils/ByteArrayList.java