Reference Guide

executeCriticalSection(procedure);
Collection<String> id = new ArrayList<String>();
for (Column<SeverityComposite, ?> sevRow :
rows.getColumns()) {
id.add(sevRow.getName().getValue().getId());
}
if (rowsSet.isEmpty()) {
rowsSet.addAll(id);
} else {
rowsSet.retainAll(id);
}
}
}
}
//Topic filter
if (filter.getTopicCondition() != null) {
final ByteBufferRange range;
switch (filter.getTopicCondition().getMode()) {
case EQUAL:
range = AlertsByOrigin.serializer.buildRange()
.withPrefix(filter.getTopicCondition()
.getValue());
break;
case STARTS_WITH:
range = AlertsByOrigin.serializer.buildRange()
.greaterThanEquals(filter
.getTopicCondition()
.getValue())
.lessThan("~");
break;
default:
range = null;
break;
}
// Find Rows for this filter
Procedure<CassandraStorable<String, Topic>> procedure =
new Procedure<CassandraStorable<String, Topic>>() {
@Override
public CassandraStorable<String, Topic> execute()
throws Exception {
return context.getContext()
.get(AlertsByTopic.COL_FAMILY,
AlertsByTopic.ROW_KEY, range,
AlertsByTopic.TOPIC_DECODER);
107