public void commit()

in src/main/java/org/apache/sling/cassandra/resource/provider/CassandraResourceProvider.java [220:235]

• 14 lines of code
• 7 McCabe index (conditional complexity)

    public void commit(ResourceResolver resourceResolver) throws PersistenceException {
        for (Map.Entry<String, Map> entry : TRANSIENT_CREATE_MAP.entrySet()) {
            if (entry.getKey() != null && entry.getValue() != null) {
                if(insertResource(entry.getKey(), entry.getValue())){
                    defineCassandra(entry.getKey());
                }
            }
        }

        for (Map.Entry<String, Map> entry : TRANSIENT_DELETE_MAP.entrySet()) {
            if(deleteResource(resourceResolver, entry.getKey())){
                CASSANDRA_MAP.remove(entry.getKey());
            }
        }

    }