core/src/main/java/org/sakaiproject/nakamura/lite/storage/jdbc/WideColumnIndexer.java
@Override
    public void invalidate(String keySpace, String columnFamily, Map<String, Object> queryProperties) {
        Map<String, CacheHolder> queryCache = client.getQueryCache();
        if (queryCache == null) {
            return;
        }
        String cacheKey = getCacheKey(keySpace, columnFamily, queryProperties);
        if (cacheKey != null) {
            LOGGER.debug("Removing Cached Query {} ",cacheKey);
            queryCache.remove(cacheKey);
        }
    }
@Override
    public void invalidate(String keySpace, String columnFamily, Map<String, Object> queryProperties) {
        Map<String, CacheHolder> queryCache = client.getQueryCache();
        if (queryCache == null) {
            return;
        }
        String cacheKey = getCacheKey(keySpace, columnFamily, queryProperties);
        if (cacheKey != null) {
            LOGGER.debug("Removing Cached Query {} ",cacheKey);
            queryCache.remove(cacheKey);
        }
    }
-----------------------------------------------------------------------------------