public interface Query<K,T extends Persistent>
DataStore.newQuery()
.Modifier and Type | Method and Description |
---|---|
Result<K,T> |
execute()
Executes the Query on the DataStore and returns the results.
|
DataStore<K,T> |
getDataStore()
Returns the DataStore, that this Query is associated with.
|
K |
getEndKey() |
long |
getEndTime() |
String[] |
getFields() |
Filter<K,T> |
getFilter() |
K |
getKey() |
long |
getLimit()
Returns the maximum number of results
|
K |
getStartKey() |
long |
getStartTime() |
long |
getTimestamp() |
boolean |
isLocalFilterEnabled() |
void |
setDataStore(DataStore<K,T> dataStore)
Sets the dataStore of this query.
|
void |
setEndKey(K endKey) |
void |
setEndTime(long endTime) |
void |
setFields(String... fieldNames) |
void |
setFilter(Filter<K,T> filter) |
void |
setKey(K key) |
void |
setKeyRange(K startKey,
K endKey)
Set the range of keys over which the query will execute.
|
void |
setLimit(long limit)
Sets the maximum number of results to return.
|
void |
setLocalFilterEnabled(boolean enable)
Set whether the local filter is enabled.
|
void |
setStartKey(K startKey) |
void |
setStartTime(long startTime) |
void |
setTimeRange(long startTime,
long endTime) |
void |
setTimestamp(long timestamp) |
void setDataStore(DataStore<K,T> dataStore)
dataStore
- the dataStore of the queryDataStore<K,T> getDataStore()
Result<K,T> execute()
Result
for the query.void setFields(String... fieldNames)
String[] getFields()
void setLocalFilterEnabled(boolean enable)
enable
- boolean isLocalFilterEnabled()
setLocalFilterEnabled(boolean)
.void setKey(K key)
void setStartKey(K startKey)
startKey
- an inclusive start keyvoid setEndKey(K endKey)
endKey
- an inclusive end keyvoid setKeyRange(K startKey, K endKey)
startKey
- an inclusive start keyendKey
- an inclusive end keyK getKey()
K getStartKey()
K getEndKey()
void setTimestamp(long timestamp)
void setStartTime(long startTime)
void setEndTime(long endTime)
void setTimeRange(long startTime, long endTime)
long getTimestamp()
long getStartTime()
long getEndTime()
void setLimit(long limit)
long getLimit()
Copyright © 2010-2015 The Apache Software Foundation. All Rights Reserved.