org.apache.gora.query.ws.impl

Class PartitionWSQueryImpl<K,T extends Persistent>

java.lang.Object

org.apache.gora.query.ws.impl.QueryWSBase<K,T>

org.apache.gora.query.ws.impl.PartitionWSQueryImpl<K,T>

All Implemented Interfaces:

PartitionQuery<K,T>, Query<K,T>

public class PartitionWSQueryImpl<K,T extends Persistent>
extends QueryWSBase<K,T>
implements PartitionQuery<K,T>

Webservices implementation for PartitionQuery.

Field Summary

Fields

Modifier and Type	Field and Description
protected Query<K,T>	baseQuery Base query
protected String[]	locations The places where this query will be executed

Fields inherited from class org.apache.gora.query.ws.impl.QueryWSBase

dataStore, endKey, endTime, fields, filter, isCompiled, limit, localFilterEnabled, queryString, startKey, startTime

Constructor Summary

Constructors

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

Method Summary

Methods

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)

Methods inherited from class org.apache.gora.query.ws.impl.QueryWSBase

execute, getConf, getEndKey, getKey, getStartKey, hashCode, setConf, setDataStore, setEndKey, setKey, setKeyRange, setStartKey, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.gora.query.Query

execute, getEndKey, getKey, getStartKey, setDataStore, setEndKey, setKey, setKeyRange, setStartKey

Field Detail

baseQuery

protected Query<K,T extends Persistent> baseQuery

Base query

locations

protected String[] locations

The places where this query will be executed

Constructor Detail

PartitionWSQueryImpl

public PartitionWSQueryImpl()

Constructor

PartitionWSQueryImpl

public PartitionWSQueryImpl(Query<K,T> baseQuery,
                    String... locations)

Constructor

PartitionWSQueryImpl

public PartitionWSQueryImpl(Query<K,T> baseQuery,
                    K startKey,
                    K endKey,
                    String... locations)

Constructor

Method Detail

getLocations

public String[] getLocations()

Description copied from interface: PartitionQuery

Returns the locations on which this partial query will run locally.

Specified by:

getLocations in interface PartitionQuery<K,T extends Persistent>

Returns:

the addresses of machines

getBaseQuery

public Query<K,T> getBaseQuery()

Gets the base query to be used

Returns:

getFields

public String[] getFields()

Specified by:

getFields in interface Query<K,T extends Persistent>

Overrides:

getFields in class QueryWSBase<K,T extends Persistent>

getDataStore

public DataStore<K,T> getDataStore()

Description copied from interface: Query

Returns the DataStore, that this Query is associated with.

Specified by:

getDataStore in interface Query<K,T extends Persistent>

Overrides:

getDataStore in class QueryWSBase<K,T extends Persistent>

Returns:

the DataStore of the Query

getTimestamp

public long getTimestamp()

Specified by:

getTimestamp in interface Query<K,T extends Persistent>

Overrides:

getTimestamp in class QueryWSBase<K,T extends Persistent>

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface Query<K,T extends Persistent>

Overrides:

getStartTime in class QueryWSBase<K,T extends Persistent>

getEndTime

public long getEndTime()

Specified by:

getEndTime in interface Query<K,T extends Persistent>

Overrides:

getEndTime in class QueryWSBase<K,T extends Persistent>

getLimit

public long getLimit()

Description copied from interface: Query

Returns the maximum number of results

Specified by:

getLimit in interface Query<K,T extends Persistent>

Overrides:

getLimit in class QueryWSBase<K,T extends Persistent>

Returns:

the limit if it is set, otherwise a negative number

setFields

public void setFields(String... fields)

Specified by:

setFields in interface Query<K,T extends Persistent>

Overrides:

setFields in class QueryWSBase<K,T extends Persistent>

setTimestamp

public void setTimestamp(long timestamp)

Specified by:

setTimestamp in interface Query<K,T extends Persistent>

Overrides:

setTimestamp in class QueryWSBase<K,T extends Persistent>

setStartTime

public void setStartTime(long startTime)

Specified by:

setStartTime in interface Query<K,T extends Persistent>

Overrides:

setStartTime in class QueryWSBase<K,T extends Persistent>

setEndTime

public void setEndTime(long endTime)

Specified by:

setEndTime in interface Query<K,T extends Persistent>

Overrides:

setEndTime in class QueryWSBase<K,T extends Persistent>

setTimeRange

public void setTimeRange(long startTime,
                long endTime)

Specified by:

setTimeRange in interface Query<K,T extends Persistent>

Overrides:

setTimeRange in class QueryWSBase<K,T extends Persistent>

setLimit

public void setLimit(long limit)

Description copied from interface: Query

Sets the maximum number of results to return.

Specified by:

setLimit in interface Query<K,T extends Persistent>

Overrides:

setLimit in class QueryWSBase<K,T extends Persistent>

getFilter

public Filter<K,T> getFilter()

Specified by:

getFilter in interface Query<K,T extends Persistent>

Returns:

The filter on this query, or null if none.

setFilter

public void setFilter(Filter<K,T> filter)

Specified by:

setFilter in interface Query<K,T extends Persistent>

isLocalFilterEnabled

public boolean isLocalFilterEnabled()

Specified by:

isLocalFilterEnabled in interface Query<K,T extends Persistent>

Returns:

Whether the local filter is enabled. See Query.setLocalFilterEnabled(boolean).

setLocalFilterEnabled

public void setLocalFilterEnabled(boolean enable)

Description copied from interface: Query

Set whether the local filter is enabled. This is usually called by data store implementations that install the filter remotely (for efficiency reasons) and therefore disable the local filter.

Specified by:

setLocalFilterEnabled in interface Query<K,T extends Persistent>

equals

public boolean equals(Object obj)

Overrides:

equals in class QueryWSBase<K,T extends Persistent>