|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.netflix.astyanax.thrift.ThriftColumnFamilyQueryImpl<K,C>
K
- C
- public class ThriftColumnFamilyQueryImpl<K,C>
Implementation of all column family queries using the thrift API.
Constructor Summary | |
---|---|
ThriftColumnFamilyQueryImpl(ExecutorService executor,
KeyspaceTracerFactory tracerFactory,
Keyspace keyspace,
ConnectionPool<org.apache.cassandra.thrift.Cassandra.Client> cp,
ColumnFamily<K,C> columnFamily,
ConsistencyLevel consistencyLevel,
RetryPolicy retry)
|
Method Summary | |
---|---|
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(K[] keys)
Query a non-contiguous set of 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 |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public ThriftColumnFamilyQueryImpl(ExecutorService executor, KeyspaceTracerFactory tracerFactory, Keyspace keyspace, ConnectionPool<org.apache.cassandra.thrift.Cassandra.Client> cp, ColumnFamily<K,C> columnFamily, ConsistencyLevel consistencyLevel, RetryPolicy retry)
Method Detail |
---|
public RowQuery<K,C> getKey(K rowKey)
ColumnFamilyQuery
getKey
in interface ColumnFamilyQuery<K,C>
public RowSliceQuery<K,C> getKeyRange(K startKey, K endKey, String startToken, String endToken, int count)
ColumnFamilyQuery
getKeyRange
in interface ColumnFamilyQuery<K,C>
count
- Max number of keys to return
public RowSliceQuery<K,C> getKeySlice(K[] keys)
ColumnFamilyQuery
getKeySlice
in interface ColumnFamilyQuery<K,C>
public RowSliceQuery<K,C> getKeySlice(Collection<K> keys)
ColumnFamilyQuery
getKeySlice
in interface ColumnFamilyQuery<K,C>
public ColumnFamilyQuery<K,C> setConsistencyLevel(ConsistencyLevel consistencyLevel)
ColumnFamilyQuery
setConsistencyLevel
in interface ColumnFamilyQuery<K,C>
public IndexQuery<K,C> searchWithIndex()
ColumnFamilyQuery
searchWithIndex
in interface ColumnFamilyQuery<K,C>
public CqlQuery<K,C> withCql(String cql)
ColumnFamilyQuery
withCql
in interface ColumnFamilyQuery<K,C>
public AllRowsQuery<K,C> getAllRows()
ColumnFamilyQuery
getAllRows
in interface ColumnFamilyQuery<K,C>
public ColumnFamilyQuery<K,C> pinToHost(Host host)
ColumnFamilyQuery
pinToHost
in interface ColumnFamilyQuery<K,C>
public ColumnFamilyQuery<K,C> withRetryPolicy(RetryPolicy retry)
ColumnFamilyQuery
withRetryPolicy
in interface ColumnFamilyQuery<K,C>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |