Reference Guide

colFamilies.add(AlertColumnFamily.CF_DEF);
colFamilies.add(AlertsBySeverity.CF_DEF);
colFamilies.add(AlertsByState.CF_DEF);
colFamilies.add(AlertsByTopic.CF_DEF);
colFamilies.add(AlertsByOrigin.CF_DEF);
colFamilies.add(AlertsCount.CF_DEF);
colFamilies.add(AlertsByUidAndSysId.CF_DEF);
colFamilies.add(AlertsByTimeStamp.CF_DEF);
return colFamilies;
}
getMainColumnFamily()
This method returns a handle to the main column family.
CassandraAlertDao.java
@Override
protected ColumnFamilyDefinition<String, String> getMainColumnFamily() {
return AlertColumnFamily.CF_DEF;
}
findRows()
This method is used to find the row keys that match a specific search criteria. Used during find
operations.
The abstraction layer calls this method.
CassandraAlertDao.java:
@Override
protected Collection<String> findRows(CassandraAlertFilter filter,
final DataStoreContext context)
throws PersistenceException, Exception {
Collection<String> rowsSet = new ArrayList<String>();
if (filter == null) {
Collection<String> id = new ArrayList<String>();
Procedure<CassandraStorable<String, String>> procedure = new
Procedure<CassandraStorable<String, String>>() {
@Override
public CassandraStorable<String, String> execute()
throws Exception {
return (context.getContext().get(
AlertsCount.COL_FAMILY, AlertsCount.COUNT_DECODER,
AlertsCount.ROW_KEY));
}
};
104