Package | Description |
---|---|
org.apache.lens.server.api.query.collect | |
org.apache.lens.server.query | |
org.apache.lens.server.query.collect |
Modifier and Type | Method and Description |
---|---|
Set<QueryContext> |
WaitingQueriesSelectionPolicy.selectQueries(FinishedLensQuery finishedQuery,
EstimatedImmutableQueryCollection waitingQueries)
Selects a subset of waiting queries eligible to move out of waiting state, based on logic of this selection policy.
|
Set<QueryContext> |
DriverSpecificWaitingQueriesSelectionPolicy.selectQueries(FinishedLensQuery finishedQuery,
EstimatedImmutableQueryCollection waitingQueries) |
Modifier and Type | Method and Description |
---|---|
FinishedLensQuery |
LensServerDAO.getQuery(String handle)
Fetch Finished query from Database.
|
Modifier and Type | Method and Description |
---|---|
void |
LensServerDAO.insertFinishedQuery(FinishedLensQuery query)
DAO method to insert a new Finished query into Table.
|
Constructor and Description |
---|
LensPersistentResult(FinishedLensQuery query,
org.apache.hadoop.conf.Configuration conf) |
Modifier and Type | Method and Description |
---|---|
Set<QueryContext> |
WaitingQueriesSelector.selectQueries(FinishedLensQuery finishedQuery,
EstimatedImmutableQueryCollection waitingQueries) |
Set<QueryContext> |
UserSpecificWaitingQueriesSelectionPolicy.selectQueries(FinishedLensQuery finishedQuery,
EstimatedImmutableQueryCollection waitingQueries) |
Set<QueryContext> |
UnioningWaitingQueriesSelector.selectQueries(FinishedLensQuery finishedQuery,
EstimatedImmutableQueryCollection waitingQueries)
Selects queries eligible by all
WaitingQueriesSelectionPolicy to move them out of waiting state. |
Copyright © 2014–2016 Apache Software Foundation. All rights reserved.