Permalink
Browse files

Changed the MultiGetColumnFamilySlice operator to check to see if a c…

…ounter column type was returned, and do the subsequent conversion if found. Otherwise, default to normal behavior.
  • Loading branch information...
1 parent 9298c35 commit 668cc471b66d3240bd26a1746884b9aca53f8d53 @Aaronontheweb Aaronontheweb committed Jan 6, 2013
Showing with 3 additions and 1 deletion.
  1. +3 −1 src/Operations/MultiGetColumnFamilySlice.cs
@@ -36,7 +36,9 @@ public override IEnumerable<FluentColumnFamily> Execute()
var key = CassandraObject.GetCassandraObjectFromDatabaseByteArray(result.Key, schema.KeyValueType);
var r = new FluentColumnFamily(key, ColumnFamily.FamilyName, schema, result.Value.Select(col => {
- return Helper.ConvertColumnToFluentColumn(col.Column, schema);
+ if(col.Counter_column != null)
+ return Helper.ConvertColumnToFluentCounterColumn(col.Counter_column, schema);
+ return Helper.ConvertColumnToFluentColumn(col.Column, schema);
}));
ColumnFamily.Context.Attach(r);
r.MutationTracker.Clear();

0 comments on commit 668cc47

Please sign in to comment.