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

        return StreamSupport.stream(rangeValueDbIterable.spliterator(), false)
                .map(rangeStoreDb::deserializeKeyVal)
                .map(entry -> {
                    final RangeStoreKey rangeStoreKey = entry.getKey();
                    final ValueStoreKey valueStoreKey = entry.getValue();
                    final String keyStr = rangeStoreKey.getKeyRange().getFrom() + "-"
                                          + rangeStoreKey.getKeyRange().getTo();
                    return buildRefStoreEntry(
                            readTxn,
                            rangeStoreKey.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