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 b934229ea9037a34d4e3aab684b086efff190e71 Merge: b9d661b095 b090698af2 Author: HTHou <[email protected]> AuthorDate: Wed May 4 16:43:11 2022 +0800 merge .github/workflows/client-cpp.yml | 4 +- .github/workflows/grafana-plugin.yml | 7 +- .github/workflows/influxdb-protocol.yml | 4 +- .github/workflows/main-unix.yml | 3 +- .github/workflows/main-win.yml | 3 +- .github/workflows/sonar-coveralls.yml | 5 +- Jenkinsfile | 2 +- LICENSE | 10 + README.md | 16 +- README_ZH.md | 15 +- .../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 12 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 199 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 39 +- checkstyle.xml | 7 +- .../main/java/org/apache/iotdb/tool/ImportCsv.java | 6 +- client-cpp/pom.xml | 7 +- client-py/SessionAlignedTimeseriesExample.py | 18 + client-py/SessionExample.py | 30 + client-py/iotdb/Session.py | 132 +- client-py/pom.xml | 8 + client-py/tests/tablet_performance_comparison.py | 4 +- client-py/tests/test_one_device.py | 152 + .../org/apache/iotdb/cluster/ClusterIoTDB.java | 1 - .../cluster/client/sync/SyncClientAdaptor.java | 2 +- .../iotdb/cluster/coordinator/Coordinator.java | 12 +- .../cluster/log/applier/AsyncDataLogApplier.java | 4 +- .../iotdb/cluster/log/applier/BaseApplier.java | 4 +- .../iotdb/cluster/log/applier/DataLogApplier.java | 8 +- .../cluster/log/logtypes/PhysicalPlanLog.java | 2 +- .../manage/FilePartitionedSnapshotLogManager.java | 2 +- .../log/manage/MetaSingleSnapshotLogManager.java | 2 +- .../log/manage/PartitionedSnapshotLogManager.java | 4 +- .../iotdb/cluster/log/snapshot/FileSnapshot.java | 6 +- .../cluster/log/snapshot/MetaSimpleSnapshot.java | 6 +- .../iotdb/cluster/metadata/CSchemaProcessor.java | 55 +- .../apache/iotdb/cluster/metadata/MetaPuller.java | 7 +- .../iotdb/cluster/partition/PartitionTable.java | 4 +- .../cluster/query/ClusterDataQueryExecutor.java | 8 +- .../cluster/query/ClusterPhysicalGenerator.java | 4 +- .../iotdb/cluster/query/ClusterPlanExecutor.java | 4 +- .../iotdb/cluster/query/ClusterPlanRouter.java | 9 +- .../apache/iotdb/cluster/query/ClusterPlanner.java | 1 + .../iotdb/cluster/query/LocalQueryExecutor.java | 14 +- .../query/aggregate/ClusterAggregateExecutor.java | 4 +- .../cluster/query/aggregate/ClusterAggregator.java | 2 +- .../cluster/query/fill/ClusterFillExecutor.java | 4 +- .../cluster/query/fill/ClusterPreviousFill.java | 2 +- .../cluster/query/fill/PreviousFillArguments.java | 2 +- .../groupby/ClusterGroupByNoVFilterDataSet.java | 2 +- .../groupby/ClusterGroupByVFilterDataSet.java | 4 +- .../query/groupby/MergeGroupByExecutor.java | 2 +- .../query/last/ClusterLastQueryExecutor.java | 2 +- .../query/manage/ClusterSessionManager.java | 1 + .../cluster/query/reader/ClusterReaderFactory.java | 25 +- .../cluster/query/reader/ClusterTimeGenerator.java | 6 +- .../query/reader/mult/MultDataSourceInfo.java | 2 +- .../iotdb/cluster/server/ClusterRPCService.java | 5 - .../server/clusterinfo/ClusterInfoServer.java | 5 - .../server/handlers/caller/LogCatchUpHandler.java | 4 +- .../handlers/caller/ShowTimeSeriesHandler.java | 4 +- .../cluster/server/member/DataGroupMember.java | 17 +- .../cluster/server/member/MetaGroupMember.java | 10 +- .../iotdb/cluster/server/member/RaftMember.java | 2 +- .../server/raft/DataRaftHeartBeatService.java | 6 - .../iotdb/cluster/server/raft/DataRaftService.java | 6 - .../server/raft/MetaRaftHeartBeatService.java | 6 - .../iotdb/cluster/server/raft/MetaRaftService.java | 6 - .../cluster/server/service/BaseAsyncService.java | 4 +- .../cluster/server/service/DataAsyncService.java | 4 +- .../cluster/server/service/DataSyncService.java | 4 +- .../iotdb/cluster/utils/ClusterQueryUtils.java | 6 +- .../apache/iotdb/cluster/utils/ClusterUtils.java | 4 +- .../apache/iotdb/cluster/utils/StatusUtils.java | 12 +- .../cluster/utils/nodetool/ClusterMonitor.java | 4 +- .../cluster/client/sync/SyncClientAdaptorTest.java | 4 +- .../org/apache/iotdb/cluster/common/IoTDBTest.java | 6 +- .../iotdb/cluster/common/TestAsyncDataClient.java | 2 +- .../iotdb/cluster/common/TestLogApplier.java | 4 +- .../org/apache/iotdb/cluster/common/TestUtils.java | 4 +- .../iotdb/cluster/integration/SingleNodeTest.java | 5 +- .../iotdb/cluster/log/CommitLogCallbackTest.java | 2 +- .../iotdb/cluster/log/CommitLogTaskTest.java | 5 +- .../apache/iotdb/cluster/log/LogParserTest.java | 4 +- .../log/applier/AsyncDataLogApplierTest.java | 4 +- .../cluster/log/applier/DataLogApplierTest.java | 6 +- .../cluster/log/applier/MetaLogApplierTest.java | 4 +- .../cluster/log/logtypes/SerializeLogTest.java | 4 +- .../FilePartitionedSnapshotLogManagerTest.java | 4 +- .../manage/MetaSingleSnapshotLogManagerTest.java | 4 +- .../cluster/log/snapshot/DataSnapshotTest.java | 4 +- .../cluster/log/snapshot/FileSnapshotTest.java | 26 +- .../log/snapshot/MetaSimpleSnapshotTest.java | 4 +- .../log/snapshot/PartitionedSnapshotTest.java | 10 +- .../cluster/log/snapshot/PullSnapshotTaskTest.java | 8 +- .../cluster/partition/SlotPartitionTableTest.java | 6 +- .../apache/iotdb/cluster/query/BaseQueryTest.java | 2 +- .../query/ClusterAggregateExecutorTest.java | 4 +- .../query/ClusterDataQueryExecutorTest.java | 4 +- .../query/ClusterPhysicalGeneratorTest.java | 6 +- .../cluster/query/ClusterPlanExecutorTest.java | 4 +- .../cluster/query/ClusterQueryRouterTest.java | 4 +- .../query/fill/ClusterFillExecutorTest.java | 2 +- .../ClusterGroupByNoVFilterDataSetTest.java | 4 +- .../groupby/ClusterGroupByVFilterDataSetTest.java | 4 +- .../query/groupby/MergeGroupByExecutorTest.java | 4 +- .../query/groupby/RemoteGroupByExecutorTest.java | 4 +- .../query/last/ClusterLastQueryExecutorTest.java | 2 +- .../query/reader/ClusterReaderFactoryTest.java | 4 +- .../query/reader/ClusterTimeGeneratorTest.java | 4 +- .../mult/AssignPathManagedMergeReaderTest.java | 4 +- .../mult/MultSeriesRawDataPointReaderTest.java | 2 +- .../reader/mult/RemoteMultSeriesReaderTest.java | 4 +- .../server/clusterinfo/ClusterInfoServerTest.java | 2 +- .../clusterinfo/ClusterInfoServiceImplTest.java | 4 +- .../handlers/forwarder/ForwardPlanHandlerTest.java | 4 +- .../iotdb/cluster/server/member/BaseMember.java | 4 +- .../cluster/server/member/DataGroupMemberTest.java | 6 +- .../cluster/server/member/MetaGroupMemberTest.java | 11 +- .../iotdb/cluster/utils/SerializeUtilTest.java | 4 +- confignode/pom.xml | 20 - .../resources/conf/iotdb-confignode.properties | 41 +- .../src/assembly/resources/sbin/stop-confignode.sh | 15 +- .../iotdb/confignode/client/AsyncClientPool.java | 105 + .../client/ConfigNodeClientPoolFactory.java | 74 + .../client/handlers/InitRegionHandler.java | 56 + .../iotdb/confignode/conf/ConfigNodeConf.java | 109 +- .../confignode/conf/ConfigNodeDescriptor.java | 42 +- .../consensus/request/ConfigRequest.java | 184 + .../consensus/request/ConfigRequestType.java | 58 + .../consensus/request/auth/AuthorReq.java | 248 + .../request/read/CountStorageGroupReq.java | 86 + .../consensus/request/read/GetDataNodeInfoReq.java | 68 + .../request/read/GetDataPartitionReq.java | 145 + .../request/read/GetOrCreateDataPartitionReq.java | 28 + .../read/GetOrCreateSchemaPartitionReq.java | 28 + .../request/read/GetSchemaPartitionReq.java | 102 + .../consensus/request/read/GetStorageGroupReq.java | 34 + .../request/write/CreateDataPartitionReq.java | 129 + .../consensus/request/write/CreateRegionsReq.java | 80 + .../request/write/CreateSchemaPartitionReq.java | 100 + .../consensus/request/write/DeleteRegionsReq.java | 79 + .../request/write/DeleteStorageGroupReq.java | 69 + .../request/write/RegisterDataNodeReq.java | 69 + .../request/write/SetDataReplicationFactorReq.java | 80 + .../write/SetSchemaReplicationFactorReq.java | 80 + .../request/write/SetStorageGroupReq.java | 71 + .../consensus/request/write/SetTTLReq.java | 79 + .../request/write/SetTimePartitionIntervalReq.java | 80 + .../consensus/response/CountStorageGroupResp.java | 54 + .../response/DataNodeConfigurationDataSet.java | 66 - .../response/DataNodeConfigurationResp.java | 62 + .../consensus/response/DataNodeLocationsResp.java | 56 + .../consensus/response/DataNodesInfoDataSet.java | 72 - .../consensus/response/DataPartitionDataSet.java | 133 - .../consensus/response/DataPartitionResp.java | 62 + .../consensus/response/PermissionInfoDataSet.java | 26 - .../consensus/response/PermissionInfoResp.java | 56 + .../consensus/response/SchemaPartitionDataSet.java | 94 - .../consensus/response/SchemaPartitionResp.java | 57 + .../response/StorageGroupSchemaDataSet.java | 66 - .../consensus/response/StorageGroupSchemaResp.java | 55 + .../statemachine/PartitionRegionStateMachine.java | 49 +- .../physical/UnknownPhysicalPlanTypeException.java | 4 +- .../confignode/manager/ClusterSchemaManager.java | 297 ++ .../iotdb/confignode/manager/ConfigManager.java | 303 +- .../iotdb/confignode/manager/ConsensusManager.java | 48 +- .../iotdb/confignode/manager/DataNodeManager.java | 52 +- .../iotdb/confignode/manager/LoadManager.java | 34 + .../apache/iotdb/confignode/manager/Manager.java | 106 +- .../iotdb/confignode/manager/PartitionManager.java | 191 +- .../confignode/manager/PermissionManager.java | 41 +- .../iotdb/confignode/manager/RegionManager.java | 134 - .../confignode/partition/StorageGroupSchema.java | 112 - .../iotdb/confignode/persistence/AuthorInfo.java | 346 ++ .../persistence/AuthorInfoPersistence.java | 146 - .../confignode/persistence/ClusterSchemaInfo.java | 358 ++ .../iotdb/confignode/persistence/DataNodeInfo.java | 201 + .../persistence/DataNodeInfoPersistence.java | 182 - .../confignode/persistence/PartitionInfo.java | 335 ++ .../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 | 67 +- .../confignode/service/ConfigNodeCommandLine.java | 2 +- .../confignode/service/balancer/LoadBalancer.java | 37 - .../service/executor/ConfigRequestExecutor.java | 138 + .../confignode/service/executor/PlanExecutor.java | 116 - .../service/thrift/ConfigNodeRPCService.java | 89 + .../thrift/ConfigNodeRPCServiceHandler.java | 54 + .../service/thrift/ConfigNodeRPCServiceMBean.java | 22 + .../thrift/ConfigNodeRPCServiceProcessor.java | 313 ++ .../service/thrift/server/ConfigNodeRPCServer.java | 110 - .../thrift/server/ConfigNodeRPCServerMBean.java | 22 - .../server/ConfigNodeRPCServerProcessor.java | 205 - .../thrift/server/ConfigNodeRPCServiceHandler.java | 55 - .../confignode/util/SerializeDeserializeUtil.java | 242 - .../apache/iotdb/confignode/auth/AuthorTest.java | 44 - .../iotdb/confignode/cli/TemporaryClientDemo.java | 76 + .../confignode/consensus/RatisConsensusDemo.java | 151 - .../consensus/request/ConfigRequestSerDeTest.java | 556 +++ .../manager/ConfigManagerManualTest.java | 133 - .../hash/DeviceGroupHashExecutorManualTest.java | 5 +- .../physical/SerializeDeserializeUT.java | 346 -- .../thrift/ConfigNodeRPCServiceProcessorTest.java | 931 ++++ .../server/ConfigNodeRPCServerProcessorTest.java | 424 -- .../utils/ConfigNodeEnvironmentUtils.java | 134 - .../utils/SerializeDeserializeUtilTest.java | 90 - .../confignode1conf/iotdb-confignode.properties | 29 + .../src/test/resources/confignode1conf/logback.xml | 140 + .../confignode2conf/iotdb-confignode.properties | 29 + .../src/test/resources/confignode2conf/logback.xml | 140 + .../confignode3conf/iotdb-confignode.properties | 29 + .../src/test/resources/confignode3conf/logback.xml | 140 + consensus/pom.xml | 13 +- .../apache/iotdb/consensus/ConsensusFactory.java | 8 +- .../org/apache/iotdb/consensus/IConsensus.java | 5 +- .../org/apache/iotdb/consensus/IStateMachine.java | 94 + .../org/apache/iotdb/consensus/common/Peer.java | 8 +- .../iotdb/consensus/common/SnapshotMeta.java | 54 + .../exception/IllegalPeerEndpointException.java | 32 + .../ratis/ApplicationStateMachineProxy.java | 83 +- .../apache/iotdb/consensus/ratis/RatisClient.java | 107 + .../iotdb/consensus/ratis/RatisConsensus.java | 306 +- .../iotdb/consensus/ratis/RequestMessage.java | 7 +- .../iotdb/consensus/ratis/SnapshotStorage.java | 100 + .../org/apache/iotdb/consensus/ratis/Utils.java | 108 +- .../consensus/standalone/StandAloneConsensus.java | 108 +- .../consensus/standalone/StandAloneServerImpl.java | 26 +- .../consensus/statemachine/EmptyStateMachine.java | 43 - .../consensus/statemachine/IStateMachine.java | 40 - .../apache/iotdb/consensus/EmptyStateMachine.java | 63 + .../iotdb/consensus/ratis/RatisConsensusTest.java | 132 +- .../apache/iotdb/consensus/ratis/SnapshotTest.java | 120 + .../apache/iotdb/consensus/ratis/TestUtils.java | 203 + .../iotdb/consensus/standalone/RecoveryTest.java | 94 + .../standalone/StandAloneConsensusTest.java | 68 +- cross-tests/pom.xml | 2 + .../tests/tools/importCsv/AbstractScript.java | 7 +- .../tests/tools/importCsv/ImportCsvTestIT.java | 31 + distribution/pom.xml | 6 + distribution/src/assembly/all.xml | 4 + distribution/src/assembly/server.xml | 4 + docker/src/main/Dockerfile-single-influxdb | 46 + docs/Community/About.md | 79 + docs/Development/ContributeGuide.md | 34 +- docs/UserGuide/API/InfluxDB-Protocol.md | 5 +- .../Administration-Management/Administration.md | 2 +- .../Data-Concept/Data-Model-and-Terminology.md | 35 +- .../Data-Modeling/SchemaRegion-rocksdb.md | 108 + docs/UserGuide/Ecosystem Integration/DBeaver.md | 22 +- .../Ecosystem Integration/Grafana Plugin.md | 141 +- docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +- .../Maintenance-Tools/SchemaFileSketch-Tool.md | 38 + docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 493 +- docs/UserGuide/Operate-Metadata/Node.md | 45 + docs/UserGuide/Operate-Metadata/Storage-Group.md | 60 + docs/UserGuide/Process-Data/Select-Into.md | 6 +- docs/UserGuide/Process-Data/Triggers.md | 11 +- docs/UserGuide/Query-Data/Select-Expression.md | 224 +- docs/UserGuide/Query-Data/Without-Null.md | 8 +- docs/UserGuide/Reference/Syntax-Conventions.md | 453 +- docs/zh/Community/About.md | 66 +- docs/zh/Development/ContributeGuide.md | 17 + docs/zh/UserGuide/API/InfluxDB-Protocol.md | 4 +- .../Administration-Management/Administration.md | 2 +- .../Data-Concept/Data-Model-and-Terminology.md | 30 +- .../Data-Modeling/SchemaRegion-rocksdb.md | 103 + docs/zh/UserGuide/Ecosystem Integration/DBeaver.md | 28 +- .../Ecosystem Integration/Grafana Plugin.md | 143 +- docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 12 +- .../Maintenance-Tools/SchemaFileSketch-Tool.md | 35 + docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 488 +- docs/zh/UserGuide/Operate-Metadata/Node.md | 45 + .../zh/UserGuide/Operate-Metadata/Storage-Group.md | 60 + docs/zh/UserGuide/Process-Data/Select-Into.md | 8 +- docs/zh/UserGuide/Process-Data/Triggers.md | 9 +- docs/zh/UserGuide/Query-Data/Select-Expression.md | 226 +- docs/zh/UserGuide/Query-Data/Without-Null.md | 8 +- docs/zh/UserGuide/Reference/Syntax-Conventions.md | 492 +- .../iotdb/hadoop/tsfile/TSFMRReadExample.java | 5 +- example/rest-client-c-example/main.c | 14 +- .../org/apache/iotdb/DataMigrationExample.java | 2 +- .../org/apache/iotdb/trigger/TriggerExample.java | 2 +- .../Apache IoTDB Dashboard v0.13.1.json | 1527 +++++++ .../Apache IoTDB Dashboard v0.14.0.json | 1527 +++++++ grafana-plugin/.gitignore | 1 + grafana-plugin/Magefile.go | 32 + grafana-plugin/README.md | 38 +- grafana-plugin/backend-compile.sh | 36 + grafana-plugin/go.mod | 23 + grafana-plugin/go.sum | 659 +++ grafana-plugin/package.json | 7 +- grafana-plugin/pkg/main.go | 40 + grafana-plugin/pkg/plugin/plugin.go | 350 ++ grafana-plugin/pom.xml | 21 + grafana-plugin/src/QueryEditor.tsx | 297 +- grafana-plugin/src/componments/AggregateFun.tsx | 44 + grafana-plugin/src/componments/FillValue.tsx | 38 + grafana-plugin/src/componments/GroupBy.tsx | 58 + grafana-plugin/src/componments/SelectValue.tsx | 1 + grafana-plugin/src/componments/TimeSeries.tsx | 82 + grafana-plugin/src/componments/WhereValue.tsx | 1 + grafana-plugin/src/datasource.ts | 158 +- grafana-plugin/src/functions.ts | 3 +- grafana-plugin/src/plugin.json | 3 + grafana-plugin/src/types.ts | 30 +- grafana-plugin/yarn.lock | 4726 ++++++++++---------- .../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 11 +- .../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 8 +- .../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 3 +- .../org/apache/iotdb/hive/TSFHiveInputFormat.java | 6 +- .../org/apache/iotdb/hive/TsFileDeserializer.java | 10 +- .../apache/iotdb/hive/TsFileDeserializerTest.java | 11 +- .../org/apache/iotdb/hive/TsFileSerDeTest.java | 11 +- influxdb-protocol/pom.xml | 40 +- .../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 3 +- .../iotdb/influxdb/protocol/dto/SessionPoint.java | 20 +- .../protocol/impl/IoTDBInfluxDBService.java | 12 +- .../iotdb/influxdb/session/InfluxDBSession.java | 44 +- .../influxdb/integration/IoTDBInfluxDBIT.java | 34 +- .../apache/iotdb/db/integration/IoTDBAliasIT.java | 7 +- .../iotdb/db/integration/IoTDBArithmeticIT.java | 4 +- .../org/apache/iotdb/db/integration/IoTDBAsIT.java | 2 +- .../iotdb/db/integration/IoTDBAuthorizationIT.java | 32 +- .../iotdb/db/integration/IoTDBCompleteIT.java | 6 +- .../db/integration/IoTDBContinuousQueryIT.java | 4 +- .../db/integration/IoTDBCreateTimeseriesIT.java | 18 +- .../apache/iotdb/db/integration/IoTDBDaemonIT.java | 16 +- .../db/integration/IoTDBDeleteStorageGroupIT.java | 23 + .../iotdb/db/integration/IoTDBDeletionIT.java | 16 +- .../db/integration/IoTDBEngineTimeGeneratorIT.java | 4 +- .../iotdb/db/integration/IoTDBExecuteBatchIT.java | 6 +- .../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 4 +- .../db/integration/IoTDBFloatPrecisionIT.java | 2 +- .../org/apache/iotdb/db/integration/IoTDBInIT.java | 7 +- .../iotdb/db/integration/IoTDBInsertNaNIT.java | 2 +- .../iotdb/db/integration/IoTDBInsertNullIT.java | 207 + .../apache/iotdb/db/integration/IoTDBLastIT.java | 2 +- ...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 4 +- .../db/integration/IoTDBLoadExternalTsfileIT.java | 4 +- .../integration/IoTDBManageTsFileResourceIT.java | 4 +- .../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 9 +- .../iotdb/db/integration/IoTDBMetadataFetchIT.java | 46 +- .../iotdb/db/integration/IoTDBNestedQueryIT.java | 56 +- .../db/integration/IoTDBNewTsFileCompactionIT.java | 2 +- .../db/integration/IoTDBPartialInsertionIT.java | 62 + .../iotdb/db/integration/IoTDBQuotedPathIT.java | 24 +- .../db/integration/IoTDBRecoverUnclosedIT.java | 17 +- .../db/integration/IoTDBRemovePartitionIT.java | 4 +- .../db/integration/IoTDBResultMetadataIT.java | 13 +- .../db/integration/IoTDBSchemaTemplateIT.java | 11 +- .../iotdb/db/integration/IoTDBSelectIntoIT.java | 10 +- .../iotdb/db/integration/IoTDBSelectSchemaIT.java | 133 + .../db/integration/IoTDBSequenceDataQueryIT.java | 4 +- .../iotdb/db/integration/IoTDBSeriesReaderIT.java | 4 +- .../iotdb/db/integration/IoTDBSimpleQueryIT.java | 33 +- .../integration/IoTDBSortedShowTimeseriesIT.java | 38 +- .../db/integration/IoTDBSyntaxConventionIT.java | 468 -- .../IoTDBSyntaxConventionIdentifierIT.java | 838 ++++ .../IoTDBSyntaxConventionStringLiteralIT.java | 764 ++++ .../iotdb/db/integration/IoTDBTagAlterIT.java | 46 +- .../apache/iotdb/db/integration/IoTDBTagIT.java | 220 +- .../db/integration/IoTDBTriggerExecutionIT.java | 192 +- .../db/integration/IoTDBTriggerManagementIT.java | 2 +- .../iotdb/db/integration/IoTDBUDFManagementIT.java | 2 +- .../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 328 ++ .../aggregation/IoTDBAggregationIT.java | 5 + ...ggregationWithoutValueFilterWithDeletionIT.java | 11 +- .../db/integration/aligned/IoTDBDeletionIT.java | 16 +- ...upBySlidingWindowQueryWithoutValueFilterIT.java | 9 +- .../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 4 +- .../groupby/IOTDBGroupByInnerIntervalIT.java | 13 +- .../db/integration/groupby/IoTDBGroupByFillIT.java | 11 +- .../sync/IoTDBSyncReceiverCollectorIT.java | 513 +++ .../db/integration/sync/IoTDBSyncReceiverIT.java | 360 ++ .../sync/IoTDBSyncReceiverLoaderIT.java | 212 + .../db/integration/sync/IoTDBSyncSenderIT.java | 621 +++ .../iotdb/db/integration/sync/SyncTestUtil.java | 238 + .../db/integration/sync/TransportClientMock.java | 75 + .../db/integration/sync/TransportHandlerMock.java | 61 + .../versionadaption/IoTDBDDLVersionAdaptionIT.java | 6 +- .../IoTDBSyntaxConventionVersionAdaptionIT.java | 100 - .../IoTDBWithoutNullAllFilterIT.java | 16 +- .../IoTDBWithoutNullAnyFilterIT.java | 8 +- .../session/IoTDBSessionDisableMemControlIT.java | 8 +- .../apache/iotdb/session/IoTDBSessionSimpleIT.java | 8 +- .../session/IoTDBSessionSyntaxConventionIT.java | 39 +- .../iotdb/session/IoTDBSessionVectorInsertIT.java | 4 +- .../apache/iotdb/session/template/TemplateUT.java | 2 +- .../src/test/resources/iotdb-engine.properties | 3 +- integration/src/test/resources/logback-test.xml | 2 +- .../iotdb/jdbc/IoTDBPreparedStatementTest.java | 3 +- metrics/dropwizard-metrics/pom.xml | 2 +- .../dropwizard/DropwizardMetricManager.java | 25 +- .../iotdb/metrics/dropwizard/MetricName.java | 6 +- .../reporter/DropwizardMetricsExporter.java | 10 +- .../metrics/dropwizard/reporter/IoTDBReporter.java | 16 +- .../dropwizard/DropwizardMetricManagerTest.java | 12 +- .../org/apache/iotdb/metrics/MetricManager.java | 6 +- .../apache/iotdb/metrics/config/MetricConfig.java | 20 +- .../micrometer/MicrometerMetricManager.java | 21 +- node-commons/pom.xml | 36 +- .../commons/client/AsyncBaseClientFactory.java | 47 + .../iotdb/commons/client/BaseClientFactory.java | 41 + .../commons/client/ClientFactoryProperty.java | 95 + .../apache/iotdb/commons/client/ClientManager.java | 97 + .../iotdb/commons/client/ClientPoolProperty.java | 84 + .../iotdb/commons/client/IClientManager.java | 43 + .../iotdb/commons/client/IClientPoolFactory.java | 28 + .../async/AsyncConfigNodeIServiceClient.java | 145 + .../async/AsyncDataNodeDataBlockServiceClient.java | 146 + .../async/AsyncDataNodeInternalServiceClient.java | 157 + .../client/sync/SyncConfigNodeIServiceClient.java | 126 + .../sync/SyncDataNodeDataBlockServiceClient.java | 127 + .../sync/SyncDataNodeInternalServiceClient.java | 138 + .../commons/client/sync/SyncThriftClient.java | 25 + .../sync/SyncThriftClientWithErrorHandler.java | 64 + .../iotdb/commons/cluster/DataNodeLocation.java | 77 - .../org/apache/iotdb/commons/cluster/Endpoint.java | 92 - .../iotdb/commons/concurrent/ThreadName.java | 19 +- .../apache/iotdb/commons/conf/IoTDBConstant.java | 15 + .../iotdb/commons/consensus/ConsensusGroupId.java | 83 +- .../iotdb/commons/consensus/DataRegionId.java | 52 +- .../apache/iotdb/commons/consensus/GroupType.java | 27 - .../iotdb/commons/consensus/PartitionRegionId.java | 52 +- .../iotdb/commons/consensus/SchemaRegionId.java | 52 +- .../commons/exception/IllegalPathException.java | 38 + .../iotdb/commons/exception/MetadataException.java | 62 + .../exception/runtime/ThriftSerDeException.java | 26 + .../iotdb/commons/partition/DataPartition.java | 151 +- .../commons/partition/DataPartitionQueryParam.java | 9 +- .../apache/iotdb/commons/partition/Partition.java | 43 + .../iotdb/commons/partition/PartitionInfo.java | 41 - .../iotdb/commons/partition/RegionReplicaSet.java | 105 - .../iotdb/commons/partition/SchemaPartition.java | 168 +- .../commons/partition/SeriesPartitionSlot.java | 59 - .../iotdb/commons/partition/TimePartitionSlot.java | 64 - .../executor/SeriesPartitionExecutor.java | 23 +- .../partition/executor/hash/APHashExecutor.java | 6 +- .../partition/executor/hash/BKDRHashExecutor.java | 6 +- .../partition/executor/hash/JSHashExecutor.java | 6 +- .../partition/executor/hash/SDBMHashExecutor.java | 6 +- .../org/apache/iotdb/commons/path/PartialPath.java | 518 +++ .../org/apache/iotdb/commons/path/PathType.java | 38 + .../apache/iotdb/commons/service/JMXService.java | 13 +- .../apache/iotdb/commons/service/ServiceType.java | 6 +- .../iotdb/commons/service/ThriftService.java | 12 +- .../commons/utils/BasicStructureSerDeUtil.java | 242 + .../apache/iotdb/commons/utils/CommonUtils.java | 12 +- .../org/apache/iotdb/commons/utils/PathUtils.java | 98 + .../apache/iotdb/commons/utils/StatusUtils.java | 3 - .../commons/utils/ThriftCommonsSerDeUtils.java | 165 + .../commons/utils/ThriftConfigNodeSerDeUtils.java | 69 + .../apache/iotdb/commons/ClientManagerTest.java | 474 ++ .../apache/iotdb/commons/ConsensusGroupIdTest.java | 23 +- .../commons/utils/BasicStructureSerDeUtilTest.java | 88 + .../commons/utils/ThriftCommonsSerDeUtilsTest.java | 116 + .../utils/ThriftConfigNodeSerDeUtilsTest.java | 67 + openapi/src/main/openapi3/iotdb-rest.yaml | 23 + pom.xml | 40 +- procedure/pom.xml | 93 + .../iotdb/procedure/CompletedProcedureCleaner.java | 88 + .../procedure/CompletedProcedureRetainer.java | 36 + .../apache/iotdb/procedure/InternalProcedure.java | 61 + .../java/org/apache/iotdb/procedure/Procedure.java | 895 ++++ .../apache/iotdb/procedure/ProcedureExecutor.java | 995 +++++ .../apache/iotdb/procedure/ProcedureLockState.java | 26 + .../apache/iotdb/procedure/RootProcedureStack.java | 177 + .../iotdb/procedure/StateMachineProcedure.java | 329 ++ .../apache/iotdb/procedure/StoppableThread.java | 49 + .../iotdb/procedure/TimeoutExecutorThread.java | 107 + .../iotdb/procedure/conf/ProcedureNodeConfig.java | 153 + .../conf/ProcedureNodeConfigDescriptor.java | 219 + .../procedure/conf/ProcedureNodeConstant.java | 32 + .../procedure/env/ClusterProcedureEnvironment.java | 25 + .../exception/ProcedureAbortedException.java | 30 + .../procedure/exception/ProcedureException.java | 44 + .../exception/ProcedureSuspendedException.java | 39 + .../exception/ProcedureTimeoutException.java | 26 + .../exception/ProcedureYieldException.java | 36 + .../scheduler/AbstractProcedureScheduler.java | 211 + .../procedure/scheduler/ProcedureScheduler.java | 109 + .../scheduler/SimpleProcedureScheduler.java | 78 + .../iotdb/procedure/service/ProcedureNode.java | 98 + .../procedure/service/ProcedureNodeMBean.java | 22 + .../iotdb/procedure/service/ProcedureServer.java | 118 + .../service/ProcedureServerCommandLine.java | 52 + .../service/ProcedureServerProcessor.java | 77 + .../procedure/service/ProcedureServiceHanlder.java | 45 + .../iotdb/procedure/store/IProcedureStore.java | 48 + .../iotdb/procedure/store/ProcedureStore.java | 195 + .../apache/iotdb/procedure/store/ProcedureWAL.java | 106 + .../apache/iotdb/procedure/NoopProcedureStore.java | 70 + .../org/apache/iotdb/procedure/TestLockRegime.java | 46 + .../org/apache/iotdb/procedure/TestProcEnv.java | 57 + .../apache/iotdb/procedure/TestProcedureBase.java | 83 + .../iotdb/procedure/TestProcedureExecutor.java | 111 + .../apache/iotdb/procedure/TestSTMProcedure.java | 57 + .../iotdb/procedure/entity/IncProcedure.java | 57 + .../iotdb/procedure/entity/NoopProcedure.java | 44 + .../procedure/entity/SimpleLockProcedure.java | 80 + .../iotdb/procedure/entity/SimpleSTMProcedure.java | 97 + .../iotdb/procedure/entity/SleepProcedure.java | 46 + .../iotdb/procedure/entity/StuckProcedure.java | 59 + .../iotdb/procedure/entity/StuckSTMProcedure.java | 112 + .../procedure/service/TestProcedureService.java | 87 + .../iotdb/procedure/store/TestProcedureStore.java | 111 + .../iotdb/procedure/util/ProcedureTestUtil.java | 66 + schema-engine-rocksdb/README.md | 38 + schema-engine-rocksdb/pom.xml | 80 + .../resources/conf/schema-rocksdb.properties | 94 + .../src/assembly/schema-engine-rocksdb.xml | 44 + .../schemaregion/rocksdb/CheckKeyResult.java | 0 .../schemaregion/rocksdb/RSchemaConfLoader.java | 185 + .../schemaregion/rocksdb/RSchemaConstants.java | 0 .../schemaregion/rocksdb/RSchemaLogger.java | 0 .../rocksdb/RSchemaReadWriteHandler.java | 515 +++ .../schemaregion/rocksdb/RSchemaRegion.java | 1897 ++++++++ .../schemaregion/rocksdb/RSchemaUtils.java | 592 +++ .../schemaregion/rocksdb/mnode/REntityMNode.java | 124 + .../schemaregion/rocksdb/mnode/RInternalMNode.java | 197 + .../schemaregion/rocksdb/mnode/RMNode.java | 254 ++ .../schemaregion/rocksdb/mnode/RMNodeType.java | 0 .../rocksdb/mnode/RMNodeValueType.java | 0 .../rocksdb/mnode/RMeasurementMNode.java | 262 ++ .../rocksdb/mnode/RStorageGroupMNode.java | 120 + .../metadata}/rocksdb/MRocksDBBenchmark.java | 0 .../metadata/rocksdb/MRocksDBUnitTest.java | 265 ++ .../rocksdb/RSchemaReadWriteHandlerTest.java | 0 .../rocksdb/RSchemaRegionAdvancedTest.java | 169 + .../metadata/rocksdb/RocksDBBenchmarkEngine.java | 153 + .../metadata}/rocksdb/RocksDBBenchmarkTask.java | 0 .../metadata}/rocksdb/RocksDBTestUtils.java | 0 server/pom.xml | 42 +- .../resources/conf/iotdb-engine.properties | 112 +- .../resources/conf/iotdb-sync-client.properties | 35 - .../assembly/resources/tools/mlog/mLogParser.bat | 62 - .../assembly/resources/tools/mlog/mLogParser.sh | 48 - .../resources/tools/schema/SchemaFileSketcher.bat | 62 + .../resources/tools/schema/SchemaFileSketcher.sh | 48 + .../assembly/resources/tools/schema/mLogParser.bat | 62 + .../assembly/resources/tools/schema/mLogParser.sh | 48 + .../assembly/resources/tools/start-sync-client.bat | 71 - .../assembly/resources/tools/start-sync-client.sh | 54 - .../assembly/resources/tools/stop-sync-client.bat | 23 - .../assembly/resources/tools/stop-sync-client.sh | 30 - .../org/apache/iotdb/db/auth/AuthorityChecker.java | 144 +- .../db/auth/authorizer/AuthorizerManager.java | 115 +- .../iotdb/db/auth/authorizer/BasicAuthorizer.java | 14 + .../db/auth/authorizer/ClusterAuthorizer.java | 164 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 400 ++ .../iotdb/db/client/DataNodeClientPoolFactory.java | 148 + .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 231 +- .../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 41 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 143 +- .../apache/iotdb/db/consensus/ConsensusImpl.java | 4 +- .../iotdb/db/consensus/ConsensusManager.java | 72 - .../consensus/statemachine/BaseStateMachine.java | 14 +- .../statemachine/DataRegionStateMachine.java | 35 +- .../statemachine/SchemaRegionStateMachine.java | 33 +- .../org/apache/iotdb/db/engine/StorageEngine.java | 37 +- .../apache/iotdb/db/engine/StorageEngineV2.java | 173 +- .../db/engine/compaction/CompactionScheduler.java | 18 +- .../engine/compaction/CompactionTaskManager.java | 71 +- .../constant/CrossCompactionPerformer.java | 2 +- .../constant/CrossCompactionSelector.java | 32 +- .../constant/InnerSeqCompactionPerformer.java | 2 +- .../constant/InnerSequenceCompactionSelector.java | 8 +- .../constant/InnerUnseqCompactionPerformer.java | 2 +- .../InnerUnsequenceCompactionSelector.java | 6 +- .../compaction/cross/CrossSpaceCompactionTask.java | 11 +- .../RewriteCrossSpaceCompactionResource.java | 2 +- .../selector/RewriteCompactionFileSelector.java | 7 +- .../rewrite/task/ReadPointPerformerSubTask.java | 2 +- .../compaction/inner/InnerSpaceCompactionTask.java | 45 +- .../inner/utils/MultiTsFileDeviceIterator.java | 9 +- .../utils/SingleSeriesCompactionExecutor.java | 4 +- .../db/engine/compaction/log/TsFileIdentifier.java | 5 + .../compaction/performer/ICompactionPerformer.java | 2 +- .../impl/ReadChunkCompactionPerformer.java | 6 +- .../impl/ReadPointCompactionPerformer.java | 15 +- .../compaction/task/AbstractCompactionTask.java | 20 +- .../compaction/task/CompactionTaskSummary.java | 32 + .../engine/cq/ContinuousQuerySchemaCheckTask.java | 4 +- .../iotdb/db/engine/cq/ContinuousQueryTask.java | 6 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 33 +- .../memtable/AlignedWritableMemChunkGroup.java | 2 +- .../apache/iotdb/db/engine/memtable/IMemTable.java | 8 +- .../db/engine/memtable/IWritableMemChunkGroup.java | 2 +- .../db/engine/memtable/WritableMemChunkGroup.java | 2 +- .../iotdb/db/engine/modification/Deletion.java | 25 +- .../iotdb/db/engine/modification/Modification.java | 4 +- .../io/LocalTextModificationAccessor.java | 11 +- .../selectinto/InsertTabletPlanGenerator.java | 4 +- .../selectinto/InsertTabletPlansIterator.java | 6 +- .../apache/iotdb/db/engine/settle/SettleTask.java | 2 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 127 +- .../db/engine/storagegroup/TsFileManager.java | 38 + .../db/engine/storagegroup/TsFileProcessor.java | 251 +- .../db/engine/storagegroup/TsFileResource.java | 8 +- .../dataregion/HashVirtualPartitioner.java | 2 +- .../dataregion/StorageGroupManager.java | 12 +- .../dataregion/VirtualPartitioner.java | 2 +- .../db/engine/trigger/executor/TriggerEngine.java | 20 +- .../engine/trigger/executor/TriggerExecutor.java | 29 +- .../service/TriggerRegistrationInformation.java | 2 +- .../service/TriggerRegistrationService.java | 56 +- .../sink/local/LocalIoTDBConfiguration.java | 4 +- .../trigger/sink/local/LocalIoTDBHandler.java | 4 +- .../trigger/sink/mqtt/MQTTConfiguration.java | 2 +- .../SyncDeviceOwnerConflictException.java | 40 - .../metadata/AcquireLockTimeoutException.java | 2 + .../metadata/AliasAlreadyExistException.java | 1 + .../metadata/AlignedTimeseriesException.java | 1 + .../metadata/DataTypeMismatchException.java | 7 +- .../exception/metadata/DeleteFailedException.java | 1 + .../metadata/IllegalParameterOfPathException.java | 1 + .../exception/metadata/IllegalPathException.java | 38 - .../metadata/MNodeTypeMismatchException.java | 1 + .../db/exception/metadata/MetadataException.java | 63 - .../metadata/PathAlreadyExistException.java | 1 + .../exception/metadata/PathNotExistException.java | 1 + .../SchemaDirCreationFailureException.java | 2 + .../metadata/SeriesOverflowException.java | 34 + .../metadata/StorageGroupAlreadySetException.java | 1 + .../metadata/StorageGroupNotSetException.java | 1 + .../metadata/cache/MNodeNotCachedException.java | 2 +- .../metadata/cache/MNodeNotPinnedException.java | 2 +- .../schemafile/RecordDuplicatedException.java | 2 +- .../metadata/schemafile/SchemaFileNotExists.java | 2 +- .../schemafile/SchemaPageOverflowException.java | 2 +- .../schemafile/SegmentNotFoundException.java | 2 +- .../schemafile/SegmentOverflowException.java | 2 +- .../template/DifferentTemplateException.java | 2 +- .../template/DuplicatedTemplateException.java | 2 +- .../template/NoTemplateOnMNodeException.java | 2 +- .../template/TemplateImcompatibeException.java | 2 +- .../template/TemplateIsInUseException.java | 2 +- .../template/UndefinedTemplateException.java | 2 +- .../exception/sql/StatementAnalyzeException.java | 15 +- .../sync/PipeDataLoadBearableException.java | 25 + .../db/exception/sync/PipeDataLoadException.java | 25 + .../sync/PipeDataLoadUnbearableException.java | 25 + .../iotdb/db/exception/sync/PipeException.java | 36 + .../db/exception/sync/PipeServerException.java | 34 + .../iotdb/db/exception/sync/PipeSinkException.java | 42 + .../iotdb/db/localconfignode/LocalConfigNode.java | 815 ++++ .../localconfignode/LocalDataPartitionTable.java | 126 + .../localconfignode/LocalSchemaPartitionTable.java | 121 + .../iotdb/db/metadata/Executor/SchemaVisitor.java | 55 - .../iotdb/db/metadata/LocalConfigManager.java | 787 ---- .../db/metadata/LocalSchemaPartitionTable.java | 121 - .../iotdb/db/metadata/LocalSchemaProcessor.java | 105 +- .../apache/iotdb/db/metadata/MetadataConstant.java | 2 +- .../db/metadata/cache/DataNodeSchemaCache.java | 186 + .../iotdb/db/metadata/cache/SchemaCacheEntity.java | 114 + .../idtable/AppendOnlyDiskSchemaManager.java | 2 +- .../apache/iotdb/db/metadata/idtable/IDTable.java | 4 +- .../db/metadata/idtable/IDTableHashmapImpl.java | 63 +- .../iotdb/db/metadata/idtable/IDTableManager.java | 4 +- .../db/metadata/idtable/entry/DeviceIDFactory.java | 2 +- .../idtable/entry/InsertMeasurementMNode.java | 22 +- .../db/metadata/idtable/entry/SchemaEntry.java | 2 +- .../db/metadata/idtable/entry/TimeseriesID.java | 2 +- .../db/metadata/lastCache/LastCacheManager.java | 10 +- .../iotdb/db/metadata/logfile/MLogTxtWriter.java | 11 +- .../iotdb/db/metadata/logfile/MLogWriter.java | 2 +- .../org/apache/iotdb/db/metadata/mnode/IMNode.java | 10 +- .../db/metadata/mnode/IStorageGroupMNode.java | 12 + .../org/apache/iotdb/db/metadata/mnode/MNode.java | 31 +- .../iotdb/db/metadata/mnode/MeasurementMNode.java | 2 - .../db/metadata/mnode/StorageGroupEntityMNode.java | 18 + .../iotdb/db/metadata/mnode/StorageGroupMNode.java | 43 +- .../mnode/estimator/BasicMNodSizeEstimator.java | 6 +- .../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 308 ++ .../iotdb/db/metadata/mtree/MTreeAboveSG.java | 97 +- .../iotdb/db/metadata/mtree/MTreeBelowSG.java | 1519 ------- .../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 1516 +++++++ .../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 1348 ++++++ .../db/metadata/mtree/store/CachedMTreeStore.java | 4 +- .../iotdb/db/metadata/mtree/store/IMTreeStore.java | 2 +- .../db/metadata/mtree/store/MemMTreeStore.java | 2 +- .../mtree/store/disk/CachedMNodeContainer.java | 27 +- .../mtree/store/disk/MTreeFlushTaskManager.java | 8 +- .../mtree/store/disk/MTreeReleaseTaskManager.java | 5 +- .../mtree/store/disk/cache/CacheManager.java | 35 +- .../mtree/store/disk/schemafile/ISchemaFile.java | 2 +- .../mtree/store/disk/schemafile/ISchemaPage.java | 2 +- .../mtree/store/disk/schemafile/ISegment.java | 4 +- .../store/disk/schemafile/MockSchemaFile.java | 2 +- .../mtree/store/disk/schemafile/RecordUtils.java | 32 +- .../mtree/store/disk/schemafile/SchemaFile.java | 174 +- .../mtree/store/disk/schemafile/SchemaPage.java | 11 +- .../mtree/store/disk/schemafile/Segment.java | 53 +- .../db/metadata/mtree/traverser/Traverser.java | 6 +- .../traverser/collector/CollectorTraverser.java | 4 +- .../mtree/traverser/collector/EntityCollector.java | 4 +- .../traverser/collector/MNodeAboveSGCollector.java | 4 +- .../mtree/traverser/collector/MNodeCollector.java | 4 +- .../traverser/collector/MeasurementCollector.java | 8 +- .../traverser/collector/StorageGroupCollector.java | 4 +- .../mtree/traverser/counter/CounterTraverser.java | 4 +- .../mtree/traverser/counter/EntityCounter.java | 4 +- .../counter/MNodeAboveSGLevelCounter.java | 4 +- .../mtree/traverser/counter/MNodeLevelCounter.java | 4 +- .../traverser/counter/MeasurementCounter.java | 4 +- .../counter/MeasurementGroupByLevelCounter.java | 4 +- .../traverser/counter/StorageGroupCounter.java | 4 +- .../apache/iotdb/db/metadata/path/AlignedPath.java | 285 +- .../iotdb/db/metadata/path/MeasurementPath.java | 214 +- .../apache/iotdb/db/metadata/path/PartialPath.java | 598 --- .../db/metadata/path/PathDeserializeUtil.java | 18 +- .../db/metadata/schemaregion/ISchemaRegion.java | 254 +- .../metadata/schemaregion/RSchemaRegionLoader.java | 111 + .../db/metadata/schemaregion/SchemaEngine.java | 161 +- .../db/metadata/schemaregion/SchemaRegion.java | 1878 -------- .../schemaregion/SchemaRegionMemoryImpl.java | 1714 +++++++ .../schemaregion/SchemaRegionSchemaFileImpl.java | 1838 ++++++++ .../metadata/schemaregion/SchemaRegionUtils.java | 44 +- .../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 - .../rocksdb/mnode/RMeasurementMNode.java | 262 -- .../rocksdb/mnode/RStorageGroupMNode.java | 102 - .../storagegroup/IStorageGroupSchemaManager.java | 12 +- .../storagegroup/StorageGroupLogWriter.java | 2 +- .../storagegroup/StorageGroupSchemaManager.java | 32 +- .../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +- .../apache/iotdb/db/metadata/tag/TagManager.java | 4 +- .../iotdb/db/metadata/template/Template.java | 28 +- .../db/metadata/template/TemplateManager.java | 4 +- .../db/metadata/tree/AbstractTreeVisitor.java | 380 ++ .../tree/AbstractTreeVisitorWithLimitOffset.java | 106 + .../apache/iotdb/db/metadata/tree/ITreeNode.java | 25 + .../db/metadata/upgrade/MetadataUpgrader.java | 45 +- .../iotdb/db/metadata/utils/MetaFormatUtils.java | 23 +- .../apache/iotdb/db/metadata/utils/MetaUtils.java | 83 +- .../db/metadata/utils/ResourceByPathUtils.java | 610 +++ .../metadata/visitor/SchemaExecutionVisitor.java | 149 + .../iotdb/db/mpp/aggregation/Accumulator.java | 70 + .../db/mpp/aggregation/AccumulatorFactory.java | 71 + .../iotdb/db/mpp/aggregation/Aggregator.java | 122 + .../iotdb/db/mpp/aggregation/AvgAccumulator.java | 180 + .../iotdb/db/mpp/aggregation/CountAccumulator.java | 101 + .../db/mpp/aggregation/ExtremeAccumulator.java | 296 ++ .../db/mpp/aggregation/FirstValueAccumulator.java | 319 ++ .../mpp/aggregation/FirstValueDescAccumulator.java | 91 + .../db/mpp/aggregation/LastValueAccumulator.java | 305 ++ .../mpp/aggregation/LastValueDescAccumulator.java | 135 + .../db/mpp/aggregation/MaxTimeAccumulator.java | 101 + .../db/mpp/aggregation/MaxTimeDescAccumulator.java | 57 + .../db/mpp/aggregation/MaxValueAccumulator.java | 270 ++ .../db/mpp/aggregation/MinTimeAccumulator.java | 105 + .../db/mpp/aggregation/MinTimeDescAccumulator.java | 41 + .../db/mpp/aggregation/MinValueAccumulator.java | 270 ++ .../iotdb/db/mpp/aggregation/SumAccumulator.java | 172 + .../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/GroupByTimeParameter.java | 27 - .../iotdb/db/mpp/common/MPPQueryContext.java | 31 +- .../apache/iotdb/db/mpp/common/PlanFragmentId.java | 4 +- .../org/apache/iotdb/db/mpp/common/QueryId.java | 4 +- .../iotdb/db/mpp/common/ResultNodeContext.java | 10 +- .../db/mpp/common/filter/BasicFilterType.java | 4 +- .../db/mpp/common/filter/BasicFunctionFilter.java | 8 +- .../iotdb/db/mpp/common/filter/FunctionFilter.java | 4 +- .../iotdb/db/mpp/common/filter/InFilter.java | 14 +- .../iotdb/db/mpp/common/filter/LikeFilter.java | 6 +- .../iotdb/db/mpp/common/filter/QueryFilter.java | 8 +- .../iotdb/db/mpp/common/filter/RegexpFilter.java | 6 +- .../iotdb/db/mpp/common/header/ColumnHeader.java | 125 + .../iotdb/db/mpp/common/header/DatasetHeader.java | 94 + .../iotdb/db/mpp/common/header/HeaderConstant.java | 130 + .../db/mpp/common/schematree/DeviceSchemaInfo.java | 42 +- .../db/mpp/common/schematree/PathPatternNode.java | 13 + .../db/mpp/common/schematree/PathPatternTree.java | 59 +- .../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 | 156 +- .../mpp/common/schematree/SchemaTreeVisitor.java | 235 - .../common/schematree/node/SchemaEntityNode.java | 119 + .../common/schematree/node/SchemaInternalNode.java | 100 + .../schematree/node/SchemaMeasurementNode.java | 102 + .../db/mpp/common/schematree/node/SchemaNode.java | 82 + .../visitor/SchemaTreeDeviceVisitor.java | 61 + .../visitor/SchemaTreeMeasurementVisitor.java | 80 + .../schematree/visitor/SchemaTreeVisitor.java | 60 + .../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 - .../apache/iotdb/db/mpp/execution/IConfigTask.java | 26 - .../iotdb/db/mpp/execution/IQueryExecution.java | 29 - .../iotdb/db/mpp/execution/QueryExecution.java | 245 - .../iotdb/db/mpp/execution/QueryStateMachine.java | 21 +- .../iotdb/db/mpp/execution/SampleConfigTask.java | 47 - .../iotdb/db/mpp/execution/SchemaDriver.java | 149 - .../db/mpp/execution/SchemaDriverContext.java | 36 - .../execution/datatransfer/DataBlockManager.java | 471 ++ .../execution/datatransfer/DataBlockService.java | 137 + .../datatransfer/DataBlockServiceMBean.java | 34 + .../DataBlockServiceThriftHandler.java | 44 + .../execution/datatransfer/IDataBlockManager.java | 85 + .../datatransfer/IDataBlockManagerCallback.java | 24 + .../db/mpp/execution/datatransfer/ISinkHandle.java | 73 + .../mpp/execution/datatransfer/ISourceHandle.java | 57 + .../execution/datatransfer/LocalSinkHandle.java | 146 + .../execution/datatransfer/LocalSourceHandle.java | 125 + .../execution/datatransfer/SharedTsBlockQueue.java | 152 + .../db/mpp/execution/datatransfer/SinkHandle.java | 371 ++ .../mpp/execution/datatransfer/SourceHandle.java | 400 ++ .../datatransfer/TsBlockSerdeFactory.java | 31 + .../iotdb/db/mpp/execution/driver/DataDriver.java | 193 + .../db/mpp/execution/driver/DataDriverContext.java | 64 + .../iotdb/db/mpp/execution/driver/Driver.java | 452 ++ .../db/mpp/execution/driver/DriverContext.java | 56 + .../iotdb/db/mpp/execution/driver/IDriver.java | 71 + .../db/mpp/execution/driver/SchemaDriver.java | 45 + .../mpp/execution/driver/SchemaDriverContext.java | 38 + .../db/mpp/execution/fragment/FragmentInfo.java | 44 + .../fragment/FragmentInstanceContext.java | 164 + .../fragment/FragmentInstanceExecution.java | 119 + .../fragment/FragmentInstanceFailureListener.java | 25 + .../execution/fragment/FragmentInstanceInfo.java | 40 + .../fragment/FragmentInstanceManager.java | 232 + .../execution/fragment/FragmentInstanceState.java | 80 + .../fragment/FragmentInstanceStateMachine.java | 183 + .../db/mpp/execution/fragment/FragmentState.java | 71 + .../mpp/execution/memory/LocalMemoryManager.java | 43 + .../iotdb/db/mpp/execution/memory/MemoryPool.java | 202 + .../iotdb/db/mpp/execution/operator/Operator.java | 55 + .../db/mpp/execution/operator/OperatorContext.java | 54 + .../operator/process/AggregateOperator.java | 72 + .../operator/process/DeviceViewOperator.java | 152 + .../execution/operator/process/FillOperator.java | 56 + .../operator/process/FilterNullOperator.java | 57 + .../execution/operator/process/FilterOperator.java | 157 + .../execution/operator/process/LimitOperator.java | 80 + .../execution/operator/process/OffsetOperator.java | 79 + .../operator/process/ProcessOperator.java | 24 + .../execution/operator/process/SortOperator.java | 57 + .../operator/process/TimeJoinOperator.java | 233 + .../operator/process/TransformOperator.java | 245 + .../operator/process/merge/AscTimeComparator.java | 33 + .../operator/process/merge/ColumnMerger.java | 60 + .../operator/process/merge/DescTimeComparator.java | 33 + .../operator/process/merge/MultiColumnMerger.java | 96 + .../operator/process/merge/SingleColumnMerger.java | 91 + .../operator/process/merge/TimeComparator.java | 28 + .../operator/schema/CountMergeOperator.java | 133 + .../operator/schema/DevicesCountOperator.java | 90 + .../operator/schema/DevicesSchemaScanOperator.java | 83 + .../schema/LevelTimeSeriesCountOperator.java | 100 + .../operator/schema/SchemaFetchOperator.java | 128 + .../operator/schema/SchemaMergeOperator.java | 94 + .../operator/schema/SchemaScanOperator.java | 112 + .../operator/schema/TimeSeriesCountOperator.java | 90 + .../schema/TimeSeriesSchemaScanOperator.java | 125 + .../operator/sink/FragmentSinkOperator.java | 66 + .../mpp/execution/operator/sink/SinkOperator.java | 43 + .../operator/source/AlignedSeriesScanUtil.java | 85 + .../operator/source/DataSourceOperator.java | 26 + .../operator/source/ExchangeOperator.java | 86 + .../source/SeriesAggregateScanOperator.java | 461 ++ .../operator/source/SeriesScanOperator.java | 153 + .../execution/operator/source/SeriesScanUtil.java | 1426 ++++++ .../execution/operator/source/SourceOperator.java | 27 + .../execution/schedule/AbstractDriverThread.java | 71 + .../db/mpp/execution/schedule/DriverScheduler.java | 357 ++ .../mpp/execution/schedule/DriverTaskThread.java | 85 + .../schedule/DriverTaskTimeoutSentinelThread.java | 56 + .../mpp/execution/schedule/ExecutionContext.java | 46 + .../schedule/FragmentInstanceAbortedException.java | 35 + .../mpp/execution/schedule/IDriverScheduler.java | 61 + .../db/mpp/execution/schedule/ITaskScheduler.java | 72 + .../iotdb/db/mpp/execution/schedule/queue/ID.java | 22 + .../schedule/queue/IDIndexedAccessible.java | 48 + .../schedule/queue/IndexedBlockingQueue.java | 201 + .../execution/schedule/queue/L1PriorityQueue.java | 102 + .../execution/schedule/queue/L2PriorityQueue.java | 129 + .../db/mpp/execution/schedule/task/DriverTask.java | 217 + .../mpp/execution/schedule/task/DriverTaskID.java | 68 + .../execution/schedule/task/DriverTaskStatus.java | 37 + .../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 - .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 150 + .../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 128 + .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 537 +++ .../mpp/plan/analyze/ClusterPartitionFetcher.java | 604 +++ .../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 121 + .../mpp/plan/analyze/FakePartitionFetcherImpl.java | 158 + .../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 99 + .../db/mpp/plan/analyze/IPartitionFetcher.java | 43 + .../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 44 + .../iotdb/db/mpp/plan/analyze/QueryType.java | 24 + .../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 57 + .../plan/analyze/StandalonePartitionFetcher.java | 127 + .../mpp/plan/analyze/StandaloneSchemaFetcher.java | 89 + .../iotdb/db/mpp/plan/analyze/TypeProvider.java | 77 + .../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 + .../iotdb/db/mpp/plan/constant/StatementType.java | 139 + .../db/mpp/plan/execution/ExecutionResult.java | 32 + .../db/mpp/plan/execution/IQueryExecution.java | 44 + .../db/mpp/plan/execution/QueryExecution.java | 336 ++ .../execution/config/AuthorizerConfigTask.java | 76 + .../mpp/plan/execution/config/ConfigExecution.java | 161 + .../plan/execution/config/ConfigTaskResult.java | 61 + .../plan/execution/config/ConfigTaskVisitor.java | 86 + .../execution/config/CountStorageGroupTask.java | 97 + .../db/mpp/plan/execution/config/IConfigTask.java | 26 + .../plan/execution/config/SetStorageGroupTask.java | 97 + .../db/mpp/plan/execution/config/SetTTLTask.java | 95 + .../execution/config/ShowStorageGroupTask.java | 112 + .../db/mpp/plan/execution/config/ShowTTLTask.java | 134 + .../db/mpp/plan/execution/config/UnSetTTLTask.java | 29 + .../db/mpp/plan/optimization/PlanOptimizer.java | 26 + .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 2214 +++++++++ .../db/mpp/plan/parser/StatementGenerator.java | 409 ++ .../db/mpp/plan/planner/DistributionPlanner.java | 567 +++ .../mpp/plan/planner/IFragmentParallelPlaner.java | 38 + .../db/mpp/plan/planner/LocalExecutionPlanner.java | 592 +++ .../db/mpp/plan/planner/LogicalPlanBuilder.java | 226 + .../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 388 ++ .../planner/SimpleFragmentParallelPlanner.java | 146 + .../plan/planner/WriteFragmentParallelPlanner.java | 73 + .../plan/planner/plan/DistributedQueryPlan.java | 57 + .../db/mpp/plan/planner/plan/FragmentInstance.java | 177 + .../db/mpp/plan/planner/plan/LogicalQueryPlan.java | 45 + .../db/mpp/plan/planner/plan/PlanFragment.java | 156 + .../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 69 + .../plan/planner/plan/node/PlanGraphPrinter.java | 309 ++ .../db/mpp/plan/planner/plan/node/PlanNode.java | 118 + .../db/mpp/plan/planner/plan/node/PlanNodeId.java | 61 + .../mpp/plan/planner/plan/node/PlanNodeType.java | 197 + .../mpp/plan/planner/plan/node/PlanNodeUtil.java | 116 + .../db/mpp/plan/planner/plan/node/PlanVisitor.java | 184 + .../planner/plan/node/SimplePlanNodeRewriter.java | 48 + .../mpp/plan/planner/plan/node/WritePlanNode.java | 36 + .../metedata/read/AbstractSchemaMergeNode.java | 61 + .../node/metedata/read/CountSchemaMergeNode.java | 54 + .../plan/node/metedata/read/DevicesCountNode.java | 68 + .../node/metedata/read/DevicesSchemaScanNode.java | 110 + .../metedata/read/LevelTimeSeriesCountNode.java | 98 + .../plan/node/metedata/read/SchemaFetchNode.java | 78 + .../plan/node/metedata/read/SchemaScanNode.java | 155 + .../node/metedata/read/SeriesSchemaMergeNode.java | 60 + .../node/metedata/read/TimeSeriesCountNode.java | 68 + .../metedata/read/TimeSeriesSchemaScanNode.java | 143 + .../node/metedata/write/AlterTimeSeriesNode.java | 298 ++ .../write/CreateAlignedTimeSeriesNode.java | 379 ++ .../node/metedata/write/CreateTimeSeriesNode.java | 332 ++ .../planner/plan/node/process/AggregationNode.java | 186 + .../planner/plan/node/process/DeviceMergeNode.java | 149 + .../planner/plan/node/process/DeviceViewNode.java | 166 + .../planner/plan/node/process/ExchangeNode.java | 209 + .../plan/planner/plan/node/process/FillNode.java | 126 + .../plan/planner/plan/node/process/FilterNode.java | 115 + .../planner/plan/node/process/FilterNullNode.java | 128 + .../plan/node/process/GroupByLevelNode.java | 172 + .../planner/plan/node/process/GroupByTimeNode.java | 165 + .../plan/planner/plan/node/process/LimitNode.java | 128 + .../plan/planner/plan/node/process/OffsetNode.java | 119 + .../planner/plan/node/process/ProcessNode.java | 29 + .../planner/plan/node/process/ProjectNode.java | 115 + .../plan/planner/plan/node/process/SortNode.java | 119 + .../planner/plan/node/process/TimeJoinNode.java | 135 + .../planner/plan/node/sink/FragmentSinkNode.java | 188 + .../mpp/plan/planner/plan/node/sink/SinkNode.java | 31 + .../source/AlignedSeriesAggregationScanNode.java | 267 ++ .../plan/node/source/AlignedSeriesScanNode.java | 264 ++ .../node/source/SeriesAggregationScanNode.java | 317 ++ .../planner/plan/node/source/SeriesScanNode.java | 312 ++ .../plan/planner/plan/node/source/SourceNode.java | 36 + .../planner/plan/node/write/BatchInsertNode.java | 40 + .../plan/node/write/InsertMultiTabletsNode.java | 279 ++ .../plan/planner/plan/node/write/InsertNode.java | 252 ++ .../planner/plan/node/write/InsertRowNode.java | 621 +++ .../planner/plan/node/write/InsertRowsNode.java | 253 ++ .../plan/node/write/InsertRowsOfOneDeviceNode.java | 289 ++ .../planner/plan/node/write/InsertTabletNode.java | 820 ++++ .../plan/parameter/AggregationDescriptor.java | 106 + .../planner/plan/parameter/AggregationStep.java | 97 + .../planner/plan/parameter/FillDescriptor.java | 69 + .../plan/parameter/FilterNullParameter.java | 89 + .../plan/parameter/GroupByTimeParameter.java | 173 + .../plan/planner/plan/parameter/InputLocation.java | 72 + .../plan/planner/plan/parameter/OutputColumn.java | 91 + .../plan/rewriter/ColumnPaginationController.java | 145 + .../db/mpp/plan/rewriter/ConcatPathRewriter.java | 190 + .../db/mpp/plan/rewriter/DnfFilterOptimizer.java | 163 + .../db/mpp/plan/rewriter/IFilterOptimizer.java | 29 + .../plan/rewriter/MergeSingleFilterOptimizer.java | 179 + .../db/mpp/plan/rewriter/RemoveNotOptimizer.java | 103 + .../db/mpp/plan/rewriter/WildcardsRemover.java | 375 ++ .../scheduler/AbstractFragInsStateTracker.java | 84 + .../db/mpp/plan/scheduler/ClusterScheduler.java | 159 + .../scheduler/FixedRateFragInsStateTracker.java | 86 + .../plan/scheduler/FragInstanceDispatchResult.java | 32 + .../plan/scheduler/IFragInstanceDispatcher.java | 37 + .../plan/scheduler/IFragInstanceStateTracker.java | 26 + .../db/mpp/plan/scheduler/IQueryTerminator.java | 26 + .../iotdb/db/mpp/plan/scheduler/IScheduler.java | 40 + .../scheduler/SimpleFragInstanceDispatcher.java | 88 + .../mpp/plan/scheduler/SimpleQueryTerminator.java | 87 + .../db/mpp/plan/scheduler/StandaloneScheduler.java | 113 + .../db/mpp/plan/statement/IConfigStatement.java | 36 + .../iotdb/db/mpp/plan/statement/Statement.java | 67 + .../iotdb/db/mpp/plan/statement/StatementNode.java | 32 + .../db/mpp/plan/statement/StatementVisitor.java | 208 + .../plan/statement/component/FillComponent.java | 51 + .../mpp/plan/statement/component/FillPolicy.java | 25 + .../statement/component/FilterNullComponent.java | 97 + .../plan/statement/component/FilterNullPolicy.java | 25 + .../plan/statement/component/FromComponent.java | 42 + .../statement/component/GroupByLevelComponent.java | 56 + .../component/GroupByLevelController.java | 247 + .../statement/component/GroupByTimeComponent.java | 101 + .../db/mpp/plan/statement/component/OrderBy.java | 28 + .../mpp/plan/statement/component/ResultColumn.java | 205 + .../plan/statement/component/ResultSetFormat.java | 27 + .../plan/statement/component/SelectComponent.java | 182 + .../plan/statement/component/WhereCondition.java | 43 + .../statement/crud/AggregationQueryStatement.java | 129 + .../plan/statement/crud/FillQueryStatement.java | 79 + .../statement/crud/GroupByFillQueryStatement.java | 49 + .../plan/statement/crud/GroupByQueryStatement.java | 61 + .../plan/statement/crud/InsertBaseStatement.java | 78 + .../crud/InsertMultiTabletsStatement.java | 86 + .../plan/statement/crud/InsertRowStatement.java | 128 + .../crud/InsertRowsOfOneDeviceStatement.java | 90 + .../plan/statement/crud/InsertRowsStatement.java | 86 + .../mpp/plan/statement/crud/InsertStatement.java | 101 + .../plan/statement/crud/InsertTabletStatement.java | 104 + .../plan/statement/crud/LastQueryStatement.java | 74 + .../db/mpp/plan/statement/crud/QueryStatement.java | 354 ++ .../plan/statement/crud/UDAFQueryStatement.java | 97 + .../plan/statement/crud/UDTFQueryStatement.java | 34 + .../metadata/AlterTimeSeriesStatement.java | 127 + .../statement/metadata/CountDevicesStatement.java | 34 + .../metadata/CountLevelTimeSeriesStatement.java | 41 + .../statement/metadata/CountNodesStatement.java | 31 + .../plan/statement/metadata/CountStatement.java | 55 + .../metadata/CountStorageGroupStatement.java | 42 + .../metadata/CountTimeSeriesStatement.java | 34 + .../metadata/CreateAlignedTimeSeriesStatement.java | 193 + .../metadata/CreateTimeSeriesStatement.java | 132 + .../statement/metadata/SchemaFetchStatement.java | 64 + .../metadata/SetStorageGroupStatement.java | 64 + .../plan/statement/metadata/SetTTLStatement.java | 73 + .../statement/metadata/ShowDevicesStatement.java | 66 + .../mpp/plan/statement/metadata/ShowStatement.java | 69 + .../metadata/ShowStorageGroupStatement.java | 64 + .../plan/statement/metadata/ShowTTLStatement.java | 60 + .../metadata/ShowTimeSeriesStatement.java | 87 + .../plan/statement/metadata/UnSetTTLStatement.java | 37 + .../db/mpp/plan/statement/sys/AuthorStatement.java | 209 + .../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 - .../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 4 +- .../protocol/influxdb/function/InfluxFunction.java | 2 +- .../influxdb/function/InfluxFunctionFactory.java | 8 +- .../db/protocol/influxdb/handler/QueryHandler.java | 24 +- .../protocol/influxdb/input/InfluxLineParser.java | 5 +- .../influxdb/meta/InfluxDBMetaManager.java | 19 +- .../db/protocol/influxdb/meta/TagInfoRecords.java | 4 +- .../influxdb/operator/InfluxSelectComponent.java | 4 +- .../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 9 +- .../db/protocol/influxdb/util/JacksonUtils.java | 44 + .../protocol/influxdb/util/QueryResultUtils.java | 3 +- .../db/protocol/influxdb/util/StringUtils.java | 3 +- .../iotdb/db/protocol/mqtt/PublishHandler.java | 2 +- .../db/protocol/rest/handler/ExceptionHandler.java | 4 +- .../handler/PhysicalPlanConstructionHandler.java | 4 +- .../protocol/rest/handler/QueryDataSetHandler.java | 14 + .../protocol/rest/impl/GrafanaApiServiceImpl.java | 41 + .../main/java/org/apache/iotdb/db/qp/Planner.java | 2 +- .../apache/iotdb/db/qp/constant/SQLConstant.java | 28 +- .../apache/iotdb/db/qp/executor/IPlanExecutor.java | 4 +- .../apache/iotdb/db/qp/executor/PlanExecutor.java | 230 +- .../org/apache/iotdb/db/qp/logical/Operator.java | 14 +- .../qp/logical/crud/AggregationQueryOperator.java | 8 +- .../db/qp/logical/crud/BasicFunctionOperator.java | 4 +- .../db/qp/logical/crud/DeleteDataOperator.java | 2 +- .../iotdb/db/qp/logical/crud/FilterOperator.java | 4 +- .../iotdb/db/qp/logical/crud/FromComponent.java | 2 +- .../db/qp/logical/crud/GroupByQueryOperator.java | 2 +- .../iotdb/db/qp/logical/crud/InOperator.java | 4 +- .../iotdb/db/qp/logical/crud/InsertOperator.java | 2 +- .../db/qp/logical/crud/LastQueryOperator.java | 2 +- .../iotdb/db/qp/logical/crud/LikeOperator.java | 4 +- .../iotdb/db/qp/logical/crud/QueryOperator.java | 8 +- .../iotdb/db/qp/logical/crud/RegexpOperator.java | 4 +- .../iotdb/db/qp/logical/crud/SelectComponent.java | 10 +- .../db/qp/logical/crud/SelectIntoOperator.java | 17 +- .../db/qp/logical/crud/UDAFQueryOperator.java | 4 +- .../qp/logical/sys/ActivateTemplateOperator.java | 2 +- .../db/qp/logical/sys/AlterTimeSeriesOperator.java | 2 +- .../iotdb/db/qp/logical/sys/AuthorOperator.java | 2 +- .../iotdb/db/qp/logical/sys/CountOperator.java | 2 +- .../sys/CreateAlignedTimeSeriesOperator.java | 2 +- .../logical/sys/CreateContinuousQueryOperator.java | 2 +- .../db/qp/logical/sys/CreateIndexOperator.java | 2 +- .../db/qp/logical/sys/CreatePipeOperator.java | 69 + .../db/qp/logical/sys/CreatePipeSinkOperator.java | 61 + .../qp/logical/sys/CreateTimeSeriesOperator.java | 2 +- .../db/qp/logical/sys/CreateTriggerOperator.java | 2 +- .../db/qp/logical/sys/DeletePartitionOperator.java | 2 +- .../qp/logical/sys/DeleteStorageGroupOperator.java | 2 +- .../qp/logical/sys/DeleteTimeSeriesOperator.java | 2 +- .../iotdb/db/qp/logical/sys/DropIndexOperator.java | 2 +- .../iotdb/db/qp/logical/sys/DropPipeOperator.java | 44 + .../db/qp/logical/sys/DropPipeSinkOperator.java | 43 + .../iotdb/db/qp/logical/sys/FlushOperator.java | 2 +- .../db/qp/logical/sys/SetStorageGroupOperator.java | 2 +- .../iotdb/db/qp/logical/sys/SetTTLOperator.java | 2 +- .../db/qp/logical/sys/SetTemplateOperator.java | 4 +- .../iotdb/db/qp/logical/sys/SettleOperator.java | 2 +- .../db/qp/logical/sys/ShowChildNodesOperator.java | 2 +- .../db/qp/logical/sys/ShowChildPathsOperator.java | 2 +- .../db/qp/logical/sys/ShowDevicesOperator.java | 2 +- .../db/qp/logical/sys/ShowLockInfoOperator.java | 2 +- .../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 45 + .../db/qp/logical/sys/ShowPipeServerOperator.java | 38 + .../db/qp/logical/sys/ShowPipeSinkOperator.java | 45 + .../qp/logical/sys/ShowPipeSinkTypeOperator.java | 38 + .../qp/logical/sys/ShowStorageGroupOperator.java | 2 +- .../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 2 +- .../db/qp/logical/sys/ShowTimeSeriesOperator.java | 2 +- .../iotdb/db/qp/logical/sys/StartPipeOperator.java | 44 + .../db/qp/logical/sys/StartPipeServerOperator.java | 38 + .../iotdb/db/qp/logical/sys/StopPipeOperator.java | 44 + .../db/qp/logical/sys/StopPipeServerOperator.java | 38 + .../iotdb/db/qp/logical/sys/UnSetTTLOperator.java | 2 +- .../db/qp/logical/sys/UnsetTemplateOperator.java | 4 +- .../org/apache/iotdb/db/qp/physical/BatchPlan.java | 2 +- .../apache/iotdb/db/qp/physical/PhysicalPlan.java | 23 +- .../iotdb/db/qp/physical/crud/AggregationPlan.java | 4 +- .../db/qp/physical/crud/AlignByDevicePlan.java | 4 +- .../db/qp/physical/crud/DeletePartitionPlan.java | 2 +- .../iotdb/db/qp/physical/crud/DeletePlan.java | 4 +- .../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 2 +- .../qp/physical/crud/InsertMultiTabletsPlan.java | 4 +- .../iotdb/db/qp/physical/crud/InsertPlan.java | 2 +- .../iotdb/db/qp/physical/crud/InsertRowPlan.java | 32 +- .../physical/crud/InsertRowsOfOneDevicePlan.java | 4 +- .../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 4 +- .../db/qp/physical/crud/InsertTabletPlan.java | 73 +- .../iotdb/db/qp/physical/crud/LastQueryPlan.java | 2 +- .../iotdb/db/qp/physical/crud/QueryPlan.java | 6 +- .../db/qp/physical/crud/RawDataQueryPlan.java | 13 +- .../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 4 +- .../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 2 +- .../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 45 +- .../db/qp/physical/sys/ActivateTemplatePlan.java | 4 +- .../db/qp/physical/sys/AlterTimeSeriesPlan.java | 4 +- .../db/qp/physical/sys/AppendTemplatePlan.java | 2 +- .../iotdb/db/qp/physical/sys/AuthorPlan.java | 6 +- .../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 4 +- .../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 4 +- .../db/qp/physical/sys/ChangeTagOffsetPlan.java | 4 +- .../iotdb/db/qp/physical/sys/ClearCachePlan.java | 4 +- .../apache/iotdb/db/qp/physical/sys/CountPlan.java | 2 +- .../physical/sys/CreateAlignedTimeSeriesPlan.java | 19 +- .../qp/physical/sys/CreateContinuousQueryPlan.java | 4 +- .../db/qp/physical/sys/CreateFunctionPlan.java | 4 +- .../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 4 +- .../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 4 +- .../iotdb/db/qp/physical/sys/CreatePipePlan.java | 110 + .../db/qp/physical/sys/CreatePipeSinkPlan.java | 98 + .../db/qp/physical/sys/CreateTemplatePlan.java | 4 +- .../db/qp/physical/sys/CreateTimeSeriesPlan.java | 14 +- .../db/qp/physical/sys/CreateTriggerPlan.java | 4 +- .../iotdb/db/qp/physical/sys/DataAuthPlan.java | 2 +- .../db/qp/physical/sys/DeleteStorageGroupPlan.java | 4 +- .../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 16 +- .../qp/physical/sys/DropContinuousQueryPlan.java | 2 +- .../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 4 +- .../iotdb/db/qp/physical/sys/DropIndexPlan.java | 4 +- .../iotdb/db/qp/physical/sys/DropPipeSinkPlan.java | 45 + .../iotdb/db/qp/physical/sys/DropTemplatePlan.java | 2 +- .../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 4 +- .../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 4 +- .../iotdb/db/qp/physical/sys/KillQueryPlan.java | 2 +- .../db/qp/physical/sys/LoadConfigurationPlan.java | 2 +- .../iotdb/db/qp/physical/sys/LoadDataPlan.java | 2 +- .../apache/iotdb/db/qp/physical/sys/LogPlan.java | 2 +- .../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 2 +- .../db/qp/physical/sys/MeasurementMNodePlan.java | 2 +- .../apache/iotdb/db/qp/physical/sys/MergePlan.java | 4 +- .../iotdb/db/qp/physical/sys/OperateFilePlan.java | 2 +- .../iotdb/db/qp/physical/sys/OperatePipePlan.java | 45 + .../db/qp/physical/sys/PruneTemplatePlan.java | 2 +- .../db/qp/physical/sys/SetStorageGroupPlan.java | 4 +- .../db/qp/physical/sys/SetSystemModePlan.java | 4 +- .../iotdb/db/qp/physical/sys/SetTTLPlan.java | 4 +- .../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 8 +- .../iotdb/db/qp/physical/sys/SettlePlan.java | 2 +- .../db/qp/physical/sys/ShowChildNodesPlan.java | 2 +- .../db/qp/physical/sys/ShowChildPathsPlan.java | 2 +- .../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 4 +- .../iotdb/db/qp/physical/sys/ShowLockInfoPlan.java | 2 +- .../iotdb/db/qp/physical/sys/ShowPipePlan.java | 33 + .../db/qp/physical/sys/ShowPipeServerPlan.java | 26 + .../iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java | 33 + .../db/qp/physical/sys/ShowPipeSinkTypePlan.java | 26 + .../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 8 +- .../db/qp/physical/sys/ShowQueryResourcePlan.java | 2 +- .../db/qp/physical/sys/ShowStorageGroupPlan.java | 2 +- .../iotdb/db/qp/physical/sys/ShowTTLPlan.java | 2 +- .../db/qp/physical/sys/ShowTimeSeriesPlan.java | 4 +- .../db/qp/physical/sys/StartPipeServerPlan.java | 56 + .../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 4 +- .../db/qp/physical/sys/StopPipeServerPlan.java | 56 + .../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 4 +- .../db/qp/physical/sys/StorageGroupMNodePlan.java | 2 +- .../iotdb/db/qp/physical/sys/TracingPlan.java | 2 +- .../db/qp/physical/sys/UnsetTemplatePlan.java | 8 +- .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 624 ++- .../iotdb/db/qp/strategy/LogicalGenerator.java | 6 +- .../iotdb/db/qp/strategy/PhysicalGenerator.java | 4 +- .../qp/strategy/optimizer/ConcatPathOptimizer.java | 12 +- .../optimizer/MergeSingleFilterOptimizer.java | 2 +- .../qp/strategy/optimizer/RemoveNotOptimizer.java | 2 +- .../apache/iotdb/db/qp/utils/DatetimeUtils.java | 15 + .../iotdb/db/qp/utils/GroupByLevelController.java | 4 +- .../apache/iotdb/db/qp/utils/WildcardsRemover.java | 4 +- .../iotdb/db/query/context/QueryContext.java | 2 +- .../db/query/control/QueryResourceManager.java | 8 +- .../iotdb/db/query/control/SessionManager.java | 71 +- .../db/query/dataset/AlignByDeviceDataSet.java | 6 +- .../apache/iotdb/db/query/dataset/ListDataSet.java | 2 +- .../db/query/dataset/NonAlignEngineDataSet.java | 2 +- .../dataset/RawQueryDataSetWithValueFilter.java | 2 +- .../dataset/RawQueryDataSetWithoutValueFilter.java | 2 +- .../query/dataset/ShowContinuousQueriesResult.java | 2 +- .../apache/iotdb/db/query/dataset/ShowDataSet.java | 2 +- .../iotdb/db/query/dataset/ShowDevicesDataSet.java | 4 +- .../db/query/dataset/ShowTimeseriesDataSet.java | 4 +- .../iotdb/db/query/dataset/SingleDataSet.java | 2 +- .../apache/iotdb/db/query/dataset/UDTFDataSet.java | 5 +- .../query/dataset/groupby/GroupByFillDataSet.java | 8 +- .../query/dataset/groupby/GroupByLevelDataSet.java | 4 +- .../query/dataset/groupby/GroupByTimeDataSet.java | 30 +- .../dataset/groupby/GroupByTimeEngineDataSet.java | 24 +- .../groupby/GroupByWithValueFilterDataSet.java | 10 +- .../groupby/GroupByWithoutValueFilterDataSet.java | 13 +- .../db/query/executor/AggregationExecutor.java | 8 +- .../iotdb/db/query/executor/FillQueryExecutor.java | 6 +- .../iotdb/db/query/executor/LastQueryExecutor.java | 10 +- .../iotdb/db/query/executor/QueryRouter.java | 7 +- .../db/query/executor/RawDataQueryExecutor.java | 13 +- .../executor/fill/AlignedLastPointReader.java | 2 +- .../apache/iotdb/db/query/executor/fill/IFill.java | 2 +- .../db/query/executor/fill/LastPointReader.java | 8 +- .../iotdb/db/query/executor/fill/LinearFill.java | 2 +- .../iotdb/db/query/executor/fill/PreviousFill.java | 2 +- .../iotdb/db/query/executor/fill/ValueFill.java | 2 +- .../groupby/impl/LocalAlignedGroupByExecutor.java | 2 +- .../groupby/impl/LocalGroupByExecutor.java | 2 +- .../iotdb/db/query/expression/Expression.java | 143 +- .../iotdb/db/query/expression/ExpressionType.java | 120 +- .../iotdb/db/query/expression/ResultColumn.java | 23 +- .../expression/binary/AdditionExpression.java | 23 +- .../query/expression/binary/BinaryExpression.java | 37 +- .../expression/binary/DivisionExpression.java | 23 +- .../query/expression/binary/EqualToExpression.java | 24 +- .../expression/binary/GreaterEqualExpression.java | 23 +- .../expression/binary/GreaterThanExpression.java | 24 +- .../expression/binary/LessEqualExpression.java | 23 +- .../expression/binary/LessThanExpression.java | 23 +- .../expression/binary/LogicAndExpression.java | 24 +- .../query/expression/binary/LogicOrExpression.java | 24 +- .../query/expression/binary/ModuloExpression.java | 23 +- .../binary/MultiplicationExpression.java | 23 +- .../expression/binary/NonEqualExpression.java | 23 +- .../expression/binary/SubtractionExpression.java | 23 +- .../db/query/expression/leaf/ConstantOperand.java | 150 + .../db/query/expression/leaf/LeafOperand.java | 42 + .../query/expression/leaf/TimeSeriesOperand.java | 164 + .../db/query/expression/leaf/TimestampOperand.java | 151 + .../query/expression/multi/FunctionExpression.java | 472 ++ .../db/query/expression/unary/ConstantOperand.java | 153 - .../query/expression/unary/FunctionExpression.java | 454 -- .../db/query/expression/unary/InExpression.java | 91 + .../db/query/expression/unary/LikeExpression.java | 135 + .../query/expression/unary/LogicNotExpression.java | 171 +- .../query/expression/unary/NegationExpression.java | 177 +- .../query/expression/unary/RegularExpression.java | 82 + .../query/expression/unary/TimeSeriesOperand.java | 174 - .../db/query/expression/unary/UnaryExpression.java | 196 + .../db/query/factory/AggregateResultFactory.java | 17 +- .../query/reader/chunk/MemAlignedPageReader.java | 2 +- .../iotdb/db/query/reader/chunk/MemPageReader.java | 4 +- .../chunk/metadata/DiskChunkMetadataLoader.java | 2 +- .../metadata/MemAlignedChunkMetadataLoader.java | 2 +- .../chunk/metadata/MemChunkMetadataLoader.java | 2 +- .../query/reader/series/AlignedSeriesReader.java | 2 +- .../query/reader/series/SeriesAggregateReader.java | 22 +- .../reader/series/SeriesRawDataBatchReader.java | 41 +- .../iotdb/db/query/reader/series/SeriesReader.java | 23 +- .../reader/series/SeriesReaderByTimestamp.java | 8 +- .../query/timegenerator/ServerTimeGenerator.java | 4 +- .../parameter/UDFParameterValidator.java | 2 +- .../api/customizer/parameter/UDFParameters.java | 6 +- .../db/query/udf/builtin/BuiltinFunction.java | 7 +- .../apache/iotdb/db/query/udf/builtin/UDTFAbs.java | 2 +- .../iotdb/db/query/udf/builtin/UDTFCast.java | 2 +- .../query/udf/builtin/UDTFContinuouslySatisfy.java | 2 +- .../iotdb/db/query/udf/builtin/UDTFDerivative.java | 2 +- .../udf/builtin/UDTFEqualSizeBucketAggSample.java | 487 ++ .../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 238 + .../builtin/UDTFEqualSizeBucketOutlierSample.java | 834 ++++ .../builtin/UDTFEqualSizeBucketRandomSample.java | 68 + .../udf/builtin/UDTFEqualSizeBucketSample.java | 48 + .../iotdb/db/query/udf/builtin/UDTFInRange.java | 2 +- .../iotdb/db/query/udf/builtin/UDTFMath.java | 2 +- .../iotdb/db/query/udf/builtin/UDTFOnOff.java | 2 +- .../iotdb/db/query/udf/builtin/UDTFSelectK.java | 2 +- .../db/query/udf/builtin/UDTFValueDifference.java | 2 +- .../db/query/udf/core/executor/UDTFContext.java | 60 + .../db/query/udf/core/executor/UDTFExecutor.java | 2 +- .../udf/core/layer/ConstantIntermediateLayer.java | 2 +- .../iotdb/db/query/udf/core/layer/DAGBuilder.java | 9 +- .../query/udf/core/layer/EvaluationDAGBuilder.java | 100 + .../query/udf/core/layer/LayerMemoryAssigner.java | 2 +- .../layer/MultiInputColumnIntermediateLayer.java | 14 + .../query/udf/core/layer/RawQueryInputLayer.java | 143 +- ...InputColumnMultiReferenceIntermediateLayer.java | 14 + ...nputColumnSingleReferenceIntermediateLayer.java | 14 + .../query/udf/core/layer/TsBlockInputDataSet.java | 64 + .../udf/core/reader/ConstantLayerPointReader.java | 2 +- .../transformer/ArithmeticAdditionTransformer.java | 35 - .../transformer/ArithmeticBinaryTransformer.java | 41 - .../transformer/ArithmeticDivisionTransformer.java | 35 - .../transformer/ArithmeticModuloTransformer.java | 35 - .../ArithmeticMultiplicationTransformer.java | 35 - .../transformer/ArithmeticNegationTransformer.java | 76 - .../ArithmeticSubtractionTransformer.java | 35 - .../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 - .../db/query/udf/core/transformer/Transformer.java | 2 +- .../core/transformer/TransparentTransformer.java | 93 - .../core/transformer/UDFQueryRowTransformer.java | 49 - .../transformer/UDFQueryRowWindowTransformer.java | 47 - .../udf/core/transformer/UDFQueryTransformer.java | 111 - .../binary/ArithmeticAdditionTransformer.java | 35 + .../binary/ArithmeticBinaryTransformer.java | 49 + .../binary/ArithmeticDivisionTransformer.java | 35 + .../binary/ArithmeticModuloTransformer.java | 35 + .../ArithmeticMultiplicationTransformer.java | 35 + .../binary/ArithmeticSubtractionTransformer.java | 35 + .../core/transformer/binary/BinaryTransformer.java | 125 + .../binary/CompareBinaryTransformer.java | 49 + .../binary/CompareEqualToTransformer.java | 56 + .../binary/CompareGreaterEqualTransformer.java | 35 + .../binary/CompareGreaterThanTransformer.java | 35 + .../binary/CompareLessEqualTransformer.java | 35 + .../binary/CompareLessThanTransformer.java | 35 + .../binary/CompareNonEqualTransformer.java | 56 + .../transformer/binary/LogicAndTransformer.java | 33 + .../transformer/binary/LogicBinaryTransformer.java | 54 + .../transformer/binary/LogicOrTransformer.java | 34 + .../transformer/multi/UDFQueryRowTransformer.java | 49 + .../multi/UDFQueryRowWindowTransformer.java | 47 + .../transformer/multi/UDFQueryTransformer.java | 112 + .../unary/ArithmeticNegationTransformer.java | 59 + .../udf/core/transformer/unary/InTransformer.java | 233 + .../transformer/unary/LogicNotTransformer.java | 48 + .../core/transformer/unary/RegularTransformer.java | 58 + .../transformer/unary/TransparentTransformer.java | 70 + .../core/transformer/unary/UnaryTransformer.java | 62 + .../query/udf/service/UDFRegistrationService.java | 2 +- .../java/org/apache/iotdb/db/service/DataNode.java | 272 +- .../iotdb/db/service/DataNodeManagementServer.java | 102 - .../db/service/DataNodeManagementServerMBean.java | 22 - .../iotdb/db/service/InfluxDBRPCService.java | 5 - .../apache/iotdb/db/service/InternalService.java | 60 +- .../iotdb/db/service/InternalServiceImpl.java | 144 - .../iotdb/db/service/InternalServiceMBean.java | 22 + .../java/org/apache/iotdb/db/service/IoTDB.java | 50 +- .../apache/iotdb/db/service/IoTDBShutdownHook.java | 8 +- .../org/apache/iotdb/db/service/RPCService.java | 17 +- .../org/apache/iotdb/db/service/SettleService.java | 4 +- .../iotdb/db/service/basic/ServiceProvider.java | 2 +- .../iotdb/db/service/metrics/MetricsService.java | 4 +- .../handler/DataNodeManagementServiceHandler.java | 58 - .../handler/InternalServiceThriftHandler.java | 44 + .../thrift/handler/RPCServiceThriftHandler.java | 10 +- .../thrift/impl/DataNodeManagementServiceImpl.java | 56 - .../thrift/impl/DataNodeTSIServiceImpl.java | 860 ++++ .../service/thrift/impl/InfluxDBServiceImpl.java | 46 +- .../service/thrift/impl/InternalServiceImpl.java | 241 + .../db/service/thrift/impl/TSIEventHandler.java | 25 + .../db/service/thrift/impl/TSServiceImpl.java | 338 +- .../apache/iotdb/db/sync/conf/SyncConstant.java | 85 +- .../apache/iotdb/db/sync/conf/SyncPathUtil.java | 143 + .../iotdb/db/sync/conf/SyncSenderConfig.java | 127 - .../iotdb/db/sync/conf/SyncSenderDescriptor.java | 124 - .../org/apache/iotdb/db/sync/package-info.java | 38 - .../iotdb/db/sync/pipedata/DeletionPipeData.java | 85 + .../apache/iotdb/db/sync/pipedata/PipeData.java | 96 + .../iotdb/db/sync/pipedata/SchemaPipeData.java | 98 + .../iotdb/db/sync/pipedata/TsFilePipeData.java | 177 + .../sync/pipedata/queue/BufferedPipeDataQueue.java | 446 ++ .../db/sync/pipedata/queue/PipeDataQueue.java | 39 + .../sync/pipedata/queue/PipeDataQueueFactory.java | 57 + .../iotdb/db/sync/receiver/ReceiverService.java | 300 ++ .../iotdb/db/sync/receiver/SyncServerManager.java | 129 - .../db/sync/receiver/SyncServerManagerMBean.java | 34 - .../db/sync/receiver/SyncServerThriftHandler.java | 56 - .../db/sync/receiver/collector/Collector.java | 170 + .../db/sync/receiver/load/DeletionLoader.java | 48 + .../iotdb/db/sync/receiver/load/FileLoader.java | 203 - .../db/sync/receiver/load/FileLoaderManager.java | 213 - .../iotdb/db/sync/receiver/load/IFileLoader.java | 50 - .../iotdb/db/sync/receiver/load/ILoadLogger.java | 57 - .../iotdb/db/sync/receiver/load/ILoader.java | 29 + .../iotdb/db/sync/receiver/load/LoadLogger.java | 72 - .../iotdb/db/sync/receiver/load/LoadType.java | 25 - .../iotdb/db/sync/receiver/load/SchemaLoader.java | 60 + .../iotdb/db/sync/receiver/load/TsFileLoader.java | 67 + .../iotdb/db/sync/receiver/manager/PipeInfo.java | 85 + .../db/sync/receiver/manager/PipeMessage.java | 76 + .../db/sync/receiver/manager/ReceiverManager.java | 227 + .../receiver/recover/ISyncReceiverLogAnalyzer.java | 33 - .../sync/receiver/recover/ISyncReceiverLogger.java | 50 - .../receiver/recover/SyncReceiverLogAnalyzer.java | 154 - .../sync/receiver/recover/SyncReceiverLogger.java | 72 - .../db/sync/receiver/recovery/ReceiverLog.java | 127 + .../receiver/recovery/ReceiverLogAnalyzer.java | 153 + .../db/sync/receiver/transfer/SyncServiceImpl.java | 370 -- .../db/sync/sender/manage/ISyncFileManager.java | 72 - .../db/sync/sender/manage/SyncFileManager.java | 291 -- .../db/sync/sender/manager/SchemaSyncManager.java | 147 + .../db/sync/sender/manager/TsFileSyncManager.java | 106 + .../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 113 + .../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 116 + .../apache/iotdb/db/sync/sender/pipe/PipeSink.java | 47 + .../iotdb/db/sync/sender/pipe/TsFilePipe.java | 400 ++ .../sender/recover/ISyncSenderLogAnalyzer.java | 47 - .../db/sync/sender/recover/ISyncSenderLogger.java | 67 - .../sync/sender/recover/SyncSenderLogAnalyzer.java | 128 - .../db/sync/sender/recover/SyncSenderLogger.java | 72 - .../db/sync/sender/recovery/SenderLogAnalyzer.java | 165 + .../db/sync/sender/recovery/SenderLogger.java | 141 + .../db/sync/sender/recovery/TsFilePipeLogger.java | 155 + .../iotdb/db/sync/sender/service/MsgManager.java | 114 + .../db/sync/sender/service/SenderService.java | 392 ++ .../db/sync/sender/service/TransportHandler.java | 152 + .../iotdb/db/sync/sender/transfer/ISyncClient.java | 95 - .../iotdb/db/sync/sender/transfer/SyncClient.java | 810 ---- .../db/sync/transport/client/ITransportClient.java | 28 + .../db/sync/transport/client/TransportClient.java | 545 +++ .../db/sync/transport/conf/TransportConfig.java | 45 + .../db/sync/transport/conf/TransportConstant.java | 36 + .../transport/server/TransportServerManager.java | 124 + .../server/TransportServerManagerMBean.java | 34 + .../server/TransportServerThriftHandler.java | 52 + .../transport/server/TransportServiceImpl.java | 398 ++ .../apache/iotdb/db/tools/TsFileRewriteTool.java | 4 +- .../apache/iotdb/db/tools/TsFileSketchTool.java | 6 +- .../org/apache/iotdb/db/tools/TsFileSplitTool.java | 2 +- .../java/org/apache/iotdb/db/tools/WalChecker.java | 2 +- .../db/tools/dataregion/DeviceMappingViewer.java | 4 +- .../org/apache/iotdb/db/tools/mlog/MLogParser.java | 251 -- .../apache/iotdb/db/tools/schema/MLogParser.java | 251 ++ .../db/tools/schema/SchemaFileSketchTool.java | 165 + .../db/tools/settle/TsFileAndModSettleTool.java | 2 +- .../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 2 +- .../org/apache/iotdb/db/utils/DataTypeUtils.java | 8 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 374 -- .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 8 +- .../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +- .../apache/iotdb/db/utils/QueryDataSetUtils.java | 96 +- .../org/apache/iotdb/db/utils/SchemaTestUtils.java | 39 - .../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +- .../java/org/apache/iotdb/db/utils/SyncUtils.java | 109 - .../timerangeiterator/AggrWindowIterator.java | 38 +- .../timerangeiterator/ITimeRangeIterator.java | 8 +- .../timerangeiterator/PreAggrWindowIterator.java | 38 +- .../PreAggrWindowWithNaturalMonthIterator.java | 50 +- .../SingleTimeWindowIterator.java | 65 + .../iotdb/db/utils/writelog/BatchLogReader.java | 2 +- .../java/org/apache/iotdb/db/wal/WALManager.java | 33 +- .../iotdb/db/wal/buffer/AbstractWALBuffer.java | 5 - .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 148 +- .../org/apache/iotdb/db/wal/buffer/WALEntry.java | 11 +- .../apache/iotdb/db/wal/buffer/WALEntryType.java | 4 +- .../iotdb/db/wal/checkpoint/CheckpointManager.java | 28 + .../java/org/apache/iotdb/db/wal/io/WALReader.java | 2 +- .../org/apache/iotdb/db/wal/node/IWALNode.java | 4 +- .../org/apache/iotdb/db/wal/node/WALFakeNode.java | 4 +- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 93 +- .../iotdb/db/wal/recover/WALNodeRecoverTask.java | 8 +- .../iotdb/db/wal/recover/WALRecoverManager.java | 7 +- .../db/wal/recover/file/TsFilePlanRedoer.java | 57 +- .../file/UnsealedTsFileRecoverPerformer.java | 7 +- .../apache/iotdb/db/wal/utils/WALWriteUtils.java | 42 + .../wal/utils/listener/AbstractResultListener.java | 2 +- .../apache/iotdb/db/auth/AuthorityCheckerTest.java | 4 +- .../iotdb/db/engine/MetadataManagerHelper.java | 2 +- .../db/engine/cache/BloomFilterCacheTest.java | 5 +- .../iotdb/db/engine/cache/ChunkCacheTest.java | 4 +- .../engine/compaction/AbstractCompactionTest.java | 4 +- .../engine/compaction/CompactionSchedulerTest.java | 4 +- .../compaction/CompactionTaskManagerTest.java | 2 +- .../ReadPointCompactionPerformerTest.java | 6 +- .../compaction/TestUtilsForAlignedSeries.java | 4 +- .../cross/CrossSpaceCompactionExceptionTest.java | 2 +- .../compaction/cross/CrossSpaceCompactionTest.java | 77 +- .../db/engine/compaction/cross/MergeTest.java | 4 +- .../cross/RewriteCompactionFileSelectorTest.java | 29 +- .../RewriteCrossSpaceCompactionRecoverTest.java | 2 +- .../cross/RewriteCrossSpaceCompactionTest.java | 6 +- .../inner/AbstractInnerSpaceCompactionTest.java | 4 +- .../inner/InnerCompactionEmptyTsFileTest.java | 89 + .../inner/InnerCompactionMoreDataTest.java | 4 +- .../inner/InnerCompactionSchedulerTest.java | 2 +- .../compaction/inner/InnerCompactionTest.java | 87 +- .../compaction/inner/InnerSeqCompactionTest.java | 6 +- .../compaction/inner/InnerUnseqCompactionTest.java | 4 +- .../ReadChunkCompactionPerformerAlignedTest.java | 2 +- .../ReadChunkCompactionPerformerNoAlignedTest.java | 4 +- .../inner/ReadChunkCompactionPerformerOldTest.java | 4 +- .../SizeTieredCompactionRecoverTest.java | 2 +- .../inner/sizetiered/SizeTieredCompactionTest.java | 4 +- ...eCrossSpaceCompactionRecoverCompatibleTest.java | 4 +- .../SizeTieredCompactionRecoverCompatibleTest.java | 2 +- .../recover/SizeTieredCompactionRecoverTest.java | 4 +- .../compaction/utils/CompactionCheckerUtils.java | 6 +- .../utils/CompactionFileGeneratorUtils.java | 10 +- .../db/engine/memtable/MemTableFlushTaskTest.java | 2 +- .../db/engine/memtable/MemTableTestUtils.java | 4 +- .../db/engine/memtable/MemtableBenchmark.java | 4 +- .../db/engine/memtable/PrimitiveMemTableTest.java | 6 +- .../engine/modification/DeletionFileNodeTest.java | 4 +- .../db/engine/modification/DeletionQueryTest.java | 4 +- .../engine/modification/ModificationFileTest.java | 2 +- .../io/LocalTextModificationAccessorTest.java | 2 +- .../db/engine/storagegroup/DataRegionTest.java | 922 ++++ .../storagegroup/FileNodeManagerBenchmark.java | 4 +- .../storagegroup/StorageGroupProcessorTest.java | 6 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 6 +- .../db/engine/storagegroup/TsFileManagerTest.java | 2 +- .../engine/storagegroup/TsFileProcessorTest.java | 23 +- .../engine/storagegroup/TsFileProcessorV2Test.java | 482 ++ .../dataregion/HashVirtualPartitionerTest.java | 4 +- .../apache/iotdb/db/metadata/MetaUtilsTest.java | 84 +- .../apache/iotdb/db/metadata/PartialPathTest.java | 4 +- .../iotdb/db/metadata/SchemaAdvancedTest.java | 4 +- .../apache/iotdb/db/metadata/SchemaBasicTest.java | 30 +- .../iotdb/db/metadata/SchemaImproveTest.java | 6 +- .../org/apache/iotdb/db/metadata/TemplateTest.java | 6 +- .../db/metadata/cache/DataNodeSchemaCacheTest.java | 95 + .../db/metadata/idtable/IDTableFlushTimeTest.java | 6 +- .../db/metadata/idtable/IDTableLogFileTest.java | 2 +- .../db/metadata/idtable/IDTableRecoverTest.java | 4 +- .../idtable/IDTableResourceControlTest.java | 6 +- .../db/metadata/idtable/IDTableRestartTest.java | 4 +- .../iotdb/db/metadata/idtable/IDTableTest.java | 6 +- .../db/metadata/idtable/InsertWithIDTableTest.java | 6 +- .../db/metadata/idtable/LastQueryWithIDTable.java | 6 +- .../QueryAlignedTimeseriesWithIDTableTest.java | 6 +- .../db/metadata/idtable/QueryWithIDTableTest.java | 6 +- .../db/metadata/idtable/entry/DeviceIDTest.java | 4 +- .../db/metadata/idtable/entry/SchemaEntryTest.java | 2 +- .../apache/iotdb/db/metadata/mnode/MNodeTest.java | 4 +- .../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 53 +- .../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 22 +- .../db/metadata/mtree/disk/MemManagerTest.java | 2 +- .../metadata/mtree/schemafile/RecordUtilTests.java | 2 +- .../metadata/mtree/schemafile/SchemaFileTest.java | 15 +- .../metadata/mtree/schemafile/SchemaPageTest.java | 3 +- .../db/metadata/mtree/schemafile/SegmentTest.java | 7 +- .../schemaregion/rocksdb/MRocksDBUnitTest.java | 238 - .../rocksdb/RSchemaRegionAdvancedTest.java | 167 - .../rocksdb/RocksDBBenchmarkEngine.java | 153 - .../db/metadata/upgrade/MetadataUpgradeTest.java | 11 +- .../iotdb/db/mpp/aggregation/AccumulatorTest.java | 349 ++ .../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 -- .../mpp/common/schematree/PathPatternTreeTest.java | 193 + .../db/mpp/common/schematree/SchemaTreeTest.java | 538 +++ .../db/mpp/execution/ConfigExecutionTest.java | 171 + .../iotdb/db/mpp/execution/DataDriverTest.java | 67 +- .../db/mpp/execution/QueryStateMachineTest.java | 1 + .../datatransfer/DataBlockManagerTest.java | 121 + .../datatransfer/LocalSinkHandleTest.java | 153 + .../datatransfer/LocalSourceHandleTest.java | 119 + .../datatransfer/SharedTsBlockQueueTest.java | 160 + .../mpp/execution/datatransfer/SinkHandleTest.java | 527 +++ .../execution/datatransfer/SourceHandleTest.java | 641 +++ .../mpp/execution/datatransfer/StubSinkHandle.java | 99 + .../iotdb/db/mpp/execution/datatransfer/Utils.java | 112 + .../db/mpp/execution/memory/MemoryPoolTest.java | 275 ++ .../execution/operator/DeviceViewOperatorTest.java | 198 + .../mpp/execution/operator/LimitOperatorTest.java | 188 + .../execution/operator/MultiColumnMergerTest.java | 208 + .../mpp/execution/operator/OffsetOperatorTest.java | 391 ++ .../operator/SeriesAggregateScanOperatorTest.java | 485 ++ .../execution/operator/SeriesScanOperatorTest.java | 135 + .../execution/operator/SingleColumnMergerTest.java | 210 + .../execution/operator/TimeJoinOperatorTest.java | 414 ++ .../operator/schema/CountMergeOperatorTest.java | 193 + .../operator/schema/SchemaCountOperatorTest.java | 231 + .../operator/schema/SchemaFetchOperatorTest.java | 149 + .../operator/schema/SchemaScanOperatorTest.java | 253 ++ .../schedule/DefaultTaskSchedulerTest.java | 399 ++ .../execution/schedule/DriverSchedulerTest.java | 164 + .../DriverTaskTimeoutSentinelThreadTest.java | 269 ++ .../schedule/queue/L1PriorityQueueTest.java | 182 + .../schedule/queue/L2PriorityQueueTest.java | 196 + .../mpp/execution/schedule/queue/QueueElement.java | 80 + .../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 - .../iotdb/db/mpp/plan/analyze/AnalyzerTest.java | 62 + .../iotdb/db/mpp/plan/parser/ASTVisitorTest.java | 41 + .../db/mpp/plan/parser/StatementGeneratorTest.java | 76 + .../db/mpp/plan/plan/DistributionPlannerTest.java | 523 +++ .../db/mpp/plan/plan/FragmentInstanceIdTest.java | 38 + .../mpp/plan/plan/FragmentInstanceSerdeTest.java | 164 + .../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 473 ++ .../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 714 +++ .../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 96 + .../plan/plan/node/PlanNodeDeserializeHelper.java | 37 + .../read/DeviceSchemaScanNodeSerdeTest.java | 77 + .../metadata/read/SchemaCountNodeSerdeTest.java | 92 + .../read/TimeSeriesSchemaScanNodeSerdeTest.java | 80 + .../node/process/AggregationNodeSerdeTest.java | 89 + .../plan/node/process/DeviceViewNodeSerdeTest.java | 55 + .../plan/node/process/ExchangeNodeSerdeTest.java | 64 + .../plan/plan/node/process/FillNodeSerdeTest.java | 58 + .../plan/node/process/FilterNodeSerdeTest.java | 58 + .../plan/node/process/FilterNullNodeSerdeTest.java | 58 + .../node/process/GroupByLevelNodeSerdeTest.java | 106 + .../plan/plan/node/process/LimitNodeSerdeTest.java | 67 + .../plan/node/process/OffsetNodeSerdeTest.java | 65 + .../plan/plan/node/process/SortNodeSerdeTest.java | 66 + .../plan/node/process/TimeJoinNodeSerdeTest.java | 81 + .../plan/node/sink/FragmentSinkNodeSerdeTest.java | 56 + .../source/SeriesAggregationScanNodeSerdeTest.java | 79 + .../plan/node/source/SeriesScanNodeSerdeTest.java | 64 + .../write/InsertMultiTabletsNodeSerdeTest.java | 101 + .../plan/node/write/InsertRowNodeSerdeTest.java | 200 + .../plan/node/write/InsertRowsNodeSerdeTest.java | 72 + .../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 81 + .../plan/node/write/InsertTabletNodeSerdeTest.java | 176 + .../plan/node/write/WritePlanNodeSplitTest.java | 278 ++ .../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 - .../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 8 +- .../db/protocol/mqtt/PayloadFormatManagerTest.java | 2 +- .../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 14 +- .../java/org/apache/iotdb/db/qp/PlannerTest.java | 6 +- .../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 4 +- .../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 2 +- .../iotdb/db/qp/physical/ConcatOptimizerTest.java | 4 +- .../iotdb/db/qp/physical/InsertRowPlanTest.java | 6 +- .../qp/physical/InsertRowsOfOneDevicePlanTest.java | 4 +- .../db/qp/physical/InsertTabletMultiPlanTest.java | 4 +- .../iotdb/db/qp/physical/InsertTabletPlanTest.java | 6 +- .../db/qp/physical/PhysicalPlanSerializeTest.java | 4 +- .../iotdb/db/qp/physical/PhysicalPlanTest.java | 40 +- .../iotdb/db/qp/physical/SerializationTest.java | 6 +- .../iotdb/db/qp/physical/SerializedSizeTest.java | 6 +- .../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 2 +- .../dataset/EngineDataSetWithValueFilterTest.java | 5 +- .../iotdb/db/query/dataset/ListDataSetTest.java | 4 +- .../iotdb/db/query/dataset/SingleDataSetTest.java | 4 +- .../query/dataset/UDTFAlignByTimeDataSetTest.java | 4 +- .../query/dataset/groupby/GroupByDataSetTest.java | 4 +- .../dataset/groupby/GroupByLevelDataSetTest.java | 4 +- .../dataset/groupby/GroupByTimeDataSetTest.java | 74 +- .../reader/series/SeriesAggregateReaderTest.java | 2 +- .../reader/series/SeriesReaderByTimestampTest.java | 2 +- .../db/query/reader/series/SeriesReaderTest.java | 6 +- .../query/reader/series/SeriesReaderTestUtil.java | 12 +- .../SerializableBinaryTVListTest.java | 3 +- .../datastructure/SerializableFloatTVListTest.java | 3 +- .../datastructure/SerializableIntTVListTest.java | 3 +- .../datastructure/SerializableLongTVListTest.java | 3 +- .../valuefilter/RawQueryWithValueFilterTest.java | 4 +- .../iotdb/db/rescon/ResourceManagerTest.java | 4 +- .../iotdb/db/service/InternalServiceImplTest.java | 202 +- .../org/apache/iotdb/db/sink/MQTTSinkTest.java | 2 +- .../sync/pipedata/BufferedPipeDataQueueTest.java | 543 +++ .../iotdb/db/sync/pipedata/PipeDataTest.java | 91 + .../db/sync/receiver/load/FileLoaderTest.java | 405 -- .../sync/receiver/manager/ReceiverManagerTest.java | 98 + .../recover/SyncReceiverLogAnalyzerTest.java | 229 - .../receiver/recover/SyncReceiverLoggerTest.java | 115 - .../receiver/recovery/ReceiverLogAnalyzerTest.java | 123 + .../db/sync/sender/manage/SyncFileManagerTest.java | 350 -- .../sender/recover/SyncSenderLogAnalyzerTest.java | 201 - .../sync/sender/recover/SyncSenderLoggerTest.java | 112 - .../db/sync/sender/transfer/SyncClientTest.java | 161 - .../db/sync/transport/TransportServiceTest.java | 208 + .../org/apache/iotdb/db/tools/MLogParserTest.java | 6 +- .../iotdb/db/tools/SchemaFileSketchTest.java | 158 + .../iotdb/db/tools/TsFileAndModSettleToolTest.java | 4 +- .../iotdb/db/tools/TsFileSelfCheckToolTest.java | 8 +- .../org/apache/iotdb/db/tools/WalCheckerTest.java | 2 +- .../apache/iotdb/db/utils/EnvironmentUtils.java | 380 ++ .../iotdb/db/utils/MathQueryDataSetUtilsTest.java | 2 +- .../org/apache/iotdb/db/utils/MemUtilsTest.java | 12 +- .../org/apache/iotdb/db/utils/SchemaTestUtils.java | 39 + .../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 4 +- .../iotdb/db/utils/TimeRangeIteratorTest.java | 230 +- .../iotdb/db/utils/TsFileRewriteToolTest.java | 4 +- .../db/utils/writelog/LogWriterReaderTest.java | 4 +- .../db/utils/writelog/MultiFileLogReaderTest.java | 4 +- .../org/apache/iotdb/db/wal/DisableWALTest.java | 2 +- .../org/apache/iotdb/db/wal/WALManagerTest.java | 16 +- .../iotdb/db/wal/buffer/WALBufferCommonTest.java | 10 +- .../db/wal/checkpoint/CheckpointManagerTest.java | 7 +- .../apache/iotdb/db/wal/io/CheckpointFileTest.java | 6 +- .../org/apache/iotdb/db/wal/io/WALFileTest.java | 9 +- .../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 21 +- .../org/apache/iotdb/db/wal/node/WALNodeTest.java | 32 +- .../db/wal/recover/WALRecoverManagerTest.java | 20 +- .../file/SealedTsFileRecoverPerformerTest.java | 5 +- .../db/wal/recover/file/TsFilePlanRedoerTest.java | 6 +- .../file/UnsealedTsFileRecoverPerformerTest.java | 7 +- .../datanode1conf/iotdb-engine.properties | 37 + .../test/resources/datanode1conf/iotdb-metric.yml | 21 + .../src/test/resources/datanode1conf/logback.xml | 302 ++ .../datanode2conf/iotdb-engine.properties | 37 + .../test/resources/datanode2conf/iotdb-metric.yml | 21 + .../src/test/resources/datanode2conf/logback.xml | 302 ++ .../datanode3conf/iotdb-engine.properties | 37 + .../test/resources/datanode3conf/iotdb-metric.yml | 21 + .../src/test/resources/datanode3conf/logback.xml | 302 ++ server/src/test/resources/iotdb-engine.properties | 4 +- server/src/test/resources/logback-test.xml | 2 +- .../iotdb/rpc/ConfigNodeConnectionException.java | 26 + .../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 3 +- .../org/apache/iotdb/rpc/RedirectException.java | 14 +- .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 19 +- .../iotdb/rpc/StatementExecutionException.java | 4 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 8 +- .../java/org/apache/iotdb/session/Session.java | 52 +- .../apache/iotdb/session/SessionConnection.java | 16 +- .../apache/iotdb/session/util/SessionUtils.java | 12 +- .../apache/iotdb/session/SessionCacheLeaderUT.java | 28 +- spark-iotdb-connector/pom.xml | 2 +- .../apache/iotdb/spark/tsfile/DefaultSource.scala | 2 +- .../iotdb/spark/tsfile/NarrowConverter.scala | 2 +- .../apache/iotdb/spark/tsfile/WideConverter.scala | 4 +- .../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 8 +- thrift-cluster/pom.xml | 5 + thrift-commons/pom.xml | 62 + thrift-commons/src/main/thrift/common.thrift | 70 + thrift-confignode/pom.xml | 2 +- .../src/main/thrift/confignode.thrift | 132 +- thrift-influxdb/src/main/thrift/influxdb.thrift | 36 +- thrift-procedure/pom.xml | 66 + thrift-procedure/src/main/thrift/procedure.thrift | 42 + thrift-sync/src/main/thrift/sync.thrift | 51 - thrift-sync/src/main/thrift/transport.thrift | 90 + thrift/pom.xml | 5 + thrift/src/main/thrift/common.thrift | 48 - thrift/src/main/thrift/management.thrift | 91 - thrift/src/main/thrift/mpp.thrift | 99 +- tsfile/pom.xml | 5 - .../tsfile/common/constant/TsFileConstant.java | 1 + .../iotdb/tsfile/read/TsFileSequenceReader.java | 28 +- .../org/apache/iotdb/tsfile/read/common/Path.java | 2 +- .../apache/iotdb/tsfile/read/common/TimeRange.java | 24 +- .../iotdb/tsfile/read/common/block/TsBlock.java | 182 +- .../tsfile/read/common/block/TsBlockBuilder.java | 20 +- .../block/column/BinaryArrayColumnEncoder.java | 85 + .../read/common/block/column/BinaryColumn.java | 30 + .../common/block/column/BinaryColumnBuilder.java | 32 +- .../read/common/block/column/BooleanColumn.java | 30 + .../common/block/column/BooleanColumnBuilder.java | 32 +- .../block/column/ByteArrayColumnEncoder.java | 68 + .../tsfile/read/common/block/column/Column.java | 14 + .../read/common/block/column/ColumnBuilder.java | 22 +- .../read/common/block/column/ColumnEncoder.java | 78 +- .../common/block/column/ColumnEncoderFactory.java | 2 + .../read/common/block/column/DoubleColumn.java | 30 + .../common/block/column/DoubleColumnBuilder.java | 32 +- .../read/common/block/column/FloatColumn.java | 29 + .../common/block/column/FloatColumnBuilder.java | 26 +- .../block/column/Int32ArrayColumnEncoder.java | 11 +- .../block/column/Int64ArrayColumnEncoder.java | 11 +- .../tsfile/read/common/block/column/IntColumn.java | 29 + .../read/common/block/column/IntColumnBuilder.java | 32 +- .../read/common/block/column/LongColumn.java | 29 + .../common/block/column/LongColumnBuilder.java | 32 +- .../read/common/block/column/NullColumn.java | 50 + .../block/column/RunLengthEncodedColumn.java | 33 +- .../read/common/block/column/TimeColumn.java | 25 + .../common/block/column/TimeColumnBuilder.java | 21 +- .../read/controller/MetadataQuerierByFileImpl.java | 25 +- .../query/dataset/DataSetWithoutTimeGenerator.java | 6 +- .../iotdb/tsfile/read/reader/IPageReader.java | 2 +- .../tsfile/read/reader/page/AlignedPageReader.java | 2 +- .../iotdb/tsfile/read/reader/page/PageReader.java | 3 +- .../apache/iotdb/tsfile/utils/BitConstructor.java | 6 +- .../apache/iotdb/tsfile/utils/ByteArrayList.java | 135 + .../iotdb/tsfile/utils/ReadWriteIOUtils.java | 12 + .../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 146 +- .../tsfile/v2/read/TsFileSequenceReaderForV2.java | 24 +- .../apache/iotdb/tsfile/write/TsFileWriter.java | 12 +- .../iotdb/tsfile/write/writer/TsFileIOWriter.java | 2 +- .../common/block/BinaryArrayColumnEncoderTest.java | 82 + .../common/block/ByteArrayColumnEncoderTest.java | 78 + .../common/block/Int32ArrayColumnEncoderTest.java | 29 +- .../common/block/Int64ArrayColumnEncoderTest.java | 29 +- .../tsfile/common/block/NullColumnUnitTest.java | 120 + .../tsfile/common/block/TsBlockSerdeTest.java | 17 +- .../iotdb/tsfile/common/block/TsBlockTest.java | 61 +- .../apache/iotdb/tsfile/read/TsFileReaderTest.java | 2 +- .../tsfile/read/TsFileSequenceReaderTest.java | 47 + .../iotdb/tsfile/read/common/BatchDataTest.java | 4 +- .../iotdb/tsfile/read/common/ColumnTest.java | 322 ++ .../apache/iotdb/tsfile/read/common/PathTest.java | 10 +- .../org/apache/iotdb/tsfile/write/WriteTest.java | 6 +- .../write/writer/RestorableTsFileIOWriterTest.java | 5 +- zeppelin-interpreter/pom.xml | 1 - 2057 files changed, 129553 insertions(+), 67910 deletions(-) diff --cc confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceHandler.java index 0000000000,ea81ce222f..2bef02d8dc mode 000000,100644..100644 --- a/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceHandler.java +++ b/confignode/src/main/java/org/apache/iotdb/confignode/service/thrift/ConfigNodeRPCServiceHandler.java @@@ -1,0 -1,52 +1,54 @@@ + /* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * - * <p>http://www.apache.org/licenses/LICENSE-2.0 ++ * http://www.apache.org/licenses/LICENSE-2.0 + * - * <p>Unless required by applicable law or agreed to in writing, software distributed under the - * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing permissions and - * limitations under the License. ++ * Unless required by applicable law or agreed to in writing, ++ * software distributed under the License is distributed on an ++ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY ++ * KIND, either express or implied. See the License for the ++ * specific language governing permissions and limitations ++ * under the License. + */ + package org.apache.iotdb.confignode.service.thrift; + + import org.apache.thrift.protocol.TProtocol; + import org.apache.thrift.server.ServerContext; + import org.apache.thrift.server.TServerEventHandler; + import org.apache.thrift.transport.TTransport; + + public class ConfigNodeRPCServiceHandler implements TServerEventHandler { + private final ConfigNodeRPCServiceProcessor processor; + + public ConfigNodeRPCServiceHandler(ConfigNodeRPCServiceProcessor processor) { + this.processor = processor; + } + + @Override + public ServerContext createContext(TProtocol arg0, TProtocol arg1) { + // nothing + return null; + } + + @Override + public void deleteContext(ServerContext arg0, TProtocol arg1, TProtocol arg2) { + // release query resources. + processor.handleClientExit(); + } + + @Override + public void preServe() { + // nothing + } + + @Override + public void processContext(ServerContext arg0, TTransport arg1, TTransport arg2) { + // nothing + } + } diff --cc server/src/main/java/org/apache/iotdb/db/service/thrift/handler/RPCServiceThriftHandler.java index 7a45db0f56,1501402b08..14c8be5108 --- a/server/src/main/java/org/apache/iotdb/db/service/thrift/handler/RPCServiceThriftHandler.java +++ b/server/src/main/java/org/apache/iotdb/db/service/thrift/handler/RPCServiceThriftHandler.java @@@ -7,19 -7,16 +7,19 @@@ * "License"); you may not use this file except in compliance * with the License. You may obtain a copy of the License at * - * <p>http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * - * <p>Unless required by applicable law or agreed to in writing, software distributed under the - * License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either - * express or implied. See the License for the specific language governing permissions and - * limitations under the License. + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. */ + package org.apache.iotdb.db.service.thrift.handler; - import org.apache.iotdb.db.service.thrift.impl.TSServiceImpl; + import org.apache.iotdb.db.service.thrift.impl.TSIEventHandler; import org.apache.thrift.protocol.TProtocol; import org.apache.thrift.server.ServerContext; diff --cc tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitConstructor.java index 1ffcf95fe8,7800fa9831..5441c85071 --- a/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitConstructor.java +++ b/tsfile/src/main/java/org/apache/iotdb/tsfile/utils/BitConstructor.java @@@ -16,11 -16,8 +16,9 @@@ * specific language governing permissions and limitations * under the License. */ + package org.apache.iotdb.tsfile.utils; - import org.eclipse.collections.impl.list.mutable.primitive.ByteArrayList; - public class BitConstructor { private static final int BITS_IN_A_BYTE = 8;
