[iotdb] branch master updated (4cc7819f2a7 -> d0b6a6612b2)

[ro...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 4cc7819f2a7 Fix doc after code package changed (#10359)
     add d0b6a6612b2 Pipe: fix bugs & smells reported by SonarCloud (#10355)

No new revisions were added by this update.

Summary of changes:
 .../manager/pipe/runtime/PipeHeartbeatParser.java  |  6 ++-
 .../manager/pipe/task/PipeTaskCoordinator.java     |  3 +-
 .../db/pipe/agent/plugin/PipePluginAgent.java      | 20 ++++++---
 .../db/pipe/agent/runtime/PipeAgentLauncher.java   |  3 +-
 .../iotdb/db/pipe/agent/task/PipeTaskAgent.java    | 46 ++++++++++++-------
 .../pipe/connector/legacy/IoTDBSyncConnector.java  | 47 ++++++++++----------
 .../pipe/connector/legacy/IoTDBSyncReceiver.java   | 13 +++---
 .../connector/legacy/loader/DeletionLoader.java    |  1 +
 .../db/pipe/connector/legacy/loader/ILoader.java   |  1 +
 .../pipe/connector/legacy/loader/TsFileLoader.java |  1 +
 .../legacy/pipedata/DeletionPipeData.java          |  9 +++-
 .../pipe/connector/legacy/pipedata/PipeData.java   |  4 +-
 .../connector/legacy/pipedata/TsFilePipeData.java  | 14 ++++--
 .../pipe/connector/v1/IoTDBThriftConnectorV1.java  | 51 +++++++++++-----------
 .../pipe/connector/v1/IoTDBThriftReceiverV1.java   |  3 +-
 .../v1/request/PipeTransferTabletReq.java          |  5 ++-
 .../pipe/connector/v2/IoTDBThriftConnectorV2.java  |  3 +-
 .../PipeTransferTabletInsertionEventHandler.java   |  3 +-
 .../event/common/row/PipeDataTypeTransformer.java  |  2 +-
 .../PipeRealtimeDataRegionHybridExtractor.java     |  9 ++--
 .../PipeRealtimeDataRegionLogExtractor.java        |  6 ++-
 .../PipeRealtimeDataRegionTsFileExtractor.java     |  6 ++-
 .../resource/file/PipeFileResourceManager.java     |  5 ++-
 .../db/pipe/resource/wal/PipeWALResource.java      |  1 +
 .../db/pipe/task/stage/PipeTaskProcessorStage.java |  1 +
 .../db/pipe/task/subtask/PipeConnectorSubtask.java | 22 +++++++---
 .../subtask/PipeConnectorSubtaskLifeCycle.java     |  1 +
 .../db/pipe/task/subtask/PipeProcessorSubtask.java |  7 ++-
 .../iotdb/db/pipe/task/subtask/PipeSubtask.java    |  9 ++--
 .../iotdb/commons/pipe/config/PipeConfig.java      |  2 +-
 .../builtin/connector/IoTDBSyncConnector.java      | 18 ++++----
 .../builtin/connector/IoTDBThriftConnector.java    | 18 ++++----
 .../plugin/builtin/extractor/IoTDBExtractor.java   | 13 +++---
 .../builtin/processor/DoNothingProcessor.java      | 14 +++---
 .../pipe/plugin/service/PipePluginClassLoader.java |  4 +-
 .../service/PipePluginClassLoaderManager.java      | 10 ++---
 .../service/PipePluginExecutableManager.java       | 14 +++---
 .../commons/pipe/task/meta/PipeMetaKeeper.java     |  1 +
 .../commons/pipe/task/meta/PipeStaticMeta.java     |  1 +
 .../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 12 ++---
 40 files changed, 246 insertions(+), 163 deletions(-)