code: public void remove(String tenantId, String triggerId) {
          if (tenantId == null) {
              throw new IllegalArgumentException("tenantId must be not null");
          }
          if (triggerId == null) {
              throw new IllegalArgumentException("triggerId must be not null");
          }
          Set<DataEntry> dataEntriesToRemove = new HashSet<>();
          activeDataEntries.stream().forEach(e -> {
              if (e.getTenantId().equals(tenantId) && e.getTriggerId().equals(triggerId)) {
                  dataEntriesToRemove.add(e);
              }
          });
          activeDataEntries.removeAll(dataEntriesToRemove);
          Set<DataId> dataIdToCheck = new HashSet<>();
          dataEntriesToRemove.stream().forEach(e -> {
              dataIdToCheck.add(new DataId(e.getTenantId(), e.getDataId()));
          });
          Set<DataId> dataIdToRemove = new HashSet<>();
          dataIdToCheck.stream().forEach(dataId -> {
              boolean found = false;
              for (DataEntry entry : activeDataEntries) {
                  DataId currentDataId = new DataId(entry.getTenantId(), entry.getDataId());
                  if (currentDataId.equals(dataId)) {
                      found = true;
                      break;
                  }
              }
              if (!found) {
                  dataIdToRemove.add(dataId);
              }
          });
          activeDataIds.removeAll(dataIdToRemove);
      }
docs: Remove all DataEntry for a specified trigger.
  
  @param triggerId to remove