You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/05/31 07:39:58 UTC
[iotdb] branch tsfile_name updated (58e8db5e6d -> 1a3d5df812)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch tsfile_name
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 58e8db5e6d [IOTDB-3100] Semantics change of TsFile filename (#6088)
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 95884ad6b9 [IOTDB-3277] [IOTDB-3310] [IOTDB-3311] Fix some SQL parser bugs in new cluster (#6060)
add 31e5893900 [IOTDB-3315] Make unset of ttl in cluster mode same as 0.13.0 version. (#6061)
add 23bb94e2e5 [IOTDB-3271] Wrong multi IP for one sender in receiver (#6037)
add bb1a88540d [ISSUES-6057] Add a method(getAllDataRegionID) to StorageEngineV2 (#6059)
add fcb27a8449 [IOTDB-3228] UDF Management in MPP Cluster: DROP FUNCTION (#6064)
add 4f101d8acf [IOTDB-3246]Improve Validation tool (#6066)
add e1dfec58e3 [IOTDB-3320] Don't return data which are not satisfied with time filter in last query (#6068)
add 88426aa3e3 [IOTDB-3319] fix IndexOutOfBoundsException when executing linear fill in group by query (#6070)
add 8500eb9cd1 Fix aligned data in memory query bug (#6065)
add c84095d093 [IOTDB-3325] Thrown an exception when using group by in raw data query (#6077)
add c01b1e1504 [IOTDB-3335] Redundant data recovered by wal in multi-leader consensus (#6076)
add 7fcb1044e7 [IOTDB-3306] Use rpc port check to avoid starting same IoTDB twice (#6069)
add 88adfbea69 [IOTDB-3229] Field is 0 rather than null when query two series in one device (#6071)
add b343478a41 [IOTDB-3339] Fix index out of bound while doing raw query (#6079)
add 48256e44f3 [IOTDB-3341] Fix timeseries id is not right while doing last query (#6082)
add 3918bf6992 [IOTDB-3346] Clear DriverTask when any RuntimeException is thrown (#6086)
add d26fa83c5d Make DataNode start DataNodeTSIServiceImpl RPC service (#6090)
add d9d2465f0d [IOTDB-3343] Aggregate existing and non-exsit timeseries together failure in AlignByDevice (#6084)
add f0fd1f5b40 [IOTDB-3165] Implement delete data (#6072)
add 1a18def1fc [IOTDB-3065]show lastest timeseries (#6063)
add ecbea664df optimize. (#6073)
add 1a3d5df812 Merge branch 'tsfile_name' of https://github.com/apache/iotdb into tsfile_name
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 20 +-
.../resources/conf/iotdb-confignode.properties | 40 +-
.../confignode/client/AsyncDataNodeClientPool.java | 31 ++
.../client/handlers/FunctionManagementHandler.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 +-
...itionReq.java => GetNodePathsPartitionReq.java} | 31 +-
.../consensus/request/write/CreateFunctionReq.java | 85 +++++
.../DropFunctionReq.java} | 42 +--
.../iotdb/confignode/manager/ConfigManager.java | 72 ++--
.../apache/iotdb/confignode/manager/Manager.java | 20 +-
.../iotdb/confignode/manager/NodeManager.java | 9 +-
.../iotdb/confignode/manager/PartitionManager.java | 23 +-
.../iotdb/confignode/manager/UDFManager.java | 164 ++++++++
.../confignode/persistence/ClusterSchemaInfo.java | 15 +
.../iotdb/confignode/persistence/UDFInfo.java | 136 +++++++
.../executor/ConfigRequestExecutor.java | 69 ++--
.../iotdb/confignode/service/ConfigNode.java | 18 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 22 +-
.../consensus/request/ConfigRequestSerDeTest.java | 12 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 3 +-
.../confignode/persistence/PartitionInfoTest.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 78 +++-
.../confignode1conf/iotdb-confignode.properties | 4 +-
.../confignode2conf/iotdb-confignode.properties | 3 +-
.../confignode3conf/iotdb-confignode.properties | 3 +-
consensus/README.md | 4 +-
consensus/pom.xml | 5 +
.../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 | 6 +-
.../wal/GetConsensusReqReaderPlan.java} | 15 +-
.../apache/iotdb/consensus/ratis/RatisClient.java | 9 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 45 ++-
.../iotdb/consensus/ratis/RequestMessage.java | 5 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 16 +-
.../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 | 1 -
.../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 | 60 +--
docs/UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 4 +-
docs/UserGuide/Reference/TSDB-Comparison.md | 7 +-
docs/zh/Community/About.md | 22 +-
.../Administration-Management/Administration.md | 60 +--
.../UserGuide/IoTDB-Introduction/Architecture.md | 2 +-
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 7 +-
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 7 +-
.../org/apache/iotdb/trigger/AlertingExample.java | 5 +-
.../org/apache/iotdb/trigger/TriggerExample.java | 4 +-
integration/pom.xml | 6 +
.../db/engine/trigger/example/Accumulator.java | 13 +-
.../iotdb/db/engine/trigger/example/Counter.java | 13 +-
.../IoTDBSyntaxConventionIdentifierIT.java | 8 -
.../db/integration/IoTDBTriggerForwardIT.java | 305 +++++++++++++++
.../db/integration/sync/IoTDBSyncReceiverIT.java | 5 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 27 --
.../session/IoTDBSessionSyntaxConventionIT.java | 65 +++-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 12 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 8 +-
.../iotdb/commons/partition/DataPartition.java | 5 +-
.../commons/partition/DataPartitionQueryParam.java | 16 +
.../apache/iotdb/commons/partition/Partition.java | 4 +
.../commons/partition/RegionReplicaSetInfo.java | 16 +-
.../iotdb/commons/partition/SchemaPartition.java | 5 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 4 +
.../service/AbstractThriftServiceThread.java | 38 +-
.../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 | 22 +-
.../iotdb/commons/udf/service/UDFLogWriter.java | 21 +-
.../udf/service/UDFRegistrationInformation.java | 13 +-
.../udf/service/UDFRegistrationService.java | 133 ++++++-
.../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 | 2 +
.../resources/conf/iotdb-engine.properties | 25 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 34 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 161 +++++++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 47 ++-
...ensusImpl.java => DataRegionConsensusImpl.java} | 40 +-
...susImpl.java => SchemaRegionConsensusImpl.java} | 40 +-
.../consensus/statemachine/BaseStateMachine.java | 29 +-
.../statemachine/DataRegionStateMachine.java | 56 ++-
.../statemachine/SchemaRegionStateMachine.java | 23 +-
.../statemachine/visitor/DataExecutionVisitor.java | 17 +
.../apache/iotdb/db/engine/StorageEngineV2.java | 11 +-
.../engine/compaction/CompactionTaskManager.java | 2 +
.../compaction/cross/CrossSpaceCompactionTask.java | 44 ++-
.../compaction/inner/InnerSpaceCompactionTask.java | 80 ++--
.../compaction/task/AbstractCompactionTask.java | 1 +
.../iotdb/db/engine/memtable/AbstractMemTable.java | 7 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 129 ++++++-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../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 | 36 +-
.../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 ++++
.../mtree/traverser/collector/MNodeCollector.java | 9 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 8 +
.../iotdb/db/metadata/path/MeasurementPath.java | 5 +
.../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 | 58 +++
.../iotdb/db/mpp/common/header/HeaderConstant.java | 19 +-
.../iotdb/db/mpp/execution/QueryIdGenerator.java | 122 ++++++
.../db/mpp/execution/operator/LastQueryUtil.java | 21 +-
.../operator/process/AggregationOperator.java | 4 +-
.../execution/operator/process/FilterOperator.java | 80 ++--
.../operator/process/LinearFillOperator.java | 3 +-
.../process/RawDataAggregationOperator.java | 6 +-
.../process/SlidingWindowAggregationOperator.java | 144 +++++++
.../operator/process/TransformOperator.java | 70 ++--
.../operator/process/UpdateLastCacheOperator.java | 7 +
.../operator/process/merge/SingleColumnMerger.java | 4 +-
.../schema/NodeManageMemoryMergeOperator.java | 19 +-
...Operator.java => NodePathsConvertOperator.java} | 50 ++-
...anOperator.java => NodePathsCountOperator.java} | 65 ++--
...rator.java => NodePathsSchemaScanOperator.java} | 34 +-
.../operator/schema/SchemaQueryMergeOperator.java | 2 -
.../schema/SchemaQueryOrderByHeatOperator.java | 161 ++++++++
.../AlignedSeriesAggregationScanOperator.java | 12 +-
.../source/SeriesAggregationScanOperator.java | 16 +-
.../execution/operator/source/SeriesScanUtil.java | 3 +
.../execution/schedule/AbstractDriverThread.java | 8 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 34 +-
.../schedule/FragmentInstanceAbortedException.java | 1 +
.../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 | 239 ++++++++----
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 25 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 16 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 10 +-
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 5 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 6 +
.../db/mpp/plan/analyze/IPartitionFetcher.java | 10 +-
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 3 +
.../plan/analyze/StandalonePartitionFetcher.java | 5 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 6 +
.../db/mpp/plan/execution/QueryExecution.java | 6 +-
.../plan/execution/config/ConfigTaskVisitor.java | 15 +
.../plan/execution/config/CreateFunctionTask.java | 117 ++++++
.../plan/execution/config/DropFunctionTask.java | 99 +++++
.../execution/config/ShowStorageGroupTask.java | 6 +-
.../db/mpp/plan/execution/config/ShowTTLTask.java | 9 +-
.../memory/StatementMemorySourceVisitor.java | 14 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 248 +++++++++++-
.../db/mpp/plan/parser/StatementGenerator.java | 37 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 224 ++++++++---
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 198 ++++++----
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 123 ++++--
.../planner/distribution/ExchangeNodeAdder.java | 72 ++--
.../plan/planner/distribution/SourceRewriter.java | 258 +++++++------
.../mpp/plan/planner/plan/node/PlanNodeType.java | 28 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 24 +-
.../metedata/read/ChildNodesSchemaScanNode.java | 87 -----
.../read/NodeManagementMemoryMergeNode.java | 20 +-
...oryMergeNode.java => NodePathsConvertNode.java} | 45 +--
...emoryMergeNode.java => NodePathsCountNode.java} | 45 +--
...aScanNode.java => NodePathsSchemaScanNode.java} | 24 +-
.../node/metedata/read/SchemaQueryMergeNode.java | 4 +
.../metedata/read/SchemaQueryOrderByHeatNode.java | 99 +++++
.../metedata/read/TimeSeriesSchemaScanNode.java | 7 +
.../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 | 8 +-
...Node.java => SlidingWindowAggregationNode.java} | 67 ++--
.../plan/node/source/AlignedLastQueryScanNode.java | 18 +-
.../source/AlignedSeriesAggregationScanNode.java | 12 -
.../plan/node/source/LastQueryScanNode.java | 20 +-
.../node/source/SeriesAggregationScanNode.java | 12 -
.../node/source/SeriesAggregationSourceNode.java | 31 ++
.../planner/plan/node/write/DeleteDataNode.java | 110 ++++--
.../plan/planner/plan/node/write/InsertNode.java | 3 +-
.../planner/plan/node/write/InsertRowNode.java | 10 +
.../planner/plan/node/write/InsertTabletNode.java | 55 +++
.../scheduler/FragmentInstanceDispatcherImpl.java | 31 +-
.../db/mpp/plan/statement/StatementVisitor.java | 28 +-
.../DeleteDataStatement.java} | 53 +--
.../db/mpp/plan/statement/crud/QueryStatement.java | 4 +
.../LastPointFetchStatement.java} | 40 +-
.../SchemaFetchStatement.java | 2 +-
.../statement/metadata/CountNodesStatement.java | 10 +
...Statement.java => CreateFunctionStatement.java} | 45 ++-
...chStatement.java => DropFunctionStatement.java} | 38 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 30 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 76 +++-
.../query/reader/chunk/MemAlignedPageReader.java | 25 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 4 +
.../java/org/apache/iotdb/db/service/DataNode.java | 92 +++--
.../java/org/apache/iotdb/db/service/IoTDB.java | 9 +-
.../thrift/impl/DataNodeTSIServiceImpl.java | 270 +++++++------
.../service/thrift/impl/InternalServiceImpl.java | 98 +++--
.../db/service/thrift/impl/TSServiceImpl.java | 117 +-----
.../db/sync/sender/service/TransportHandler.java | 5 +-
.../db/sync/transport/client/TransportClient.java | 21 +-
.../db/tools/validate/TsFileValidationTool.java | 13 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 25 ++
.../java/org/apache/iotdb/db/wal/WALManager.java | 15 +-
.../allocation/AbstractNodeAllocationStrategy.java | 9 +
.../db/wal/allocation/FirstCreateStrategy.java | 4 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 4 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 7 +-
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 40 +-
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 1 -
.../apache/iotdb/db/wal/io/CheckpointReader.java | 22 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 5 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 13 +-
.../db/wal/recover/CheckpointRecoverUtils.java | 32 +-
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 34 +-
.../iotdb/db/wal/utils/CheckpointFileUtils.java | 3 +-
.../apache/iotdb/db/wal/utils/WALFileUtils.java | 30 +-
.../iotdb/db/engine/StorageEngineV2Test.java | 71 ++++
.../compaction/CompactionTaskManagerTest.java | 31 +-
.../metadata/idtable/trigger_example/Counter.java | 13 +-
.../operator/AggregationOperatorTest.java | 2 +-
.../execution/operator/LinearFillOperatorTest.java | 113 +++++-
.../SlidingWindowAggregationOperatorTest.java | 244 ++++++++++++
...erTest.java => DefaultDriverSchedulerTest.java} | 2 +-
.../execution/schedule/DriverSchedulerTest.java | 2 +-
.../DriverTaskTimeoutSentinelThreadTest.java | 43 +++
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 6 +-
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 51 ++-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 63 +++-
.../distribution/AggregationDistributionTest.java | 16 +-
.../plan/distribution/AlignedByDeviceTest.java} | 19 +-
.../plan/distribution/DeleteTimeseriesTest.java | 71 ----
...Test.java => DistributionPlannerBasicTest.java} | 2 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 118 ++++++
.../NodeManagementMemoryMergeNodeSerdeTest.java | 81 ++--
.../node/process/AggregationNodeSerdeTest.java | 3 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 4 +-
.../plan/node/write/DeleteDataNodeSerdeTest.java | 21 +-
.../iotdb/db/service/InternalServiceImplTest.java | 24 +-
.../db/sync/transport/TransportServiceTest.java | 8 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 2 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 6 +-
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 12 +-
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 16 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 +-
.../datanode1conf/iotdb-engine.properties | 3 +-
.../datanode2conf/iotdb-engine.properties | 3 +-
.../datanode3conf/iotdb-engine.properties | 3 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../.vuepress/theme/global-components/IoTDB.vue | 64 +---
.../.vuepress/theme/global-components/IoTDBZH.vue | 67 ++--
thrift-commons/src/main/thrift/common.thrift | 6 +-
.../src/main/thrift/confignode.thrift | 50 ++-
.../pom.xml | 56 +--
.../src/main/thrift/mutlileader.thrift | 35 +-
thrift/src/main/thrift/mpp.thrift | 26 +-
.../tsfile/common/constant/TsFileConstant.java | 5 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 3 +-
.../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 +-
316 files changed, 11054 insertions(+), 2779 deletions(-)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/client/handlers/FunctionManagementHandler.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
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{read/GetChildPathsPartitionReq.java => write/DropFunctionReq.java} (54%)
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
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 (97%)
copy consensus/src/main/java/org/apache/iotdb/consensus/{exception/IllegalPeerNumException.java => multileader/wal/GetConsensusReqReaderPlan.java} (73%)
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
rename consensus/src/test/java/org/apache/iotdb/consensus/{ => standalone}/EmptyStateMachine.java (94%)
create mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerForwardIT.java
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 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/CountNodesStatement.java => node-commons/src/main/java/org/apache/iotdb/commons/udf/service/UDFExecutableResource.java (66%)
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 node-commons/src/main/java/org/apache/iotdb/commons/partition/RegionReplicaSetInfo.java => server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardConfiguration.java (52%)
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
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/process/SlidingWindowAggregationOperator.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/schema/SchemaQueryOrderByHeatOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/CreateFunctionTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/DropFunctionTask.java
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/read/SchemaQueryOrderByHeatNode.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/SchemaFetchStatement.java => crud/DeleteDataStatement.java} (52%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/SchemaFetchStatement.java => internal/LastPointFetchStatement.java} (55%)
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 => DropFunctionStatement.java} (61%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/StorageEngineV2Test.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/operator/SlidingWindowAggregationOperatorTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/execution/schedule/{DefaultTaskSchedulerTest.java => DefaultDriverSchedulerTest.java} (99%)
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%)
delete mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/DeleteTimeseriesTest.java
rename server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/{BasicTest.java => DistributionPlannerBasicTest.java} (99%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/plan/distribution/LastQueryTest.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%)