Reference Guide

private static final ColumnFamily<String, SeverityComposite> COL_FAMILY
= ColumnFamily.newColumnFamily("AlertsBySeverity",
StringSerializer .get(), serializer, ByteSerializer .get());
private static final ColumnFamilyDefinition<String, SeverityComposite>
CF_DEF = new ColumnFamilyDefinition<String, SeverityComposite>(
COL_FAMILY, BasicType.UTF8, BasicType.BYTES,
new CompositeType(BasicType.UTF8, BasicType.UTF8),
"Alerts By Severity CF");
private static final String ROW_KEY = "AlertsBySeverity";
private static final
Provider<ColumnDecoder<SeverityComposite, ?>,
ColumnName<SeverityComposite, ?>> SEVERITY_DECODER = new Provider
<ColumnDecoder<SeverityComposite, ?>,
ColumnName<SeverityComposite, ?>>() {
@Override
public ColumnDecoder<SeverityComposite, ?>
get(ColumnName<SeverityComposite, ?> entity) {
return ValuelessColumnDecoder.getInstance();
}
};
@Override
public void prepareMutation(CassandraAlert transportable,
DataStoreContext context) throws Exception {
CassandraStorable<String, SeverityComposite> storable = new
CassandraStorable<String, SeverityComposite>(ROW_KEY);
storable.setColumn(new ValuelessColumn<SeverityComposite>(
ColumnName.<SeverityComposite, Void> valueOf(
new SeverityComposite(transportable.getSeverity(),
transportable.getId().getValue()))));
context.getContext().prepareMutation(COL_FAMILY, storable);
}
@Override
public void prepareTransaction(CassandraAlert transportable,
DataStoreContext context) throws Exception {
context.getTransactionContext()
.prepareTransaction(COL_FAMILY.getName(), ROW_KEY);
}
99