You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/04/12 15:34:23 UTC
[iotdb] 01/01: Merge branch 'master' of https://github.com/apache/iotdb into skywalking_eye
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 <hh...@outlook.com>
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(-)