org.apache.lens.server.query.collect

Class ThreadSafeQueryCollection

java.lang.Object

org.apache.lens.server.query.collect.ThreadSafeQueryCollection

All Implemented Interfaces:

ImmutableQueryCollection, MutableQueryCollection, QueryCollection

public class ThreadSafeQueryCollection
extends Object
implements QueryCollection

Makes a QueryCollection implementation thread safe by synchronizing all behaviours.

See Also:

QueryCollection

Constructor Summary

Constructors

Constructor and Description
ThreadSafeQueryCollection(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(String user)
int	getQueriesCount()
Integer	getQueryIndex(QueryContext query)
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

ThreadSafeQueryCollection

public ThreadSafeQueryCollection(@NonNull
                         QueryCollection queries)

Method Detail

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

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