This is an automated email from the ASF dual-hosted git repository. yongzao pushed a commit to branch optimize-getOrCreatePartition in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 120b7da20c13c010a3722fdef7cdcc6d8e671c7c Merge: 3206ed95d10 f8516ed32d8 Author: YongzaoDan <[email protected]> AuthorDate: Tue May 23 09:29:07 2023 +0800 Merge branch 'master' into optimize-getOrCreatePartition .../statemachine/ConfigRegionStateMachine.java | 6 +- .../manager/pipe/runtime/PipeMetaSyncer.java | 21 ++++- .../Ecosystem-Integration/Grafana-Plugin.md | 8 +- .../Ecosystem-Integration/Grafana-Plugin.md | 6 +- .../builtin/connector/DoNothingConnector.java | 4 +- .../builtin/connector/IoTDBThriftConnector.java | 4 +- .../builtin/processor/DoNothingProcessor.java | 11 ++- .../org/apache/iotdb/pipe/api/PipeConnector.java | 10 +-- .../org/apache/iotdb/pipe/api/PipeProcessor.java | 10 +-- .../iotdb/pipe/api/collector/EventCollector.java | 39 ++-------- .../org/apache/iotdb/pipe/api/event/Event.java | 6 +- .../pipe/api/event/dml/deletion/DeletionEvent.java | 48 ------------ .../event/dml/insertion/TabletInsertionEvent.java | 6 -- .../event/dml/insertion/TsFileInsertionEvent.java | 6 -- .../compaction/schedule/CompactionScheduler.java | 49 ++++++++---- .../compaction/schedule/CompactionTaskManager.java | 1 + .../iotdb/db/engine/storagegroup/DataRegion.java | 12 ++- .../db/engine/storagegroup/TsFileManager.java | 1 + .../PipeRealtimeDataRegionHybridCollector.java | 49 ++++++------ .../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 6 +- .../event/realtime/PipeRealtimeCollectEvent.java | 6 -- .../event/view/collector/PipeEventCollector.java | 19 +---- .../execution/executor/PipeSubtaskExecutor.java | 24 ++++-- .../execution/scheduler/PipeSubtaskScheduler.java | 89 ++++++++++++++++++++++ .../execution/scheduler/PipeTaskScheduler.java | 74 ------------------ .../db/pipe/task/subtask/PipeConnectorSubtask.java | 27 +++---- .../db/pipe/task/subtask/PipeProcessorSubtask.java | 26 +++---- .../iotdb/db/pipe/task/subtask/PipeSubtask.java | 34 +++++++-- .../SizeTieredCompactionSelectorTest.java | 38 +++++++++ .../core/collector/PipeRealtimeCollectTest.java | 20 +++-- 30 files changed, 333 insertions(+), 327 deletions(-)
