This is an automated email from the ASF dual-hosted git repository. caogaofei pushed a commit to branch table_model_auth in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3bea488e0141623dbab1a0e0dbf8f44a1858e80e Merge: 29d21941ace 0fc81c642e7 Author: Beyyes <[email protected]> AuthorDate: Tue Jun 11 09:49:26 2024 +0800 Merge branch 'ty/TableModelGrammar' of github.com:apache/iotdb into ty/TableModelGrammar .github/workflows/cluster-it-1c1d.yml | 2 +- .github/workflows/cluster-it-1c3d.yml | 2 +- .github/workflows/pipe-it-2cluster.yml | 2 +- .github/workflows/sonar-codecov.yml | 2 +- .github/workflows/unit-test.yml | 2 +- .gitignore | 1 + .mvn/{gradle-enterprise.xml => develocity.xml} | 15 +- .mvn/extensions.xml | 6 +- code-coverage/pom.xml | 2 +- distribution/pom.xml | 10 +- example/client-cpp-example/pom.xml | 2 +- example/jdbc/pom.xml | 2 +- .../java/org/apache/iotdb/JDBCCharsetExample.java | 2 +- example/mqtt-customize/pom.xml | 2 +- example/mqtt/pom.xml | 2 +- example/pipe-count-point-processor/pom.xml | 2 +- example/pipe-opc-ua-sink/pom.xml | 2 +- example/pom.xml | 2 +- example/rest-java-example/pom.xml | 2 +- example/schema/pom.xml | 2 +- example/session/pom.xml | 2 +- example/trigger/pom.xml | 2 +- example/udf/pom.xml | 2 +- integration-test/pom.xml | 32 +- .../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 3 +- .../db/it/orderBy/IoTDBOrderByForDebugIT.java | 1406 ++++++++++++++++++++ .../db/it/regionscan/IoTDBActiveRegionScanIT.java | 23 +- .../db/it/schema/IoTDBCreateTimeseriesIT.java | 31 + .../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 2 +- .../iotdb/db/it/udaf/IoTDBUDAFOrderByIT.java | 5 +- .../it/autocreate/IoTDBPipeAutoConflictIT.java | 9 +- .../pipe/it/autocreate/IoTDBPipeAutoDropIT.java | 62 +- .../pipe/it/autocreate/IoTDBPipeClusterIT.java | 44 +- .../IoTDBPipeConnectorCompressionIT.java | 126 ++ .../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 31 +- .../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 2 +- .../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 18 +- .../it/dual/AbstractSubscriptionDualIT.java | 13 +- .../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 9 + .../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 195 +++ .../it/dual/IoTDBSubscriptionTopicIT.java | 2 +- .../it/local/IoTDBSubscriptionBasicIT.java | 118 +- .../it/local/IoTDBSubscriptionRestartIT.java | 31 +- .../apache/iotdb/tools/it/ExportDataTestIT.java | 12 +- .../apache/iotdb/tools/it/ImportDataTestIT.java | 16 +- iotdb-api/external-api/pom.xml | 2 +- iotdb-api/pipe-api/pom.xml | 2 +- iotdb-api/pom.xml | 2 +- iotdb-api/trigger-api/pom.xml | 2 +- iotdb-api/udf-api/pom.xml | 2 +- .../org/apache/iotdb/udf/api/utils/RowImpl.java | 21 + iotdb-client/cli/pom.xml | 18 +- .../org/apache/iotdb/tool/AbstractDataTool.java | 33 +- .../java/org/apache/iotdb/tool/ExportData.java | 14 +- .../java/org/apache/iotdb/tool/ImportData.java | 8 +- .../java/org/apache/iotdb/tool/ImportSchema.java | 62 +- iotdb-client/client-cpp/pom.xml | 4 +- iotdb-client/client-py/pom.xml | 4 +- iotdb-client/client-py/requirements.txt | 4 +- iotdb-client/client-py/resources/setup.py | 7 +- iotdb-client/isession/pom.xml | 8 +- iotdb-client/jdbc/pom.xml | 8 +- .../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 12 +- iotdb-client/pom.xml | 2 +- iotdb-client/service-rpc/pom.xml | 6 +- .../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 8 +- iotdb-client/session/pom.xml | 10 +- iotdb-core/antlr/pom.xml | 2 +- iotdb-core/confignode/pom.xml | 24 +- .../metric/PipeConfigRegionExtractorMetrics.java | 4 +- .../procedure/env/RegionMaintainHandler.java | 1 + .../subscription/topic/CreateTopicProcedure.java | 6 +- iotdb-core/consensus/pom.xml | 14 +- .../consensus/iot/logdispatcher/LogDispatcher.java | 34 +- .../apache/iotdb/consensus/iot/ReplicateTest.java | 111 +- iotdb-core/datanode/pom.xml | 38 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 + .../PipeTransferTabletBatchEventHandler.java | 28 +- .../PipeTransferTabletInsertionEventHandler.java | 22 +- .../PipeTransferTsFileInsertionEventHandler.java | 18 +- .../event/common/heartbeat/PipeHeartbeatEvent.java | 48 +- .../PipeHistoricalDataRegionTsFileExtractor.java | 68 +- .../realtime/PipeRealtimeDataRegionExtractor.java | 11 +- .../PipeRealtimeDataRegionHybridExtractor.java | 9 +- .../PipeDataNodeRemainingEventAndTimeOperator.java | 3 - .../subtask/connector/PipeConnectorSubtask.java | 2 +- ...SortOperator.java => AbstractSortOperator.java} | 146 +- .../process/ActiveRegionScanMergeOperator.java | 37 +- .../execution/operator/process/SortOperator.java | 309 +---- .../operator/process/StreamSortOperator.java | 203 +++ .../AbstractRegionScanDataSourceOperator.java | 19 +- .../source/ActiveDeviceRegionScanOperator.java | 40 +- .../source/ActiveTimeSeriesRegionScanOperator.java | 34 +- .../queryengine/plan/analyze/AnalyzeVisitor.java | 23 +- .../config/executor/ClusterConfigTaskExecutor.java | 8 +- .../plan/optimization/LimitOffsetPushDown.java | 3 +- .../db/queryengine/plan/parser/ASTVisitor.java | 8 +- .../plan/planner/OperatorTreeGenerator.java | 10 +- .../plan/planner/TableOperatorGenerator.java | 53 + .../plan/planner/distribution/SourceRewriter.java | 1 + .../planner/plan/parameter/SeriesScanOptions.java | 32 +- .../plan/scheduler/AsyncPlanNodeSender.java | 6 +- .../scheduler/FragmentInstanceDispatcherImpl.java | 52 +- .../schemaengine/schemaregion/ISchemaRegion.java | 20 + .../attribute/DeviceAttributeStore.java | 177 +++ .../IDeviceAttributeStore.java} | 31 +- .../schemaregion/impl/SchemaRegionMemoryImpl.java | 63 +- .../schemaregion/impl/SchemaRegionPBTreeImpl.java | 27 + .../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 215 ++- .../mtree/impl/mem/mnode/basic/BasicMNode.java | 3 +- .../container/KeyNullableConcurrentHashMap.java | 175 +++ .../mem/mnode/container/MemMNodeContainer.java | 3 +- .../mtree/impl/mem/mnode/info/BasicMNodeInfo.java | 2 +- .../mtree/impl/mem/mnode/info/TableDeviceInfo.java | 119 ++ .../impl/mem/snapshot/MemMTreeSnapshotUtil.java | 36 +- .../read/req/impl/ShowTableDevicesPlan.java | 60 + .../read/resp/info/IDeviceSchemaInfo.java | 4 + .../read/resp/info/impl/ShowDevicesResult.java | 31 + .../utils/filter/DeviceFilterVisitor.java | 19 + .../execute/recover/CompactionRecoverManager.java | 2 +- .../dataregion/tsfile/TsFileResource.java | 22 +- .../tsfile/timeindex/ArrayDeviceTimeIndex.java | 16 + .../dataregion/tsfile/timeindex/FileTimeIndex.java | 5 + .../receiver/SubscriptionReceiverV1.java | 11 +- .../apache/iotdb/db/utils/sort/DiskSpiller.java | 17 +- .../iotdb/db/utils/sort/SortBufferManager.java | 33 +- .../schemaRegion/SchemaRegionTableDeviceTest.java | 328 +++++ .../schemaRegion/SchemaRegionTestUtil.java | 67 + .../execution/operator/SortOperatorTest.java | 47 +- .../operator/process/StreamSortOperatorTest.java | 591 ++++++++ .../plan/optimization/LimitOffsetPushDownTest.java | 28 + .../apache/iotdb/db/utils/sort/SortUtilTest.java | 6 +- iotdb-core/metrics/core/pom.xml | 4 +- iotdb-core/metrics/interface/pom.xml | 8 +- iotdb-core/metrics/pom.xml | 2 +- iotdb-core/node-commons/pom.xml | 26 +- .../resources/conf/iotdb-system.properties | 18 + .../apache/iotdb/commons/conf/CommonConfig.java | 20 + .../iotdb/commons/conf/CommonDescriptor.java | 16 + .../org/apache/iotdb/commons/path/PartialPath.java | 5 +- .../apache/iotdb/commons/path/PathPatternUtil.java | 3 +- .../iotdb/commons/path/fa/nfa/SimpleNFA.java | 5 +- .../config/constant/PipeConnectorConstant.java | 10 + .../compressor/PipeCompressorConfig.java} | 23 +- .../compressor/PipeCompressorFactory.java | 62 +- .../connector/compressor/PipeZSTDCompressor.java | 17 +- .../pipe/connector/protocol/IoTDBConnector.java | 25 +- .../apache/iotdb/commons/schema/MemUsageUtil.java | 61 + .../iotdb/commons/schema/SchemaConstant.java | 5 + .../iotdb/commons/schema/filter/SchemaFilter.java | 9 + .../commons/schema/filter/SchemaFilterType.java | 10 + .../commons/schema/filter/SchemaFilterVisitor.java | 15 + .../schema/filter/impl/DeviceAttributeFilter.java | 76 ++ .../schema/filter/impl/DeviceFilterUtil.java | 68 + .../commons/schema/filter/impl/DeviceIdFilter.java | 79 ++ .../iotdb/commons/schema/filter/impl/OrFilter.java | 74 ++ .../commons/schema/tree/AbstractTreeVisitor.java | 4 +- .../service/metric/PerformanceOverviewMetrics.java | 21 + .../commons/subscription/meta/topic/TopicMeta.java | 2 +- .../apache/iotdb/commons/utils/StatusUtils.java | 22 +- iotdb-core/pom.xml | 2 +- iotdb-core/relational-grammar/pom.xml | 2 +- iotdb-protocol/openapi/pom.xml | 2 +- iotdb-protocol/pom.xml | 2 +- iotdb-protocol/thrift-commons/pom.xml | 2 +- iotdb-protocol/thrift-confignode/pom.xml | 4 +- iotdb-protocol/thrift-consensus/pom.xml | 4 +- iotdb-protocol/thrift-datanode/pom.xml | 4 +- library-udf/pom.xml | 4 +- pom.xml | 2 +- 170 files changed, 5712 insertions(+), 1093 deletions(-)
