You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/05/20 02:47:01 UTC
[iotdb] branch alignedAggregateScanOp updated (9755bee74e -> d7c64e8b44)
This is an automated email from the ASF dual-hosted git repository.
xiangweiwei pushed a change to branch alignedAggregateScanOp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 9755bee74e add methods in localExecutionPlanner
add b8b17bb265 spotless apply
add b0d58269b3 [IOTDB-3210]fix npe (#5932)
add c0529f57aa fix a bug for system.properties (#5933)
add 7042883fc0 [IOTDB-3219] fix stop-server on windows (#5936)
add b8cd0c2cc0 Avoild using symlink when pack all-in-one package (#5935)
add f4e458178c [IOTDB-3073][IOTDB-3095] Unescape identifier and Use antlr to parse PartialPath/Path (#5848)
add 0378bbe78a [IOTDB-3144][IOTDB-3130][IOTDB-3133] Set the default pipe status of receiver after reboot to STOP (#5859)
add 71e9389e95 [IOTDB-3196] Add wal read interface for consensus group (#5931)
add 0a00929135 Fix confignode script error (#5942)
add 1055a4030f [IOTDB-3200] [PartitionInfo] replace bytebuffer with stream (#5921)
add 80475f77d0 [IOTDB-3213] Apply visitor pattern for DataRegionStateMachine (#5944)
add 05fc9f5421 [IOTDB-3024] Implement SchemaRegion Memory mode snapshot (#5925)
add f78e90fdbd Add distribution plan logic for AlignedSeriesScan (#5941)
add 3e63945619 [IOTDB-3196] Add search index in InsertNode (#5945)
add 406a79f08c [IOTDB-3101] definition of attributekey and attributevalue (#5888)
add def4fb0fae Modify the serialize/deserialize of MTreeAboveSG with stream & Add storageGroupNode to the result of MNodeAboveSGCollector (#5947)
add 1ebeac5b6a [IOTDB-2977] Take and load snapshot for DataRegionStateMachine (#5923)
add eaeb42bee4 [IOTDB-3163] Refactor compaction memory estimator frame and add new estimator of RewriteCrossCompaction (#5868)
add 81b91176a0 add internal port compare when dispatching locally (#5954)
add b724afb4b2 [IOTDB-3238] Fix cannot insert data into data node (#5956)
add dd1a28c58d [IOTDB-3214] Refact predefined metrics in metric framework. (#5930)
add 271148e072 Print file name while meeting error in reading or deserializing (#5959)
add 854d945850 remove dataOutputStream (#5946)
add 5ce066c37b [IOTDB-3239] fix missing aligned data (#5960)
add eb4300c9fb [IOTDB-3038] Implementation of fill operator (#5837)
add d7c64e8b44 merge master
No new revisions were added by this update.
Summary of changes:
LICENSE | 18 +-
antlr/pom.xml | 1 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 179 ++++++++
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 14 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +-
.../org/apache/iotdb/db/qp/sql/PathParser.g4 | 40 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +-
cli/src/assembly/resources/sbin/start-cli.bat | 2 +-
cli/src/assembly/resources/sbin/start-cli.sh | 8 +-
client-py/tests/test_dataframe.py | 10 +-
.../log/manage/PartitionedSnapshotLogManager.java | 4 +-
.../server/handlers/caller/ElectionHandler.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 4 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 2 +-
.../assembly/resources/sbin/start-confignode.bat | 2 +-
.../assembly/resources/sbin/start-confignode.sh | 8 +-
.../assembly/resources/sbin/stop-confignode.bat | 2 +-
.../confignode/persistence/ClusterSchemaInfo.java | 27 +-
.../iotdb/confignode/persistence/NodeInfo.java | 58 ++-
.../confignode/persistence/PartitionInfo.java | 108 ++---
.../executor/ConfigRequestExecutor.java | 16 +-
.../persistence/ClusterSchemaInfoTest.java | 2 +-
.../confignode/persistence/PartitionInfoTest.java | 33 +-
.../iotdb/consensus/wal/ConsensusReqReader.java | 86 ++++
distribution/pom.xml | 22 -
distribution/src/assembly/cluster.xml | 81 ----
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 205 ++++-----
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 206 ++++-----
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../db/integration/IoTDBContinuousQueryIT.java | 42 ++
.../db/integration/IoTDBCreateTimeseriesIT.java | 2 +-
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 2 +-
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 2 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 4 +-
.../iotdb/db/integration/IoTDBSnapshotIT.java | 259 +++++++++++
.../IoTDBSyntaxConventionIdentifierIT.java | 160 ++++++-
.../iotdb/db/integration/IoTDBTagAlterIT.java | 4 +-
.../db/integration/sync/IoTDBSyncReceiverIT.java | 32 +-
.../IoTDBWithoutNullAnyFilterIT.java | 10 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 8 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 8 +-
.../session/IoTDBSessionSyntaxConventionIT.java | 18 +-
.../java/org/apache/iotdb/session/SessionTest.java | 28 +-
.../apache/iotdb/session/template/TemplateUT.java | 14 +-
.../dropwizard/DropwizardMetricManager.java | 32 --
.../main/assembly/resources/conf/iotdb-metric.yml | 5 +-
.../iotdb/metrics/DoNothingMetricService.java | 14 +-
.../org/apache/iotdb/metrics/MetricManager.java | 8 -
.../org/apache/iotdb/metrics/MetricService.java | 21 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 3 +-
.../iotdb/metrics/impl/DoNothingMetricManager.java | 4 -
.../IMetricSet.java} | 17 +-
.../predefined/jvm/JvmClassLoaderMetrics.java | 52 +++
.../metrics/predefined/jvm/JvmCompileMetrics.java | 50 ++
.../iotdb/metrics/predefined/jvm/JvmGcMetrics.java | 292 ++++++++++++
.../metrics/predefined/jvm/JvmMemoryMetrics.java | 105 +++++
.../iotdb/metrics/predefined/jvm/JvmMetrics.java | 49 ++
.../metrics/predefined/jvm/JvmThreadMetrics.java | 87 ++++
.../metrics/predefined/logback/LogbackMetrics.java | 180 ++++++++
.../utils/{PredefinedMetric.java => JvmUtils.java} | 28 +-
.../iotdb/metrics/utils/PredefinedMetric.java | 5 +-
.../micrometer/MicrometerMetricManager.java | 51 --
node-commons/pom.xml | 5 +
.../iotdb/commons/partition/DataPartition.java | 113 +++--
.../iotdb/commons/partition/SchemaPartition.java | 64 ++-
.../org/apache/iotdb/commons/path/PartialPath.java | 51 +-
.../org/apache/iotdb/commons/utils/PathUtils.java | 78 +---
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 34 ++
.../iotdb/commons/partition/DataPartitionTest.java | 20 +-
.../commons/partition/SchemaPartitionTest.java | 19 +-
.../apache/iotdb/commons/path/PartialPathTest.java | 511 +++++++++++++++++++++
.../apache/iotdb/commons/utils/PathUtilsTest.java | 125 -----
.../schemaregion/rocksdb/RSchemaRegion.java | 22 +-
.../schemaregion/rocksdb/RSchemaUtils.java | 2 +-
server/pom.xml | 5 -
.../assembly/resources/sbin/remove-datanode.bat | 2 +-
.../src/assembly/resources/sbin/remove-datanode.sh | 8 +-
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../src/assembly/resources/sbin/start-datanode.sh | 8 +-
.../src/assembly/resources/sbin/start-server.bat | 2 +-
server/src/assembly/resources/sbin/start-server.sh | 8 +-
server/src/assembly/resources/sbin/stop-server.bat | 2 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 13 +-
.../statemachine/DataRegionStateMachine.java | 74 ++-
.../statemachine/SchemaRegionStateMachine.java | 6 +-
.../statemachine/visitor/DataExecutionVisitor.java | 116 +++++
.../apache/iotdb/db/engine/StorageEngineV2.java | 13 +
.../apache/iotdb/db/engine/cache/ChunkCache.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 4 +-
.../compaction/CompactionMetricsManager.java | 4 +-
.../db/engine/compaction/CompactionScheduler.java | 4 +-
.../db/engine/compaction/CompactionUtils.java | 4 +-
.../constant/InnerSequenceCompactionSelector.java | 8 +-
.../InnerUnsequenceCompactionSelector.java | 8 +-
...ement.java => AbstractCrossSpaceEstimator.java} | 25 +-
.../rewrite/CrossSpaceCompactionResource.java | 89 ++++
.../RewriteCrossSpaceCompactionResource.java | 206 ---------
.../RewriteCrossSpaceCompactionSelector.java | 17 +-
.../selector/RewriteCompactionFileSelector.java | 195 ++------
.../cross/utils/AbstractCompactionEstimator.java | 63 +++
.../IFileQueryMemMeasurement.java | 2 +-
.../cross/utils/InplaceCompactionEstimator.java | 173 +++++++
.../utils/ReadPointCrossCompactionEstimator.java | 172 +++++++
.../AbstractInnerSpaceEstimator.java} | 25 +-
.../sizetiered/SizeTieredCompactionSelector.java | 9 +-
.../compaction/task/ICompactionSelector.java | 20 +
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 13 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 4 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 4 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 4 +-
.../iotdb/db/engine/snapshot/SnapshotLoader.java | 196 ++++++++
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 166 +++++++
.../exception/DirectoryNotLegalException.java} | 15 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 8 +-
.../engine/storagegroup/TsFileNameGenerator.java | 2 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 4 +-
.../apache/iotdb/db/metadata/MetadataConstant.java | 5 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 11 +-
.../db/metadata/idtable/entry/SHA256DeviceID.java | 7 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 9 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 55 ++-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 4 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 4 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 2 +-
.../traverser/collector/MNodeAboveSGCollector.java | 6 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 13 +-
.../db/metadata/rescon/TimeseriesStatistics.java | 4 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 81 +++-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 22 +-
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 12 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 34 ++
.../iotdb/db/metadata/template/Template.java | 20 +-
.../execution/operator/process/FillOperator.java | 50 +-
.../execution/operator/process/LimitOperator.java | 3 +
.../operator/process/LinearFillOperator.java | 191 ++++++++
.../execution/operator/process/OffsetOperator.java | 3 +
.../execution/operator/process/fill/IFill.java} | 13 +-
.../process/fill/constant/BinaryConstantFill.java | 63 +++
.../process/fill/constant/BooleanConstantFill.java | 62 +++
.../process/fill/constant/DoubleConstantFill.java | 62 +++
.../process/fill/constant/FloatConstantFill.java | 62 +++
.../process/fill/constant/IntConstantFill.java | 62 +++
.../process/fill/constant/LongConstantFill.java | 62 +++
.../process/fill/linear/DoubleLinearFill.java | 94 ++++
.../process/fill/linear/FloatLinearFill.java | 94 ++++
.../process/fill/linear/IntLinearFill.java | 94 ++++
.../operator/process/fill/linear/LinearFill.java | 186 ++++++++
.../process/fill/linear/LongLinearFill.java | 94 ++++
.../process/fill/previous/BinaryPreviousFill.java | 86 ++++
.../process/fill/previous/BooleanPreviousFill.java | 85 ++++
.../process/fill/previous/DoublePreviousFill.java | 85 ++++
.../process/fill/previous/FloatPreviousFill.java | 85 ++++
.../process/fill/previous/IntPreviousFill.java | 85 ++++
.../process/fill/previous/LongPreviousFill.java | 85 ++++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 48 +-
.../db/mpp/plan/parser/StatementGenerator.java | 8 +-
.../db/mpp/plan/planner/DistributionPlanner.java | 53 ++-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 150 +++++-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 25 +
.../plan/planner/plan/node/process/FillNode.java | 8 +
.../source/AlignedSeriesAggregationScanNode.java | 1 +
.../plan/node/source/AlignedSeriesScanNode.java | 12 +-
.../plan/node/write/InsertMultiTabletsNode.java | 16 +
.../plan/planner/plan/node/write/InsertNode.java | 52 ++-
.../planner/plan/node/write/InsertRowNode.java | 10 +-
.../planner/plan/node/write/InsertRowsNode.java | 16 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 16 +
.../planner/plan/node/write/InsertTabletNode.java | 9 +
.../planner/plan/parameter/FillDescriptor.java | 8 +
.../scheduler/FragmentInstanceDispatcherImpl.java | 4 +-
.../mpp/plan/statement/literal/BooleanLiteral.java | 9 +-
.../mpp/plan/statement/literal/DoubleLiteral.java | 14 +-
.../db/mpp/plan/statement/literal/Literal.java | 25 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 25 +-
.../mpp/plan/statement/literal/StringLiteral.java | 6 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 2 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 2 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 35 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 8 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 8 +-
.../query/dataset/groupby/GroupByLevelDataSet.java | 9 +-
.../db/query/pool/RawQueryReadTaskPoolManager.java | 4 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 7 +-
.../iotdb/db/service/metrics/MetricsService.java | 150 ++----
.../db/service/metrics/{ => enums}/Metric.java | 2 +-
.../db/service/metrics/{ => enums}/Operation.java | 2 +-
.../iotdb/db/service/metrics/{ => enums}/Tag.java | 2 +-
.../FileMetrics.java} | 132 +-----
.../ProcessMetrics.java} | 51 +-
.../SystemMetrics.java} | 37 +-
.../db/service/thrift/ProcessorWithMetrics.java | 4 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 2 +-
.../db/service/thrift/impl/TSServiceImpl.java | 2 +-
.../apache/iotdb/db/sync/conf/SyncConstant.java | 2 +-
.../iotdb/db/sync/receiver/ReceiverService.java | 16 +-
.../db/sync/receiver/collector/Collector.java | 2 +-
.../receiver/recovery/ReceiverLogAnalyzer.java | 6 +-
.../db/sync/sender/service/TransportHandler.java | 5 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 6 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 2 +-
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 69 ---
.../org/apache/iotdb/db/wal/node/IWALNode.java | 3 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 18 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 46 ++
.../engine/compaction/CompactionSchedulerTest.java | 2 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 17 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 6 +-
.../cross/RewriteCompactionFileSelectorTest.java | 81 ++--
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 4 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 158 -------
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 152 ++----
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 41 +-
.../metadata/mtree/schemafile/SchemaFileTest.java | 4 +-
.../db/metadata/schemaRegion/SchemaRegionTest.java | 100 ++++
.../db/metadata/upgrade/MetadataUpgradeTest.java | 2 +-
.../mpp/execution/operator/FillOperatorTest.java | 353 ++++++++++++++
.../execution/operator/LinearFillOperatorTest.java | 441 ++++++++++++++++++
.../read/DeviceSchemaScanNodeSerdeTest.java | 2 +-
.../metadata/read/SchemaCountNodeSerdeTest.java | 4 +-
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 2 +-
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 7 +-
.../plan/node/write/InsertTabletNodeSerdeTest.java | 2 +-
.../db/qp/physical/PhysicalPlanSerializeTest.java | 6 +-
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
tsfile/pom.xml | 10 +
.../tsfile/common/constant/TsFileConstant.java | 7 +
.../iotdb/tsfile/exception/PathParseException.java | 12 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 67 ++-
.../org/apache/iotdb/tsfile/read/common/Path.java | 77 ++--
.../read/common/parser/PathNodesGenerator.java | 94 ++++
.../tsfile/read/common/parser/PathParseError.java | 35 +-
.../tsfile/read/common/parser/PathVisitor.java | 75 +++
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 3 +-
.../apache/iotdb/tsfile/read/common/PathTest.java | 163 ++++++-
.../tsfile/write/MetadataIndexConstructorTest.java | 2 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 2 +-
241 files changed, 8078 insertions(+), 2522 deletions(-)
create mode 100644 antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/IdentifierParser.g4
copy server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/IFileQueryMemMeasurement.java => antlr/src/main/antlr4/org/apache/iotdb/db/qp/sql/PathParser.g4 (64%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/wal/ConsensusReqReader.java
delete mode 100644 distribution/src/assembly/cluster.xml
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBSnapshotIT.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/{utils/PredefinedMetric.java => predefined/IMetricSet.java} (71%)
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmClassLoaderMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmCompileMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmGcMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmMemoryMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/jvm/JvmThreadMetrics.java
create mode 100644 metrics/interface/src/main/java/org/apache/iotdb/metrics/predefined/logback/LogbackMetrics.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/{PredefinedMetric.java => JvmUtils.java} (50%)
delete mode 100644 node-commons/src/test/java/org/apache/iotdb/commons/utils/PathUtilsTest.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/statemachine/visitor/DataExecutionVisitor.java
copy server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/{rewrite/selector/IFileQueryMemMeasurement.java => AbstractCrossSpaceEstimator.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/CrossSpaceCompactionResource.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/RewriteCrossSpaceCompactionResource.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/AbstractCompactionEstimator.java
copy server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/{rewrite/selector => utils}/IFileQueryMemMeasurement.java (94%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/InplaceCompactionEstimator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/utils/ReadPointCrossCompactionEstimator.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite/selector/IFileQueryMemMeasurement.java => inner/AbstractInnerSpaceEstimator.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotLoader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/snapshot/SnapshotTaker.java
copy server/src/main/java/org/apache/iotdb/db/{service/metrics/Tag.java => engine/snapshot/exception/DirectoryNotLegalException.java} (70%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/LinearFillOperator.java
copy server/src/main/java/org/apache/iotdb/db/{service/metrics/Tag.java => mpp/execution/operator/process/fill/IFill.java} (81%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/constant/BinaryConstantFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/constant/BooleanConstantFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/constant/DoubleConstantFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/constant/FloatConstantFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/constant/IntConstantFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/constant/LongConstantFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/linear/DoubleLinearFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/linear/FloatLinearFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/linear/IntLinearFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/linear/LinearFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/linear/LongLinearFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BinaryPreviousFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/BooleanPreviousFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/DoublePreviousFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/FloatPreviousFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/IntPreviousFill.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/fill/previous/LongPreviousFill.java
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{ => enums}/Metric.java (96%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{ => enums}/Operation.java (96%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{ => enums}/Tag.java (94%)
copy server/src/main/java/org/apache/iotdb/db/service/metrics/{MetricsService.java => predefined/FileMetrics.java} (53%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{ProcessMetricsMonitor.java => predefined/ProcessMetrics.java} (80%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{SysRunMetricsMonitor.java => predefined/SystemMetrics.java} (82%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/utils/MergeUtils.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/PartialPathTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/FillOperatorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/LinearFillOperatorTest.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/PredefinedMetric.java => tsfile/src/main/java/org/apache/iotdb/tsfile/exception/PathParseException.java (79%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathNodesGenerator.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/DoNothingMetricService.java => tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathParseError.java (55%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/parser/PathVisitor.java