public class

ThriftColumnFamilyQueryImpl

extends Object
implements ColumnFamilyQuery<K, C>
java.lang.Object
   ↳ com.netflix.astyanax.thrift.ThriftColumnFamilyQueryImpl<K, C>

Class Overview

Implementation of all column family queries using the thrift API.

Summary

Public Constructors
ThriftColumnFamilyQueryImpl(ExecutorService executor, KeyspaceTracerFactory tracerFactory, Keyspace keyspace, ConnectionPool<Client> cp, ColumnFamily<K, C> columnFamily, ConsistencyLevel consistencyLevel, RetryPolicy retry)
Public Methods
AllRowsQuery<K, C> getAllRows()
Query to get an iterator to all rows in the column family
RowQuery<K, C> getKey(K rowKey)
Query a single key
RowSliceQuery<K, C> getKeyRange(K startKey, K endKey, String startToken, String endToken, int count)
Query a range of keys.
RowSliceQuery<K, C> getKeySlice(Collection<K> keys)
Query a non-contiguous set of keys.
RowSliceQuery<K, C> getKeySlice(Iterable<K> keys)
Query a non-contiguous set of keys.
RowSliceQuery<K, C> getKeySlice(K[] keys)
ColumnFamilyQuery<K, C> pinToHost(Host host)
Run the query on the specified host
IndexQuery<K, C> searchWithIndex()
Search for keys matching the provided index clause
ColumnFamilyQuery<K, C> setConsistencyLevel(ConsistencyLevel consistencyLevel)
Set the consistency level for this operations.
CqlQuery<K, C> withCql(String cql)
Prepare a CQL Query
ColumnFamilyQuery<K, C> withRetryPolicy(RetryPolicy retry)
Set the retry policy to use instead of the default
[Expand]
Inherited Methods
From class java.lang.Object
From interface com.netflix.astyanax.query.ColumnFamilyQuery

Public Constructors

public ThriftColumnFamilyQueryImpl (ExecutorService executor, KeyspaceTracerFactory tracerFactory, Keyspace keyspace, ConnectionPool<Client> cp, ColumnFamily<K, C> columnFamily, ConsistencyLevel consistencyLevel, RetryPolicy retry)

Public Methods

public AllRowsQuery<K, C> getAllRows ()

Query to get an iterator to all rows in the column family

public RowQuery<K, C> getKey (K rowKey)

Query a single key

public RowSliceQuery<K, C> getKeyRange (K startKey, K endKey, String startToken, String endToken, int count)

Query a range of keys. startKey and endKey cannot not be used with the RandomPartitioner.

Parameters
count Max number of keys to return

public RowSliceQuery<K, C> getKeySlice (Collection<K> keys)

Query a non-contiguous set of keys.

public RowSliceQuery<K, C> getKeySlice (Iterable<K> keys)

Query a non-contiguous set of keys.

public RowSliceQuery<K, C> getKeySlice (K[] keys)

public ColumnFamilyQuery<K, C> pinToHost (Host host)

Run the query on the specified host

public IndexQuery<K, C> searchWithIndex ()

Search for keys matching the provided index clause

public ColumnFamilyQuery<K, C> setConsistencyLevel (ConsistencyLevel consistencyLevel)

Set the consistency level for this operations.

public CqlQuery<K, C> withCql (String cql)

Prepare a CQL Query

public ColumnFamilyQuery<K, C> withRetryPolicy (RetryPolicy retry)

Set the retry policy to use instead of the default