public void process()

in webindex/modules/data/src/main/java/webindex/data/fluo/DomainCombineQ.java [50:61]


    public void process(TransactionBase tx, Iterable<Change<String, Long>> updates) {
      for (Change<String, Long> update : updates) {
        String domain = update.getKey();
        Long oldVal = update.getOldValue().orElse(0L);
        Long newVal = update.getNewValue().orElse(0L);
        if (oldVal == 0L && newVal > 0L) {
          domainsNew.mark();
        }
        exportQ.add(tx, domain, new DomainUpdate(domain, oldVal, newVal));
        domainsChanged.mark();
      }
    }