You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2022/04/11 01:12:18 UTC
[iotdb] branch ty-mpp updated (10b8ec3d6e -> d34c22d1a4)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty-mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 10b8ec3d6e Construct ExchangeOperator in LocalExecutionPlanner and move initQueryDataSource method from SourceOperator to DataSourceOperator
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 d34c22d1a4 resolve conflicts
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 +
.../consensus/response/PermissionInfoDataSet.java | 9 +-
.../statemachine/PartitionRegionStateMachine.java | 5 +-
.../iotdb/confignode/manager/ConfigManager.java | 12 +
.../apache/iotdb/confignode/manager/Manager.java | 8 +
.../confignode/manager/PermissionManager.java | 25 +-
.../persistence/AuthorInfoPersistence.java | 146 ++++
.../iotdb/confignode/physical/PhysicalPlan.java | 20 +
.../confignode/physical/PhysicalPlanType.java | 20 +-
.../iotdb/confignode/physical/sys/AuthorPlan.java | 228 ++++++
.../confignode/service/executor/PlanExecutor.java | 36 +-
.../server/ConfigNodeRPCServerProcessor.java | 25 +
.../apache/iotdb/confignode/auth/AuthorTest.java | 31 +-
docs/UserGuide/API/InfluxDB-Protocol.md | 341 ++++++++
docs/UserGuide/Data-Concept/Time-Partition.md | 8 +-
.../{VirtualStorageGroup.md => DataRegion.md} | 10 +-
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/Reference/Config-Manual.md | 16 +-
.../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 +-
.../iotdb/commons/concurrent/ThreadName.java | 10 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 6 +
.../iotdb/commons/partition/DataPartition.java | 4 +-
.../resources/conf/iotdb-engine.properties | 132 ++--
.../db/auth/authorizer/AuthorizerManager.java | 190 +++++
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 1 +
.../authorizer/ClusterAuthorizer.java} | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 261 ++++---
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 41 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 147 ++--
.../db/conf/directories/DirectoryManager.java | 4 -
.../iotdb/db/conf/directories/FolderManager.java | 65 ++
.../strategy/DirectoryStrategyType.java} | 13 +-
.../apache/iotdb/db/consensus/ConsensusImpl.java | 4 +-
.../statemachine/DataRegionStateMachine.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 188 ++---
.../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 +-
.../exception/sql/StatementAnalyzeException.java | 6 +
.../iotdb/db/metadata/LocalConfigManager.java | 1 -
.../iotdb/db/metadata/logfile/MLogReader.java | 2 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 2 +-
.../db/metadata/schemaregion/SchemaRegion.java | 2 -
.../apache/iotdb/db/metadata/tag/TagManager.java | 10 +-
.../org/apache/iotdb/db/mpp/common/DataRegion.java | 58 --
.../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 | 4 +-
.../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 +
.../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 | 31 +-
.../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 ++++
.../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 +-
.../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/IoTDB.java | 4 +-
.../iotdb/db/service/metrics/MetricsService.java | 33 +-
.../db/service/thrift/impl/TSServiceImpl.java | 265 ++++++-
.../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} | 16 +-
.../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} | 39 +-
.../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} | 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 +++++++
.../org/apache/iotdb/db/wal/utils/WALMode.java | 27 +-
.../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 +-
.../db/metadata/upgrade/MetadataUpgradeTest.java | 2 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 4 +-
.../db/mpp/sql/plan/DistributionPlannerTest.java | 101 ++-
.../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} | 47 +-
.../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/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 +-
359 files changed, 17963 insertions(+), 7275 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 docs/UserGuide/API/InfluxDB-Protocol.md
rename docs/UserGuide/Data-Modeling/{VirtualStorageGroup.md => DataRegion.md} (85%)
rename docs/zh/UserGuide/Data-Modeling/{VirtualStorageGroup.md => DataRegion.md} (78%)
rename integration/src/test/java/org/apache/iotdb/db/integration/aligned/{IOTDBInsertAlignedValuesIT.java => IoTDBInsertAlignedValuesIT.java} (92%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/auth/authorizer/AuthorizerManager.java
copy server/src/main/java/org/apache/iotdb/db/{mpp/sql/statement/crud/UDTFQueryStatement.java => auth/authorizer/ClusterAuthorizer.java} (80%)
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%)
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%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/common/DataRegion.java
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/{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
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/trigger/service/TriggerLogReader.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/{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 confignode/src/main/java/org/apache/iotdb/confignode/physical/PhysicalPlanType.java => server/src/main/java/org/apache/iotdb/db/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/trigger/service/TriggerLogReader.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