Package org.apache.druid.server

Class QuerySwappingQueryRunner<T>

java.lang.Object

org.apache.druid.server.QuerySwappingQueryRunner<T>

All Implemented Interfaces:

QueryRunner<T>

public class QuerySwappingQueryRunner<T>
extends Object
implements QueryRunner<T>

A QueryRunner which validates that a *specific* query is passed in, and then swaps it with another one. Useful in passing the modified query to the underlying runners, since the QuerySegmentWalker Useful since walkers might need to enrich the query with additional parameters and the callers actually calling the `run()` won't know about this modification. It validates that the query passed to the `run()` was the same query that was passed while creating the runner, to ensure that the enrichment was done to the correct query.

Constructor Summary

Constructors

Constructor	Description
QuerySwappingQueryRunner(QueryRunner<T> baseRunner, Query<T> query, Query<T> newQuery)

Method Summary

Modifier and Type	Method	Description
Sequence<T>	run(QueryPlus<T> queryPlus, ResponseContext responseContext)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.query.QueryRunner

run

Constructor Details

QuerySwappingQueryRunner

public QuerySwappingQueryRunner(QueryRunner<T> baseRunner,
 Query<T> query,
 Query<T> newQuery)

Method Details

run

public Sequence<T> run(QueryPlus<T> queryPlus,
 ResponseContext responseContext)

Specified by:

run in interface QueryRunner<T>