@Override
    protected RefDataLoader createLoader(final RefStreamDefinition refStreamDefinition,
                                         final long effectiveTimeMs) {
        //TODO should we pass in an ErrorReceivingProxy so we can log errors with it?
        final RefDataLoader refDataLoader = offHeapRefDataLoaderFactory.create(
                refStreamDefStripedReentrantLock,
                refStreamDefinition,
                effectiveTimeMs,
                this,
                lmdbEnvironment);

        refDataLoader.setCommitInterval(referenceDataConfigProvider.get().getMaxPutsBeforeCommit());
        return refDataLoader;
    }
Get an instance of a {@link RefDataLoader} for bulk loading multiple entries for a given
{@link RefStreamDefinition} and its associated effectiveTimeMs. The {@link RefDataLoader}
should be used in a try with resources block to ensure any transactions are closed, e.g.
<pre>try (RefDataLoader refDataLoader = refDataOffHeapStore.getLoader(...)) { ... }</pre>
stroom-pipeline/src/main/java/stroom/pipeline/refdata/store/offheapstore/RefDataOffHeapStore.java