This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch beyyes/fix_limit_offset_serialie in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 22691c892754ff810dc3b9ea5284b4578406307a Merge: 3536b019486 c8e5c211ec0 Author: Beyyes <[email protected]> AuthorDate: Thu Jul 25 14:10:18 2024 +0800 Merge branch 'ty/TableModelGrammar' into beyyes/fix_limit_offset_serialie .../org/apache/iotdb/DataMigrationExample.java | 3 +- .../org/apache/iotdb/it/utils/TsFileGenerator.java | 8 +- .../it/partition/IoTDBPartitionGetterIT.java | 2 +- .../iotdb/confignode/manager/ConfigManager.java | 43 +++-- .../impl/schema/DeactivateTemplateProcedure.java | 2 +- .../impl/schema/SetTemplateProcedure.java | 2 +- .../impl/schema/UnsetTemplateProcedure.java | 2 +- .../impl/schema/table/CreateTableProcedure.java | 2 +- .../org/apache/iotdb/db/auth/AuthorityChecker.java | 6 +- .../iotdb/db/auth/ClusterAuthorityFetcher.java | 4 +- .../apache/iotdb/db/auth/IAuthorityFetcher.java | 3 +- .../dataregion/DataExecutionVisitor.java | 7 +- .../schemaregion/SchemaExecutionVisitor.java | 2 +- .../schemaregion/PipePlanPatternParseVisitor.java | 4 +- .../visitor/PipePlanToStatementVisitor.java | 5 +- .../rest/v1/impl/GrafanaApiServiceImpl.java | 1 + .../rest/v2/impl/GrafanaApiServiceImpl.java | 1 + .../protocol/thrift/impl/ClientRPCServiceImpl.java | 7 +- .../impl/DataNodeInternalRPCServiceImpl.java | 5 +- .../common/schematree/ClusterSchemaTree.java | 4 +- .../execution/MemoryEstimationHelper.java | 13 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 16 +- .../plan/analyze/ExpressionAnalyzer.java | 2 +- .../plan/analyze/LoadTsfileAnalyzer.java | 3 +- .../queryengine/plan/analyze/SelectIntoUtils.java | 2 +- .../analyze/cache/schema/DataNodeSchemaCache.java | 2 +- .../schema/DeviceUsingTemplateSchemaCache.java | 2 +- .../cache/schema/TimeSeriesSchemaCache.java | 6 +- .../cache/schema/dualkeycache/IDualKeyCache.java | 2 +- .../schema/dualkeycache/impl/DualKeyCacheImpl.java | 2 +- .../analyze/schema/AutoCreateSchemaExecutor.java | 4 +- .../analyze/schema/ClusterSchemaFetchExecutor.java | 3 +- .../plan/analyze/schema/ClusterSchemaFetcher.java | 4 +- .../plan/analyze/schema/NormalSchemaFetcher.java | 5 +- .../plan/expression/ExpressionFactory.java | 3 +- .../db/queryengine/plan/parser/ASTVisitor.java | 9 +- .../plan/parser/StatementGenerator.java | 11 +- .../plan/planner/OperatorTreeGenerator.java | 8 +- .../node/metedata/read/TimeSeriesCountNode.java | 3 +- .../metedata/read/TimeSeriesSchemaScanNode.java | 3 +- .../node/metedata/write/AlterTimeSeriesNode.java | 6 +- .../metedata/write/CreateMultiTimeSeriesNode.java | 3 +- .../node/metedata/write/CreateTimeSeriesNode.java | 15 +- .../plan/node/source/TimeseriesRegionScanNode.java | 3 +- .../planner/plan/node/write/DeleteDataNode.java | 37 ++--- .../parameter/DeviceViewIntoPathDescriptor.java | 2 +- .../plan/relational/sql/parser/AstBuilder.java | 2 + .../db/queryengine/plan/statement/Statement.java | 2 +- .../plan/statement/crud/DeleteDataStatement.java | 12 +- .../plan/statement/crud/InsertRowStatement.java | 2 +- .../crud/InsertRowsOfOneDeviceStatement.java | 2 +- .../plan/statement/crud/InsertStatement.java | 2 +- .../plan/statement/crud/InsertTabletStatement.java | 2 +- .../InternalBatchActivateTemplateStatement.java | 2 +- .../InternalCreateMultiTimeSeriesStatement.java | 3 +- .../InternalCreateTimeSeriesStatement.java | 4 +- .../metadata/CreateAlignedTimeSeriesStatement.java | 2 +- .../metadata/CreateMultiTimeSeriesStatement.java | 10 +- .../metadata/CreateTimeSeriesStatement.java | 7 +- .../template/ActivateTemplateStatement.java | 2 +- .../template/BatchActivateTemplateStatement.java | 2 +- .../template/DeactivateTemplateStatement.java | 3 +- .../schemaregion/impl/SchemaRegionMemoryImpl.java | 2 +- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 2 +- .../visitor/SchemaRegionPlanDeserializer.java | 8 +- .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 6 +- .../mtree/impl/mem/mnode/info/LogicalViewInfo.java | 3 +- .../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 2 +- .../write/req/ICreateTimeSeriesPlan.java | 6 +- .../write/req/SchemaRegionWritePlanFactory.java | 3 +- .../write/req/impl/CreateTimeSeriesPlanImpl.java | 12 +- .../db/storageengine/dataregion/DataRegion.java | 12 +- .../execute/utils/CompactionPathUtils.java | 2 +- .../execute/utils/MultiTsFileDeviceIterator.java | 5 +- .../dataregion/memtable/AbstractMemTable.java | 6 +- .../dataregion/modification/Deletion.java | 12 +- .../dataregion/modification/Modification.java | 10 +- .../io/LocalTextModificationAccessor.java | 6 +- .../tsfile/timeindex/ArrayDeviceTimeIndex.java | 2 +- .../dataregion/wal/buffer/IWALByteBufferView.java | 21 +-- .../dataregion/wal/buffer/WALBuffer.java | 12 +- .../wal/recover/file/TsFilePlanRedoer.java | 6 +- .../file/UnsealedTsFileRecoverPerformer.java | 3 +- .../db/tools/schema/SRStatementGenerator.java | 10 +- .../utils/datastructure/PatternTreeMapFactory.java | 4 +- .../db/metadata/cache/DataNodeSchemaCacheTest.java | 22 +-- .../cache/dualkeycache/DualKeyCacheTest.java | 15 +- .../db/metadata/idtable/entry/DeviceIDTest.java | 7 +- .../iotdb/db/metadata/path/PatternTreeMapTest.java | 73 ++++----- .../schemaRegion/SchemaRegionBasicTest.java | 32 ++-- .../schemaRegion/SchemaRegionManagementTest.java | 5 +- .../SchemaRegionSimpleRecoverTest.java | 5 +- .../schemaRegion/SchemaRegionTestUtil.java | 5 +- .../schemaRegion/SchemaStatisticsTest.java | 3 +- .../PipeStatementPatternParseVisitorTest.java | 5 +- .../extractor/PipePlanPatternParseVisitorTest.java | 16 +- .../extractor/SchemaRegionListeningQueueTest.java | 3 +- .../resource/PipeTsFileResourceManagerTest.java | 8 +- .../logical/SchemaQueryLogicalPlannerTest.java | 8 - .../metadata/write/MetadataWriteNodeSerDeTest.java | 3 +- .../pipe/PipeEnrichedDeleteDataNodeSerdeTest.java | 10 +- .../node/write/DeleteDataNodeSerdeTest.java | 10 +- .../DataNodeInternalRPCServiceImplTest.java | 9 +- .../storageengine/dataregion/DataRegionTest.java | 72 ++++----- .../compaction/CompactionTaskComparatorTest.java | 4 +- .../compaction/ReadChunkInnerCompactionTest.java | 30 ++-- ...eCrossSpaceCompactionWithFastPerformerTest.java | 12 +- ...sSpaceCompactionWithReadPointPerformerTest.java | 12 +- .../InnerSeqCompactionWithFastPerformerTest.java | 8 +- ...nerSeqCompactionWithReadChunkPerformerTest.java | 8 +- .../inner/InnerSpaceCompactionExceptionTest.java | 9 +- .../inner/InnerSpaceCompactionSelectorTest.java | 6 +- ...nkCompactionPerformerWithAlignedSeriesTest.java | 14 +- .../ReadChunkCompactionPerformerAlignedTest.java | 3 +- .../repair/RepairUnsortedFileCompactionTest.java | 4 +- .../settle/SettleCompactionSelectorTest.java | 58 +++---- .../settle/SettleRequestHandlerTest.java | 4 +- .../compaction/utils/CompactionCheckerUtils.java | 17 +- .../utils/CompactionFileGeneratorUtils.java | 7 +- .../dataregion/memtable/PrimitiveMemTableTest.java | 10 +- .../modification/ModificationFileTest.java | 30 ++-- .../io/LocalTextModificationAccessorTest.java | 10 +- .../dataregion/wal/io/WALFileTest.java | 3 +- .../wal/node/ConsensusReqReaderTest.java | 3 +- .../wal/recover/file/TsFilePlanRedoerTest.java | 3 +- .../file/UnsealedTsFileRecoverPerformerTest.java | 3 +- .../dataregion/wal/utils/WALByteBufferForTest.java | 12 +- .../org/apache/iotdb/db/tools/MLogParserTest.java | 3 +- .../iotdb/db/tools/TsFileAndModSettleToolTest.java | 4 +- .../db/utils/SchemaRegionSnapshotParserTest.java | 23 +-- .../org/apache/iotdb/db/utils/SchemaTestUtils.java | 2 +- .../org/apache/iotdb/commons/path/AlignedPath.java | 29 +--- .../apache/iotdb/commons/path/MeasurementPath.java | 42 ++++- .../org/apache/iotdb/commons/path/PartialPath.java | 127 +++++++++++---- .../apache/iotdb/commons/path/PathPatternTree.java | 28 +++- .../apache/iotdb/commons/path/PatternTreeMap.java | 2 +- .../commons/pipe/pattern/IoTDBPipePattern.java | 11 +- .../commons/schema/view/LogicalViewSchema.java | 3 +- .../org/apache/iotdb/commons/utils/AuthUtils.java | 2 +- .../apache/iotdb/commons/path/PartialPathTest.java | 174 +++++++++++++++++---- 140 files changed, 932 insertions(+), 595 deletions(-)
