This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch lmh/udfSemanticCheck in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ac7ea772d60d86bcf4034ffb64066ea237eb488c Merge: 2072575d49 0eb5010414 Author: Minghui Liu <[email protected]> AuthorDate: Mon Jun 27 14:34:38 2022 +0800 Merge remote-tracking branch 'origin/master' into lmh/udfSemanticCheck .github/workflows/cluster-it.yml | 6 +- .github/workflows/sonar-coveralls.yml | 2 +- .github/workflows/standalone-it-for-mpp.yml | 8 +- README.md | 18 +- README_ZH.md | 17 +- .../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +- .../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 5 +- .../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 3 +- cluster/pom.xml | 228 -- cluster/src/assembly/cluster.xml | 35 - .../resources/conf/iotdb-cluster.properties | 200 -- cluster/src/assembly/resources/sbin/add-node.bat | 133 -- cluster/src/assembly/resources/sbin/add-node.sh | 95 - cluster/src/assembly/resources/sbin/nodetool.bat | 58 - cluster/src/assembly/resources/sbin/nodetool.sh | 48 - .../src/assembly/resources/sbin/remove-node.bat | 110 - cluster/src/assembly/resources/sbin/remove-node.sh | 72 - cluster/src/assembly/resources/sbin/start-node.bat | 136 -- cluster/src/assembly/resources/sbin/start-node.sh | 97 - cluster/src/assembly/resources/sbin/stop-node.bat | 27 - cluster/src/assembly/resources/sbin/stop-node.sh | 39 - .../java/org/apache/iotdb/cluster/ClientMain.java | 469 ----- .../iotdb/cluster/ClusterFileFlushPolicy.java | 75 - .../org/apache/iotdb/cluster/ClusterIoTDB.java | 675 ------ .../apache/iotdb/cluster/ClusterIoTDBMBean.java | 36 - .../cluster/ClusterIoTDBServerCommandLine.java | 94 - .../apache/iotdb/cluster/RemoteTsFileResource.java | 150 -- .../apache/iotdb/cluster/client/BaseFactory.java | 54 - .../iotdb/cluster/client/ClientCategory.java | 38 - .../apache/iotdb/cluster/client/ClientManager.java | 223 -- .../iotdb/cluster/client/ClientPoolFactory.java | 101 - .../iotdb/cluster/client/IClientManager.java | 35 - .../cluster/client/async/AsyncBaseFactory.java | 68 - .../cluster/client/async/AsyncDataClient.java | 218 -- .../cluster/client/async/AsyncMetaClient.java | 178 -- .../cluster/client/sync/SyncClientAdaptor.java | 527 ----- .../iotdb/cluster/client/sync/SyncDataClient.java | 154 -- .../iotdb/cluster/client/sync/SyncMetaClient.java | 144 -- .../apache/iotdb/cluster/config/ClusterConfig.java | 584 ------ .../iotdb/cluster/config/ClusterConstant.java | 144 -- .../iotdb/cluster/config/ClusterDescriptor.java | 418 ---- .../iotdb/cluster/config/ConsistencyLevel.java | 67 - .../iotdb/cluster/coordinator/Coordinator.java | 807 ------- .../iotdb/cluster/exception/AddSelfException.java | 28 - .../exception/BadSeedUrlFormatException.java | 30 - .../exception/ChangeMembershipException.java | 28 - .../exception/CheckConsistencyException.java | 37 - .../exception/ConfigInconsistentException.java | 29 - .../cluster/exception/EmptyIntervalException.java | 28 - .../cluster/exception/EntryCompactedException.java | 30 - .../exception/EntryUnavailableException.java | 28 - .../GetEntriesWrongParametersException.java | 27 - .../cluster/exception/LeaderUnknownException.java | 31 - .../cluster/exception/LogExecutionException.java | 27 - .../cluster/exception/MemberReadOnlyException.java | 33 - .../cluster/exception/NoHeaderNodeException.java | 31 - .../cluster/exception/NotInSameGroupException.java | 32 - .../cluster/exception/NotManagedSlotException.java | 33 - .../PartitionTableUnavailableException.java | 30 - .../iotdb/cluster/exception/PullFileException.java | 34 - .../cluster/exception/QueryTimeOutException.java | 27 - .../cluster/exception/ReaderNotFoundException.java | 27 - .../cluster/exception/RequestTimeOutException.java | 34 - .../exception/SnapshotInstallationException.java | 37 - .../exception/StartUpCheckFailureException.java | 31 - .../exception/TruncateCommittedEntryException.java | 30 - .../cluster/exception/UnknownLogTypeException.java | 28 - .../exception/UnsupportedPlanException.java | 29 - .../iotdb/cluster/log/CommitLogCallback.java | 48 - .../apache/iotdb/cluster/log/CommitLogTask.java | 65 - .../org/apache/iotdb/cluster/log/HardState.java | 114 - .../java/org/apache/iotdb/cluster/log/Log.java | 145 -- .../org/apache/iotdb/cluster/log/LogApplier.java | 35 - .../apache/iotdb/cluster/log/LogDispatcher.java | 461 ---- .../org/apache/iotdb/cluster/log/LogParser.java | 110 - .../org/apache/iotdb/cluster/log/Snapshot.java | 75 - .../iotdb/cluster/log/StableEntryManager.java | 61 - .../cluster/log/applier/AsyncDataLogApplier.java | 302 --- .../iotdb/cluster/log/applier/BaseApplier.java | 263 --- .../iotdb/cluster/log/applier/DataLogApplier.java | 185 -- .../iotdb/cluster/log/applier/MetaLogApplier.java | 90 - .../iotdb/cluster/log/catchup/CatchUpTask.java | 403 ---- .../iotdb/cluster/log/catchup/LogCatchUpTask.java | 350 --- .../cluster/log/catchup/SnapshotCatchUpTask.java | 159 -- .../iotdb/cluster/log/logtypes/AddNodeLog.java | 136 -- .../iotdb/cluster/log/logtypes/CloseFileLog.java | 124 -- .../cluster/log/logtypes/EmptyContentLog.java | 63 - .../iotdb/cluster/log/logtypes/LargeTestLog.java | 78 - .../cluster/log/logtypes/PhysicalPlanLog.java | 115 - .../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 131 -- .../cluster/log/manage/CommittedEntryManager.java | 301 --- .../manage/FilePartitionedSnapshotLogManager.java | 259 --- .../log/manage/MetaSingleSnapshotLogManager.java | 93 - .../log/manage/PartitionedSnapshotLogManager.java | 137 -- .../iotdb/cluster/log/manage/RaftLogManager.java | 1038 --------- .../log/manage/UnCommittedEntryManager.java | 276 --- .../log/manage/serializable/LogManagerMeta.java | 143 -- .../serializable/SyncLogDequeSerializer.java | 1409 ------------- .../iotdb/cluster/log/snapshot/FileSnapshot.java | 641 ------ .../cluster/log/snapshot/MetaSimpleSnapshot.java | 342 --- .../cluster/log/snapshot/PartitionedSnapshot.java | 223 -- .../cluster/log/snapshot/PullSnapshotTask.java | 269 --- .../log/snapshot/PullSnapshotTaskDescriptor.java | 135 -- .../cluster/log/snapshot/SnapshotFactory.java | 28 - .../cluster/log/snapshot/SnapshotInstaller.java | 33 - .../log/snapshot/TimeseriesSchemaSnapshot.java | 31 - .../iotdb/cluster/metadata/CSchemaProcessor.java | 1741 --------------- .../apache/iotdb/cluster/metadata/MetaPuller.java | 452 ---- .../cluster/partition/NodeAdditionResult.java | 37 - .../iotdb/cluster/partition/NodeRemovalResult.java | 61 - .../iotdb/cluster/partition/PartitionGroup.java | 109 - .../iotdb/cluster/partition/PartitionTable.java | 154 -- .../partition/balancer/DefaultSlotBalancer.java | 121 -- .../cluster/partition/balancer/SlotBalancer.java | 43 - .../iotdb/cluster/partition/slot/SlotManager.java | 402 ---- .../partition/slot/SlotNodeAdditionResult.java | 40 - .../partition/slot/SlotNodeRemovalResult.java | 79 - .../cluster/partition/slot/SlotPartitionTable.java | 611 ------ .../iotdb/cluster/partition/slot/SlotStrategy.java | 48 - .../partition/slot/SlotTimePartitionFilter.java | 56 - .../cluster/query/ClusterDataQueryExecutor.java | 325 --- .../cluster/query/ClusterPhysicalGenerator.java | 106 - .../iotdb/cluster/query/ClusterPlanExecutor.java | 923 -------- .../iotdb/cluster/query/ClusterPlanRouter.java | 507 ----- .../apache/iotdb/cluster/query/ClusterPlanner.java | 35 - .../iotdb/cluster/query/ClusterQueryRouter.java | 109 - .../cluster/query/ClusterUDTFQueryExecutor.java | 103 - .../iotdb/cluster/query/LocalQueryExecutor.java | 1066 ---------- .../iotdb/cluster/query/RemoteQueryContext.java | 73 - .../query/aggregate/ClusterAggregateExecutor.java | 107 - .../cluster/query/aggregate/ClusterAggregator.java | 292 --- .../cluster/query/fill/ClusterFillExecutor.java | 104 - .../cluster/query/fill/ClusterLinearFill.java | 80 - .../cluster/query/fill/ClusterPreviousFill.java | 269 --- .../cluster/query/fill/PreviousFillArguments.java | 70 - .../iotdb/cluster/query/filter/SlotSgFilter.java | 47 - .../cluster/query/filter/SlotTsFileFilter.java | 69 - .../groupby/ClusterGroupByNoVFilterDataSet.java | 61 - .../groupby/ClusterGroupByVFilterDataSet.java | 75 - .../query/groupby/MergeGroupByExecutor.java | 143 -- .../query/groupby/RemoteGroupByExecutor.java | 176 -- .../query/last/ClusterLastQueryExecutor.java | 296 --- .../cluster/query/manage/ClusterQueryManager.java | 129 -- .../query/manage/ClusterSessionManager.java | 138 -- .../cluster/query/manage/QueryCoordinator.java | 66 - .../cluster/query/reader/ClusterReaderFactory.java | 1229 ----------- .../cluster/query/reader/ClusterTimeGenerator.java | 217 -- .../iotdb/cluster/query/reader/DataSourceInfo.java | 272 --- .../iotdb/cluster/query/reader/EmptyReader.java | 172 -- .../reader/ManagedDescPriorityMergeReader.java | 96 - .../query/reader/ManagedPriorityMergeReader.java | 94 - .../cluster/query/reader/MergedReaderByTime.java | 47 - .../reader/RemoteSeriesReaderByTimestamp.java | 122 -- .../query/reader/RemoteSimpleSeriesReader.java | 167 -- .../query/reader/mult/AbstractMultPointReader.java | 70 - .../mult/AssignPathAscPriorityMergeReader.java | 49 - .../mult/AssignPathDescPriorityMergeReader.java | 49 - .../reader/mult/AssignPathManagedMergeReader.java | 121 -- .../mult/IAssignPathPriorityMergeReader.java | 47 - .../query/reader/mult/IMultBatchReader.java | 31 - .../cluster/query/reader/mult/MultBatchReader.java | 74 - .../query/reader/mult/MultDataSourceInfo.java | 270 --- .../cluster/query/reader/mult/MultElement.java | 49 - .../reader/mult/MultSeriesRawDataPointReader.java | 55 - .../query/reader/mult/RemoteMultSeriesReader.java | 227 -- .../iotdb/cluster/server/ClusterRPCService.java | 110 - .../iotdb/cluster/server/ClusterTSServiceImpl.java | 47 - .../iotdb/cluster/server/HardLinkCleaner.java | 110 - .../apache/iotdb/cluster/server/NodeCharacter.java | 28 - .../cluster/server/PullSnapshotHintService.java | 181 -- .../org/apache/iotdb/cluster/server/Response.java | 63 - .../iotdb/cluster/server/StoppedMemberManager.java | 160 -- .../server/basic/ClusterServiceProvider.java | 95 - .../server/clusterinfo/ClusterInfoServer.java | 90 - .../server/clusterinfo/ClusterInfoServerMBean.java | 22 - .../server/clusterinfo/ClusterInfoServiceImpl.java | 71 - .../ClusterInfoServiceThriftHandler.java | 55 - .../handlers/caller/AppendGroupEntryHandler.java | 157 -- .../handlers/caller/AppendNodeEntryHandler.java | 187 -- .../server/handlers/caller/ElectionHandler.java | 167 -- .../server/handlers/caller/GenericHandler.java | 94 - .../caller/GetChildNodeNextLevelHandler.java | 59 - .../caller/GetChildNodeNextLevelPathHandler.java | 60 - .../server/handlers/caller/GetDevicesHandler.java | 60 - .../handlers/caller/GetNodesListHandler.java | 59 - .../caller/GetTimeseriesSchemaHandler.java | 59 - .../server/handlers/caller/HeartbeatHandler.java | 156 -- .../server/handlers/caller/JoinClusterHandler.java | 65 - .../server/handlers/caller/LogCatchUpHandler.java | 115 - .../handlers/caller/LogCatchUpInBatchHandler.java | 111 - .../server/handlers/caller/NodeStatusHandler.java | 59 - .../handlers/caller/PreviousFillHandler.java | 101 - .../caller/PullMeasurementSchemaHandler.java | 78 - .../handlers/caller/PullSnapshotHandler.java | 81 - .../caller/PullTimeseriesSchemaHandler.java | 73 - .../handlers/caller/ShowTimeSeriesHandler.java | 121 -- .../handlers/caller/SnapshotCatchUpHandler.java | 61 - .../server/handlers/caller/package-info.java | 21 - .../handlers/forwarder/ForwardPlanHandler.java | 68 - .../server/heartbeat/DataHeartbeatThread.java | 68 - .../cluster/server/heartbeat/HeartbeatThread.java | 443 ---- .../server/heartbeat/MetaHeartbeatThread.java | 96 - .../cluster/server/member/DataGroupMember.java | 1164 ---------- .../cluster/server/member/MetaGroupMember.java | 1954 ----------------- .../server/member/MetaGroupMemberMBean.java | 35 - .../iotdb/cluster/server/member/RaftMember.java | 2219 -------------------- .../cluster/server/member/RaftMemberMBean.java | 53 - .../iotdb/cluster/server/member/package-info.java | 24 - .../iotdb/cluster/server/monitor/NodeReport.java | 268 --- .../iotdb/cluster/server/monitor/NodeStatus.java | 118 -- .../cluster/server/monitor/NodeStatusManager.java | 183 -- .../apache/iotdb/cluster/server/monitor/Peer.java | 70 - .../apache/iotdb/cluster/server/monitor/Timer.java | 337 --- .../server/raft/AbstractDataRaftService.java | 54 - .../server/raft/AbstractMetaRaftService.java | 52 - .../cluster/server/raft/AbstractRaftService.java | 76 - .../server/raft/DataRaftHeartBeatService.java | 62 - .../server/raft/DataRaftHeartBeatServiceMBean.java | 22 - .../iotdb/cluster/server/raft/DataRaftService.java | 59 - .../cluster/server/raft/DataRaftServiceMBean.java | 22 - .../server/raft/MetaRaftHeartBeatService.java | 62 - .../server/raft/MetaRaftHeartBeatServiceMBean.java | 22 - .../iotdb/cluster/server/raft/MetaRaftService.java | 59 - .../cluster/server/raft/MetaRaftServiceMBean.java | 22 - .../cluster/server/raft/RaftServiceHandler.java | 43 - .../cluster/server/service/BaseAsyncService.java | 176 -- .../cluster/server/service/BaseSyncService.java | 181 -- .../cluster/server/service/DataAsyncService.java | 503 ----- .../cluster/server/service/DataGroupEngine.java | 510 ----- .../server/service/DataGroupServiceImpls.java | 749 ------- .../cluster/server/service/DataSyncService.java | 458 ---- .../cluster/server/service/MetaAsyncService.java | 255 --- .../cluster/server/service/MetaSyncService.java | 253 --- .../iotdb/cluster/server/service/package-info.java | 24 - .../apache/iotdb/cluster/utils/ClientUtils.java | 66 - .../iotdb/cluster/utils/ClusterConsistent.java | 30 - .../apache/iotdb/cluster/utils/ClusterNode.java | 86 - .../iotdb/cluster/utils/ClusterQueryUtils.java | 84 - .../apache/iotdb/cluster/utils/ClusterUtils.java | 376 ---- .../org/apache/iotdb/cluster/utils/IOUtils.java | 88 - .../iotdb/cluster/utils/NodeSerializeUtils.java | 92 - .../apache/iotdb/cluster/utils/PartitionUtils.java | 184 -- .../apache/iotdb/cluster/utils/PlanSerializer.java | 59 - .../apache/iotdb/cluster/utils/StatusUtils.java | 228 -- .../cluster/utils/nodetool/ClusterMonitor.java | 325 --- .../utils/nodetool/ClusterMonitorMBean.java | 85 - .../iotdb/cluster/utils/nodetool/NodeTool.java | 52 - .../iotdb/cluster/utils/nodetool/Printer.java | 38 - .../cluster/utils/nodetool/function/Header.java | 60 - .../cluster/utils/nodetool/function/LogView.java | 88 - .../cluster/utils/nodetool/function/Migration.java | 59 - .../utils/nodetool/function/NodeToolCmd.java | 145 -- .../cluster/utils/nodetool/function/Partition.java | 102 - .../cluster/utils/nodetool/function/Ring.java | 50 - .../cluster/utils/nodetool/function/Slot.java | 63 - .../cluster/utils/nodetool/function/Status.java | 63 - .../iotdb/cluster/client/BaseClientTest.java | 156 -- .../iotdb/cluster/client/ClientManagerTest.java | 212 -- .../cluster/client/ClientPoolFactoryTest.java | 293 --- .../iotdb/cluster/client/MockClientManager.java | 47 - .../cluster/client/async/AsyncDataClientTest.java | 79 - .../cluster/client/async/AsyncMetaClientTest.java | 78 - .../cluster/client/sync/SyncClientAdaptorTest.java | 464 ---- .../cluster/client/sync/SyncDataClientTest.java | 110 - .../cluster/client/sync/SyncMetaClientTest.java | 110 - .../org/apache/iotdb/cluster/common/IoTDBTest.java | 176 -- .../iotdb/cluster/common/TestAsyncClient.java | 53 - .../iotdb/cluster/common/TestAsyncDataClient.java | 304 --- .../iotdb/cluster/common/TestAsyncMetaClient.java | 50 - .../iotdb/cluster/common/TestDataGroupMember.java | 45 - .../org/apache/iotdb/cluster/common/TestLog.java | 67 - .../iotdb/cluster/common/TestLogApplier.java | 66 - .../iotdb/cluster/common/TestLogManager.java | 39 - .../cluster/common/TestManagedSeriesReader.java | 96 - .../iotdb/cluster/common/TestMetaGroupMember.java | 39 - .../cluster/common/TestPartitionedLogManager.java | 54 - .../apache/iotdb/cluster/common/TestSnapshot.java | 110 - .../iotdb/cluster/common/TestSyncClient.java | 47 - .../org/apache/iotdb/cluster/common/TestUtils.java | 439 ---- .../cluster/integration/BaseSingleNodeTest.java | 90 - .../iotdb/cluster/integration/SingleNodeTest.java | 131 -- .../iotdb/cluster/log/CommitLogCallbackTest.java | 53 - .../iotdb/cluster/log/CommitLogTaskTest.java | 78 - .../apache/iotdb/cluster/log/HardStateTest.java | 49 - .../iotdb/cluster/log/LogDispatcherTest.java | 269 --- .../apache/iotdb/cluster/log/LogParserTest.java | 122 -- .../log/applier/AsyncDataLogApplierTest.java | 174 -- .../cluster/log/applier/DataLogApplierTest.java | 499 ----- .../cluster/log/applier/MetaLogApplierTest.java | 135 -- .../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 398 ---- .../cluster/log/catchup/LogCatchUpTaskTest.java | 301 --- .../log/catchup/SnapshotCatchUpTaskTest.java | 282 --- .../cluster/log/logtypes/SerializeLogTest.java | 146 -- .../log/manage/CommittedEntryManagerTest.java | 625 ------ .../FilePartitionedSnapshotLogManagerTest.java | 117 -- .../manage/MetaSingleSnapshotLogManagerTest.java | 93 - .../cluster/log/manage/RaftLogManagerTest.java | 1889 ----------------- .../log/manage/UnCommittedEntryManagerTest.java | 695 ------ .../serializable/SyncLogDequeSerializerTest.java | 612 ------ .../cluster/log/snapshot/DataSnapshotTest.java | 196 -- .../cluster/log/snapshot/FileSnapshotTest.java | 310 --- .../log/snapshot/MetaSimpleSnapshotTest.java | 346 --- .../log/snapshot/PartitionedSnapshotTest.java | 204 -- .../snapshot/PullSnapshotTaskDescriptorTest.java | 64 - .../cluster/log/snapshot/PullSnapshotTaskTest.java | 337 --- .../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 132 -- .../cluster/partition/SchemaProcessorWhiteBox.java | 54 - .../iotdb/cluster/partition/SlotManagerTest.java | 155 -- .../cluster/partition/SlotPartitionTableTest.java | 546 ----- .../apache/iotdb/cluster/query/BaseQueryTest.java | 125 -- .../query/ClusterAggregateExecutorTest.java | 145 -- .../query/ClusterDataQueryExecutorTest.java | 240 --- .../query/ClusterPhysicalGeneratorTest.java | 72 - .../cluster/query/ClusterPlanExecutorTest.java | 112 - .../iotdb/cluster/query/ClusterPlannerTest.java | 55 - .../cluster/query/ClusterQueryRouterTest.java | 324 --- .../query/ClusterUDTFQueryExecutorTest.java | 121 -- .../iotdb/cluster/query/LoadConfigurationTest.java | 124 -- .../query/fill/ClusterFillExecutorTest.java | 170 -- .../ClusterGroupByNoVFilterDataSetTest.java | 90 - .../groupby/ClusterGroupByVFilterDataSetTest.java | 102 - .../query/groupby/MergeGroupByExecutorTest.java | 117 -- .../query/groupby/RemoteGroupByExecutorTest.java | 171 -- .../query/last/ClusterLastQueryExecutorTest.java | 95 - .../query/manage/ClusterQueryManagerTest.java | 182 -- .../cluster/query/manage/QueryCoordinatorTest.java | 121 -- .../query/reader/ClusterReaderFactoryTest.java | 85 - .../query/reader/ClusterTimeGeneratorTest.java | 134 -- .../cluster/query/reader/DatasourceInfoTest.java | 112 - .../reader/RemoteSeriesReaderByTimestampTest.java | 269 --- .../query/reader/RemoteSimpleSeriesReaderTest.java | 243 --- .../mult/AssignPathManagedMergeReaderTest.java | 208 -- .../mult/MultSeriesRawDataPointReaderTest.java | 67 - .../reader/mult/RemoteMultSeriesReaderTest.java | 346 --- .../server/clusterinfo/ClusterInfoServerTest.java | 99 - .../clusterinfo/ClusterInfoServiceImplTest.java | 100 - .../caller/AppendGroupEntryHandlerTest.java | 188 -- .../caller/AppendNodeEntryHandlerTest.java | 175 -- .../handlers/caller/ElectionHandlerTest.java | 178 -- .../server/handlers/caller/GenericHandlerTest.java | 58 - .../handlers/caller/HeartbeatHandlerTest.java | 121 -- .../handlers/caller/JoinClusterHandlerTest.java | 67 - .../handlers/caller/LogCatchUpHandlerTest.java | 128 -- .../caller/PullMeasurementSchemaHandlerTest.java | 92 - .../handlers/caller/PullSnapshotHandlerTest.java | 84 - .../caller/SnapshotCatchUpHandlerTest.java | 58 - .../handlers/forwarder/ForwardPlanHandlerTest.java | 59 - .../server/heartbeat/DataHeartbeatThreadTest.java | 160 -- .../server/heartbeat/HeartbeatThreadTest.java | 244 --- .../server/heartbeat/MetaHeartbeatThreadTest.java | 244 --- .../iotdb/cluster/server/member/BaseMember.java | 328 --- .../cluster/server/member/DataGroupMemberTest.java | 1255 ----------- .../cluster/server/member/MetaGroupMemberTest.java | 1488 ------------- .../cluster/server/member/RaftMemberTest.java | 246 --- .../cluster/utils/CreateTemplatePlanUtil.java | 74 - .../iotdb/cluster/utils/SerializeUtilTest.java | 210 -- cluster/src/test/resources/logback-test.xml | 41 - .../resources/node1conf/iotdb-cluster.properties | 37 - .../resources/node1conf/iotdb-engine.properties | 30 - .../src/test/resources/node1conf/iotdb-metric.yml | 21 - cluster/src/test/resources/node1conf/logback.xml | 282 --- .../resources/node2conf/iotdb-cluster.properties | 37 - .../resources/node2conf/iotdb-engine.properties | 30 - .../src/test/resources/node2conf/iotdb-metric.yml | 21 - cluster/src/test/resources/node2conf/logback.xml | 282 --- .../resources/node3conf/iotdb-cluster.properties | 37 - .../resources/node3conf/iotdb-engine.properties | 30 - .../src/test/resources/node3conf/iotdb-metric.yml | 21 - cluster/src/test/resources/node3conf/logback.xml | 282 --- .../resources/conf/iotdb-confignode.properties | 10 +- .../assembly/resources/sbin/remove-confignode.sh | 41 +- .../confignode/client/AsyncDataNodeClientPool.java | 10 +- .../client/SyncConfigNodeClientPool.java | 106 +- .../confignode/client/SyncDataNodeClientPool.java | 8 +- .../confignode/conf/ConfigNodeDescriptor.java | 2 +- .../confignode/conf/ConfigNodeRemoveCheck.java | 102 + .../confignode/conf/ConfigNodeStartupCheck.java | 37 +- .../consensus/request/ConfigRequest.java | 16 +- .../consensus/request/ConfigRequestType.java | 6 +- ...LocationsReq.java => GetRegionInfoListReq.java} | 10 +- .../write/AdjustMaxRegionGroupCountReq.java | 89 + .../consensus/request/write/CreateRegionsReq.java | 28 +- .../RemoveConfigNodeReq.java} | 53 +- ...nLocationsResp.java => RegionInfoListResp.java} | 14 +- .../statemachine/PartitionRegionStateMachine.java | 4 +- .../confignode/manager/ClusterSchemaManager.java | 151 +- .../iotdb/confignode/manager/ConfigManager.java | 65 +- .../iotdb/confignode/manager/ConsensusManager.java | 136 +- .../manager/{Manager.java => IManager.java} | 20 +- .../iotdb/confignode/manager/NodeManager.java | 93 +- .../iotdb/confignode/manager/PartitionManager.java | 230 +- .../iotdb/confignode/manager/ProcedureManager.java | 17 +- .../iotdb/confignode/manager/load/LoadManager.java | 34 +- .../manager/load/balancer/PartitionBalancer.java | 6 +- .../manager/load/balancer/RegionBalancer.java | 25 +- .../manager/load/balancer/RouteBalancer.java | 6 +- .../partition/GreedyPartitionAllocator.java | 6 +- .../confignode/persistence/ClusterSchemaInfo.java | 171 +- .../iotdb/confignode/persistence/NodeInfo.java | 29 + .../executor/ConfigRequestExecutor.java | 20 +- .../persistence/partition/PartitionInfo.java | 61 +- .../persistence/partition/RegionGroup.java | 11 +- .../partition/StorageGroupPartitionTable.java | 76 +- .../procedure/env/ConfigNodeProcedureEnv.java | 43 +- .../procedure/impl/AddConfigNodeProcedure.java | 188 ++ .../impl/DeleteStorageGroupProcedure.java | 3 +- .../procedure/state/AddConfigNodeState.java | 8 +- .../procedure/store/ProcedureFactory.java | 9 +- .../iotdb/confignode/service/ConfigNode.java | 49 +- .../confignode/service/ConfigNodeCommandLine.java | 8 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 84 +- .../consensus/request/ConfigRequestSerDeTest.java | 54 +- .../confignode/persistence/PartitionInfoTest.java | 72 +- .../thrift/ConfigNodeRPCServiceProcessorTest.java | 20 +- .../confignode1conf/iotdb-confignode.properties | 2 +- .../confignode2conf/iotdb-confignode.properties | 2 +- .../confignode3conf/iotdb-confignode.properties | 2 +- .../iotdb/consensus/config/MultiLeaderConfig.java | 8 +- .../apache/iotdb/consensus/config/RatisConfig.java | 2 +- .../multileader/MultiLeaderConsensus.java | 2 +- .../multileader/logdispatcher/LogDispatcher.java | 34 +- .../ratis/FileInfoWithDelayedMd5Computing.java | 75 + .../iotdb/consensus/ratis/RatisConsensus.java | 2 +- .../iotdb/consensus/ratis/SnapshotStorage.java | 10 +- .../multileader/MultiLeaderConsensusTest.java | 47 +- distribution/src/assembly/all.xml | 4 +- distribution/src/assembly/server.xml | 4 +- docker/src/main/Dockerfile-cluster | 44 - docker/src/main/Dockerfile-single | 2 +- docker/src/main/Dockerfile-single-influxdb | 4 +- docker/src/main/Dockerfile-single-tc | 2 +- docs/Development/ContributeGuide.md | 14 - docs/Development/HowtoContributeCode.md | 4 +- docs/Download/README.md | 1 + docs/UserGuide/API/Programming-MQTT.md | 8 +- .../Administration-Management/Administration.md | 10 +- docs/UserGuide/Cluster/Cluster-Setup-Example.md | 8 +- docs/UserGuide/Cluster/Cluster-Setup.md | 8 +- docs/UserGuide/Data-Concept/Data-Type.md | 2 +- .../Data-Modeling/SchemaRegion-rocksdb.md | 2 +- .../Ecosystem Integration/Writing Data on HDFS.md | 2 +- .../Integration-Test-refactoring-tutorial.md | 346 ++- docs/UserGuide/Maintenance-Tools/JMX-Tool.md | 2 +- .../Maintenance-Tools/Maintenance-Command.md | 6 +- .../Maintenance-Tools/Monitor-and-Log-Tools.md | 2 +- docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 4 +- docs/UserGuide/Maintenance-Tools/Watermark-Tool.md | 4 +- .../Operate-Metadata/Auto-Create-MetaData.md | 28 +- docs/UserGuide/Process-Data/Triggers.md | 2 +- .../Process-Data/UDF-User-Defined-Function.md | 60 +- docs/UserGuide/Query-Data/Query-Filter.md | 15 + docs/UserGuide/QuickStart/QuickStart.md | 10 +- docs/UserGuide/QuickStart/ServerFileList.md | 4 +- docs/UserGuide/Reference/Config-Manual.md | 8 +- .../Write-And-Delete-Data/Load-External-Tsfile.md | 2 +- docs/zh/Development/HowtoContributeCode.md | 4 +- docs/zh/Download/README.md | 1 + docs/zh/UserGuide/API/Programming-MQTT.md | 6 +- .../Administration-Management/Administration.md | 10 +- docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 10 +- docs/zh/UserGuide/Cluster/Cluster-Setup.md | 12 +- docs/zh/UserGuide/Data-Concept/Data-Type.md | 2 +- .../Data-Modeling/SchemaRegion-rocksdb.md | 2 +- .../Ecosystem Integration/Writing Data on HDFS.md | 2 +- .../Integration-Test-refactoring-tutorial.md | 352 ++-- docs/zh/UserGuide/Maintenance-Tools/JMX-Tool.md | 2 +- .../Maintenance-Tools/Maintenance-Command.md | 6 +- .../Maintenance-Tools/Monitor-and-Log-Tools.md | 2 +- docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 6 +- .../UserGuide/Maintenance-Tools/Watermark-Tool.md | 4 +- .../Operate-Metadata/Auto-Create-MetaData.md | 30 +- docs/zh/UserGuide/Process-Data/Triggers.md | 2 +- .../Process-Data/UDF-User-Defined-Function.md | 63 +- docs/zh/UserGuide/Query-Data/Query-Filter.md | 14 + docs/zh/UserGuide/QuickStart/QuickStart.md | 4 +- docs/zh/UserGuide/QuickStart/ServerFileList.md | 4 +- docs/zh/UserGuide/Reference/Config-Manual.md | 14 +- .../Write-And-Delete-Data/Load-External-Tsfile.md | 2 +- example/mqtt-customize/README.md | 4 +- .../server/CustomizedJsonPayloadFormatter.java | 2 +- example/mqtt/README.md | 2 +- integration-test/pom.xml | 480 ++--- .../src/assembly/mpp-share.xml | 15 +- integration-test/src/assembly/mpp-test.xml | 11 +- .../java/org/apache/iotdb/it/env/AbstractEnv.java | 182 +- .../apache/iotdb/it/env/AbstractNodeWrapper.java | 299 ++- .../org/apache/iotdb/it/env/ConfigNodeWrapper.java | 56 +- .../org/apache/iotdb/it/env/DataNodeWrapper.java | 45 +- .../org/apache/iotdb/it/env/IoTDBTestRunner.java | 7 +- .../org/apache/iotdb/it/env/RemoteServerEnv.java | 7 +- .../iotdb/it/env/StandaloneDataNodeWrapper.java | 5 +- .../apache/iotdb/it/env/StandaloneOnMppEnv.java | 34 +- .../org/apache/iotdb/itbase/env/BaseConfig.java | 4 + .../java/org/apache/iotdb/itbase/env/BaseEnv.java | 4 +- .../apache/iotdb/itbase/env/BaseNodeWrapper.java | 4 + .../InconsistentDataException.java | 7 +- .../exception/ParallelRequestTimeoutException.java | 10 +- .../itbase/runtime/ClusterTestConnection.java | 8 +- .../iotdb/itbase/runtime/ClusterTestStatement.java | 2 +- .../itbase/runtime/ParallelRequestDelegate.java | 8 +- .../iotdb/itbase/runtime/RequestDelegate.java | 7 +- integration-test/src/script/append-to-env.sh | 32 - .../iotdb/db/it/IoTDBCreateTimeseriesIT.java | 257 +++ .../org/apache/iotdb/db/it/IoTDBFilterNullIT.java | 131 ++ .../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 620 ++++++ .../org/apache/iotdb/db/it}/IoTDBTimeZoneIT.java | 32 +- .../it}/aggregation/IoTDBAggregationByLevelIT.java | 323 ++- .../it}/aggregation/IoTDBAggregationDeleteIT.java | 23 +- .../db/it}/aggregation/IoTDBAggregationIT.java | 494 ++--- .../aggregation/IoTDBAggregationLargeDataIT.java | 431 ++-- .../aggregation/IoTDBAggregationSmallDataIT.java | 241 +-- .../db/it/alignbydevice}/IoTDBAlignByDeviceIT.java | 196 +- ...T.java => IoTDBAggregationWithDeletion2IT.java} | 3 +- ...IT.java => IoTDBAggregationWithDeletionIT.java} | 117 +- .../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 1441 +++++++------ .../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +- .../iotdb/db/it/env/StandaloneEnvConfig.java | 5 + .../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 3 - .../iotdb/db/it/udf/IoTDBUDFWindowQueryIT.java | 816 +++++++ .../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 842 ++++++++ .../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 5 +- .../iotdb/db/it/udf/IoTDBUDTFNonAlignQueryIT.java | 350 +++ .../apache/iotdb/integration/env/ClusterNode.java | 4 +- .../iotdb/db/integration/IoTDBAuthorizationIT.java | 10 +- .../db/integration/IoTDBCreateTimeseriesIT.java | 314 --- .../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 --------- .../IoTDBAggregationWithValueFilter2IT.java | 65 - .../aligned/IoTDBAggregationWithValueFilterIT.java | 264 --- ...BAggregationWithValueFilterWithDeletion2IT.java | 85 - ...DBAggregationWithValueFilterWithDeletionIT.java | 221 -- .../main/java/org/apache/iotdb/jdbc/Config.java | 6 + .../org/apache/iotdb/jdbc/IoTDBConnection.java | 34 +- .../apache/iotdb/jdbc/IoTDBConnectionParams.java | 25 + .../src/main/java/org/apache/iotdb/jdbc/Utils.java | 18 + .../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 12 + .../apache/iotdb/commons/client/ClientManager.java | 2 +- ...AsyncDataNodeMPPDataExchangeServiceClient.java} | 26 +- ... SyncDataNodeMPPDataExchangeServiceClient.java} | 28 +- .../iotdb/commons/concurrent/ThreadName.java | 4 +- .../apache/iotdb/commons/conf/IoTDBConstant.java | 3 +- .../org/apache/iotdb/commons/path/PartialPath.java | 32 + .../apache/iotdb/commons/service/ServiceType.java | 2 +- .../commons/udf/service/UDFClassLoaderManager.java | 4 +- .../iotdb/commons/partition/SerializeTest.java | 4 +- .../commons/utils/ThriftCommonsSerDeUtilsTest.java | 8 +- pom.xml | 6 +- schema-engine-rocksdb/README.md | 2 +- .../resources/conf/schema-rocksdb.properties | 8 +- .../schemaregion/rocksdb/RSchemaConfLoader.java | 4 +- .../conf/{iotdb-env.bat => datanode-env.bat} | 2 +- .../conf/{iotdb-env.sh => datanode-env.sh} | 2 +- ...engine.properties => iotdb-datanode.properties} | 22 +- .../src/assembly/resources/sbin/start-datanode.bat | 14 +- .../src/assembly/resources/sbin/start-datanode.sh | 14 +- .../assembly/resources/sbin/start-new-server.bat | 6 +- .../assembly/resources/sbin/start-new-server.sh | 8 +- .../src/assembly/resources/sbin/start-server.bat | 6 +- server/src/assembly/resources/sbin/start-server.sh | 8 +- .../src/assembly/resources/sbin/stop-datanode.bat | 4 +- .../src/assembly/resources/sbin/stop-datanode.sh | 2 +- server/src/assembly/resources/sbin/stop-server.bat | 4 +- server/src/assembly/resources/sbin/stop-server.sh | 2 +- .../assembly/resources/tools/rocksdb-transfer.bat | 6 +- .../assembly/resources/tools/rocksdb-transfer.sh | 8 +- .../assembly/resources/tools/start-WalChecker.sh | 6 +- .../apache/iotdb/db/client/ConfigNodeClient.java | 36 +- .../iotdb/db/client/DataNodeClientPoolFactory.java | 30 +- .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 114 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 80 +- .../db/conf/directories/DirectoryManager.java | 6 + .../db/consensus/DataRegionConsensusImpl.java | 9 + .../apache/iotdb/db/engine/StorageEngineV2.java | 50 +- .../iotdb/db/engine/memtable/AbstractMemTable.java | 8 +- .../apache/iotdb/db/engine/memtable/IMemTable.java | 2 +- .../iotdb/db/engine/snapshot/SnapshotLoader.java | 144 +- .../iotdb/db/engine/snapshot/SnapshotTaker.java | 53 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 76 +- .../metadata/DataTypeMismatchException.java | 8 +- .../metadata/SeriesOverflowException.java | 2 +- .../exception/query/PathNumOverLimitException.java | 2 +- .../iotdb/db/localconfignode/LocalConfigNode.java | 33 +- .../db/metadata/cache/DataNodeSchemaCache.java | 8 +- .../iotdb/db/metadata/cache/SchemaCacheEntry.java | 23 + .../iotdb/db/metadata/mtree/MTreeAboveSG.java | 12 +- .../mtree/snapshot/MemMTreeSnapshotUtil.java | 12 + .../iotdb/db/metadata/rescon/MemoryStatistics.java | 2 +- .../schemaregion/SchemaRegionMemoryImpl.java | 31 +- .../apache/iotdb/db/metadata/tag/TagLogFile.java | 2 +- .../iotdb/db/mpp/aggregation/Accumulator.java | 8 +- .../iotdb/db/mpp/aggregation/Aggregator.java | 9 +- .../iotdb/db/mpp/aggregation/AvgAccumulator.java | 62 +- .../iotdb/db/mpp/aggregation/CountAccumulator.java | 27 +- .../db/mpp/aggregation/ExtremeAccumulator.java | 62 +- .../db/mpp/aggregation/FirstValueAccumulator.java | 110 +- .../mpp/aggregation/FirstValueDescAccumulator.java | 48 +- .../db/mpp/aggregation/LastValueAccumulator.java | 98 +- .../mpp/aggregation/LastValueDescAccumulator.java | 60 +- .../db/mpp/aggregation/MaxTimeAccumulator.java | 13 +- .../db/mpp/aggregation/MaxTimeDescAccumulator.java | 15 +- .../db/mpp/aggregation/MaxValueAccumulator.java | 62 +- .../db/mpp/aggregation/MinTimeAccumulator.java | 15 +- .../db/mpp/aggregation/MinTimeDescAccumulator.java | 13 +- .../db/mpp/aggregation/MinValueAccumulator.java | 62 +- .../iotdb/db/mpp/aggregation/SumAccumulator.java | 62 +- .../slidingwindow/SlidingWindowAggregator.java | 3 +- .../iotdb/db/mpp/common/header/HeaderConstant.java | 6 +- .../iotdb/db/mpp/common/schematree/SchemaTree.java | 22 +- .../common/schematree/node/SchemaEntityNode.java | 22 +- .../common/schematree/node/SchemaInternalNode.java | 22 +- .../schematree/node/SchemaMeasurementNode.java | 22 +- .../db/mpp/common/schematree/node/SchemaNode.java | 5 +- .../datatransfer/DataBlockServiceMBean.java | 34 - .../iotdb/db/mpp/execution/driver/DataDriver.java | 2 +- .../iotdb/db/mpp/execution/driver/Driver.java | 2 +- .../iotdb/db/mpp/execution/driver/IDriver.java | 2 +- .../db/mpp/execution/driver/SchemaDriver.java | 2 +- .../IMPPDataExchangeManager.java} | 8 +- .../IMPPDataExchangeManagerCallback.java} | 4 +- .../{datatransfer => exchange}/ISinkHandle.java | 2 +- .../{datatransfer => exchange}/ISourceHandle.java | 2 +- .../LocalSinkHandle.java | 4 +- .../LocalSourceHandle.java | 13 +- .../MPPDataExchangeManager.java} | 65 +- .../MPPDataExchangeService.java} | 61 +- .../exchange/MPPDataExchangeServiceMBean.java | 5 +- .../MPPDataExchangeServiceThriftHandler.java} | 4 +- .../SharedTsBlockQueue.java | 2 +- .../{datatransfer => exchange}/SinkHandle.java | 25 +- .../{datatransfer => exchange}/SourceHandle.java | 31 +- .../TsBlockSerdeFactory.java | 2 +- .../fragment/FragmentInstanceExecution.java | 2 +- .../operator/process/DeviceMergeOperator.java | 3 + .../operator/process/DeviceViewOperator.java | 3 + .../operator/process/FilterNullOperator.java | 57 - .../execution/operator/process/FilterOperator.java | 137 +- .../process/RawDataAggregationOperator.java | 50 +- .../process/SlidingWindowAggregationOperator.java | 19 +- .../operator/process/TransformOperator.java | 154 +- .../operator/schema/SchemaFetchMergeOperator.java | 52 +- .../operator/schema/SchemaFetchScanOperator.java | 21 +- .../operator/schema/SchemaQueryMergeOperator.java | 43 +- .../operator/sink/FragmentSinkOperator.java | 66 - .../AlignedSeriesAggregationScanOperator.java | 137 +- .../operator/source/ExchangeOperator.java | 2 +- .../source/SeriesAggregationScanOperator.java | 120 +- .../db/mpp/execution/schedule/DriverScheduler.java | 10 +- .../db/mpp/execution/schedule/task/DriverTask.java | 2 +- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 2 +- .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 19 +- .../mpp/plan/analyze/ClusterPartitionFetcher.java | 344 +-- .../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 11 +- .../db/mpp/plan/analyze/ExpressionAnalyzer.java | 4 + .../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 5 + .../mpp/plan/analyze/FakePartitionFetcherImpl.java | 32 +- .../mpp/plan/analyze/GroupByLevelController.java | 13 +- .../db/mpp/plan/constant/DataNodeEndPoints.java | 2 +- .../db/mpp/plan/execution/QueryExecution.java | 30 +- .../mpp/plan/execution/config/ShowRegionTask.java | 23 +- .../plan/execution/memory/MemorySourceHandle.java | 2 +- .../iotdb/db/mpp/plan/expression/Expression.java | 13 +- .../db/mpp/plan/expression/ExpressionType.java | 11 +- .../plan/expression/unary/IsNullExpression.java | 88 + .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 13 + .../db/mpp/plan/planner/LocalExecutionPlanner.java | 31 +- .../db/mpp/plan/planner/LogicalPlanBuilder.java | 16 +- .../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 22 +- .../planner/distribution/DistributionPlanner.java | 2 +- .../SimpleFragmentParallelPlanner.java | 4 +- .../node/metedata/read/SchemaFetchMergeNode.java | 2 +- .../plan/planner/plan/node/process/FilterNode.java | 19 +- .../planner/plan/node/process/TransformNode.java | 30 +- .../statement/component/GroupByLevelComponent.java | 13 + .../db/mpp/plan/statement/component/OrderBy.java | 13 +- .../crud/InsertMultiTabletsStatement.java | 2 +- .../plan/statement/crud/InsertRowStatement.java | 2 +- .../plan/statement/crud/InsertRowsStatement.java | 2 +- .../plan/statement/crud/InsertTabletStatement.java | 2 +- .../db/mpp/plan/statement/crud/QueryStatement.java | 3 +- .../mpp/plan/statement/literal/BooleanLiteral.java | 8 +- .../mpp/plan/statement/literal/DoubleLiteral.java | 6 + .../db/mpp/plan/statement/literal/LongLiteral.java | 6 + .../db/mpp/plan/statement/literal/NullLiteral.java | 6 + .../mpp/transformation/api/LayerPointReader.java | 2 +- .../db/mpp/transformation/api/LayerRowReader.java | 2 +- .../transformation/api/LayerRowWindowReader.java | 2 +- .../db/mpp/transformation/api/YieldableReader.java | 12 +- .../db/mpp/transformation/api/YieldableState.java | 9 +- .../dag/input/ConstantInputReader.java | 8 +- .../dag/input}/IUDFInputDataSet.java | 10 +- .../dag/input/QueryDataSetInputLayer.java | 70 +- .../dag/input/TsBlockInputDataSet.java | 37 +- .../MultiInputColumnIntermediateLayer.java | 355 +++- ...InputColumnMultiReferenceIntermediateLayer.java | 142 ++ ...nputColumnSingleReferenceIntermediateLayer.java | 158 +- .../dag/transformer/Transformer.java | 19 + .../dag/transformer/binary/BinaryTransformer.java | 71 + .../transformer/binary/LogicBinaryTransformer.java | 34 + .../transformer/multi/UDFQueryRowTransformer.java | 15 + .../multi/UDFQueryRowWindowTransformer.java | 12 + .../dag/transformer/multi/UDFQueryTransformer.java | 21 +- ...naryTransformer.java => IsNullTransformer.java} | 47 +- .../dag/transformer/unary/UnaryTransformer.java | 22 + .../mpp/transformation/dag/util/InputRowUtils.java | 2 +- .../transformation/dag/util/LayerCacheUtils.java | 88 +- .../tv/ElasticSerializableTVList.java | 6 + .../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 28 +- .../iotdb/db/query/control/SessionManager.java | 30 +- .../db/query/dataset/AlignByDeviceDataSet.java | 3 +- .../dataset/RawQueryDataSetWithValueFilter.java | 1 + .../iotdb/db/query/dataset/UDFInputDataSet.java | 1 + .../UDFRawQueryInputDataSetWithoutValueFilter.java | 1 + .../db/query/dataset/UDTFAlignByTimeDataSet.java | 1 + .../apache/iotdb/db/query/dataset/UDTFDataSet.java | 1 + .../groupby/impl/LocalAlignedGroupByExecutor.java | 81 +- .../groupby/impl/LocalGroupByExecutor.java | 59 +- .../java/org/apache/iotdb/db/service/DataNode.java | 16 +- .../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 + .../java/org/apache/iotdb/db/service/NewIoTDB.java | 4 +- .../thrift/impl/DataNodeTSIServiceImpl.java | 9 +- .../java/org/apache/iotdb/db/wal/WALManager.java | 24 +- .../allocation/AbstractNodeAllocationStrategy.java | 2 +- .../db/wal/allocation/FirstCreateStrategy.java | 18 +- .../iotdb/db/wal/buffer/AbstractWALBuffer.java | 34 +- .../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 2 +- .../apache/iotdb/db/wal/buffer/SignalWALEntry.java | 2 +- .../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 34 +- .../org/apache/iotdb/db/wal/buffer/WALEntry.java | 22 +- .../iotdb/db/wal/checkpoint/CheckpointManager.java | 16 +- .../iotdb/db/wal/checkpoint/MemTableInfo.java | 24 +- .../apache/iotdb/db/wal/io/CheckpointReader.java | 6 +- .../org/apache/iotdb/db/wal/io/ILogWriter.java | 8 + .../java/org/apache/iotdb/db/wal/io/LogWriter.java | 5 + .../org/apache/iotdb/db/wal/node/IWALNode.java | 10 +- .../org/apache/iotdb/db/wal/node/WALFakeNode.java | 10 +- .../java/org/apache/iotdb/db/wal/node/WALNode.java | 145 +- .../db/wal/recover/CheckpointRecoverUtils.java | 14 +- .../iotdb/db/wal/recover/WALNodeRecoverTask.java | 33 +- .../apache/iotdb/db/wal/utils/WALFileStatus.java | 46 +- .../apache/iotdb/db/wal/utils/WALFileUtils.java | 63 +- .../db/metadata/mtree/disk/MemManagerTest.java | 6 +- .../db/metadata/schemaRegion/SchemaRegionTest.java | 6 +- .../db/mpp/common/schematree/SchemaTreeTest.java | 11 +- .../iotdb/db/mpp/execution/DataDriverTest.java | 2 +- .../LocalSinkHandleTest.java | 10 +- .../LocalSourceHandleTest.java | 4 +- .../MPPDataExchangeManagerTest.java} | 32 +- .../SharedTsBlockQueueTest.java | 24 +- .../{datatransfer => exchange}/SinkHandleTest.java | 42 +- .../SourceHandleTest.java | 51 +- .../{datatransfer => exchange}/StubSinkHandle.java | 2 +- .../{datatransfer => exchange}/Utils.java | 2 +- .../schema/SchemaFetchScanOperatorTest.java | 4 +- .../schedule/DefaultDriverSchedulerTest.java | 36 +- .../execution/schedule/DriverSchedulerTest.java | 13 +- .../mpp/plan/plan/FragmentInstanceSerdeTest.java | 8 +- .../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 24 +- .../iotdb/db/mpp/plan/plan/distribution/Util.java | 4 +- .../plan/node/process/FilterNodeSerdeTest.java | 3 +- .../plan/scheduler/StandaloneSchedulerTest.java | 6 +- ...piServiceIT.java => GrafanaApiServiceTest.java} | 2 +- ...estServiceIT.java => IoTDBRestServiceTest.java} | 2 +- .../org/apache/iotdb/db/script/EnvScriptIT.java | 9 +- .../iotdb/db/service/InternalServiceImplTest.java | 6 +- .../org/apache/iotdb/db/tools/WalCheckerTest.java | 13 +- .../db/wal/checkpoint/CheckpointManagerTest.java | 16 +- .../apache/iotdb/db/wal/io/CheckpointFileTest.java | 8 +- .../org/apache/iotdb/db/wal/io/WALFileTest.java | 7 +- .../iotdb/db/wal/node/ConsensusReqReaderTest.java | 28 +- .../org/apache/iotdb/db/wal/node/WALNodeTest.java | 37 +- .../db/wal/recover/WALRecoverManagerTest.java | 12 +- .../iotdb/db/wal/utils/WALFileUtilsTest.java | 162 +- ...engine.properties => iotdb-datanode.properties} | 4 +- ...engine.properties => iotdb-datanode.properties} | 4 +- ...engine.properties => iotdb-datanode.properties} | 4 +- ...engine.properties => iotdb-datanode.properties} | 2 +- .../java/org/apache/iotdb/rpc/TSStatusCode.java | 6 +- testcontainer/pom.xml | 14 - .../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 4 +- thrift-cluster/pom.xml | 72 - thrift-cluster/rpc-changelist.md | 181 -- thrift-cluster/src/main/thrift/cluster.thrift | 584 ------ thrift-commons/src/main/thrift/common.thrift | 14 +- .../src/main/thrift/confignode.thrift | 12 +- thrift/src/main/thrift/mpp.thrift | 2 +- .../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +- .../read/common/block/column/TimeColumn.java | 4 + 786 files changed, 12233 insertions(+), 76236 deletions(-)
