This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch sync_connection_error_code
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3bcd27eb44 Separate SYNC_CONNECTION_ERROR and DISPATCH_ERROR
add 82bd466c0c Bump reload4j from 1.2.22 to 1.2.24 (#8689)
add f2b9c0ebd1 [IOTDB-5285] Modifying system properties before the initial
startup causes the datanode to fail to start (#8717)
add 468d675475 [IOTDB-5346] Fix log error in MemtableFlushTask when
recovering (#8724)
add 415808dc2e Add cluster_name related judgement and logs (#8727)
add bd70ca269b fix the wal comment (#8673)
add d2085948df [IOTDB-5347] Implement iterating query for devices and
timeseries schema query (#8728)
add f38561724e [IOTDB-5351] Add StatisticsUpdaterTrigger as trigger
example and fix possible IT failures
add c65cead563 Make subprocesses' exit under control in IT cases (#8734)
add a1f259d517 Bump spring-boot-dependencies from 1.5.15.RELEASE to
1.5.22.RELEASE (#8690)
add f26ff29ff2 reconstruct compaction package (#8720)
add 7c9395de11 [IOTDB-5342][IOTDB-5359][IOTDB-5360] Some optimization in
AbstractTreeVisitor (#8721)
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 7bbac9ec98 [IOTDB-5373] Eliminate stale code in LocalConfigNode and
LocalSchemaProcessor to simplify interfaces of ISchemaRegion (#8767)
add 87ed1f975b [IOTDB-5312] Consolidate ClientManagers in Datanodes for
unified management (#8654)
add 2b4732ccd9 [IOTDB-5379] Fix the unit of Prometheus timer metric values
(#8773)
add 4c52365559 [IOTDB-5378] Implement Iterating Query for MTree Node Query
(#8771)
add 228607c5f0 Revert "[IOTDB-5209] Limit the read rate of compaction
execution (#8461)" (#8777)
add a06624782a [IOTDB-5384] add
core_client_count_for_each_node_in_client_manager and
max_client_count_for_each_node_in_client_manager parameters for confignode and
datanode (#8779)
add 48002969a5 update javadoc (#8789)
add cea3c5ce21 [IOTDB-4982] Replace recursion algorithm in Traverser with
iteration algorithm (#8765)
add d55ca83df7 [IoTDB-5374] Implement MLNode basic service framework
(#8772)
add 5f914f014e [IOTDB-3662] upgrade audit log (#8791)
add 362f56cdf5 Change version to 1.1.0-SNAPSHOT (#8796)
add 5de6adf3de [IOTDB-5386] Implement SchemaSource Component to Simplify
Schema Operators (#8792)
add c1dde58682 Jenkins disable integration (#8787)
add c085fb1a8c [IOTDB-4005] Pipeline fragmentInstance to implement
parallel execution
add ff87697828 Merge branch 'master' into sync_connection_error_code
No new revisions were added by this update.
Summary of changes:
.gitignore | 1 +
Jenkinsfile | 42 +-
antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 3 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
cli/pom.xml | 2 +-
client-cpp/pom.xml | 2 +-
client-py/pom.xml | 2 +-
code-coverage/pom.xml | 2 +-
compile-tools/pom.xml | 2 +-
compile-tools/thrift/pom.xml | 2 +-
confignode/pom.xml | 2 +-
.../resources/conf/iotdb-confignode.properties | 11 +
.../confignode/client/DataNodeRequestType.java | 5 +-
.../client/async/AsyncDataNodeClientPool.java | 6 +
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 2 +
.../iotdb/confignode/conf/ConfigNodeConfig.java | 33 +
.../confignode/conf/ConfigNodeDescriptor.java | 16 +
.../confignode/conf/SystemPropertiesUtils.java | 5 +
.../iotdb/confignode/manager/ConfigManager.java | 8 +
.../iotdb/confignode/manager/ConsensusManager.java | 10 +-
.../apache/iotdb/confignode/manager/IManager.java | 2 +
.../iotdb/confignode/manager/node/NodeManager.java | 38 +
.../persistence/schema/ClusterSchemaInfo.java | 14 -
.../iotdb/confignode/service/ConfigNode.java | 10 +-
.../service/thrift/ConfigNodeRPCService.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 5 +
consensus/pom.xml | 2 +-
.../iotdb/consensus/config/ConsensusConfig.java | 9 +-
.../iotdb/consensus/config/IoTConsensusConfig.java | 40 +-
.../apache/iotdb/consensus/config/RatisConfig.java | 219 ++++--
.../iot/client/AsyncIoTConsensusServiceClient.java | 73 +-
.../iot/client/IoTConsensusClientPool.java | 24 +-
.../iot/client/SyncIoTConsensusServiceClient.java | 72 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 25 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 27 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 2 +-
distribution/pom.xml | 2 +-
docs/UserGuide/Cluster/Cluster-Maintenance.md | 83 ++
.../Maintenance-Tools/Maintenance-Command.md | 14 +-
.../Apache-IoTDB-ConfigNode-Dashboard.json | 2 +-
.../Apache-IoTDB-DataNode-Dashboard.json | 6 +-
docs/UserGuide/Monitor-Alert/Metric-Tool.md | 51 +-
.../Operators-Functions/User-Defined-Function.md | 2 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 16 +-
.../Reference/ConfigNode-Config-Manual.md | 18 +
docs/UserGuide/Reference/DataNode-Config-Manual.md | 18 +
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 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 16 +-
.../Reference/ConfigNode-Config-Manual.md | 20 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 18 +
docs/zh/UserGuide/Reference/Status-Codes.md | 2 +
example/client-cpp-example/pom.xml | 2 +-
example/ext-pipe-plugin-example/pom.xml | 4 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 2 +-
example/influxdb-protocol-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pom.xml | 2 +-
example/pulsar/pom.xml | 2 +-
example/rabbitmq/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
.../org/apache/iotdb/trigger/SimpleTrigger.java | 38 -
.../iotdb/trigger/StatisticsUpdaterTrigger.java | 160 ++++
.../apache/iotdb/trigger/old/AlertingExample.java | 108 ---
example/tsfile/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
external-api/pom.xml | 2 +-
external-pipe-api/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana-connector/pom.xml | 4 +-
grafana-plugin/pom.xml | 2 +-
hadoop/pom.xml | 2 +-
hive-connector/pom.xml | 2 +-
influxdb-protocol/pom.xml | 2 +-
integration-test/checkstyle.xml | 2 +-
integration-test/pom.xml | 9 +-
.../trigger/example/TriggerFireTimesCounter.java | 26 +-
.../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 | 144 ++--
.../it/env/{ => cluster}/AbstractNodeWrapper.java | 149 ++--
.../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 ++++++++
.../iotdb/it/env/cluster/MppConfigNodeConfig.java | 43 +-
.../MppDataNodeConfig.java} | 33 +-
.../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 ++++++
.../it/env/remote/RemoteConfigNodeConfig.java | 9 +-
.../iotdb/it/env/remote/RemoteDataNodeConfig.java | 9 +-
.../iotdb/it/env/{ => remote}/RemoteServerEnv.java | 48 +-
.../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 +++
.../apache/iotdb/itbase/env/ConfigNodeConfig.java | 9 +-
.../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 | 12 +-
.../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 | 14 +-
.../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 +-
.../src/test/resources/TriggerFireTimesCounter.jar | Bin 1397 -> 1519 bytes
integration/pom.xml | 2 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 2 +-
.../integration/IoTDBCompactionWithIDTableIT.java | 2 +-
.../integration/IoTDBSizeTieredCompactionIT.java | 4 +-
isession/pom.xml | 2 +-
jdbc/pom.xml | 2 +-
library-udf/pom.xml | 2 +-
metrics/dropwizard-metrics/pom.xml | 2 +-
.../dropwizard/DropwizardMetricNameTool.java | 11 +
.../dropwizard/reporter/DropwizardJmxReporter.java | 17 +-
.../type/DropwizardHistogramSnapshot.java | 14 +-
metrics/interface/pom.xml | 2 +-
.../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 +-
.../metrics/impl/DoNothingHistogramSnapshot.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 | 20 +-
.../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 +-
metrics/micrometer-metrics/pom.xml | 4 +-
.../micrometer/reporter/MicrometerJmxReporter.java | 8 +-
.../type/MicrometerHistogramSnapshot.java | 14 +-
.../metrics/micrometer/type/MicrometerTimer.java | 2 +-
....java => MicrometerTimerHistogramSnapshot.java} | 30 +-
metrics/pom.xml | 2 +-
mlnode/.flake8 | 33 +
mlnode/.gitignore | 5 +
external-pipe-api/pom.xml => mlnode/README.md | 42 +-
{client-py => mlnode}/iotdb/__init__.py | 0
.../iotdb => mlnode/iotdb/mlnode}/__init__.py | 0
mlnode/iotdb/mlnode/client.py | 51 ++
mlnode/iotdb/mlnode/config.py | 107 +++
mlnode/iotdb/mlnode/constant.py | 21 +
mlnode/iotdb/mlnode/exception.py | 26 +
mlnode/iotdb/mlnode/handler.py | 53 ++
mlnode/iotdb/mlnode/log.py | 34 +
mlnode/iotdb/mlnode/script.py | 36 +
mlnode/iotdb/mlnode/service.py | 60 ++
mlnode/iotdb/mlnode/util.py | 48 ++
mlnode/pom.xml | 2 +-
mlnode/pyproject.toml | 54 ++
mlnode/resources/conf/iotdb-mlnode.toml | 50 ++
mlnode/resources/conf/logging_config.ini | 40 +
node-commons/pom.xml | 2 +-
.../resources/conf/iotdb-common.properties | 4 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 2 +-
.../iotdb/commons/auth/user/BasicUserManager.java | 2 +-
.../apache/iotdb/commons/client/ClientManager.java | 11 +-
.../iotdb/commons/client/ClientPoolFactory.java | 145 +++-
.../iotdb/commons/client/IClientManager.java | 8 +-
.../apache/iotdb/commons/client/ThriftClient.java | 89 +++
.../AsyncConfigNodeHeartbeatServiceClient.java | 73 +-
.../async/AsyncConfigNodeIServiceClient.java | 75 +-
.../async/AsyncDataNodeHeartbeatServiceClient.java | 73 +-
.../async/AsyncDataNodeInternalServiceClient.java | 73 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 77 +-
....java => BorrowNullClientManagerException.java} | 9 +-
.../client/exception/ClientManagerException.java | 5 +
...ava => CreateTAsyncClientManagerException.java} | 7 +-
.../AsyncThriftClientFactory.java} | 42 +-
.../client/{ => factory}/BaseClientFactory.java | 9 +-
.../client/factory/ThriftClientFactory.java | 20 +-
.../client/{ => property}/ClientPoolProperty.java | 36 +-
.../ThriftClientProperty.java} | 12 +-
.../client/sync/SyncConfigNodeIServiceClient.java | 51 +-
.../sync/SyncDataNodeInternalServiceClient.java | 67 +-
.../SyncDataNodeMPPDataExchangeServiceClient.java | 57 +-
.../sync/SyncThriftClientWithErrorHandler.java | 62 +-
.../iotdb/commons/concurrent/ThreadName.java | 8 +-
.../threadpool/WrappedThreadPoolExecutor.java | 1 +
.../apache/iotdb/commons/conf/CommonConfig.java | 45 +-
.../iotdb/commons/conf/CommonDescriptor.java | 67 +-
.../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 +-
.../commons/schema/tree/AbstractTreeVisitor.java | 198 +++--
.../tree/AbstractTreeVisitorWithLimitOffset.java | 101 ---
.../iotdb/commons/schema/tree/ITreeNode.java | 4 +-
.../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 +-
.../iotdb/commons/client/ClientManagerTest.java | 83 +-
openapi/pom.xml | 2 +-
pom.xml | 5 +-
rewrite-tsfile-tool/pom.xml | 2 +-
.../java/org/apache/iotdb/RewriteTsFileTool.java | 2 +-
schema-engine-rocksdb/pom.xml | 2 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 158 +---
.../schemaregion/rocksdb/mnode/RMNode.java | 5 +
schema-engine-tag/pom.xml | 2 +-
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 111 +--
.../utils/ShowTimeSeriesResultUtils.java | 6 +-
server/pom.xml | 2 +-
.../resources/conf/iotdb-datanode.properties | 11 +
.../AuditLogOperation.java} | 15 +-
.../AuditLogStorage.java} | 13 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 236 ++++++
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 14 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 60 +-
.../org/apache/iotdb/db/client/ConfigNodeInfo.java | 2 +-
.../iotdb/db/client/DataNodeClientPoolFactory.java | 127 +---
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 129 +++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 49 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 64 +-
.../db/consensus/DataRegionConsensusImpl.java | 26 +-
.../db/consensus/SchemaRegionConsensusImpl.java | 28 +-
.../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 +-
.../ICrossSpaceCompactionFileSelector.java | 33 -
.../exception}/CompactionExceptionHandler.java | 5 +-
.../performer/ICompactionPerformer.java | 4 +-
.../performer/ICrossCompactionPerformer.java | 3 +-
.../performer/ISeqCompactionPerformer.java | 3 +-
.../performer/IUnseqCompactionPerformer.java | 3 +-
.../constant/CrossCompactionPerformer.java | 8 +-
.../constant/InnerSeqCompactionPerformer.java | 8 +-
.../constant/InnerUnseqCompactionPerformer.java | 8 +-
.../performer/impl/FastCompactionPerformer.java | 34 +-
.../impl/ReadChunkCompactionPerformer.java | 14 +-
.../impl/ReadPointCompactionPerformer.java | 36 +-
.../recover}/CompactionRecoverManager.java | 9 +-
.../recover}/CompactionRecoverTask.java | 15 +-
.../{ => execute}/task/AbstractCompactionTask.java | 6 +-
.../{ => execute}/task/CompactionTaskSummary.java | 2 +-
.../task}/CrossSpaceCompactionTask.java | 21 +-
.../task}/InnerSpaceCompactionTask.java | 17 +-
.../subtask}/FastCompactionPerformerSubTask.java | 9 +-
.../task/subtask}/ReadPointPerformerSubTask.java | 8 +-
.../task/subtask}/SubCompactionTaskSummary.java | 2 +-
.../{ => execute/utils}/CompactionUtils.java | 2 +-
.../utils/MultiTsFileDeviceIterator.java | 8 +-
.../fast}/AlignedSeriesCompactionExecutor.java | 19 +-
.../fast}/NonAlignedSeriesCompactionExecutor.java | 11 +-
.../executor/fast}/SeriesCompactionExecutor.java | 29 +-
.../fast/element}/ChunkMetadataElement.java | 2 +-
.../utils/executor/fast/element}/FileElement.java | 2 +-
.../utils/executor/fast/element}/PageElement.java | 2 +-
.../utils/executor/fast/element}/PointElement.java | 2 +-
.../AlignedSeriesCompactionExecutor.java | 17 +-
.../readchunk}/SingleSeriesCompactionExecutor.java | 24 +-
.../utils}/log/CompactionLogAnalyzer.java | 20 +-
.../{ => execute/utils}/log/CompactionLogger.java | 2 +-
.../{ => execute/utils}/log/TsFileIdentifier.java | 2 +-
.../utils}/reader/IDataBlockReader.java | 2 +-
.../utils}/reader/PointPriorityReader.java | 8 +-
.../utils}/reader/SeriesDataBlockReader.java | 2 +-
.../utils}/writer/AbstractCompactionWriter.java | 20 +-
.../writer/AbstractCrossCompactionWriter.java | 6 +-
.../writer/AbstractInnerCompactionWriter.java | 6 +-
.../utils}/writer/FastCrossCompactionWriter.java | 2 +-
.../utils}/writer/FastInnerCompactionWriter.java | 2 +-
.../writer/ReadPointCrossCompactionWriter.java | 2 +-
.../writer/ReadPointInnerCompactionWriter.java | 2 +-
.../{ => schedule}/CompactionScheduler.java | 14 +-
.../{ => schedule}/CompactionTaskManager.java | 25 +-
.../{ => schedule}/CompactionWorker.java | 8 +-
.../DefaultCompactionTaskComparatorImpl.java | 10 +-
.../comparator/ICompactionTaskComparator.java | 8 +-
.../constant/CompactionPriority.java | 2 +-
.../constant/CompactionTaskStatus.java | 2 +-
.../{ => schedule}/constant/CompactionType.java | 2 +-
.../{ => schedule}/constant/ProcessChunkType.java | 2 +-
.../{task => selector}/ICompactionSelector.java | 14 +-
.../{cross => selector}/ICrossSpaceSelector.java | 6 +-
.../IInnerSeqSpaceSelector.java | 4 +-
.../IInnerUnseqSpaceSelector.java | 4 +-
.../constant/CrossCompactionSelector.java | 6 +-
.../constant/InnerSequenceCompactionSelector.java | 6 +-
.../InnerUnsequenceCompactionSelector.java | 6 +-
.../estimator}/AbstractCompactionEstimator.java | 2 +-
.../estimator}/AbstractCrossSpaceEstimator.java | 3 +-
.../estimator}/AbstractInnerSpaceEstimator.java | 3 +-
.../estimator}/IFileQueryMemMeasurement.java | 2 +-
.../estimator}/InplaceCompactionEstimator.java | 3 +-
.../ReadPointCrossCompactionEstimator.java | 3 +-
.../impl}/RewriteCrossSpaceCompactionSelector.java | 23 +-
.../impl}/SizeTieredCompactionSelector.java | 17 +-
.../utils}/CrossCompactionTaskResource.java | 2 +-
.../utils}/CrossSpaceCompactionCandidate.java | 14 +-
.../iotdb/db/engine/load/LoadTsFileManager.java | 12 +-
.../modification/utils/TracedBufferedReader.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 10 +-
.../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/localconfignode/LocalConfigNode.java | 843 +--------------------
.../localconfignode/LocalSchemaPartitionTable.java | 2 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 85 +--
.../db/metadata/cache/DataNodeSchemaCache.java | 1 -
.../idtable/AppendOnlyDiskSchemaManager.java | 6 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 2 +-
.../idtable/entry/InsertMeasurementMNode.java | 5 +
.../db/metadata/mnode/AboveDatabaseMNode.java | 24 +-
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 7 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 5 +
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 2 +-
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 5 +
.../metadata/mnode/container/MNodeContainers.java | 7 +
.../mnode/iterator/AbstractTraverserIterator.java | 115 +++
.../iterator/CachedTraverserIterator.java} | 31 +-
.../iterator/MemoryTraverserIterator.java} | 22 +-
.../iotdb/db/metadata/mtree/ConfigMTree.java | 325 +++-----
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 147 +---
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 552 +++++---------
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 596 ++++++---------
.../db/metadata/mtree/store/CachedMTreeStore.java | 36 +-
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 6 +
.../db/metadata/mtree/store/MemMTreeStore.java | 19 +
.../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 | 464 +-----------
.../traverser/TraverserWithLimitOffsetWrapper.java | 122 +++
.../DatabaseTraverser.java} | 49 +-
.../mtree/traverser/basic/EntityTraverser.java | 74 ++
.../mtree/traverser/basic/MNodeTraverser.java | 103 +++
.../MeasurementTraverser.java} | 55 +-
.../traverser/collector/CollectorTraverser.java | 96 ---
...eGroupCollector.java => DatabaseCollector.java} | 38 +-
.../mtree/traverser/collector/EntityCollector.java | 39 +-
.../traverser/collector/MNodeAboveSGCollector.java | 25 +-
.../mtree/traverser/collector/MNodeCollector.java | 58 +-
.../traverser/collector/MeasurementCollector.java | 60 +-
.../metadata/mtree/traverser/counter/Counter.java | 9 +-
...orageGroupCounter.java => DatabaseCounter.java} | 31 +-
.../mtree/traverser/counter/EntityCounter.java | 27 +-
.../mtree/traverser/counter/MNodeLevelCounter.java | 83 --
.../traverser/counter/MeasurementCounter.java | 73 --
.../counter/MeasurementGroupByLevelCounter.java | 126 ---
.../mtree/traverser/updater/EntityUpdater.java | 65 ++
.../traverser/updater/MeasurementUpdater.java | 66 ++
.../mtree/traverser/updater/Updater.java} | 18 +-
.../impl/read/AbstractShowSchemaPlanImpl.java | 2 +-
.../impl/read/SchemaRegionReadPlanFactory.java | 25 +-
.../impl/read/ShowDevicesPlanImpl.java | 20 +-
.../schemaregion/impl/read/ShowNodesPlanImpl.java} | 23 +-
.../plan/schemaregion/read/IShowDevicesPlan.java | 4 +-
.../{IShowDevicesPlan.java => IShowNodesPlan.java} | 4 +-
.../plan/schemaregion/result/ShowNodesResult.java | 33 +-
.../plan/schemaregion/result/ShowSchemaResult.java | 4 +-
.../schemaregion/result/ShowTimeSeriesResult.java | 11 +-
.../info/INodeSchemaInfo.java} | 9 +-
.../metadata/query/info/ITimeSeriesSchemaInfo.java | 2 +
.../db/metadata/schemaregion/ISchemaRegion.java | 137 +---
.../db/metadata/schemaregion/SchemaEngine.java | 8 +-
.../schemaregion/SchemaRegionMemoryImpl.java | 290 ++-----
.../schemaregion/SchemaRegionSchemaFileImpl.java | 229 +-----
.../storagegroup/IStorageGroupSchemaManager.java | 153 +---
.../storagegroup/StorageGroupSchemaManager.java | 154 +---
.../metadata/template/ClusterTemplateManager.java | 8 +-
.../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 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 4 +-
.../iotdb/db/mpp/common/header/DatasetHeader.java | 2 +-
.../mpp/common/schematree/ClusterSchemaTree.java | 22 +-
.../common/schematree/node/SchemaInternalNode.java | 1 +
.../db/mpp/common/schematree/node/SchemaNode.java | 2 +-
.../visitor/SchemaTreeDeviceVisitor.java | 17 +-
.../visitor/SchemaTreeMeasurementVisitor.java | 21 +-
.../schematree/visitor/SchemaTreeVisitor.java | 22 +-
...eVisitor.java => SchemaTreeVisitorFactory.java} | 43 +-
.../SchemaTreeVisitorWithLimitOffsetWrapper.java | 120 +++
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 2 +-
.../iotdb/db/mpp/execution/QueryStateMachine.java | 9 +
.../iotdb/db/mpp/execution/StateMachine.java | 4 +-
.../iotdb/db/mpp/execution/driver/DataDriver.java | 37 +-
.../db/mpp/execution/driver/DataDriverContext.java | 48 +-
.../iotdb/db/mpp/execution/driver/Driver.java | 34 +-
.../db/mpp/execution/driver/DriverContext.java | 76 +-
.../iotdb/db/mpp/execution/driver/IDriver.java | 5 +-
.../db/mpp/execution/driver/SchemaDriver.java | 5 +-
.../mpp/execution/driver/SchemaDriverContext.java | 13 +-
.../exchange/IMPPDataExchangeManager.java | 4 +-
.../db/mpp/execution/exchange/LocalSinkHandle.java | 25 +-
.../mpp/execution/exchange/LocalSourceHandle.java | 27 +-
.../execution/exchange/MPPDataExchangeManager.java | 113 ++-
.../execution/exchange/MPPDataExchangeService.java | 5 +-
.../mpp/execution/exchange/SharedTsBlockQueue.java | 5 +
.../db/mpp/execution/exchange/SinkHandle.java | 2 +-
.../db/mpp/execution/exchange/SourceHandle.java | 3 +-
.../fragment/FragmentInstanceContext.java | 128 ++--
.../fragment/FragmentInstanceExecution.java | 25 +-
.../fragment/FragmentInstanceManager.java | 37 +-
.../mpp/execution/operator/AbstractOperator.java | 94 +++
.../db/mpp/execution/operator/OperatorContext.java | 32 +-
.../operator/factory/OperatorFactory.java | 26 +-
.../operator/factory/SourceOperatorFactory.java} | 17 +-
.../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 | 32 +-
.../process/join/VerticallyConcatOperator.java | 2 +-
.../last/AbstractUpdateLastCacheOperator.java | 4 +-
...or.java => CountGroupByLevelMergeOperator.java} | 87 +--
...tor.java => CountGroupByLevelScanOperator.java} | 129 ++--
.../operator/schema/CountMergeOperator.java | 43 +-
.../schema/NodePathsSchemaScanOperator.java | 94 ++-
.../schema/PathsUsingTemplateScanOperator.java | 82 --
...CountOperator.java => SchemaCountOperator.java} | 91 ++-
.../schema/SchemaQueryOrderByHeatOperator.java | 5 +-
.../operator/schema/SchemaQueryScanOperator.java | 76 +-
.../operator/schema/TimeSeriesCountOperator.java | 138 ----
.../DeviceSchemaSource.java} | 69 +-
.../operator/schema/source/ISchemaSource.java | 50 ++
.../operator/schema/source/NodeSchemaSource.java | 81 ++
.../schema/source/PathsUsingTemplateSource.java | 118 +++
.../schema/source/SchemaSourceFactory.java | 78 ++
.../TimeSeriesSchemaSource.java} | 88 +--
.../source/AbstractDataSourceOperator.java | 21 +-
.../AbstractSeriesAggregationScanOperator.java | 23 +-
.../operator/source/AbstractSourceOperator.java} | 14 +-
.../operator/source/AlignedSeriesScanOperator.java | 50 +-
.../operator/source/AlignedSeriesScanUtil.java | 3 +-
.../operator/source/ExchangeOperator.java | 4 +
.../operator/source/SeriesScanOperator.java | 117 ++-
.../execution/operator/source/SeriesScanUtil.java | 6 +-
.../execution/schedule/AbstractDriverThread.java | 20 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 144 ++--
...eption.java => DriverTaskAbortedException.java} | 8 +-
.../mpp/execution/schedule/DriverTaskThread.java | 12 +-
.../schedule/DriverTaskTimeoutSentinelThread.java | 2 +-
.../mpp/execution/schedule/IDriverScheduler.java | 7 +-
.../schedule/queue/IDIndexedAccessible.java | 2 +-
.../schedule/queue/IndexedBlockingQueue.java | 3 +-
.../execution/schedule/queue/L1PriorityQueue.java | 10 +-
.../execution/schedule/queue/L2PriorityQueue.java | 16 +-
.../db/mpp/execution/schedule/task/DriverTask.java | 44 +-
.../task/{DriverTaskID.java => DriverTaskId.java} | 49 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 10 +-
.../apache/iotdb/db/mpp/plan/TestRPCClient.java | 16 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 4 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 10 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 6 +-
.../db/mpp/plan/analyze/cache/PartitionCache.java | 11 +-
.../analyze/cache/StorageGroupCacheResult.java | 2 +-
.../db/mpp/plan/execution/IQueryExecution.java | 2 +
.../db/mpp/plan/execution/QueryExecution.java | 17 +-
.../mpp/plan/execution/config/ConfigExecution.java | 5 +
.../plan/execution/config/ConfigTaskVisitor.java | 7 +
.../config/executor/ClusterConfigTaskExecutor.java | 55 +-
.../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 +-
.../plan/planner/LocalExecutionPlanContext.java | 175 +++--
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 100 +--
.../plan/planner/MemoryDistributionCalculator.java | 472 ------------
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 392 ++++++----
.../db/mpp/plan/planner/PipelineDriverFactory.java | 59 ++
.../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 +-
.../iotdb/db/query/control/SessionManager.java | 45 +-
.../query/control/clientsession/ClientSession.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../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 +-
.../recorder/CompactionMetricsRecorder.java | 12 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 119 ++-
.../impl/DataNodeInternalRPCServiceImpl.java | 21 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 15 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 6 +-
.../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 | 37 +-
.../trigger/service/TriggerInformationUpdater.java | 8 +-
.../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 +-
.../file/UnsealedTsFileRecoverPerformer.java | 10 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 4 +-
.../wal/utils/listener/AbstractResultListener.java | 2 +-
.../engine/compaction/AbstractCompactionTest.java | 5 +-
.../engine/compaction/CompactionSchedulerTest.java | 10 +-
.../CompactionSchedulerWithFastPerformerTest.java | 10 +-
.../compaction/CompactionTaskComparatorTest.java | 17 +-
.../compaction/CompactionTaskManagerTest.java | 13 +-
.../compaction/FastAlignedCrossCompactionTest.java | 4 +-
.../FastCrossCompactionPerformerTest.java | 11 +-
.../FastInnerCompactionPerformerTest.java | 8 +-
.../FastNonAlignedCrossCompactionTest.java | 4 +-
.../ReadPointCompactionPerformerTest.java | 11 +-
.../db/engine/compaction/TsFileIdentifierUT.java | 4 +-
.../cross/CrossSpaceCompactionExceptionTest.java | 16 +-
.../CrossSpaceCompactionWithFastPerformerTest.java | 13 +-
...eCompactionWithFastPerformerValidationTest.java | 20 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 13 +-
...actionWithReadPointPerformerValidationTest.java | 18 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 6 +-
.../RewriteCrossSpaceCompactionRecoverTest.java | 16 +-
...eCrossSpaceCompactionWithFastPerformerTest.java | 7 +-
...sSpaceCompactionWithReadPointPerformerTest.java | 7 +-
.../inner/FastCompactionPerformerAlignedTest.java | 10 +-
.../FastCompactionPerformerNoAlignedTest.java | 10 +-
.../inner/InnerCompactionEmptyTsFileTest.java | 7 +-
.../compaction/inner/InnerCompactionLogTest.java | 6 +-
.../inner/InnerCompactionMoreDataTest.java | 8 +-
.../inner/InnerCompactionSchedulerTest.java | 4 +-
.../InnerSeqCompactionWithFastPerformerTest.java | 9 +-
...nerSeqCompactionWithReadChunkPerformerTest.java | 9 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 12 +-
.../InnerUnseqCompactionWithFastPerformerTest.java | 8 +-
...rUnseqCompactionWithReadPointPerformerTest.java | 8 +-
.../ReadChunkCompactionPerformerAlignedTest.java | 8 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 8 +-
.../inner/ReadChunkCompactionPerformerOldTest.java | 10 +-
.../SizeTieredCompactionRecoverTest.java | 22 +-
.../SizeTieredCompactionSelectorTest.java | 1 +
...eCrossSpaceCompactionRecoverCompatibleTest.java | 4 +-
.../SizeTieredCompactionRecoverCompatibleTest.java | 12 +-
.../recover/SizeTieredCompactionRecoverTest.java | 18 +-
.../compaction/utils/CompactionCheckerUtils.java | 4 +-
.../compaction/utils/CompactionClearUtils.java | 2 +-
.../compaction/utils/CompactionConfigRestorer.java | 14 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 2 +-
.../db/engine/storagegroup/DataRegionTest.java | 10 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 4 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 53 --
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 383 ----------
.../schemaRegion/SchemaRegionBasicTest.java | 171 ++---
.../schemaRegion/SchemaRegionTemplateTest.java | 72 +-
.../schemaRegion/SchemaRegionTestUtil.java | 126 +++
.../apache/iotdb/db/metric/MetricServiceTest.java | 4 +-
.../common/schematree/ClusterSchemaTreeTest.java | 110 ++-
.../ClusterSchemaTreeTestWithRelease.java} | 31 +-
.../MockSchemaTreeMeasurementVisitor.java | 105 +++
.../iotdb/db/mpp/execution/DataDriverTest.java | 52 +-
.../execution/exchange/LocalSinkHandleTest.java | 26 +-
.../execution/exchange/LocalSourceHandleTest.java | 12 +-
.../exchange/MPPDataExchangeManagerTest.java | 16 +-
.../operator/AggregationOperatorTest.java | 17 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 9 +-
.../operator/AlignedSeriesScanOperatorTest.java | 92 +--
.../operator/DeviceMergeOperatorTest.java | 77 +-
.../execution/operator/DeviceViewOperatorTest.java | 16 +-
.../mpp/execution/operator/FillOperatorTest.java | 17 +-
.../operator/LastQueryMergeOperatorTest.java | 25 +-
.../execution/operator/LastQueryOperatorTest.java | 49 +-
.../operator/LastQuerySortOperatorTest.java | 49 +-
.../mpp/execution/operator/LimitOperatorTest.java | 22 +-
.../execution/operator/LinearFillOperatorTest.java | 57 +-
.../execution/operator/MergeSortOperatorTest.java | 208 +++--
.../mpp/execution/operator/OffsetOperatorTest.java | 73 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 258 ++-----
.../operator/RawDataAggregationOperatorTest.java | 22 +-
.../SeriesAggregationScanOperatorTest.java | 8 +-
.../execution/operator/SeriesScanOperatorTest.java | 8 +-
.../operator/SingleDeviceViewOperatorTest.java | 20 +-
.../SlidingWindowAggregationOperatorTest.java | 12 +-
.../execution/operator/TimeJoinOperatorTest.java | 56 +-
.../operator/UpdateLastCacheOperatorTest.java | 13 +-
.../operator/VerticallyConcatOperatorTest.java | 14 +-
.../schema/CountGroupByLevelMergeOperatorTest.java | 174 +++++
.../operator/schema/CountMergeOperatorTest.java | 139 ----
.../operator/schema/SchemaCountOperatorTest.java | 244 +++---
.../schema/SchemaQueryScanOperatorTest.java | 76 +-
.../schedule/DefaultDriverSchedulerTest.java | 166 ++--
.../execution/schedule/DriverSchedulerTest.java | 45 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 23 +-
.../schedule/queue/L1PriorityQueueTest.java | 6 +-
.../schedule/queue/L2PriorityQueueTest.java | 12 +-
.../mpp/execution/schedule/queue/QueueElement.java | 4 +-
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 4 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 11 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 9 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 4 +-
.../iotdb/db/wal/utils/WALFileUtilsTest.java | 26 +
service-rpc/pom.xml | 2 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
session/pom.xml | 2 +-
site/pom.xml | 2 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/pom.xml | 2 +-
testcontainer/pom.xml | 2 +-
thrift-commons/pom.xml | 2 +-
thrift-confignode/pom.xml | 2 +-
.../src/main/thrift/confignode.thrift | 3 +
thrift-influxdb/pom.xml | 2 +-
thrift-iot-consensus/pom.xml | 2 +-
thrift-mlnode/pom.xml | 2 +-
thrift-mlnode/src/main/thrift/mlnode.thrift | 10 +-
thrift/pom.xml | 2 +-
thrift/src/main/thrift/datanode.thrift | 2 +
trigger-api/pom.xml | 2 +-
tsfile/pom.xml | 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 +
udf-api/pom.xml | 2 +-
zeppelin-interpreter/pom.xml | 2 +-
941 files changed, 13088 insertions(+), 14241 deletions(-)
delete mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/SimpleTrigger.java
create mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/StatisticsUpdaterTrigger.java
delete mode 100644
example/trigger/src/main/java/org/apache/iotdb/trigger/old/AlertingExample.java
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 (87%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ =>
cluster}/AbstractNodeWrapper.java (71%)
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
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/reporter/iotdb/MemoryInternalIoTDBReporter.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/cluster/MppConfigNodeConfig.java
(52%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{SimpleEnv.java
=> 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
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/read/IShowDevicesPlan.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteConfigNodeConfig.java
(83%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/read/IShowDevicesPlan.java
=>
integration-test/src/main/java/org/apache/iotdb/it/env/remote/RemoteDataNodeConfig.java
(84%)
rename integration-test/src/main/java/org/apache/iotdb/it/env/{ =>
remote}/RemoteServerEnv.java (85%)
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
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/ITreeNode.java
=>
integration-test/src/main/java/org/apache/iotdb/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
metrics/micrometer-metrics/src/main/java/org/apache/iotdb/metrics/micrometer/type/{MicrometerHistogramSnapshot.java
=> MicrometerTimerHistogramSnapshot.java} (73%)
create mode 100644 mlnode/.flake8
copy external-pipe-api/pom.xml => mlnode/README.md (54%)
copy {client-py => mlnode}/iotdb/__init__.py (100%)
copy {client-py/iotdb => mlnode/iotdb/mlnode}/__init__.py (100%)
create mode 100644 mlnode/iotdb/mlnode/client.py
create mode 100644 mlnode/iotdb/mlnode/config.py
create mode 100644 mlnode/iotdb/mlnode/constant.py
create mode 100644 mlnode/iotdb/mlnode/exception.py
create mode 100644 mlnode/iotdb/mlnode/handler.py
create mode 100644 mlnode/iotdb/mlnode/log.py
create mode 100644 mlnode/iotdb/mlnode/script.py
create mode 100644 mlnode/iotdb/mlnode/service.py
create mode 100644 mlnode/iotdb/mlnode/util.py
create mode 100644 mlnode/pyproject.toml
create mode 100644 mlnode/resources/conf/iotdb-mlnode.toml
create mode 100644 mlnode/resources/conf/logging_config.ini
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/client/ThriftClient.java
copy
node-commons/src/main/java/org/apache/iotdb/commons/client/exception/{ClientManagerException.java
=> BorrowNullClientManagerException.java} (79%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/client/exception/{ClientManagerException.java
=> CreateTAsyncClientManagerException.java} (82%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/client/{AsyncBaseClientFactory.java
=> factory/AsyncThriftClientFactory.java} (50%)
rename node-commons/src/main/java/org/apache/iotdb/commons/client/{ =>
factory}/BaseClientFactory.java (82%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/source/SeriesSourceNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/client/factory/ThriftClientFactory.java
(61%)
rename node-commons/src/main/java/org/apache/iotdb/commons/client/{ =>
property}/ClientPoolProperty.java (65%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/client/{ClientFactoryProperty.java
=> property/ThriftClientProperty.java} (93%)
delete mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/schema/tree/AbstractTreeVisitorWithLimitOffset.java
copy
server/src/main/java/org/apache/iotdb/db/{engine/compaction/constant/CompactionPriority.java
=> audit/AuditLogOperation.java} (83%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/compaction/constant/CompactionPriority.java
=> audit/AuditLogStorage.java} (84%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/audit/AuditLogger.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/selector/ICrossSpaceCompactionFileSelector.java
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/exception}/CompactionExceptionHandler.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/ICompactionPerformer.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/ICrossCompactionPerformer.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/ISeqCompactionPerformer.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/IUnseqCompactionPerformer.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/performer}/constant/CrossCompactionPerformer.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/performer}/constant/InnerSeqCompactionPerformer.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/performer}/constant/InnerUnseqCompactionPerformer.java (81%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/impl/FastCompactionPerformer.java (88%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/impl/ReadChunkCompactionPerformer.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/performer/impl/ReadPointCompactionPerformer.java (88%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/recover}/CompactionRecoverManager.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task =>
execute/recover}/CompactionRecoverTask.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/task/AbstractCompactionTask.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute}/task/CompactionTaskSummary.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross =>
execute/task}/CrossSpaceCompactionTask.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner =>
execute/task}/InnerSpaceCompactionTask.java (96%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite/task
=> execute/task/subtask}/FastCompactionPerformerSubTask.java (93%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite/task
=> execute/task/subtask}/ReadPointPerformerSubTask.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task =>
execute/task/subtask}/SubCompactionTaskSummary.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/CompactionUtils.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner =>
execute}/utils/MultiTsFileDeviceIterator.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast}/AlignedSeriesCompactionExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast}/NonAlignedSeriesCompactionExecutor.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast}/SeriesCompactionExecutor.java (96%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast/element}/ChunkMetadataElement.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast/element}/FileElement.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast/element}/PageElement.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> execute/utils/executor/fast/element}/PointElement.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/utils
=> execute/utils/executor/readchunk}/AlignedSeriesCompactionExecutor.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/utils
=> execute/utils/executor/readchunk}/SingleSeriesCompactionExecutor.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/log/CompactionLogAnalyzer.java (83%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/log/CompactionLogger.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/log/TsFileIdentifier.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/reader/IDataBlockReader.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/reader/PointPriorityReader.java (95%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/reader/SeriesDataBlockReader.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/AbstractCompactionWriter.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/AbstractCrossCompactionWriter.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/AbstractInnerCompactionWriter.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/FastCrossCompactionWriter.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/FastInnerCompactionWriter.java (99%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/ReadPointCrossCompactionWriter.java (98%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
execute/utils}/writer/ReadPointInnerCompactionWriter.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/CompactionScheduler.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/CompactionTaskManager.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/CompactionWorker.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/comparator/DefaultCompactionTaskComparatorImpl.java (92%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/comparator/ICompactionTaskComparator.java (79%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/constant/CompactionPriority.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/constant/CompactionTaskStatus.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/constant/CompactionType.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
schedule}/constant/ProcessChunkType.java (93%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{task =>
selector}/ICompactionSelector.java (83%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross =>
selector}/ICrossSpaceSelector.java (83%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner =>
selector}/IInnerSeqSpaceSelector.java (89%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner =>
selector}/IInnerUnseqSpaceSelector.java (89%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
selector}/constant/CrossCompactionSelector.java (88%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
selector}/constant/InnerSequenceCompactionSelector.java (87%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{ =>
selector}/constant/InnerUnsequenceCompactionSelector.java (87%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> selector/estimator}/AbstractCompactionEstimator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross =>
selector/estimator}/AbstractCrossSpaceEstimator.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner =>
selector/estimator}/AbstractInnerSpaceEstimator.java (91%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> selector/estimator}/IFileQueryMemMeasurement.java (94%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> selector/estimator}/InplaceCompactionEstimator.java (97%)
rename server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/utils
=> selector/estimator}/ReadPointCrossCompactionEstimator.java (98%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite =>
selector/impl}/RewriteCrossSpaceCompactionSelector.java (91%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{inner/sizetiered =>
selector/impl}/SizeTieredCompactionSelector.java (92%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite =>
selector/utils}/CrossCompactionTaskResource.java (98%)
rename
server/src/main/java/org/apache/iotdb/db/engine/compaction/{cross/rewrite =>
selector/utils}/CrossSpaceCompactionCandidate.java (96%)
copy
server/src/main/java/org/apache/iotdb/db/exception/{metadata/template/NoTemplateOnMNodeException.java
=> query/KilledByOthersException.java} (67%)
rename
node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncThriftClient.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mnode/AboveDatabaseMNode.java
(67%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/iterator/AbstractTraverserIterator.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/{mtree/traverser/counter/EntityCounter.java
=> mnode/iterator/CachedTraverserIterator.java} (61%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/{mtree/traverser/counter/CounterTraverser.java
=> mnode/iterator/MemoryTraverserIterator.java} (64%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/TraverserWithLimitOffsetWrapper.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{collector/StorageGroupCollector.java
=> basic/DatabaseTraverser.java} (53%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/basic/EntityTraverser.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/basic/MNodeTraverser.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/{counter/MNodeAboveSGLevelCounter.java
=> basic/MeasurementTraverser.java} (50%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/CollectorTraverser.java
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/collector/{StorageGroupCollector.java
=> DatabaseCollector.java} (58%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/client/exception/ClientManagerException.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/Counter.java
(80%)
rename
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/counter/{StorageGroupCounter.java
=> DatabaseCounter.java} (62%)
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/metadata/mtree/traverser/updater/EntityUpdater.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mtree/traverser/updater/MeasurementUpdater.java
copy
server/src/main/java/org/apache/iotdb/db/{exception/metadata/schemafile/RecordDuplicatedException.java
=> metadata/mtree/traverser/updater/Updater.java} (65%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/planner/plan/node/source/SeriesSourceNode.java
=> metadata/plan/schemaregion/impl/read/ShowNodesPlanImpl.java} (64%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/read/{IShowDevicesPlan.java
=> IShowNodesPlan.java} (91%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/path/fa/dfa/transition/AbstractDFATransition.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/result/ShowNodesResult.java
(57%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/{plan/schemaregion/read/IShowDevicesPlan.java
=> query/info/INodeSchemaInfo.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/{SchemaTreeVisitor.java
=> SchemaTreeVisitorFactory.java} (51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/common/schematree/visitor/SchemaTreeVisitorWithLimitOffsetWrapper.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/DoNothingMetricService.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/factory/OperatorFactory.java
(58%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/{plan/planner/plan/node/process/ProcessNode.java
=> execution/operator/factory/SourceOperatorFactory.java} (63%)
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%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{LevelTimeSeriesCountOperator.java
=> CountGroupByLevelScanOperator.java} (50%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/PathsUsingTemplateScanOperator.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesCountOperator.java
=> SchemaCountOperator.java} (59%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/TimeSeriesCountOperator.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{DevicesSchemaScanOperator.java
=> source/DeviceSchemaSource.java} (52%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/ISchemaSource.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/NodeSchemaSource.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/PathsUsingTemplateSource.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/source/SchemaSourceFactory.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{TimeSeriesSchemaScanOperator.java
=> source/TimeSeriesSchemaSource.java} (62%)
copy
metrics/interface/src/main/java/org/apache/iotdb/metrics/type/Counter.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
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/{FragmentInstanceAbortedException.java
=> DriverTaskAbortedException.java} (82%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/schedule/task/{DriverTaskID.java
=> DriverTaskId.java} (56%)
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%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/MemoryDistributionCalculator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/PipelineDriverFactory.java
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%)
copy server/src/test/java/org/apache/iotdb/db/{utils/SchemaTestUtils.java =>
mpp/common/schematree/ClusterSchemaTreeTestWithRelease.java} (56%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/common/schematree/MockSchemaTreeMeasurementVisitor.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountGroupByLevelMergeOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/schema/CountMergeOperatorTest.java
