You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/11/11 07:02:01 UTC
[iotdb] branch lmh/docUpdate updated (671a50720d -> 1106f5c341)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/docUpdate
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 671a50720d refactor user guide (tmp save)
add 842b873015 remove Tracing
add 3e86379d82 [IOTDB-4681] speed up mpp load (#7725)
add cb74d4983d [IOTDB-4673]Removes the space character from both the start and the end of the parameter value (#7921)
add 1f8085c65d [IOTDB-4768] Balancing cluster RegionGroup leader distribution by MinimumCostFlow algorithm (#7774)
add c17c0479ef [IOTDB-4866] Fix schema tree bug when append nested device (#7925)
add f67a8c28d8 Chapter-adjustment (#7922)
add 6abecabfad fix the NPE when addPeer to a MultiLeader Group with 1 replic (#7927)
add bbc910b087 [IOTDB-4868] Drop trigger should fail when trigger.OnDrop throws an exception (#7928)
add 91d475c9b8 Add class which are inspired by Trino into LICENSE (#7926)
add 14cd9c4666 [IOTDB-4871] Only call restore method for stateful trigger
add 7e16003793 Rollback modification of FrangmentInstanceDispatherImpl.dispatchWriteSync (#7933)
add cec66b62f5 Use CAS way to reserve memory (#7939)
add ebad1dd5bf Grafana plugin code optimization (#7934)
add c29f46ac03 Change initBeforeClass to initBeforeTest (#7938)
add 9c271753fd fix: submodule url (#7940)
add fe0fa38d8a [IOTDB-4880] Fix memory leak in query (#7937)
add f4e73491f1 cleanup spotless workaround code and doc (#7942)
add ff2541bf6b [IOTDB-4865] Cluster tool — show cluster details (#7935)
add 939bc592aa Remove old storage engine code and refactor UTs (#7932)
add 87a416e6d2 [IOTDB-4666]Get the devices on one leaf node at a time while compacting (#7646)
add 9ac112433e [IOTDB-4576]Add NULL Operand and modify operations about it & Use False if the series in the predicate does not exist (#7924)
add 072835c94a [IOTDB-4819] Record concrete failure info in FI State and pass it to client
add 2c5f012540 [IOTDB-4745] Add ADD_NEW_NODE state for ConfigNodeProcedure (#7743)
add c04d3fa9cc [IOTDB-4835] Fix InnerSpaceCompaction may be blocked (#7901)
add 887e49fb2b optimize transfer leader implementation (#7923)
add b22ed4b4ad [IOTDB-4811]Fix snapshot file name error (#7900)
add 05633d6e8c [IOTDB-4894] Fix bug that TsFileSketchTool prints only the first page info when there are multiple pages in a chunk (#7955)
add a5d6e97259 [IOTDB-4726]show cluster return with msg: 500 null (#7952)
add 9f9975eac5 [IOTDB-4876] Fix PathPatternTree missing information on subpaths (#7943)
add 7bc44b5db6 [IOTDB-4753] Error serialized data size in TsFileData (#7953)
add fa4613221a Bump swagger-jersey2-jaxrs from 1.5.18 to 1.5.24 (#7893)
add 43cc564aa5 [IOTDB-4558] Use insertRowsOfOneDevice to execute insert multi rows sql statement (#7918)
add 1bd98662c2 [IOTDB-4887] Tidy the UDF and Trigger folders (#7945)
add c1dafdd072 [IOTDB-4851] Perfect ChangeLeader method in RegionMigrateProcedure (#7948)
add 487b3edc16 [IOTDB-4784] Control total memory for enabling time partition for storage engine (#7792)
add 18fc3f391e [IOTDB-4771]BufferedPipeDataQueueTest.testOfferWhileTakingWithDiscontinuousSerialNumber fail (#7954)
add 6a85f6c60c [IOTDB-4838] Adapt SchemaRegionSchemaFileImpl's recovery to Ratis. (#7936)
add 3614ca7899 Remove old storage engine step two (#7959)
add 5e5de92c6c Remove the entry of setting tsfile size (#7962)
add 44c090592b [ISSUE-7941] Fix NumberFormatException when JDK version is 17-internal (#7947)
add 6dcd5a59d5 Fix the problem in greedySelectLeader (#7964)
add dca02600c0 Merge remote-tracking branch 'origin/master' into lmh/docUpdate
add 1106f5c341 refactor directory structure
No new revisions were added by this update.
Summary of changes:
.gitmodules | 4 +-
LICENSE | 15 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../confignode/client/DataNodeRequestType.java | 1 +
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/async/handlers/AsyncClientHandler.java | 1 +
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 98 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 75 +-
.../confignode/conf/ConfigNodeDescriptor.java | 501 ++++---
.../iotdb/confignode/manager/ConsensusManager.java | 47 +-
.../manager/load/balancer/RouteBalancer.java | 145 +-
.../manager/load/balancer/router/mcf/MCFEdge.java | 29 +-
.../balancer/router/mcf/MCFLeaderBalancer.java | 305 ++++
.../iotdb/confignode/manager/node/NodeManager.java | 13 +
.../manager/partition/PartitionManager.java | 12 +
.../iotdb/confignode/persistence/TriggerInfo.java | 2 +-
.../iotdb/confignode/persistence/UDFInfo.java | 2 +-
.../confignode/persistence/node/NodeInfo.java | 16 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 62 +-
.../procedure/env/DataNodeRemoveHandler.java | 83 +-
.../impl/node/AddConfigNodeProcedure.java | 40 +-
.../impl/node/RemoveDataNodeProcedure.java | 2 +
.../impl/statemachine/RegionMigrateProcedure.java | 19 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 4 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +
.../balancer/router/mcf/MCFLeaderBalancerTest.java | 216 +++
.../confignode1conf/iotdb-common.properties | 2 +-
.../confignode2conf/iotdb-common.properties | 2 +-
.../confignode3conf/iotdb-common.properties | 2 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 12 +
.../multileader/logdispatcher/LogDispatcher.java | 24 +-
.../logdispatcher/MultiLeaderMemoryManager.java | 40 +-
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 23 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 18 +
docs/UserGuide/Cluster/Cluster-Setup.md | 2 +-
.../Sync-Tool.md | 0
.../Frequently-asked-questions.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 23 +
.../UserGuide/{Alert => Monitor-Alert}/Alerting.md | 0
.../Metric-Tool.md | 0
docs/UserGuide/Process-Data/Triggers.md | 23 +-
docs/UserGuide/Reference/Syntax-Conventions.md | 6 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 2 +-
.../Sync-Tool.md | 0
.../Frequently-asked-questions.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 22 +
.../UserGuide/{Alert => Monitor-Alert}/Alerting.md | 2 +-
.../Metric-Tool.md | 0
.../UserGuide/Operators-Functions/Aggregation.md | 0
.../Anomaly-Detection.md | 0
.../M4.md => Operators-Functions/Comparison.md} | 4 -
docs/zh/UserGuide/Operators-Functions/Constant.md | 56 +
.../Operators-Functions/Continuous-Interval.md | 71 +
.../zh/UserGuide/Operators-Functions/Conversion.md | 128 ++
.../Data-Matching.md | 0
.../Data-Profiling.md | 0
.../Data-Quality.md | 0
.../Data-Repairing.md | 0
.../Frequency-Domain.md | 0
.../M4.md => Operators-Functions/Lambda.md} | 5 -
docs/zh/UserGuide/Operators-Functions/Logical.md | 164 +++
.../UserGuide/Operators-Functions/Mathematical.md | 114 ++
docs/zh/UserGuide/Operators-Functions/Overview.md | 57 +
docs/zh/UserGuide/Operators-Functions/Sample.md | 391 +++++
docs/zh/UserGuide/Operators-Functions/Selection.md | 51 +
.../Series-Discovery.md | 0
.../String.md} | 61 +-
.../Time-Series.md} | 36 +-
.../User-Defined-Function.md} | 2 +-
.../Operators-Functions/Variation-Trend.md | 55 +
.../Continuous-Query.md | 0
.../zh/UserGuide/Query-Data/Functions-Operators.md | 993 -------------
.../{UDF-Library/M4.md => Query-Data/Order-By.md} | 6 +-
docs/zh/UserGuide/Query-Data/Overview.md | 38 +-
docs/zh/UserGuide/Query-Data/Select-Expression.md | 2 +-
.../{Process-Data => Query-Data}/Select-Into.md | 0
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 6 +-
.../Triggers.md => Trigger/Trigger.md} | 22 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 3 +-
grafana-plugin/README.md | 128 --
grafana-plugin/pkg/main.go | 2 +-
.../pkg/plugin/iotdb_resource_handler.go | 170 +++
grafana-plugin/pkg/plugin/plugin.go | 119 +-
grafana-plugin/src/ConfigEditor.tsx | 70 +-
grafana-plugin/src/datasource.ts | 47 +-
grafana-plugin/src/img/addIoTDBDataSource.png | Bin 0 -> 43760 bytes
grafana-plugin/src/img/showData.png | Bin 0 -> 170827 bytes
grafana-plugin/src/plugin.json | 4 +-
grafana-plugin/src/types.ts | 3 +-
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 1 +
.../java/org/apache/iotdb/it/env/MppConfig.java | 7 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 8 +
.../it/IoTDBClusterRegionLeaderBalancingIT.java | 151 ++
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues3IT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValues4IT.java | 4 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 4 +-
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 242 ++++
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 39 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 55 +-
.../IoTDBLoadExternalTsfileWithVirtualSGIT.java | 4 +-
.../db/integration/IoTDBRemovePartitionIT.java | 622 ++++----
.../resources/conf/iotdb-common.properties | 65 +-
.../iotdb/commons/conf/CommonDescriptor.java | 61 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 3 +-
.../iotdb/commons/partition/DataPartition.java | 8 -
.../apache/iotdb/commons/path/PathPatternNode.java | 58 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 16 +-
.../apache/iotdb/commons/trigger/TriggerTable.java | 4 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 2 +-
.../iotdb/commons/path/PathPatternTreeTest.java | 19 +
.../iotdb/commons/utils/JVMCommonUtilsTest.java | 30 +-
pom.xml | 8 +-
.../schemaregion/rocksdb/RSchemaRegion.java | 131 --
.../metadata/tagSchemaRegion/TagSchemaRegion.java | 85 --
.../apache/iotdb/db/client/ConfigNodeClient.java | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 43 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 175 +--
.../statemachine/DataRegionStateMachine.java | 16 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 1011 +------------
.../apache/iotdb/db/engine/StorageEngineV2.java | 42 +-
.../engine/compaction/CompactionTaskManager.java | 1 +
.../sizetiered/SizeTieredCompactionSelector.java | 78 +-
.../inner/utils/MultiTsFileDeviceIterator.java | 4 +-
.../iotdb/db/engine/load/AlignedChunkData.java | 339 ++---
.../org/apache/iotdb/db/engine/load/ChunkData.java | 25 +-
.../apache/iotdb/db/engine/load/DeletionData.java | 4 +-
.../iotdb/db/engine/load/LoadTsFileManager.java | 17 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 258 ++--
.../apache/iotdb/db/engine/load/TsFileData.java | 3 +-
.../load/TsFileSplitter.java} | 415 ++----
.../iotdb/db/engine/memtable/AbstractMemTable.java | 204 +--
.../engine/memtable/AlignedWritableMemChunk.java | 10 +
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 25 +-
.../db/engine/memtable/IWritableMemChunk.java | 6 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 2 +
.../iotdb/db/engine/memtable/WritableMemChunk.java | 9 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 25 +-
.../selectinto/InsertTabletPlanGenerator.java | 252 ----
.../selectinto/InsertTabletPlansIterator.java | 190 ---
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 18 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 755 ++--------
.../db/engine/storagegroup/DataRegionInfo.java | 2 +-
...hTimeManager.java => HashLastFlushTimeMap.java} | 235 ++-
...meManager.java => IDTableLastFlushTimeMap.java} | 179 ++-
...lushTimeManager.java => ILastFlushTimeMap.java} | 34 +-
.../db/engine/storagegroup/TimePartitionInfo.java | 66 +
.../engine/storagegroup/TimePartitionManager.java | 165 +++
.../db/engine/storagegroup/TsFileManager.java | 6 +
.../db/engine/storagegroup/TsFileProcessor.java | 172 +--
.../db/engine/storagegroup/TsFileResource.java | 6 +
.../dataregion/HashVirtualPartitioner.java | 58 -
.../dataregion/StorageGroupManager.java | 505 -------
.../storagegroup/timeindex/DeviceTimeIndex.java | 4 +-
.../storagegroup/timeindex/FileTimeIndex.java | 6 +-
.../db/engine/trigger/executor/TriggerEngine.java | 64 -
.../trigger/sink/local/LocalIoTDBHandler.java | 12 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 33 -
.../apache/iotdb/db/metadata/MetadataConstant.java | 3 +-
.../apache/iotdb/db/metadata/idtable/IDTable.java | 3 +-
.../db/metadata/idtable/IDTableHashmapImpl.java | 134 --
.../db/metadata/idtable/entry/DeviceEntry.java | 37 +-
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 9 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 53 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 1 +
.../db/metadata/mtree/store/CachedMTreeStore.java | 29 +-
.../mtree/store/disk/schemafile/ISchemaFile.java | 3 +
.../store/disk/schemafile/MockSchemaFile.java | 6 +
.../mtree/store/disk/schemafile/SchemaFile.java | 72 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 3 -
.../schemaregion/SchemaRegionMemoryImpl.java | 215 ---
.../schemaregion/SchemaRegionSchemaFileImpl.java | 445 +++---
.../metadata/schemaregion/SchemaRegionUtils.java | 48 -
.../apache/iotdb/db/metadata/tag/TagManager.java | 58 +-
.../db/mpp/common/header/ColumnHeaderConstant.java | 21 +-
.../db/mpp/common/header/DatasetHeaderFactory.java | 4 +
.../mpp/common/schematree/ClusterSchemaTree.java | 3 +
.../common/schematree/node/SchemaEntityNode.java | 1 +
.../iotdb/db/mpp/execution/StateMachine.java | 3 -
.../fragment/FragmentInstanceContext.java | 11 +-
.../fragment/FragmentInstanceExecution.java | 9 +-
.../fragment/FragmentInstanceFailureInfo.java | 212 +++
.../execution/fragment/FragmentInstanceInfo.java | 21 +-
.../fragment/FragmentInstanceManager.java | 35 +-
.../operator/process/FilterAndProjectOperator.java | 10 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 5 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 34 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 31 +-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 12 +-
.../plan/execution/config/ConfigTaskVisitor.java | 5 +-
.../config/executor/ClusterConfigTaskExecutor.java | 20 +-
.../config/executor/IConfigTaskExecutor.java | 3 +-
.../executor/StandaloneConfigTaskExecutor.java | 3 +-
...lusterTask.java => ShowClusterDetailsTask.java} | 78 +-
.../execution/config/metadata/ShowClusterTask.java | 8 +-
.../config/metadata/ShowFunctionsTask.java | 15 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 5 +
.../db/mpp/plan/expression/ExpressionType.java | 2 +
.../db/mpp/plan/expression/leaf/NullOperand.java | 101 ++
.../plan/expression/unary/NegationExpression.java | 2 +
.../visitor/ColumnTransformerVisitor.java | 17 +
.../plan/expression/visitor/ExpressionVisitor.java | 5 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 12 +-
.../plan/node/load/LoadSingleTsFileNode.java | 415 +-----
.../planner/plan/node/load/LoadTsFileNode.java | 19 +-
.../plan/node/load/LoadTsFilePieceNode.java | 13 +-
.../planner/plan/node/write/InsertRowNode.java | 2 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 12 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../scheduler/AbstractFragInsStateTracker.java | 33 +-
.../scheduler/FixedRateFragInsStateTracker.java | 27 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 58 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 230 ++-
.../statement/metadata/ShowClusterStatement.java | 10 +
.../dag/column/ColumnTransformer.java | 31 +
.../binary/CompareBinaryColumnTransformer.java | 7 +-
.../binary/CompareEqualToColumnTransformer.java | 2 +-
.../column/binary/LogicAndColumnTransformer.java | 30 +
.../binary/LogicBinaryColumnTransformer.java | 24 -
.../column/binary/LogicOrColumnTransformer.java | 30 +
.../dag/column/leaf/NullColumnTransformer.java} | 31 +-
.../ternary/CompareTernaryColumnTransformer.java | 17 +-
.../dag/column/unary/InColumnTransformer.java | 8 +-
.../column/unary/LogicNotColumnTransformer.java | 2 +-
.../dag/column/unary/RegularColumnTransformer.java | 2 +-
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 14 -
.../db/protocol/influxdb/meta/TagInfoRecords.java | 24 -
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 79 --
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 1374 ------------------
.../db/qp/logical/crud/DeleteDataOperator.java | 15 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 31 +-
.../db/qp/logical/sys/DeletePartitionOperator.java | 3 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 24 -
.../db/qp/physical/crud/DeletePartitionPlan.java | 53 -
.../iotdb/db/qp/physical/crud/DeletePlan.java | 221 ---
.../qp/physical/crud/InsertMultiTabletsPlan.java | 453 ------
.../iotdb/db/qp/physical/crud/InsertPlan.java | 239 ----
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 812 -----------
.../physical/crud/InsertRowsOfOneDevicePlan.java | 296 ----
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 302 ----
.../db/qp/physical/crud/InsertTabletPlan.java | 895 ------------
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 4 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 31 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 6 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 14 -
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 9 +-
.../org/apache/iotdb/db/service/MQTTService.java | 6 +-
.../java/org/apache/iotdb/db/service/NewIoTDB.java | 4 -
.../org/apache/iotdb/db/service/SettleService.java | 36 +-
.../org/apache/iotdb/db/service/UpgradeSevice.java | 16 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 34 +-
.../db/service/thrift/impl/TSServiceImpl.java | 548 +------
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 6 +-
.../db/sync/receiver/load/DeletionLoader.java | 7 -
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 15 -
.../apache/iotdb/db/tools/TsFileSketchTool.java | 193 ++-
.../iotdb/db/tools/TsFileSplitByPartitionTool.java | 10 +-
.../db/tools/dataregion/DeviceMappingViewer.java | 63 -
.../db/tools/schema/SchemaFileSketchTool.java | 7 +
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 6 +-
.../iotdb/db/trigger/executor/TriggerExecutor.java | 3 +-
.../trigger/service/TriggerManagementService.java | 8 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 24 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 54 -
.../apache/iotdb/db/utils/TimePartitionUtils.java | 4 +
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 17 +-
.../db/utils/datastructure/BooleanTVList.java | 13 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 13 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 13 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 13 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 13 +-
.../iotdb/db/utils/datastructure/TVList.java | 20 +-
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 23 +-
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 7 +-
.../apache/iotdb/db/wal/buffer/WALInfoEntry.java | 20 +-
.../org/apache/iotdb/db/wal/node/IWALNode.java | 11 -
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 19 -
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 42 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 101 --
.../file/UnsealedTsFileRecoverPerformer.java | 11 +-
.../engine/compaction/AbstractCompactionTest.java | 21 +
.../engine/compaction/CompactionSchedulerTest.java | 103 +-
.../ReadPointCompactionPerformerTest.java | 153 +-
.../compaction/inner/InnerSeqCompactionTest.java | 6 +-
.../utils/MultiTsFileDeviceIteratorTest.java | 120 ++
.../db/engine/memtable/MemTableFlushTaskTest.java | 6 +-
.../db/engine/memtable/MemTableTestUtils.java | 69 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 65 +-
.../db/engine/storagegroup/DataRegionTest.java | 87 +-
.../storagegroup/FileNodeManagerBenchmark.java | 132 --
.../storagegroup/IDTableLastFlushTimeMapTest.java | 129 ++
.../engine/storagegroup/LastFlushTimeMapTest.java | 223 +++
.../storagegroup/StorageGroupProcessorTest.java | 871 ------------
.../iotdb/db/engine/storagegroup/TTLTest.java | 156 +-
.../storagegroup/TimePartitionManagerTest.java | 129 ++
.../engine/storagegroup/TsFileProcessorTest.java | 476 -------
.../engine/storagegroup/TsFileProcessorV2Test.java | 12 +-
.../dataregion/HashVirtualPartitionerTest.java | 63 -
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 298 ----
.../org/apache/iotdb/db/metadata/TemplateTest.java | 151 +-
.../db/metadata/idtable/IDTableFlushTimeTest.java | 226 ---
.../db/metadata/idtable/IDTableLogFileTest.java | 239 ++--
.../db/metadata/idtable/IDTableRecoverTest.java | 354 +++--
.../iotdb/db/metadata/idtable/IDTableTest.java | 1479 +++++++++----------
.../db/metadata/idtable/LastQueryWithIDTable.java | 285 ++--
.../schemaRegion/SchemaRegionBasicTest.java | 124 ++
.../schemaRegion/SchemaRegionSnapshotTest.java | 168 ---
.../common/schematree/ClusterSchemaTreeTest.java | 25 +
.../FragmentInstanceFailureInfoSerdeTest.java | 85 ++
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 69 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 140 --
.../qp/physical/InsertRowsOfOneDevicePlanTest.java | 75 -
.../db/qp/physical/PhysicalPlanSerializeTest.java | 326 -----
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 1490 --------------------
.../iotdb/db/qp/physical/SerializationTest.java | 151 --
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 --
.../iotdb/db/query/dataset/SingleDataSetTest.java | 199 ++-
.../sync/pipedata/BufferedPipeDataQueueTest.java | 1 +
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 397 +++---
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 16 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 14 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 35 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 11 +-
.../db/utils/writelog/LogWriterReaderTest.java | 50 +-
.../db/utils/writelog/MultiFileLogReaderTest.java | 15 +-
.../org/apache/iotdb/db/wal/WALManagerTest.java | 52 +-
.../db/wal/allocation/ElasticStrategyTest.java | 16 +-
.../db/wal/allocation/FirstCreateStrategyTest.java | 18 +-
.../db/wal/allocation/RoundRobinStrategyTest.java | 16 +-
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 68 +-
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 119 +-
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 22 +-
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 90 +-
.../db/wal/recover/WALRecoverManagerTest.java | 100 +-
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 244 ++--
.../file/UnsealedTsFileRecoverPerformerTest.java | 44 +-
.../datanode1conf/iotdb-common.properties | 2 +-
.../datanode2conf/iotdb-common.properties | 2 +-
.../datanode3conf/iotdb-common.properties | 2 +-
.../datanode3conf/iotdb-datanode.properties | 2 +-
.../src/test/resources/iotdb-datanode.properties | 2 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
site/src/main/.vuepress/config.js | 118 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 10 +-
.../src/main/thrift/confignode.thrift | 3 +
thrift/src/main/thrift/datanode.thrift | 10 +-
.../iotdb/tsfile/file/header/ChunkHeader.java | 21 +
.../iotdb/tsfile/file/header/PageHeader.java | 10 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 34 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 118 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 5 +-
.../read/common/block/column/NullColumn.java | 87 +-
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 2 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 4 +
.../write/writer/TsFileIOWriterEndFileTest.java | 49 +
366 files changed, 10494 insertions(+), 21126 deletions(-)
copy server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/VirtualPartitioner.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFEdge.java (64%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFLeaderBalancer.java
create mode 100644 confignode/src/test/java/org/apache/iotdb/confignode/manager/load/balancer/router/mcf/MCFLeaderBalancerTest.java
rename docs/UserGuide/{Maintenance-Tools => Edge-Cloud-Collaboration}/Sync-Tool.md (100%)
rename docs/UserGuide/{Reference => FAQ}/Frequently-asked-questions.md (100%)
rename docs/UserGuide/{Alert => Monitor-Alert}/Alerting.md (100%)
rename docs/UserGuide/{Maintenance-Tools => Monitor-Alert}/Metric-Tool.md (100%)
rename docs/zh/UserGuide/{Maintenance-Tools => Edge-Cloud-Collaboration}/Sync-Tool.md (100%)
rename docs/zh/UserGuide/{Reference => FAQ}/Frequently-asked-questions.md (100%)
rename docs/zh/UserGuide/{Alert => Monitor-Alert}/Alerting.md (99%)
rename docs/zh/UserGuide/{Maintenance-Tools => Monitor-Alert}/Metric-Tool.md (100%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Aggregation.md
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Anomaly-Detection.md (100%)
copy docs/zh/UserGuide/{UDF-Library/M4.md => Operators-Functions/Comparison.md} (86%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Constant.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Continuous-Interval.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Conversion.md
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Matching.md (100%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Profiling.md (100%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Quality.md (100%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Data-Repairing.md (100%)
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Frequency-Domain.md (100%)
copy docs/zh/UserGuide/{UDF-Library/M4.md => Operators-Functions/Lambda.md} (86%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Logical.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Mathematical.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Overview.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Sample.md
create mode 100644 docs/zh/UserGuide/Operators-Functions/Selection.md
rename docs/zh/UserGuide/{UDF-Library => Operators-Functions}/Series-Discovery.md (100%)
rename docs/zh/UserGuide/{UDF-Library/String-Processing.md => Operators-Functions/String.md} (90%)
rename docs/zh/UserGuide/{UDF-Library/Series-Processing.md => Operators-Functions/Time-Series.md} (83%)
rename docs/zh/UserGuide/{Process-Data/UDF-User-Defined-Function.md => Operators-Functions/User-Defined-Function.md} (99%)
create mode 100644 docs/zh/UserGuide/Operators-Functions/Variation-Trend.md
rename docs/zh/UserGuide/{Process-Data => Query-Data}/Continuous-Query.md (100%)
delete mode 100644 docs/zh/UserGuide/Query-Data/Functions-Operators.md
rename docs/zh/UserGuide/{UDF-Library/M4.md => Query-Data/Order-By.md} (86%)
rename docs/zh/UserGuide/{Process-Data => Query-Data}/Select-Into.md (100%)
rename docs/zh/UserGuide/{Process-Data/Triggers.md => Trigger/Trigger.md} (95%)
create mode 100644 grafana-plugin/pkg/plugin/iotdb_resource_handler.go
create mode 100644 grafana-plugin/src/img/addIoTDBDataSource.png
create mode 100644 grafana-plugin/src/img/showData.png
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBNullOperandIT.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/metadata/ShowClusterStatement.java => node-commons/src/test/java/org/apache/iotdb/commons/utils/JVMCommonUtilsTest.java (53%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/plan/planner/plan/node/load/LoadSingleTsFileNode.java => engine/load/TsFileSplitter.java} (53%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/selectinto/InsertTabletPlanGenerator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/selectinto/InsertTabletPlansIterator.java
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{LastFlushTimeManager.java => HashLastFlushTimeMap.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{IDTableFlushTimeManager.java => IDTableLastFlushTimeMap.java} (51%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{ILastFlushTimeManager.java => ILastFlushTimeMap.java} (67%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/HashVirtualPartitioner.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/dataregion/StorageGroupManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureInfo.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/metadata/{ShowClusterTask.java => ShowClusterDetailsTask.java} (56%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/leaf/NullOperand.java
rename server/src/main/java/org/apache/iotdb/db/{engine/storagegroup/dataregion/VirtualPartitioner.java => mpp/transformation/dag/column/leaf/NullColumnTransformer.java} (62%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/DeletePartitionPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/DeletePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertMultiTabletsPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsOfOneDevicePlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertRowsPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertTabletPlan.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/tools/dataregion/DeviceMappingViewer.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/compaction/utils/MultiTsFileDeviceIteratorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/FileNodeManagerBenchmark.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/IDTableLastFlushTimeMapTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/LastFlushTimeMapTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/StorageGroupProcessorTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessorTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/dataregion/HashVirtualPartitionerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableFlushTimeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/schemaRegion/SchemaRegionSnapshotTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureInfoSerdeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/ConcatOptimizerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/InsertRowsOfOneDevicePlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/PhysicalPlanSerializeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/PhysicalPlanTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/SerializationTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/SerializedSizeTest.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/write/writer/TsFileIOWriterEndFileTest.java