org.apache.lens.server.api.query.constraint

Class MaxConcurrentDriverQueriesConstraint

java.lang.Object

org.apache.lens.server.api.query.constraint.MaxConcurrentDriverQueriesConstraint

All Implemented Interfaces:

QueryLaunchingConstraint

public class MaxConcurrentDriverQueriesConstraint
extends Object
implements QueryLaunchingConstraint

Constructor Summary

Constructors

Constructor and Description
MaxConcurrentDriverQueriesConstraint(int maxConcurrentQueries, Map<String,Integer> maxConcurrentQueriesPerQueue, Map<Priority,Integer> maxConcurrentQueriesPerPriority, Integer defaultMaxConcurrentQueriesPerQueueLimit, int maxConcurrentLaunches)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	allowsLaunchOf(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries) Returns whether this constraint allows candidate query to be launched.

Methods inherited from class java.lang.Object

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

Constructor Detail

MaxConcurrentDriverQueriesConstraint

@ConstructorProperties(value={"maxConcurrentQueries","maxConcurrentQueriesPerQueue","maxConcurrentQueriesPerPriority","defaultMaxConcurrentQueriesPerQueueLimit","maxConcurrentLaunches"})
@Generated(value="lombok")
public MaxConcurrentDriverQueriesConstraint(int maxConcurrentQueries,
                                                                              Map<String,Integer> maxConcurrentQueriesPerQueue,
                                                                              Map<Priority,Integer> maxConcurrentQueriesPerPriority,
                                                                              Integer defaultMaxConcurrentQueriesPerQueueLimit,
                                                                              int maxConcurrentLaunches)

Method Detail

allowsLaunchOf

public boolean allowsLaunchOf(QueryContext candidateQuery,
                     EstimatedImmutableQueryCollection launchedQueries)

Description copied from interface: QueryLaunchingConstraint

Returns whether this constraint allows candidate query to be launched.

Specified by:

allowsLaunchOf in interface QueryLaunchingConstraint

Parameters:

candidateQuery - The query which is the next candidate to be launched.

launchedQueries - Current launched queries

Returns: