public void updateTriggersOnTransferNodes(List<TDataNodeLocation> transferNodes) {
    Set<TDataNodeLocation> dataNodeLocationSet = new HashSet<>(transferNodes);
    triggerTable
        .values()
        .forEach(
            triggerInformation -> {
              if (triggerInformation.isStateful()
                  && dataNodeLocationSet.contains(triggerInformation.getDataNodeLocation())) {
                triggerInformation.setTriggerState(TTriggerState.TRANSFERRING);
              }
            });
  }
This Class used to save the information of Triggers and implements methods of manipulate it.
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/trigger/TriggerTable.java