in src/main/java/org/apache/sling/cassandra/resource/provider/CassandraResource.java [131:149]
public Iterator<Resource> listChildren() {
List<Resource> children = new ArrayList<Resource>();
try {
QueryResult<CqlRows<String, String, String>> result = CassandraResourceProviderUtil.getAllNodes(
resourceProvider.getKeyspace(),
CassandraResourceProviderUtil.getColumnFamilySector(resourcePath));
for (Row<String, String, String> row : result.get().getList()) {
for (HColumn column : row.getColumnSlice().getColumns()) {
if ("path".equals(column.getName()) && CassandraResourceProviderUtil.isAnImmediateChild(resourcePath, column.getValue().toString())) {
children.add( new CassandraResource(resourceProvider,resourceResolver,column.getValue().toString(),valueMap));
}
}
}
} catch (Exception e) {
System.out.println("Error occurred while getting child nodes " + e.getMessage());
LOGGER.error("Error occurred while getting child nodes " + e.getMessage());
}
return children.iterator();
}