You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2023/01/06 03:46:51 UTC
[iotdb] branch jira5312 updated (6ff734cc78 -> 1faca36f68)
This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch jira5312
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6ff734cc78 rename IoTConsensusServiceClient to SyncIoTConsensusServiceClient
add fface4c3ca [IOTDB-5077] Support new command formats in SHOW REGIONS (#8748)
add 11c489bc25 [IOTDB-4933] More detailed error message for udf/trigger executor and fix typo in udf doc
add df78367ee6 [IOTDB-5308] Limit the output tsblock's size of each operator[Part1]
add 0f944f7861 [IOTDB-5358]dn_data_dir failed to be effectively set when executing load (#8749)
add 7e3bea1349 [IOTDB-5361] Refactor device and timeseries count based on SchemaReader (#8755)
add 067519f297 fix some code smells (#8731)
add 72a94eb531 [IOTDB-5334] Optimize metric related code and log (#8739)
add 2f8abb245c [IOTDB-5284] Fix some code smells (#8730)
add 5a40a19ed4 [IOTDB-5284] Fix some iotdb-server code smells (#8754)
add 22bd622a57 [IOTDB-5284] Fix some code smells (#8751)
add 621e036983 [IOTDB-5284] Fix some iotdb-server code smells (#8743)
add a1c29277ac [IOTDB-5284] Fix some iotdb-server code smells (#8738)
add 1a29eb07c1 [IOTDB-5365] Init lastEnterReadyQueueTime of DriverTask while creating it
add 24e5d2fe8d [IOTDB-4497] Improve NodeStatus definition (#8732)
add afc58a0ad3 [IOTDB-5364] Refactor Count TimeSeries Group By Level based on SchemaReader (#8759)
add a2f39140f9 [IOTDB-5303] Refine IT: Make cluster properties mutable easily (#8671)
add 854288ccd7 [IOTDB-5323] Extend File related Metrics (#8761)
add 6e98062c1f [IOTDB-4817] Support kill query in cluster
add 1faca36f68 Merge branch 'master' into jira5312
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 3 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../confignode/client/DataNodeRequestType.java | 5 +-
.../client/async/AsyncDataNodeClientPool.java | 6 +
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../client/sync/SyncDataNodeClientPool.java | 2 +
.../iotdb/confignode/manager/ConfigManager.java | 8 +
.../apache/iotdb/confignode/manager/IManager.java | 2 +
.../iotdb/confignode/manager/node/NodeManager.java | 38 ++
.../thrift/ConfigNodeRPCServiceProcessor.java | 5 +
docs/UserGuide/Cluster/Cluster-Maintenance.md | 83 ++++
.../Maintenance-Tools/Maintenance-Command.md | 14 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 51 +--
.../Operators-Functions/User-Defined-Function.md | 2 +-
docs/UserGuide/Reference/Status-Codes.md | 2 +
docs/zh/UserGuide/Cluster/Cluster-Maintenance.md | 82 ++++
.../Maintenance-Tools/Maintenance-Command.md | 16 +-
docs/zh/UserGuide/Monitor-Alert/Metric-Tool.md | 69 ++--
.../Operators-Functions/User-Defined-Function.md | 2 +-
docs/zh/UserGuide/Reference/Status-Codes.md | 2 +
integration-test/checkstyle.xml | 2 +-
integration-test/pom.xml | 4 +-
.../org/apache/iotdb/it/env/ConfigFactory.java | 45 ---
.../java/org/apache/iotdb/it/env/EnvFactory.java | 3 +
.../java/org/apache/iotdb/it/env/MppConfig.java | 398 ------------------
.../iotdb/it/env/{ => cluster}/AbstractEnv.java | 139 ++++---
.../it/env/{ => cluster}/AbstractNodeWrapper.java | 140 +++++--
.../iotdb/it/env/{ => cluster}/Cluster1Env.java | 20 +-
.../it/env/{ => cluster}/ConfigNodeWrapper.java | 62 ++-
.../it/env/{ => cluster}/DataNodeWrapper.java | 86 ++--
.../iotdb/it/env/{ => cluster}/EnvUtils.java | 61 ++-
.../apache/iotdb/it/env/cluster/MppBaseConfig.java | 120 ++++++
.../iotdb/it/env/cluster/MppClusterConfig.java | 68 ++++
.../iotdb/it/env/cluster/MppCommonConfig.java | 334 +++++++++++++++
.../MppConfigNodeConfig.java} | 33 +-
.../iotdb/it/env/cluster/MppDataNodeConfig.java | 36 +-
.../it/env/cluster/MppSharedCommonConfig.java | 346 ++++++++++++++++
.../org/apache/iotdb/it/env/cluster/SimpleEnv.java | 16 +-
.../iotdb/it/env/remote/RemoteClusterConfig.java | 56 +++
.../iotdb/it/env/remote/RemoteCommonConfig.java | 249 ++++++++++++
.../RemoteConfigNodeConfig.java} | 6 +-
.../RemoteDataNodeConfig.java} | 6 +-
.../iotdb/it/env/{ => remote}/RemoteServerEnv.java | 43 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 447 ---------------------
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 55 ++-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 -
.../org/apache/iotdb/itbase/env/ClusterConfig.java | 60 +++
.../org/apache/iotdb/itbase/env/CommonConfig.java | 113 ++++++
.../env/ConfigNodeConfig.java} | 7 +-
.../env/DataNodeConfig.java} | 7 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 4 +-
.../confignode/it/IoTDBClusterAuthorityIT.java | 2 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 30 +-
.../confignode/it/IoTDBSnapshotTransferIT.java | 9 +-
.../iotdb/confignode/it/IoTDBStorageGroupIT.java | 2 +-
.../it/cluster/IoTDBClusterNodeErrorStartUpIT.java | 40 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 63 +--
.../it/cluster/IoTDBClusterRestartIT.java | 55 +--
.../load/IoTDBClusterRegionLeaderBalancingIT.java | 71 +---
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 52 +--
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 57 +--
.../IoTDBCustomRegionGroupExtensionIT.java | 66 +--
.../it/partition/IoTDBPartitionDurableIT.java | 50 +--
.../it/partition/IoTDBPartitionGetterIT.java | 69 +---
.../partition/IoTDBPartitionInheritPolicyIT.java | 45 +--
.../confignode/it/utils/ConfigNodeTestUtils.java | 51 ++-
.../org/apache/iotdb/db/it/IOTDBLoadTsFileIT.java | 10 +-
.../java/org/apache/iotdb/db/it/IoTDBAuthIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBDatetimeFormatIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 19 +-
.../org/apache/iotdb/db/it/IoTDBEncodingIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBExecuteBatchIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBFilterBetweenIT.java | 4 +-
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 30 +-
.../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 7 +-
.../apache/iotdb/db/it/IoTDBFlushQueryMergeIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBInsertNaNIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBInsertNullIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 4 +-
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBMultiDeviceIT.java | 47 +--
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 34 +-
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 8 +-
.../db/it/IoTDBQueryWithRecreatedTimeseriesIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBQuotedPathIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBRecoverIT.java | 4 +-
.../apache/iotdb/db/it/IoTDBRecoverUnclosedIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 4 +-
.../it/IoTDBSameMeasurementsDifferentTypesIT.java | 30 +-
.../java/org/apache/iotdb/db/it/IoTDBSettleIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 4 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 4 +-
.../it/IoTDBSyntaxConventionStringLiteralIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBTimeZoneIT.java | 4 +-
.../java/org/apache/iotdb/db/it/IoTDBTtlIT.java | 4 +-
.../it/aggregation/IoTDBAggregationByLevelIT.java | 4 +-
.../it/aggregation/IoTDBAggregationDeleteIT.java | 10 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 6 +-
.../aggregation/IoTDBAggregationLargeDataIT.java | 9 +-
.../it/aggregation/IoTDBAggregationOptimizeIT.java | 4 +-
.../aggregation/IoTDBAggregationScanOrderIT.java | 24 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 4 +-
.../db/it/aggregation/IoTDBTagAggregationIT.java | 4 +-
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 4 +-
.../IoTDBOrderByWithAlignByDeviceIT.java | 4 +-
.../aligned/IoTDBAggregationWithDeletion2IT.java | 31 +-
.../it/aligned/IoTDBAggregationWithDeletionIT.java | 28 +-
.../db/it/aligned/IoTDBAlignedDataDeletionIT.java | 20 +-
.../db/it/aligned/IoTDBAlignedLastQuery2IT.java | 31 +-
.../db/it/aligned/IoTDBAlignedLastQuery3IT.java | 31 +-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 29 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery2IT.java | 31 +-
.../db/it/aligned/IoTDBAlignedSeriesQuery3IT.java | 30 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 28 +-
.../IoTDBAlignedSeriesQueryWithDeletionIT.java | 29 +-
.../IoTDBCountMultiTimesWithDeletionIT.java | 29 +-
.../db/it/aligned/IoTDBGroupByLevelQueryIT.java | 30 +-
...GroupByQueryWithValueFilterWithDeletion2IT.java | 30 +-
...BGroupByQueryWithValueFilterWithDeletionIT.java | 29 +-
...upByQueryWithoutValueFilterWithDeletion2IT.java | 31 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 31 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 18 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 18 +-
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 18 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 10 +-
.../it/aligned/IoTDBLastQueryWithDeletion2IT.java | 27 +-
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 24 +-
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 30 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 29 +-
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 30 +-
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 29 +-
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 27 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 24 +-
.../org/apache/iotdb/db/it/cq/IoTDBCQExecIT.java | 4 +-
.../java/org/apache/iotdb/db/it/cq/IoTDBCQIT.java | 4 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 275 -------------
.../iotdb/db/it/env/StandaloneEnvConfig.java | 354 ----------------
.../apache/iotdb/db/it/groupby/IOTDBGroupByIT.java | 11 +-
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 4 +-
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 28 +-
.../apache/iotdb/db/it/groupby/IoTDBHavingIT.java | 11 +-
.../iotdb/db/it/groupby/IoTDBLeftORightCIT.java | 4 +-
.../iotdb/db/it/last/IoTDBLastWithTTLIT.java | 4 +-
.../apache/iotdb/db/it/mqtt/IoTDBMQTTSinkIT.java | 12 +-
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 4 +-
.../iotdb/db/it/query/IoTDBArithmeticIT.java | 4 +-
.../iotdb/db/it/query/IoTDBFuzzyQueryIT.java | 4 +-
.../org/apache/iotdb/db/it/query/IoTDBInIT.java | 4 +-
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 11 +-
.../iotdb/db/it/query/IoTDBNullValueFillIT.java | 4 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 11 +-
.../apache/iotdb/db/it/query/IoTDBQueryDemoIT.java | 4 +-
.../query/IoTDBQueryWithComplexValueFilterIT.java | 4 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 4 +-
.../it/query/IoTDBSelectCompareExpressionIT.java | 4 +-
.../iotdb/db/it/query/IoTDBSelectSchemaIT.java | 4 +-
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 4 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 4 +-
.../db/it/schema/IoTDBCreateStorageGroupIT.java | 4 +-
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 4 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 4 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 12 +-
.../db/it/schema/IoTDBDeleteStorageGroupIT.java | 4 +-
.../db/it/schema/IoTDBDeleteTimeseriesIT.java | 11 +-
.../schema/IoTDBDeleteTimeseriesSchemaFileIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 40 +-
.../it/schema/IoTDBMetadataFetchSchemaFileIT.java | 8 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 4 +-
.../db/it/schema/IoTDBSortedShowTimeseriesIT.java | 4 +-
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 4 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 4 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 22 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 18 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 13 +-
.../org/apache/iotdb/db/it/sync/IoTDBPipeIT.java | 4 +-
.../apache/iotdb/db/it/sync/IoTDBPipeSinkIT.java | 4 +-
.../db/it/trigger/IoTDBTriggerExecutionIT.java | 4 +-
.../db/it/trigger/IoTDBTriggerManagementIT.java | 4 +-
.../org/apache/iotdb/db/it/udf/IoTDBUDFM4IT.java | 14 +-
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 4 +-
.../db/it/udf/IoTDBUDFOtherWindowQueryIT.java | 33 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 33 +-
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 24 +-
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../iotdb/db/it/udf/IoTDBUDTFHybridQueryIT.java | 4 +-
.../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 14 +-
.../iotdb/db/it/watermark/IoTDBWatermarkIT.java | 34 +-
.../db/it/withoutNull/IoTDBWithoutAllNullIT.java | 4 +-
.../db/it/withoutNull/IoTDBWithoutAnyNullIT.java | 4 +-
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 9 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 4 +-
.../apache/iotdb/libudf/it/anomaly/AnomalyIT.java | 10 +-
.../apache/iotdb/libudf/it/dmatch/DMatchIT.java | 10 +-
.../iotdb/libudf/it/dprofile/DProfileIT.java | 10 +-
.../iotdb/libudf/it/dquality/DQualityIT.java | 10 +-
.../apache/iotdb/libudf/it/drepair/DRepairIT.java | 10 +-
.../iotdb/libudf/it/frequency/FrequencyIT.java | 10 +-
.../apache/iotdb/libudf/it/series/SeriesIT.java | 10 +-
.../apache/iotdb/libudf/it/string/StringIT.java | 10 +-
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 4 +-
.../session/it/IoTDBSessionAlignedInsertIT.java | 11 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 6 +-
.../it/IoTDBSessionDisableMemControlIT.java | 13 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 4 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 4 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 4 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 4 +-
.../org/apache/iotdb/session/it/SessionIT.java | 4 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 4 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 4 +-
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 4 +-
.../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 4 +-
.../dropwizard/DropwizardMetricNameTool.java | 11 +
.../dropwizard/reporter/DropwizardJmxReporter.java | 17 +-
.../iotdb/metrics/AbstractMetricManager.java | 73 ++--
.../iotdb/metrics/AbstractMetricService.java | 98 ++---
.../apache/iotdb/metrics/CompositeReporter.java | 14 +-
.../iotdb/metrics/DoNothingMetricService.java | 4 +-
.../apache/iotdb/metrics/config/MetricConfig.java | 95 +++--
.../metrics/config/MetricConfigDescriptor.java | 12 +-
.../iotdb/metrics/metricsets/IMetricSet.java | 6 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 4 +-
.../iotdb/metrics/metricsets/jvm/JvmMetrics.java | 2 +-
.../iotdb/metrics/metricsets/jvm/JvmUtils.java | 8 +-
.../metrics/metricsets/logback/LogbackMetrics.java | 2 +-
.../metricsets/logback/MetricsTurboFilter.java | 12 +-
.../apache/iotdb/metrics/reporter/JmxReporter.java | 2 +-
.../apache/iotdb/metrics/reporter/Reporter.java | 6 +-
...orter.java => IoTDBInternalMemoryReporter.java} | 2 +-
...TDBReporter.java => IoTDBInternalReporter.java} | 12 +-
.../metrics/reporter/iotdb/IoTDBReporter.java | 12 +-
...oTDBReporter.java => IoTDBSessionReporter.java} | 27 +-
.../reporter/prometheus/PrometheusReporter.java | 14 +-
.../org/apache/iotdb/metrics/type/AutoGauge.java | 2 +-
.../org/apache/iotdb/metrics/type/Counter.java | 6 +-
.../java/org/apache/iotdb/metrics/type/Gauge.java | 8 +-
.../org/apache/iotdb/metrics/type/Histogram.java | 6 +-
.../iotdb/metrics/type/HistogramSnapshot.java | 14 +-
.../java/org/apache/iotdb/metrics/type/Rate.java | 14 +-
.../java/org/apache/iotdb/metrics/type/Timer.java | 12 +-
.../iotdb/metrics/utils/IoTDBMetricsUtils.java | 16 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 14 +-
.../apache/iotdb/metrics/utils/MetricLevel.java | 4 +-
.../utils/{MetricLevel.java => SystemType.java} | 32 +-
.../iotdb/metrics/config/MetricConfigTest.java | 4 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 8 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 2 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 2 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +-
.../threadpool/WrappedThreadPoolExecutor.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 2 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 17 +-
.../iotdb/commons/partition/DataPartition.java | 2 +-
.../apache/iotdb/commons/partition/Partition.java | 2 +-
.../partition/executor/hash/BKDRHashExecutor.java | 4 +-
.../partition/executor/hash/JSHashExecutor.java | 4 +-
.../fa/dfa/transition/AbstractDFATransition.java | 2 +-
.../security/encrypt/MessageDigestEncrypt.java | 4 +-
.../service/AbstractThriftServiceThread.java | 10 +-
.../commons/service/metric/MetricService.java | 52 +--
.../commons/service/metric/MetricServiceMBean.java | 1 +
.../commons/service/metric/enums/Operation.java | 1 +
.../iotdb/commons/sync/metadata/SyncMetadata.java | 2 +
.../apache/iotdb/commons/sync/pipe/PipeInfo.java | 4 +-
.../iotdb/commons/sync/pipesink/IoTDBPipeSink.java | 2 +-
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 2 +-
.../builtin/UDTFEqualSizeBucketRandomSample.java | 1 +
.../apache/iotdb/commons/udf/utils/KDTreeUtil.java | 10 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 2 +-
.../commons/utils/BasicStructureSerDeUtil.java | 4 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 4 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 13 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 67 ---
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 44 --
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 8 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 25 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 2 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 15 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 8 +-
.../iotdb/db/engine/TsFileMetricManager.java | 24 +-
.../iotdb/db/engine/cache/BloomFilterCache.java | 4 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 4 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 2 +-
.../exception/CompactionExceptionHandler.java | 2 +-
.../performer/ICrossCompactionPerformer.java | 1 +
.../execute/performer/ISeqCompactionPerformer.java | 1 +
.../performer/IUnseqCompactionPerformer.java | 1 +
.../performer/impl/FastCompactionPerformer.java | 8 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../impl/ReadPointCompactionPerformer.java | 10 +-
.../execute/recover/CompactionRecoverTask.java | 5 +-
.../execute/task/InnerSpaceCompactionTask.java | 2 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 6 +-
.../fast/AlignedSeriesCompactionExecutor.java | 2 +-
.../executor/fast/SeriesCompactionExecutor.java | 18 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 5 +-
.../writer/AbstractCrossCompactionWriter.java | 2 +-
.../writer/AbstractInnerCompactionWriter.java | 2 +-
.../compaction/selector/ICrossSpaceSelector.java | 1 +
.../selector/IInnerSeqSpaceSelector.java | 1 +
.../selector/IInnerUnseqSpaceSelector.java | 1 +
.../impl/RewriteCrossSpaceCompactionSelector.java | 7 +-
.../iotdb/db/engine/load/LoadTsFileManager.java | 12 +-
.../modification/utils/TracedBufferedReader.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 2 +-
.../engine/trigger/sink/forward/ForwardEvent.java | 1 +
.../db/engine/trigger/utils/BatchHandlerQueue.java | 1 +
.../schemafile/RecordDuplicatedException.java | 2 +-
.../schemafile/SegmentOverflowException.java | 9 +-
.../template/DifferentTemplateException.java | 2 +-
.../template/NoTemplateOnMNodeException.java | 2 +-
.../template/UndefinedTemplateException.java | 2 +-
.../KilledByOthersException.java} | 16 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 2 +
.../db/metadata/cache/DataNodeSchemaCache.java | 1 -
.../idtable/AppendOnlyDiskSchemaManager.java | 6 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 2 +-
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 2 +-
.../metadata/mnode/container/MNodeContainers.java | 7 +
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 49 ---
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 85 ----
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 85 ----
.../db/metadata/mtree/store/CachedMTreeStore.java | 18 +-
.../mtree/store/disk/cache/CacheManager.java | 6 +-
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 1 +
.../store/disk/schemafile/AliasIndexPage.java | 2 +-
.../mtree/store/disk/schemafile/InternalPage.java | 2 +-
.../store/disk/schemafile/MockSchemaFile.java | 12 +-
.../mtree/store/disk/schemafile/SchemaFile.java | 3 +-
.../mtree/store/disk/schemafile/SchemaPage.java | 4 +-
.../mtree/store/disk/schemafile/Segment.java | 2 +-
.../mtree/store/disk/schemafile/SegmentedPage.java | 6 +-
.../disk/schemafile/pagemgr/BTreePageManager.java | 12 +-
.../store/disk/schemafile/pagemgr/PageManager.java | 2 +-
.../db/metadata/mtree/traverser/Traverser.java | 3 +-
.../mtree/traverser/collector/EntityCollector.java | 4 +-
.../traverser/collector/MNodeAboveSGCollector.java | 2 +-
.../mtree/traverser/collector/MNodeCollector.java | 2 +-
.../traverser/collector/MeasurementCollector.java | 6 +-
.../traverser/collector/StorageGroupCollector.java | 2 +-
.../mtree/traverser/counter/CounterTraverser.java | 2 +-
.../counter/MNodeAboveSGLevelCounter.java | 60 ---
.../mtree/traverser/counter/MNodeLevelCounter.java | 83 ----
.../traverser/counter/MeasurementCounter.java | 73 ----
.../counter/MeasurementGroupByLevelCounter.java | 126 ------
.../impl/read/AbstractShowSchemaPlanImpl.java | 2 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 4 +
.../plan/schemaregion/result/ShowSchemaResult.java | 4 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 49 ---
.../db/metadata/schemaregion/SchemaEngine.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 57 ---
.../schemaregion/SchemaRegionSchemaFileImpl.java | 60 +--
.../metadata/template/ClusterTemplateManager.java | 2 +-
.../iotdb/db/metadata/template/Template.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 1 +
.../mpp/aggregation/FirstValueDescAccumulator.java | 6 +
.../mpp/aggregation/LastValueDescAccumulator.java | 6 +
.../slidingwindow/SlidingWindowAggregator.java | 2 +-
.../SlidingWindowAggregatorFactory.java | 11 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 2 +-
.../common/schematree/node/SchemaInternalNode.java | 1 +
.../db/mpp/common/schematree/node/SchemaNode.java | 2 +-
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 2 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 9 +
.../iotdb/db/mpp/execution/driver/Driver.java | 2 +-
.../fragment/FragmentInstanceContext.java | 1 +
.../mpp/execution/operator/AbstractOperator.java | 94 +++++
.../operator/process/AbstractIntoOperator.java | 8 +-
.../operator/process/AbstractProcessOperator.java | 15 +-
.../process/SingleInputAggregationOperator.java | 2 +-
.../operator/process/TransformOperator.java | 6 +-
.../process/join/RowBasedTimeJoinOperator.java | 37 +-
.../operator/process/join/TimeJoinOperator.java | 33 +-
.../process/join/VerticallyConcatOperator.java | 2 +-
.../last/AbstractUpdateLastCacheOperator.java | 2 +-
...or.java => CountGroupByLevelMergeOperator.java} | 80 ++--
.../operator/schema/CountMergeOperator.java | 36 --
.../operator/schema/DevicesCountOperator.java | 82 +---
.../schema/LevelTimeSeriesCountOperator.java | 103 +++--
...CountOperator.java => SchemaCountOperator.java} | 84 ++--
.../schema/SchemaQueryOrderByHeatOperator.java | 5 +-
.../operator/schema/TimeSeriesCountOperator.java | 93 +----
.../source/AbstractDataSourceOperator.java | 25 +-
.../AbstractSeriesAggregationScanOperator.java | 23 +-
.../operator/source/AbstractSourceOperator.java} | 14 +-
.../operator/source/AlignedSeriesScanOperator.java | 50 +--
.../operator/source/SeriesScanOperator.java | 41 +-
.../execution/schedule/AbstractDriverThread.java | 11 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 3 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 4 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 5 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 6 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 6 +-
.../analyze/cache/StorageGroupCacheResult.java | 2 +-
.../db/mpp/plan/execution/IQueryExecution.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 15 +-
.../mpp/plan/execution/config/ConfigExecution.java | 5 +
.../plan/execution/config/ConfigTaskVisitor.java | 7 +
.../config/executor/ClusterConfigTaskExecutor.java | 48 +++
.../config/executor/IConfigTaskExecutor.java | 3 +
.../plan/execution/config/sys/KillQueryTask.java | 31 +-
.../plan/expression/ternary/BetweenExpression.java | 1 +
.../visitor/ColumnTransformerVisitor.java | 25 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 32 +-
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 17 +-
.../db/mpp/plan/planner/SubPlanTypeExtractor.java | 5 +
.../SimpleFragmentParallelPlanner.java | 4 +-
.../plan/planner/distribution/SourceRewriter.java | 2 +-
.../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 2 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 13 +-
.../db/mpp/plan/planner/plan/node/PlanNode.java | 2 +-
.../metedata/read/AbstractSchemaMergeNode.java | 4 +-
.../metedata/read/PathsUsingTemplateScanNode.java | 2 +
.../node/metedata/read/SchemaFetchMergeNode.java | 1 +
.../node/metedata/read/SchemaQueryMergeNode.java | 1 +
.../write/CreateAlignedTimeSeriesNode.java | 1 +
.../metedata/write/CreateMultiTimeSeriesNode.java | 1 +
.../node/metedata/write/CreateTimeSeriesNode.java | 1 +
.../plan/node/process/MultiChildProcessNode.java | 4 +-
.../planner/plan/node/process/ProcessNode.java | 2 +-
.../plan/node/process/SingleChildProcessNode.java | 4 +-
.../node/process/last/LastQueryCollectNode.java | 1 +
.../plan/node/process/last/LastQueryMergeNode.java | 1 +
.../plan/node/process/last/LastQueryNode.java | 1 +
.../mpp/plan/planner/plan/node/sink/SinkNode.java | 2 +-
.../source/AlignedSeriesAggregationScanNode.java | 3 +
.../node/source/SeriesAggregationScanNode.java | 3 +
.../node/source/SeriesAggregationSourceNode.java | 2 +-
.../planner/plan/node/source/SeriesSourceNode.java | 2 +-
.../CrossSeriesAggregationDescriptor.java | 1 +
.../plan/planner/plan/parameter/OutputColumn.java | 2 +-
.../scheduler/AbstractFragInsStateTracker.java | 2 +-
.../scheduler/FixedRateFragInsStateTracker.java | 4 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 18 +-
.../db/mpp/plan/statement/StatementVisitor.java | 5 +
.../plan/statement/component/IntoComponent.java | 8 +-
.../crud/InsertMultiTabletsStatement.java | 1 +
.../plan/statement/crud/InsertRowStatement.java | 1 +
.../crud/InsertRowsOfOneDeviceStatement.java | 3 +-
.../plan/statement/crud/InsertRowsStatement.java | 1 +
.../plan/statement/crud/InsertTabletStatement.java | 1 +
.../statement/metadata/ShowRegionStatement.java | 14 +-
.../KillQueryStatement.java} | 47 +--
.../iotdb/db/mpp/statistics/StatisticsManager.java | 2 +-
.../dag/column/ColumnTransformer.java | 2 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 2 +-
.../dag/column/binary/BinaryColumnTransformer.java | 2 +-
.../binary/CompareBinaryColumnTransformer.java | 2 +-
.../binary/LogicBinaryColumnTransformer.java | 2 +-
.../dag/column/leaf/LeafColumnTransformer.java | 2 +-
.../ternary/CompareTernaryColumnTransformer.java | 4 +-
.../column/ternary/TernaryColumnTransformer.java | 2 +-
.../dag/column/unary/UnaryColumnTransformer.java | 2 +-
.../dag/transformer/unary/UnaryTransformer.java | 2 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 7 +-
.../protocol/influxdb/function/InfluxFunction.java | 4 +-
.../function/aggregator/InfluxAggregator.java | 2 +-
.../function/aggregator/InfluxMeanFunction.java | 2 +-
.../function/aggregator/InfluxStddevFunction.java | 3 +-
.../function/aggregator/InfluxSumFunction.java | 2 +-
.../influxdb/function/selector/InfluxSelector.java | 2 +-
.../influxdb/handler/AbstractQueryHandler.java | 6 +-
.../protocol/influxdb/handler/NewQueryHandler.java | 5 +-
.../protocol/influxdb/handler/TagQueryHandler.java | 2 +-
.../influxdb/statement/InfluxSelectComponent.java | 1 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 2 +-
.../iotdb/db/query/control/FileReaderManager.java | 2 +-
.../iotdb/db/query/control/QueryFileManager.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +-
.../db/service/DataNodeServerCommandLine.java | 2 +-
.../org/apache/iotdb/db/service/SettleService.java | 5 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 2 +-
.../iotdb/db/service/metrics/FileMetrics.java | 286 +++++++------
...porter.java => IoTDBInternalLocalReporter.java} | 32 +-
.../iotdb/db/service/metrics/ProcessMetrics.java | 31 +-
.../iotdb/db/service/metrics/SystemMetrics.java | 39 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 21 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 15 +-
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 2 +-
.../iotdb/db/sync/datasource/PipeOpManager.java | 8 +-
.../iotdb/db/sync/datasource/PipeOpSgManager.java | 6 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 10 +-
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 4 +-
.../db/sync/externalpipe/ExtPipePluginManager.java | 4 +-
.../db/sync/externalpipe/operation/Operation.java | 2 +-
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 1 +
.../apache/iotdb/db/sync/pipedata/PipeData.java | 4 +-
.../db/sync/pipedata/load/DeletionLoader.java | 4 +-
.../iotdb/db/sync/pipedata/load/TsFileLoader.java | 5 +-
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 2 +-
.../db/sync/sender/pipe/ExternalPipeSink.java | 2 +-
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 2 +-
.../db/sync/sender/recovery/TsFilePipeLogger.java | 2 +-
.../db/sync/transport/client/SenderManager.java | 2 +-
.../db/sync/transport/server/ReceiverManager.java | 4 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 2 +-
.../db/tools/settle/TsFileAndModSettleTool.java | 6 +-
.../db/tools/validate/TsFileValidationTool.java | 2 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 4 +-
.../db/trigger/executor/TriggerFireVisitor.java | 19 +-
.../trigger/service/TriggerInformationUpdater.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../datastructure/FixedPriorityBlockingQueue.java | 4 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../allocation/AbstractNodeAllocationStrategy.java | 2 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 2 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 4 +-
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 2 +-
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 2 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 2 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../wal/utils/listener/AbstractResultListener.java | 2 +-
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 128 ------
.../schemaRegion/SchemaRegionBasicTest.java | 111 +++--
.../schemaRegion/SchemaRegionTestUtil.java | 68 ++++
.../execution/operator/MergeSortOperatorTest.java | 3 +
.../mpp/execution/operator/OperatorMemoryTest.java | 36 +-
...ava => CountGroupByLevelMergeOperatorTest.java} | 135 +++++--
.../operator/schema/SchemaCountOperatorTest.java | 187 +++++++--
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
.../src/main/thrift/confignode.thrift | 3 +
thrift/src/main/thrift/datanode.thrift | 2 +
.../iotdb/tsfile/read/common/block/TsBlock.java | 9 +
.../read/common/block/column/BinaryColumn.java | 5 +
.../read/common/block/column/BooleanColumn.java | 5 +
.../tsfile/read/common/block/column/Column.java | 2 +
.../read/common/block/column/DoubleColumn.java | 5 +
.../read/common/block/column/FloatColumn.java | 5 +
.../tsfile/read/common/block/column/IntColumn.java | 5 +
.../read/common/block/column/LongColumn.java | 5 +
.../read/common/block/column/NullColumn.java | 5 +
.../block/column/RunLengthEncodedColumn.java | 5 +
.../read/common/block/column/TimeColumn.java | 5 +
543 files changed, 5000 insertions(+), 6016 deletions(-)
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/ConfigFactory.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/MppConfig.java
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ => cluster}/AbstractEnv.java (88%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ => cluster}/AbstractNodeWrapper.java (73%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/{ => cluster}/Cluster1Env.java (65%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ => cluster}/ConfigNodeWrapper.java (63%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ => cluster}/DataNodeWrapper.java (57%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ => cluster}/EnvUtils.java (58%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppBaseConfig.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppClusterConfig.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppCommonConfig.java
rename integration-test/src/main/java/org/apache/iotdb/it/env/{SimpleEnv.java => cluster/MppConfigNodeConfig.java} (51%)
rename server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/EntityCounter.java => integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppDataNodeConfig.java (52%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppSharedCommonConfig.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/type/AutoGauge.java => integration-test/src/main/java/org/apache/iotdb/it/env/cluster/SimpleEnv.java (72%)
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteClusterConfig.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteCommonConfig.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/{RemoteServerConfig.java => remote/RemoteConfigNodeConfig.java} (83%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/{RemoteServerConfig.java => remote/RemoteDataNodeConfig.java} (84%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ => remote}/RemoteServerEnv.java (88%)
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/BaseConfig.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/ClusterConfig.java
create mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/env/CommonConfig.java
copy integration-test/src/main/java/org/apache/iotdb/{it/env/RemoteServerConfig.java => itbase/env/ConfigNodeConfig.java} (83%)
rename integration-test/src/main/java/org/apache/iotdb/{it/env/RemoteServerConfig.java => itbase/env/DataNodeConfig.java} (84%)
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnv.java
delete mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/env/StandaloneEnvConfig.java
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/{MemoryInternalIoTDBReporter.java => IoTDBInternalMemoryReporter.java} (96%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/{InternalIoTDBReporter.java => IoTDBInternalReporter.java} (88%)
rename metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/{SessionIoTDBReporter.java => IoTDBSessionReporter.java} (87%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/{MetricLevel.java => SystemType.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/exception/{metadata/schemafile/RecordDuplicatedException.java => query/KilledByOthersException.java} (67%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MNodeAboveSGLevelCounter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MNodeLevelCounter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MeasurementCounter.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/MeasurementGroupByLevelCounter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/AbstractOperator.java
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/Reporter.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractProcessOperator.java (74%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{CountMergeOperator.java => CountGroupByLevelMergeOperator.java} (73%)
copy server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesCountOperator.java => SchemaCountOperator.java} (62%)
copy metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/MetricLevel.java => server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/AbstractDataSourceOperator.java (67%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/planner/plan/node/process/ProcessNode.java => execution/operator/source/AbstractSourceOperator.java} (72%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/Cluster1Env.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/sys/KillQueryTask.java (50%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/ShowRegionStatement.java => sys/KillQueryStatement.java} (54%)
rename server/src/main/java/org/apache/iotdb/db/service/metrics/{IoTDBInternalReporter.java => IoTDBInternalLocalReporter.java} (85%)
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/{CountMergeOperatorTest.java => CountGroupByLevelMergeOperatorTest.java} (51%)