This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/TableModelGrammar in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 37f5135e55bc1e1ce648783f92250226568e0821 Merge: edd9f243828 3d87ecc1346 Author: JackieTien97 <[email protected]> AuthorDate: Fri Apr 26 15:53:57 2024 +0800 Merge remote-tracking branch 'origin/master' into ty/TableModelGrammar .../apache/iotdb/tools/it/ExportDataTestIT.java | 6 +- .../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +- .../org/apache/iotdb/tool/AbstractDataTool.java | 1 + .../java/org/apache/iotdb/tool/ExportData.java | 21 +-- .../java/org/apache/iotdb/tool/ImportData.java | 73 +++++------ .../consensus/request/ConfigPhysicalPlan.java | 1 + .../consensus/request/ConfigPhysicalPlanType.java | 1 + .../request/ConfigPhysicalPlanVisitor.java | 6 + .../consensus/request/auth/AuthorPlan.java | 3 + .../response/pipe/task/PipeTableResp.java | 8 +- .../confignode/manager/PermissionManager.java | 3 +- .../iotdb/confignode/manager/ProcedureManager.java | 3 +- .../receiver/IoTDBConfigNodeReceiverAgent.java | 6 +- .../protocol/IoTDBConfigRegionAirGapConnector.java | 5 +- .../pipe/event/PipeConfigRegionSnapshotEvent.java | 53 ++++---- .../pipe/event/PipeConfigRegionWritePlanEvent.java | 46 +++++-- .../extractor/ConfigRegionListeningFilter.java | 5 +- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 1 + .../PipeConfigPhysicalPlanTSStatusVisitor.java | 9 ++ .../iotdb/confignode/persistence/AuthorInfo.java | 3 + .../persistence/executor/ConfigPlanExecutor.java | 1 + .../schema/CNPhysicalPlanGenerator.java | 9 +- .../procedure/env/RegionMaintainHandler.java | 3 +- .../impl/pipe/task/AlterPipeProcedureV2.java | 2 +- .../confignode/persistence/AuthorInfoTest.java | 21 +++ .../persistence/CNPhysicalPlanGeneratorTest.java | 3 + .../consensus/iot/logdispatcher/LogDispatcher.java | 8 ++ .../apache/iotdb/consensus/iot/ReplicateTest.java | 36 ++++- .../src/assembly/resources/conf/datanode-env.bat | 3 - .../src/assembly/resources/conf/datanode-env.sh | 3 - .../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 2 +- .../request/PipeTransferTabletInsertNodeReq.java | 46 ++----- .../airgap/IoTDBDataRegionAirGapConnector.java | 9 +- .../airgap/IoTDBSchemaRegionAirGapConnector.java | 5 +- .../protocol/legacy/IoTDBLegacyPipeConnector.java | 14 +- .../connector/protocol/opcua/OpcUaConnector.java | 4 +- .../thrift/sync/IoTDBDataRegionSyncConnector.java | 10 +- .../protocol/websocket/WebSocketConnector.java | 17 ++- .../websocket/WebSocketConnectorServer.java | 5 +- .../db/pipe/event/common/row/PipeRowCollector.java | 4 +- .../schema/PipeSchemaRegionSnapshotEvent.java | 9 ++ .../schema/PipeSchemaRegionWritePlanEvent.java | 44 +++++-- .../tablet/PipeInsertNodeTabletInsertionEvent.java | 121 ++++++++++++----- .../tablet/TabletInsertionDataContainer.java | 15 ++- .../common/tsfile/PipeTsFileInsertionEvent.java | 9 ++ .../dataregion/IoTDBDataRegionExtractor.java | 43 +++++- .../realtime/PipeRealtimeDataRegionExtractor.java | 6 +- .../processor/aggregate/AggregateProcessor.java | 2 +- .../twostage/plugin/TwoStageCountProcessor.java | 3 + .../legacy/IoTDBLegacyPipeReceiverAgent.java | 1 - .../protocol/thrift/IoTDBDataNodeReceiver.java | 13 +- .../visitor/PipePlanToStatementVisitor.java | 105 +++++++++++---- .../visitor/PipeStatementTSStatusVisitor.java | 5 +- .../pipe/task/connection/PipeEventCollector.java | 3 +- .../subtask/processor/PipeProcessorSubtask.java | 38 +++--- .../planner/plan/node/write/InsertRowsNode.java | 9 +- .../impl/ReadChunkCompactionPerformer.java | 12 +- .../execute/utils/MultiTsFileDeviceIterator.java | 146 ++++++++++++--------- .../dataregion/snapshot/SnapshotLoader.java | 12 +- .../broker/SubscriptionPrefetchingQueue.java | 28 ++-- .../db/tools/schema/SRStatementGenerator.java | 104 ++++++++++----- .../db/auth/user/LocalFileUserManagerTest.java | 8 ++ .../extractor/IoTDBDataRegionExtractorTest.java | 32 ++--- .../utils/MultiTsFileDeviceIteratorTest.java | 70 ++++++++++ .../dataregion/wal/WALManagerTest.java | 5 + .../dataregion/wal/node/WALNodeTest.java | 5 + .../wal/node/WalDeleteOutdatedNewTest.java | 5 + .../db/utils/SchemaRegionSnapshotParserTest.java | 86 +++++++++++- .../src/assembly/resources/sbin/start-all.sh | 2 +- .../src/assembly/resources/sbin/stop-all.sh | 2 +- .../commons/auth/authorizer/BasicAuthorizer.java | 12 +- .../iotdb/commons/auth/authorizer/IAuthorizer.java | 2 + .../iotdb/commons/auth/user/BasicUserManager.java | 16 ++- .../iotdb/commons/auth/user/IUserManager.java | 3 +- .../commons/pipe/event/PipeSnapshotEvent.java | 19 ++- .../commons/pipe/event/PipeWritePlanEvent.java | 35 +++-- .../commons/pipe/receiver/IoTDBFileReceiver.java | 6 +- .../commons/pipe/task/meta/PipeStaticMeta.java | 29 ++-- .../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 28 ++-- pom.xml | 2 +- 80 files changed, 1069 insertions(+), 489 deletions(-)
