@NotNull
    private Stream<RefStoreEntry> buildKeyValueStoreEntryStream(
            final Txn<ByteBuffer> readTxn,
            final CursorIterable<ByteBuffer> keyValueDbIterable,
            final Map<UID, MapDefinition> uidToMapDefMap,
            final Map<MapDefinition, RefDataProcessingInfo> mapDefToProcessingInfoMap) {

        return StreamSupport.stream(keyValueDbIterable.spliterator(), false)
                .map(keyValueStoreDb::deserializeKeyVal)
                .map(entry -> {
                    final KeyValueStoreKey keyValueStoreKey = entry.getKey();
                    final ValueStoreKey valueStoreKey = entry.getValue();
                    final String keyStr = keyValueStoreKey.getKey();

                    return buildRefStoreEntry(readTxn,
                            keyValueStoreKey.getMapUid(),
                            keyStr,
                            valueStoreKey, uidToMapDefMap, mapDefToProcessingInfoMap);
                });
    }
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