in src/main/java/org/apache/sling/cassandra/resource/provider/CassandraResourceProvider.java [107:130]
public Resource getResource(ResourceResolver resourceResolver, String s) {
//Populating the map of cassandra mappers.
if(s.startsWith("/") && !s.equals("/content/cassandra") && s.split("/").length <= 4){
return new CassandraResource(this, resourceResolver, s, new CassandraResource.CassandraValueMap(s),new HashMap<String, Object>());
}
System.out.println("%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%%"+s);
if (CASSANDRA_MAP.get(s) == null) {
return null;
}
if (CassandraResourceProviderUtil.getColumnFamilySector(s) != null && !getCassandraMapperMap().containsKey(CassandraResourceProviderUtil.getColumnFamilySector(s))) {
getCassandraMapperMap().put(CassandraResourceProviderUtil.getColumnFamilySector(s), new DefaultCassandraMapperImpl());
}
try {
return new CassandraResource(this, resourceResolver, s, CASSANDRA_MAP.get(s));
// return CassandraResourceProviderUtil.isResourceExists(this,keyspace,s) ? new CassandraResource(this,resourceResolver, s,CASSANDRA_MAP.get(s)) : null;
} catch (Exception e) {
System.out.println("Error at Provider " + e.getMessage());
LOGGER.error("Error at Provider " + e.getMessage());
LOGGER.debug(e.getMessage());
}
return null;
}