public int getPipeHeartbeatEventCount() {
    return eventCounter.getPipeHeartbeatEventCount();
  }
Clear the matcher and disruptor. The method {@link PipeDataRegionAssigner#publishToAssign}
should not be used after calling this method.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/PipeDataRegionAssigner.java