T
- public class FetchIndex<T> extends Object implements RiakOperation<List<String>>
Modifier and Type | Field and Description |
---|---|
protected String |
continuation |
protected T |
from |
protected RiakIndex<T> |
index |
protected Integer |
maxResults |
protected boolean |
returnTerms |
protected T |
to |
protected T |
value |
Constructor and Description |
---|
FetchIndex(RawClient client,
String bucket,
RiakIndex<T> index,
Retrier retrier) |
Modifier and Type | Method and Description |
---|---|
List<String> |
execute() |
StreamingOperation<IndexEntry> |
executeStreaming()
Performs an index query as a streaming operation from Riak
Note that you must call
StreamingOperation.cancel() on the returned
StreamingOperation if you do not iterate through the entire result set. |
FetchIndex<T> |
from(T from) |
FetchIndex<T> |
maxResults(int maxResults)
Pagination support for 2i queries.
|
FetchIndex<T> |
returnKeyAndIndexValue(boolean returnBoth)
Return both the object keys and the index values
* This is only available in v1.4+ of Riak and only via streaming
|
FetchIndex<T> |
to(T to) |
FetchIndex<T> |
withContinuation(String continuation)
Sets the continuation received with a previous call
* * This is only available in v1.4+ of Riak and only via streaming
|
FetchIndex<T> |
withValue(T value) |
protected T value
protected T from
protected T to
protected boolean returnTerms
protected Integer maxResults
protected String continuation
public List<String> execute() throws RiakException
execute
in interface RiakOperation<List<String>>
RiakException
public StreamingOperation<IndexEntry> executeStreaming() throws RiakException
StreamingOperation.cancel()
on the returned
StreamingOperation if you do not iterate through the entire result set.
Note this is only available using Riak 1.4RiakException
public FetchIndex<T> withValue(T value)
public FetchIndex<T> from(T from)
public FetchIndex<T> to(T to)
public FetchIndex<T> maxResults(int maxResults)
maxResults
entries
starting at the lower range or the continuation returned from a previous query
This is only available in v1.4+ of Riak and only via streamingmaxResults
- executeStreaming()
public FetchIndex<T> returnKeyAndIndexValue(boolean returnBoth)
returnBoth
- executeStreaming()
public FetchIndex<T> withContinuation(String continuation)
continuation
- executeStreaming()
,
StreamingOperation.getContinuation()
Copyright © 2013. All Rights Reserved.