This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch tsbs/iot in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 367e010486213fcec2cdc2a9046342b98210617d Merge: 6eb29f4365e 1a16b6d333a Author: JackieTien97 <[email protected]> AuthorDate: Tue May 7 17:20:47 2024 +0800 Merge remote-tracking branch 'origin/master' into tsbs/iot .git-blame-ignore-revs | 1 + .github/workflows/grafana-plugin.yml | 68 - .gitignore | 7 - codecov.yml | 1 - distribution/pom.xml | 133 - distribution/src/assembly/flink-sql-connector.xml | 41 - distribution/src/assembly/grafana-connector.xml | 48 - distribution/src/assembly/grafana-plugin.xml | 38 - distribution/src/assembly/spark-connector.xml | 48 - docker/ReadMe.md | 44 - .../GrafanaPlugin/Dockerfile-0.14.0-iotdb | 42 - .../DockerCompose/GrafanaPlugin/docker-compose.yml | 48 - .../main/DockerCompose/docker-compose-grafana.yml | 50 - docker/src/main/Dockerfile-0.12.6-grafana | 41 - .../src/main/Dockerfile-0.13.3-grafana-connector | 41 - example/flink-sql/pom.xml | 99 - .../org/apache/iotdb/example/BatchSinkExample.java | 74 - .../apache/iotdb/example/BoundedScanExample.java | 52 - .../java/org/apache/iotdb/example/CDCExample.java | 54 - .../org/apache/iotdb/example/LookupExample.java | 77 - .../apache/iotdb/example/StreamingSinkExample.java | 68 - example/flink/README.md | 40 - example/flink/pom.xml | 61 - .../org/apache/iotdb/flink/FlinkIoTDBSink.java | 101 - .../org/apache/iotdb/flink/FlinkIoTDBSource.java | 93 - .../apache/iotdb/flink/FlinkTsFileBatchSink.java | 128 - .../apache/iotdb/flink/FlinkTsFileBatchSource.java | 81 - .../apache/iotdb/flink/FlinkTsFileStreamSink.java | 129 - .../iotdb/flink/FlinkTsFileStreamSource.java | 84 - .../java/org/apache/iotdb/flink/TsFileUtils.java | 107 - example/hadoop/pom.xml | 38 - .../org/apache/iotdb/hadoop/tsfile/Constant.java | 32 - .../iotdb/hadoop/tsfile/TSFMRReadExample.java | 136 - .../iotdb/hadoop/tsfile/TSMRWriteExample.java | 185 - .../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 139 - .../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 77 - example/kafka/pom.xml | 48 - example/kafka/readme.md | 75 - .../main/java/org/apache/iotdb/kafka/Constant.java | 68 - .../main/java/org/apache/iotdb/kafka/Consumer.java | 136 - .../org/apache/iotdb/kafka/ConsumerThread.java | 164 - .../main/java/org/apache/iotdb/kafka/Producer.java | 63 - example/pom.xml | 15 +- example/pulsar/pom.xml | 55 - .../java/org/apache/iotdb/pulsar/Constant.java | 67 - .../org/apache/iotdb/pulsar/PulsarConsumer.java | 111 - .../apache/iotdb/pulsar/PulsarConsumerThread.java | 161 - .../org/apache/iotdb/pulsar/PulsarProducer.java | 55 - example/rabbitmq/pom.xml | 47 - example/rabbitmq/readme.md | 63 - .../java/org/apache/iotdb/rabbitmq/Constant.java | 72 - .../iotdb/rabbitmq/RabbitMQChannelUtils.java | 52 - .../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 139 - .../apache/iotdb/rabbitmq/RabbitMQProducer.java | 49 - example/rocketmq/pom.xml | 48 - example/rocketmq/readme.md | 83 - .../java/org/apache/iotdb/rocketmq/Constant.java | 70 - .../apache/iotdb/rocketmq/RocketMQConsumer.java | 208 - .../apache/iotdb/rocketmq/RocketMQProducer.java | 100 - .../main/java/org/apache/iotdb/rocketmq/Utils.java | 39 - .../org/apache/iotdb/DataMigrationExample.java | 4 +- .../iotdb/HybridTimeseriesSessionExample.java | 1 + .../iotdb/SyntaxConventionRelatedExample.java | 1 + integration-test/pom.xml | 61 +- .../it/env/cluster/config/MppCommonConfig.java | 18 + .../env/cluster/config/MppSharedCommonConfig.java | 21 + .../iotdb/it/env/cluster/env/AbstractEnv.java | 1 + .../it/env/remote/config/RemoteCommonConfig.java | 15 + .../org/apache/iotdb/itbase/env/CommonConfig.java | 6 + .../iotdb/itbase/runtime/ClusterTestStatement.java | 38 +- .../IoTDBRegionMigrateReliabilityITFramework.java | 8 +- .../db/it/aggregation/maxby/IoTDBMaxByIT.java | 4 +- .../db/it/aggregation/minby/IoTDBMinByIT.java | 4 +- .../db/it/schema/IoTDBCreateStorageGroupIT.java | 1 + .../apache/iotdb/db/it/schema/IoTDBTagLimitIT.java | 196 + .../org/apache/iotdb/flink/it/AbstractTest.java | 46 - .../java/org/apache/iotdb/flink/it/SinkTest.java | 163 - .../java/org/apache/iotdb/flink/it/SourceTest.java | 192 - .../test/java/org/apache/iotdb/flink/it/Utils.java | 94 - .../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 32 +- .../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 28 +- .../org/apache/iotdb/spark/it/AbstractTest.java | 55 - .../java/org/apache/iotdb/spark/it/ReadTest.java | 145 - .../test/java/org/apache/iotdb/spark/it/Utils.java | 95 - .../java/org/apache/iotdb/spark/it/WriteTest.java | 116 - .../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 4 +- .../it/dual/IoTDBSubscriptionTopicIT.java | 47 + .../iotdb/zeppelin/it/IoTDBInterpreterIT.java | 390 - .../main/java/org/apache/iotdb/udf/api/State.java | 3 +- .../main/java/org/apache/iotdb/udf/api/UDAF.java | 3 +- .../cli/src/assembly/resources/sbin/start-cli.bat | 2 +- .../cli/src/assembly/resources/tools/backup.bat | 125 - .../cli/src/assembly/resources/tools/backup.sh | 134 - .../src/assembly/resources/tools/export-data.bat | 6 +- .../src/assembly/resources/tools/export-tsfile.bat | 6 +- .../src/assembly/resources/tools/import-data.bat | 6 +- .../src/assembly/resources/tools/load-tsfile.bat | 2 +- .../java/org/apache/iotdb/tool/ExportTsFile.java | 4 +- .../java/org/apache/iotdb/tool/ImportData.java | 3 +- .../java/org/apache/iotdb/isession/ISession.java | 36 +- .../org/apache/iotdb/isession/SessionConfig.java | 1 + .../apache/iotdb/isession/pool/ISessionPool.java | 52 +- .../iotdb/isession/pool/SessionDataSetWrapper.java | 1 + .../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 4 +- .../main/java/org/apache/iotdb/jdbc/Config.java | 1 + .../org/apache/iotdb/jdbc/IoTDBConnection.java | 1 + .../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 11 +- .../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 1 + .../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 1 + .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 1 + .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 1 + .../rpc/subscription/config/ConsumerConfig.java | 8 + .../response/PipeSubscribeHandshakeResp.java | 26 +- .../java/org/apache/iotdb/session/Session.java | 33 +- .../org/apache/iotdb/session/pool/SessionPool.java | 12 +- .../session/subscription/SubscriptionConsumer.java | 30 +- .../subscription/SubscriptionEndpointsSyncer.java | 9 +- .../session/subscription/SubscriptionProvider.java | 25 +- .../SubscriptionSessionConnection.java | 6 +- iotdb-connector/flink-iotdb-connector/README.md | 58 - iotdb-connector/flink-iotdb-connector/pom.xml | 84 - .../iotdb/flink/DefaultIoTSerializationSchema.java | 130 - .../main/java/org/apache/iotdb/flink/Event.java | 70 - .../java/org/apache/iotdb/flink/IoTDBSink.java | 213 - .../java/org/apache/iotdb/flink/IoTDBSource.java | 100 - .../apache/iotdb/flink/IoTSerializationSchema.java | 32 - .../apache/iotdb/flink/options/IoTDBOptions.java | 70 - .../iotdb/flink/options/IoTDBSinkOptions.java | 106 - .../iotdb/flink/options/IoTDBSourceOptions.java | 51 - .../flink/DefaultIoTSerializationSchemaTest.java | 54 - .../iotdb/flink/IoTDBSinkBatchInsertTest.java | 116 - .../iotdb/flink/IoTDBSinkBatchTimerTest.java | 83 - .../apache/iotdb/flink/IoTDBSinkInsertTest.java | 72 - iotdb-connector/flink-sql-iotdb-connector/pom.xml | 124 - .../flink/sql/client/IoTDBWebSocketClient.java | 92 - .../org/apache/iotdb/flink/sql/common/Options.java | 64 - .../org/apache/iotdb/flink/sql/common/Utils.java | 177 - .../sql/exception/IllegalIoTDBPathException.java | 25 - .../sql/exception/IllegalOptionException.java | 25 - .../sql/exception/IllegalSchemaException.java | 25 - .../sql/exception/IllegalUrlPathException.java | 25 - .../exception/UnsupportedDataTypeException.java | 25 - .../sql/factory/IoTDBDynamicTableFactory.java | 230 - .../sql/function/IoTDBBoundedScanFunction.java | 167 - .../flink/sql/function/IoTDBCDCSourceFunction.java | 297 - .../flink/sql/function/IoTDBLookupFunction.java | 149 - .../flink/sql/function/IoTDBSinkFunction.java | 143 - .../flink/sql/provider/IoTDBDynamicTableSink.java | 64 - .../sql/provider/IoTDBDynamicTableSource.java | 76 - .../iotdb/flink/sql/wrapper/SchemaWrapper.java | 46 - .../iotdb/flink/sql/wrapper/TabletWrapper.java | 47 - .../org.apache.flink.table.factories.Factory | 20 - iotdb-connector/flink-tsfile-connector/README.md | 177 - iotdb-connector/flink-tsfile-connector/pom.xml | 158 - .../apache/iotdb/flink/tsfile/RowRecordParser.java | 46 - .../iotdb/flink/tsfile/RowRowRecordParser.java | 121 - .../iotdb/flink/tsfile/RowTSRecordConverter.java | 166 - .../iotdb/flink/tsfile/TSRecordConverter.java | 60 - .../iotdb/flink/tsfile/TSRecordOutputFormat.java | 98 - .../iotdb/flink/tsfile/TsFileInputFormat.java | 174 - .../iotdb/flink/tsfile/TsFileOutputFormat.java | 136 - .../iotdb/flink/tsfile/util/TSFileConfigUtil.java | 65 - .../RowTSRecordOutputFormatIntegrationTest.java | 54 - .../flink/tsfile/RowTSRecordOutputFormatTest.java | 75 - .../flink/tsfile/RowTsFileConnectorTestBase.java | 77 - .../RowTsFileInputFormatIntegrationTest.java | 108 - .../flink/tsfile/RowTsFileInputFormatTest.java | 88 - .../flink/tsfile/RowTsFileInputFormatTestBase.java | 49 - .../tsfile/RowTsFileOutputFormatTestBase.java | 119 - .../util/TSFileConfigUtilCompletenessTest.java | 102 - .../apache/iotdb/flink/util/TsFileWriteUtil.java | 233 - .../src/test/resources/log4j.properties | 28 - .../grafana-connector/img/add_data_source.png | Bin 108927 -> 0 bytes .../grafana-connector/img/add_graph.png | Bin 364163 -> 0 bytes .../grafana-connector/img/edit_data_source.png | Bin 177869 -> 0 bytes iotdb-connector/grafana-connector/pom.xml | 257 - iotdb-connector/grafana-connector/readme.md | 192 - iotdb-connector/grafana-connector/readme_zh.md | 195 - .../web/grafana/TsfileWebDemoApplication.java | 30 - .../apache/iotdb/web/grafana/bean/TimeValues.java | 47 - .../iotdb/web/grafana/conf/MyConfiguration.java | 47 - .../controller/DatabaseConnectController.java | 196 - .../org/apache/iotdb/web/grafana/dao/BasicDao.java | 34 - .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 208 - .../web/grafana/interceptor/LoginInterceptor.java | 64 - .../grafana/service/DatabaseConnectService.java | 33 - .../service/impl/DatabaseConnectServiceImpl.java | 46 - .../src/main/resources/application.properties | 39 - .../web/grafana/dao/impl/BasicDaoImplTest.java | 53 - iotdb-connector/grafana-plugin/.gitignore | 33 - iotdb-connector/grafana-plugin/.prettierrc.js | 20 - iotdb-connector/grafana-plugin/CHANGELOG.md | 24 - iotdb-connector/grafana-plugin/LICENSE | 201 - iotdb-connector/grafana-plugin/Magefile.go | 32 - iotdb-connector/grafana-plugin/README.md | 177 - iotdb-connector/grafana-plugin/backend-compile.bat | 31 - iotdb-connector/grafana-plugin/backend-compile.sh | 48 - iotdb-connector/grafana-plugin/go.mod | 107 - iotdb-connector/grafana-plugin/jest.config.js | 24 - iotdb-connector/grafana-plugin/package.json | 31 - iotdb-connector/grafana-plugin/pkg/main.go | 40 - .../pkg/plugin/iotdb_resource_handler.go | 170 - .../grafana-plugin/pkg/plugin/plugin.go | 430 - iotdb-connector/grafana-plugin/pom.xml | 116 - .../grafana-plugin/src/ConfigEditor.tsx | 108 - iotdb-connector/grafana-plugin/src/QueryEditor.tsx | 343 - .../src/componments/AggregateFun.tsx | 44 - .../src/componments/ControlValue.tsx | 38 - .../grafana-plugin/src/componments/FillValue.tsx | 38 - .../grafana-plugin/src/componments/Form.tsx | 42 - .../grafana-plugin/src/componments/FromValue.tsx | 110 - .../grafana-plugin/src/componments/GroupBy.tsx | 58 - .../grafana-plugin/src/componments/SelectValue.tsx | 110 - .../grafana-plugin/src/componments/TimeSeries.tsx | 82 - .../grafana-plugin/src/componments/WhereValue.tsx | 39 - iotdb-connector/grafana-plugin/src/datasource.ts | 106 - iotdb-connector/grafana-plugin/src/functions.ts | 20 - .../grafana-plugin/src/img/addIoTDBDataSource.png | Bin 43760 -> 0 bytes iotdb-connector/grafana-plugin/src/img/logo.svg | 271 - .../grafana-plugin/src/img/showData.png | Bin 170827 -> 0 bytes iotdb-connector/grafana-plugin/src/module.ts | 25 - iotdb-connector/grafana-plugin/src/plugin.json | 50 - iotdb-connector/grafana-plugin/src/types.ts | 68 - iotdb-connector/grafana-plugin/tsconfig.json | 9 - iotdb-connector/grafana-plugin/yarn.lock | 11194 ------------------- iotdb-connector/hadoop/README.md | 212 - iotdb-connector/hadoop/pom.xml | 191 - .../iotdb/hadoop/fileSystem/HDFSConfUtil.java | 115 - .../apache/iotdb/hadoop/fileSystem/HDFSFile.java | 455 - .../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 114 - .../apache/iotdb/hadoop/fileSystem/HDFSOutput.java | 108 - .../org/apache/iotdb/hadoop/tsfile/IReaderSet.java | 38 - .../iotdb/hadoop/tsfile/TSFHadoopException.java | 45 - .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 297 - .../apache/iotdb/hadoop/tsfile/TSFInputSplit.java | 39 - .../iotdb/hadoop/tsfile/TSFOutputFormat.java | 58 - .../iotdb/hadoop/tsfile/TSFRecordReader.java | 260 - .../iotdb/hadoop/tsfile/TSFRecordWriter.java | 62 - .../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 202 - .../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 229 - .../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 71 - .../iotdb/hadoop/tsfile/TsFileTestHelper.java | 121 - .../iotdb/hadoop/tsfile/constant/TestConstant.java | 28 - .../hadoop/src/test/resources/logback.xml | 41 - iotdb-connector/hive-connector/pom.xml | 139 - .../org/apache/iotdb/hive/TSFHiveInputFormat.java | 56 - .../org/apache/iotdb/hive/TSFHiveOutputFormat.java | 75 - .../org/apache/iotdb/hive/TSFHiveRecordReader.java | 158 - .../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 71 - .../org/apache/iotdb/hive/TsFileDeserializer.java | 159 - .../java/org/apache/iotdb/hive/TsFileSerDe.java | 169 - .../apache/iotdb/hive/TsFileSerDeException.java | 40 - .../apache/iotdb/hive/TSFHiveInputFormatTest.java | 111 - .../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 159 - .../apache/iotdb/hive/TsFileDeserializerTest.java | 126 - .../org/apache/iotdb/hive/TsFileSerDeTest.java | 149 - .../org/apache/iotdb/hive/TsFileTestHelper.java | 126 - .../apache/iotdb/hive/constant/TestConstant.java | 28 - .../hive-connector/src/test/resources/logback.xml | 39 - iotdb-connector/pom.xml | 66 - iotdb-connector/spark-iotdb-connector/pom.xml | 140 - .../spark-iotdb-connector/scala_2.11/pom.xml | 50 - .../spark-iotdb-connector/scala_2.12/pom.xml | 51 - .../org/apache/iotdb/spark/db/Converter.scala | 89 - .../org/apache/iotdb/spark/db/DataFrameTools.scala | 131 - .../org/apache/iotdb/spark/db/DefaultSource.scala | 61 - .../org/apache/iotdb/spark/db/IoTDBOptions.scala | 43 - .../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 137 - .../org/apache/iotdb/spark/db/IoTDBRelation.scala | 117 - .../org/apache/iotdb/spark/db/SQLConstant.scala | 27 - .../org/apache/iotdb/spark/db/Transformer.scala | 172 - .../scala/org/apache/iotdb/spark/db/package.scala | 36 - iotdb-connector/spark-tsfile/pom.xml | 114 - .../iotdb/spark/tsfile/io/TsFileOutputFormat.java | 45 - .../iotdb/spark/tsfile/io/TsFileRecordWriter.java | 61 - .../org/apache/iotdb/spark/tsfile/qp/Executor.java | 51 - .../iotdb/spark/tsfile/qp/QueryProcessor.java | 195 - .../spark/tsfile/qp/common/BasicOperator.java | 66 - .../spark/tsfile/qp/common/FilterOperator.java | 161 - .../iotdb/spark/tsfile/qp/common/Operator.java | 44 - .../iotdb/spark/tsfile/qp/common/SQLConstant.java | 138 - .../iotdb/spark/tsfile/qp/common/SingleQuery.java | 65 - .../iotdb/spark/tsfile/qp/common/TSQueryPlan.java | 68 - .../qp/exception/BasicOperatorException.java | 29 - .../tsfile/qp/exception/DNFOptimizeException.java | 29 - .../qp/exception/LogicalOptimizeException.java | 29 - .../tsfile/qp/exception/MergeFilterException.java | 28 - .../qp/exception/QueryOperatorException.java | 28 - .../qp/exception/QueryProcessorException.java | 37 - .../tsfile/qp/exception/RemoveNotException.java | 29 - .../tsfile/qp/optimizer/DNFFilterOptimizer.java | 154 - .../tsfile/qp/optimizer/IFilterOptimizer.java | 31 - .../qp/optimizer/MergeSingleFilterOptimizer.java | 133 - .../tsfile/qp/optimizer/PhysicalOptimizer.java | 251 - .../tsfile/qp/optimizer/RemoveNotOptimizer.java | 92 - .../org/apache/iotdb/spark/tsfile/Converter.scala | 144 - .../apache/iotdb/spark/tsfile/DefaultSource.scala | 293 - .../iotdb/spark/tsfile/NarrowConverter.scala | 596 - .../spark/tsfile/NarrowTsFileOutputWriter.scala | 50 - .../apache/iotdb/spark/tsfile/Transformer.scala | 175 - .../iotdb/spark/tsfile/TsFileWriterFactory.scala | 42 - .../apache/iotdb/spark/tsfile/WideConverter.scala | 504 - .../spark/tsfile/WideTsFileOutputWriter.scala | 53 - .../org/apache/iotdb/spark/tsfile/package.scala | 62 - .../apache/iotdb/spark/constant/TestConstant.java | 28 - .../org/apache/iotdb/spark/tool/TsFileExample.java | 111 - .../apache/iotdb/spark/tool/TsFileWriteTool.java | 280 - .../apache/iotdb/spark/tsfile/ConverterTest.scala | 270 - .../apache/iotdb/spark/tsfile/HDFSInputTest.java | 81 - .../org/apache/iotdb/spark/tsfile/TSFileSuit.scala | 641 -- .../zeppelin-interpreter/IoTDB-Zeppelin-Demo.zpln | 377 - iotdb-connector/zeppelin-interpreter/pom.xml | 90 - .../apache/zeppelin/iotdb/IoTDBInterpreter.java | 296 - .../src/main/resources/interpreter-setting.json | 70 - .../src/assembly/resources/conf/confignode-env.bat | 14 +- .../assembly/resources/sbin/remove-confignode.bat | 2 +- .../assembly/resources/sbin/start-confignode.bat | 10 +- .../assembly/resources/sbin/stop-confignode.bat | 4 +- .../iotdb/confignode/manager/ProcedureManager.java | 14 +- .../manager/consensus/ConsensusManager.java | 13 +- .../iotdb/confignode/manager/load/LoadManager.java | 46 +- .../manager/load/balancer/RouteBalancer.java | 9 +- .../router/leader/AbstractLeaderBalancer.java | 48 +- .../router/leader/GreedyLeaderBalancer.java | 14 +- .../router/leader/MinCostFlowLeaderBalancer.java | 142 +- .../confignode/manager/load/cache/LoadCache.java | 181 +- .../consensus/ConsensusGroupHeartbeatSample.java | 7 + .../cache/consensus/ConsensusGroupStatistics.java | 7 + .../manager/load/cache/node/BaseNodeCache.java | 8 +- .../manager/load/cache/node/NodeStatistics.java | 4 +- .../manager/load/cache/region/RegionCache.java | 3 +- .../load/cache/region/RegionGroupCache.java | 30 +- .../load/cache/region/RegionHeartbeatSample.java | 7 + .../manager/load/service/EventService.java | 133 +- .../iotdb/confignode/manager/node/NodeManager.java | 7 +- .../manager/partition/PartitionManager.java | 1 + .../pipe/execution/PipeConfigNodeSubtask.java | 1 + .../execution/PipeConfigNodeSubtaskExecutor.java | 4 +- .../manager/schema/ClusterSchemaManager.java | 36 +- .../persistence/executor/ConfigPlanExecutor.java | 3 +- .../confignode/persistence/node/NodeInfo.java | 24 +- .../partition/DatabasePartitionTable.java | 4 +- .../persistence/partition/PartitionInfo.java | 1 + .../persistence/partition/RegionGroup.java | 4 +- .../persistence/schema/ClusterSchemaInfo.java | 8 +- .../iotdb/confignode/procedure/Procedure.java | 32 +- .../confignode/procedure/ProcedureExecutor.java | 4 +- .../procedure/env/ConfigNodeProcedureEnv.java | 38 +- .../procedure/env/RegionMaintainHandler.java | 14 +- .../impl/node/AddConfigNodeProcedure.java | 2 +- .../impl/region/AddRegionPeerProcedure.java | 48 +- .../impl/region/CreateRegionGroupsProcedure.java | 9 +- .../impl/region/RemoveRegionPeerProcedure.java | 6 +- .../procedure/scheduler/ProcedureScheduler.java | 4 +- .../confignode/manager/load/FakeSubscriber.java | 92 + .../confignode/manager/load/LoadManagerTest.java | 295 + .../router/leader/CFDLeaderBalancerTest.java | 34 +- .../router/leader/GreedyLeaderBalancerTest.java | 30 +- .../leader/LeaderBalancerComparisonTest.java | 39 +- .../manager/load/cache/RegionGroupCacheTest.java | 23 +- .../consensus/iot/IoTConsensusServerImpl.java | 7 +- .../iot/service/IoTConsensusRPCService.java | 7 +- .../ratis/metrics/IoTDBMetricRegistry.java | 9 + .../iotdb/consensus/ratis/utils/RetryPolicy.java | 1 + .../src/assembly/resources/conf/datanode-env.bat | 17 +- .../assembly/resources/sbin/remove-datanode.bat | 2 +- .../src/assembly/resources/sbin/start-datanode.bat | 41 +- .../src/assembly/resources/sbin/start-datanode.sh | 1 + .../src/assembly/resources/sbin/stop-datanode.bat | 4 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 + .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 + .../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 2 + .../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 1 + .../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 8 +- .../tsfile/TsFileInsertionDataContainer.java | 4 +- .../realtime/PipeRealtimeDataRegionExtractor.java | 4 +- .../sdt/SwingingDoorTrendingFilter.java | 1 + .../connector/PipeConnectorSubtaskManager.java | 29 +- .../iotdb/db/protocol/client/ConfigNodeInfo.java | 1 + .../rest/utils/InsertTabletSortDataUtils.java | 1 + .../iotdb/db/protocol/session/SessionManager.java | 1 + .../common/schematree/ClusterSchemaTree.java | 1 + .../timerangeiterator/ITimeRangeIterator.java | 4 +- .../execution/exchange/sink/SinkChannel.java | 2 + .../exchange/source/LocalSourceHandle.java | 1 + .../fragment/FragmentInstanceContext.java | 3 + .../execution/load/LoadTsFileManager.java | 6 +- .../queryengine/execution/memory/MemoryPool.java | 2 + .../process/AbstractConsumeAllOperator.java | 5 +- .../operator/process/LinearFillOperator.java | 1 + .../operator/process/MergeSortOperator.java | 4 +- .../process/join/FullOuterTimeJoinOperator.java | 4 +- .../process/join/InnerTimeJoinOperator.java | 1 + .../metric/DataExchangeCostMetricSet.java | 1 + .../metric/QueryExecutionMetricSet.java | 3 + .../queryengine/plan/analyze/AnalyzeVisitor.java | 1 + .../queryengine/plan/analyze/ExpressionUtils.java | 3 +- .../analyze/cache/partition/PartitionCache.java | 5 + .../cache/partition/StorageGroupCacheResult.java | 2 + .../plan/analyze/schema/ISchemaComputation.java | 8 +- .../plan/execution/IQueryExecution.java | 4 +- .../queryengine/plan/execution/QueryExecution.java | 4 +- .../config/executor/ClusterConfigTaskExecutor.java | 31 +- .../visitor/TransformToViewExpressionVisitor.java | 6 + .../metedata/write/view/CreateLogicalViewNode.java | 1 + .../plan/planner/plan/node/write/InsertNode.java | 2 + .../planner/plan/node/write/InsertRowNode.java | 1 + .../planner/plan/node/write/InsertTabletNode.java | 1 + .../planner/plan/parameter/SeriesScanOptions.java | 4 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 4 +- .../plan/statement/crud/InsertBaseStatement.java | 1 + .../metadata/view/AlterLogicalViewStatement.java | 1 + .../row/ElasticSerializableRowRecordList.java | 1 + .../tv/ElasticSerializableTVList.java | 1 + .../schemaengine/schemaregion/ISchemaRegion.java | 4 + .../schemaregion/impl/SchemaRegionMemoryImpl.java | 57 +- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 54 +- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 1 + .../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 6 +- .../mtree/impl/mem/mnode/info/MeasurementInfo.java | 3 + .../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 1 + .../mtree/impl/pbtree/flush/Scheduler.java | 1 + .../mtree/impl/pbtree/schemafile/SchemaFile.java | 1 + .../impl/pbtree/schemafile/SegmentedPage.java | 1 + .../schemafile/pagemgr/BTreePageManager.java | 4 +- .../pbtree/schemafile/pagemgr/PageManager.java | 5 +- .../reader/impl/TimeseriesReaderWithViewFetch.java | 1 + .../schemaengine/schemaregion/tag/TagLogFile.java | 215 +- .../schemaengine/schemaregion/tag/TagManager.java | 162 +- .../schemaregion/utils/ResourceByPathUtils.java | 2 + .../view/visitor/TransformToExpressionVisitor.java | 6 + .../write/req/view/ICreateLogicalViewPlan.java | 8 +- .../db/service/DataNodeServerCommandLine.java | 7 +- .../apache/iotdb/db/service/IoTDBShutdownHook.java | 4 +- .../org/apache/iotdb/db/service/RPCService.java | 7 +- .../db/service/metrics/CompactionMetrics.java | 2 + .../db/storageengine/dataregion/DataRegion.java | 62 +- .../dataregion/ILastFlushTimeMap.java | 3 + .../impl/ReadChunkCompactionPerformer.java | 5 +- .../compaction/selector/estimator/FileInfo.java | 1 + .../compaction/tool/ListTimeRangeImpl.java | 1 + .../dataregion/memtable/AbstractMemTable.java | 3 + .../dataregion/memtable/DeviceIDFactory.java | 1 + .../dataregion/memtable/IMemTable.java | 8 +- .../dataregion/memtable/IWritableMemChunk.java | 4 +- .../dataregion/memtable/TsFileProcessor.java | 6 + .../dataregion/read/control/FileReaderManager.java | 2 + .../dataregion/tsfile/TsFileResource.java | 24 +- .../generator/SimpleFileVersionController.java | 2 + .../dataregion/tsfile/timeindex/ITimeIndex.java | 8 +- .../dataregion/wal/allocation/ElasticStrategy.java | 1 + .../wal/allocation/FirstCreateStrategy.java | 1 + .../wal/allocation/RoundRobinStrategy.java | 1 + .../dataregion/wal/buffer/WALBuffer.java | 6 + .../wal/checkpoint/CheckpointManager.java | 5 + .../storageengine/dataregion/wal/node/WALNode.java | 9 + .../dataregion/wal/recover/WALRecoverManager.java | 2 + .../wal/utils/listener/AbstractResultListener.java | 1 + .../db/storageengine/rescon/disk/TierManager.java | 5 + .../db/storageengine/rescon/memory/SystemInfo.java | 34 + .../rescon/memory/TimePartitionManager.java | 14 + .../agent/SubscriptionBrokerAgent.java | 4 +- .../broker/SerializedEnrichedEvent.java | 4 +- .../receiver/SubscriptionReceiverV1.java | 39 +- .../SubscriptionConnectorSubtaskManager.java | 37 +- .../java/org/apache/iotdb/db/tools/WalChecker.java | 4 +- .../db/tools/schema/SRStatementGenerator.java | 71 +- .../db/tools/settle/TsFileAndModSettleTool.java | 1 + .../java/org/apache/iotdb/db/utils/MathUtils.java | 1 + .../java/org/apache/iotdb/db/utils/MemUtils.java | 20 + .../apache/iotdb/db/metadata/MetaUtilsTest.java | 3 +- .../schemaRegion/SchemaRegionAliasAndTagTest.java | 1 + .../AlignedSeriesAggregationScanOperatorTest.java | 3 +- .../operator/RawDataAggregationOperatorTest.java | 1 + .../schedule/DefaultDriverSchedulerTest.java | 3 +- .../storageengine/dataregion/DataRegionTest.java | 101 +- .../iotdb/db/storageengine/dataregion/TTLTest.java | 4 +- .../compaction/CompactionSchedulerTest.java | 8 + .../CompactionSchedulerWithFastPerformerTest.java | 8 + .../TsFileValidationCorrectnessTests.java | 1 + .../cross/CrossSpaceCompactionSelectorTest.java | 44 +- ...actionWithReadPointPerformerValidationTest.java | 8 +- .../cross/RewriteCompactionFileSelectorTest.java | 5 +- .../inner/InnerSpaceCompactionSelectorTest.java | 22 +- ...nkCompactionPerformerWithAlignedSeriesTest.java | 55 +- .../settle/SettleRequestHandlerTest.java | 3 +- .../utils/MultiTsFileDeviceIteratorTest.java | 10 +- .../file/UnsealedTsFileRecoverPerformerTest.java | 5 +- .../rescon/memory/TimePartitionManagerTest.java | 3 + .../apache/iotdb/db/utils/SerializeUtilsTest.java | 3 + .../iotdb/metrics/core/IoTDBMetricManager.java | 1 + .../metrics/core/reporter/IoTDBJmxReporter.java | 5 + .../iotdb/metrics/core/uitls/IoTDBCachedGauge.java | 5 + .../iotdb/metrics/AbstractMetricManager.java | 3 + .../iotdb/metrics/AbstractMetricService.java | 5 + .../apache/iotdb/metrics/config/MetricConfig.java | 11 + .../reporter/iotdb/IoTDBSessionReporter.java | 1 + .../org/apache/iotdb/metrics/utils/MetricInfo.java | 4 + iotdb-core/node-commons/pom.xml | 7 +- .../resources/conf/iotdb-common.properties | 14 +- .../assembly/resources/sbin/destroy-confignode.bat | 2 +- .../assembly/resources/sbin/destroy-datanode.bat | 2 +- .../src/assembly/resources/sbin/health_check.bat | 40 +- .../src/assembly/resources/sbin/health_check.sh | 23 +- .../assembly/resources/sbin/start-standalone.bat | 4 +- .../assembly/resources/sbin/stop-standalone.bat | 4 +- .../org/apache/iotdb/commons/auth/entity/Role.java | 1 + .../iotdb/commons/auth/user/BasicUserManager.java | 1 + .../commons/auth/user/LocalFileUserAccessor.java | 1 + .../client/property/ThriftClientProperty.java | 2 + .../apache/iotdb/commons/conf/CommonConfig.java | 18 + .../iotdb/commons/conf/CommonDescriptor.java | 12 + .../commons/consensus/index/ProgressIndex.java | 4 +- .../index/impl/TimeWindowStateProgressIndex.java | 4 +- .../iotdb/commons/exception/IoTDBException.java | 1 + .../commons/executable/ExecutableManager.java | 1 + .../org/apache/iotdb/commons/path/PartialPath.java | 18 +- .../apache/iotdb/commons/path/PathPatternNode.java | 5 +- .../apache/iotdb/commons/path/PatternTreeMap.java | 1 + .../org/apache/iotdb/commons/path/fa/IFAState.java | 12 +- .../iotdb/commons/path/fa/IFATransition.java | 4 +- .../apache/iotdb/commons/path/fa/IPatternFA.java | 12 +- .../commons/path/fa/match/IStateMatchInfo.java | 28 +- .../task/subtask/PipeAbstractConnectorSubtask.java | 4 +- .../commons/schema/node/info/IDeviceInfo.java | 8 +- .../commons/schema/node/role/IDeviceMNode.java | 8 +- .../schema/view/viewExpression/ViewExpression.java | 4 +- .../binary/BinaryViewExpression.java | 2 + .../binary/arithmetic/AdditionViewExpression.java | 1 + .../arithmetic/ArithmeticBinaryViewExpression.java | 1 + .../binary/arithmetic/DivisionViewExpression.java | 1 + .../binary/arithmetic/ModuloViewExpression.java | 1 + .../arithmetic/MultiplicationViewExpression.java | 1 + .../arithmetic/SubtractionViewExpression.java | 1 + .../compare/CompareBinaryViewExpression.java | 1 + .../binary/logic/LogicBinaryViewExpression.java | 1 + .../view/viewExpression/leaf/NullViewOperand.java | 4 +- .../viewExpression/leaf/TimeSeriesViewOperand.java | 2 + .../viewExpression/leaf/TimestampViewOperand.java | 4 +- .../multi/FunctionViewExpression.java | 2 + .../ternary/BetweenViewExpression.java | 2 + .../ternary/TernaryViewExpression.java | 2 + .../viewExpression/unary/InViewExpression.java | 2 + .../viewExpression/unary/IsNullViewExpression.java | 2 + .../viewExpression/unary/LikeViewExpression.java | 2 + .../unary/LogicNotViewExpression.java | 1 + .../unary/NegationViewExpression.java | 1 + .../unary/RegularViewExpression.java | 2 + .../viewExpression/unary/UnaryViewExpression.java | 1 + .../visitor/ViewExpressionVisitor.java | 6 + .../iotdb/commons/service/StartupChecks.java | 1 + .../iotdb/commons/service/ThriftService.java | 7 +- .../meta/consumer/ConsumerGroupMeta.java | 4 +- .../commons/subscription/meta/topic/TopicMeta.java | 4 +- .../iotdb/commons/trigger/TriggerInformation.java | 2 + .../apache/iotdb/commons/trigger/TriggerTable.java | 1 + .../udf/builtin/BuiltinAggregationFunction.java | 8 +- .../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 6 +- .../org/apache/iotdb/commons/utils/AuthUtils.java | 2 + .../org/apache/iotdb/commons/utils/IOUtils.java | 1 + .../apache/iotdb/commons/utils/NodeUrlUtils.java | 1 + .../apache/iotdb/commons/path/PartialPathTest.java | 8 + .../iotdb/library/anomaly/util/MissDetector.java | 56 +- .../library/anomaly/util/StreamMissDetector.java | 4 +- .../iotdb/library/anomaly/util/WindowDetect.java | 8 +- .../library/dquality/util/TimeSeriesQuality.java | 8 +- .../iotdb/library/frequency/util/DWTUtil.java | 2 + pom.xml | 39 +- 568 files changed, 3277 insertions(+), 39347 deletions(-)
