You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/04/11 04:03:09 UTC
[iotdb] branch rocksdb/dev updated (c54a7a50f0 -> 516f100ab3)
This is an automated email from the ASF dual-hosted git repository.
jianyun pushed a change to branch rocksdb/dev
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c54a7a50f0 Merge branch 'lsj/0408-1' into 'feature/rocksdb'
add 40fd10e634 Remove redundant docs (#5454)
add 2e82976def [IOTDB-2303]Library dmatch (#4835)
add bd01ddea00 [IOTDB-2832] Initialize the consensus layer of the Datanode (#5417)
add 9d206f9568 [IOTDB-2857] Move methods in serviceProvider to sessionManager (#5440)
add 19d469775d Construct SinkHandle in LocalExecutionPlanner and remove the IOExecption in next and hasNext method of Operator (#5449)
add f3cc2821ba Update iotdb-doap.rdf (#5456)
add 87c8ab4ac8 [IOTDB-2304]Library-UDF Data Repairing Functions (#4833)
add 69b3920af7 Update iotdb-doap.rdf (#5457)
add dd67c0aacb Update iotdb-doap.rdf (#5458)
add a8f7439db9 [IOTDB-2841] add permission manager model (#5401)
add 931e309ad8 [IOTDB-2803]add AlterTimeSeriesNode and CreateAlignedTimeSeriesNode to PlanNodeType and its serialize and deserialize (#5444)
add 03f876ea19 [IOTDB-2864] Fix Read-only occurred when insert Text values to aligned timeseries (#5460)
add 1d946c71c7 Fix coverage check
add 99c824f4d0 [IOTDB-2807]Speed up the cross space compaction by multi-threads (#5415)
add 9ee5aedc1d [IOTDB-2801] New storage engine framework (#5357)
add 168cfe85ce [IOTDB-2827] Batch insert in new cluster (#5412)
add 43a8febae5 Modify the jdbc query time column to be empty (#5281)
add ce3661f2db user SerializeDeserializeUtil in confignode/AuthorPlan (#5467)
add 18c54ca050 Update ContributeGuide.md (#5463)
add 3c81f567f4 [IOTDB-1614] New WAL (#5320)
add cc78c84f99 [IOTDB-2658] Generate logical plan for query statement —— UT & Raw Data Query & Aggregation Query (#5469)
add 3e476e3756 [IOTDB-2806][InfluxDB] Compatibility of Apache IoTDB with InfluxDB - Complete UserGuide (#5351)
add 600ba97481 [IOTDB-2872] Rename vsg to dataRegion (#5470)
add b4a2185774 Merge branch 'master' into lsj/0411-1
add 4207589d9a [rocksdb] merge master and fix conflicts
add 0611a09de9 Merge branch 'lsj/0411-1' into 'feature/rocksdb'
add 9023fa94a3 [RocksDB] fix sonar bugs
add c395f1c565 [RcoskDB] fix some sonar detected code smell bugs
add 516f100ab3 Merge branch 'jianyun/dev-rocksdb' into 'feature/rocksdb'
No new revisions were added by this update.
Summary of changes:
.github/workflows/influxdb-protocol.yml | 8 +-
.github/workflows/sonar-coveralls.yml | 2 +-
README.md | 2 +-
README_ZH.md | 2 +-
.../iotdb/cluster/ClusterFileFlushPolicy.java | 11 +-
.../iotdb/cluster/coordinator/Coordinator.java | 26 +-
.../cluster/log/applier/AsyncDataLogApplier.java | 10 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 14 +-
.../iotdb/cluster/metadata/CSchemaProcessor.java | 27 +-
.../partition/slot/SlotTimePartitionFilter.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 59 +-
.../cluster/server/member/DataGroupMember.java | 11 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 2 +-
.../cluster/log/applier/DataLogApplierTest.java | 10 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 14 +-
.../log/snapshot/PartitionedSnapshotTest.java | 6 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 4 +-
.../iotdb/cluster/server/member/BaseMember.java | 9 +-
.../cluster/server/member/DataGroupMemberTest.java | 4 +-
.../cluster/server/member/MetaGroupMemberTest.java | 4 +-
.../iotdb/cluster/utils/SerializeUtilTest.java | 2 -
confignode/pom.xml | 5 +
.../resources/conf/iotdb-confignode.properties | 21 +-
.../iotdb/confignode/conf/ConfigNodeConf.java | 30 +-
.../confignode/conf/ConfigNodeDescriptor.java | 39 +-
.../consensus/response/PermissionInfoDataSet.java | 9 +-
.../statemachine/PartitionRegionStateMachine.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 16 +
.../iotdb/confignode/manager/ConsensusManager.java | 57 +-
.../apache/iotdb/confignode/manager/Manager.java | 8 +
.../confignode/manager/PermissionManager.java | 25 +-
.../persistence/AuthorInfoPersistence.java | 146 ++
.../persistence/RegionInfoPersistence.java | 6 +-
.../iotdb/confignode/physical/PhysicalPlan.java | 25 +-
.../confignode/physical/PhysicalPlanType.java | 20 +-
.../iotdb/confignode/physical/sys/AuthorPlan.java | 228 +++
.../physical/sys/SchemaPartitionPlan.java | 3 +-
.../confignode/service/executor/PlanExecutor.java | 36 +-
.../server/ConfigNodeRPCServerProcessor.java | 29 +
.../apache/iotdb/confignode/auth/AuthorTest.java | 31 +-
.../server/ConfigNodeRPCServerProcessorTest.java | 56 +-
consensus/README.md | 126 +-
consensus/pom.xml | 2 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 57 +
.../ConsensusGroupAlreadyExistException.java | 2 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 150 +-
.../org/apache/iotdb/consensus/ratis/Utils.java | 17 +-
.../consensus/standalone/StandAloneConsensus.java | 20 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 23 +-
.../apache/iotdb/consensus/ratis/UtilsTest.java | 7 +-
.../standalone/StandAloneConsensusTest.java | 43 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 341 ++++
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
.../{VirtualStorageGroup.md => DataRegion.md} | 10 +-
docs/UserGuide/Library-UDF/Anomaly-Detection.md | 523 ------
docs/UserGuide/Library-UDF/Data-Profile.md | 1798 --------------------
docs/UserGuide/Library-UDF/Data-Quality.md | 523 ------
docs/UserGuide/Library-UDF/Frequency-Domain.md | 594 -------
docs/UserGuide/Library-UDF/Get-Started.md | 61 -
docs/UserGuide/Library-UDF/Series-Discovery.md | 170 --
docs/UserGuide/Reference/Config-Manual.md | 41 +-
docs/zh/Development/ContributeGuide.md | 11 +-
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 122 +-
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 -
.../{VirtualStorageGroup.md => DataRegion.md} | 12 +-
docs/zh/UserGuide/Library-UDF/Anomaly Detection.md | 530 ------
docs/zh/UserGuide/Library-UDF/Data-Profile.md | 1790 -------------------
docs/zh/UserGuide/Library-UDF/Data-Quality.md | 510 ------
docs/zh/UserGuide/Library-UDF/Frequency-Domain.md | 587 -------
docs/zh/UserGuide/Library-UDF/Get-Started.md | 58 -
docs/zh/UserGuide/Library-UDF/Series-Discovery.md | 171 --
docs/zh/UserGuide/Reference/Config-Manual.md | 16 +-
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 1 -
.../iotdb/integration/env/ClusterEnvConfig.java | 5 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 2 +-
.../iotdb/db/integration/IoTDBCompleteIT.java | 9 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 6 +-
.../db/integration/IoTDBNewTsFileCompactionIT.java | 7 +-
.../aggregation/IoTDBAggregationIT.java | 28 +
...luesIT.java => IoTDBInsertAlignedValuesIT.java} | 21 +-
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 6 +-
.../db/integration/env/StandaloneEnvConfig.java | 4 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 7 +-
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 86 +
.../org/apache/iotdb/library/dmatch/UDAFDtw.java | 91 +
.../apache/iotdb/library/dmatch/UDAFPearson.java | 95 ++
.../apache/iotdb/library/dmatch/UDTFPtnSym.java | 98 ++
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 86 +
.../library/dmatch/util/CrossCorrelation.java | 54 +
.../iotdb/library/drepair/UDTFTimestampRepair.java | 102 ++
.../iotdb/library/drepair/UDTFValueFill.java | 104 ++
.../iotdb/library/drepair/UDTFValueRepair.java | 122 ++
.../apache/iotdb/library/drepair/util/ARFill.java | 93 +
.../iotdb/library/drepair/util/LikelihoodFill.java | 128 ++
.../iotdb/library/drepair/util/LinearFill.java | 57 +
.../iotdb/library/drepair/util/LsGreedy.java | 141 ++
.../apache/iotdb/library/drepair/util/MAFill.java | 57 +
.../iotdb/library/drepair/util/MeanFill.java | 27 +-
.../iotdb/library/drepair/util/PreviousFill.java | 45 +-
.../apache/iotdb/library/drepair/util/Screen.java | 138 ++
.../iotdb/library/drepair/util/ScreenFill.java | 154 ++
.../library/drepair/util/TimestampInterval.java | 213 +++
.../library/drepair/util/TimestampRepair.java | 154 ++
.../iotdb/library/drepair/util/ValueFill.java | 81 +
.../iotdb/library/drepair/util/ValueRepair.java | 130 ++
.../apache/iotdb/library/dmatch/DMatchTests.java | 826 +++++++++
.../apache/iotdb/library/drepair/DRepairTests.java | 317 ++++
.../org/apache/iotdb/commons/cluster/Endpoint.java | 10 +
.../iotdb/commons/concurrent/ThreadName.java | 10 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 81 +-
.../{ConsensusGroupId.java => DataRegionId.java} | 50 +-
...onsensusGroupId.java => PartitionRegionId.java} | 50 +-
.../{ConsensusGroupId.java => SchemaRegionId.java} | 50 +-
.../iotdb/commons/partition/DataNodeLocation.java | 6 +-
.../iotdb/commons/partition/DataPartition.java | 4 +-
.../iotdb/commons/partition/RegionReplicaSet.java | 38 +-
.../apache/iotdb/commons/utils/CommonUtils.java | 10 +-
.../resources/conf/iotdb-engine.properties | 151 +-
.../assembly/resources/tools/rocksdb-transfer.bat | 2 +-
.../assembly/resources/tools/rocksdb-transfer.sh | 2 +-
.../db/auth/authorizer/AuthorizerManager.java | 190 +++
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 1 +
.../authorizer/ClusterAuthorizer.java} | 8 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 291 ++--
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 41 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 151 +-
.../db/conf/directories/DirectoryManager.java | 4 -
.../iotdb/db/conf/directories/FolderManager.java | 65 +
.../strategy/DirectoryStrategyType.java} | 13 +-
.../iotdb/db/consensus/ConsensusExample.java | 113 --
.../apache/iotdb/db/consensus/ConsensusImpl.java | 77 +
.../statemachine/DataRegionStateMachine.java | 11 +-
.../statemachine/SchemaRegionStateMachine.java | 11 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 173 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 595 +++++++
.../db/engine/compaction/CompactionScheduler.java | 6 +-
.../engine/compaction/CompactionTaskManager.java | 18 +
.../db/engine/compaction/CompactionUtils.java | 120 +-
.../db/engine/compaction/TsFileIdentifier.java | 30 +-
.../AbstractCrossSpaceCompactionSelector.java | 6 +-
.../RewriteCrossSpaceCompactionSelector.java | 4 +-
.../cross/rewrite/task/SubCompactionTask.java | 107 ++
.../AbstractInnerSpaceCompactionSelector.java | 6 +-
.../sizetiered/SizeTieredCompactionSelector.java | 2 +-
.../compaction/task/CompactionRecoverManager.java | 25 +-
.../writer/AbstractCompactionWriter.java | 64 +-
.../writer/CrossSpaceCompactionWriter.java | 80 +-
.../writer/InnerSpaceCompactionWriter.java | 27 +-
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 2 +-
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 2 +-
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 4 +-
.../iotdb/db/engine/flush/FlushListener.java | 17 +-
.../flush/FlushStatus.java} | 15 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 14 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 329 +++-
.../engine/memtable/AlignedWritableMemChunk.java | 51 +
.../memtable/AlignedWritableMemChunkGroup.java | 22 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 22 +-
.../db/engine/memtable/IWritableMemChunk.java | 3 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 3 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 28 +
.../db/engine/memtable/WritableMemChunkGroup.java | 37 +
...lStorageGroupProcessor.java => DataRegion.java} | 864 ++++++----
.../db/engine/storagegroup/StorageGroupInfo.java | 49 +-
.../db/engine/storagegroup/TsFileManager.java | 15 +-
.../db/engine/storagegroup/TsFileProcessor.java | 306 +++-
.../engine/storagegroup/TsFileProcessorInfo.java | 9 +-
.../db/engine/storagegroup/TsFileResource.java | 4 +-
.../HashVirtualPartitioner.java | 6 +-
.../StorageGroupManager.java | 218 +--
.../VirtualPartitioner.java | 10 +-
.../engine/trigger/service/TriggerLogReader.java | 2 +-
.../engine/trigger/service/TriggerLogWriter.java | 4 +-
...ssorException.java => DataRegionException.java} | 10 +-
.../metadata/AcquireLockTimeoutException.java | 1 +
.../exception/sql/StatementAnalyzeException.java | 6 +
.../iotdb/db/metadata/LocalConfigManager.java | 33 +-
.../db/metadata/LocalSchemaPartitionTable.java | 26 +-
.../apache/iotdb/db/metadata/SchemaEngineType.java | 1 +
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 2 +-
.../db/metadata/schemaregion/SchemaEngine.java | 14 +-
.../db/metadata/schemaregion/SchemaRegion.java | 10 +-
.../metadata/schemaregion/SchemaRegionUtils.java | 1 +
.../schemaregion/rocksdb/CheckKeyResult.java | 4 -
.../schemaregion/rocksdb/RSchemaConstants.java | 1 +
.../schemaregion/rocksdb/RSchemaLogger.java | 1 +
.../rocksdb/RSchemaReadWriteHandler.java | 1 +
.../schemaregion/rocksdb/RSchemaRegion.java | 163 +-
.../schemaregion/rocksdb/RSchemaUtils.java | 1 +
.../schemaregion/rocksdb/mnode/REntityMNode.java | 1 +
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 1 +
.../schemaregion/rocksdb/mnode/RMNode.java | 1 +
.../schemaregion/rocksdb/mnode/RMNodeType.java | 1 +
.../rocksdb/mnode/RMNodeValueType.java | 1 +
.../rocksdb/mnode/RMeasurementMNode.java | 1 +
.../rocksdb/mnode/RStorageGroupMNode.java | 1 +
.../apache/iotdb/db/metadata/tag/TagManager.java | 10 +-
.../iotdb/db/metadata/template/Template.java | 18 +-
.../db/metadata/template/TemplateManager.java | 6 +-
.../db/mpp/common/filter/BasicFunctionFilter.java | 8 +-
.../iotdb/db/mpp/common/filter/InFilter.java | 6 +-
.../iotdb/db/mpp/common/filter/LikeFilter.java | 8 +-
.../iotdb/db/mpp/common/filter/QueryFilter.java | 19 +-
.../iotdb/db/mpp/common/filter/RegexpFilter.java | 8 +-
.../db/mpp/common/schematree/PathPatternTree.java | 2 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 6 +-
.../apache/iotdb/db/mpp/execution/DataDriver.java | 4 +-
.../iotdb/db/mpp/execution/DataDriverContext.java | 8 +-
.../db/mpp/execution/FragmentInstanceManager.java | 51 +-
.../org/apache/iotdb/db/mpp/operator/Operator.java | 4 +-
.../db/mpp/operator/process/LimitOperator.java | 4 +-
.../db/mpp/operator/process/TimeJoinOperator.java | 5 +-
.../db/mpp/operator/source/SeriesScanOperator.java | 56 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 21 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 354 +++-
.../db/mpp/sql/analyze/ClusterSchemaFetcher.java | 8 +
.../mpp/sql/analyze/FakePartitionFetcherImpl.java | 13 +-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 57 +-
.../iotdb/db/mpp/sql/analyze/ISchemaFetcher.java | 5 +
.../mpp/sql/analyze/StandaloneSchemaFetcher.java | 8 +
.../apache/iotdb/db/mpp/sql/parser/ASTVisitor.java | 223 ++-
.../db/mpp/sql/parser/StatementGenerator.java | 153 +-
.../db/mpp/sql/planner/DistributionPlanner.java | 26 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 58 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 427 +++--
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 277 +++
.../plan/IOutputPlanNode.java} | 17 +-
.../db/mpp/sql/planner/plan/PlanFragment.java | 7 +-
.../plan/SimpleFragmentParallelPlanner.java | 4 +-
.../iotdb/db/mpp/sql/planner/plan/SubPlan.java | 3 +-
.../db/mpp/sql/planner/plan/node/ColumnHeader.java | 88 +
.../db/mpp/sql/planner/plan/node/PlanNode.java | 6 +-
.../db/mpp/sql/planner/plan/node/PlanNodeType.java | 26 +-
.../plan/node/metedata/read/ShowDevicesNode.java | 5 -
.../node/metedata/write/AlterTimeSeriesNode.java | 128 +-
.../plan/node/metedata/write/AuthorNode.java | 264 +++
.../write/CreateAlignedTimeSeriesNode.java | 191 ++-
.../node/metedata/write/CreateTimeSeriesNode.java | 5 -
.../planner/plan/node/process/AggregateNode.java | 93 +-
.../planner/plan/node/process/DeviceMergeNode.java | 83 +-
.../planner/plan/node/process/ExchangeNode.java | 12 +-
.../sql/planner/plan/node/process/FillNode.java | 21 +-
.../sql/planner/plan/node/process/FilterNode.java | 63 +-
.../planner/plan/node/process/FilterNullNode.java | 65 +-
.../plan/node/process/GroupByLevelNode.java | 93 +-
.../sql/planner/plan/node/process/LimitNode.java | 47 +-
.../sql/planner/plan/node/process/OffsetNode.java | 41 +-
.../sql/planner/plan/node/process/SortNode.java | 21 +-
.../planner/plan/node/process/TimeJoinNode.java | 82 +-
.../planner/plan/node/sink/FragmentSinkNode.java | 10 +-
.../plan/node/source/SeriesAggregateScanNode.java | 135 +-
.../planner/plan/node/source/SeriesScanNode.java | 84 +-
.../sql/planner/plan/node/source/SourceNode.java | 22 -
.../plan/node/write/InsertMultiTabletNode.java | 69 -
.../plan/node/write/InsertMultiTabletsNode.java | 159 ++
.../sql/planner/plan/node/write/InsertNode.java | 25 +-
.../sql/planner/plan/node/write/InsertRowNode.java | 15 +-
.../planner/plan/node/write/InsertRowsNode.java | 81 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 77 +-
.../planner/plan/node/write/InsertTabletNode.java | 25 +-
.../sql/rewriter/ColumnPaginationController.java | 46 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 24 +-
.../db/mpp/sql/statement/StatementVisitor.java | 145 +-
.../statement/component/GroupByLevelComponent.java | 5 +
.../component/GroupByLevelController.java | 16 +
.../sql/statement/component/SelectComponent.java | 16 +-
.../statement/crud/AggregationQueryStatement.java | 29 +-
.../mpp/sql/statement/crud/FillQueryStatement.java | 7 +-
.../statement/crud/GroupByFillQueryStatement.java | 5 +
.../sql/statement/crud/GroupByQueryStatement.java | 5 +
.../sql/statement/crud/InsertBaseStatement.java | 3 -
.../crud/InsertMultiTabletsStatement.java | 80 +
.../mpp/sql/statement/crud/InsertRowStatement.java | 1 -
.../crud/InsertRowsOfOneDeviceStatement.java | 90 +
.../sql/statement/crud/InsertRowsStatement.java | 87 +
.../sql/statement/crud/InsertTabletStatement.java | 6 +-
.../mpp/sql/statement/crud/LastQueryStatement.java | 7 +-
.../db/mpp/sql/statement/crud/QueryStatement.java | 41 +-
.../mpp/sql/statement/crud/UDAFQueryStatement.java | 7 +-
.../mpp/sql/statement/crud/UDTFQueryStatement.java | 6 +
.../db/mpp/sql/statement/sys/AuthorStatement.java | 152 ++
.../db/protocol/influxdb/handler/QueryHandler.java | 3 +-
.../iotdb/db/protocol/mqtt/PublishHandler.java | 12 +-
.../rest/handler/AuthorizationHandler.java | 12 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 2 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 2 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 6 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 116 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 72 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 46 +-
...TabletPlan.java => InsertMultiTabletsPlan.java} | 28 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 275 ++-
.../db/qp/physical/crud/InsertTabletPlan.java | 462 +++--
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 2 +-
.../db/query/control/QueryResourceManager.java | 12 +-
.../iotdb/db/query/control/SessionManager.java | 118 +-
.../groupby/GroupByWithValueFilterDataSet.java | 11 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 11 +-
.../db/query/executor/AggregationExecutor.java | 20 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 10 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 10 +-
.../db/query/executor/RawDataQueryExecutor.java | 20 +-
.../iotdb/db/query/expression/Expression.java | 4 -
.../query/expression/binary/BinaryExpression.java | 7 -
.../db/query/expression/unary/ConstantOperand.java | 7 -
.../query/expression/unary/FunctionExpression.java | 11 -
.../query/expression/unary/LogicNotExpression.java | 7 -
.../query/expression/unary/NegationExpression.java | 7 -
.../query/expression/unary/TimeSeriesOperand.java | 8 -
.../query/timegenerator/ServerTimeGenerator.java | 10 +-
.../apache/iotdb/db/rescon/MemTableManager.java | 14 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 14 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +-
.../iotdb/db/service/basic/ServiceProvider.java | 172 --
.../iotdb/db/service/metrics/MetricsService.java | 33 +-
.../service/thrift/impl/InfluxDBServiceImpl.java | 18 +-
.../db/service/thrift/impl/TSServiceImpl.java | 396 +++--
.../db/sync/sender/manage/ISyncFileManager.java | 4 +-
.../db/sync/sender/manage/SyncFileManager.java | 12 +-
.../iotdb/db/sync/sender/transfer/SyncClient.java | 8 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 81 +-
.../DeviceMappingViewer.java | 7 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 27 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 54 +
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 3 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 101 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 2 +-
.../SerializedSize.java} | 14 +-
.../db/utils/datastructure/AlignedTVList.java | 202 ++-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 37 +
.../db/utils/datastructure/BooleanTVList.java | 33 +
.../iotdb/db/utils/datastructure/DoubleTVList.java | 32 +
.../iotdb/db/utils/datastructure/FloatTVList.java | 32 +
.../iotdb/db/utils/datastructure/IntTVList.java | 32 +
.../iotdb/db/utils/datastructure/LongTVList.java | 32 +
.../iotdb/db/utils/datastructure/TVList.java | 28 +-
.../io => utils/writelog}/BatchLogReader.java | 2 +-
.../io => utils/writelog}/ILogReader.java | 2 +-
.../io => utils/writelog}/ILogWriter.java | 2 +-
.../{writelog/io => utils/writelog}/LogWriter.java | 2 +-
.../io => utils/writelog}/MultiFileLogReader.java | 2 +-
.../io => utils/writelog}/SingleFileLogReader.java | 4 +-
.../java/org/apache/iotdb/db/wal/WALManager.java | 226 +++
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 76 +
.../buffer/IWALBuffer.java} | 29 +-
.../iotdb/db/wal/buffer/IWALByteBufferView.java | 52 +
.../buffer/SignalWALEntry.java} | 38 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 454 +++++
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 219 +++
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 55 +
.../buffer/WALEntryValue.java} | 21 +-
.../apache/iotdb/db/wal/checkpoint/Checkpoint.java | 102 ++
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 257 +++
.../checkpoint/CheckpointType.java} | 35 +-
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 113 ++
.../exception/WALException.java} | 19 +-
.../exception/WALNodeClosedException.java} | 10 +-
.../exception/WALRecoverException.java} | 12 +-
.../apache/iotdb/db/wal/io/CheckpointReader.java | 63 +
.../apache/iotdb/db/wal/io/CheckpointWriter.java | 61 +
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 61 +
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 96 ++
.../java/org/apache/iotdb/db/wal/io/WALReader.java | 114 ++
.../java/org/apache/iotdb/db/wal/io/WALWriter.java | 60 +
.../org/apache/iotdb/db/wal/node/IWALNode.java | 52 +
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 118 ++
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 380 +++++
.../db/wal/recover/CheckpointRecoverUtils.java | 78 +
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 151 ++
.../iotdb/db/wal/recover/WALRecoverManager.java | 172 ++
.../file/AbstractTsFileRecoverPerformer.java | 126 ++
.../recover/file/SealedTsFileRecoverPerformer.java | 54 +
.../db/wal/recover/file/TsFilePlanRedoer.java | 159 ++
.../file/UnsealedTsFileRecoverPerformer.java | 271 +++
.../utils/WALMode.java} | 28 +-
.../apache/iotdb/db/wal/utils/WALWriteUtils.java | 134 ++
.../wal/utils/listener/AbstractResultListener.java | 87 +
.../utils/listener/WALFlushListener.java} | 11 +-
.../utils/listener/WALRecoverListener.java} | 16 +-
.../apache/iotdb/db/writelog/WALFlushListener.java | 50 -
.../writelog/manager/MultiFileLogNodeManager.java | 206 ---
.../db/writelog/manager/WriteLogNodeManager.java | 49 -
.../db/writelog/node/ExclusiveWriteLogNode.java | 389 -----
.../iotdb/db/writelog/node/WriteLogNode.java | 92 -
.../iotdb/db/writelog/recover/LogReplayer.java | 242 ---
.../writelog/recover/TsFileRecoverPerformer.java | 316 ----
.../db/engine/compaction/CompactionUtilsTest.java | 321 +++-
.../db/engine/compaction/TsFileIdentifierUT.java | 8 +-
.../compaction/cross/CrossSpaceCompactionTest.java | 3 +
.../cross/RewriteCrossSpaceCompactionTest.java | 10 +-
.../recover/SizeTieredCompactionRecoverTest.java | 8 +-
.../db/engine/memtable/MemTableTestUtils.java | 2 -
.../db/engine/memtable/PrimitiveMemTableTest.java | 32 +-
.../engine/modification/DeletionFileNodeTest.java | 24 +-
.../storagegroup/StorageGroupProcessorTest.java | 71 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 60 +-
.../engine/storagegroup/TsFileProcessorTest.java | 2 -
.../HashVirtualPartitionerTest.java | 6 +-
.../db/metadata/idtable/IDTableFlushTimeTest.java | 10 +-
.../db/metadata/idtable/InsertWithIDTableTest.java | 7 +-
.../schemaregion/rocksdb/MRocksDBUnitTest.java | 6 +-
.../rocksdb/RSchemaRegionAdvancedTest.java | 5 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 2 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 4 +-
.../iotdb/db/mpp/operator/LimitOperatorTest.java | 2 +-
.../db/mpp/operator/SeriesScanOperatorTest.java | 2 +-
.../db/mpp/operator/TimeJoinOperatorTest.java | 2 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 123 +-
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 287 +++-
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 567 ++++++
.../db/qp/physical/InsertTabletMultiPlanTest.java | 19 +-
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 ++
.../db/sync/receiver/load/FileLoaderTest.java | 23 +-
.../recover/SyncReceiverLogAnalyzerTest.java | 5 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 117 +-
.../io => utils/writelog}/LogWriterReaderTest.java | 15 +-
.../writelog}/MultiFileLogReaderTest.java | 7 +-
.../org/apache/iotdb/db/wal/DisableWALTest.java | 54 +
.../org/apache/iotdb/db/wal/WALManagerTest.java | 107 ++
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 158 ++
.../apache/iotdb/db/wal/buffer/WALBufferTest.java} | 19 +-
.../db/wal/checkpoint/CheckpointManagerTest.java | 154 ++
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 133 ++
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 222 +++
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 65 +
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 262 +++
.../db/wal/recover/WALRecoverManagerTest.java | 466 +++++
.../file/SealedTsFileRecoverPerformerTest.java | 307 ++++
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 400 +++++
.../file/UnsealedTsFileRecoverPerformerTest.java | 260 +++
.../db/wal/utils/TsFileUtilsForRecoverTest.java} | 45 +-
.../iotdb/db/wal/utils/WALByteBufferForTest.java} | 52 +-
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 220 ---
.../apache/iotdb/db/writelog/PerformanceTest.java | 219 ---
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 185 --
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 451 -----
.../db/writelog/recover/DeviceStringTest.java | 132 --
.../iotdb/db/writelog/recover/LogReplayerTest.java | 288 ----
.../recover/RecoverResourceFromReaderTest.java | 231 ---
.../db/writelog/recover/SeqTsFileRecoverTest.java | 565 ------
.../writelog/recover/UnseqTsFileRecoverTest.java | 277 ---
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 1 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
site/iotdb-doap.rdf | 16 +-
site/src/main/.vuepress/config.js | 3 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 14 +-
.../src/main/thrift/confignode.thrift | 13 +
.../read/expression/impl/BinaryExpression.java | 39 +
.../read/expression/impl/GlobalTimeExpression.java | 20 +
.../expression/impl/SingleSeriesExpression.java | 20 +
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 67 +-
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 20 +
.../tsfile/write/schema/IMeasurementSchema.java | 2 +
.../tsfile/write/schema/MeasurementSchema.java | 18 +
.../write/schema/VectorMeasurementSchema.java | 13 +
.../write/writer/RestorableTsFileIOWriter.java | 5 +
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 8 +-
.../iotdb/tsfile/utils/FilePathUtilsTest.java | 12 +-
465 files changed, 22451 insertions(+), 15637 deletions(-)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/UDTFQueryStatement.java => confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/PermissionInfoDataSet.java (80%)
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/GroupByFillQueryStatement.java => confignode/src/main/java/org/apache/iotdb/confignode/manager/PermissionManager.java (60%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/persistence/AuthorInfoPersistence.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/physical/sys/AuthorPlan.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/GroupByFillQueryStatement.java => confignode/src/test/java/org/apache/iotdb/confignode/auth/AuthorTest.java (58%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ConsensusFactory.java
create mode 100644 docs/UserGuide/API/InfluxDB-Protocol.md
rename docs/UserGuide/Data-Modeling/{VirtualStorageGroup.md => DataRegion.md} (85%)
delete mode 100644 docs/UserGuide/Library-UDF/Anomaly-Detection.md
delete mode 100644 docs/UserGuide/Library-UDF/Data-Profile.md
delete mode 100644 docs/UserGuide/Library-UDF/Data-Quality.md
delete mode 100644 docs/UserGuide/Library-UDF/Frequency-Domain.md
delete mode 100644 docs/UserGuide/Library-UDF/Get-Started.md
delete mode 100644 docs/UserGuide/Library-UDF/Series-Discovery.md
rename docs/zh/UserGuide/Data-Modeling/{VirtualStorageGroup.md => DataRegion.md} (78%)
delete mode 100644 docs/zh/UserGuide/Library-UDF/Anomaly Detection.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Data-Profile.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Data-Quality.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Frequency-Domain.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Get-Started.md
delete mode 100644 docs/zh/UserGuide/Library-UDF/Series-Discovery.md
rename integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IOTDBInsertAlignedValuesIT.java => IoTDBInsertAlignedValuesIT.java} (92%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDAFCov.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDAFDtw.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDAFPearson.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDTFPtnSym.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/UDTFXCorr.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/dmatch/util/CrossCorrelation.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/UDTFTimestampRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/UDTFValueFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/UDTFValueRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ARFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LikelihoodFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LinearFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/LsGreedy.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/MAFill.java
copy server/src/main/java/org/apache/iotdb/db/metadata/SchemaEngineType.java => library-udf/src/main/java/org/apache/iotdb/library/drepair/util/MeanFill.java (62%)
rename consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java => library-udf/src/main/java/org/apache/iotdb/library/drepair/util/PreviousFill.java (52%)
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/Screen.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ScreenFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/TimestampInterval.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/TimestampRepair.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ValueFill.java
create mode 100644 library-udf/src/main/java/org/apache/iotdb/library/drepair/util/ValueRepair.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/dmatch/DMatchTests.java
create mode 100644 library-udf/src/test/java/org/apache/iotdb/library/drepair/DRepairTests.java
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => DataRegionId.java} (71%)
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => PartitionRegionId.java} (71%)
copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => SchemaRegionId.java} (71%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/authorizer/AuthorizerManager.java
copy server/src/main/java/org/apache/iotdb/db/{exception/metadata/AcquireLockTimeoutException.java => auth/authorizer/ClusterAuthorizer.java} (81%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/conf/directories/FolderManager.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => conf/directories/strategy/DirectoryStrategyType.java} (77%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusExample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusImpl.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/StorageEngineV2.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/compaction/cross/rewrite/task/SubCompactionTask.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => engine/flush/FlushStatus.java} (79%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{VirtualStorageGroupProcessor.java => DataRegion.java} (84%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{virtualSg => dataregion}/HashVirtualPartitioner.java (89%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{virtualSg => dataregion}/StorageGroupManager.java (63%)
copy server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{virtualSg => dataregion}/VirtualPartitioner.java (80%)
copy server/src/main/java/org/apache/iotdb/db/exception/{StorageGroupProcessorException.java => DataRegionException.java} (74%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/QueryPlanBuilder.java
copy server/src/main/java/org/apache/iotdb/db/mpp/sql/{statement/crud/UDTFQueryStatement.java => planner/plan/IOutputPlanNode.java} (68%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/ColumnHeader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/write/AuthorNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/write/InsertMultiTabletsNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertMultiTabletsStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsOfOneDeviceStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/crud/InsertRowsStatement.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/sql/statement/sys/AuthorStatement.java
rename server/src/main/java/org/apache/iotdb/db/qp/physical/crud/{InsertMultiTabletPlan.java => InsertMultiTabletsPlan.java} (94%)
rename server/src/main/java/org/apache/iotdb/db/tools/{virtualsg => dataregion}/DeviceMappingViewer.java (90%)
copy server/src/main/java/org/apache/iotdb/db/{exception/metadata/AcquireLockTimeoutException.java => utils/SerializedSize.java} (75%)
rename server/src/main/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/BatchLogReader.java (98%)
rename server/src/main/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/ILogReader.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/ILogWriter.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/LogWriter.java (98%)
rename server/src/main/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/MultiFileLogReader.java (97%)
rename server/src/main/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/SingleFileLogReader.java (97%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/WALManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/AbstractWALBuffer.java
rename server/src/main/java/org/apache/iotdb/db/{engine/storagegroup/virtualSg/VirtualPartitioner.java => wal/buffer/IWALBuffer.java} (61%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/IWALByteBufferView.java
copy server/src/main/java/org/apache/iotdb/db/{engine/cq/CQLogReader.java => wal/buffer/SignalWALEntry.java} (51%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALBuffer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALEntry.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/buffer/WALEntryType.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/SchemaEngineType.java => wal/buffer/WALEntryValue.java} (63%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/Checkpoint.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/CheckpointManager.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/analyze/FakeSchemaFetcherImpl.java => wal/checkpoint/CheckpointType.java} (56%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/MemTableInfo.java
rename server/src/main/java/org/apache/iotdb/db/{exception/StorageGroupProcessorException.java => wal/exception/WALException.java} (64%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => wal/exception/WALNodeClosedException.java} (77%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => wal/exception/WALRecoverException.java} (75%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/CheckpointReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/CheckpointWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/ILogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/LogWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/WALReader.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/io/WALWriter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/node/IWALNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/node/WALFakeNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/node/WALNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/CheckpointRecoverUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/WALNodeRecoverTask.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/WALRecoverManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/AbstractTsFileRecoverPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/SealedTsFileRecoverPerformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/TsFilePlanRedoer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/recover/file/UnsealedTsFileRecoverPerformer.java
copy server/src/main/java/org/apache/iotdb/db/{metadata/SchemaEngineType.java => wal/utils/WALMode.java} (66%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/WALWriteUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/utils/listener/AbstractResultListener.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => wal/utils/listener/WALFlushListener.java} (76%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => wal/utils/listener/WALRecoverListener.java} (67%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/WALFlushListener.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/manager/MultiFileLogNodeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/manager/WriteLogNodeManager.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/node/ExclusiveWriteLogNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/node/WriteLogNode.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/recover/LogReplayer.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
rename server/src/test/java/org/apache/iotdb/db/engine/storagegroup/{virtualSg => dataregion}/HashVirtualPartitionerTest.java (90%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/sql/plan/QueryLogicalPlanUtil.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/qp/physical/SerializedSizeTest.java
rename server/src/test/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/LogWriterReaderTest.java (92%)
rename server/src/test/java/org/apache/iotdb/db/{writelog/io => utils/writelog}/MultiFileLogReaderTest.java (91%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/DisableWALTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/WALManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/buffer/WALBufferCommonTest.java
copy server/src/{main/java/org/apache/iotdb/db/mpp/sql/statement/crud/UDTFQueryStatement.java => test/java/org/apache/iotdb/db/wal/buffer/WALBufferTest.java} (65%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/checkpoint/CheckpointManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/io/CheckpointFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/io/WALFileTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/node/WALFakeNodeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/node/WALNodeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/WALRecoverManagerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/file/SealedTsFileRecoverPerformerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/file/TsFilePlanRedoerTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/wal/recover/file/UnsealedTsFileRecoverPerformerTest.java
copy server/src/{main/java/org/apache/iotdb/db/engine/flush/FlushListener.java => test/java/org/apache/iotdb/db/wal/utils/TsFileUtilsForRecoverTest.java} (54%)
copy server/src/{main/java/org/apache/iotdb/db/mpp/sql/planner/plan/node/metedata/read/ShowDevicesNode.java => test/java/org/apache/iotdb/db/wal/utils/WALByteBufferForTest.java} (52%)
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/IoTDBLogFileSizeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/DeviceStringTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/RecoverResourceFromReaderTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverTest.java