You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/03/29 11:00:06 UTC
[iotdb] branch ty-mpp-2 updated (f06fb77 -> bd3fa42)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty-mpp-2
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f06fb77 add UT for LimitOperator
add c6e47b9 [IOTDB-2671][metrics] Improve the implementation of iotdbReporter (#5338)
add 1705a8a [IOTDB-2679] Support logical operators in select clauses (#5273)
add bbfa720 [IOTDB-2803] adapt metadata write operation to plannode (#5344)
add b103385 Add SchemaRegion Interfaces to SchemaEngine (#5349)
add 5404730 Rename SchemaEngine to LocalSchemaProcessor and Rename SchemaRegionManager to SchemaEngine (#5359)
add 0f21cef Fix typos in mpp.thrift (#5360)
add 27f2b96 [IOTDB-2713] Generate Analysis for query statement (#5343)
add 4a70fba [IOTDB-2658] Generate logical plan for query statement (#5356)
add bcd53d7 [IOTDB-2810] Design and implementation of TsBlock and its builder (#5362)
add bd3fa42 resolve conflicts
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 47 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 3 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 8 +-
.../iotdb/cluster/coordinator/Coordinator.java | 10 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 8 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 6 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 2 +-
.../log/manage/PartitionedSnapshotLogManager.java | 4 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 4 +-
.../{CSchemaEngine.java => CSchemaProcessor.java} | 30 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 10 +-
.../iotdb/cluster/partition/PartitionTable.java | 4 +-
.../cluster/query/ClusterPhysicalGenerator.java | 8 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 22 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 17 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 31 +-
.../iotdb/cluster/query/filter/SlotSgFilter.java | 2 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 4 +-
.../cluster/server/member/DataGroupMember.java | 6 +-
.../cluster/server/member/MetaGroupMember.java | 2 +-
.../cluster/server/service/DataAsyncService.java | 15 +-
.../cluster/server/service/DataSyncService.java | 12 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 2 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +-
.../log/applier/AsyncDataLogApplierTest.java | 6 +-
.../cluster/log/applier/DataLogApplierTest.java | 13 +-
.../cluster/log/applier/MetaLogApplierTest.java | 6 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 4 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 2 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 12 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 4 +-
.../log/snapshot/PartitionedSnapshotTest.java | 5 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 3 +-
...eWhiteBox.java => SchemaProcessorWhiteBox.java} | 20 +-
.../cluster/partition/SlotPartitionTableTest.java | 28 +-
.../cluster/query/ClusterPlanExecutorTest.java | 2 +-
.../clusterinfo/ClusterInfoServiceImplTest.java | 4 +-
.../iotdb/cluster/server/member/BaseMember.java | 10 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 22 +-
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +-
docs/UserGuide/Query-Data/Select-Expression.md | 85 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 14 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 80 +-
.../iotdb/db/integration/IoTDBArithmeticIT.java | 18 +-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 4 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 14 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 35 -
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 12 +-
.../IoTDBSelectCompareExpressionIT.java | 482 +++++++++++
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 18 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 8 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 26 +-
.../db/integration/IoTDBTriggerManagementIT.java | 8 +-
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 6 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 4 +-
metrics/dropwizard-metrics/pom.xml | 1 -
.../iotdb/metrics/dropwizard/MetricName.java | 33 +-
.../reporter/DropwizardIoTDBReporter.java | 5 +-
.../reporter/DropwizardMetricsExporter.java | 36 +-
.../metrics/dropwizard/reporter/IoTDBReporter.java | 204 +++--
.../org.apache.iotdb.metrics.reporter.Reporter | 3 +-
metrics/interface/pom.xml | 5 +
.../main/assembly/resources/conf/iotdb-metric.yml | 14 +-
.../org/apache/iotdb/metrics/MetricService.java | 22 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 133 ++-
.../iotdb/metrics/reporter/CompositeReporter.java | 14 +-
.../apache/iotdb/metrics/utils/MetricsUtils.java | 33 +-
.../interface/src/test/resources/iotdb-metric.yml | 14 +-
.../micrometer/reporter}/IoTDBMeterRegistry.java | 114 +--
.../micrometer/reporter}/IoTDBRegistryConfig.java | 7 +-
.../{IoTDBJmxConfig.java => JmxConfig.java} | 6 +-
.../reporter/MicrometerIoTDBReporter.java | 4 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 2 +-
.../org.apache.iotdb.metrics.reporter.Reporter | 3 +-
.../iotdb/commons/partition/SchemaRegionId.java | 23 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 21 +-
.../db/engine/compaction/CompactionUtils.java | 4 +-
.../inner/utils/InnerSpaceCompactionUtils.java | 2 +-
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 2 +-
.../storagegroup/VirtualStorageGroupProcessor.java | 14 +-
.../service/TriggerRegistrationService.java | 2 +-
.../trigger/sink/local/LocalIoTDBHandler.java | 6 +-
.../iotdb/db/metadata/LocalConfigManager.java | 783 +++++++++++++++++
.../db/metadata/LocalSchemaPartitionTable.java | 121 +++
...SchemaEngine.java => LocalSchemaProcessor.java} | 673 ++++-----------
.../apache/iotdb/db/metadata/MetadataConstant.java | 1 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 10 +-
.../iotdb/db/metadata/idtable/IDTableManager.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 2 +-
.../db/metadata/lastCache/LastCacheManager.java | 6 +-
.../db/metadata/mnode/IStorageGroupMNode.java | 6 -
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 9 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 17 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 18 -
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 78 +-
.../iotdb/db/metadata/mtree/MTreeBelowSG.java | 75 +-
.../traverser/collector/MNodeAboveSGCollector.java | 9 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../counter/MNodeAboveSGLevelCounter.java | 9 +-
.../db/metadata/schemaregion/SchemaEngine.java | 82 ++
.../metadata/{ => schemaregion}/SchemaRegion.java | 188 +++--
.../IStorageGroupSchemaManager.java | 56 +-
.../storagegroup/StorageGroupLogReader.java | 28 +-
.../storagegroup/StorageGroupLogWriter.java | 56 ++
.../StorageGroupSchemaManager.java | 189 +++--
.../iotdb/db/metadata/template/Template.java | 33 +-
.../db/metadata/template/TemplateManager.java | 56 +-
.../db/metadata/upgrade/MetadataUpgrader.java | 66 +-
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 4 +-
.../db/mpp/common/schematree/PathPatternNode.java | 68 +-
.../db/mpp/common/schematree/PathPatternTree.java | 104 ++-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 19 +-
.../execution/scheduler/StandaloneScheduler.java | 4 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 4 +
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 28 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 89 +-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 11 -
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 8 -
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 11 -
.../iotdb/db/mpp/sql/constant/FilterConstant.java | 3 +-
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 108 ++-
.../db/mpp/sql/planner/DistributionPlanner.java | 19 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 15 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 213 ++++-
.../sql/planner/plan/node/PlanNodeIdAllocator.java | 7 +
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 18 +-
.../db/mpp/sql/planner/plan/node/PlanVisitor.java | 16 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 139 +++
.../write/CreateAlignedTimeSeriesNode.java} | 131 ++-
.../node/metedata/write/CreateTimeSeriesNode.java | 1 -
.../planner/plan/node/process/DeviceMergeNode.java | 17 +-
.../sql/planner/plan/node/process/FillNode.java | 20 +-
.../sql/planner/plan/node/process/FilterNode.java | 22 +-
.../planner/plan/node/process/FilterNullNode.java | 29 +-
.../plan/node/process/GroupByLevelNode.java | 21 +-
.../sql/planner/plan/node/process/LimitNode.java | 11 +
.../sql/planner/plan/node/process/OffsetNode.java | 11 +
.../sql/planner/plan/node/process/SortNode.java | 15 +
.../planner/plan/node/process/TimeJoinNode.java | 23 +-
.../planner/plan/node/source/CsvSourceNode.java | 10 +
.../plan/node/source/SeriesAggregateScanNode.java | 21 +
.../planner/plan/node/source/SeriesScanNode.java | 30 +
.../sql/planner/plan/node/source/SourceNode.java | 22 +
.../sql/rewriter/ColumnPaginationController.java | 101 +++
.../db/mpp/sql/rewriter/ConcatPathRewriter.java | 308 ++-----
.../db/mpp/sql/rewriter/IStatementRewriter.java | 33 -
.../db/mpp/sql/rewriter/WildcardsRemover.java | 339 ++++++--
.../iotdb/db/mpp/sql/statement/StatementNode.java | 2 -
.../sql/{tree => statement}/StatementVisitor.java | 18 +-
.../statement/component}/FillPolicy.java | 2 +-
.../statement/component/FilterNullComponent.java | 8 +-
.../statement/component}/FilterNullPolicy.java | 2 +-
.../statement/component/GroupByLevelComponent.java | 6 +
.../component/GroupByLevelController.java | 10 +-
.../mpp/sql/statement/component/ResultColumn.java | 11 +-
.../sql/statement/component/SelectComponent.java | 21 +-
.../db/mpp/sql/statement/crud/InsertStatement.java | 2 +-
.../db/mpp/sql/statement/crud/QueryStatement.java | 2 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 2 +-
.../metadata/AlterTimeSeriesStatement.java | 119 +++
.../metadata/CreateAlignedTimeSeriesStatement.java | 17 +-
.../metadata/CreateTimeSeriesStatement.java | 2 +-
.../apache/iotdb/db/mpp/sql/tree/Expression.java | 21 -
.../iotdb/db/qp/constant/FilterConstant.java | 3 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 91 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 4 +-
.../iotdb/db/qp/logical/crud/SelectComponent.java | 4 +-
.../db/qp/logical/crud/UDAFQueryOperator.java | 4 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 3 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 38 +
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 3 +-
.../iotdb/db/qp/utils/GroupByLevelController.java | 4 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 4 +-
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 2 +-
.../db/query/dataset/ShowTimeseriesDataSet.java | 2 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 16 +-
.../iotdb/db/query/expression/Expression.java | 12 +-
.../query/expression/binary/BinaryExpression.java | 53 +-
.../binary/EqualToExpression.java} | 21 +-
.../binary/GreaterEqualExpression.java} | 23 +-
.../binary/GreaterThanExpression.java} | 22 +-
.../binary/LessEqualExpression.java} | 22 +-
.../binary/LessThanExpression.java} | 22 +-
.../binary/LogicAndExpression.java} | 21 +-
.../binary/LogicOrExpression.java} | 21 +-
.../binary/NonEqualExpression.java} | 22 +-
.../db/query/expression/unary/ConstantOperand.java | 15 +
.../query/expression/unary/FunctionExpression.java | 56 +-
...tionExpression.java => LogicNotExpression.java} | 54 +-
.../query/expression/unary/NegationExpression.java | 21 +-
.../query/expression/unary/TimeSeriesOperand.java | 23 +-
.../transformer/ArithmeticAdditionTransformer.java | 2 +-
.../transformer/ArithmeticBinaryTransformer.java | 98 +--
.../transformer/ArithmeticDivisionTransformer.java | 2 +-
.../transformer/ArithmeticModuloTransformer.java | 2 +-
.../ArithmeticMultiplicationTransformer.java | 2 +-
.../ArithmeticSubtractionTransformer.java | 2 +-
...naryTransformer.java => BinaryTransformer.java} | 77 +-
...nsformer.java => CompareBinaryTransformer.java} | 14 +-
...sformer.java => CompareEqualToTransformer.java} | 13 +-
...er.java => CompareGreaterEqualTransformer.java} | 8 +-
...mer.java => CompareGreaterThanTransformer.java} | 8 +-
...ormer.java => CompareLessEqualTransformer.java} | 8 +-
...former.java => CompareLessThanTransformer.java} | 8 +-
...former.java => CompareNonEqualTransformer.java} | 13 +-
...loTransformer.java => LogicAndTransformer.java} | 9 +-
...ransformer.java => LogicBinaryTransformer.java} | 15 +-
.../udf/core/transformer/LogicNotTransformer.java | 66 ++
...uloTransformer.java => LogicOrTransformer.java} | 9 +-
.../iotdb/db/service/InternalServiceImpl.java | 13 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 19 +-
.../iotdb/db/service/metrics/MetricsService.java | 4 +-
.../db/service/thrift/impl/TSServiceImpl.java | 20 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 2 +-
.../db/sync/sender/manage/SyncFileManager.java | 2 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 11 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 4 +-
.../org.apache.iotdb.metrics.reporter.Reporter | 19 -
.../iotdb/db/engine/MetadataManagerHelper.java | 48 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 8 +-
.../engine/compaction/AbstractCompactionTest.java | 10 +-
.../engine/compaction/CompactionSchedulerTest.java | 64 +-
.../compaction/TestUtilsForAlignedSeries.java | 6 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 8 +-
.../db/engine/compaction/cross/MergeTest.java | 8 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 8 +-
.../inner/InnerCompactionMoreDataTest.java | 4 +-
.../compaction/inner/InnerCompactionTest.java | 8 +-
.../compaction/inner/InnerSeqCompactionTest.java | 8 +-
.../InnerSpaceCompactionUtilsAlignedTest.java | 4 +-
.../InnerSpaceCompactionUtilsNoAlignedTest.java | 6 +-
.../compaction/inner/InnerUnseqCompactionTest.java | 8 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 8 +-
.../recover/SizeTieredCompactionRecoverTest.java | 8 +-
.../engine/modification/DeletionFileNodeTest.java | 4 +-
.../db/engine/modification/DeletionQueryTest.java | 4 +-
.../storagegroup/FileNodeManagerBenchmark.java | 8 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 16 +-
...neAdvancedTest.java => SchemaAdvancedTest.java} | 72 +-
...maEngineBasicTest.java => SchemaBasicTest.java} | 930 +++++++++++----------
...gineImproveTest.java => SchemaImproveTest.java} | 51 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 117 +--
.../iotdb/db/metadata/idtable/IDTableTest.java | 70 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 18 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 8 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 4 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 24 +-
.../iotdb/db/mpp/common/PathPatternTreeTest.java | 131 +++
.../db/mpp/operator/SeriesScanOperatorTest.java | 2 +-
.../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 10 +-
.../db/mpp/sql/parser/StatementGeneratorTest.java | 4 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 10 +-
.../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 219 +++++
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 288 ++++++-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 34 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 4 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 18 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 12 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 10 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 12 +-
.../iotdb/db/qp/physical/SerializationTest.java | 14 +-
.../dataset/EngineDataSetWithValueFilterTest.java | 2 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 14 +-
.../query/dataset/groupby/GroupByDataSetTest.java | 2 +-
.../dataset/groupby/GroupByFillDataSetTest.java | 2 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 2 +-
.../query/reader/series/SeriesReaderTestUtil.java | 8 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 8 +-
.../db/sync/receiver/load/FileLoaderTest.java | 11 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 11 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 2 +-
.../sender/recover/SyncSenderLogAnalyzerTest.java | 2 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 123 ++-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 8 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 10 +-
.../db/writelog/recover/DeviceStringTest.java | 12 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 4 +-
.../recover/RecoverResourceFromReaderTest.java | 8 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 8 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 8 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 4 +-
thrift/src/main/thrift/mpp.thrift | 16 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 4 +-
289 files changed, 7034 insertions(+), 3429 deletions(-)
rename cluster/src/main/java/org/apache/iotdb/cluster/metadata/{CSchemaEngine.java => CSchemaProcessor.java} (98%)
rename cluster/src/test/java/org/apache/iotdb/cluster/partition/{SchemaEngineWhiteBox.java => SchemaProcessorWhiteBox.java} (67%)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectCompareExpressionIT.java
rename {server/src/main/java/org/apache/iotdb/db => metrics/dropwizard-metrics/src/main/java/org/apache/iotdb}/metrics/dropwizard/reporter/DropwizardIoTDBReporter.java (92%)
rename {server/src/main/java/org/apache/iotdb/db => metrics/dropwizard-metrics/src/main/java/org/apache/iotdb}/metrics/dropwizard/reporter/IoTDBReporter.java (53%)
rename server/src/main/java/org/apache/iotdb/db/metrics/metricsUtils.java => metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricsUtils.java (69%)
rename {server/src/main/java/org/apache/iotdb/db/metrics/micrometer/registry => metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter}/IoTDBMeterRegistry.java (60%)
rename {server/src/main/java/org/apache/iotdb/db/metrics/micrometer/registry => metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter}/IoTDBRegistryConfig.java (85%)
copy metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/{IoTDBJmxConfig.java => JmxConfig.java} (88%)
rename {server/src/main/java/org/apache/iotdb/db => metrics/micrometer-metrics/src/main/java/org/apache/iotdb}/metrics/micrometer/reporter/MicrometerIoTDBReporter.java (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalConfigManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/LocalSchemaPartitionTable.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{SchemaEngine.java => LocalSchemaProcessor.java} (67%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/schemaregion/SchemaEngine.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => schemaregion}/SchemaRegion.java (91%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => storagegroup}/IStorageGroupSchemaManager.java (82%)
rename metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/reporter/IoTDBJmxConfig.java => server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupLogReader.java (57%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/storagegroup/StorageGroupLogWriter.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{ => storagegroup}/StorageGroupSchemaManager.java (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AlterTimeSeriesNode.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/{statement/metadata/CreateAlignedTimeSeriesStatement.java => planner/plan/node/metedata/write/CreateAlignedTimeSeriesNode.java} (54%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/ColumnPaginationController.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/rewriter/IStatementRewriter.java
rename server/src/main/java/org/apache/iotdb/db/mpp/sql/{tree => statement}/StatementVisitor.java (80%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{common => sql/statement/component}/FillPolicy.java (93%)
rename server/src/main/java/org/apache/iotdb/db/mpp/{common => sql/statement/component}/FilterNullPolicy.java (93%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/metadata/AlterTimeSeriesStatement.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/tree/Expression.java
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/EqualToExpression.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/GreaterEqualExpression.java} (52%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/GreaterThanExpression.java} (52%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/LessEqualExpression.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/LessThanExpression.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/LogicAndExpression.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/LogicOrExpression.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/query/{udf/core/transformer/ArithmeticMultiplicationTransformer.java => expression/binary/NonEqualExpression.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/query/expression/unary/{NegationExpression.java => LogicNotExpression.java} (80%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticBinaryTransformer.java => BinaryTransformer.java} (61%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => CompareBinaryTransformer.java} (75%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => CompareEqualToTransformer.java} (75%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => CompareGreaterEqualTransformer.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticAdditionTransformer.java => CompareGreaterThanTransformer.java} (80%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticAdditionTransformer.java => CompareLessEqualTransformer.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticAdditionTransformer.java => CompareLessThanTransformer.java} (81%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => CompareNonEqualTransformer.java} (75%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => LogicAndTransformer.java} (76%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => LogicBinaryTransformer.java} (76%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/LogicNotTransformer.java
copy server/src/main/java/org/apache/iotdb/db/query/udf/core/transformer/{ArithmeticModuloTransformer.java => LogicOrTransformer.java} (76%)
delete mode 100644 server/src/main/resources/META-INF/services/org.apache.iotdb.metrics.reporter.Reporter
rename server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineAdvancedTest.java => SchemaAdvancedTest.java} (76%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineBasicTest.java => SchemaBasicTest.java} (68%)
rename server/src/test/java/org/apache/iotdb/db/metadata/{SchemaEngineImproveTest.java => SchemaImproveTest.java} (78%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/common/PathPatternTreeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java