public void handleTemporaryMetaChanges(final Iterable<PipeMeta> pipeMetaList) {
    final Set<String> pipeTaskIDs = new HashSet<>();
    pipeMetaList.forEach(
        pipeMeta -> {
          final String pipeTaskID =
              pipeMeta.getStaticMeta().getPipeName()
                  + "_"
                  + pipeMeta.getStaticMeta().getCreationTime();
          if (!pipeTemporaryMetaMap.containsKey(pipeTaskID)) {
            register(pipeMeta);
          }
          pipeTaskIDs.add(pipeTaskID);
        });
    ImmutableSet.copyOf(pipeTemporaryMetaMap.keySet()).stream()
        .filter(pipeTaskID -> !pipeTaskIDs.contains(pipeTaskID))
        .forEach(this::deregister);
  }
The {@link PipeTemporaryMetaInCoordinatorMetrics} is to calculate the pipe-statistics from the
{@link PipeTemporaryMeta}. The class is lock-free and can only read from the thread-safe
variables from the {@link PipeTemporaryMeta}.
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/metric/overview/PipeTemporaryMetaInCoordinatorMetrics.java