private ProcessingInfoResponse buildProcessingInfoResponse(
            final Txn<ByteBuffer> readTxn,
            final Entry<RefStreamDefinition, RefDataProcessingInfo> entry) {

        final RefStreamDefinition refStreamDefinition = entry.getKey();
        final RefDataProcessingInfo refDataProcessingInfo = entry.getValue();

        // Sub-query to get the map names for this refStreamDefinition
        final List<MapDefinition> mapDefinitions = mapDefinitionUIDStore.getMapDefinitions(readTxn,
                refStreamDefinition);

        final Map<String, EntryCounts> mapNameToEntryCountsMap = new HashMap<>();
        for (final MapDefinition mapDefinition : mapDefinitions) {
            final Optional<UID> optMapUid = mapDefinitionUIDStore.get(readTxn, mapDefinition);

            optMapUid.ifPresent(mapUid -> {
                final long keyValueCount = keyValueStoreDb.getEntryCount(mapUid, readTxn);
                final long rangeValueCount = rangeStoreDb.getEntryCount(mapUid, readTxn);
                mapNameToEntryCountsMap.put(
                        mapDefinition.getMapName(),
                        new EntryCounts(keyValueCount, rangeValueCount));
            });
        }

        return new ProcessingInfoResponse(
                refStreamDefinition,
                refDataProcessingInfo,
                mapNameToEntryCountsMap);
    }
For use in testing at SMALL scale. Dumps the content of each DB to the logger.
stroom-pipeline/src/main/java/stroom/pipeline/refdata/store/offheapstore/RefDataOffHeapStore.java