org.apache.lens.server.query.collect

Class DefaultEstimatedQueryCollection

java.lang.Object

org.apache.lens.server.query.collect.DefaultEstimatedQueryCollection

All Implemented Interfaces:

EstimatedImmutableQueryCollection, ImmutableQueryCollection, EstimatedQueryCollection, MutableQueryCollection

public class DefaultEstimatedQueryCollection
extends Object
implements EstimatedQueryCollection

Implementation which creates multiple in memory views of queries existing in lens system and owns responsibility of keeping all the views consistent with each other.

See Also:

EstimatedQueryCollection

Constructor Summary

Constructors

Constructor and Description
DefaultEstimatedQueryCollection(QueryCollection queries)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(QueryContext query) add the given query to existing queries
boolean	addAll(Set<QueryContext> queries)
Set<QueryContext>	getQueries()
Set<QueryContext>	getQueries(LensDriver driver)
Set<QueryContext>	getQueries(String user)
int	getQueriesCount()
int	getQueriesCount(LensDriver driver)
Integer	getQueryIndex(QueryContext query)
QueryCost	getTotalQueryCost(String user) Get total query cost of all queries of given user
boolean	remove(QueryContext query) removes given query from existing queries
boolean	removeAll(Set<QueryContext> queries)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEstimatedQueryCollection

public DefaultEstimatedQueryCollection(@NonNull
                               QueryCollection queries)

Method Detail

getQueries

public Set<QueryContext> getQueries(LensDriver driver)

Specified by:

getQueries in interface EstimatedImmutableQueryCollection

Parameters:

driver - Driver for which queries have to be returned.

Returns:

A set of queries for which given driver is the selected driver. A new set is created and returned. Elements in the set are not cloned or copied. Multiple iterations over returned set are guaranteed to be in same order. If there are no queries, then an empty set is returned. null is never returned.

getQueriesCount

public int getQueriesCount(LensDriver driver)

Specified by:

getQueriesCount in interface EstimatedImmutableQueryCollection

Parameters:

driver - Driver for which count of queries have to be returned.

Returns:

count of queries of given driver.

getTotalQueryCost

public QueryCost getTotalQueryCost(String user)

Description copied from interface: EstimatedImmutableQueryCollection

Get total query cost of all queries of given user

Specified by:

getTotalQueryCost in interface EstimatedImmutableQueryCollection

Returns:

total query cost of all queries of user

add

public boolean add(QueryContext query)

Description copied from interface: MutableQueryCollection

add the given query to existing queries

Specified by:

add in interface MutableQueryCollection

Parameters:

query -

Returns:

Throws:

IllegalStateException - if selected driver or selected driver query cost is not set for the query

addAll

public boolean addAll(Set<QueryContext> queries)

Specified by:

addAll in interface MutableQueryCollection

Parameters:

queries -

Returns:

Throws:

IllegalStateException - if selected driver or selected driver query cost is not set for any of the queries

remove

public boolean remove(QueryContext query)

Description copied from interface: MutableQueryCollection

removes given query from existing queries

Specified by:

remove in interface MutableQueryCollection

Parameters:

query -

Returns:

removeAll

public boolean removeAll(Set<QueryContext> queries)

Specified by:

removeAll in interface MutableQueryCollection

getQueries

public Set<QueryContext> getQueries()

Specified by:

getQueries in interface ImmutableQueryCollection

Returns:

A new set copied from this collection of queries. Elements in the set are not cloned or copied. Multiple iterations over returned set are guaranteed to be in same order. If there are no queries, then an empty set is returned. null is never returned.

getQueries

public Set<QueryContext> getQueries(String user)

Specified by:

getQueries in interface ImmutableQueryCollection

Parameters:

user - User for whom queries have to be returned.

Returns:

A set of queries submitted by the given user. A new set is created and returned. Elements in the set are not cloned or copied. Multiple iterations over returned set are guaranteed to be in same order. If there are no queries, then an empty set is returned. null is never returned.

getQueriesCount

public int getQueriesCount()

Specified by:

getQueriesCount in interface ImmutableQueryCollection

Returns:

Count of existing queries

getQueryIndex

public Integer getQueryIndex(QueryContext query)

Specified by:

getQueryIndex in interface ImmutableQueryCollection

Returns:

Index of a query within collection