in src/main/java/org/apache/sling/cassandra/resource/provider/CassandraResourceProvider.java [260:282]
private boolean insertResource(String path, Map map) throws PersistenceException {
try {
String r = getrowID(path);
if(r == null){
return false;
}
String _cf = CassandraResourceProviderUtil.getColumnFamilySector(path);
createColumnFamily(_cf, this.getKeyspace(), new StringSerializer());
String metadata = map.get("metadata") == null? "resolutionPathInfo=json":(String)map.get("metadata");
String resourceType = map.get("resourceType") == null?"nt:cassandra":(String)map.get("resourceType");
String resourceSuperType = map.get("resourceSuperType") == null?"nt:superCassandra":(String) map.get("resourceSuperType");
addData(this.getKeyspace(), _cf, new StringSerializer(),
new String[]{
"'" + r + "','" + path + "','" + resourceType + "','" + resourceSuperType + "','" + metadata + "'",
});
} catch (NoSuchAlgorithmException e) {
throw new PersistenceException(e.getMessage());
} catch (UnsupportedEncodingException e) {
throw new PersistenceException(e.getMessage());
}
return true;
}