Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Fetching contributors…

Cannot retrieve contributors at this time

44 lines (34 sloc) 0.964 kb
using System;
using FluentCassandra.Types;
using Apache.Cassandra;
namespace FluentCassandra.Operations
{
public class GetSuperColumn : ColumnFamilyOperation<FluentSuperColumn>
{
/*
* ColumnOrSuperColumn get(keyspace, key, column_path, consistency_level)
*/
public CassandraObject Key { get; private set; }
public CassandraObject SuperColumnName { get; private set; }
public override FluentSuperColumn Execute()
{
var schema = ColumnFamily.GetSchema();
var path = new CassandraColumnPath {
ColumnFamily = ColumnFamily.FamilyName
};
if (SuperColumnName != null)
path.SuperColumn = SuperColumnName;
var output = Session.GetClient().get(
Key,
path,
Session.ReadConsistency
);
return (FluentSuperColumn)Helper.ConvertToFluentBaseColumn(output, schema);
}
public GetSuperColumn(CassandraObject key, CassandraObject superColumnName)
{
Key = key;
SuperColumnName = superColumnName;
}
}
}
Jump to Line
Something went wrong with that request. Please try again.