public OffHeapStagingStore create(final RefStreamDefinition refStreamDefinition,
                                      final MapDefinitionUIDStore mapDefinitionUIDStore) {

        final LmdbEnv stagingLmdbEnv = buildStagingEnv(
                lmdbEnvFactory,
                refStreamDefinition);

        final KeyValueStagingDb keyValueStagingDb = keyValueStagingDbFactory.create(stagingLmdbEnv);
        final RangeValueStagingDb rangeValueStagingDb = rangeValueStagingDbFactory.create(stagingLmdbEnv);

        return new OffHeapStagingStore(
                stagingLmdbEnv,
                keyValueStagingDb,
                rangeValueStagingDb,
                mapDefinitionUIDStore,
                pooledByteBufferOutputStreamFactory);
    }
Create a {@link OffHeapStagingStore} for use by one thread to load a reference stream into.
@param refStreamDefinition The {@link RefStreamDefinition} of the stream being loaded.
@param mapDefinitionUIDStore The mapDefinitionUIDStore for the destination.
stroom-pipeline/src/main/java/stroom/pipeline/refdata/store/offheapstore/OffHeapStagingStoreFactory.java