This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch skywalking_eye in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e452d899c3c8aef91f4f1ef83dd2ec17c9aeef9d Merge: 1a61d1044d f33ee814b8 Author: HTHou <[email protected]> AuthorDate: Tue Apr 12 23:33:36 2022 +0800 Merge branch 'master' of https://github.com/apache/iotdb into skywalking_eye .github/dependabot.yml | 26 + .github/workflows/client-cpp.yml | 103 + .github/workflows/client-go.yml | 4 + .github/workflows/client-python.yml | 63 + .github/workflows/client.yml | 99 - .github/workflows/cluster.yml | 4 + .github/workflows/e2e.yml | 4 + .github/workflows/grafana-plugin.yml | 7 +- .github/workflows/influxdb-protocol.yml | 10 +- .github/workflows/main-unix.yml | 4 + .github/workflows/main-win.yml | 4 + .github/workflows/sonar-coveralls.yml | 13 +- README.md | 6 +- README_ZH.md | 6 +- antlr/pom.xml | 2 +- .../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 2 + .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 65 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +- cli/pom.xml | 4 +- client-cpp/pom.xml | 6 +- client-cpp/src/main/Session.h | 4 +- client-py/README.md | 290 +- client-py/SessionAlignedTimeseriesExample.py | 16 +- client-py/SessionAlignedTimeseriesTest.py | 280 - client-py/SessionExample.py | 50 +- client-py/SessionTest.py | 336 - client-py/iotdb/Session.py | 104 +- client-py/iotdb/utils/IoTDBConstants.py | 13 + client-py/iotdb/utils/IoTDBRpcDataSet.py | 2 +- client-py/iotdb/utils/NumpyTablet.py | 32 +- client-py/iotdb/utils/Tablet.py | 31 +- client-py/pom.xml | 2 +- client-py/requirements_dev.txt | 2 +- client-py/setup.py | 3 +- client-py/tests/tablet_performance_comparison.py | 8 +- client-py/tests/test_aligned_timeseries.py | 294 + client-py/tests/test_dataframe.py | 6 +- client-py/tests/test_numpy_tablet.py | 147 + client-py/tests/test_session.py | 362 + client-py/tests/test_tablet.py | 109 + client-py/tests/test_todf.py | 16 +- cluster/pom.xml | 2 +- .../resources/conf/iotdb-cluster.properties | 6 +- .../java/org/apache/iotdb/cluster/ClientMain.java | 4 +- .../iotdb/cluster/ClusterFileFlushPolicy.java | 11 +- .../org/apache/iotdb/cluster/ClusterIoTDB.java | 81 +- .../cluster/ClusterIoTDBServerCommandLine.java | 94 + .../apache/iotdb/cluster/RemoteTsFileResource.java | 5 +- .../cluster/client/async/AsyncDataClient.java | 2 +- .../cluster/client/async/AsyncMetaClient.java | 2 +- .../cluster/client/sync/SyncClientAdaptor.java | 2 +- .../iotdb/cluster/client/sync/SyncDataClient.java | 2 +- .../iotdb/cluster/client/sync/SyncMetaClient.java | 2 +- .../iotdb/cluster/config/ClusterConstant.java | 2 +- .../iotdb/cluster/config/ClusterDescriptor.java | 2 +- .../iotdb/cluster/coordinator/Coordinator.java | 44 +- .../apache/iotdb/cluster/log/LogDispatcher.java | 6 +- .../org/apache/iotdb/cluster/log/Snapshot.java | 5 + .../cluster/log/applier/AsyncDataLogApplier.java | 18 +- .../iotdb/cluster/log/applier/BaseApplier.java | 6 +- .../iotdb/cluster/log/applier/DataLogApplier.java | 20 +- .../iotdb/cluster/log/catchup/CatchUpTask.java | 2 +- .../iotdb/cluster/log/catchup/LogCatchUpTask.java | 4 +- .../cluster/log/manage/CommittedEntryManager.java | 2 +- .../log/manage/MetaSingleSnapshotLogManager.java | 2 +- .../log/manage/PartitionedSnapshotLogManager.java | 4 +- .../iotdb/cluster/log/manage/RaftLogManager.java | 4 +- .../log/manage/UnCommittedEntryManager.java | 2 +- .../serializable/SyncLogDequeSerializer.java | 4 +- .../cluster/log/snapshot/MetaSimpleSnapshot.java | 89 +- .../cluster/log/snapshot/PartitionedSnapshot.java | 39 +- .../apache/iotdb/cluster/metadata/CMManager.java | 1781 ---- .../iotdb/cluster/metadata/CSchemaProcessor.java | 1770 ++++ .../apache/iotdb/cluster/metadata/MetaPuller.java | 10 +- .../iotdb/cluster/partition/PartitionTable.java | 4 +- .../partition/slot/SlotTimePartitionFilter.java | 2 +- .../cluster/query/ClusterPhysicalGenerator.java | 8 +- .../iotdb/cluster/query/ClusterPlanExecutor.java | 28 +- .../iotdb/cluster/query/ClusterPlanRouter.java | 78 +- .../iotdb/cluster/query/LocalQueryExecutor.java | 42 +- .../iotdb/cluster/query/filter/SlotSgFilter.java | 2 +- .../groupby/ClusterGroupByNoVFilterDataSet.java | 4 +- .../groupby/ClusterGroupByVFilterDataSet.java | 2 +- .../query/groupby/MergeGroupByExecutor.java | 2 +- .../query/groupby/RemoteGroupByExecutor.java | 2 +- .../query/last/ClusterLastQueryExecutor.java | 42 +- .../cluster/query/manage/ClusterQueryManager.java | 2 +- .../cluster/query/reader/ClusterReaderFactory.java | 2 +- .../cluster/query/reader/ClusterTimeGenerator.java | 6 +- .../iotdb/cluster/query/reader/EmptyReader.java | 2 +- .../iotdb/cluster/server/ClusterRPCService.java | 10 +- .../cluster/server/ClusterRPCServiceMBean.java | 2 +- .../iotdb/cluster/server/ClusterTSServiceImpl.java | 2 +- .../cluster/server/PullSnapshotHintService.java | 2 +- .../server/basic/ClusterServiceProvider.java | 2 +- .../server/clusterinfo/ClusterInfoServer.java | 10 +- .../server/handlers/caller/HeartbeatHandler.java | 6 +- .../handlers/forwarder/ForwardPlanHandler.java | 2 +- .../cluster/server/member/DataGroupMember.java | 29 +- .../cluster/server/member/MetaGroupMember.java | 14 +- .../iotdb/cluster/server/member/RaftMember.java | 27 +- .../cluster/server/monitor/NodeStatusManager.java | 2 +- .../cluster/server/raft/AbstractRaftService.java | 6 +- .../server/raft/DataRaftHeartBeatService.java | 8 +- .../iotdb/cluster/server/raft/DataRaftService.java | 8 +- .../server/raft/MetaRaftHeartBeatService.java | 8 +- .../iotdb/cluster/server/raft/MetaRaftService.java | 8 +- .../cluster/server/service/BaseAsyncService.java | 4 +- .../cluster/server/service/BaseSyncService.java | 2 +- .../cluster/server/service/DataAsyncService.java | 17 +- .../cluster/server/service/DataGroupEngine.java | 8 +- .../server/service/DataGroupServiceImpls.java | 2 +- .../cluster/server/service/DataSyncService.java | 12 +- .../iotdb/cluster/utils/ClusterQueryUtils.java | 2 +- .../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +- .../apache/iotdb/cluster/utils/PartitionUtils.java | 4 +- .../apache/iotdb/cluster/utils/PlanSerializer.java | 4 +- .../apache/iotdb/cluster/utils/StatusUtils.java | 6 +- .../cluster/utils/nodetool/ClusterMonitor.java | 16 +- .../cluster/client/sync/SyncClientAdaptorTest.java | 2 +- .../org/apache/iotdb/cluster/common/IoTDBTest.java | 4 +- .../iotdb/cluster/common/TestAsyncDataClient.java | 2 +- .../iotdb/cluster/integration/SingleNodeTest.java | 2 +- .../iotdb/cluster/log/LogDispatcherTest.java | 2 +- .../log/applier/AsyncDataLogApplierTest.java | 6 +- .../cluster/log/applier/DataLogApplierTest.java | 31 +- .../cluster/log/applier/MetaLogApplierTest.java | 16 +- .../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 4 +- .../cluster/log/catchup/LogCatchUpTaskTest.java | 2 +- .../manage/MetaSingleSnapshotLogManagerTest.java | 2 +- .../serializable/SyncLogDequeSerializerTest.java | 2 +- .../cluster/log/snapshot/DataSnapshotTest.java | 4 +- .../cluster/log/snapshot/FileSnapshotTest.java | 36 +- .../log/snapshot/MetaSimpleSnapshotTest.java | 127 +- .../log/snapshot/PartitionedSnapshotTest.java | 91 +- .../cluster/log/snapshot/PullSnapshotTaskTest.java | 11 +- .../iotdb/cluster/partition/MManagerWhiteBox.java | 54 - .../cluster/partition/SchemaProcessorWhiteBox.java | 54 + .../cluster/partition/SlotPartitionTableTest.java | 28 +- .../cluster/query/ClusterPlanExecutorTest.java | 2 +- .../query/ClusterUDTFQueryExecutorTest.java | 2 +- .../query/groupby/RemoteGroupByExecutorTest.java | 2 +- .../clusterinfo/ClusterInfoServiceImplTest.java | 4 +- .../handlers/caller/HeartbeatHandlerTest.java | 17 + .../handlers/forwarder/ForwardPlanHandlerTest.java | 2 +- .../iotdb/cluster/server/member/BaseMember.java | 21 +- .../cluster/server/member/DataGroupMemberTest.java | 10 +- .../cluster/server/member/MetaGroupMemberTest.java | 28 +- .../iotdb/cluster/utils/SerializeUtilTest.java | 2 - cluster/src/test/resources/logback-test.xml | 41 + cluster/src/test/resources/logback.xml | 41 - code-coverage/pom.xml | 4 +- compile-tools/pom.xml | 2 +- compile-tools/thrift/pom.xml | 2 +- confignode/pom.xml | 127 + confignode/src/assembly/confignode.xml | 45 + .../src/assembly/resources/conf/confignode-env.bat | 146 + .../src/assembly/resources/conf/confignode-env.sh | 264 + .../resources/conf/iotdb-confignode.properties | 154 + confignode/src/assembly/resources/conf/jmx.access | 22 + .../src/assembly/resources/conf/jmx.password | 22 + .../src/assembly/resources/conf/logback-tool.xml | 22 + confignode/src/assembly/resources/conf/logback.xml | 140 + .../assembly/resources/sbin/start-confignode.bat | 123 + .../assembly/resources/sbin/start-confignode.sh | 79 + .../assembly/resources/sbin/stop-confignode.bat | 38 + .../src/assembly/resources/sbin/stop-confignode.sh | 35 + .../iotdb/confignode/conf/ConfigNodeConf.java | 278 + .../iotdb/confignode/conf/ConfigNodeConfCheck.java | 155 + .../iotdb/confignode/conf/ConfigNodeConstant.java | 51 + .../confignode/conf/ConfigNodeDescriptor.java | 210 + .../response/DataNodeConfigurationDataSet.java | 66 + .../consensus/response/DataNodesInfoDataSet.java | 72 + .../consensus/response/DataPartitionDataSet.java | 133 + .../consensus/response/PermissionInfoDataSet.java | 26 + .../consensus/response/SchemaPartitionDataSet.java | 94 + .../response/StorageGroupSchemaDataSet.java | 66 + .../statemachine/PartitionRegionStateMachine.java | 119 + .../confignode/exception/ConfigNodeException.java | 26 + .../physical/UnknownPhysicalPlanTypeException.java | 29 + .../iotdb/confignode/manager/ConfigManager.java | 211 + .../iotdb/confignode/manager/ConsensusManager.java | 141 + .../iotdb/confignode/manager/DataNodeManager.java | 178 + .../apache/iotdb/confignode/manager/Manager.java | 129 + .../iotdb/confignode/manager/PartitionManager.java | 212 + .../confignode/manager/PermissionManager.java | 40 + .../iotdb/confignode/manager/RegionManager.java | 134 + .../confignode/partition/DataPartitionRule.java | 50 + .../confignode/partition/StorageGroupSchema.java | 112 + .../persistence/AuthorInfoPersistence.java | 146 + .../persistence/DataNodeInfoPersistence.java | 182 + .../persistence/PartitionInfoPersistence.java | 210 + .../persistence/RegionInfoPersistence.java | 207 + .../iotdb/confignode/physical/PhysicalPlan.java | 155 + .../confignode/physical/PhysicalPlanType.java | 52 + .../physical/crud/CreateDataPartitionPlan.java | 128 + .../physical/crud/CreateRegionsPlan.java | 96 + .../physical/crud/CreateSchemaPartitionPlan.java | 39 + .../crud/GetOrCreateDataPartitionPlan.java | 139 + .../crud/GetOrCreateSchemaPartitionPlan.java | 98 + .../iotdb/confignode/physical/sys/AuthorPlan.java | 248 + .../physical/sys/DeleteStorageGroupPlan.java | 39 + .../physical/sys/QueryDataNodeInfoPlan.java | 68 + .../physical/sys/QueryStorageGroupSchemaPlan.java | 41 + .../physical/sys/RegisterDataNodePlan.java | 79 + .../physical/sys/SetStorageGroupPlan.java | 74 + .../iotdb/confignode/service/ConfigNode.java | 107 + .../confignode/service/ConfigNodeCommandLine.java | 89 + .../iotdb/confignode/service/ConfigNodeMBean.java | 21 + .../confignode/service/balancer/LoadBalancer.java | 37 + .../confignode/service/executor/PlanExecutor.java | 116 + .../service/thrift/server/ConfigNodeRPCServer.java | 110 + .../thrift/server/ConfigNodeRPCServerMBean.java | 22 + .../server/ConfigNodeRPCServerProcessor.java | 205 + .../thrift/server/ConfigNodeRPCServiceHandler.java | 52 + .../confignode/util/SerializeDeserializeUtil.java | 242 + .../apache/iotdb/confignode/auth/AuthorTest.java | 44 + .../confignode/consensus/RatisConsensusDemo.java | 151 + .../manager/ConfigManagerManualTest.java | 133 + .../hash/DeviceGroupHashExecutorManualTest.java | 94 + .../physical/SerializeDeserializeUT.java | 346 + .../server/ConfigNodeRPCServerProcessorTest.java | 424 + .../utils/ConfigNodeEnvironmentUtils.java | 134 + .../utils/SerializeDeserializeUtilTest.java | 90 + consensus/README.md | 163 + consensus/pom.xml | 65 + .../apache/iotdb/consensus/ConsensusFactory.java | 57 + .../org/apache/iotdb/consensus/IConsensus.java | 63 + .../iotdb/consensus/common/ConsensusGroup.java | 62 + .../org/apache/iotdb/consensus/common/DataSet.java | 22 + .../org/apache/iotdb/consensus/common/Peer.java | 62 + .../common/request/ByteBufferConsensusRequest.java | 44 + .../common/request/IConsensusRequest.java | 27 + .../common/response/ConsensusGenericResponse.java | 64 + .../common/response/ConsensusReadResponse.java | 65 + .../common/response/ConsensusResponse.java | 39 + .../common/response/ConsensusWriteResponse.java | 65 + .../consensus/exception/ConsensusException.java | 31 + .../ConsensusGroupAlreadyExistException.java | 36 + .../exception/ConsensusGroupNotExistException.java | 36 + .../exception/IllegalPeerNumException.java | 29 + .../PeerAlreadyInConsensusGroupException.java | 31 + .../PeerNotInConsensusGroupException.java | 29 + .../exception/RatisRequestFailedException.java | 26 + .../ratis/ApplicationStateMachineProxy.java | 87 + .../iotdb/consensus/ratis/RatisConsensus.java | 566 + .../iotdb/consensus/ratis/RequestMessage.java | 71 + .../iotdb/consensus/ratis/ResponseMessage.java | 66 + .../org/apache/iotdb/consensus/ratis/Utils.java | 163 + .../consensus/standalone/StandAloneConsensus.java | 194 + .../consensus/standalone/StandAloneServerImpl.java | 65 + .../consensus/statemachine/EmptyStateMachine.java | 43 + .../consensus/statemachine/IStateMachine.java | 40 + consensus/src/main/resources/logback-test.xml | 31 + .../iotdb/consensus/ratis/RatisConsensusTest.java | 265 + .../apache/iotdb/consensus/ratis/UtilsTest.java | 37 + .../standalone/StandAloneConsensusTest.java | 277 + cross-tests/pom.xml | 2 +- .../tests/tools/importCsv/ExportCsvTestIT.java | 31 +- distribution/pom.xml | 2 +- docs/Community/About.md | 20 + docs/Community/Community-Powered By.md | 2 +- docs/Download/README.md | 40 +- docs/UserGuide/API/InfluxDB-Protocol.md | 341 + docs/UserGuide/API/Programming-Java-Native-API.md | 9 +- docs/UserGuide/API/Programming-MQTT.md | 2 +- .../UserGuide/API/Programming-Python-Native-API.md | 254 +- docs/UserGuide/API/Programming-TsFile-API.md | 4 +- .../Administration-Management/Administration.md | 6 +- docs/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +- docs/UserGuide/Data-Concept/Encoding.md | 17 +- docs/UserGuide/Data-Concept/Schema-Template.md | 2 + docs/UserGuide/Data-Concept/Time-Partition.md | 8 +- docs/UserGuide/Data-Modeling/DataRegion.md | 55 + .../UserGuide/Data-Modeling/VirtualStorageGroup.md | 55 - .../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +- .../Ecosystem Integration/MapReduce TsFile.md | 2 +- .../Ecosystem Integration/Spark TsFile.md | 2 +- .../Maintenance-Tools/Maintenance-Command.md | 8 - docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 28 +- docs/UserGuide/Operate-Metadata/Template.md | 2 + docs/UserGuide/Operate-Metadata/Timeseries.md | 41 +- docs/UserGuide/Process-Data/Alerting.md | 2 +- docs/UserGuide/Process-Data/Continuous-Query.md | 4 +- docs/UserGuide/Process-Data/Triggers.md | 6 +- .../Process-Data/UDF-User-Defined-Function.md | 8 +- docs/UserGuide/Query-Data/Aggregate-Query.md | 28 +- docs/UserGuide/Query-Data/Last-Query.md | 8 +- docs/UserGuide/Query-Data/Overview.md | 27 +- docs/UserGuide/Query-Data/Select-Expression.md | 85 +- docs/UserGuide/Query-Data/Without-Null.md | 162 +- docs/UserGuide/QuickStart/WayToGetIoTDB.md | 19 +- docs/UserGuide/Reference/Config-Manual.md | 66 +- docs/UserGuide/Reference/SQL-Reference.md | 7 +- docs/zh/Community/About.md | 63 + docs/zh/Development/ContributeGuide.md | 11 +- docs/zh/Download/README.md | 35 +- docs/zh/UserGuide/API/InfluxDB-Protocol.md | 122 +- docs/zh/UserGuide/API/Programming-JDBC.md | 2 +- .../UserGuide/API/Programming-Java-Native-API.md | 8 +- docs/zh/UserGuide/API/Programming-MQTT.md | 2 +- .../UserGuide/API/Programming-Python-Native-API.md | 265 +- docs/zh/UserGuide/API/Programming-TsFile-API.md | 4 +- .../Administration-Management/Administration.md | 8 +- docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +- docs/zh/UserGuide/Data-Concept/Encoding.md | 17 +- docs/zh/UserGuide/Data-Concept/Schema-Template.md | 2 +- docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 - docs/zh/UserGuide/Data-Modeling/DataRegion.md | 53 + .../UserGuide/Data-Modeling/VirtualStorageGroup.md | 53 - .../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +- .../Ecosystem Integration/MapReduce TsFile.md | 2 +- .../Ecosystem Integration/Spark TsFile.md | 2 +- .../Maintenance-Tools/Maintenance-Command.md | 7 - docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 70 +- docs/zh/UserGuide/Operate-Metadata/Template.md | 2 + docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 36 +- docs/zh/UserGuide/Process-Data/Alerting.md | 2 +- docs/zh/UserGuide/Process-Data/Continuous-Query.md | 4 +- docs/zh/UserGuide/Process-Data/Triggers.md | 6 +- .../Process-Data/UDF-User-Defined-Function.md | 8 +- docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 37 +- docs/zh/UserGuide/Query-Data/Last-Query.md | 4 +- docs/zh/UserGuide/Query-Data/Overview.md | 27 +- docs/zh/UserGuide/Query-Data/Select-Expression.md | 80 +- docs/zh/UserGuide/Query-Data/Without-Null.md | 163 +- docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 19 +- docs/zh/UserGuide/Reference/Config-Manual.md | 41 +- docs/zh/UserGuide/Reference/SQL-Reference.md | 8 +- docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 1 - example/client-cpp-example/pom.xml | 2 +- example/flink/pom.xml | 2 +- example/hadoop/pom.xml | 2 +- example/jdbc/pom.xml | 2 +- example/kafka/pom.xml | 4 +- example/kafka/readme.md | 4 +- example/mqtt-customize/README.md | 4 +- example/mqtt-customize/pom.xml | 2 +- ...apache.iotdb.db.protocol.mqtt.PayloadFormatter} | 0 example/mqtt/pom.xml | 2 +- example/pom.xml | 2 +- example/pulsar/pom.xml | 2 +- example/rabbitmq/pom.xml | 2 +- example/rest-client-c-example/CMakeLists.txt | 25 + example/rest-client-c-example/README.md | 111 + example/rest-client-c-example/base64.c | 100 + example/rest-client-c-example/base64.h | 30 + example/rest-client-c-example/main.c | 124 + example/rocketmq/pom.xml | 2 +- example/rocketmq/readme.md | 4 +- example/session/pom.xml | 2 +- .../iotdb/AlignedTimeseriesSessionExample.java | 9 +- .../main/java/org/apache/iotdb/SessionExample.java | 5 +- .../java/org/apache/iotdb/SessionPoolExample.java | 42 +- example/trigger/pom.xml | 4 +- example/tsfile/pom.xml | 2 +- example/tsfile/readme.md | 2 +- example/udf/pom.xml | 2 +- flink-iotdb-connector/pom.xml | 2 +- flink-tsfile-connector/pom.xml | 2 +- .../flink/tsfile/RowTSRecordOutputFormatIT.java | 54 - .../RowTSRecordOutputFormatIntegrationTest.java | 54 + .../iotdb/flink/tsfile/RowTsFileInputFormatIT.java | 108 - .../RowTsFileInputFormatIntegrationTest.java | 108 + .../util/TSFileConfigUtilCompletenessTest.java | 4 +- grafana-connector/pom.xml | 2 +- .../controller/DatabaseConnectController.java | 3 +- .../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 43 +- grafana-plugin/package.json | 4 +- grafana-plugin/pom.xml | 2 +- grafana-plugin/src/componments/ControlValue.tsx | 5 +- grafana-plugin/src/componments/FromValue.tsx | 8 +- grafana-plugin/src/componments/SelectValue.tsx | 8 +- grafana-plugin/src/componments/WhereValue.tsx | 5 +- grafana-plugin/src/datasource.ts | 16 +- grafana-plugin/yarn.lock | 10529 +++++++++---------- hadoop/README.md | 2 +- hadoop/pom.xml | 2 +- hive-connector/pom.xml | 4 +- influxdb-protocol/pom.xml | 2 +- .../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 4 +- .../iotdb/influxdb/example/InfluxDBExample.java | 38 +- .../protocol/impl/IoTDBInfluxDBService.java | 22 +- .../iotdb/influxdb/session/InfluxDBSession.java | 29 + .../influxdb/integration/IoTDBInfluxDBIT.java | 77 +- integration/pom.xml | 9 +- .../iotdb/integration/env/ClusterEnvConfig.java | 5 +- .../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +- .../iotdb/db/integration/IOTDBGroupByIT.java | 996 -- .../integration/IOTDBGroupByInnerIntervalIT.java | 335 - .../apache/iotdb/db/integration/IOTDBInsertIT.java | 26 + .../iotdb/db/integration/IoTDBArithmeticIT.java | 18 +- .../iotdb/db/integration/IoTDBAuthorizationIT.java | 49 + .../iotdb/db/integration/IoTDBCheckConfigIT.java | 6 +- .../integration/IoTDBCompactionWithIDTableIT.java | 352 + .../iotdb/db/integration/IoTDBCompleteIT.java | 9 +- .../db/integration/IoTDBCreateSnapshotIT.java | 180 - .../apache/iotdb/db/integration/IoTDBDaemonIT.java | 2 +- .../iotdb/db/integration/IoTDBEncodingIT.java | 145 +- .../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 2 +- .../iotdb/db/integration/IoTDBGroupByFillIT.java | 2648 ----- .../db/integration/IoTDBGroupByFillMixPathsIT.java | 479 - .../integration/IoTDBGroupByFillWithRangeIT.java | 179 - .../db/integration/IoTDBGroupByMonthFillIT.java | 272 - .../iotdb/db/integration/IoTDBGroupByMonthIT.java | 273 - .../iotdb/db/integration/IoTDBGroupByUnseqIT.java | 185 - .../iotdb/db/integration/IoTDBLargeDataIT.java | 2 +- .../apache/iotdb/db/integration/IoTDBLastIT.java | 147 +- .../db/integration/IoTDBLoadExternalTsfileIT.java | 76 +- .../integration/IoTDBManageTsFileResourceIT.java | 8 +- .../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 134 + .../iotdb/db/integration/IoTDBMetadataFetchIT.java | 74 +- .../iotdb/db/integration/IoTDBMultiSeriesIT.java | 2 +- .../iotdb/db/integration/IoTDBNestedQueryIT.java | 12 +- .../db/integration/IoTDBNewTsFileCompactionIT.java | 7 +- .../db/integration/IoTDBRecoverUnclosedIT.java | 2 +- .../db/integration/IoTDBResultMetadataIT.java | 82 + .../IoTDBSelectCompareExpressionIT.java | 482 + .../iotdb/db/integration/IoTDBSelectIntoIT.java | 18 +- .../iotdb/db/integration/IoTDBSimpleQueryIT.java | 8 +- .../integration/IoTDBSizeTieredCompactionIT.java | 2 +- .../db/integration/IoTDBTriggerExecutionIT.java | 26 +- .../db/integration/IoTDBTriggerManagementIT.java | 8 +- .../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +- .../iotdb/db/integration/IoTDBUDFManagementIT.java | 12 +- .../aggregation/IoTDBAggregationIT.java | 28 + .../aligned/IOTDBInsertAlignedValuesIT.java | 372 - .../IoTDBGroupByQueryWithoutValueFilterIT.java | 14 - ...GroupBySlidingWindowQueryWithValueFilterIT.java | 951 ++ ...upBySlidingWindowQueryWithoutValueFilterIT.java | 940 ++ .../aligned/IoTDBInsertAlignedValuesIT.java | 391 + .../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 70 +- .../db/integration/env/StandaloneEnvConfig.java | 4 +- .../db/integration/groupby/IOTDBGroupByIT.java | 996 ++ .../groupby/IOTDBGroupByInnerIntervalIT.java | 335 + .../db/integration/groupby/IoTDBGroupByFillIT.java | 2648 +++++ .../groupby/IoTDBGroupByFillMixPathsIT.java | 479 + .../groupby/IoTDBGroupByFillWithRangeIT.java | 179 + .../groupby/IoTDBGroupByMonthFillIT.java | 272 + .../integration/groupby/IoTDBGroupByMonthIT.java | 366 + .../integration/groupby/IoTDBGroupByUnseqIT.java | 185 + .../versionadaption/IoTDBDDLVersionAdaptionIT.java | 4 +- .../IoTDBQueryVersionAdaptionIT.java | 1 - .../IoTDBWithoutNullAllFilterIT.java | 1973 ++++ .../IoTDBWithoutNullAnyFilterIT.java | 1866 ++++ .../iotdb/session/IoTDBSessionComplexIT.java | 9 +- .../session/IoTDBSessionDisableMemControlIT.java | 210 + .../iotdb/session/IoTDBSessionIteratorIT.java | 2 +- .../apache/iotdb/session/IoTDBSessionSimpleIT.java | 53 +- .../session/IoTDBSessionSyntaxConventionIT.java | 2 +- .../session/IoTDBSessionVectorABDeviceIT.java | 233 + .../session/IoTDBSessionVectorAggregationIT.java | 0 .../IoTDBSessionVectorAggregationWithUnSeqIT.java | 195 + .../iotdb/session/IoTDBSessionVectorInsertIT.java | 520 + .../java/org/apache/iotdb/session/SessionTest.java | 673 ++ .../apache/iotdb/session/pool/SessionPoolTest.java | 482 + .../apache/iotdb/session/template/TemplateUT.java | 399 + integration/src/test/resources/logback-test.xml | 58 + integration/src/test/resources/logback.xml | 58 - jdbc/README.md | 4 +- jdbc/pom.xml | 2 +- .../org/apache/iotdb/jdbc/IoTDBConnection.java | 2 +- .../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 29 +- .../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +- .../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +- .../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +- .../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 2 +- .../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 2 +- .../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +- .../iotdb/jdbc/IoTDBPreparedStatementTest.java | 1 + .../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 2 +- library-udf/pom.xml | 14 +- .../org/apache/iotdb/library/dmatch/UDAFCov.java | 86 + .../org/apache/iotdb/library/dmatch/UDAFDtw.java | 91 + .../apache/iotdb/library/dmatch/UDAFPearson.java | 95 + .../apache/iotdb/library/dmatch/UDTFPtnSym.java | 98 + .../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 86 + .../library/dmatch/util/CrossCorrelation.java | 54 + .../iotdb/library/dprofile/UDAFIntegral.java | 113 + .../iotdb/library/dprofile/UDAFIntegralAvg.java | 89 + .../org/apache/iotdb/library/dprofile/UDAFMad.java | 85 + .../apache/iotdb/library/dprofile/UDAFMedian.java | 85 + .../apache/iotdb/library/dprofile/UDAFMode.java | 177 + .../iotdb/library/dprofile/UDAFPercentile.java | 168 + .../apache/iotdb/library/dprofile/UDAFPeriod.java | 142 + .../apache/iotdb/library/dprofile/UDAFSkew.java | 73 + .../apache/iotdb/library/dprofile/UDAFSpread.java | 124 + .../apache/iotdb/library/dprofile/UDAFStddev.java | 69 + .../org/apache/iotdb/library/dprofile/UDTFACF.java | 79 + .../iotdb/library/dprofile/UDTFDistinct.java | 189 + .../iotdb/library/dprofile/UDTFHistogram.java | 88 + .../apache/iotdb/library/dprofile/UDTFMinMax.java | 110 + .../apache/iotdb/library/dprofile/UDTFMvAvg.java | 81 + .../apache/iotdb/library/dprofile/UDTFPACF.java | 95 + .../org/apache/iotdb/library/dprofile/UDTFQLB.java | 104 + .../iotdb/library/dprofile/UDTFResample.java | 116 + .../apache/iotdb/library/dprofile/UDTFSample.java | 133 + .../apache/iotdb/library/dprofile/UDTFSegment.java | 123 + .../apache/iotdb/library/dprofile/UDTFSpline.java | 100 + .../apache/iotdb/library/dprofile/UDTFZScore.java | 105 + .../library/dprofile/util/CrossCorrelation.java | 53 + .../dprofile/util/ExactOrderStatistics.java | 281 + .../iotdb/library/dprofile/util/GKArray.java | 179 + .../iotdb/library/dprofile/util/MADSketch.java | 283 + .../apache/iotdb/library/dprofile/util/Mad.java | 34 + .../iotdb/library/dprofile/util/MaxSelector.java | 76 + .../iotdb/library/dprofile/util/Resampler.java | 243 + .../iotdb/library/dprofile/util/Segment.java | 161 + .../iotdb/library/dprofile/util/YuleWalker.java | 71 + .../iotdb/library/dquality/UDTFCompleteness.java | 76 + .../iotdb/library/dquality/UDTFConsistency.java | 74 + .../iotdb/library/dquality/UDTFTimeliness.java | 73 + .../iotdb/library/dquality/UDTFValidity.java | 73 + .../library/dquality/util/TimeSeriesQuality.java | 243 + .../iotdb/library/drepair/UDTFTimestampRepair.java | 102 + .../iotdb/library/drepair/UDTFValueFill.java | 104 + .../iotdb/library/drepair/UDTFValueRepair.java | 122 + .../apache/iotdb/library/drepair/util/ARFill.java | 93 + .../iotdb/library/drepair/util/LikelihoodFill.java | 128 + .../iotdb/library/drepair/util/LinearFill.java | 57 + .../iotdb/library/drepair/util/LsGreedy.java | 141 + .../apache/iotdb/library/drepair/util/MAFill.java | 57 + .../iotdb/library/drepair/util/MeanFill.java | 40 + .../iotdb/library/drepair/util/PreviousFill.java | 49 + .../apache/iotdb/library/drepair/util/Screen.java | 138 + .../iotdb/library/drepair/util/ScreenFill.java | 154 + .../library/drepair/util/TimestampInterval.java | 213 + .../library/drepair/util/TimestampRepair.java | 154 + .../iotdb/library/drepair/util/ValueFill.java | 81 + .../iotdb/library/drepair/util/ValueRepair.java | 130 + .../apache/iotdb/library/frequency/UDTFConv.java | 82 + .../apache/iotdb/library/frequency/UDTFDWT.java | 96 + .../apache/iotdb/library/frequency/UDTFDeconv.java | 112 + .../apache/iotdb/library/frequency/UDTFFFT.java | 106 + .../iotdb/library/frequency/UDTFHighPass.java | 98 + .../apache/iotdb/library/frequency/UDTFIDWT.java | 97 + .../apache/iotdb/library/frequency/UDTFIFFT.java | 113 + .../iotdb/library/frequency/UDTFLowPass.java | 95 + .../iotdb/library/frequency/util/DWTUtil.java | 228 + .../iotdb/library/frequency/util/FFTUtil.java | 82 + .../library/series/UDTFConsecutiveSequences.java | 78 + .../library/series/UDTFConsecutiveWindows.java | 90 + .../iotdb/library/series/util/ConsecutiveUtil.java | 129 + .../iotdb/library/string/UDTFRegexMatch.java | 71 + .../iotdb/library/string/UDTFRegexReplace.java | 130 + .../iotdb/library/string/UDTFRegexSplit.java | 76 + .../iotdb/library/string/UDTFStrReplace.java | 153 + .../iotdb/library/util/BooleanCircularQueue.java | 138 + .../apache/iotdb/library/util/CircularQueue.java | 138 + .../iotdb/library/util/DoubleCircularQueue.java | 138 + .../iotdb/library/util/LinearRegression.java | 91 + .../iotdb/library/util/LongCircularQueue.java | 138 + .../iotdb/library/util/NoNumberException.java | 29 + .../java/org/apache/iotdb/library/util/Util.java | 306 + .../apache/iotdb/library/dmatch/DMatchTests.java | 826 ++ .../iotdb/library/dprofile/DProfileTests.java | 629 ++ .../iotdb/library/dquality/DQualityTests.java | 385 + .../apache/iotdb/library/drepair/DRepairTests.java | 317 + .../iotdb/library/frequency/FrequencyTests.java | 300 + .../apache/iotdb/library/series/SeriesTest.java | 467 + .../apache/iotdb/library/string/StringTests.java | 258 + metrics/dropwizard-metrics/pom.xml | 5 +- .../iotdb/metrics/dropwizard/MetricName.java | 60 +- .../reporter/DropwizardIoTDBReporter.java | 75 + .../reporter/DropwizardMetricsExporter.java | 169 +- .../metrics/dropwizard/reporter/IoTDBReporter.java | 247 + .../org.apache.iotdb.metrics.reporter.Reporter | 3 +- metrics/interface/pom.xml | 9 +- .../main/assembly/resources/conf/iotdb-metric.yml | 15 +- .../org/apache/iotdb/metrics/MetricService.java | 22 +- .../apache/iotdb/metrics/config/MetricConfig.java | 143 +- .../iotdb/metrics/reporter/CompositeReporter.java | 14 +- .../apache/iotdb/metrics/utils/MetricsUtils.java | 56 + .../interface/src/test/resources/iotdb-metric.yml | 15 +- metrics/micrometer-metrics/pom.xml | 4 +- .../micrometer/reporter/IoTDBJmxConfig.java | 31 - .../micrometer/reporter/IoTDBMeterRegistry.java | 146 + .../micrometer/reporter/IoTDBRegistryConfig.java | 50 + .../metrics/micrometer/reporter/JmxConfig.java | 29 + .../reporter/MicrometerIoTDBReporter.java | 92 + .../micrometer/reporter/MicrometerJmxReporter.java | 2 +- .../org.apache.iotdb.metrics.reporter.Reporter | 3 +- metrics/pom.xml | 2 +- node-commons/pom.xml | 177 + .../apache/iotdb/commons/ServerCommandLine.java | 67 + .../iotdb/commons/cluster/DataNodeLocation.java | 77 + .../org/apache/iotdb/commons/cluster/Endpoint.java | 92 + .../apache/iotdb/commons/concurrent/HashLock.java | 62 + .../concurrent/IoTDBDaemonThreadFactory.java | 37 + .../IoTDBDefaultThreadExceptionHandler.java | 33 + .../commons/concurrent/IoTDBThreadPoolFactory.java | 289 + .../iotdb/commons/concurrent/IoTThreadFactory.java | 58 + .../iotdb/commons/concurrent/ThreadName.java | 91 + .../iotdb/commons/concurrent/WrappedRunnable.java | 46 + .../concurrent/threadpool/IThreadPoolMBean.java | 45 + .../WrappedScheduledExecutorService.java | 193 + .../WrappedScheduledExecutorServiceMBean.java | 22 + .../WrappedSingleThreadExecutorService.java | 119 + .../WrappedSingleThreadExecutorServiceMBean.java | 22 + .../WrappedSingleThreadScheduledExecutor.java | 141 + .../WrappedSingleThreadScheduledExecutorMBean.java | 22 + .../threadpool/WrappedThreadPoolExecutor.java | 82 + .../threadpool/WrappedThreadPoolExecutorMBean.java | 22 + .../apache/iotdb/commons/conf/IoTDBConstant.java | 203 + .../iotdb/commons/consensus/ConsensusGroupId.java | 77 + .../iotdb/commons/consensus/DataRegionId.java | 78 + .../apache/iotdb/commons/consensus/GroupType.java | 27 + .../iotdb/commons/consensus/PartitionRegionId.java | 78 + .../iotdb/commons/consensus/SchemaRegionId.java | 78 + .../commons/exception/BadNodeUrlException.java | 26 + .../commons/exception/ConfigurationException.java | 44 + .../iotdb/commons/exception/IoTDBException.java | 67 + .../iotdb/commons/exception/ShutdownException.java | 40 + .../iotdb/commons/exception/StartupException.java | 40 + .../exception/runtime/RPCServiceException.java | 32 + .../iotdb/commons/partition/DataPartition.java | 207 + .../commons/partition/DataPartitionQueryParam.java | 43 + .../iotdb/commons/partition/PartitionInfo.java | 41 + .../iotdb/commons/partition/RegionReplicaSet.java | 105 + .../iotdb/commons/partition/SchemaPartition.java | 87 + .../commons/partition/SeriesPartitionSlot.java | 59 + .../iotdb/commons/partition/TimePartitionSlot.java | 64 + .../executor/SeriesPartitionExecutor.java | 33 + .../partition/executor/hash/APHashExecutor.java | 45 + .../partition/executor/hash/BKDRHashExecutor.java | 43 + .../partition/executor/hash/JSHashExecutor.java | 43 + .../partition/executor/hash/SDBMHashExecutor.java | 41 + .../service/AbstractThriftServiceThread.java | 322 + .../org/apache/iotdb/commons/service/IService.java | 49 + .../apache/iotdb/commons/service/JMXService.java | 101 + .../iotdb/commons/service/RegisterManager.java | 85 + .../apache/iotdb/commons/service/ServiceType.java | 92 + .../apache/iotdb/commons/service/StartupCheck.java | 28 + .../iotdb/commons/service/StartupChecks.java | 78 + .../iotdb/commons/service/ThriftService.java | 171 + .../iotdb/commons/service/ThriftServiceThread.java | 89 + .../apache/iotdb/commons/utils/CommonUtils.java | 59 + .../apache/iotdb/commons/utils/JVMCommonUtils.java | 81 + .../apache/iotdb/commons/utils/StatusUtils.java | 226 + .../org/apache/iotdb/commons/utils/TestOnly.java | 34 + .../apache/iotdb/commons/ConsensusGroupIdTest.java | 53 + .../IoTDBDefaultThreadExceptionHandlerTest.java | 80 + .../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 221 + openapi/pom.xml | 2 +- pom.xml | 34 +- server/pom.xml | 33 +- .../resources/conf/iotdb-engine.properties | 298 +- .../src/assembly/resources/sbin/start-datanode.bat | 136 + .../src/assembly/resources/sbin/start-datanode.sh | 97 + .../src/assembly/resources/sbin/stop-datanode.bat | 27 + .../src/assembly/resources/sbin/stop-datanode.sh | 39 + server/src/assembly/resources/sbin/stop-server.sh | 13 +- .../assembly/resources/tools/rocksdb-transfer.bat | 126 + .../assembly/resources/tools/rocksdb-transfer.sh | 82 + .../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +- .../db/auth/authorizer/AuthorizerManager.java | 190 + .../iotdb/db/auth/authorizer/BasicAuthorizer.java | 9 +- .../db/auth/authorizer/ClusterAuthorizer.java | 23 + .../apache/iotdb/db/auth/entity/PrivilegeType.java | 38 +- .../iotdb/db/auth/role/BasicRoleManager.java | 2 +- .../iotdb/db/auth/role/LocalFileRoleAccessor.java | 2 +- .../iotdb/db/auth/user/BasicUserManager.java | 2 +- .../iotdb/db/auth/user/LocalFileUserAccessor.java | 2 +- .../org/apache/iotdb/db/concurrent/HashLock.java | 62 - .../db/concurrent/IoTDBDaemonThreadFactory.java | 37 - .../IoTDBDefaultThreadExceptionHandler.java | 33 - .../db/concurrent/IoTDBThreadPoolFactory.java | 277 - .../iotdb/db/concurrent/IoTThreadFactory.java | 58 - .../org/apache/iotdb/db/concurrent/ThreadName.java | 84 - .../iotdb/db/concurrent/WrappedRunnable.java | 46 - .../db/concurrent/threadpool/IThreadPoolMBean.java | 45 - .../WrappedScheduledExecutorService.java | 193 - .../WrappedScheduledExecutorServiceMBean.java | 22 - .../WrappedSingleThreadExecutorService.java | 119 - .../WrappedSingleThreadExecutorServiceMBean.java | 22 - .../WrappedSingleThreadScheduledExecutor.java | 141 - .../WrappedSingleThreadScheduledExecutorMBean.java | 22 - .../threadpool/WrappedThreadPoolExecutor.java | 82 - .../threadpool/WrappedThreadPoolExecutorMBean.java | 22 - .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 613 +- .../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 71 +- .../org/apache/iotdb/db/conf/IoTDBConstant.java | 195 - .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 418 +- .../db/conf/directories/DirectoryManager.java | 6 +- .../iotdb/db/conf/directories/FolderManager.java | 65 + .../directories/strategy/DirectoryStrategy.java | 4 +- .../strategy/DirectoryStrategyType.java | 26 + .../strategy/MaxDiskUsableSpaceFirstStrategy.java | 6 +- .../MinFolderOccupiedSpaceFirstStrategy.java | 6 +- .../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +- .../directories/strategy/SequenceStrategy.java | 6 +- .../db/conf/rest/IoTDBRestServiceDescriptor.java | 2 +- .../apache/iotdb/db/consensus/ConsensusImpl.java | 77 + .../iotdb/db/consensus/ConsensusManager.java | 72 + .../consensus/statemachine/BaseStateMachine.java | 78 + .../statemachine/DataRegionStateMachine.java | 92 + .../statemachine/SchemaRegionStateMachine.java | 61 + .../org/apache/iotdb/db/engine/StorageEngine.java | 229 +- .../apache/iotdb/db/engine/StorageEngineV2.java | 595 ++ .../iotdb/db/engine/cache/BloomFilterCache.java | 2 +- .../db/engine/cache/CacheHitRatioMonitor.java | 10 +- .../apache/iotdb/db/engine/cache/ChunkCache.java | 2 +- .../db/engine/cache/TimeSeriesMetadataCache.java | 17 +- .../compaction/CompactionExceptionHandler.java | 247 + .../compaction/CompactionMetricsManager.java | 171 + .../db/engine/compaction/CompactionPriority.java | 26 - .../compaction/CompactionRecoverManager.java | 119 + .../db/engine/compaction/CompactionScheduler.java | 165 +- .../compaction/CompactionTaskComparator.java | 111 - .../engine/compaction/CompactionTaskManager.java | 193 +- .../db/engine/compaction/CompactionUtils.java | 340 +- .../db/engine/compaction/TsFileIdentifier.java | 229 - .../DefaultCompactionTaskComparatorImpl.java | 110 + .../comparator/ICompactionTaskComparator.java | 35 + .../compaction/constant/CompactionPriority.java | 26 + .../compaction/constant/CompactionTaskStatus.java | 26 + .../engine/compaction/constant/CompactionType.java | 25 + .../constant/CrossCompactionPerformer.java | 41 + .../constant/CrossCompactionSelector.java | 71 + .../constant/InnerSeqCompactionPerformer.java | 41 + .../constant/InnerSequenceCompactionSelector.java | 48 + .../constant/InnerUnseqCompactionPerformer.java | 41 + .../InnerUnsequenceCompactionSelector.java | 48 + .../compaction/constant/ProcessChunkType.java | 25 + .../AbstractCrossSpaceCompactionSelector.java | 56 - .../cross/AbstractCrossSpaceCompactionTask.java | 109 - .../compaction/cross/CrossCompactionStrategy.java | 100 - .../CrossSpaceCompactionExceptionHandler.java | 232 - .../compaction/cross/CrossSpaceCompactionTask.java | 281 + .../cross/CrossSpaceCompactionTaskFactory.java | 49 - .../compaction/cross/ICrossSpaceSelector.java | 30 + .../RewriteCrossSpaceCompactionResource.java | 206 + .../RewriteCrossSpaceCompactionSelector.java | 64 +- .../manage/CrossSpaceCompactionResource.java | 211 - .../selector/ICrossSpaceMergeFileSelector.java | 2 - .../cross/rewrite/selector/IMergePathSelector.java | 31 - .../cross/rewrite/selector/MergeFileStrategy.java | 27 - .../cross/rewrite/selector/NaivePathSelector.java | 55 - .../selector/RewriteCompactionFileSelector.java | 20 +- .../rewrite/task/ReadPointPerformerSubTask.java | 107 + .../task/RewriteCrossCompactionRecoverTask.java | 464 - .../task/RewriteCrossSpaceCompactionTask.java | 248 - .../AbstractInnerSpaceCompactionSelector.java | 59 - .../inner/AbstractInnerSpaceCompactionTask.java | 142 - .../compaction/inner/IInnerSeqSpaceSelector.java | 28 + .../compaction/inner/IInnerUnseqSpaceSelector.java | 28 + .../compaction/inner/InnerCompactionStrategy.java | 105 - .../InnerSpaceCompactionExceptionHandler.java | 277 - .../compaction/inner/InnerSpaceCompactionTask.java | 367 + .../inner/InnerSpaceCompactionTaskFactory.java | 48 - .../SizeTieredCompactionRecoverTask.java | 324 - .../sizetiered/SizeTieredCompactionSelector.java | 76 +- .../inner/sizetiered/SizeTieredCompactionTask.java | 269 - .../utils/AlignedSeriesCompactionExecutor.java | 27 +- .../inner/utils/InnerSpaceCompactionUtils.java | 306 - .../utils/SingleSeriesCompactionExecutor.java | 45 +- .../compaction/log/CompactionLogAnalyzer.java | 162 + .../db/engine/compaction/log/CompactionLogger.java | 83 + .../db/engine/compaction/log/TsFileIdentifier.java | 229 + .../compaction/performer/ICompactionPerformer.java | 49 + .../performer/ICrossCompactionPerformer.java | 27 + .../performer/ISeqCompactionPerformer.java | 27 + .../performer/IUnseqCompactionPerformer.java | 27 + .../impl/ReadChunkCompactionPerformer.java | 166 + .../impl/ReadPointCompactionPerformer.java | 360 + .../task/AbstractCompactionSelector.java | 29 - .../compaction/task/AbstractCompactionTask.java | 61 +- .../compaction/task/CompactionRecoverTask.java | 523 +- .../compaction/task/ICompactionSelector.java | 54 + .../utils/log/CompactionLogAnalyzer.java | 163 - .../compaction/utils/log/CompactionLogger.java | 83 - .../writer/AbstractCompactionWriter.java | 75 +- .../writer/CrossSpaceCompactionWriter.java | 80 +- .../writer/InnerSpaceCompactionWriter.java | 27 +- .../org/apache/iotdb/db/engine/cq/CQLogReader.java | 2 +- .../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 2 +- .../engine/cq/ContinuousQuerySchemaCheckTask.java | 2 +- .../iotdb/db/engine/cq/ContinuousQueryService.java | 10 +- .../iotdb/db/engine/cq/ContinuousQueryTask.java | 8 +- .../engine/cq/ContinuousQueryTaskPoolManager.java | 4 +- .../iotdb/db/engine/flush/FlushListener.java | 17 +- .../apache/iotdb/db/engine/flush/FlushManager.java | 10 +- .../apache/iotdb/db/engine/flush/FlushStatus.java | 28 + .../iotdb/db/engine/flush/TsFileFlushPolicy.java | 14 +- .../engine/flush/pool/FlushSubTaskPoolManager.java | 4 +- .../db/engine/flush/pool/FlushTaskPoolManager.java | 4 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 329 +- .../engine/memtable/AlignedWritableMemChunk.java | 57 +- .../memtable/AlignedWritableMemChunkGroup.java | 22 + .../apache/iotdb/db/engine/memtable/IMemTable.java | 22 +- .../db/engine/memtable/IWritableMemChunk.java | 9 +- .../db/engine/memtable/IWritableMemChunkGroup.java | 3 +- .../iotdb/db/engine/memtable/WritableMemChunk.java | 28 + .../db/engine/memtable/WritableMemChunkGroup.java | 37 + .../apache/iotdb/db/engine/settle/SettleTask.java | 2 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 3493 ++++++ .../db/engine/storagegroup/StorageGroupInfo.java | 49 +- .../db/engine/storagegroup/TsFileManager.java | 17 +- .../engine/storagegroup/TsFileNameGenerator.java | 4 +- .../db/engine/storagegroup/TsFileProcessor.java | 310 +- .../engine/storagegroup/TsFileProcessorInfo.java | 9 +- .../db/engine/storagegroup/TsFileResource.java | 99 +- .../db/engine/storagegroup/TsFileResourceList.java | 7 +- .../engine/storagegroup/TsFileResourceStatus.java | 27 + .../storagegroup/VirtualStorageGroupProcessor.java | 3285 ------ .../dataregion/HashVirtualPartitioner.java | 58 + .../dataregion/StorageGroupManager.java | 489 + .../dataregion/VirtualPartitioner.java | 39 + .../virtualSg/HashVirtualPartitioner.java | 58 - .../virtualSg/StorageGroupManager.java | 513 - .../storagegroup/virtualSg/VirtualPartitioner.java | 39 - .../engine/trigger/executor/TriggerExecutor.java | 2 +- .../engine/trigger/service/TriggerLogReader.java | 2 +- .../engine/trigger/service/TriggerLogWriter.java | 4 +- .../service/TriggerRegistrationService.java | 34 +- .../trigger/sink/local/LocalIoTDBHandler.java | 6 +- .../iotdb/db/engine/upgrade/UpgradeTask.java | 2 +- .../db/exception/BadNodeUrlFormatException.java | 28 + .../iotdb/db/exception/BatchProcessException.java | 2 +- .../iotdb/db/exception/ConfigurationException.java | 44 - .../iotdb/db/exception/DataRegionException.java | 35 + .../apache/iotdb/db/exception/IoTDBException.java | 67 - .../iotdb/db/exception/LoadFileException.java | 1 + .../apache/iotdb/db/exception/MergeException.java | 1 + .../db/exception/QueryIdNotExsitException.java | 1 + .../exception/QueryInBatchStatementException.java | 1 + .../iotdb/db/exception/ShutdownException.java | 40 - .../iotdb/db/exception/StartupException.java | 40 - .../iotdb/db/exception/StorageEngineException.java | 1 + .../exception/StorageGroupProcessorException.java | 34 - .../db/exception/SyncConnectionException.java | 1 + .../SyncDeviceOwnerConflictException.java | 1 + .../iotdb/db/exception/SystemCheckException.java | 1 + .../db/exception/TsFileProcessorException.java | 1 + .../iotdb/db/exception/WriteProcessException.java | 1 + .../db/exception/index/IndexManagerException.java | 2 +- .../metadata/AcquireLockTimeoutException.java | 26 + .../metadata/DifferentTemplateException.java | 33 - .../metadata/DuplicatedTemplateException.java | 31 - .../db/exception/metadata/MetadataException.java | 2 +- .../metadata/NoTemplateOnMNodeException.java | 33 - .../SchemaDirCreationFailureException.java | 26 + .../metadata/StorageGroupNotSetException.java | 6 + .../metadata/TemplateImcompatibeException.java | 40 - .../metadata/TemplateIsInUseException.java | 33 - .../metadata/UndefinedTemplateException.java | 31 - .../metadata/cache/MNodeNotCachedException.java | 28 + .../metadata/cache/MNodeNotPinnedException.java | 29 + .../schemafile/RecordDuplicatedException.java | 34 + .../metadata/schemafile/SchemaFileNotExists.java | 34 + .../schemafile/SchemaPageOverflowException.java | 34 + .../schemafile/SegmentNotFoundException.java | 41 + .../schemafile/SegmentOverflowException.java | 41 + .../template/DifferentTemplateException.java | 34 + .../template/DuplicatedTemplateException.java | 32 + .../template/NoTemplateOnMNodeException.java | 34 + .../template/TemplateImcompatibeException.java | 41 + .../template/TemplateIsInUseException.java | 34 + .../template/UndefinedTemplateException.java | 32 + .../exception/query/LogicalOperatorException.java | 2 +- .../exception/query/LogicalOptimizeException.java | 2 +- .../db/exception/query/QueryProcessException.java | 2 +- .../db/exception/runtime/RPCServiceException.java | 32 - .../db/exception/runtime/SQLParserException.java | 35 - .../iotdb/db/exception/sql/SQLParserException.java | 35 + .../iotdb/db/exception/sql/SemanticException.java | 27 + .../exception/sql/StatementAnalyzeException.java | 45 + .../iotdb/db/metadata/Executor/SchemaVisitor.java | 55 + .../iotdb/db/metadata/LocalConfigManager.java | 787 ++ .../db/metadata/LocalSchemaPartitionTable.java | 121 + .../iotdb/db/metadata/LocalSchemaProcessor.java | 1431 +++ .../org/apache/iotdb/db/metadata/MManager.java | 2431 ----- .../apache/iotdb/db/metadata/MetadataConstant.java | 10 +- .../idtable/AppendOnlyDiskSchemaManager.java | 41 +- .../apache/iotdb/db/metadata/idtable/IDTable.java | 12 +- .../db/metadata/idtable/IDTableHashmapImpl.java | 41 +- .../iotdb/db/metadata/idtable/IDTableManager.java | 40 +- .../db/metadata/idtable/IDiskSchemaManager.java | 2 +- .../db/metadata/idtable/entry/DeviceEntry.java | 2 +- .../db/metadata/idtable/entry/DeviceIDFactory.java | 2 +- .../iotdb/db/metadata/idtable/entry/IDeviceID.java | 4 + .../idtable/entry/InsertMeasurementMNode.java | 32 +- .../db/metadata/idtable/entry/PlainDeviceID.java | 12 + .../db/metadata/idtable/entry/SHA256DeviceID.java | 21 + .../db/metadata/idtable/entry/SchemaEntry.java | 2 +- .../db/metadata/lastCache/LastCacheManager.java | 8 +- .../iotdb/db/metadata/logfile/MLogReader.java | 4 +- .../iotdb/db/metadata/logfile/MLogTxtReader.java | 2 +- .../iotdb/db/metadata/logfile/MLogUpgrader.java | 290 - .../iotdb/db/metadata/logfile/MLogWriter.java | 2 +- .../iotdb/db/metadata/mnode/EntityMNode.java | 21 + .../org/apache/iotdb/db/metadata/mnode/IMNode.java | 24 +- .../iotdb/db/metadata/mnode/InternalMNode.java | 65 +- .../org/apache/iotdb/db/metadata/mnode/MNode.java | 35 +- .../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 10 +- .../iotdb/db/metadata/mnode/MeasurementMNode.java | 19 +- .../db/metadata/mnode/StorageGroupEntityMNode.java | 13 + .../iotdb/db/metadata/mnode/StorageGroupMNode.java | 13 + .../metadata/mnode/container/IMNodeContainer.java | 25 + .../mnode/container/MNodeContainerMapImpl.java | 26 + .../metadata/mnode/container/MNodeContainers.java | 103 + .../mnode/estimator/BasicMNodSizeEstimator.java | 117 + .../mnode/estimator/IMNodeSizeEstimator.java | 38 + .../db/metadata/mnode/iterator/IMNodeIterator.java | 28 + .../db/metadata/mnode/iterator/MNodeIterator.java | 48 + .../org/apache/iotdb/db/metadata/mtree/MTree.java | 1898 ---- .../iotdb/db/metadata/mtree/MTreeAboveSG.java | 506 + .../iotdb/db/metadata/mtree/MTreeBelowSG.java | 1519 +++ .../db/metadata/mtree/store/CachedMTreeStore.java | 590 ++ .../iotdb/db/metadata/mtree/store/IMTreeStore.java | 61 + .../db/metadata/mtree/store/MemMTreeStore.java | 170 + .../mtree/store/disk/CachedMNodeContainer.java | 428 + .../mtree/store/disk/ICachedMNodeContainer.java | 80 + .../mtree/store/disk/MTreeFlushTaskManager.java | 75 + .../mtree/store/disk/MTreeReleaseTaskManager.java | 74 + .../db/metadata/mtree/store/disk/SegmentLock.java | 91 + .../mtree/store/disk/cache/CacheEntry.java | 48 + .../mtree/store/disk/cache/CacheManager.java | 537 + .../mtree/store/disk/cache/ICacheManager.java | 52 + .../mtree/store/disk/cache/LRUCacheManager.java | 256 + .../mtree/store/disk/cache/PlainCacheManager.java | 72 + .../disk/memcontrol/CachedMNodeSizeEstimator.java | 71 + .../mtree/store/disk/memcontrol/IMemManager.java | 52 + .../store/disk/memcontrol/MemManagerHolder.java | 41 + .../MemManagerNodeEstimatedSizeBasedImpl.java | 132 + .../memcontrol/MemManagerNodeNumBasedImpl.java | 105 + .../mtree/store/disk/schemafile/ISchemaFile.java | 63 + .../mtree/store/disk/schemafile/ISchemaPage.java | 125 + .../mtree/store/disk/schemafile/ISegment.java | 95 + .../store/disk/schemafile/MockSchemaFile.java | 235 + .../mtree/store/disk/schemafile/RecordUtils.java | 339 + .../mtree/store/disk/schemafile/SchemaFile.java | 937 ++ .../mtree/store/disk/schemafile/SchemaPage.java | 623 ++ .../mtree/store/disk/schemafile/Segment.java | 708 ++ .../db/metadata/mtree/traverser/Traverser.java | 276 +- .../traverser/collector/CollectorTraverser.java | 11 +- .../mtree/traverser/collector/EntityCollector.java | 11 +- .../traverser/collector/MNodeAboveSGCollector.java | 59 + .../mtree/traverser/collector/MNodeCollector.java | 8 +- .../traverser/collector/MeasurementCollector.java | 31 +- .../traverser/collector/StorageGroupCollector.java | 6 +- .../mtree/traverser/counter/CounterTraverser.java | 6 +- .../mtree/traverser/counter/EntityCounter.java | 6 +- .../counter/MNodeAboveSGLevelCounter.java | 60 + .../mtree/traverser/counter/MNodeLevelCounter.java | 29 +- .../traverser/counter/MeasurementCounter.java | 6 +- .../counter/MeasurementGroupByLevelCounter.java | 32 +- .../traverser/counter/StorageGroupCounter.java | 6 +- .../apache/iotdb/db/metadata/path/AlignedPath.java | 57 +- .../iotdb/db/metadata/path/MeasurementPath.java | 50 +- .../apache/iotdb/db/metadata/path/PartialPath.java | 36 +- .../db/metadata/path/PathDeserializeUtil.java | 59 + .../iotdb/db/metadata/rescon/MemoryStatistics.java | 97 + .../db/metadata/rescon/SchemaResourceManager.java | 67 + .../db/metadata/rescon/TimeseriesStatistics.java | 76 + .../db/metadata/schemaregion/ISchemaRegion.java | 193 + .../db/metadata/schemaregion/SchemaEngine.java | 106 + .../db/metadata/schemaregion/SchemaEngineMode.java | 26 + .../db/metadata/schemaregion/SchemaRegion.java | 1878 ++++ .../metadata/schemaregion/SchemaRegionUtils.java | 59 + .../schemaregion/rocksdb/CheckKeyResult.java | 50 + .../schemaregion/rocksdb/RSchemaConstants.java | 76 + .../schemaregion/rocksdb/RSchemaLogger.java | 61 + .../rocksdb/RSchemaReadWriteHandler.java | 514 + .../schemaregion/rocksdb/RSchemaRegion.java | 1962 ++++ .../schemaregion/rocksdb/RSchemaUtils.java | 592 ++ .../schemaregion/rocksdb/mnode/REntityMNode.java | 124 + .../schemaregion/rocksdb/mnode/RInternalMNode.java | 197 + .../schemaregion/rocksdb/mnode/RMNode.java | 234 + .../schemaregion/rocksdb/mnode/RMNodeType.java | 49 + .../rocksdb/mnode/RMNodeValueType.java | 47 + .../rocksdb/mnode/RMeasurementMNode.java | 262 + .../rocksdb/mnode/RStorageGroupMNode.java | 102 + .../storagegroup/IStorageGroupSchemaManager.java | 210 + .../storagegroup/StorageGroupLogReader.java | 47 + .../storagegroup/StorageGroupLogWriter.java | 56 + .../storagegroup/StorageGroupSchemaManager.java | 263 + .../apache/iotdb/db/metadata/tag/TagManager.java | 47 +- .../iotdb/db/metadata/template/Template.java | 65 +- .../db/metadata/template/TemplateLogReader.java | 46 + .../db/metadata/template/TemplateLogWriter.java | 64 + .../db/metadata/template/TemplateManager.java | 241 +- .../db/metadata/upgrade/MetadataUpgrader.java | 438 + .../iotdb/db/metadata/utils/MetaFormatUtils.java | 10 +- .../apache/iotdb/db/metadata/utils/MetaUtils.java | 4 +- .../reporter/DropwizardIoTDBReporter.java | 74 - .../metrics/dropwizard/reporter/IoTDBReporter.java | 233 - .../org/apache/iotdb/db/metrics/metricsUtils.java | 61 - .../micrometer/registry/IoTDBMeterRegistry.java | 150 - .../micrometer/registry/IoTDBRegistryConfig.java | 31 - .../reporter/MicrometerIoTDBReporter.java | 94 - .../iotdb/db/mpp/buffer/DataBlockManager.java | 342 + .../iotdb/db/mpp/buffer/DataBlockService.java | 141 + .../mpp/buffer/DataBlockServiceClientFactory.java | 50 + .../mpp/buffer/DataBlockServiceThriftHandler.java | 44 + .../iotdb/db/mpp/buffer/IDataBlockManager.java | 79 + .../apache/iotdb/db/mpp/buffer/ISinkHandle.java | 78 + .../apache/iotdb/db/mpp/buffer/ISourceHandle.java | 54 + .../org/apache/iotdb/db/mpp/buffer/SinkHandle.java | 366 + .../apache/iotdb/db/mpp/buffer/SourceHandle.java | 408 + .../apache/iotdb/db/mpp/buffer/StubSinkHandle.java | 88 + .../iotdb/db/mpp/buffer/TsBlockSerdeFactory.java | 31 + .../iotdb/db/mpp/common/FragmentInstanceId.java | 102 + .../iotdb/db/mpp/common/GroupByTimeParameter.java | 27 + .../iotdb/db/mpp/common/MPPQueryContext.java | 66 + .../apache/iotdb/db/mpp/common/PlanFragmentId.java | 101 + .../org/apache/iotdb/db/mpp/common/QueryId.java | 138 + .../iotdb/db/mpp/common/ResultNodeContext.java | 67 + .../apache/iotdb/db/mpp/common/SchemaRegion.java | 29 + .../apache/iotdb/db/mpp/common/SessionInfo.java | 26 + .../db/mpp/common/filter/BasicFilterType.java | 189 + .../db/mpp/common/filter/BasicFunctionFilter.java | 191 + .../mpp/common/filter/FilterDeserializeUtil.java | 63 + .../iotdb/db/mpp/common/filter/FunctionFilter.java | 91 + .../iotdb/db/mpp/common/filter/InFilter.java | 224 + .../iotdb/db/mpp/common/filter/LikeFilter.java | 152 + .../iotdb/db/mpp/common/filter/QueryFilter.java | 354 + .../iotdb/db/mpp/common/filter/RegexpFilter.java | 150 + .../db/mpp/common/schematree/DeviceSchemaInfo.java | 47 + .../db/mpp/common/schematree/PathPatternNode.java | 103 + .../db/mpp/common/schematree/PathPatternTree.java | 203 + .../db/mpp/common/schematree/SchemaEntityNode.java | 95 + .../mpp/common/schematree/SchemaInternalNode.java | 83 + .../common/schematree/SchemaMeasurementNode.java | 82 + .../iotdb/db/mpp/common/schematree/SchemaNode.java | 76 + .../iotdb/db/mpp/common/schematree/SchemaTree.java | 121 + .../mpp/common/schematree/SchemaTreeVisitor.java | 235 + .../iotdb/db/mpp/execution/ConfigExecution.java | 110 + .../apache/iotdb/db/mpp/execution/Coordinator.java | 111 + .../apache/iotdb/db/mpp/execution/DataDriver.java | 321 + .../iotdb/db/mpp/execution/DataDriverContext.java | 62 + .../org/apache/iotdb/db/mpp/execution/Driver.java | 63 + .../iotdb/db/mpp/execution/DriverContext.java | 46 + .../iotdb/db/mpp/execution/ExecutionResult.java | 32 + .../iotdb/db/mpp/execution/FragmentInfo.java | 44 + .../db/mpp/execution/FragmentInstanceContext.java | 124 + .../mpp/execution/FragmentInstanceExecution.java | 88 + .../db/mpp/execution/FragmentInstanceInfo.java | 40 + .../db/mpp/execution/FragmentInstanceManager.java | 198 + .../db/mpp/execution/FragmentInstanceState.java | 80 + .../iotdb/db/mpp/execution/FragmentState.java | 71 + .../iotdb/db/mpp/execution/FutureStateChange.java | 74 + .../apache/iotdb/db/mpp/execution/IConfigTask.java | 26 + .../iotdb/db/mpp/execution/IQueryExecution.java | 29 + .../iotdb/db/mpp/execution/QueryExecution.java | 245 + .../apache/iotdb/db/mpp/execution/QueryState.java | 49 + .../iotdb/db/mpp/execution/QueryStateMachine.java | 129 + .../iotdb/db/mpp/execution/SampleConfigTask.java | 47 + .../iotdb/db/mpp/execution/SchemaDriver.java | 149 + .../db/mpp/execution/SchemaDriverContext.java | 36 + .../iotdb/db/mpp/execution/StateMachine.java | 322 + .../scheduler/AbstractFragInsStateTracker.java | 73 + .../mpp/execution/scheduler/ClusterScheduler.java | 157 + .../scheduler/FixedRateFragInsStateTracker.java | 70 + .../scheduler/FragInstanceDispatchResult.java | 32 + .../scheduler/IFragInstanceDispatcher.java | 37 + .../scheduler/IFragInstanceStateTracker.java | 26 + .../mpp/execution/scheduler/IQueryTerminator.java | 24 + .../db/mpp/execution/scheduler/IScheduler.java | 40 + .../scheduler/InternalServiceClientFactory.java | 40 + .../scheduler/SimpleFragInstanceDispatcher.java | 75 + .../execution/scheduler/SimpleQueryTerminator.java | 82 + .../execution/scheduler/StandaloneScheduler.java | 56 + .../iotdb/db/mpp/memory/LocalMemoryManager.java | 43 + .../org/apache/iotdb/db/mpp/memory/MemoryPool.java | 185 + .../org/apache/iotdb/db/mpp/operator/Operator.java | 57 + .../iotdb/db/mpp/operator/OperatorContext.java | 54 + .../db/mpp/operator/process/AggregateOperator.java | 57 + .../mpp/operator/process/DeviceMergeOperator.java | 56 + .../db/mpp/operator/process/FillOperator.java | 56 + .../mpp/operator/process/FilterNullOperator.java | 57 + .../mpp/operator/process/GroupByLevelOperator.java | 57 + .../db/mpp/operator/process/LimitOperator.java | 82 + .../db/mpp/operator/process/OffsetOperator.java | 57 + .../db/mpp/operator/process/ProcessOperator.java | 24 + .../db/mpp/operator/process/SortOperator.java | 57 + .../db/mpp/operator/process/TimeJoinOperator.java | 201 + .../db/mpp/operator/sink/FragmentSinkOperator.java | 66 + .../iotdb/db/mpp/operator/sink/SinkOperator.java | 43 + .../mpp/operator/source/AlignedSeriesScanUtil.java | 85 + .../db/mpp/operator/source/DataSourceOperator.java | 26 + .../db/mpp/operator/source/ExchangeOperator.java | 93 + .../source/SeriesAggregateScanOperator.java | 66 + .../db/mpp/operator/source/SeriesScanOperator.java | 153 + .../db/mpp/operator/source/SeriesScanUtil.java | 1403 +++ .../db/mpp/operator/source/SourceOperator.java | 27 + .../iotdb/db/mpp/schedule/AbstractExecutor.java | 72 + .../iotdb/db/mpp/schedule/ExecutionContext.java | 46 + .../db/mpp/schedule/FragmentInstanceScheduler.java | 369 + .../mpp/schedule/FragmentInstanceTaskExecutor.java | 84 + .../schedule/FragmentInstanceTimeoutSentinel.java | 55 + .../mpp/schedule/IFragmentInstanceScheduler.java | 61 + .../iotdb/db/mpp/schedule/ITaskScheduler.java | 77 + .../org/apache/iotdb/db/mpp/schedule/queue/ID.java | 22 + .../db/mpp/schedule/queue/IDIndexedAccessible.java | 48 + .../mpp/schedule/queue/IndexedBlockingQueue.java | 201 + .../db/mpp/schedule/queue/L1PriorityQueue.java | 91 + .../db/mpp/schedule/queue/L2PriorityQueue.java | 109 + .../db/mpp/schedule/task/FragmentInstanceTask.java | 202 + .../mpp/schedule/task/FragmentInstanceTaskID.java | 66 + .../schedule/task/FragmentInstanceTaskStatus.java | 37 + .../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 99 + .../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 591 ++ .../mpp/sql/analyze/ClusterPartitionFetcher.java | 59 + .../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 49 + .../mpp/sql/analyze/FakePartitionFetcherImpl.java | 119 + .../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 92 + .../db/mpp/sql/analyze/IPartitionFetcher.java | 41 + .../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 44 + .../apache/iotdb/db/mpp/sql/analyze/QueryType.java | 24 + .../sql/analyze/StandalonePartitionFetcher.java | 66 + .../mpp/sql/analyze/StandaloneSchemaFetcher.java | 55 + .../iotdb/db/mpp/sql/constant/FilterConstant.java | 103 + .../iotdb/db/mpp/sql/constant/StatementType.java | 137 + .../db/mpp/sql/optimization/PlanOptimizer.java | 26 + .../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 1950 ++++ .../db/mpp/sql/parser/StatementGenerator.java | 394 + .../db/mpp/sql/planner/DistributionPlanner.java | 373 + .../db/mpp/sql/planner/LocalExecutionPlanner.java | 330 + .../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 476 + .../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 277 + .../mpp/sql/planner/plan/DistributedQueryPlan.java | 57 + .../db/mpp/sql/planner/plan/FragmentInstance.java | 181 + .../sql/planner/plan/IFragmentParallelPlaner.java | 36 + .../db/mpp/sql/planner/plan/IOutputPlanNode.java | 34 + .../db/mpp/sql/planner/plan/LogicalQueryPlan.java | 45 + .../db/mpp/sql/planner/plan/PlanFragment.java | 134 + .../plan/SimpleFragmentParallelPlanner.java | 142 + .../iotdb/db/mpp/sql/planner/plan/SubPlan.java | 69 + .../db/mpp/sql/planner/plan/node/ColumnHeader.java | 106 + .../db/mpp/sql/planner/plan/node/PlanNode.java | 122 + .../db/mpp/sql/planner/plan/node/PlanNodeId.java | 61 + .../db/mpp/sql/planner/plan/node/PlanNodeType.java | 140 + .../db/mpp/sql/planner/plan/node/PlanNodeUtil.java | 116 + .../db/mpp/sql/planner/plan/node/PlanVisitor.java | 104 + .../planner/plan/node/SimplePlanNodeRewriter.java | 44 + .../plan/node/metedata/read/ShowDevicesNode.java | 67 + .../planner/plan/node/metedata/read/ShowNode.java | 36 + .../node/metedata/write/AlterTimeSeriesNode.java | 308 + .../plan/node/metedata/write/AuthorNode.java | 351 + .../write/CreateAlignedTimeSeriesNode.java | 376 + .../node/metedata/write/CreateTimeSeriesNode.java | 318 + .../planner/plan/node/process/AggregateNode.java | 190 + .../planner/plan/node/process/DeviceMergeNode.java | 215 + .../planner/plan/node/process/ExchangeNode.java | 189 + .../sql/planner/plan/node/process/FillNode.java | 146 + .../sql/planner/plan/node/process/FilterNode.java | 178 + .../planner/plan/node/process/FilterNullNode.java | 172 + .../plan/node/process/GroupByLevelNode.java | 185 + .../sql/planner/plan/node/process/LimitNode.java | 150 + .../sql/planner/plan/node/process/OffsetNode.java | 145 + .../sql/planner/plan/node/process/ProcessNode.java | 29 + .../sql/planner/plan/node/process/SortNode.java | 157 + .../planner/plan/node/process/TimeJoinNode.java | 197 + .../planner/plan/node/sink/FragmentSinkNode.java | 175 + .../mpp/sql/planner/plan/node/sink/SinkNode.java | 31 + .../plan/node/source/SeriesAggregateScanNode.java | 258 + .../planner/plan/node/source/SeriesScanNode.java | 320 + .../sql/planner/plan/node/source/SourceNode.java | 36 + .../plan/node/write/InsertMultiTabletsNode.java | 164 + .../sql/planner/plan/node/write/InsertNode.java | 141 + .../sql/planner/plan/node/write/InsertRowNode.java | 117 + .../planner/plan/node/write/InsertRowsNode.java | 141 + .../plan/node/write/InsertRowsOfOneDeviceNode.java | 137 + .../planner/plan/node/write/InsertTabletNode.java | 285 + .../sql/rewriter/ColumnPaginationController.java | 145 + .../db/mpp/sql/rewriter/ConcatPathRewriter.java | 187 + .../db/mpp/sql/rewriter/DnfFilterOptimizer.java | 163 + .../db/mpp/sql/rewriter/IFilterOptimizer.java | 29 + .../sql/rewriter/MergeSingleFilterOptimizer.java | 179 + .../db/mpp/sql/rewriter/RemoveNotOptimizer.java | 103 + .../db/mpp/sql/rewriter/WildcardsRemover.java | 369 + .../iotdb/db/mpp/sql/statement/Statement.java | 58 + .../iotdb/db/mpp/sql/statement/StatementNode.java | 32 + .../db/mpp/sql/statement/StatementVisitor.java | 227 + .../mpp/sql/statement/component/FillComponent.java | 51 + .../db/mpp/sql/statement/component/FillPolicy.java | 23 + .../statement/component/FilterNullComponent.java | 98 + .../sql/statement/component/FilterNullPolicy.java | 25 + .../mpp/sql/statement/component/FromComponent.java | 42 + .../statement/component/GroupByLevelComponent.java | 56 + .../component/GroupByLevelController.java | 241 + .../statement/component/GroupByTimeComponent.java | 101 + .../db/mpp/sql/statement/component/OrderBy.java | 26 + .../mpp/sql/statement/component/ResultColumn.java | 196 + .../sql/statement/component/ResultSetFormat.java | 27 + .../sql/statement/component/SelectComponent.java | 165 + .../sql/statement/component/WhereCondition.java | 43 + .../statement/crud/AggregationQueryStatement.java | 117 + .../mpp/sql/statement/crud/FillQueryStatement.java | 78 + .../statement/crud/GroupByFillQueryStatement.java | 48 + .../sql/statement/crud/GroupByQueryStatement.java | 48 + .../sql/statement/crud/InsertBaseStatement.java | 101 + .../crud/InsertMultiTabletsStatement.java | 88 + .../mpp/sql/statement/crud/InsertRowStatement.java | 206 + .../crud/InsertRowsOfOneDeviceStatement.java | 91 + .../sql/statement/crud/InsertRowsStatement.java | 95 + .../db/mpp/sql/statement/crud/InsertStatement.java | 89 + .../sql/statement/crud/InsertTabletStatement.java | 130 + .../mpp/sql/statement/crud/LastQueryStatement.java | 61 + .../db/mpp/sql/statement/crud/QueryStatement.java | 290 + .../mpp/sql/statement/crud/UDAFQueryStatement.java | 96 + .../mpp/sql/statement/crud/UDTFQueryStatement.java | 33 + .../metadata/AlterTimeSeriesStatement.java | 119 + .../metadata/CreateAlignedTimeSeriesStatement.java | 172 + .../metadata/CreateTimeSeriesStatement.java | 124 + .../statement/metadata/ShowDevicesStatement.java | 52 + .../mpp/sql/statement/metadata/ShowStatement.java | 50 + .../metadata/ShowTimeSeriesStatement.java | 81 + .../db/mpp/sql/statement/sys/AuthorStatement.java | 152 + .../protocol/influxdb/constant/InfluxConstant.java | 28 + .../influxdb/constant/InfluxDBConstant.java | 24 - .../influxdb/constant/InfluxSQLConstant.java | 7 + .../protocol/influxdb/function/InfluxFunction.java | 58 + .../influxdb/function/InfluxFunctionFactory.java | 62 + .../influxdb/function/InfluxFunctionValue.java | 46 + .../function/aggregator/InfluxAggregator.java | 35 + .../function/aggregator/InfluxCountFunction.java | 59 + .../function/aggregator/InfluxMeanFunction.java | 72 + .../function/aggregator/InfluxMedianFunction.java | 75 + .../function/aggregator/InfluxModeFunction.java | 88 + .../function/aggregator/InfluxSpreadFunction.java | 88 + .../function/aggregator/InfluxStddevFunction.java | 68 + .../function/aggregator/InfluxSumFunction.java | 68 + .../function/selector/InfluxFirstFunction.java | 73 + .../function/selector/InfluxLastFunction.java | 73 + .../function/selector/InfluxMaxFunction.java | 102 + .../function/selector/InfluxMinFunction.java | 102 + .../influxdb/function/selector/InfluxSelector.java | 57 + .../db/protocol/influxdb/handler/QueryHandler.java | 957 ++ .../influxdb/meta/InfluxDBMetaManager.java | 10 +- .../influxdb/operator/InfluxSelectComponent.java | 8 +- .../db/protocol/influxdb/util/CommonUtils.java | 40 + .../db/protocol/influxdb/util/FieldUtils.java | 51 + .../db/protocol/influxdb/util/FilterUtils.java | 83 + .../protocol/influxdb/util/QueryResultUtils.java | 291 + .../db/protocol/influxdb/util/StringUtils.java | 97 + .../db/protocol/mqtt/PayloadFormatManager.java | 89 +- .../iotdb/db/protocol/mqtt/PublishHandler.java | 14 +- .../apache/iotdb/db/protocol/rest/RestService.java | 6 +- .../rest/handler/AuthorizationHandler.java | 12 +- .../db/protocol/rest/handler/ExceptionHandler.java | 2 +- .../protocol/rest/impl/GrafanaApiServiceImpl.java | 4 +- .../db/protocol/rest/impl/PingApiServiceImpl.java | 2 +- .../db/protocol/rest/impl/RestApiServiceImpl.java | 4 +- .../main/java/org/apache/iotdb/db/qp/Planner.java | 2 +- .../iotdb/db/qp/constant/FilterConstant.java | 3 +- .../apache/iotdb/db/qp/constant/SQLConstant.java | 4 + .../apache/iotdb/db/qp/executor/IPlanExecutor.java | 6 +- .../apache/iotdb/db/qp/executor/PlanExecutor.java | 296 +- .../db/qp/logical/crud/BasicFunctionOperator.java | 2 +- .../db/qp/logical/crud/BasicOperatorType.java | 4 +- .../db/qp/logical/crud/DeleteDataOperator.java | 2 +- .../db/qp/logical/crud/FillQueryOperator.java | 2 +- .../iotdb/db/qp/logical/crud/InsertOperator.java | 2 +- .../iotdb/db/qp/logical/crud/QueryOperator.java | 33 +- .../iotdb/db/qp/logical/crud/SelectComponent.java | 4 +- .../db/qp/logical/crud/SpecialClauseComponent.java | 22 + .../db/qp/logical/crud/UDAFQueryOperator.java | 4 +- .../sys/CreateAlignedTimeSeriesOperator.java | 59 +- .../db/qp/logical/sys/CreateSnapshotOperator.java | 40 - .../org/apache/iotdb/db/qp/physical/BatchPlan.java | 2 +- .../apache/iotdb/db/qp/physical/PhysicalPlan.java | 88 +- .../iotdb/db/qp/physical/crud/AggregationPlan.java | 6 +- .../db/qp/physical/crud/AlignByDevicePlan.java | 54 +- .../iotdb/db/qp/physical/crud/DeletePlan.java | 46 +- .../db/qp/physical/crud/GroupByTimeFillPlan.java | 7 +- .../db/qp/physical/crud/InsertMultiTabletPlan.java | 447 - .../qp/physical/crud/InsertMultiTabletsPlan.java | 447 + .../iotdb/db/qp/physical/crud/InsertPlan.java | 2 +- .../iotdb/db/qp/physical/crud/InsertRowPlan.java | 279 +- .../physical/crud/InsertRowsOfOneDevicePlan.java | 2 +- .../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 4 +- .../db/qp/physical/crud/InsertTabletPlan.java | 462 +- .../iotdb/db/qp/physical/crud/LastQueryPlan.java | 12 +- .../iotdb/db/qp/physical/crud/QueryPlan.java | 19 +- .../db/qp/physical/crud/RawDataQueryPlan.java | 25 + .../physical/sys/CreateAlignedTimeSeriesPlan.java | 179 +- .../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 4 +- .../db/qp/physical/sys/CreateSnapshotPlan.java | 56 - .../db/qp/physical/sys/CreateTemplatePlan.java | 2 +- .../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 6 +- .../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 2 +- .../db/qp/physical/sys/UnsetTemplatePlan.java | 2 +- .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 101 +- .../iotdb/db/qp/strategy/LogicalGenerator.java | 6 +- .../qp/strategy/optimizer/ConcatPathOptimizer.java | 125 +- .../apache/iotdb/db/qp/utils/DatetimeUtils.java | 24 +- .../iotdb/db/qp/utils/GroupByLevelController.java | 96 +- .../apache/iotdb/db/qp/utils/WildcardsRemover.java | 4 +- .../db/query/aggregation/AggregateResult.java | 62 +- .../aggregation/RemovableAggregateResult.java | 30 + .../db/query/aggregation/impl/AvgAggrResult.java | 22 +- .../db/query/aggregation/impl/CountAggrResult.java | 14 +- .../query/aggregation/impl/ExtremeAggrResult.java | 8 +- .../aggregation/impl/FirstValueAggrResult.java | 3 - .../aggregation/impl/LastValueAggrResult.java | 3 - .../query/aggregation/impl/MaxTimeAggrResult.java | 5 + .../query/aggregation/impl/MaxValueAggrResult.java | 4 + .../query/aggregation/impl/MinTimeAggrResult.java | 5 + .../query/aggregation/impl/MinValueAggrResult.java | 4 + .../db/query/aggregation/impl/SumAggrResult.java | 20 +- .../db/query/control/QueryResourceManager.java | 12 +- .../iotdb/db/query/control/QueryTimeManager.java | 6 +- .../iotdb/db/query/control/SessionManager.java | 191 +- .../db/query/control/SessionTimeoutManager.java | 2 +- .../db/query/dataset/AlignByDeviceDataSet.java | 10 +- .../db/query/dataset/NonAlignEngineDataSet.java | 2 +- .../dataset/RawQueryDataSetWithoutValueFilter.java | 61 +- .../iotdb/db/query/dataset/ShowDevicesDataSet.java | 8 +- .../db/query/dataset/ShowTimeseriesDataSet.java | 18 +- .../db/query/dataset/UDTFAlignByTimeDataSet.java | 21 +- .../dataset/groupby/AlignedGroupByExecutor.java | 37 - .../dataset/groupby/GroupByEngineDataSet.java | 239 - .../db/query/dataset/groupby/GroupByExecutor.java | 40 - .../query/dataset/groupby/GroupByFillDataSet.java | 2 +- .../query/dataset/groupby/GroupByLevelDataSet.java | 2 +- .../query/dataset/groupby/GroupByTimeDataSet.java | 177 + .../dataset/groupby/GroupByTimeEngineDataSet.java | 91 + .../groupby/GroupByWithValueFilterDataSet.java | 98 +- .../groupby/GroupByWithoutValueFilterDataSet.java | 115 +- .../groupby/LocalAlignedGroupByExecutor.java | 364 - .../dataset/groupby/LocalGroupByExecutor.java | 365 - .../db/query/executor/AggregationExecutor.java | 22 +- .../iotdb/db/query/executor/FillQueryExecutor.java | 10 +- .../iotdb/db/query/executor/LastQueryExecutor.java | 247 +- .../iotdb/db/query/executor/QueryRouter.java | 10 +- .../db/query/executor/RawDataQueryExecutor.java | 20 +- .../apache/iotdb/db/query/executor/fill/IFill.java | 13 +- .../executor/groupby/AlignedGroupByExecutor.java | 37 + .../db/query/executor/groupby/GroupByExecutor.java | 40 + .../groupby/SlidingWindowGroupByExecutor.java | 66 + .../SlidingWindowGroupByExecutorFactory.java | 117 + .../EmptyQueueSlidingWindowGroupByExecutor.java | 51 + .../groupby/impl/LocalAlignedGroupByExecutor.java | 365 + .../groupby/impl/LocalGroupByExecutor.java | 366 + ...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 + .../NormalQueueSlidingWindowGroupByExecutor.java | 61 + .../SmoothQueueSlidingWindowGroupByExecutor.java | 55 + .../iotdb/db/query/expression/Expression.java | 24 +- .../iotdb/db/query/expression/ExpressionType.java | 115 + .../iotdb/db/query/expression/ResultColumn.java | 17 + .../expression/binary/AdditionExpression.java | 19 + .../query/expression/binary/BinaryExpression.java | 72 +- .../expression/binary/DivisionExpression.java | 19 + .../query/expression/binary/EqualToExpression.java | 61 + .../expression/binary/GreaterEqualExpression.java | 63 + .../expression/binary/GreaterThanExpression.java | 62 + .../expression/binary/LessEqualExpression.java | 62 + .../expression/binary/LessThanExpression.java | 62 + .../expression/binary/LogicAndExpression.java | 61 + .../query/expression/binary/LogicOrExpression.java | 61 + .../query/expression/binary/ModuloExpression.java | 19 + .../binary/MultiplicationExpression.java | 19 + .../expression/binary/NonEqualExpression.java | 62 + .../expression/binary/SubtractionExpression.java | 19 + .../db/query/expression/unary/ConstantOperand.java | 40 +- .../query/expression/unary/FunctionExpression.java | 90 +- .../query/expression/unary/LogicNotExpression.java | 197 + .../query/expression/unary/NegationExpression.java | 48 +- .../query/expression/unary/TimeSeriesOperand.java | 45 +- .../db/query/factory/AggregateResultFactory.java | 2 + .../iotdb/db/query/pool/QueryTaskManager.java | 4 +- .../db/query/pool/RawQueryReadTaskPoolManager.java | 4 +- .../db/query/reader/chunk/ChunkReaderWrap.java | 3 +- .../reader/chunk/DiskChunkReaderByTimestamp.java | 8 +- .../query/reader/chunk/MemAlignedPageReader.java | 40 + .../iotdb/db/query/reader/chunk/MemPageReader.java | 93 + .../query/reader/series/AlignedSeriesReader.java | 2 +- .../query/reader/series/SeriesAggregateReader.java | 2 +- .../reader/series/SeriesRawDataBatchReader.java | 2 +- .../iotdb/db/query/reader/series/SeriesReader.java | 53 +- .../reader/series/SeriesReaderByTimestamp.java | 2 +- .../query/timegenerator/ServerTimeGenerator.java | 10 +- .../transformer/ArithmeticAdditionTransformer.java | 2 +- .../transformer/ArithmeticBinaryTransformer.java | 98 +- .../transformer/ArithmeticDivisionTransformer.java | 2 +- .../transformer/ArithmeticModuloTransformer.java | 2 +- .../ArithmeticMultiplicationTransformer.java | 2 +- .../ArithmeticSubtractionTransformer.java | 2 +- .../udf/core/transformer/BinaryTransformer.java | 182 + .../core/transformer/CompareBinaryTransformer.java | 41 + .../transformer/CompareEqualToTransformer.java | 40 + .../CompareGreaterEqualTransformer.java | 35 + .../transformer/CompareGreaterThanTransformer.java | 35 + .../transformer/CompareLessEqualTransformer.java | 35 + .../transformer/CompareLessThanTransformer.java | 35 + .../transformer/CompareNonEqualTransformer.java | 40 + .../udf/core/transformer/LogicAndTransformer.java | 34 + .../core/transformer/LogicBinaryTransformer.java | 40 + .../udf/core/transformer/LogicNotTransformer.java | 66 + .../udf/core/transformer/LogicOrTransformer.java | 34 + .../row/SerializableRowRecordList.java | 2 +- .../datastructure/tv/SerializableBinaryTVList.java | 2 +- .../tv/SerializableBooleanTVList.java | 2 +- .../datastructure/tv/SerializableDoubleTVList.java | 2 +- .../datastructure/tv/SerializableFloatTVList.java | 2 +- .../datastructure/tv/SerializableIntTVList.java | 2 +- .../datastructure/tv/SerializableLongTVList.java | 2 +- .../udf/service/TemporaryQueryDataFileService.java | 6 +- .../query/udf/service/UDFClassLoaderManager.java | 6 +- .../query/udf/service/UDFRegistrationService.java | 8 +- .../apache/iotdb/db/rescon/MemTableManager.java | 14 +- .../org/apache/iotdb/db/rescon/SystemInfo.java | 12 +- .../iotdb/db/rescon/TsFileResourceManager.java | 2 +- .../java/org/apache/iotdb/db/service/DataNode.java | 224 + .../org/apache/iotdb/db/service/DataNodeMBean.java | 21 + .../iotdb/db/service/DataNodeManagementServer.java | 102 + .../db/service/DataNodeManagementServerMBean.java | 22 + .../db/service/DataNodeServerCommandLine.java | 84 + .../java/org/apache/iotdb/db/service/IService.java | 49 - .../iotdb/db/service/InfluxDBRPCService.java | 9 +- .../apache/iotdb/db/service/InternalService.java | 56 + .../iotdb/db/service/InternalServiceImpl.java | 144 + .../java/org/apache/iotdb/db/service/IoTDB.java | 36 +- .../org/apache/iotdb/db/service/IoTDBMBean.java | 4 +- .../apache/iotdb/db/service/IoTDBShutdownHook.java | 6 + .../org/apache/iotdb/db/service/JMXService.java | 101 - .../org/apache/iotdb/db/service/MQTTService.java | 2 + .../org/apache/iotdb/db/service/RPCService.java | 9 +- .../apache/iotdb/db/service/RPCServiceMBean.java | 2 +- .../apache/iotdb/db/service/RegisterManager.java | 85 - .../org/apache/iotdb/db/service/ServiceType.java | 90 - .../org/apache/iotdb/db/service/SettleService.java | 6 +- .../org/apache/iotdb/db/service/StartupCheck.java | 28 - .../org/apache/iotdb/db/service/StartupChecks.java | 78 - .../org/apache/iotdb/db/service/StaticResps.java | 6 +- .../org/apache/iotdb/db/service/UpgradeSevice.java | 4 +- .../db/service/basic/BasicOpenSessionResp.java | 2 +- .../db/service/basic/QueryFrequencyRecorder.java | 2 +- .../iotdb/db/service/basic/ServiceProvider.java | 180 +- .../apache/iotdb/db/service/metrics/Metric.java | 3 + .../iotdb/db/service/metrics/MetricsService.java | 47 +- .../db/service/metrics/MetricsServiceMBean.java | 2 +- .../iotdb/db/service/thrift/ThriftService.java | 173 - .../db/service/thrift/ThriftServiceThread.java | 321 - .../handler/DataNodeManagementServiceHandler.java | 58 + .../thrift/impl/DataNodeManagementServiceImpl.java | 56 + .../service/thrift/impl/InfluxDBServiceImpl.java | 32 +- .../db/service/thrift/impl/TSServiceImpl.java | 490 +- .../iotdb/db/sync/conf/SyncSenderDescriptor.java | 2 +- .../iotdb/db/sync/receiver/SyncServerManager.java | 10 +- .../db/sync/receiver/SyncServerManagerMBean.java | 2 +- .../db/sync/receiver/load/FileLoaderManager.java | 4 +- .../db/sync/receiver/transfer/SyncServiceImpl.java | 4 +- .../db/sync/sender/manage/ISyncFileManager.java | 4 +- .../db/sync/sender/manage/SyncFileManager.java | 16 +- .../iotdb/db/sync/sender/transfer/SyncClient.java | 12 +- .../apache/iotdb/db/tools/TsFileRewriteTool.java | 3 +- .../org/apache/iotdb/db/tools/TsFileSplitTool.java | 5 +- .../java/org/apache/iotdb/db/tools/WalChecker.java | 81 +- .../db/tools/dataregion/DeviceMappingViewer.java | 63 + .../db/tools/settle/TsFileAndModSettleTool.java | 9 +- .../db/tools/virtualsg/DeviceMappingViewer.java | 63 - .../java/org/apache/iotdb/db/utils/AuthUtils.java | 4 +- .../org/apache/iotdb/db/utils/CommonUtils.java | 70 +- .../org/apache/iotdb/db/utils/DataTypeUtils.java | 2 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 31 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 21 +- .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 16 +- .../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 + .../java/org/apache/iotdb/db/utils/MathUtils.java | 51 + .../java/org/apache/iotdb/db/utils/MemUtils.java | 56 +- .../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 5 +- .../apache/iotdb/db/utils/QueryDataSetUtils.java | 289 +- .../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +- .../org/apache/iotdb/db/utils/SchemaUtils.java | 9 +- .../org/apache/iotdb/db/utils/SerializedSize.java | 29 + .../org/apache/iotdb/db/utils/StatusUtils.java | 46 - .../java/org/apache/iotdb/db/utils/TestOnly.java | 34 - .../org/apache/iotdb/db/utils/ThreadUtils.java | 2 +- .../org/apache/iotdb/db/utils/UpgradeUtils.java | 3 +- .../db/utils/datastructure/AlignedTVList.java | 204 +- .../iotdb/db/utils/datastructure/BinaryTVList.java | 37 + .../db/utils/datastructure/BooleanTVList.java | 33 + .../iotdb/db/utils/datastructure/DoubleTVList.java | 32 + .../iotdb/db/utils/datastructure/FloatTVList.java | 32 + .../iotdb/db/utils/datastructure/IntTVList.java | 32 + .../iotdb/db/utils/datastructure/LongTVList.java | 32 + .../iotdb/db/utils/datastructure/TVList.java | 30 +- .../iotdb/db/utils/datastructure/TimeSelector.java | 18 + .../org/apache/iotdb/db/utils/stats/CpuTimer.java | 156 + .../timerangeiterator/AggrWindowIterator.java | 149 + .../timerangeiterator/ITimeRangeIterator.java | 37 + .../timerangeiterator/PreAggrWindowIterator.java | 142 + .../PreAggrWindowWithNaturalMonthIterator.java | 109 + .../TimeRangeIteratorFactory.java | 69 + .../windowing/runtime/WindowEvaluationTask.java | 2 +- .../runtime/WindowEvaluationTaskPoolManager.java | 6 +- .../utils/windowing/window/EvictableBatchList.java | 2 +- .../iotdb/db/utils/writelog/BatchLogReader.java | 83 + .../apache/iotdb/db/utils/writelog/ILogReader.java | 50 + .../apache/iotdb/db/utils/writelog/ILogWriter.java | 50 + .../apache/iotdb/db/utils/writelog/LogWriter.java | 133 + .../db/utils/writelog/MultiFileLogReader.java | 76 + .../db/utils/writelog/SingleFileLogReader.java | 166 + .../java/org/apache/iotdb/db/wal/WALManager.java | 226 + .../iotdb/db/wal/buffer/AbstractWALBuffer.java | 76 + .../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 40 + .../iotdb/db/wal/buffer/IWALByteBufferView.java | 52 + .../apache/iotdb/db/wal/buffer/SignalWALEntry.java | 51 + .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 454 + .../org/apache/iotdb/db/wal/buffer/WALEntry.java | 219 + .../apache/iotdb/db/wal/buffer/WALEntryType.java | 55 + .../apache/iotdb/db/wal/buffer/WALEntryValue.java | 30 + .../apache/iotdb/db/wal/checkpoint/Checkpoint.java | 102 + .../iotdb/db/wal/checkpoint/CheckpointManager.java | 257 + .../iotdb/db/wal/checkpoint/CheckpointType.java | 49 + .../iotdb/db/wal/checkpoint/MemTableInfo.java | 113 + .../iotdb/db/wal/exception/WALException.java | 38 + .../db/wal/exception/WALNodeClosedException.java | 25 + .../db/wal/exception/WALRecoverException.java | 29 + .../apache/iotdb/db/wal/io/CheckpointReader.java | 63 + .../apache/iotdb/db/wal/io/CheckpointWriter.java | 61 + .../org/apache/iotdb/db/wal/io/ILogWriter.java | 61 + .../java/org/apache/iotdb/db/wal/io/LogWriter.java | 96 + .../java/org/apache/iotdb/db/wal/io/WALReader.java | 114 + .../java/org/apache/iotdb/db/wal/io/WALWriter.java | 60 + .../org/apache/iotdb/db/wal/node/IWALNode.java | 52 + .../org/apache/iotdb/db/wal/node/WALFakeNode.java | 118 + .../java/org/apache/iotdb/db/wal/node/WALNode.java | 380 + .../db/wal/recover/CheckpointRecoverUtils.java | 78 + .../iotdb/db/wal/recover/WALNodeRecoverTask.java | 151 + .../iotdb/db/wal/recover/WALRecoverManager.java | 172 + .../file/AbstractTsFileRecoverPerformer.java | 126 + .../recover/file/SealedTsFileRecoverPerformer.java | 54 + .../db/wal/recover/file/TsFilePlanRedoer.java | 159 + .../file/UnsealedTsFileRecoverPerformer.java | 271 + .../org/apache/iotdb/db/wal/utils/WALMode.java | 35 + .../apache/iotdb/db/wal/utils/WALWriteUtils.java | 134 + .../wal/utils/listener/AbstractResultListener.java | 87 + .../db/wal/utils/listener/WALFlushListener.java | 26 + .../db/wal/utils/listener/WALRecoverListener.java | 35 + .../apache/iotdb/db/writelog/WALFlushListener.java | 50 - .../iotdb/db/writelog/io/BatchLogReader.java | 83 - .../apache/iotdb/db/writelog/io/ILogReader.java | 50 - .../apache/iotdb/db/writelog/io/ILogWriter.java | 50 - .../org/apache/iotdb/db/writelog/io/LogWriter.java | 133 - .../iotdb/db/writelog/io/MultiFileLogReader.java | 76 - .../iotdb/db/writelog/io/SingleFileLogReader.java | 161 - .../writelog/manager/MultiFileLogNodeManager.java | 206 - .../db/writelog/manager/WriteLogNodeManager.java | 49 - .../db/writelog/node/ExclusiveWriteLogNode.java | 389 - .../iotdb/db/writelog/node/WriteLogNode.java | 92 - .../iotdb/db/writelog/recover/LogReplayer.java | 242 - .../writelog/recover/TsFileRecoverPerformer.java | 316 - .../org.apache.iotdb.metrics.reporter.Reporter | 19 - .../IoTDBDefaultThreadExceptionHandlerTest.java | 80 - .../db/concurrent/IoTDBThreadPoolFactoryTest.java | 218 - .../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 2 + .../strategy/DirectoryStrategyTest.java | 24 +- .../iotdb/db/engine/MetadataManagerHelper.java | 48 +- .../iotdb/db/engine/cache/ChunkCacheTest.java | 15 +- .../engine/compaction/AbstractCompactionTest.java | 13 +- .../engine/compaction/CompactionSchedulerTest.java | 65 +- .../compaction/CompactionTaskComparatorTest.java | 60 +- .../compaction/CompactionTaskManagerTest.java | 102 +- .../db/engine/compaction/CompactionUtilsTest.java | 3518 ------- .../ReadPointCompactionPerformerTest.java | 3826 +++++++ .../compaction/TestUtilsForAlignedSeries.java | 6 +- .../db/engine/compaction/TsFileIdentifierUT.java | 17 +- .../cross/CrossSpaceCompactionExceptionTest.java | 54 +- .../compaction/cross/CrossSpaceCompactionTest.java | 99 +- .../db/engine/compaction/cross/MergeTest.java | 17 +- .../engine/compaction/cross/MergeUpgradeTest.java | 8 +- .../cross/RewriteCompactionFileSelectorTest.java | 106 +- .../RewriteCrossSpaceCompactionRecoverTest.java | 101 +- .../cross/RewriteCrossSpaceCompactionTest.java | 58 +- .../inner/AbstractInnerSpaceCompactionTest.java | 17 +- .../compaction/inner/InnerCompactionLogTest.java | 2 +- .../inner/InnerCompactionMoreDataTest.java | 15 +- .../inner/InnerCompactionSchedulerTest.java | 47 +- .../compaction/inner/InnerCompactionTest.java | 23 +- .../compaction/inner/InnerSeqCompactionTest.java | 48 +- .../inner/InnerSpaceCompactionExceptionTest.java | 106 +- .../InnerSpaceCompactionUtilsAlignedTest.java | 534 - .../InnerSpaceCompactionUtilsNoAlignedTest.java | 837 -- .../inner/InnerSpaceCompactionUtilsOldTest.java | 128 - .../compaction/inner/InnerUnseqCompactionTest.java | 22 +- .../ReadChunkCompactionPerformerAlignedTest.java | 534 + .../ReadChunkCompactionPerformerNoAlignedTest.java | 918 ++ .../inner/ReadChunkCompactionPerformerOldTest.java | 133 + .../SizeTieredCompactionRecoverTest.java | 200 +- .../inner/sizetiered/SizeTieredCompactionTest.java | 23 +- ...eCrossSpaceCompactionRecoverCompatibleTest.java | 23 +- .../SizeTieredCompactionRecoverCompatibleTest.java | 172 +- .../recover/SizeTieredCompactionRecoverTest.java | 184 +- .../task/FakedCrossSpaceCompactionTask.java | 62 - .../task/FakedCrossSpaceCompactionTaskFactory.java | 47 - .../task/FakedInnerSpaceCompactionTask.java | 97 - .../task/FakedInnerSpaceCompactionTaskFactory.java | 50 - .../compaction/utils/CompactionClearUtils.java | 4 +- .../compaction/utils/CompactionConfigRestorer.java | 15 +- .../utils/CompactionFileGeneratorUtils.java | 2 +- .../db/engine/memtable/MemTableTestUtils.java | 2 - .../db/engine/memtable/PrimitiveMemTableTest.java | 32 +- .../engine/modification/DeletionFileNodeTest.java | 34 +- .../db/engine/modification/DeletionQueryTest.java | 4 +- .../engine/storagegroup/FakedTsFileResource.java | 20 +- .../storagegroup/FileNodeManagerBenchmark.java | 8 +- .../storagegroup/StorageGroupProcessorTest.java | 131 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 78 +- .../db/engine/storagegroup/TsFileManagerTest.java | 2 +- .../engine/storagegroup/TsFileProcessorTest.java | 4 +- .../dataregion/HashVirtualPartitionerTest.java | 63 + .../virtualSg/HashVirtualPartitionerTest.java | 63 - .../iotdb/db/metadata/MManagerAdvancedTest.java | 228 - .../iotdb/db/metadata/MManagerBasicTest.java | 2492 ----- .../iotdb/db/metadata/MManagerImproveTest.java | 193 - .../org/apache/iotdb/db/metadata/MTreeTest.java | 1060 -- .../iotdb/db/metadata/SchemaAdvancedTest.java | 228 + .../apache/iotdb/db/metadata/SchemaBasicTest.java | 2703 +++++ .../iotdb/db/metadata/SchemaImproveTest.java | 188 + .../org/apache/iotdb/db/metadata/TemplateTest.java | 135 +- .../db/metadata/idtable/IDTableFlushTimeTest.java | 16 +- .../iotdb/db/metadata/idtable/IDTableTest.java | 74 +- .../db/metadata/idtable/InsertWithIDTableTest.java | 25 +- .../iotdb/db/metadata/mlog/MLogUpgraderTest.java | 176 - .../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 292 + .../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 830 ++ .../mtree/disk/CachedMNodeContainerTest.java | 51 + .../db/metadata/mtree/disk/MemManagerTest.java | 112 + .../mtree/multimode/MTreeDiskModeTest.java | 42 + .../mtree/multimode/MTreeFullMemoryTest.java | 28 + .../mtree/multimode/MTreeMemoryModeTest.java | 35 + .../mtree/multimode/MTreeNonMemoryTest.java | 28 + .../mtree/multimode/MTreePartialMemoryTest.java | 28 + .../metadata/mtree/schemafile/RecordUtilTests.java | 78 + .../metadata/mtree/schemafile/SchemaFileTest.java | 787 ++ .../metadata/mtree/schemafile/SchemaPageTest.java | 130 + .../db/metadata/mtree/schemafile/SegmentTest.java | 148 + .../db/metadata/multimode/SchemaDiskModeTest.java | 42 + .../metadata/multimode/SchemaFullMemoryTest.java | 29 + .../metadata/multimode/SchemaMemoryModeTest.java | 35 + .../db/metadata/multimode/SchemaNonMemoryTest.java | 29 + .../multimode/SchemaPartialMemoryTest.java | 28 + .../schemaregion/rocksdb/MRocksDBBenchmark.java | 98 + .../schemaregion/rocksdb/MRocksDBUnitTest.java | 238 + .../rocksdb/RSchemaReadWriteHandlerTest.java | 77 + .../rocksdb/RSchemaRegionAdvancedTest.java | 167 + .../rocksdb/RocksDBBenchmarkEngine.java | 153 + .../schemaregion/rocksdb/RocksDBBenchmarkTask.java | 109 + .../schemaregion/rocksdb/RocksDBTestUtils.java | 72 + .../db/metadata/upgrade/MetadataUpgradeTest.java | 306 + .../apache/iotdb/db/mpp/buffer/SinkHandleTest.java | 460 + .../iotdb/db/mpp/buffer/SourceHandleTest.java | 588 ++ .../java/org/apache/iotdb/db/mpp/buffer/Utils.java | 106 + .../iotdb/db/mpp/common/PathPatternTreeTest.java | 174 + .../apache/iotdb/db/mpp/common/SchemaTreeTest.java | 273 + .../iotdb/db/mpp/execution/DataDriverTest.java | 213 + .../db/mpp/execution/QueryStateMachineTest.java | 142 + .../apache/iotdb/db/mpp/memory/MemoryPoolTest.java | 250 + .../iotdb/db/mpp/operator/LimitOperatorTest.java | 174 + .../db/mpp/operator/SeriesScanOperatorTest.java | 128 + .../db/mpp/operator/TimeJoinOperatorTest.java | 160 + .../db/mpp/schedule/DefaultTaskSchedulerTest.java | 398 + .../schedule/FragmentInstanceSchedulerTest.java | 148 + .../FragmentInstanceTimeoutSentinelTest.java | 275 + .../db/mpp/schedule/queue/L1PriorityQueueTest.java | 160 + .../db/mpp/schedule/queue/L2PriorityQueueTest.java | 169 + .../iotdb/db/mpp/schedule/queue/QueueElement.java | 80 + .../iotdb/db/mpp/sql/analyze/AnalyzerTest.java | 58 + .../iotdb/db/mpp/sql/parser/ASTVisitorTest.java | 41 + .../db/mpp/sql/parser/StatementGeneratorTest.java | 76 + .../db/mpp/sql/plan/DistributionPlannerTest.java | 270 + .../db/mpp/sql/plan/FragmentInstanceIdTest.java | 38 + .../db/mpp/sql/plan/FragmentInstanceSerdeTest.java | 147 + .../iotdb/db/mpp/sql/plan/LogicalPlanPrinter.java | 219 + .../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 794 ++ .../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 567 + .../iotdb/db/mpp/sql/plan/QueryPlannerTest.java | 67 + .../sql/plan/node/PlanNodeDeserializeHelper.java | 37 + .../metadata/read/ShowDevicesNodeSerdeTest.java | 42 + .../plan/node/process/AggregateNodeSerdeTest.java | 58 + .../node/process/DeviceMergeNodeSerdeTest.java | 81 + .../plan/node/process/ExchangeNodeSerdeTest.java | 101 + .../sql/plan/node/process/FillNodeSerdeTest.java | 85 + .../sql/plan/node/process/FilterNodeSerdeTest.java | 97 + .../plan/node/process/FilterNullNodeSerdeTest.java | 102 + .../node/process/GroupByLevelNodeSerdeTest.java | 117 + .../sql/plan/node/process/LimitNodeSerdeTest.java | 119 + .../sql/plan/node/process/OffsetNodeSerdeTest.java | 186 + .../sql/plan/node/process/SortNodeSerdeTest.java | 130 + .../plan/node/process/TimeJoinNodeSerdeTest.java | 135 + .../plan/node/sink/FragmentSinkNodeSerdeTest.java | 53 + .../source/SeriesAggregateScanNodeSerdeTest.java | 69 + .../plan/node/source/SeriesScanNodeSerdeTest.java | 55 + .../db/protocol/mqtt/PayloadFormatManagerTest.java | 7 + .../iotdb/db/protocol/rest/IoTDBRestServiceIT.java | 2 +- .../java/org/apache/iotdb/db/qp/PlannerTest.java | 38 +- .../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 6 +- .../iotdb/db/qp/physical/ConcatOptimizerTest.java | 18 +- .../iotdb/db/qp/physical/InsertRowPlanTest.java | 12 +- .../db/qp/physical/InsertTabletMultiPlanTest.java | 19 +- .../iotdb/db/qp/physical/InsertTabletPlanTest.java | 10 +- .../db/qp/physical/PhysicalPlanSerializeTest.java | 2 + .../iotdb/db/qp/physical/PhysicalPlanTest.java | 14 +- .../iotdb/db/qp/physical/SerializationTest.java | 14 +- .../iotdb/db/qp/physical/SerializedSizeTest.java | 130 + .../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 43 + .../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 2 +- .../dataset/EngineDataSetWithValueFilterTest.java | 2 +- .../query/dataset/UDTFAlignByTimeDataSetTest.java | 14 +- .../query/dataset/groupby/GroupByDataSetTest.java | 226 + .../dataset/groupby/GroupByEngineDataSetTest.java | 504 - .../dataset/groupby/GroupByFillDataSetTest.java | 2 +- .../dataset/groupby/GroupByLevelDataSetTest.java | 2 +- .../dataset/groupby/GroupByTimeDataSetTest.java | 636 +- .../reader/series/SeriesAggregateReaderTest.java | 3 +- .../reader/series/SeriesReaderByTimestampTest.java | 3 +- .../db/query/reader/series/SeriesReaderTest.java | 3 +- .../query/reader/series/SeriesReaderTestUtil.java | 42 +- .../iotdb/db/rescon/ResourceManagerTest.java | 27 +- .../iotdb/db/service/InternalServiceImplTest.java | 138 + .../db/sync/receiver/load/FileLoaderTest.java | 50 +- .../recover/SyncReceiverLogAnalyzerTest.java | 20 +- .../db/sync/sender/manage/SyncFileManagerTest.java | 4 +- .../sender/recover/SyncSenderLogAnalyzerTest.java | 6 +- .../sync/sender/recover/SyncSenderLoggerTest.java | 2 +- .../db/sync/sender/transfer/SyncClientTest.java | 2 +- .../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 2 +- .../org/apache/iotdb/db/tools/MLogParserTest.java | 163 +- .../org/apache/iotdb/db/tools/WalCheckerTest.java | 117 +- .../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 8 +- .../iotdb/db/utils/TimeRangeIteratorTest.java | 220 + .../db/utils/datastructure/TimeSelectorTest.java | 22 + .../db/utils/writelog/LogWriterReaderTest.java | 205 + .../db/utils/writelog/MultiFileLogReaderTest.java | 86 + .../org/apache/iotdb/db/wal/DisableWALTest.java | 54 + .../org/apache/iotdb/db/wal/WALManagerTest.java | 107 + .../iotdb/db/wal/buffer/WALBufferCommonTest.java | 158 + .../apache/iotdb/db/wal/buffer/WALBufferTest.java | 38 + .../db/wal/checkpoint/CheckpointManagerTest.java | 154 + .../apache/iotdb/db/wal/io/CheckpointFileTest.java | 133 + .../org/apache/iotdb/db/wal/io/WALFileTest.java | 222 + .../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 65 + .../org/apache/iotdb/db/wal/node/WALNodeTest.java | 262 + .../db/wal/recover/WALRecoverManagerTest.java | 466 + .../file/SealedTsFileRecoverPerformerTest.java | 307 + .../db/wal/recover/file/TsFilePlanRedoerTest.java | 400 + .../file/UnsealedTsFileRecoverPerformerTest.java | 260 + .../db/wal/utils/TsFileUtilsForRecoverTest.java | 39 + .../iotdb/db/wal/utils/WALByteBufferForTest.java | 75 + .../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 220 - .../apache/iotdb/db/writelog/PerformanceTest.java | 219 - .../iotdb/db/writelog/WriteLogNodeManagerTest.java | 185 - .../apache/iotdb/db/writelog/WriteLogNodeTest.java | 451 - .../iotdb/db/writelog/io/LogWriterReaderTest.java | 212 - .../db/writelog/io/MultiFileLogReaderTest.java | 89 - .../db/writelog/recover/DeviceStringTest.java | 132 - .../iotdb/db/writelog/recover/LogReplayerTest.java | 288 - .../recover/RecoverResourceFromReaderTest.java | 231 - .../db/writelog/recover/SeqTsFileRecoverTest.java | 565 - .../writelog/recover/UnseqTsFileRecoverTest.java | 277 - server/src/test/resources/iotdb-engine.properties | 2 + server/src/test/resources/logback-test.xml | 60 + server/src/test/resources/logback.xml | 58 - service-rpc/pom.xml | 2 +- .../apache/iotdb/rpc/BatchExecutionException.java | 2 +- .../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 2 +- .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 3 +- .../org/apache/iotdb/rpc/RedirectException.java | 8 +- .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 4 +- .../iotdb/rpc/StatementExecutionException.java | 2 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 15 +- session/pom.xml | 15 +- .../java/org/apache/iotdb/session/Session.java | 107 +- .../apache/iotdb/session/SessionConnection.java | 4 +- .../org/apache/iotdb/session/pool/SessionPool.java | 197 +- .../apache/iotdb/session/util/SessionUtils.java | 2 +- .../session/IoTDBSessionDisableMemControlIT.java | 203 - .../session/IoTDBSessionVectorABDeviceIT.java | 233 - .../IoTDBSessionVectorAggregationWithUnSeqIT.java | 195 - .../iotdb/session/IoTDBSessionVectorInsertIT.java | 513 - .../apache/iotdb/session/SessionCacheLeaderUT.java | 2 +- .../java/org/apache/iotdb/session/SessionTest.java | 673 -- .../apache/iotdb/session/pool/SessionPoolTest.java | 482 - .../apache/iotdb/session/template/TemplateUT.java | 256 - site/iotdb-doap.rdf | 16 +- site/pom.xml | 2 +- site/src/main/.vuepress/config.js | 18 +- spark-iotdb-connector/pom.xml | 2 +- .../apache/iotdb/spark/db/EnvironmentUtils.java | 20 +- .../org/apache/iotdb/spark/db/IoTDBTest.scala | 3 +- .../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 3 +- .../iotdb/spark/db/unit/DataFrameToolsTest.scala | 4 +- spark-tsfile/pom.xml | 2 +- testcontainer/pom.xml | 2 +- testcontainer/src/tool/parser.py | 4 +- thrift-cluster/pom.xml | 2 +- thrift-cluster/src/main/thrift/cluster.thrift | 5 +- thrift-confignode/pom.xml | 67 + .../src/main/thrift/confignode.thrift | 137 + thrift-influxdb/pom.xml | 2 +- thrift-influxdb/src/main/thrift/influxdb.thrift | 19 + thrift-sync/pom.xml | 2 +- thrift/pom.xml | 2 +- thrift/src/main/thrift/common.thrift | 48 + thrift/src/main/thrift/management.thrift | 91 + thrift/src/main/thrift/mpp.thrift | 137 + thrift/src/main/thrift/rpc.thrift | 94 +- tsfile/README.md | 2 +- tsfile/pom.xml | 46 +- .../iotdb/tsfile/common/conf/TSFileConfig.java | 20 + .../iotdb/tsfile/common/conf/TSFileDescriptor.java | 6 + .../iotdb/tsfile/encoding/decoder/Decoder.java | 11 + .../iotdb/tsfile/encoding/decoder/FreqDecoder.java | 140 + .../tsfile/encoding/decoder/IntZigzagDecoder.java | 94 + .../tsfile/encoding/decoder/LongZigzagDecoder.java | 101 + .../iotdb/tsfile/encoding/encoder/FreqEncoder.java | 313 + .../tsfile/encoding/encoder/IntZigzagEncoder.java | 101 + .../tsfile/encoding/encoder/LongZigzagEncoder.java | 111 + .../tsfile/encoding/encoder/TSEncodingBuilder.java | 87 +- .../tsfile/file/metadata/enums/TSEncoding.java | 8 +- .../read/TsFileAlignedSeriesReaderIterator.java | 10 +- .../org/apache/iotdb/tsfile/read/common/Path.java | 21 + .../iotdb/tsfile/read/common/block/TsBlock.java | 317 + .../tsfile/read/common/block/TsBlockBuilder.java | 295 + .../read/common/block/TsBlockBuilderStatus.java | 75 + .../tsfile/read/common/block/TsBlockMetadata.java | 41 + .../read/common/block/column/BinaryColumn.java | 126 + .../common/block/column/BinaryColumnBuilder.java | 154 + .../read/common/block/column/BooleanColumn.java | 125 + .../common/block/column/BooleanColumnBuilder.java | 156 + .../tsfile/read/common/block/column/Column.java | 100 + .../read/common/block/column/ColumnBuilder.java | 85 + .../common/block/column/ColumnBuilderStatus.java | 91 + .../read/common/block/column/ColumnEncoder.java | 108 + .../common/block/column/ColumnEncoderFactory.java | 40 + .../read/common/block/column/ColumnEncoding.java | 64 + .../read/common/block/column/ColumnUtil.java | 97 + .../read/common/block/column/DoubleColumn.java | 125 + .../common/block/column/DoubleColumnBuilder.java | 156 + .../read/common/block/column/FloatColumn.java | 124 + .../common/block/column/FloatColumnBuilder.java | 156 + .../block/column/Int32ArrayColumnEncoder.java | 90 + .../block/column/Int64ArrayColumnEncoder.java | 90 + .../tsfile/read/common/block/column/IntColumn.java | 124 + .../read/common/block/column/IntColumnBuilder.java | 156 + .../read/common/block/column/LongColumn.java | 124 + .../common/block/column/LongColumnBuilder.java | 156 + .../block/column/RunLengthEncodedColumn.java | 149 + .../read/common/block/column/TimeColumn.java | 112 + .../common/block/column/TimeColumnBuilder.java | 133 + .../read/common/block/column/TsBlockSerde.java | 125 + .../iotdb/tsfile/read/expression/IExpression.java | 3 + .../read/expression/impl/BinaryExpression.java | 55 + .../read/expression/impl/GlobalTimeExpression.java | 33 + .../expression/impl/SingleSeriesExpression.java | 29 + .../iotdb/tsfile/read/filter/basic/Filter.java | 8 + .../tsfile/read/query/dataset/QueryDataSet.java | 53 +- .../iotdb/tsfile/read/reader/IPageReader.java | 3 + .../read/reader/chunk/AlignedChunkReader.java | 30 + .../chunk/AlignedChunkReaderByTimestamp.java | 47 - .../tsfile/read/reader/chunk/ChunkReader.java | 24 + .../read/reader/chunk/ChunkReaderByTimestamp.java | 44 - .../tsfile/read/reader/page/AlignedPageReader.java | 44 + .../iotdb/tsfile/read/reader/page/PageReader.java | 86 + .../reader/series/FileSeriesReaderByTimestamp.java | 13 +- .../apache/iotdb/tsfile/utils/BitConstructor.java | 93 + .../org/apache/iotdb/tsfile/utils/BitReader.java | 70 + .../org/apache/iotdb/tsfile/utils/BloomFilter.java | 7 +- .../apache/iotdb/tsfile/utils/FilePathUtils.java | 2 +- .../iotdb/tsfile/utils/MeasurementGroup.java | 3 +- .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 106 +- .../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 20 + .../write/chunk/AlignedChunkGroupWriterImpl.java | 9 +- .../chunk/NonAlignedChunkGroupWriterImpl.java | 32 +- .../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 12 +- .../apache/iotdb/tsfile/write/record/Tablet.java | 19 +- .../tsfile/write/schema/IMeasurementSchema.java | 2 + .../tsfile/write/schema/MeasurementSchema.java | 18 + .../write/schema/VectorMeasurementSchema.java | 13 + .../write/writer/RestorableTsFileIOWriter.java | 5 + .../iotdb/tsfile/write/writer/TsFileIOWriter.java | 8 +- .../tsfile/common/block/ColumnEncoderTest.java | 144 + .../common/block/Int32ArrayColumnEncoderTest.java | 113 + .../common/block/Int64ArrayColumnEncoderTest.java | 114 + .../tsfile/common/block/TsBlockSerdeTest.java | 97 + .../iotdb/tsfile/common/block/TsBlockTest.java | 317 + .../tsfile/encoding/decoder/FreqDecoderTest.java | 161 + .../encoding/decoder/IntZigzagDecoderTest.java | 99 + .../encoding/decoder/LongZigzagDecoderTest.java | 94 + .../apache/iotdb/tsfile/read/TsFileReaderTest.java | 4 + .../iotdb/tsfile/read/reader/ChunkReaderTest.java | 109 + .../iotdb/tsfile/utils/FilePathUtilsTest.java | 12 +- .../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 12 + .../iotdb/tsfile/write/TsFileReadWriteTest.java | 3 +- .../iotdb/tsfile/write/TsFileWriteApiTest.java | 99 + zeppelin-interpreter/pom.xml | 2 +- .../zeppelin/iotdb/IoTDBInterpreterTest.java | 2 +- 1891 files changed, 170839 insertions(+), 56797 deletions(-)
