| 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 |
|---|---|
List<FinishedLensQuery> |
LensServerDAO.findFinishedQueryDetails(List<QueryStatus.Status> states,
String user,
String driverName,
String queryName,
long fromDate,
long toDate)
Find finished queries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LensServerDAO.getFailedAttempts(FinishedLensQuery query) |
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–2018 Apache Software Foundation. All rights reserved.