com.basho.riak.client.api.commands.indexes

Class SecondaryIndexQuery<T,S,U>

java.lang.Object

com.basho.riak.client.api.RiakCommand<S,U>

com.basho.riak.client.api.commands.indexes.SecondaryIndexQuery<T,S,U>

Type Parameters:

S - the type being used for the query.

Direct Known Subclasses:

BigIntIndexQuery, BinIndexQuery, IntIndexQuery, RawIndexQuery

public abstract class SecondaryIndexQuery<T,S,U>
extends RiakCommand<S,U>

A Secondary Index Query.

Serves as a base class for all 2i queries.

Since:

2.0

Author:

Brian Roach

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	SecondaryIndexQuery.IndexConverter<T>
static class	SecondaryIndexQuery.Init<S,T extends SecondaryIndexQuery.Init<S,T>>
static class	SecondaryIndexQuery.Response<T> Base class for all 2i responses.
static class	SecondaryIndexQuery.Type

Field Summary

Fields

Modifier and Type	Field and Description
protected BinaryValue	continuation
protected T	end
protected String	indexName
protected T	match
protected Integer	maxResults
protected Namespace	namespace
protected boolean	paginationSort
protected boolean	returnTerms
protected T	start
protected String	termFilter
protected Integer	timeout

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SecondaryIndexQuery(SecondaryIndexQuery.Init<T,?> builder)

Method Summary

Methods

Modifier and Type	Method and Description
protected SecondaryIndexQueryOperation.Query	createCoreQuery()
protected RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query>	executeCoreAsync(RiakCluster cluster)
BinaryValue	getContinuation() Get the continuation supplied for this query.
protected abstract SecondaryIndexQuery.IndexConverter<T>	getConverter()
String	getIndexName() Get the full index name for this query.
T	getMatchValue() Get the match value supplied for this query.
Integer	getMaxResults() Get the max number of results for this query.
Namespace	getNamespace() Get the location for this query.
boolean	getPaginationSort() Get the pagination sort setting.
T	getRangeEnd() Get the range end value for this query.
T	getRangeStart() Get the range start value for this query.
boolean	getReturnKeyAndIndex() Get whether this query will return both index keys and object keys.
String	getTermFilter() Get the regex term filter for this query.
Integer	getTimeout() Get the timeout value for this query.

Methods inherited from class com.basho.riak.client.api.RiakCommand

execute, executeAsync

Methods inherited from class java.lang.Object

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

Field Detail

namespace

protected final Namespace namespace

indexName

protected final String indexName

continuation

protected final BinaryValue continuation

match

protected final T match

start

protected final T start

end

protected final T end

maxResults

protected final Integer maxResults

returnTerms

protected final boolean returnTerms

paginationSort

protected final boolean paginationSort

termFilter

protected final String termFilter

timeout

protected Integer timeout

Constructor Detail

SecondaryIndexQuery

protected SecondaryIndexQuery(SecondaryIndexQuery.Init<T,?> builder)

Method Detail

getConverter

protected abstract SecondaryIndexQuery.IndexConverter<T> getConverter()

getNamespace

public Namespace getNamespace()

Get the location for this query.

Returns:

the location encompassing a bucket and bucket type.

getIndexName

public String getIndexName()

Get the full index name for this query.

Returns:

the index name including Riak suffix.

getMatchValue

public T getMatchValue()

Get the match value supplied for this query.

Returns:

the single index key to match, or null if not present

getRangeStart

public T getRangeStart()

Get the range start value for this query.

Returns:

the range start, or null if not present.

getRangeEnd

public T getRangeEnd()

Get the range end value for this query.

Returns:

the range end value, or null if not present

getMaxResults

public Integer getMaxResults()

Get the max number of results for this query.

Returns:

the max number of results, or null if not present.

getReturnKeyAndIndex

public boolean getReturnKeyAndIndex()

Get whether this query will return both index keys and object keys.

Returns:

true if specified, false otherwise.

getPaginationSort

public boolean getPaginationSort()

Get the pagination sort setting.

Returns:

true if set, false otherwise.

getTermFilter

public String getTermFilter()

Get the regex term filter for this query.

Returns:

the filter, or null if not set.

getContinuation

public BinaryValue getContinuation()

Get the continuation supplied for this query.

Returns:

the continuation, or null if not set.

getTimeout

public Integer getTimeout()

Get the timeout value for this query.

Returns:

the timeout value, or null if not set.

createCoreQuery

protected final SecondaryIndexQueryOperation.Query createCoreQuery()

executeCoreAsync

protected RiakFuture<SecondaryIndexQueryOperation.Response,SecondaryIndexQueryOperation.Query> executeCoreAsync(RiakCluster cluster)