Uses of Class
org.apache.lens.server.api.query.QueryContext

Packages that use QueryContext

Package	Description
org.apache.lens.driver.es
org.apache.lens.driver.hive
org.apache.lens.driver.jdbc
org.apache.lens.lib.query
org.apache.lens.server.api.driver
org.apache.lens.server.api.query
org.apache.lens.server.api.query.collect
org.apache.lens.server.api.query.constraint
org.apache.lens.server.query
org.apache.lens.server.query.collect
org.apache.lens.server.query.constraint

Uses of QueryContext in org.apache.lens.driver.es

Methods in org.apache.lens.driver.es with parameters of type QueryContext

Modifier and Type	Method and Description
LensResultSet	ESDriver.execute(QueryContext context) Elastic search does not have a concept of prepared query.
void	ESDriver.executeAsync(QueryContext context)
LensResultSet	ESDriver.fetchResultSet(QueryContext context)
void	ESDriver.updateStatus(QueryContext context)

Uses of QueryContext in org.apache.lens.driver.hive

Methods in org.apache.lens.driver.hive with parameters of type QueryContext

Modifier and Type	Method and Description
LensResultSet	HiveDriver.execute(QueryContext ctx)
void	HiveDriver.executeAsync(QueryContext ctx)
LensResultSet	HiveDriver.fetchResultSet(QueryContext ctx)
void	HiveDriver.updateStatus(QueryContext context)

Uses of QueryContext in org.apache.lens.driver.jdbc

Methods in org.apache.lens.driver.jdbc with parameters of type QueryContext

Modifier and Type	Method and Description
LensResultSet	JDBCDriver.execute(QueryContext context) Blocking execute of the query.
void	JDBCDriver.executeAsync(QueryContext context) Asynchronously execute the query.
LensResultSet	JDBCDriver.fetchResultSet(QueryContext context) Fetch the results of the query, specified by the handle.
void	JDBCDriver.updateStatus(QueryContext context) Get status of the query, specified by the handle.

Uses of QueryContext in org.apache.lens.lib.query

Methods in org.apache.lens.lib.query with parameters of type QueryContext

Modifier and Type	Method and Description
void	WrappedFileFormatter.init(QueryContext ctx, LensResultSetMetadata metadata)
void	FileSerdeFormatter.init(QueryContext ctx, LensResultSetMetadata metadata)
void	FilePersistentFormatter.init(QueryContext ctx, LensResultSetMetadata metadata)
void	AbstractOutputFormatter.init(QueryContext ctx, LensResultSetMetadata metadata)
void	AbstractFileFormatter.init(QueryContext ctx, LensResultSetMetadata metadata)

Uses of QueryContext in org.apache.lens.server.api.driver

Methods in org.apache.lens.server.api.driver with parameters of type QueryContext

Modifier and Type	Method and Description
LensResultSet	LensDriver.execute(QueryContext context) Blocking execute of the query
void	LensDriver.executeAsync(QueryContext context) Asynchronously execute the query.
LensResultSet	LensDriver.fetchResultSet(QueryContext context) Fetch the results of the query, specified by the handle.
void	LensDriver.updateStatus(QueryContext context) Update driver query status in the context object.

Uses of QueryContext in org.apache.lens.server.api.query

Methods in org.apache.lens.server.api.query that return QueryContext

Modifier and Type	Method and Description
static QueryContext	QueryContext.createContextWithSingleDriver(String query, String user, LensConf qconf, org.apache.hadoop.conf.Configuration conf, LensDriver driver, String lensSessionPublicId, boolean mergeDriverConf) Utility create method to create context with single driver.
QueryContext	QueryEnded.getQueryContext()
QueryContext	FinishedLensQuery.toQueryContext(org.apache.hadoop.conf.Configuration conf, Collection<LensDriver> drivers)

Methods in org.apache.lens.server.api.query with parameters of type QueryContext

Modifier and Type	Method and Description
void	QueryOutputFormatter.init(QueryContext ctx, LensResultSetMetadata metadata) Initialize the formatter.

Constructors in org.apache.lens.server.api.query with parameters of type QueryContext

Constructor and Description
FinishedLensQuery(QueryContext ctx) Instantiates a new finished lens query.
QueryCancelled(QueryContext ctx, long eventTime, QueryStatus.Status prev, QueryStatus.Status current, QueryHandle handle, String user, String cause) Instantiates a new query cancelled.
QueryCancelled(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause)
QueryClosed(QueryContext ctx, long eventTime, QueryStatus.Status prev, QueryStatus.Status current, QueryHandle handle, String user, String cause) Instantiates a new query closed.
QueryClosed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause)
QueryEnded(QueryContext ctx, long eventTime, QueryStatus.Status prev, QueryStatus.Status current, QueryHandle handle, String user, String cause) Instantiates a new query ended.
QueryFailed(QueryContext ctx, long eventTime, QueryStatus.Status prev, QueryStatus.Status current, QueryHandle handle, String user, String cause) Instantiates a new query failed.
QueryFailed(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState, String cause)
QuerySuccess(QueryContext ctx, long eventTime, QueryStatus.Status prev, QueryStatus.Status current, QueryHandle handle) Instantiates a new query success.
QuerySuccess(QueryContext ctx, QueryStatus.Status prevState, QueryStatus.Status currState)

Uses of QueryContext in org.apache.lens.server.api.query.collect

Methods in org.apache.lens.server.api.query.collect that return types with arguments of type QueryContext

Modifier and Type	Method and Description
Set<QueryContext>	ImmutableQueryCollection.getQueries()
Set<QueryContext>	EstimatedImmutableQueryCollection.getQueries(LensDriver driver)
Set<QueryContext>	ImmutableQueryCollection.getQueries(String user)
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)

Methods in org.apache.lens.server.api.query.collect with parameters of type QueryContext

Modifier and Type	Method and Description
Integer	ImmutableQueryCollection.getQueryIndex(QueryContext query)

Uses of QueryContext in org.apache.lens.server.api.query.constraint

Methods in org.apache.lens.server.api.query.constraint with parameters of type QueryContext

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

Uses of QueryContext in org.apache.lens.server.query

Methods in org.apache.lens.server.query that return QueryContext

Modifier and Type	Method and Description
QueryContext	QueryExecutionServiceImpl.FinishedQuery.getCtx() The ctx.

Methods in org.apache.lens.server.query with parameters of type QueryContext

Modifier and Type	Method and Description
int	QueryContextPriorityComparator.compare(QueryContext o1, QueryContext o2)

Constructors in org.apache.lens.server.query with parameters of type QueryContext

Constructor and Description
LensPersistentResult(QueryContext ctx, org.apache.hadoop.conf.Configuration conf)

Uses of QueryContext in org.apache.lens.server.query.collect

Methods in org.apache.lens.server.query.collect that return types with arguments of type QueryContext

Modifier and Type	Method and Description
Set<QueryContext>	ThreadSafeQueryCollection.getQueries()
Set<QueryContext>	ThreadSafeEstimatedQueryCollection.getQueries()
Set<QueryContext>	DefaultQueryCollection.getQueries()
Set<QueryContext>	DefaultEstimatedQueryCollection.getQueries()
Set<QueryContext>	ThreadSafeEstimatedQueryCollection.getQueries(LensDriver driver)
Set<QueryContext>	DefaultEstimatedQueryCollection.getQueries(LensDriver driver)
Set<QueryContext>	ThreadSafeQueryCollection.getQueries(String user)
Set<QueryContext>	ThreadSafeEstimatedQueryCollection.getQueries(String user)
Set<QueryContext>	DefaultQueryCollection.getQueries(String user)
Set<QueryContext>	DefaultEstimatedQueryCollection.getQueries(String user)
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.

Methods in org.apache.lens.server.query.collect with parameters of type QueryContext

Modifier and Type	Method and Description
boolean	ThreadSafeQueryCollection.add(QueryContext query)
boolean	ThreadSafeEstimatedQueryCollection.add(QueryContext query)
boolean	MutableQueryCollection.add(QueryContext query) add the given query to existing queries
boolean	DefaultQueryCollection.add(QueryContext query)
boolean	DefaultEstimatedQueryCollection.add(QueryContext query)
Integer	ThreadSafeQueryCollection.getQueryIndex(QueryContext query)
Integer	ThreadSafeEstimatedQueryCollection.getQueryIndex(QueryContext query)
Integer	DefaultQueryCollection.getQueryIndex(QueryContext query) Since the collection is a linkedHashSet, the order of queries is always maintained.
Integer	DefaultEstimatedQueryCollection.getQueryIndex(QueryContext query)
boolean	ThreadSafeQueryCollection.remove(QueryContext query)
boolean	ThreadSafeEstimatedQueryCollection.remove(QueryContext query)
boolean	MutableQueryCollection.remove(QueryContext query) removes given query from existing queries
boolean	DefaultQueryCollection.remove(QueryContext query)
boolean	DefaultEstimatedQueryCollection.remove(QueryContext query)

Method parameters in org.apache.lens.server.query.collect with type arguments of type QueryContext

Modifier and Type	Method and Description
boolean	ThreadSafeQueryCollection.addAll(Set<QueryContext> queries)
boolean	ThreadSafeEstimatedQueryCollection.addAll(Set<QueryContext> queries)
boolean	MutableQueryCollection.addAll(Set<QueryContext> queries)
boolean	DefaultQueryCollection.addAll(Set<QueryContext> queries)
boolean	DefaultEstimatedQueryCollection.addAll(Set<QueryContext> queries)
boolean	ThreadSafeQueryCollection.removeAll(Set<QueryContext> queries)
boolean	ThreadSafeEstimatedQueryCollection.removeAll(Set<QueryContext> queries)
boolean	MutableQueryCollection.removeAll(Set<QueryContext> queries)
boolean	DefaultQueryCollection.removeAll(Set<QueryContext> queries)
boolean	DefaultEstimatedQueryCollection.removeAll(Set<QueryContext> queries)

Constructor parameters in org.apache.lens.server.query.collect with type arguments of type QueryContext

Constructor and Description
DefaultQueryCollection(Set<QueryContext> queries)
DefaultQueryCollection(TreeSet<QueryContext> treeSet)

Uses of QueryContext in org.apache.lens.server.query.constraint

Methods in org.apache.lens.server.query.constraint with parameters of type QueryContext

Modifier and Type	Method and Description
boolean	TotalQueryCostCeilingConstraint.allowsLaunchOf(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries) This constraint allows a query to be launched by the user, if total query cost of launched queries of the user is less than or equal to the total query cost ceiling per user OR the total query cost ceiling per user is not present.
boolean	QueryLaunchingConstraintsChecker.canLaunch(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)
boolean	DefaultQueryLaunchingConstraintsChecker.canLaunch(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)