This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch ty/removeTsFileModule in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 70908c750d4dfb2a68409f7e4eec46f4c9cab866 Merge: 0bfa806f62f fd48ef68254 Author: JackieTien97 <[email protected]> AuthorDate: Wed Apr 3 08:39:37 2024 +0800 Merge remote-tracking branch 'origin/master' into ty/removeTsFileModule .../parameter/PipeParameterValidator.java | 22 +-- .../statemachine/ConfigRegionStateMachine.java | 18 ++- .../client/IoTDBConfigNodeSyncClientManager.java | 8 +- .../protocol/IoTDBConfigRegionConnector.java | 6 +- .../extractor/ConfigRegionListeningFilter.java | 11 -- .../receiver/protocol/IoTDBConfigNodeReceiver.java | 8 - .../PipeConfigPhysicalPlanTSStatusVisitor.java | 3 + .../schemaregion/SchemaRegionStateMachine.java | 8 +- .../client/IoTDBDataNodeAsyncClientManager.java | 86 +++++++++-- .../client/IoTDBDataNodeSyncClientManager.java | 5 +- .../async/IoTDBDataRegionAsyncConnector.java | 4 +- .../thrift/sync/IoTDBDataNodeSyncConnector.java | 5 +- .../common/tsfile/PipeTsFileInsertionEvent.java | 42 ++++-- .../realtime/PipeRealtimeDataRegionExtractor.java | 2 +- .../visitor/PipeStatementExceptionVisitor.java | 27 +++- .../visitor/PipeStatementTSStatusVisitor.java | 23 +-- .../dataregion/memtable/TsFileProcessor.java | 163 ++++++++++----------- .../config/constant/PipeConnectorConstant.java | 18 +++ .../pipe/connector/PipeReceiverStatusHandler.java | 10 +- .../pipe/connector/client/IoTDBSyncClient.java | 4 +- .../connector/client/IoTDBSyncClientManager.java | 107 ++++++++++++-- .../connector/protocol/IoTDBAirGapConnector.java | 98 +++++++++++-- .../pipe/connector/protocol/IoTDBConnector.java | 57 +++++-- .../connector/protocol/IoTDBSslSyncConnector.java | 6 +- 24 files changed, 524 insertions(+), 217 deletions(-)
