org.apache.lens.server.query.collect

Class ThreadSafeEstimatedQueryCollection

java.lang.Object

org.apache.lens.server.query.collect.ThreadSafeEstimatedQueryCollection

All Implemented Interfaces:

EstimatedImmutableQueryCollection, ImmutableQueryCollection, EstimatedQueryCollection, MutableQueryCollection

public class ThreadSafeEstimatedQueryCollection
extends Object
implements EstimatedQueryCollection

Makes an implementation of EstimatedQueryCollection interface thread safe by wrapping all behaviours in synchronized method.

Constructor Summary

Constructors

Constructor and Description
ThreadSafeEstimatedQueryCollection(EstimatedQueryCollection estimatedQueries)

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

ThreadSafeEstimatedQueryCollection

public ThreadSafeEstimatedQueryCollection(@NonNull
                                  EstimatedQueryCollection estimatedQueries)

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

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

add

public boolean add(QueryContext query)

Description copied from interface: MutableQueryCollection

add the given query to existing queries

Specified by:

add in interface MutableQueryCollection

Returns:

addAll

public boolean addAll(Set<QueryContext> queries)

Specified by:

addAll in interface MutableQueryCollection

Returns:

remove

public boolean remove(QueryContext query)

Description copied from interface: MutableQueryCollection

removes given query from existing queries

Specified by:

remove in interface MutableQueryCollection

Returns:

removeAll

public boolean removeAll(Set<QueryContext> queries)

Specified by:

removeAll in interface MutableQueryCollection