This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/feature/show_datanodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 428a309c27 fix the line separator problem in ShowClusterStatement class
add c0362c2f4e [IOTDB-2919] Refactor delete storage group (#5994)
add ac0f1be089 [IOTDB-3265] Button Text of Main Features Section Overflow
on Mobile Version Homepage (#6003)
add 4e3e7204d8 [IOTDB-3184] Implement Timeseries version and blacklist
(#5998)
add 796991f75f [IOTDB-3218] Datanode can not be stoped by using
stop-server.sh (#6005)
add a09471f6ba [IOTDB-3236] remove datatypes, encodings, and compressors
from keywords (#5955)
add 5e59402019 [IOTDB-3279] Fix import csv tool error message (#6007)
add 5f8c634848 [IOTDB-3232] Implement read interface for WAL (#5993)
add f35f1133f6 [IOTDB-3237] Too much information in SQL parser error
message (#5984)
add 68c0285527 [IOTDB-3070][IOTDB-3074] modify docs related to syntax
convention (#5983)
add 44885d5a3d [IOTDB-3268] Refactor measurement check logic in session
api for better performance (#5995)
add c115adde55 [IOTDB-3083] DataNode AuthorInfo cache (#5943)
add cde99e33a4 [IOTDB-3253] Upgrade dependency: Ratis from 2.2.0 to 2.3.0
(#5991)
add 039a461cae [IOTDB-3207] Refactor Create Multi timeseries and Apply in
Auto create (#6009)
add 527847ea2b add lastCacheEnable in use. (#5997)
add 20cf75b8cd [IOTDB-3286] False Carousel Ratio on Desktop Version
Homepage (#6012)
add 47a1675af7 [IOTDB-3102] data-sync support ext pipe fwk (#5804)
add cabb8fff2f [IOTDB-3244] Implememtation of LastOperator (#6001)
add 7970bb0fbf [IOTDB-2919] Change regionCleaner work interval from 5s to
300s (#6016)
add 756e876256 Distribution plan for delete timeseries (#6006)
add 3b364a51ae [IOTDB-3281] Replacing log4j with reload4j (#6008)
add aec89d3569 [IOTDB-3290] modify check logic of CreateTimeSeries (#6013)
add 882dbcfc2e [IOTDB-3221] Fix NPE exception when getOrCreatePartition
(#5988)
add c36df17ac3 [IOTDB-3288] Fix user doc of auth module (#6020)
add d7d69709f1 [IOTDB-3227] UDF Management in MPP Cluster: CREATE FUNCTION
(#6014)
add 0f5ab7c02c Revert "[IOTDB-3286] False Carousel Ratio on Desktop
Version Homepage (#6012)" (#6022)
add 1f724c807d [IOTDB-3288] Fix single quotes to backtick. (#6023)
add 790e57ff71 [IOTDB-3283] Implement Analyzer & LogicalPlanner for last
query (#6017)
add 1a972e81e1 renew pictures of 'Structure of Apache IoTDB (#6018)
add ec6eba9305 [IOTDB-3242] Avoid generating same QueryId in different
DataNode (#6015)
add 0d8d00443e [IOTDB-3286] False Carousel Ratio on Desktop Version
Homepage (#6028)
add 1f3152976a [IOTDB-3040] Fix TTL cannot delete the expired tsfile
(#5895)
add 5eb0a8f38e [IOTDB-3294] Update database comparison docs (#6027)
add 5e368d4eef [IOTDB-3081] Implementation of
SlidingWindowAggregationOperator (#5986)
add f78561434d Implement LastPointFetchStatement (#6036)
add 120a8c2fbe [IoTDB-3304] complete last query distribution plan (#6031)
add 8cc2bf6221 [IOTDB-3297] leader interface change (#6024)
add 327e07bf22 Fix Last Query Bug for Aligned (#6038)
add 6387b0e191 [IOTDB-3171] Fix NPE when getting modification file (#6033)
add b535b278dc Improve aligned write in tsfile api (#6021)
add 064c16679d Use cache for last query (#6042)
add 15fa098316 [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException:
Client has an error!Caused by: java.net.ConnectException: Connection refused
(#6043)
add 257ed97251 [IOTDB-3303] Support last query api for new cluster (#6030)
add 4de2073b1f Add GroupbyTimeParameter in GroupByLevelNode (#6044)
add 467243dbd4 [IOTDB-3240] [ErrorMSG]java.lang.IllegalStateException:
Client has an error!Caused by: java.net.ConnectException: Connection refused
(#6049)
add 8675ccb7ce [IOTDB-3129] Fix NPE bug while showing a non-exists
timeseries (#6050)
add 3b900430e8 Update last cache when insert (#6048)
add 3226bb7a74 fix aligned page reader bug (#6054)
add eb9b204475 update show ttl and show storage group. (#6040)
add 982140c9e7 Distribution plan for Align by device and GroupByLevel
(#6053)
add 94bd0fe924 [IOTDB-3258] implement count nodes (#6002)
add 8f68e51bbe [IOTDB-3188] Multi leader consensus algorithm
implementation (#5939)
add 9ae4c88415 combine the byte value with 0xff and cast one of the
operands of addition to long (#5889)
add 2226800133 [IOTDB-3300] Improve measurement check performance for
session api (#6019)
add 6ec70deb51 [IOTDB-3230] Change characters allowed in identifier (#6039)
add c643667761 [IOTDB-3251] ForwardTrigger: support MQTT/HTTP data
forwarding (#5870)
add 652e9a7a76 fix conflict with master
add d94c8a6431 fix conflict with master
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 7 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 24 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 113 ---
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 3 +-
.../resources/conf/iotdb-confignode.properties | 40 +-
.../confignode/client/AsyncDataNodeClientPool.java | 16 +
.../confignode/client/SyncDataNodeClientPool.java | 139 +++
.../client/handlers/CreateFunctionHandler.java | 58 ++
.../iotdb/confignode/conf/ConfigNodeConf.java | 63 +-
.../confignode/conf/ConfigNodeDescriptor.java | 14 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 83 +-
.../consensus/request/ConfigRequest.java | 14 +-
.../consensus/request/ConfigRequestType.java | 5 +-
.../request/read/GetChildPathsPartitionReq.java | 68 --
...itionReq.java => GetNodePathsPartitionReq.java} | 31 +-
.../consensus/request/write/CreateFunctionReq.java | 85 ++
.../request/write/PreDeleteStorageGroupReq.java | 86 ++
.../iotdb/confignode/manager/ConfigManager.java | 103 ++-
.../apache/iotdb/confignode/manager/Manager.java | 23 +-
.../iotdb/confignode/manager/NodeManager.java | 9 +-
.../iotdb/confignode/manager/PartitionManager.java | 61 +-
.../confignode/manager/PermissionManager.java | 79 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../iotdb/confignode/manager/UDFManager.java | 119 +++
.../iotdb/confignode/persistence/AuthorInfo.java | 96 ++-
.../confignode/persistence/ClusterSchemaInfo.java | 15 +
.../confignode/persistence/PartitionInfo.java | 58 +-
.../iotdb/confignode/persistence/UDFInfo.java | 117 +++
.../executor/ConfigRequestExecutor.java | 68 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 112 ++-
.../impl/DeleteStorageGroupProcedure.java | 169 +---
.../procedure/state/DeleteStorageGroupState.java | 7 +-
.../iotdb/confignode/service/ConfigNode.java | 18 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 21 +-
.../consensus/request/ConfigRequestSerDeTest.java | 12 +-
.../confignode/persistence/AuthorInfoTest.java | 10 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 3 +-
.../confignode/persistence/PartitionInfoTest.java | 8 +-
.../confignode/procedure/TestProcedureBase.java | 1 +
.../procedure/TestProcedureExecutor.java | 1 +
.../confignode/procedure/TestSTMProcedure.java | 1 +
.../confignode/procedure/entity/IncProcedure.java | 2 +-
.../confignode/procedure/entity/NoopProcedure.java | 2 +-
.../procedure/entity/SimpleLockProcedure.java | 2 +-
.../procedure/entity/SimpleSTMProcedure.java | 2 +-
.../procedure/entity/SleepProcedure.java | 2 +-
.../procedure/entity/StuckProcedure.java | 2 +-
.../procedure/entity/StuckSTMProcedure.java | 2 +-
.../procedure/env/TestConfigNodeEnv.java | 4 +-
.../procedure/{ => env}/TestProcEnv.java | 2 +-
.../procedure/store/TestProcedureStore.java | 2 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 152 +++-
.../confignode1conf/iotdb-confignode.properties | 11 +-
.../confignode2conf/iotdb-confignode.properties | 3 +-
.../confignode3conf/iotdb-confignode.properties | 3 +-
consensus/README.md | 4 +-
consensus/pom.xml | 7 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 6 +
.../org/apache/iotdb/consensus/common/Peer.java | 15 +
.../common/request/IndexedConsensusRequest.java | 88 ++
.../common/response/ConsensusReadResponse.java | 6 +-
.../common/response/ConsensusResponse.java | 2 +-
.../exception/IllegalPeerEndpointException.java | 9 +-
.../exception/IllegalPeerNumException.java | 4 +-
.../MultiLeaderConsensus.java} | 93 +-
.../multileader/MultiLeaderServerImpl.java | 186 ++++
.../client/AsyncMultiLeaderServiceClient.java | 145 ++++
.../multileader/client/DispatchLogHandler.java | 100 +++
.../client/MultiLeaderConsensusClientPool.java | 54 ++
.../conf/MultiLeaderConsensusConfig.java | 40 +
.../multileader/logdispatcher/IndexController.java | 150 ++++
.../multileader/logdispatcher/LogDispatcher.java | 299 +++++++
.../multileader/logdispatcher/PendingBatch.java | 76 ++
.../multileader/logdispatcher/SyncStatus.java | 89 ++
.../multileader/service/MultiLeaderRPCService.java | 95 +++
.../service/MultiLeaderRPCServiceHandler.java} | 34 +-
.../service/MultiLeaderRPCServiceMBean.java | 4 +-
.../service/MultiLeaderRPCServiceProcessor.java | 82 ++
.../{ => multileader}/wal/ConsensusReqReader.java | 30 +-
.../multileader/wal/GetConsensusReqReaderPlan.java | 16 +-
.../ratis/ApplicationStateMachineProxy.java | 19 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 9 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 45 +-
.../iotdb/consensus/ratis/RequestMessage.java | 5 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 87 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 23 +-
.../consensus/standalone/StandAloneConsensus.java | 41 +-
.../multileader/MultiLeaderConsensusTest.java | 419 +++++++++
.../logdispatcher/IndexControllerTest.java | 110 +++
.../multileader/logdispatcher/SyncStatusTest.java | 211 +++++
.../iotdb/consensus/ratis/RatisConsensusTest.java | 26 +-
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 13 +-
.../apache/iotdb/consensus/ratis/TestUtils.java | 16 +-
.../{ => standalone}/EmptyStateMachine.java | 3 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 9 +-
.../standalone/StandAloneConsensusTest.java | 9 +-
.../Administration-Management/Administration.md | 66 +-
docs/UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 478 ++++++++---
docs/UserGuide/Reference/TSDB-Comparison.md | 7 +-
docs/zh/Community/About.md | 22 +-
.../Administration-Management/Administration.md | 66 +-
.../UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 502 +++++++----
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 7 +-
example/ext-pipe-plugin-example/README.md | 60 ++
.../ext-pipe-plugin-example}/pom.xml | 62 +-
.../iotdb/extpipe/ExtPipeSinkWriterFactory.java | 134 +++
.../iotdb/extpipe/ExtPipeSinkWriterImpl.java | 176 ++++
.../org/apache/iotdb/trigger/AlertingExample.java | 5 +-
.../org/apache/iotdb/trigger/TriggerExample.java | 4 +-
{consensus => external-pipe-api}/pom.xml | 28 +-
.../apache/iotdb/pipe/external/api/DataType.java | 37 +-
.../external/api/ExternalPipeSinkWriterStatus.java | 77 ++
.../pipe/external/api/IExternalPipeSinkWriter.java | 161 ++++
.../api/IExternalPipeSinkWriterFactory.java | 63 ++
integration/pom.xml | 6 +
.../db/engine/trigger/example/Accumulator.java | 13 +-
.../iotdb/db/engine/trigger/example/Counter.java | 13 +-
.../db/integration/IoTDBCreateTimeseriesIT.java | 78 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 3 +-
.../IoTDBSyntaxConventionIdentifierIT.java | 25 +-
.../db/integration/IoTDBTriggerForwardIT.java | 305 +++++++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 52 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 27 -
.../session/IoTDBSessionSyntaxConventionIT.java | 65 +-
library-udf/pom.xml | 4 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 20 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 8 +-
.../iotdb/commons/partition/DataPartition.java | 26 +-
.../commons/partition/RegionReplicaSetInfo.java | 27 +-
.../iotdb/commons/partition/SchemaPartition.java | 29 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +
.../apache/iotdb/commons/service/ServiceType.java | 4 +-
.../iotdb/commons/udf/service/SnapshotUtils.java | 96 +++
.../commons/udf/service/UDFClassLoaderManager.java | 8 +
.../commons/udf/service/UDFExecutableManager.java | 196 +++++
.../commons/udf/service/UDFExecutableResource.java | 23 +-
.../iotdb/commons/udf/service/UDFLogWriter.java | 21 +-
.../udf/service/UDFRegistrationInformation.java | 13 +-
.../udf/service/UDFRegistrationService.java | 127 ++-
.../org/apache/iotdb/commons/utils/PathUtils.java | 86 ++
.../apache/iotdb/commons/ClientManagerTest.java | 5 +-
.../iotdb/commons/partition/SerializeTest.java | 3 +-
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 6 +-
pom.xml | 18 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 14 +
.../rocksdb/mnode/RMeasurementMNode.java | 10 +
server/pom.xml | 5 +
.../resources/conf/iotdb-engine.properties | 33 +-
server/src/assembly/resources/sbin/stop-server.sh | 15 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 54 +-
.../AuthorityFetcher.java} | 100 ++-
.../apache/iotdb/db/auth/AuthorizerManager.java | 330 ++++++--
.../apache/iotdb/db/client/ConfigNodeClient.java | 30 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 207 ++++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 63 +-
...ensusImpl.java => DataRegionConsensusImpl.java} | 40 +-
...susImpl.java => SchemaRegionConsensusImpl.java} | 40 +-
.../consensus/statemachine/BaseStateMachine.java | 29 +-
.../statemachine/DataRegionStateMachine.java | 56 +-
.../statemachine/SchemaRegionStateMachine.java | 23 +-
.../engine/compaction/CompactionTaskManager.java | 2 +
.../compaction/cross/CrossSpaceCompactionTask.java | 44 +-
.../compaction/inner/InnerSpaceCompactionTask.java | 80 +-
.../compaction/task/AbstractCompactionTask.java | 1 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 57 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 17 +-
.../iotdb/db/engine/trigger/api/Trigger.java | 37 +-
.../db/engine/trigger/builtin/ForwardTrigger.java | 229 +++++
.../db/engine/trigger/executor/TriggerEngine.java | 14 +-
.../engine/trigger/executor/TriggerExecutor.java | 43 +-
.../iotdb/db/engine/trigger/sink/api/Event.java | 8 +-
.../iotdb/db/engine/trigger/sink/api/Handler.java | 5 +
.../engine/trigger/sink/forward/ForwardEvent.java | 70 ++
.../sink/http/HTTPForwardConfiguration.java} | 38 +-
.../trigger/sink/http/HTTPForwardEvent.java} | 11 +-
.../trigger/sink/http/HTTPForwardHandler.java | 133 +++
.../sink/mqtt/MQTTForwardConfiguration.java | 137 +++
.../trigger/sink/mqtt/MQTTForwardEvent.java} | 11 +-
.../trigger/sink/mqtt/MQTTForwardHandler.java | 97 +++
.../db/engine/trigger/utils/BatchHandlerQueue.java | 150 ++++
.../engine/trigger/utils/HTTPConnectionPool.java | 49 ++
.../trigger/utils/MQTTConnectionFactory.java | 115 +++
.../engine/trigger/utils/MQTTConnectionPool.java | 79 ++
.../metadata/cache/DataNodeLastCacheManager.java | 6 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 17 +-
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 16 +-
.../idtable/entry/InsertMeasurementMNode.java | 10 +
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 4 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 12 +
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 1 +
.../mtree/traverser/collector/MNodeCollector.java | 9 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 8 +
.../iotdb/db/metadata/path/MeasurementPath.java | 30 +
.../db/metadata/schemaregion/ISchemaRegion.java | 6 +
.../schemaregion/SchemaRegionMemoryImpl.java | 20 +
.../schemaregion/SchemaRegionSchemaFileImpl.java | 14 +
.../utils/TimeseriesVersionUtil.java} | 10 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 88 +-
.../iotdb/db/mpp/aggregation/Aggregator.java | 22 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 6 +
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 2 +-
.../EmptyQueueSlidingWindowAggregator.java | 58 ++
.../MonotonicQueueSlidingWindowAggregator.java | 76 ++
.../NormalQueueSlidingWindowAggregator.java | 61 ++
.../slidingwindow/SlidingWindowAggregator.java | 143 ++++
.../SlidingWindowAggregatorFactory.java | 149 ++++
.../SmoothQueueSlidingWindowAggregator.java | 57 ++
.../iotdb/db/mpp/common/header/HeaderConstant.java | 24 +-
.../db/mpp/common/schematree/PathPatternTree.java | 6 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 18 +-
.../common/schematree/node/SchemaInternalNode.java | 5 +
.../schematree/node/SchemaMeasurementNode.java | 12 +-
.../db/mpp/common/schematree/node/SchemaNode.java | 2 +
.../visitor/SchemaTreeMeasurementVisitor.java | 8 +-
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 122 +++
.../db/mpp/execution/operator/LastQueryUtil.java | 94 +++
.../operator/process/AggregationOperator.java | 4 +-
.../operator/process/LastQueryMergeOperator.java | 82 ++
.../process/RawDataAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 144 ++++
.../operator/process/UpdateLastCacheOperator.java | 129 +++
.../schema/NodeManageMemoryMergeOperator.java | 19 +-
...Operator.java => NodePathsConvertOperator.java} | 50 +-
...anOperator.java => NodePathsCountOperator.java} | 65 +-
...rator.java => NodePathsSchemaScanOperator.java} | 34 +-
.../AlignedSeriesAggregationScanOperator.java | 12 +-
.../operator/source/LastCacheScanOperator.java | 64 ++
.../source/SeriesAggregationScanOperator.java | 16 +-
.../execution/operator/source/SeriesScanUtil.java | 3 +
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 15 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 4 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 141 +++-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 18 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 54 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 5 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 8 +-
.../db/mpp/plan/analyze/IPartitionFetcher.java | 10 +-
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 22 +-
.../plan/analyze/StandalonePartitionFetcher.java | 5 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 1 +
.../db/mpp/plan/execution/QueryExecution.java | 8 +-
.../execution/config/AuthorizerConfigTask.java | 107 +--
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../plan/execution/config/CreateFunctionTask.java | 117 +++
.../execution/config/ShowStorageGroupTask.java | 9 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 10 +-
.../memory/StatementMemorySourceVisitor.java | 14 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 227 ++++-
.../db/mpp/plan/parser/StatementGenerator.java | 22 +-
.../db/mpp/plan/planner/DistributionPlanner.java | 909 --------------------
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 412 ++++++++-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 188 ++++-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 113 ++-
.../distribution/DistributionPlanContext.java | 13 +-
.../planner/distribution/DistributionPlanner.java | 179 ++++
.../planner/distribution/ExchangeNodeAdder.java | 319 +++++++
.../NodeDistribution.java} | 20 +-
.../distribution/NodeDistributionType.java} | 9 +-
.../NodeGroupContext.java} | 28 +-
.../SimpleFragmentParallelPlanner.java | 3 +-
.../plan/planner/distribution/SourceRewriter.java | 717 ++++++++++++++++
.../WriteFragmentParallelPlanner.java | 3 +-
.../db/mpp/plan/planner/plan/PlanFragment.java | 6 +-
.../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 2 +-
.../planner/plan/node/IPartitionRelatedNode.java} | 8 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 24 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 29 +-
.../mpp/plan/planner/plan/node/WritePlanNode.java | 5 +-
.../metedata/read/ChildNodesSchemaScanNode.java | 87 --
.../read/NodeManagementMemoryMergeNode.java | 20 +-
...oryMergeNode.java => NodePathsConvertNode.java} | 45 +-
...emoryMergeNode.java => NodePathsCountNode.java} | 45 +-
...aScanNode.java => NodePathsSchemaScanNode.java} | 24 +-
.../write/CreateAlignedTimeSeriesNode.java | 30 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 362 ++------
.../node/metedata/write/CreateTimeSeriesNode.java | 36 +-
.../node/metedata/write/DeleteTimeSeriesNode.java | 38 +-
.../metedata/write/InvalidateSchemaCacheNode.java | 15 +-
.../plan/node/metedata/write/MeasurementGroup.java | 275 ++++++
.../planner/plan/node/process/AggregationNode.java | 41 +-
.../planner/plan/node/process/DeviceMergeNode.java | 9 +-
.../planner/plan/node/process/DeviceViewNode.java | 14 +-
.../plan/node/process/GroupByLevelNode.java | 70 +-
.../plan/node/process/LastQueryMergeNode.java | 38 +-
...Node.java => SlidingWindowAggregationNode.java} | 67 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 50 +-
.../source/AlignedSeriesAggregationScanNode.java | 12 -
.../plan/node/source/LastQueryScanNode.java | 60 +-
.../node/source/SeriesAggregationScanNode.java | 12 -
.../node/source/SeriesAggregationSourceNode.java | 31 +
.../plan/planner/plan/node/source/SourceNode.java | 5 +-
.../planner/plan/node/write/DeleteDataNode.java | 72 +-
.../plan/node/write/InsertMultiTabletsNode.java | 15 +-
.../plan/planner/plan/node/write/InsertNode.java | 9 +-
.../planner/plan/node/write/InsertRowNode.java | 10 +
.../planner/plan/node/write/InsertRowsNode.java | 9 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 9 +
.../planner/plan/node/write/InsertTabletNode.java | 55 ++
.../scheduler/FragmentInstanceDispatcherImpl.java | 31 +-
.../db/mpp/plan/statement/StatementVisitor.java | 25 +-
.../LastPointFetchStatement.java} | 31 +-
.../SchemaFetchStatement.java | 2 +-
.../statement/metadata/CountNodesStatement.java | 10 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 32 +-
...Statement.java => CreateFunctionStatement.java} | 45 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 19 -
...java => CreateTimeSeriesByDeviceStatement.java} | 42 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 30 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 50 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 337 ++++++--
.../apache/iotdb/db/qp/strategy/SQLParseError.java | 24 +
.../iotdb/db/query/executor/LastQueryExecutor.java | 5 +-
.../query/reader/chunk/MemAlignedPageReader.java | 15 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 4 +
.../java/org/apache/iotdb/db/service/DataNode.java | 74 +-
.../db/service/metrics/predefined/FileMetrics.java | 3 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 181 ++--
.../service/thrift/impl/InternalServiceImpl.java | 97 ++-
.../db/service/thrift/impl/TSServiceImpl.java | 88 +-
.../iotdb/db/sync/datasource/AbstractOpBlock.java | 110 +++
.../datasource/ModsfileOpBlock.java} | 34 +-
.../iotdb/db/sync/datasource/PipeOpManager.java | 221 +++++
.../iotdb/db/sync/datasource/PipeOpSgManager.java | 166 ++++
.../db/sync/datasource/PipeStorageGroupInfo.java | 45 +-
.../iotdb/db/sync/datasource/TsFileOpBlock.java | 604 +++++++++++++
.../iotdb/db/sync/externalpipe/ExtPipePlugin.java | 602 +++++++++++++
.../externalpipe/ExtPipePluginConfiguration.java | 140 +++
.../db/sync/externalpipe/ExtPipePluginManager.java | 276 ++++++
.../sync/externalpipe/ExtPipePluginRegister.java | 129 +++
.../db/sync/externalpipe/ExternalPipeStatus.java | 58 ++
.../externalpipe/operation/InsertOperation.java | 69 ++
.../db/sync/externalpipe/operation/Operation.java | 41 +-
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 27 +
.../db/sync/sender/pipe/ExternalPipeSink.java | 93 ++
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 49 +-
.../apache/iotdb/db/sync/sender/pipe/PipeSink.java | 27 +-
.../db/sync/sender/service/SenderService.java | 181 +++-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 13 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 25 +
.../java/org/apache/iotdb/db/wal/WALManager.java | 111 +--
.../allocation/AbstractNodeAllocationStrategy.java | 79 ++
.../db/wal/allocation/FirstCreateStrategy.java | 105 +++
.../allocation/NodeAllocationStrategy.java} | 24 +-
.../db/wal/allocation/RoundRobinStrategy.java | 106 +++
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 11 +-
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 13 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 59 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 13 +-
.../apache/iotdb/db/wal/io/CheckpointWriter.java | 30 -
.../java/org/apache/iotdb/db/wal/io/WALWriter.java | 29 -
.../org/apache/iotdb/db/wal/node/IWALNode.java | 5 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 436 +++++++++-
.../db/wal/recover/CheckpointRecoverUtils.java | 12 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 35 +-
.../iotdb/db/wal/recover/WALRecoverManager.java | 3 +-
.../CheckpointFileUtils.java} | 50 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 134 +++
.../iotdb/db/auth/AuthorizerManagerTest.java | 164 ++++
.../compaction/CompactionTaskManagerTest.java | 31 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 26 +-
.../metadata/idtable/trigger_example/Counter.java | 13 +-
.../db/mpp/common/schematree/SchemaTreeTest.java | 24 +-
.../operator/AggregationOperatorTest.java | 2 +-
.../operator/LastCacheScanOperatorTest.java | 93 ++
.../operator/LastQueryMergeOperatorTest.java | 327 ++++++++
.../SeriesAggregationScanOperatorTest.java | 3 +-
.../SlidingWindowAggregationOperatorTest.java | 244 ++++++
.../operator/UpdateLastCacheOperatorTest.java | 219 +++++
.../schema/SchemaFetchScanOperatorTest.java | 9 +-
.../db/mpp/plan/plan/DistributionPlannerTest.java | 934 ---------------------
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 6 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 45 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 63 +-
.../distribution/AggregationDistributionTest.java | 420 +++++++++
.../plan/distribution/AlignedByDeviceTest.java} | 19 +-
.../plan/distribution/DeleteTimeseriesTest.java | 71 ++
.../distribution/DistributionPlannerBasicTest.java | 378 +++++++++
.../mpp/plan/plan/distribution/LastQueryTest.java | 118 +++
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 191 +++++
.../NodeManagementMemoryMergeNodeSerdeTest.java | 81 +-
.../node/process/AggregationNodeSerdeTest.java | 3 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 4 +-
.../plan/node/write/DeleteDataNodeSerdeTest.java | 19 +-
.../iotdb/db/service/InternalServiceImplTest.java | 40 +-
.../db/sync/datasource/PipeOpManagerTest.java | 207 +++++
.../db/sync/datasource/TsFileOpBlockTest.java | 160 ++++
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 9 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 +
.../org/apache/iotdb/db/wal/DisableWALTest.java | 2 +-
.../org/apache/iotdb/db/wal/WALManagerTest.java | 32 +-
.../FirstCreateStrategyTest.java} | 79 +-
.../RoundRobinStrategyTest.java} | 47 +-
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 4 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 17 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 516 ++++++++++++
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 18 +-
.../iotdb/db/wal/utils/WALFileUtilsTest.java | 215 +++++
.../datanode1conf/iotdb-engine.properties | 3 +-
.../datanode2conf/iotdb-engine.properties | 3 +-
.../datanode3conf/iotdb-engine.properties | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +
site/src/main/.vuepress/theme/components/Page.vue | 12 +-
.../.vuepress/theme/global-components/IoTDB.vue | 91 +-
.../.vuepress/theme/global-components/IoTDBZH.vue | 107 ++-
thrift-commons/src/main/thrift/common.thrift | 6 +-
.../src/main/thrift/confignode.thrift | 63 +-
.../pom.xml | 56 +-
.../src/main/thrift/mutlileader.thrift | 35 +-
thrift/src/main/thrift/mpp.thrift | 25 +
.../tsfile/common/constant/TsFileConstant.java | 5 +-
.../tsfile/read/common/parser/PathParseError.java | 23 +
.../tsfile/read/common/parser/PathVisitor.java | 2 +-
.../iotdb/tsfile/read/reader/IPageReader.java | 4 +
.../tsfile/read/reader/page/AlignedPageReader.java | 13 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 3 +
.../write/chunk/AlignedChunkGroupWriterImpl.java | 85 +-
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 2 +-
423 files changed, 22281 insertions(+), 6119 deletions(-)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/SyncDataNodeClientPool.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/CreateFunctionHandler.java
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetChildPathsPartitionReq.java
rename
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetChildNodesPartitionReq.java
=> GetNodePathsPartitionReq.java} (72%)
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/CreateFunctionReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/PreDeleteStorageGroupReq.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/UDFManager.java
create mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/persistence/UDFInfo.java
copy
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/api/Event.java =>
confignode/src/test/java/org/apache/iotdb/confignode/procedure/env/TestConfigNodeEnv.java
(90%)
rename confignode/src/test/java/org/apache/iotdb/confignode/procedure/{ =>
env}/TestProcEnv.java (97%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/common/request/IndexedConsensusRequest.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/{standalone/StandAloneConsensus.java
=> multileader/MultiLeaderConsensus.java} (72%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/MultiLeaderServerImpl.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/AsyncMultiLeaderServiceClient.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/DispatchLogHandler.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/client/MultiLeaderConsensusClientPool.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/conf/MultiLeaderConsensusConfig.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/IndexController.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/LogDispatcher.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/PendingBatch.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/logdispatcher/SyncStatus.java
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCService.java
copy
consensus/src/{test/java/org/apache/iotdb/consensus/EmptyStateMachine.java =>
main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceHandler.java}
(51%)
copy
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/api/Event.java =>
consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceMBean.java
(88%)
create mode 100644
consensus/src/main/java/org/apache/iotdb/consensus/multileader/service/MultiLeaderRPCServiceProcessor.java
rename consensus/src/main/java/org/apache/iotdb/consensus/{ =>
multileader}/wal/ConsensusReqReader.java (74%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/DeleteStorageGroupState.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/multileader/wal/GetConsensusReqReaderPlan.java
(74%)
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/multileader/MultiLeaderConsensusTest.java
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/multileader/logdispatcher/IndexControllerTest.java
create mode 100644
consensus/src/test/java/org/apache/iotdb/consensus/multileader/logdispatcher/SyncStatusTest.java
copy consensus/src/test/java/org/apache/iotdb/consensus/{ =>
standalone}/EmptyStateMachine.java (94%)
create mode 100644 example/ext-pipe-plugin-example/README.md
copy {consensus => example/ext-pipe-plugin-example}/pom.xml (55%)
create mode 100644
example/ext-pipe-plugin-example/src/main/java/org/apache/iotdb/extpipe/ExtPipeSinkWriterFactory.java
create mode 100644
example/ext-pipe-plugin-example/src/main/java/org/apache/iotdb/extpipe/ExtPipeSinkWriterImpl.java
copy {consensus => external-pipe-api}/pom.xml (58%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerEndpointException.java
=>
external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/DataType.java
(58%)
create mode 100644
external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/ExternalPipeSinkWriterStatus.java
create mode 100644
external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/IExternalPipeSinkWriter.java
create mode 100644
external-pipe-api/src/main/java/org/apache/iotdb/pipe/external/api/IExternalPipeSinkWriterFactory.java
create mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerForwardIT.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/WritePlanNode.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSetInfo.java
(56%)
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/SnapshotUtils.java
create mode 100644
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableManager.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerEndpointException.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableResource.java
(66%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/execution/config/AuthorizerConfigTask.java
=> auth/AuthorityFetcher.java} (67%)
copy server/src/main/java/org/apache/iotdb/db/consensus/{ConsensusImpl.java =>
DataRegionConsensusImpl.java} (56%)
rename server/src/main/java/org/apache/iotdb/db/consensus/{ConsensusImpl.java
=> SchemaRegionConsensusImpl.java} (57%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/builtin/ForwardTrigger.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/ForwardEvent.java
copy server/src/main/java/org/apache/iotdb/db/{sync/sender/pipe/PipeSink.java
=> engine/trigger/sink/http/HTTPForwardConfiguration.java} (51%)
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/statement/metadata/CountNodesStatement.java
=> engine/trigger/sink/http/HTTPForwardEvent.java} (74%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardConfiguration.java
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/statement/metadata/CountNodesStatement.java
=> engine/trigger/sink/mqtt/MQTTForwardEvent.java} (74%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardHandler.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/BatchHandlerQueue.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/HTTPConnectionPool.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/MQTTConnectionFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/MQTTConnectionPool.java
copy
server/src/main/java/org/apache/iotdb/db/{engine/trigger/sink/api/Event.java =>
metadata/utils/TimeseriesVersionUtil.java} (80%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/EmptyQueueSlidingWindowAggregator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/MonotonicQueueSlidingWindowAggregator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/NormalQueueSlidingWindowAggregator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SlidingWindowAggregator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SlidingWindowAggregatorFactory.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/aggregation/slidingwindow/SmoothQueueSlidingWindowAggregator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/QueryIdGenerator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/LastQueryUtil.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/LastQueryMergeOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/SlidingWindowAggregationOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/UpdateLastCacheOperator.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{NodeManageMemoryMergeOperator.java
=> NodePathsConvertOperator.java} (66%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{ChildNodesSchemaScanOperator.java
=> NodePathsCountOperator.java} (50%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/{ChildPathsSchemaScanOperator.java
=> NodePathsSchemaScanOperator.java} (75%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/source/LastCacheScanOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/CreateFunctionTask.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/DistributionPlanner.java
copy
consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerNumException.java
=>
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/DistributionPlanContext.java
(73%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/DistributionPlanner.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/ExchangeNodeAdder.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/{plan/node/WritePlanNode.java
=> distribution/NodeDistribution.java} (69%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/trigger/sink/api/Event.java =>
mpp/plan/planner/distribution/NodeDistributionType.java} (81%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/{plan/node/source/SourceNode.java
=> distribution/NodeGroupContext.java} (55%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/{ =>
distribution}/SimpleFragmentParallelPlanner.java (97%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/distribution/SourceRewriter.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/{ =>
distribution}/WriteFragmentParallelPlanner.java (95%)
copy
server/src/main/java/org/apache/iotdb/db/{engine/trigger/sink/api/Event.java =>
mpp/plan/planner/plan/node/IPartitionRelatedNode.java} (79%)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/ChildNodesSchemaScanNode.java
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{NodeManagementMemoryMergeNode.java
=> NodePathsConvertNode.java} (58%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{NodeManagementMemoryMergeNode.java
=> NodePathsCountNode.java} (58%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/{ChildPathsSchemaScanNode.java
=> NodePathsSchemaScanNode.java} (76%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/MeasurementGroup.java
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{GroupByTimeNode.java
=> SlidingWindowAggregationNode.java} (72%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/DeleteTimeSeriesStatement.java
=> internal/LastPointFetchStatement.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata =>
internal}/SchemaFetchStatement.java (97%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{SchemaFetchStatement.java
=> CreateFunctionStatement.java} (57%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/{SchemaFetchStatement.java
=> CreateTimeSeriesByDeviceStatement.java} (54%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/AbstractOpBlock.java
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/statement/metadata/DeleteTimeSeriesStatement.java
=> sync/datasource/ModsfileOpBlock.java} (58%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/PipeOpManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/PipeOpSgManager.java
rename
consensus/src/test/java/org/apache/iotdb/consensus/EmptyStateMachine.java =>
server/src/main/java/org/apache/iotdb/db/sync/datasource/PipeStorageGroupInfo.java
(51%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/datasource/TsFileOpBlock.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePlugin.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePluginConfiguration.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePluginManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExtPipePluginRegister.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/ExternalPipeStatus.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/operation/InsertOperation.java
copy
confignode/src/test/java/org/apache/iotdb/confignode/procedure/entity/NoopProcedure.java
=>
server/src/main/java/org/apache/iotdb/db/sync/externalpipe/operation/Operation.java
(52%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/sync/sender/pipe/ExternalPipeSink.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/wal/allocation/AbstractNodeAllocationStrategy.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/wal/allocation/FirstCreateStrategy.java
copy
server/src/main/java/org/apache/iotdb/db/{mpp/plan/planner/plan/node/WritePlanNode.java
=> wal/allocation/NodeAllocationStrategy.java} (65%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/wal/allocation/RoundRobinStrategy.java
copy server/src/main/java/org/apache/iotdb/db/wal/{io/CheckpointWriter.java =>
utils/CheckpointFileUtils.java} (52%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/wal/utils/WALFileUtils.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/auth/AuthorizerManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/LastCacheScanOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/LastQueryMergeOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SlidingWindowAggregationOperatorTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/UpdateLastCacheOperatorTest.java
delete mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/DistributionPlannerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AggregationDistributionTest.java
copy
server/src/{main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountNodesStatement.java
=>
test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/AlignedByDeviceTest.java}
(70%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/DeleteTimeseriesTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/DistributionPlannerBasicTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/LastQueryTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/Util.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/PipeOpManagerTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/sync/datasource/TsFileOpBlockTest.java
copy server/src/test/java/org/apache/iotdb/db/wal/{WALManagerTest.java =>
allocation/FirstCreateStrategyTest.java} (57%)
copy server/src/test/java/org/apache/iotdb/db/wal/{WALManagerTest.java =>
allocation/RoundRobinStrategyTest.java} (73%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/wal/node/ConsensusReqReaderTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/wal/utils/WALFileUtilsTest.java
copy {consensus => thrift-multi-leader-consensus}/pom.xml (56%)
copy
consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java
=> thrift-multi-leader-consensus/src/main/thrift/mutlileader.thrift (63%)
