private void insert() {
        stateMap.forEach((stateDoc, list) -> {
            try {
                final Provider<CqlSession> sessionProvider =
                        cqlSessionFactory.getSessionProvider(stateDoc.getScyllaDbRef());
                new StateDao(sessionProvider, stateDoc.getName()).insert(list);
                list.forEach(state -> byteBufferFactory.release(state.value()));
                list.clear();
            } catch (final Exception e) {
                errorReceiverProxy.log(Severity.ERROR, null, getElementId(), e.getMessage(), e);
            }
        });
        stateMap.clear();

        temporalStateMap.forEach((stateDoc, list) -> {
            try {
                final Provider<CqlSession> sessionProvider =
                        cqlSessionFactory.getSessionProvider(stateDoc.getScyllaDbRef());
                new TemporalStateDao(sessionProvider, stateDoc.getName()).insert(list);
                list.forEach(state -> byteBufferFactory.release(state.value()));
                list.clear();
            } catch (final Exception e) {
                errorReceiverProxy.log(Severity.ERROR, null, getElementId(), e.getMessage(), e);
            }
        });
        temporalStateMap.clear();

        rangedStateMap.forEach((stateDoc, list) -> {
            try {
                final Provider<CqlSession> sessionProvider =
                        cqlSessionFactory.getSessionProvider(stateDoc.getScyllaDbRef());
                new RangedStateDao(sessionProvider, stateDoc.getName()).insert(list);
                list.forEach(state -> byteBufferFactory.release(state.value()));
                list.clear();
            } catch (final Exception e) {
                errorReceiverProxy.log(Severity.ERROR, null, getElementId(), e.getMessage(), e);
            }
        });
        rangedStateMap.clear();

        temporalRangedStateMap.forEach((stateDoc, list) -> {
            try {
                final Provider<CqlSession> sessionProvider =
                        cqlSessionFactory.getSessionProvider(stateDoc.getScyllaDbRef());
                new TemporalRangedStateDao(sessionProvider, stateDoc.getName()).insert(list);
                list.forEach(state -> byteBufferFactory.release(state.value()));
                list.clear();
            } catch (final Exception e) {
                errorReceiverProxy.log(Severity.ERROR, null, getElementId(), e.getMessage(), e);
            }
        });
        temporalRangedStateMap.clear();

        sessionMap.forEach((stateDoc, list) -> {
            try {
                final Provider<CqlSession> sessionProvider =
                        cqlSessionFactory.getSessionProvider(stateDoc.getScyllaDbRef());
                new SessionDao(sessionProvider, stateDoc.getName()).insert(list);
                list.clear();
            } catch (final Exception e) {
                errorReceiverProxy.log(Severity.ERROR, null, getElementId(), e.getMessage(), e);
            }
        });
        sessionMap.clear();
    }
This XML filter captures XML content that defines key, value maps to be
stored as reference data. The key, value map content is likely to have been
produced as the result of an XSL transformation of some reference data.
<p>
This filter will typically fire
stroom-state/stroom-state-impl/src/main/java/stroom/state/impl/pipeline/StateFilter.java