|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.netflix.astyanax.thrift.AbstractThriftAllRowsQueryImpl<K,C>
public abstract class AbstractThriftAllRowsQueryImpl<K,C>
Field Summary | |
---|---|
protected org.apache.cassandra.thrift.SlicePredicate |
predicate
|
Constructor Summary | |
---|---|
AbstractThriftAllRowsQueryImpl(ColumnFamily<K,C> columnFamily)
|
Method Summary | |
---|---|
int |
getBlockSize()
|
protected ExceptionCallback |
getExceptionCallback()
|
protected abstract List<org.apache.cassandra.thrift.KeySlice> |
getNextBlock(org.apache.cassandra.thrift.KeyRange range)
|
boolean |
getRepeatLastToken()
|
AllRowsQuery<K,C> |
setBlockSize(int blockSize)
|
AllRowsQuery<K,C> |
setExceptionCallback(ExceptionCallback cb)
Sets the exception handler to use when handling exceptions inside Iterator.next(). |
AllRowsQuery<K,C> |
setRepeatLastToken(boolean repeatLastToken)
If true will repeat the last token in the previous block. |
AllRowsQuery<K,C> |
setRowLimit(int rowLimit)
Maximum number of rows to return for each incremental query to Cassandra. |
AllRowsQuery<K,C> |
withColumnRange(ByteBuffer startColumn,
ByteBuffer endColumn,
boolean reversed,
int count)
Specify a range and provide pre-constructed start and end columns. |
AllRowsQuery<K,C> |
withColumnRange(ByteBufferRange range)
Specify a range of composite columns. |
AllRowsQuery<K,C> |
withColumnRange(C startColumn,
C endColumn,
boolean reversed,
int count)
Specify a range of columns to return. |
AllRowsQuery<K,C> |
withColumnSlice(C... columns)
Specify a non-contiguous set of columns to retrieve. |
AllRowsQuery<K,C> |
withColumnSlice(Collection<C> columns)
Specify a non-contiguous set of columns to retrieve. |
AllRowsQuery<K,C> |
withColumnSlice(ColumnSlice<C> slice)
Use this when your application caches the column slice. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface com.netflix.astyanax.query.AllRowsQuery |
---|
executeWithCallback |
Methods inherited from interface com.netflix.astyanax.Execution |
---|
execute, executeAsync |
Field Detail |
---|
protected org.apache.cassandra.thrift.SlicePredicate predicate
Constructor Detail |
---|
public AbstractThriftAllRowsQueryImpl(ColumnFamily<K,C> columnFamily)
Method Detail |
---|
public AllRowsQuery<K,C> setExceptionCallback(ExceptionCallback cb)
AllRowsQuery
setExceptionCallback
in interface AllRowsQuery<K,C>
protected ExceptionCallback getExceptionCallback()
public AllRowsQuery<K,C> withColumnSlice(C... columns)
AllRowsQuery
withColumnSlice
in interface AllRowsQuery<K,C>
public AllRowsQuery<K,C> withColumnSlice(Collection<C> columns)
AllRowsQuery
withColumnSlice
in interface AllRowsQuery<K,C>
public AllRowsQuery<K,C> withColumnRange(C startColumn, C endColumn, boolean reversed, int count)
AllRowsQuery
withColumnRange
in interface AllRowsQuery<K,C>
startColumn
- First column in the rangeendColumn
- Last column in the rangereversed
- True if the order should be reversed. Note that for reversed,
startColumn should be greater than endColumn.count
- Maximum number of columns to return (similar to SQL LIMIT)
public AllRowsQuery<K,C> withColumnRange(ByteBuffer startColumn, ByteBuffer endColumn, boolean reversed, int count)
AllRowsQuery
withColumnRange
in interface AllRowsQuery<K,C>
public AllRowsQuery<K,C> withColumnSlice(ColumnSlice<C> slice)
AllRowsQuery
withColumnSlice
in interface AllRowsQuery<K,C>
public AllRowsQuery<K,C> withColumnRange(ByteBufferRange range)
AllRowsQuery
withColumnRange
in interface AllRowsQuery<K,C>
public AllRowsQuery<K,C> setBlockSize(int blockSize)
setBlockSize
in interface AllRowsQuery<K,C>
public AllRowsQuery<K,C> setRowLimit(int rowLimit)
AllRowsQuery
setRowLimit
in interface AllRowsQuery<K,C>
public int getBlockSize()
public AllRowsQuery<K,C> setRepeatLastToken(boolean repeatLastToken)
AllRowsQuery
setRepeatLastToken
in interface AllRowsQuery<K,C>
public boolean getRepeatLastToken()
protected abstract List<org.apache.cassandra.thrift.KeySlice> getNextBlock(org.apache.cassandra.thrift.KeyRange range)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |