This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch issue_3076
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 870949223b Optimize StandAloneConsensus read/write performance &&
consensus module code refactor
add 8a6031a3c1 [IOTDB-2972] implement local sink/source handle (#5732)
add f6abf3d1da move columnToTsBlockIndexMap from LogicalPlanner to
DistributionPlanner (#5733)
add a4a8656cec [IOTDB-2981] Modify antlr, IoTDBSqlVisitor and ASTVisitor
for new syntax convention (#5696)
add 10ab99946a rename package of mpp and confignode (#5758)
add daeef7b822 Optimize StandAloneConsensus read/write performance &&
consensus module code refactor
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (870949223b)
\
N -- N -- N refs/heads/issue_3076 (daeef7b822)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 9 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 138 ++--
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 15 +-
.../iotdb/cluster/metadata/CSchemaProcessor.java | 6 +-
.../cluster/query/ClusterDataQueryExecutor.java | 6 +-
.../query/aggregate/ClusterAggregateExecutor.java | 2 +-
.../cluster/query/fill/ClusterFillExecutor.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 3 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 4 +-
.../LoadBalancer.java => manager/LoadManager.java} | 7 +-
.../Data-Concept/Data-Model-and-Terminology.md | 35 +-
docs/UserGuide/Query-Data/Without-Null.md | 8 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 453 ++++++++---
.../Data-Concept/Data-Model-and-Terminology.md | 30 +-
docs/zh/UserGuide/Query-Data/Without-Null.md | 8 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 492 +++++++++---
.../org/apache/iotdb/DataMigrationExample.java | 2 +-
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 2 +-
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 2 +-
.../db/integration/IoTDBCreateTimeseriesIT.java | 18 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 16 +-
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 6 +-
.../db/integration/IoTDBFloatPrecisionIT.java | 2 +-
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 2 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 8 +-
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 24 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 29 +-
.../integration/IoTDBSortedShowTimeseriesIT.java | 38 +-
.../db/integration/IoTDBSyntaxConventionIT.java | 468 ------------
.../IoTDBSyntaxConventionIdentifierIT.java | 838 +++++++++++++++++++++
.../IoTDBSyntaxConventionStringLiteralIT.java | 764 +++++++++++++++++++
.../iotdb/db/integration/IoTDBTagAlterIT.java | 46 +-
.../apache/iotdb/db/integration/IoTDBTagIT.java | 220 ++++--
.../aggregation/IoTDBAggregationIT.java | 5 +
.../db/integration/aligned/IoTDBDeletionIT.java | 16 +-
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 6 +-
.../IoTDBSyntaxConventionVersionAdaptionIT.java | 100 ---
.../IoTDBWithoutNullAllFilterIT.java | 16 +-
.../IoTDBWithoutNullAnyFilterIT.java | 8 +-
.../session/IoTDBSessionSyntaxConventionIT.java | 39 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +-
.../db/auth/authorizer/AuthorizerManager.java | 6 +-
.../db/auth/authorizer/ClusterAuthorizer.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../consensus/statemachine/BaseStateMachine.java | 2 +-
.../statemachine/DataRegionStateMachine.java | 16 +-
.../statemachine/SchemaRegionStateMachine.java | 6 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 4 +-
.../utils/SingleSeriesCompactionExecutor.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 4 +-
.../iotdb/db/engine/modification/Modification.java | 2 +-
.../selectinto/InsertTabletPlansIterator.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 10 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../exception/sql/StatementAnalyzeException.java | 2 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 4 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 9 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 10 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 13 +-
.../apache/iotdb/db/metadata/path/PartialPath.java | 32 +-
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 17 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 82 +-
.../db/metadata/utils/ResourceByPathUtils.java | 9 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 10 +-
.../iotdb/db/mpp/common/MPPQueryContext.java | 2 +-
.../org/apache/iotdb/db/mpp/common/QueryId.java | 2 +-
.../iotdb/db/mpp/common/ResultNodeContext.java | 2 +-
.../db/mpp/common/filter/BasicFilterType.java | 4 +-
.../db/mpp/common/filter/BasicFunctionFilter.java | 4 +-
.../iotdb/db/mpp/common/filter/FunctionFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/InFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/LikeFilter.java | 2 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 4 +-
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 2 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 1 +
.../datatransfer}/DataBlockManager.java | 112 ++-
.../datatransfer}/DataBlockService.java | 4 +-
.../datatransfer}/DataBlockServiceMBean.java | 2 +-
.../DataBlockServiceThriftHandler.java | 2 +-
.../datatransfer}/IDataBlockManager.java | 28 +-
.../datatransfer}/IDataBlockManagerCallback.java | 2 +-
.../datatransfer}/ISinkHandle.java | 2 +-
.../datatransfer}/ISourceHandle.java | 2 +-
.../execution/datatransfer/LocalSinkHandle.java | 146 ++++
.../execution/datatransfer/LocalSourceHandle.java | 125 +++
.../execution/datatransfer/SharedTsBlockQueue.java | 152 ++++
.../datatransfer}/SinkHandle.java | 6 +-
.../datatransfer}/SourceHandle.java | 6 +-
.../datatransfer}/TsBlockSerdeFactory.java | 2 +-
.../db/mpp/execution/{ => driver}/DataDriver.java | 10 +-
.../execution/{ => driver}/DataDriverContext.java | 5 +-
.../db/mpp/execution/{ => driver}/Driver.java | 8 +-
.../mpp/execution/{ => driver}/DriverContext.java | 3 +-
.../db/mpp/execution/{ => driver}/IDriver.java | 4 +-
.../mpp/execution/{ => driver}/SchemaDriver.java | 6 +-
.../{ => driver}/SchemaDriverContext.java | 3 +-
.../mpp/execution/{ => fragment}/FragmentInfo.java | 4 +-
.../{ => fragment}/FragmentInstanceContext.java | 7 +-
.../{ => fragment}/FragmentInstanceExecution.java | 9 +-
.../FragmentInstanceFailureListener.java | 2 +-
.../{ => fragment}/FragmentInstanceInfo.java | 2 +-
.../{ => fragment}/FragmentInstanceManager.java | 16 +-
.../{ => fragment}/FragmentInstanceState.java | 2 +-
.../FragmentInstanceStateMachine.java | 17 +-
.../execution/{ => fragment}/FragmentState.java | 2 +-
.../{ => execution}/memory/LocalMemoryManager.java | 2 +-
.../db/mpp/{ => execution}/memory/MemoryPool.java | 2 +-
.../db/mpp/{ => execution}/operator/Operator.java | 2 +-
.../{ => execution}/operator/OperatorContext.java | 6 +-
.../operator/process/AggregateOperator.java | 4 +-
.../operator/process/DeviceViewOperator.java | 6 +-
.../operator/process/FillOperator.java | 4 +-
.../operator/process/FilterNullOperator.java | 4 +-
.../operator/process/FilterOperator.java | 6 +-
.../operator/process/GroupByLevelOperator.java | 4 +-
.../operator/process/LimitOperator.java | 6 +-
.../operator/process/OffsetOperator.java | 4 +-
.../operator/process/ProcessOperator.java | 4 +-
.../operator/process/SortOperator.java | 4 +-
.../operator/process/TimeJoinOperator.java | 12 +-
.../operator/process/TransformOperator.java | 6 +-
.../operator/process/merge/AscTimeComparator.java | 2 +-
.../operator/process/merge/ColumnMerger.java | 2 +-
.../operator/process/merge/DescTimeComparator.java | 2 +-
.../operator/process/merge/MultiColumnMerger.java | 4 +-
.../operator/process/merge/SingleColumnMerger.java | 4 +-
.../operator/process/merge/TimeComparator.java | 2 +-
.../operator/schema/CountMergeOperator.java | 10 +-
.../operator/schema/DevicesCountOperator.java | 10 +-
.../operator/schema/DevicesSchemaScanOperator.java | 8 +-
.../schema/LevelTimeSeriesCountOperator.java | 10 +-
.../operator/schema/SchemaFetchOperator.java | 8 +-
.../operator/schema/SchemaMergeOperator.java | 10 +-
.../operator/schema/SchemaScanOperator.java | 8 +-
.../operator/schema/TimeSeriesCountOperator.java | 10 +-
.../schema/TimeSeriesSchemaScanOperator.java | 8 +-
.../operator/sink/FragmentSinkOperator.java | 4 +-
.../operator/sink/SinkOperator.java | 4 +-
.../operator/source/AlignedSeriesScanUtil.java | 4 +-
.../operator/source/DataSourceOperator.java | 2 +-
.../operator/source/ExchangeOperator.java | 8 +-
.../source/SeriesAggregateScanOperator.java | 8 +-
.../operator/source/SeriesScanOperator.java | 6 +-
.../operator/source/SeriesScanUtil.java | 27 +-
.../operator/source/SourceOperator.java | 6 +-
.../schedule/AbstractDriverThread.java | 6 +-
.../{ => execution}/schedule/DriverScheduler.java | 20 +-
.../{ => execution}/schedule/DriverTaskThread.java | 8 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 6 +-
.../{ => execution}/schedule/ExecutionContext.java | 4 +-
.../schedule/FragmentInstanceAbortedException.java | 4 +-
.../{ => execution}/schedule/IDriverScheduler.java | 7 +-
.../{ => execution}/schedule/ITaskScheduler.java | 6 +-
.../db/mpp/{ => execution}/schedule/queue/ID.java | 2 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 2 +-
.../schedule/queue/L1PriorityQueue.java | 2 +-
.../schedule/queue/L2PriorityQueue.java | 2 +-
.../{ => execution}/schedule/task/DriverTask.java | 14 +-
.../schedule/task/DriverTaskID.java | 4 +-
.../schedule/task/DriverTaskStatus.java | 2 +-
.../db/mpp/{execution => plan}/Coordinator.java | 15 +-
.../db/mpp/{sql => plan}/analyze/Analysis.java | 6 +-
.../db/mpp/{sql => plan}/analyze/Analyzer.java | 58 +-
.../analyze/ClusterPartitionFetcher.java | 2 +-
.../analyze/ClusterSchemaFetcher.java | 8 +-
.../analyze/FakePartitionFetcherImpl.java | 2 +-
.../analyze/FakeSchemaFetcherImpl.java | 2 +-
.../{sql => plan}/analyze/IPartitionFetcher.java | 2 +-
.../mpp/{sql => plan}/analyze/ISchemaFetcher.java | 2 +-
.../db/mpp/{sql => plan}/analyze/QueryType.java | 2 +-
.../mpp/{sql => plan}/analyze/SchemaValidator.java | 6 +-
.../analyze/StandalonePartitionFetcher.java | 2 +-
.../analyze/StandaloneSchemaFetcher.java | 2 +-
.../db/mpp/{sql => plan}/analyze/TypeProvider.java | 2 +-
.../mpp/{sql => plan}/constant/FilterConstant.java | 2 +-
.../mpp/{sql => plan}/constant/StatementType.java | 2 +-
.../mpp/{ => plan}/execution/ExecutionResult.java | 2 +-
.../mpp/{ => plan}/execution/IQueryExecution.java | 2 +-
.../mpp/{ => plan}/execution/QueryExecution.java | 37 +-
.../execution/config/AuthorizerConfigTask.java | 6 +-
.../execution/config/ConfigExecution.java | 10 +-
.../execution/config/ConfigTaskResult.java | 2 +-
.../execution/config/ConfigTaskVisitor.java | 16 +-
.../execution/config/CountStorageGroupTask.java | 4 +-
.../{ => plan}/execution/config/IConfigTask.java | 2 +-
.../execution/config/SetStorageGroupTask.java | 4 +-
.../execution/config/ShowStorageGroupTask.java | 4 +-
.../{sql => plan}/optimization/PlanOptimizer.java | 4 +-
.../db/mpp/{sql => plan}/parser/ASTVisitor.java | 341 +++++----
.../{sql => plan}/parser/StatementGenerator.java | 30 +-
.../{sql => plan}/planner/DistributionPlanner.java | 56 +-
.../planner/IFragmentParallelPlaner.java | 4 +-
.../planner/LocalExecutionPlanner.java | 120 +--
.../{sql => plan}/planner/LogicalPlanBuilder.java | 32 +-
.../mpp/{sql => plan}/planner/LogicalPlanner.java | 76 +-
.../planner/SimpleFragmentParallelPlanner.java | 20 +-
.../planner/WriteFragmentParallelPlanner.java | 14 +-
.../planner/plan/DistributedQueryPlan.java | 2 +-
.../planner/plan/FragmentInstance.java | 10 +-
.../planner/plan/LogicalQueryPlan.java | 4 +-
.../{sql => plan}/planner/plan/PlanFragment.java | 12 +-
.../db/mpp/{sql => plan}/planner/plan/SubPlan.java | 2 +-
.../planner/plan/node/PlanGraphPrinter.java | 12 +-
.../{sql => plan}/planner/plan/node/PlanNode.java | 2 +-
.../planner/plan/node/PlanNodeId.java | 2 +-
.../planner/plan/node/PlanNodeType.java | 70 +-
.../planner/plan/node/PlanNodeUtil.java | 2 +-
.../planner/plan/node/PlanVisitor.java | 66 +-
.../planner/plan/node/SimplePlanNodeRewriter.java | 2 +-
.../planner/plan/node/WritePlanNode.java | 4 +-
.../metedata/read/AbstractSchemaMergeNode.java | 8 +-
.../node/metedata/read/CountSchemaMergeNode.java | 10 +-
.../plan/node/metedata/read/DevicesCountNode.java | 8 +-
.../node/metedata/read/DevicesSchemaScanNode.java | 8 +-
.../metedata/read/LevelTimeSeriesCountNode.java | 8 +-
.../plan/node/metedata/read/SchemaFetchNode.java | 10 +-
.../plan/node/metedata/read/SchemaScanNode.java | 10 +-
.../node/metedata/read/SeriesSchemaMergeNode.java | 10 +-
.../node/metedata/read/TimeSeriesCountNode.java | 8 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 8 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 19 +-
.../write/CreateAlignedTimeSeriesNode.java | 14 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 25 +-
.../planner/plan/node/process/AggregationNode.java | 16 +-
.../planner/plan/node/process/DeviceMergeNode.java | 12 +-
.../planner/plan/node/process/DeviceViewNode.java | 12 +-
.../planner/plan/node/process/ExchangeNode.java | 12 +-
.../planner/plan/node/process/FillNode.java | 12 +-
.../planner/plan/node/process/FilterNode.java | 10 +-
.../planner/plan/node/process/FilterNullNode.java | 16 +-
.../plan/node/process/GroupByLevelNode.java | 16 +-
.../planner/plan/node/process/GroupByTimeNode.java | 16 +-
.../planner/plan/node/process/LimitNode.java | 10 +-
.../planner/plan/node/process/OffsetNode.java | 10 +-
.../planner/plan/node/process/ProcessNode.java | 6 +-
.../planner/plan/node/process/ProjectNode.java | 10 +-
.../planner/plan/node/process/SortNode.java | 12 +-
.../planner/plan/node/process/TimeJoinNode.java | 12 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 10 +-
.../planner/plan/node/sink/SinkNode.java | 6 +-
.../source/AlignedSeriesAggregationScanNode.java | 16 +-
.../plan/node/source/AlignedSeriesScanNode.java | 22 +-
.../node/source/SeriesAggregationScanNode.java | 16 +-
.../planner/plan/node/source/SeriesScanNode.java | 12 +-
.../planner/plan/node/source/SourceNode.java | 6 +-
.../planner/plan/node/write/BatchInsertNode.java | 2 +-
.../plan/node/write/InsertMultiTabletsNode.java | 12 +-
.../planner/plan/node/write/InsertNode.java | 6 +-
.../planner/plan/node/write/InsertRowNode.java | 12 +-
.../planner/plan/node/write/InsertRowsNode.java | 12 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 12 +-
.../planner/plan/node/write/InsertTabletNode.java | 12 +-
.../plan/parameter/AggregationDescriptor.java | 2 +-
.../planner/plan/parameter/AggregationStep.java | 2 +-
.../planner/plan/parameter/FillDescriptor.java | 4 +-
.../plan/parameter/FilterNullParameter.java | 4 +-
.../plan/parameter/GroupByTimeParameter.java | 2 +-
.../planner/plan/parameter/InputLocation.java | 2 +-
.../planner/plan/parameter/OutputColumn.java | 2 +-
.../rewriter/ColumnPaginationController.java | 4 +-
.../{sql => plan}/rewriter/ConcatPathRewriter.java | 8 +-
.../{sql => plan}/rewriter/DnfFilterOptimizer.java | 4 +-
.../{sql => plan}/rewriter/IFilterOptimizer.java | 2 +-
.../rewriter/MergeSingleFilterOptimizer.java | 2 +-
.../{sql => plan}/rewriter/RemoveNotOptimizer.java | 6 +-
.../{sql => plan}/rewriter/WildcardsRemover.java | 20 +-
.../scheduler/AbstractFragInsStateTracker.java | 6 +-
.../scheduler/ClusterScheduler.java | 10 +-
.../scheduler/FixedRateFragInsStateTracker.java | 6 +-
.../scheduler/FragInstanceDispatchResult.java | 2 +-
.../scheduler/IFragInstanceDispatcher.java | 4 +-
.../scheduler/IFragInstanceStateTracker.java | 2 +-
.../scheduler/IQueryTerminator.java | 2 +-
.../{execution => plan}/scheduler/IScheduler.java | 4 +-
.../scheduler/SimpleFragInstanceDispatcher.java | 4 +-
.../scheduler/SimpleQueryTerminator.java | 4 +-
.../scheduler/StandaloneScheduler.java | 8 +-
.../{sql => plan}/statement/IConfigStatement.java | 4 +-
.../db/mpp/{sql => plan}/statement/Statement.java | 6 +-
.../mpp/{sql => plan}/statement/StatementNode.java | 2 +-
.../{sql => plan}/statement/StatementVisitor.java | 60 +-
.../statement/component/FillComponent.java | 4 +-
.../statement/component/FillPolicy.java | 2 +-
.../statement/component/FilterNullComponent.java | 4 +-
.../statement/component/FilterNullPolicy.java | 2 +-
.../statement/component/FromComponent.java | 4 +-
.../statement/component/GroupByLevelComponent.java | 4 +-
.../component/GroupByLevelController.java | 6 +-
.../statement/component/GroupByTimeComponent.java | 4 +-
.../{sql => plan}/statement/component/OrderBy.java | 2 +-
.../statement/component/ResultColumn.java | 6 +-
.../statement/component/ResultSetFormat.java | 2 +-
.../statement/component/SelectComponent.java | 8 +-
.../statement/component/WhereCondition.java | 4 +-
.../statement/crud/AggregationQueryStatement.java | 12 +-
.../statement/crud/FillQueryStatement.java | 8 +-
.../statement/crud/GroupByFillQueryStatement.java | 6 +-
.../statement/crud/GroupByQueryStatement.java | 6 +-
.../statement/crud/InsertBaseStatement.java | 4 +-
.../crud/InsertMultiTabletsStatement.java | 4 +-
.../statement/crud/InsertRowStatement.java | 6 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 4 +-
.../statement/crud/InsertRowsStatement.java | 4 +-
.../statement/crud/InsertStatement.java | 8 +-
.../statement/crud/InsertTabletStatement.java | 4 +-
.../statement/crud/LastQueryStatement.java | 6 +-
.../statement/crud/QueryStatement.java | 24 +-
.../statement/crud/UDAFQueryStatement.java | 8 +-
.../statement/crud/UDTFQueryStatement.java | 4 +-
.../metadata/AlterTimeSeriesStatement.java | 8 +-
.../statement/metadata/CountDevicesStatement.java | 4 +-
.../metadata/CountLevelTimeSeriesStatement.java | 4 +-
.../statement/metadata/CountNodesStatement.java | 2 +-
.../statement/metadata/CountStatement.java | 4 +-
.../metadata/CountStorageGroupStatement.java | 8 +-
.../metadata/CountTimeSeriesStatement.java | 4 +-
.../metadata/CreateAlignedTimeSeriesStatement.java | 8 +-
.../metadata/CreateTimeSeriesStatement.java | 8 +-
.../statement/metadata/SchemaFetchStatement.java | 8 +-
.../metadata/SetStorageGroupStatement.java | 12 +-
.../statement/metadata/ShowDevicesStatement.java | 4 +-
.../statement/metadata/ShowStatement.java | 6 +-
.../metadata/ShowStorageGroupStatement.java | 8 +-
.../metadata/ShowTimeSeriesStatement.java | 4 +-
.../statement/sys/AuthorStatement.java | 12 +-
.../db/protocol/influxdb/handler/QueryHandler.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 2 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 9 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 316 ++++----
.../db/query/control/QueryResourceManager.java | 6 +-
.../groupby/GroupByWithValueFilterDataSet.java | 2 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 2 +-
.../db/query/executor/AggregationExecutor.java | 6 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 4 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 2 +-
.../db/query/executor/RawDataQueryExecutor.java | 4 +-
.../db/query/executor/fill/LastPointReader.java | 6 +-
.../iotdb/db/query/expression/Expression.java | 2 +-
.../query/expression/binary/BinaryExpression.java | 2 +-
.../db/query/expression/leaf/ConstantOperand.java | 2 +-
.../query/expression/leaf/TimeSeriesOperand.java | 2 +-
.../query/expression/multi/FunctionExpression.java | 2 +-
.../db/query/expression/unary/UnaryExpression.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 18 +-
.../query/timegenerator/ServerTimeGenerator.java | 2 +-
.../query/udf/core/layer/TsBlockInputDataSet.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 34 +-
.../service/thrift/impl/InternalServiceImpl.java | 14 +-
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 4 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 6 +-
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 4 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 4 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 4 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 6 +-
.../file/UnsealedTsFileRecoverPerformer.java | 4 +-
.../compaction/utils/CompactionCheckerUtils.java | 2 +-
.../utils/CompactionFileGeneratorUtils.java | 6 +-
.../db/engine/storagegroup/DataRegionTest.java | 4 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 2 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 71 +-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 24 +-
.../rocksdb/RocksDBBenchmarkEngine.java | 2 +-
.../db/mpp/execution/ConfigExecutionTest.java | 9 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 28 +-
.../db/mpp/execution/QueryStateMachineTest.java | 1 +
.../datatransfer/DataBlockManagerTest.java | 121 +++
.../datatransfer/LocalSinkHandleTest.java | 153 ++++
.../datatransfer/LocalSourceHandleTest.java | 119 +++
.../datatransfer/SharedTsBlockQueueTest.java | 160 ++++
.../datatransfer}/SinkHandleTest.java | 8 +-
.../datatransfer}/SourceHandleTest.java | 10 +-
.../datatransfer}/StubSinkHandle.java | 4 +-
.../{buffer => execution/datatransfer}/Utils.java | 10 +-
.../mpp/{ => execution}/memory/MemoryPoolTest.java | 2 +-
.../operator/DeviceViewOperatorTest.java | 14 +-
.../operator/LimitOperatorTest.java | 24 +-
.../operator/MultiColumnMergerTest.java | 6 +-
.../operator/SeriesAggregateScanOperatorTest.java | 18 +-
.../operator/SeriesScanOperatorTest.java | 12 +-
.../operator/SingleColumnMergerTest.java | 10 +-
.../operator/TimeJoinOperatorTest.java | 24 +-
.../operator/schema/CountMergeOperatorTest.java | 14 +-
.../operator/schema/SchemaCountOperatorTest.java | 14 +-
.../operator/schema/SchemaFetchOperatorTest.java | 2 +-
.../operator/schema/SchemaScanOperatorTest.java | 14 +-
.../schedule/DefaultTaskSchedulerTest.java | 10 +-
.../schedule/DriverSchedulerTest.java | 12 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 12 +-
.../schedule/queue/L1PriorityQueueTest.java | 2 +-
.../schedule/queue/L2PriorityQueueTest.java | 2 +-
.../schedule/queue/QueueElement.java | 2 +-
.../db/mpp/{sql => plan}/analyze/AnalyzerTest.java | 6 +-
.../mpp/{sql => plan}/parser/ASTVisitorTest.java | 2 +-
.../parser/StatementGeneratorTest.java | 6 +-
.../plan/DistributionPlannerTest.java | 36 +-
.../{sql => plan}/plan/FragmentInstanceIdTest.java | 2 +-
.../plan/FragmentInstanceSerdeTest.java | 26 +-
.../mpp/{sql => plan}/plan/LogicalPlannerTest.java | 68 +-
.../{sql => plan}/plan/QueryLogicalPlanUtil.java | 36 +-
.../mpp/{sql => plan}/plan/QueryPlannerTest.java | 16 +-
.../plan/node/PlanNodeDeserializeHelper.java | 6 +-
.../read/DeviceSchemaScanNodeSerdeTest.java | 18 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 16 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 18 +-
.../node/process/AggregationNodeSerdeTest.java | 18 +-
.../plan/node/process/DeviceViewNodeSerdeTest.java | 12 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 14 +-
.../plan/node/process/FillNodeSerdeTest.java | 16 +-
.../plan/node/process/FilterNodeSerdeTest.java | 12 +-
.../plan/node/process/FilterNullNodeSerdeTest.java | 14 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 18 +-
.../plan/node/process/LimitNodeSerdeTest.java | 14 +-
.../plan/node/process/OffsetNodeSerdeTest.java | 12 +-
.../plan/node/process/SortNodeSerdeTest.java | 12 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 12 +-
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 10 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 16 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 10 +-
.../write/InsertMultiTabletsNodeSerdeTest.java | 10 +-
.../plan/node/write/InsertRowNodeSerdeTest.java | 8 +-
.../plan/node/write/InsertRowsNodeSerdeTest.java | 10 +-
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 10 +-
.../plan/node/write/InsertTabletNodeSerdeTest.java | 8 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 6 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 2 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 2 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 2 +-
.../query/dataset/groupby/GroupByDataSetTest.java | 4 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 4 +-
.../iotdb/db/service/InternalServiceImplTest.java | 12 +-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 2 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 2 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 4 +-
.../tsfile/common/constant/TsFileConstant.java | 1 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 10 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 2 +-
.../read/controller/MetadataQuerierByFileImpl.java | 8 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 7 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 8 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 2 +-
.../apache/iotdb/tsfile/read/common/PathTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 6 +-
454 files changed, 6095 insertions(+), 3150 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/{service/balancer/LoadBalancer.java
=> manager/LoadManager.java} (88%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionIdentifierIT.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSyntaxConventionStringLiteralIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/versionadaption/IoTDBSyntaxConventionVersionAdaptionIT.java
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/DataBlockManager.java (76%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/DataBlockService.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/DataBlockServiceMBean.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/DataBlockServiceThriftHandler.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/IDataBlockManager.java (74%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/IDataBlockManagerCallback.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/ISinkHandle.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/ISourceHandle.java (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSourceHandle.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/datatransfer/SharedTsBlockQueue.java
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/SinkHandle.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/SourceHandle.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/TsBlockSerdeFactory.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/DataDriver.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/DataDriverContext.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/Driver.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/DriverContext.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/IDriver.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/SchemaDriver.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
driver}/SchemaDriverContext.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInfo.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceContext.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceExecution.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceFailureListener.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceInfo.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceManager.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceState.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentInstanceStateMachine.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/execution/{ =>
fragment}/FragmentState.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/memory/LocalMemoryManager.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/memory/MemoryPool.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/Operator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/OperatorContext.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/AggregateOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/DeviceViewOperator.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/FillOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/FilterNullOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/FilterOperator.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/GroupByLevelOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/LimitOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/OffsetOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/ProcessOperator.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/SortOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/TimeJoinOperator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/TransformOperator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/merge/AscTimeComparator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/merge/ColumnMerger.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/merge/DescTimeComparator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/merge/MultiColumnMerger.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/merge/SingleColumnMerger.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/process/merge/TimeComparator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/CountMergeOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/DevicesCountOperator.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/DevicesSchemaScanOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/LevelTimeSeriesCountOperator.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/SchemaFetchOperator.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/SchemaMergeOperator.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/SchemaScanOperator.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/TimeSeriesCountOperator.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/TimeSeriesSchemaScanOperator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/sink/FragmentSinkOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/sink/SinkOperator.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/AlignedSeriesScanUtil.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/DataSourceOperator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/ExchangeOperator.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/SeriesAggregateScanOperator.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/SeriesScanOperator.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/SeriesScanUtil.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/source/SourceOperator.java (82%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/AbstractDriverThread.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/DriverScheduler.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/DriverTaskThread.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/DriverTaskTimeoutSentinelThread.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/ExecutionContext.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/FragmentInstanceAbortedException.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/IDriverScheduler.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/ITaskScheduler.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/ID.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/IDIndexedAccessible.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/IndexedBlockingQueue.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/L1PriorityQueue.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/L2PriorityQueue.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/task/DriverTask.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/task/DriverTaskID.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/task/DriverTaskStatus.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/Coordinator.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/Analysis.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/Analyzer.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/ClusterPartitionFetcher.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/ClusterSchemaFetcher.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/FakePartitionFetcherImpl.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/FakeSchemaFetcherImpl.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/IPartitionFetcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/ISchemaFetcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/QueryType.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/SchemaValidator.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/StandalonePartitionFetcher.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/StandaloneSchemaFetcher.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/TypeProvider.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/constant/FilterConstant.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/constant/StatementType.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/ExecutionResult.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/IQueryExecution.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/QueryExecution.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/AuthorizerConfigTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/ConfigExecution.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/ConfigTaskResult.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/ConfigTaskVisitor.java (80%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/CountStorageGroupTask.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/IConfigTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/SetStorageGroupTask.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{ =>
plan}/execution/config/ShowStorageGroupTask.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/optimization/PlanOptimizer.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/parser/ASTVisitor.java (87%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/parser/StatementGenerator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/DistributionPlanner.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/IFragmentParallelPlaner.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/LocalExecutionPlanner.java (81%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/LogicalPlanBuilder.java (84%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/LogicalPlanner.java (83%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/SimpleFragmentParallelPlanner.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/WriteFragmentParallelPlanner.java (85%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/DistributedQueryPlan.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/FragmentInstance.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/LogicalQueryPlan.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/PlanFragment.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/SubPlan.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/PlanGraphPrinter.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/PlanNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/PlanNodeId.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/PlanNodeType.java (64%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/PlanNodeUtil.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/PlanVisitor.java (62%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/SimplePlanNodeRewriter.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/WritePlanNode.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/AbstractSchemaMergeNode.java (84%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/CountSchemaMergeNode.java (82%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/DevicesCountNode.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/DevicesSchemaScanNode.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/LevelTimeSeriesCountNode.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/SchemaFetchNode.java (86%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/SchemaScanNode.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/SeriesSchemaMergeNode.java (83%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/TimeSeriesCountNode.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/read/TimeSeriesSchemaScanNode.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/write/AlterTimeSeriesNode.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/metedata/write/CreateTimeSeriesNode.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/AggregationNode.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/DeviceMergeNode.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/DeviceViewNode.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/ExchangeNode.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/FillNode.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/FilterNode.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/FilterNullNode.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/GroupByLevelNode.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/GroupByTimeNode.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/LimitNode.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/OffsetNode.java (89%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/ProcessNode.java (82%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/ProjectNode.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/SortNode.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/process/TimeJoinNode.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/sink/FragmentSinkNode.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/sink/SinkNode.java (83%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/source/AlignedSeriesAggregationScanNode.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/source/AlignedSeriesScanNode.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/source/SeriesAggregationScanNode.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/source/SeriesScanNode.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/source/SourceNode.java (86%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/BatchInsertNode.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/InsertMultiTabletsNode.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/InsertNode.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/InsertRowNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/InsertRowsNode.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/InsertRowsOfOneDeviceNode.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/node/write/InsertTabletNode.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/AggregationDescriptor.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/AggregationStep.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/FillDescriptor.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/FilterNullParameter.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/GroupByTimeParameter.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/InputLocation.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/planner/plan/parameter/OutputColumn.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/ColumnPaginationController.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/ConcatPathRewriter.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/DnfFilterOptimizer.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/IFilterOptimizer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/MergeSingleFilterOptimizer.java (99%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/RemoveNotOptimizer.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/rewriter/WildcardsRemover.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/AbstractFragInsStateTracker.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/ClusterScheduler.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/FixedRateFragInsStateTracker.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/FragInstanceDispatchResult.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/IFragInstanceDispatcher.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/IFragInstanceStateTracker.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/IQueryTerminator.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/IScheduler.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/SimpleFragInstanceDispatcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/SimpleQueryTerminator.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{execution =>
plan}/scheduler/StandaloneScheduler.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/IConfigStatement.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/Statement.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/StatementNode.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/StatementVisitor.java (73%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/FillComponent.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/FillPolicy.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/FilterNullComponent.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/FilterNullPolicy.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/FromComponent.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/GroupByLevelComponent.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/GroupByLevelController.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/GroupByTimeComponent.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/OrderBy.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/ResultColumn.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/ResultSetFormat.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/SelectComponent.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/component/WhereCondition.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/AggregationQueryStatement.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/FillQueryStatement.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/GroupByFillQueryStatement.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/GroupByQueryStatement.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertBaseStatement.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertMultiTabletsStatement.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertRowStatement.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertRowsOfOneDeviceStatement.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertRowsStatement.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertStatement.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/InsertTabletStatement.java (96%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/LastQueryStatement.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/QueryStatement.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/UDAFQueryStatement.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/crud/UDTFQueryStatement.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/AlterTimeSeriesStatement.java (92%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CountDevicesStatement.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CountLevelTimeSeriesStatement.java (91%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CountNodesStatement.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CountStatement.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CountStorageGroupStatement.java (84%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CountTimeSeriesStatement.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CreateAlignedTimeSeriesStatement.java (95%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/CreateTimeSeriesStatement.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/SchemaFetchStatement.java (88%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/SetStorageGroupStatement.java (83%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/ShowDevicesStatement.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/ShowStatement.java (90%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/ShowStorageGroupStatement.java (87%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/metadata/ShowTimeSeriesStatement.java (94%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{sql =>
plan}/statement/sys/AuthorStatement.java (93%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/DataBlockManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSinkHandleTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/LocalSourceHandleTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/datatransfer/SharedTsBlockQueueTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/SinkHandleTest.java (98%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/SourceHandleTest.java (98%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/StubSinkHandle.java (94%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{buffer =>
execution/datatransfer}/Utils.java (92%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/memory/MemoryPoolTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/DeviceViewOperatorTest.java (93%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/LimitOperatorTest.java (89%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/MultiColumnMergerTest.java (97%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/SeriesAggregateScanOperatorTest.java (96%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/SeriesScanOperatorTest.java (92%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/SingleColumnMergerTest.java (95%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/TimeJoinOperatorTest.java (95%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/CountMergeOperatorTest.java (93%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/SchemaCountOperatorTest.java (94%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/SchemaFetchOperatorTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/operator/schema/SchemaScanOperatorTest.java (95%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/DefaultTaskSchedulerTest.java (98%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/DriverSchedulerTest.java (95%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/DriverTaskTimeoutSentinelThreadTest.java (97%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/L1PriorityQueueTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/L2PriorityQueueTest.java (99%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{ =>
execution}/schedule/queue/QueueElement.java (97%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/analyze/AnalyzerTest.java (91%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/parser/ASTVisitorTest.java (96%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/parser/StatementGeneratorTest.java (93%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/DistributionPlannerTest.java (94%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/FragmentInstanceIdTest.java (97%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/FragmentInstanceSerdeTest.java (88%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/LogicalPlannerTest.java (86%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/QueryLogicalPlanUtil.java (95%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/QueryPlannerTest.java (86%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/PlanNodeDeserializeHelper.java (87%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/metadata/read/DeviceSchemaScanNodeSerdeTest.java (80%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/metadata/read/SchemaCountNodeSerdeTest.java (86%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/metadata/read/TimeSeriesSchemaScanNodeSerdeTest.java (80%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/AggregationNodeSerdeTest.java (84%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/DeviceViewNodeSerdeTest.java (82%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/ExchangeNodeSerdeTest.java (82%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/FillNodeSerdeTest.java (77%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/FilterNodeSerdeTest.java (83%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/FilterNullNodeSerdeTest.java (79%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/GroupByLevelNodeSerdeTest.java (86%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/LimitNodeSerdeTest.java (83%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/OffsetNodeSerdeTest.java (84%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/SortNodeSerdeTest.java (85%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/process/TimeJoinNodeSerdeTest.java (87%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/sink/FragmentSinkNodeSerdeTest.java (84%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/source/SeriesAggregationScanNodeSerdeTest.java (84%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/source/SeriesScanNodeSerdeTest.java (87%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/write/InsertMultiTabletsNodeSerdeTest.java (90%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/write/InsertRowNodeSerdeTest.java (96%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/write/InsertRowsNodeSerdeTest.java (87%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/write/InsertRowsOfOneDeviceNodeSerdeTest.java (88%)
rename server/src/test/java/org/apache/iotdb/db/mpp/{sql =>
plan}/plan/node/write/InsertTabletNodeSerdeTest.java (95%)
