This is an automated email from the ASF dual-hosted git repository. xiangweiwei pushed a commit to branch aggregator in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit be277e5a108557cc3bb6922ebfeb1a902c977d86 Merge: e9a1b58d1b 8f7fb57661 Author: Alima777 <[email protected]> AuthorDate: Fri Apr 29 09:55:36 2022 +0800 Merge branch 'master' into aggregator LICENSE | 9 + 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 +++++ .../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 | 17 +- .../iotdb/confignode/manager/DataNodeManager.java | 4 + .../apache/iotdb/confignode/manager/Manager.java | 10 +- .../iotdb/confignode/manager/PartitionManager.java | 6 +- .../confignode/persistence/ClusterSchemaInfo.java | 34 +- .../confignode/persistence/PartitionInfo.java | 57 +- .../service/executor/ConfigRequestExecutor.java | 21 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 22 +- .../consensus/request/ConfigRequestSerDeTest.java | 89 ++- docs/UserGuide/Process-Data/Select-Into.md | 6 +- docs/zh/UserGuide/Process-Data/Select-Into.md | 8 +- .../iotdb/db/integration/IoTDBSelectIntoIT.java | 6 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 21 +- .../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 ++-- .../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 | 7 + .../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 25 +- .../db/mpp/operator/source/ExchangeOperator.java | 2 +- .../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 10 + .../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 16 +- .../mpp/sql/analyze/ClusterPartitionFetcher.java | 177 +++--- .../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 2 + .../iotdb/db/mpp/sql/analyze/SchemaValidator.java | 14 +- .../iotdb/db/mpp/sql/analyze/TypeProvider.java | 77 +++ .../db/mpp/sql/planner/DistributionPlanner.java | 10 +- .../db/mpp/sql/planner/LocalExecutionPlanner.java | 76 ++- .../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 | 12 - .../node/metedata/read/TimeSeriesCountNode.java | 12 - .../metedata/read/TimeSeriesSchemaScanNode.java | 12 - .../node/metedata/write/AlterTimeSeriesNode.java | 12 - .../write/CreateAlignedTimeSeriesNode.java | 11 - .../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 | 12 - .../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 | 12 - .../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 +- .../db/mpp/sql/statement/StatementVisitor.java | 4 +- .../db/mpp/sql/statement/component/FillPolicy.java | 4 +- .../db/mpp/sql/statement/component/OrderBy.java | 4 +- .../db/qp/logical/crud/SelectIntoOperator.java | 15 + .../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 ++ .../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 25 + .../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 +- tsfile/pom.xml | 5 - .../apache/iotdb/tsfile/utils/BitConstructor.java | 3 - .../apache/iotdb/tsfile/utils/ByteArrayList.java | 135 +++++ 139 files changed, 4465 insertions(+), 4443 deletions(-)
