public class PartitionWSQueryImpl<K,T extends Persistent> extends QueryWSBase<K,T> implements PartitionQuery<K,T>
PartitionQuery
.Modifier and Type | Field and Description |
---|---|
protected Query<K,T> |
baseQuery
Base query
|
protected String[] |
locations
The places where this query will be executed
|
dataStore, endKey, endTime, fields, filter, isCompiled, limit, localFilterEnabled, queryString, startKey, startTime
Constructor and Description |
---|
PartitionWSQueryImpl()
Constructor
|
PartitionWSQueryImpl(Query<K,T> baseQuery,
K startKey,
K endKey,
String... locations)
Constructor
|
PartitionWSQueryImpl(Query<K,T> baseQuery,
String... locations)
Constructor
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
Query<K,T> |
getBaseQuery()
Gets the base query to be used
|
DataStore<K,T> |
getDataStore()
Returns the DataStore, that this Query is associated with.
|
long |
getEndTime() |
String[] |
getFields() |
Filter<K,T> |
getFilter() |
long |
getLimit()
Returns the maximum number of results
|
String[] |
getLocations()
Returns the locations on which this partial query will run locally.
|
long |
getStartTime() |
long |
getTimestamp() |
boolean |
isLocalFilterEnabled() |
void |
setEndTime(long endTime) |
void |
setFields(String... fields) |
void |
setFilter(Filter<K,T> filter) |
void |
setLimit(long limit)
Sets the maximum number of results to return.
|
void |
setLocalFilterEnabled(boolean enable)
Set whether the local filter is enabled.
|
void |
setStartTime(long startTime) |
void |
setTimeRange(long startTime,
long endTime) |
void |
setTimestamp(long timestamp) |
execute, getConf, getEndKey, getKey, getStartKey, hashCode, setConf, setDataStore, setEndKey, setKey, setKeyRange, setStartKey, toString
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
execute, getEndKey, getKey, getStartKey, setDataStore, setEndKey, setKey, setKeyRange, setStartKey
protected Query<K,T extends Persistent> baseQuery
protected String[] locations
public PartitionWSQueryImpl()
public PartitionWSQueryImpl(Query<K,T> baseQuery, String... locations)
public String[] getLocations()
PartitionQuery
getLocations
in interface PartitionQuery<K,T extends Persistent>
public String[] getFields()
getFields
in interface Query<K,T extends Persistent>
getFields
in class QueryWSBase<K,T extends Persistent>
public DataStore<K,T> getDataStore()
Query
getDataStore
in interface Query<K,T extends Persistent>
getDataStore
in class QueryWSBase<K,T extends Persistent>
public long getTimestamp()
getTimestamp
in interface Query<K,T extends Persistent>
getTimestamp
in class QueryWSBase<K,T extends Persistent>
public long getStartTime()
getStartTime
in interface Query<K,T extends Persistent>
getStartTime
in class QueryWSBase<K,T extends Persistent>
public long getEndTime()
getEndTime
in interface Query<K,T extends Persistent>
getEndTime
in class QueryWSBase<K,T extends Persistent>
public long getLimit()
Query
getLimit
in interface Query<K,T extends Persistent>
getLimit
in class QueryWSBase<K,T extends Persistent>
public void setFields(String... fields)
setFields
in interface Query<K,T extends Persistent>
setFields
in class QueryWSBase<K,T extends Persistent>
public void setTimestamp(long timestamp)
setTimestamp
in interface Query<K,T extends Persistent>
setTimestamp
in class QueryWSBase<K,T extends Persistent>
public void setStartTime(long startTime)
setStartTime
in interface Query<K,T extends Persistent>
setStartTime
in class QueryWSBase<K,T extends Persistent>
public void setEndTime(long endTime)
setEndTime
in interface Query<K,T extends Persistent>
setEndTime
in class QueryWSBase<K,T extends Persistent>
public void setTimeRange(long startTime, long endTime)
setTimeRange
in interface Query<K,T extends Persistent>
setTimeRange
in class QueryWSBase<K,T extends Persistent>
public void setLimit(long limit)
Query
setLimit
in interface Query<K,T extends Persistent>
setLimit
in class QueryWSBase<K,T extends Persistent>
public Filter<K,T> getFilter()
getFilter
in interface Query<K,T extends Persistent>
null
if none.public void setFilter(Filter<K,T> filter)
setFilter
in interface Query<K,T extends Persistent>
public boolean isLocalFilterEnabled()
isLocalFilterEnabled
in interface Query<K,T extends Persistent>
Query.setLocalFilterEnabled(boolean)
.public void setLocalFilterEnabled(boolean enable)
Query
setLocalFilterEnabled
in interface Query<K,T extends Persistent>
public boolean equals(Object obj)
equals
in class QueryWSBase<K,T extends Persistent>
Copyright © 2010-2015 The Apache Software Foundation. All Rights Reserved.