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.driver.hooks
org.apache.lens.server.api.query
org.apache.lens.server.api.query.collect
org.apache.lens.server.api.query.comparators
org.apache.lens.server.api.query.constraint
org.apache.lens.server.api.query.events
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)
void	HiveDriver.registerForCompletionNotification(QueryContext context, long timeoutMillis, QueryCompletionListener listener)
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
String	MaxJDBCConnectionCheckConstraint.allowsLaunchOf(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)
LensResultSet	JDBCDriver.execute(QueryContext context) Blocking execute of the query.
void	JDBCDriver.executeAsync(QueryContext context) Asynchronously execute the query.
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 that return types with arguments of type QueryContext

Modifier and Type	Method and Description
RetryPolicyDecider<QueryContext>	LensDriver.getRetryPolicyDecider()
RetryPolicyDecider<QueryContext>	AbstractLensDriver.getRetryPolicyDecider()

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.
LensResultSet	AbstractLensDriver.fetchResultSet(QueryContext ctx) Default implementation for fetchResultSet for all drivers.
void	LensDriver.registerForCompletionNotification(QueryContext context, long timeoutMillis, QueryCompletionListener listener) Register for query completion notification.
void	AbstractLensDriver.registerForCompletionNotification(QueryContext context, long timeoutMillis, QueryCompletionListener listener)
void	LensDriver.updateStatus(QueryContext context) Update driver query status in the context object.

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

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

Modifier and Type	Method and Description
void	NoOpDriverQueryHook.preLaunch(QueryContext ctx)
void	DriverQueryHook.preLaunch(QueryContext ctx) Called just before launching the query on the selected driver.
void	ChainedDriverQueryHook.preLaunch(QueryContext ctx)

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	FinishedLensQuery.toQueryContext(org.apache.hadoop.conf.Configuration conf, Collection<LensDriver> drivers)

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

Modifier and Type	Method and Description
BackOffRetryHandler<QueryContext>	QueryContext.getDriverRetryPolicy()
BackOffRetryHandler<QueryContext>	QueryContext.getRetryPolicy()
BackOffRetryHandler<QueryContext>	QueryContext.getServerRetryPolicy()

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.

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

Modifier and Type	Method and Description
void	QueryContext.setDriverRetryPolicy(BackOffRetryHandler<QueryContext> driverRetryPolicy)
void	QueryContext.setServerRetryPolicy(BackOffRetryHandler<QueryContext> serverRetryPolicy)

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.

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.comparators

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

Modifier and Type	Method and Description
int	QueryPriorityComparator.compare(QueryContext o1, QueryContext o2)
int	QueryCostComparator.compare(QueryContext o1, QueryContext o2)
int	MoreRetriesFirstComparator.compare(QueryContext o1, QueryContext o2)
int	FIFOQueryComparator.compare(QueryContext o1, QueryContext o2)

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
String	QueryLaunchingConstraint.allowsLaunchOf(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries) Returns whether this constraint allows candidate query to be launched.
String	MaxConcurrentDriverQueriesConstraint.allowsLaunchOf(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)

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

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

Modifier and Type	Method and Description
QueryContext	QueryEnded.getQueryContext()

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

Constructor and Description
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.query

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

Modifier and Type	Method and Description
QueryContext	QueryExecutionServiceImpl.FinishedQuery.getCtx() The ctx.
QueryContext	QueryExecutionServiceImpl.getQueryContext(QueryHandle queryHandle) Gets the query context.

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 that return types with arguments of type QueryContext

Modifier and Type	Method and Description
BackOffRetryHandler<QueryContext>	RetryPolicyToConstraingAdapter.getConstraint()

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

Modifier and Type	Method and Description
String	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.
String	RetryPolicyToConstraingAdapter.allowsLaunchOf(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)
boolean	QueryLaunchingConstraintsChecker.canLaunch(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)
boolean	DefaultQueryLaunchingConstraintsChecker.canLaunch(QueryContext candidateQuery, EstimatedImmutableQueryCollection launchedQueries)

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

Constructor and Description
RetryPolicyToConstraingAdapter(BackOffRetryHandler<QueryContext> constraint)