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/04/10 14:07:30 UTC
[iotdb] branch mv_vsg_dataregion updated (ee5d2f5f03 -> 7c22f7f3ee)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch mv_vsg_dataregion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ee5d2f5f03 rename more
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 ccfaf2f539 fix confilcts
add 7c22f7f3ee update
No new revisions were added by this update.
Summary of changes:
.../iotdb/cluster/metadata/CSchemaProcessor.java | 10 +-
.../iotdb/cluster/server/member/BaseMember.java | 9 +-
.../iotdb/cluster/utils/SerializeUtilTest.java | 2 -
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
docs/UserGuide/Reference/Config-Manual.md | 27 -
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 2 -
.../iotdb/session/IoTDBSessionComplexIT.java | 7 +-
.../iotdb/commons/concurrent/ThreadName.java | 9 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../resources/conf/iotdb-engine.properties | 118 ++---
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 235 +++++----
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 26 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 135 ++---
.../db/conf/directories/DirectoryManager.java | 4 -
.../iotdb/db/conf/directories/FolderManager.java | 65 +++
.../strategy/DirectoryStrategyType.java} | 13 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 94 ++--
.../apache/iotdb/db/engine/StorageEngineV2.java | 39 +-
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 2 +-
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 2 +-
.../iotdb/db/engine/flush/FlushListener.java | 17 +-
.../flush/FlushStatus.java} | 15 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 131 ++++-
.../engine/memtable/AlignedWritableMemChunk.java | 51 ++
.../memtable/AlignedWritableMemChunkGroup.java | 22 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 10 +-
.../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 ++
.../iotdb/db/engine/storagegroup/DataRegion.java | 509 ++++++++----------
.../db/engine/storagegroup/StorageGroupInfo.java | 39 --
.../db/engine/storagegroup/TsFileProcessor.java | 153 +++---
.../dataregion/StorageGroupManager.java | 41 +-
.../engine/trigger/service/TriggerLogReader.java | 2 +-
.../engine/trigger/service/TriggerLogWriter.java | 4 +-
.../exception/sql/StatementAnalyzeException.java | 6 +
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../db/metadata/schemaregion/SchemaRegion.java | 2 -
.../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 +-
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 6 +-
.../apache/iotdb/db/mpp/sql/analyze/Analysis.java | 21 +-
.../apache/iotdb/db/mpp/sql/analyze/Analyzer.java | 59 ++-
.../db/mpp/sql/analyze/FakeSchemaFetcherImpl.java | 51 +-
.../db/mpp/sql/parser/StatementGenerator.java | 4 +-
.../db/mpp/sql/planner/LocalExecutionPlanner.java | 7 +-
.../iotdb/db/mpp/sql/planner/LogicalPlanner.java | 236 +++------
.../iotdb/db/mpp/sql/planner/QueryPlanBuilder.java | 277 ++++++++++
.../plan/IOutputPlanNode.java} | 17 +-
.../db/mpp/sql/planner/plan/node/ColumnHeader.java | 88 ++++
.../db/mpp/sql/planner/plan/node/PlanNode.java | 2 -
.../plan/node/metedata/read/ShowDevicesNode.java | 5 -
.../node/metedata/write/AlterTimeSeriesNode.java | 5 -
.../plan/node/metedata/write/AuthorNode.java | 5 -
.../write/CreateAlignedTimeSeriesNode.java | 5 -
.../node/metedata/write/CreateTimeSeriesNode.java | 5 -
.../planner/plan/node/process/AggregateNode.java | 93 +++-
.../planner/plan/node/process/DeviceMergeNode.java | 79 ++-
.../planner/plan/node/process/ExchangeNode.java | 5 -
.../sql/planner/plan/node/process/FillNode.java | 17 +-
.../sql/planner/plan/node/process/FilterNode.java | 59 ++-
.../planner/plan/node/process/FilterNullNode.java | 63 ++-
.../plan/node/process/GroupByLevelNode.java | 91 ++--
.../sql/planner/plan/node/process/LimitNode.java | 41 +-
.../sql/planner/plan/node/process/OffsetNode.java | 37 +-
.../sql/planner/plan/node/process/SortNode.java | 17 +-
.../planner/plan/node/process/TimeJoinNode.java | 78 ++-
.../planner/plan/node/sink/FragmentSinkNode.java | 5 -
.../plan/node/source/SeriesAggregateScanNode.java | 133 +++--
.../planner/plan/node/source/SeriesScanNode.java | 78 ++-
.../sql/planner/plan/node/source/SourceNode.java | 22 -
.../plan/node/write/InsertMultiTabletsNode.java | 5 -
.../sql/planner/plan/node/write/InsertRowNode.java | 15 +-
.../planner/plan/node/write/InsertRowsNode.java | 5 -
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 -
.../planner/plan/node/write/InsertTabletNode.java | 17 +-
.../sql/rewriter/ColumnPaginationController.java | 46 +-
.../db/mpp/sql/rewriter/WildcardsRemover.java | 24 +-
.../db/mpp/sql/statement/StatementVisitor.java | 28 +
.../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 +
.../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 +
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 2 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 61 +--
.../iotdb/db/qp/physical/crud/DeletePlan.java | 44 +-
.../qp/physical/crud/InsertMultiTabletsPlan.java | 4 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 275 ++++++++--
.../db/qp/physical/crud/InsertTabletPlan.java | 462 +++++++++++------
.../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 -
.../apache/iotdb/db/rescon/MemTableManager.java | 14 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +-
.../iotdb/db/service/metrics/MetricsService.java | 33 +-
.../db/service/thrift/impl/TSServiceImpl.java | 4 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 81 +--
.../apache/iotdb/db/utils/EnvironmentUtils.java | 27 +-
.../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} | 16 +-
.../db/utils/datastructure/AlignedTVList.java | 190 +++++++
.../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} | 23 +-
.../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} | 15 +-
.../apache/iotdb/db/wal/checkpoint/Checkpoint.java | 102 ++++
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 257 ++++++++++
.../checkpoint/CheckpointType.java} | 48 +-
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 113 ++++
.../exception/WALException.java} | 23 +-
.../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} | 22 +-
.../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 | 435 ----------------
.../iotdb/db/writelog/node/WriteLogNode.java | 101 ----
.../iotdb/db/writelog/recover/LogReplayer.java | 240 ---------
.../writelog/recover/TsFileRecoverPerformer.java | 316 ------------
.../db/engine/memtable/MemTableTestUtils.java | 2 -
.../db/engine/memtable/PrimitiveMemTableTest.java | 32 +-
.../storagegroup/StorageGroupProcessorTest.java | 63 ---
.../engine/storagegroup/TsFileProcessorTest.java | 2 -
.../db/metadata/upgrade/MetadataUpgradeTest.java | 2 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 101 ++--
.../iotdb/db/mpp/sql/plan/LogicalPlannerTest.java | 103 +---
.../db/mpp/sql/plan/QueryLogicalPlanUtil.java | 567 +++++++++++++++++++++
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 +++++
.../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} | 46 +-
.../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/TSStatusCode.java | 1 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 14 +-
.../read/expression/impl/BinaryExpression.java | 39 ++
.../read/expression/impl/GlobalTimeExpression.java | 20 +
.../expression/impl/SingleSeriesExpression.java | 20 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 43 +-
.../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 +
224 files changed, 11274 insertions(+), 6198 deletions(-)
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%)
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => engine/flush/FlushStatus.java} (79%)
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
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.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
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => wal/buffer/IWALBuffer.java} (60%)
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/{mpp/sql/statement/crud/UDTFQueryStatement.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/{engine/cq/CQLogReader.java => wal/checkpoint/CheckpointType.java} (55%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/wal/checkpoint/MemTableInfo.java
copy server/src/main/java/org/apache/iotdb/db/{exception/sql/StatementAnalyzeException.java => wal/exception/WALException.java} (59%)
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/{mpp/sql/statement/crud/UDTFQueryStatement.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
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/cq/CQLogReader.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