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();
}
}