me.prettyprint.cassandra.model.thrift
Class ThriftCountQuery<K,N>

java.lang.Object
  me.prettyprint.cassandra.model.thrift.ThriftCountQuery<K,N>

All Implemented Interfaces:

CountQuery<K,N>, Query<Integer>

public final class ThriftCountQuery<K,N>
extends Object
implements CountQuery<K,N>

Counts column for a standard column family

Author:

Ran Tavory

Field Summary

protected String	columnFamily
protected K	key
protected Serializer<K>	keySerializer
protected ExecutingKeyspace	keyspace
protected HSlicePredicate<N>	slicePredicate The slice predicate for which the count it performed

Constructor Summary

ThriftCountQuery(Keyspace k, Serializer<K> keySerializer, Serializer<N> nameSerializer)

Method Summary

protected QueryResult<Integer>	countColumns()
QueryResult<Integer>	execute()
ThriftCountQuery<K,N>	setColumnFamily(String cf)
CountQuery<K,N>	setColumnNames(N... columnNames)
ThriftCountQuery<K,N>	setKey(K key)
CountQuery<K,N>	setRange(N start, N finish, int count)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

keyspace

protected final ExecutingKeyspace keyspace

columnFamily

protected String columnFamily

key

protected K key

keySerializer

protected final Serializer<K> keySerializer

slicePredicate

protected final HSlicePredicate<N> slicePredicate

The slice predicate for which the count it performed

Constructor Detail

ThriftCountQuery

public ThriftCountQuery(Keyspace k,
                        Serializer<K> keySerializer,
                        Serializer<N> nameSerializer)

Method Detail

execute

public QueryResult<Integer> execute()

Specified by:

execute in interface Query<Integer>

toString

public String toString()

Overrides:

toString in class Object

setKey

public ThriftCountQuery<K,N> setKey(K key)

Specified by:

setKey in interface CountQuery<K,N>

setColumnFamily

public ThriftCountQuery<K,N> setColumnFamily(String cf)

Specified by:

setColumnFamily in interface CountQuery<K,N>

setRange

public CountQuery<K,N> setRange(N start,
                                N finish,
                                int count)

Specified by:

setRange in interface CountQuery<K,N>

setColumnNames

public CountQuery<K,N> setColumnNames(N... columnNames)

countColumns

protected QueryResult<Integer> countColumns()