org.apache.lens.server.query.collect

Class UnioningWaitingQueriesSelector

java.lang.Object

org.apache.lens.server.query.collect.UnioningWaitingQueriesSelector

All Implemented Interfaces:

WaitingQueriesSelector

public class UnioningWaitingQueriesSelector
extends Object
implements WaitingQueriesSelector

Selects queries eligible by all WaitingQueriesSelectionPolicy to move them out of waiting state.

Constructor Summary

Constructors

Constructor and Description
UnioningWaitingQueriesSelector(com.google.common.collect.ImmutableSet<WaitingQueriesSelectionPolicy> selectionPolicies)

Method Summary

Modifier and Type	Method and Description
Set<QueryContext>	selectQueries(FinishedLensQuery finishedQuery, EstimatedImmutableQueryCollection waitingQueries) Selects queries eligible by all WaitingQueriesSelectionPolicy to move them out of waiting state.

Methods inherited from class java.lang.Object

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

Constructor Detail

UnioningWaitingQueriesSelector

public UnioningWaitingQueriesSelector(@NonNull
                                      com.google.common.collect.ImmutableSet<WaitingQueriesSelectionPolicy> selectionPolicies)

Method Detail

selectQueries

public Set<QueryContext> selectQueries(FinishedLensQuery finishedQuery,
                                       EstimatedImmutableQueryCollection waitingQueries)

Selects queries eligible by all WaitingQueriesSelectionPolicy to move them out of waiting state.

Specified by:

selectQueries in interface WaitingQueriesSelector

Parameters:

finishedQuery -

waitingQueries -

Returns:

See Also:

WaitingQueriesSelector.selectQueries(FinishedLensQuery, EstimatedImmutableQueryCollection)