Uses of Interface
org.apache.druid.query.QueryRunner
Packages that use QueryRunner
Package
Description
-
Uses of QueryRunner in org.apache.druid.query
Classes in org.apache.druid.query that implement QueryRunnerModifier and TypeClassDescriptionclassQuery runner that wraps a base single-segment query runner, and wraps its results in aBySegmentResultValueClassobject if the "bySegment" query context parameter is set.classclassA QueryRunner that combines a list of other QueryRunners and executes them in parallel on an executor.classclassQuery runner that appliesQueryToolChest.makePostComputeManipulatorFn(Query, MetricManipulationFn)to the result stream.classclassclassclassThis runner optimizes queries made on a single segment, using per-segment information, before submitting the queries to the base runner.classclassclassIf there's a subquery, run it instead of the outer queryclassImplements a QueryRunner that takesResultSerializationModeinto account.classMethods in org.apache.druid.query that return QueryRunnerModifier and TypeMethodDescriptionQueryRunnerFactory.createRunner(Segment segment) Given a specific segment, this method will create aQueryRunner.<T> QueryRunner<Object> QueryLogic.entryPoint(Query<T> query, QuerySegmentWalker walker) Builds aQueryRunnerfor the given query and walker.<T> QueryRunner<T> QuerySegmentWalker.getQueryRunnerForIntervals(Query<T> query, Iterable<org.joda.time.Interval> intervals) Gets the Queryable for a given interval, the Queryable returned can be any version(s) or partitionNumber(s) such that it represents the interval.<T> QueryRunner<T> QuerySegmentWalker.getQueryRunnerForSegments(Query<T> query, Iterable<SegmentDescriptor> specs) Gets the Queryable for a given list of SegmentDescriptors.AbstractPrioritizedQueryRunnerCallable.getRunner()BaseQuery.getRunner(QuerySegmentWalker walker) PrioritizedQueryRunnerCallable.getRunner()This method can be used by the extensions to get the runner that the given query execution task corresponds to.Query.getRunner(QuerySegmentWalker walker) static <T> QueryRunner<T> QueryRunnerHelper.makeClosingQueryRunner(QueryRunner<T> runner, Closeable closeable) QueryToolChest.mergeResults(QueryRunner<ResultType> runner) This method wraps a QueryRunner.QueryToolChest.mergeResults(QueryRunner<ResultType> runner, boolean willMergeRunner) LikeQueryToolChest.mergeResults(QueryRunner), but with an additional flag that indicates the type of runner that is passeed to the call.default QueryRunner<T> QueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<T>> queryRunners) Deprecated.QueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<T>> queryRunners) Runners generated with createRunner() and combined into an Iterable in (time,shardId) order are passed along to this method with anQueryProcessingPool.QueryToolChest.postMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.PostProcessingOperator.postProcess(QueryRunner<T> baseQueryRunner) TimewarpOperator.postProcess(QueryRunner<T> baseQueryRunner) TimewarpOperator.postProcess(QueryRunner<T> baseRunner, long now) QueryToolChest.preMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.static <T> QueryRunner<T> CPUTimeMetricQueryRunner.safeBuild(QueryRunner<T> delegate, QueryToolChest<T, ? extends Query<T>> queryToolChest, ServiceEmitter emitter, AtomicLong accumulator, boolean report) Methods in org.apache.druid.query that return types with arguments of type QueryRunnerModifier and TypeMethodDescriptionSinkQueryRunners.iterator()Iterator<Pair<org.joda.time.Interval, QueryRunner<T>>> SinkQueryRunners.runnerIntervalMappingIterator()Methods in org.apache.druid.query with parameters of type QueryRunnerModifier and TypeMethodDescriptionstatic <K,J extends Query<K>>
FluentQueryRunner<K> FluentQueryRunner.create(QueryRunner<K> runner, QueryToolChest<K, J> toolchest) BySegmentSkippingQueryRunner.doRun(QueryRunner<T> baseRunner, QueryPlus<T> queryPlus, ResponseContext context) ResultMergeQueryRunner.doRun(QueryRunner<T> baseRunner, QueryPlus<T> queryPlus, ResponseContext context) FluentQueryRunner.from(QueryRunner<T> runner) static <T> QueryRunner<T> QueryRunnerHelper.makeClosingQueryRunner(QueryRunner<T> runner, Closeable closeable) QueryToolChest.mergeResults(QueryRunner<ResultType> runner) This method wraps a QueryRunner.QueryToolChest.mergeResults(QueryRunner<ResultType> runner, boolean willMergeRunner) LikeQueryToolChest.mergeResults(QueryRunner), but with an additional flag that indicates the type of runner that is passeed to the call.QueryToolChest.postMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.PostProcessingOperator.postProcess(QueryRunner<T> baseQueryRunner) TimewarpOperator.postProcess(QueryRunner<T> baseQueryRunner) TimewarpOperator.postProcess(QueryRunner<T> baseRunner, long now) QueryToolChest.preMergeQueryDecoration(QueryRunner<ResultType> runner) Wraps a QueryRunner.static <T> QueryRunner<T> CPUTimeMetricQueryRunner.safeBuild(QueryRunner<T> delegate, QueryToolChest<T, ? extends Query<T>> queryToolChest, ServiceEmitter emitter, AtomicLong accumulator, boolean report) Method parameters in org.apache.druid.query with type arguments of type QueryRunnerModifier and TypeMethodDescriptionFluentQueryRunner.map(Function<QueryRunner<T>, QueryRunner<T>> mapFn) FluentQueryRunner.map(Function<QueryRunner<T>, QueryRunner<T>> mapFn) default QueryRunner<T> QueryRunnerFactory.mergeRunners(ExecutorService queryExecutor, Iterable<QueryRunner<T>> queryRunners) Deprecated.QueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<T>> queryRunners) Runners generated with createRunner() and combined into an Iterable in (time,shardId) order are passed along to this method with anQueryProcessingPool.Constructors in org.apache.druid.query with parameters of type QueryRunnerModifierConstructorDescriptionAbstractPrioritizedQueryRunnerCallable(int priority, QueryRunner<V> runner) BySegmentQueryRunner(SegmentId segmentId, org.joda.time.DateTime timestamp, QueryRunner<T> base) BySegmentSkippingQueryRunner(QueryRunner<T> baseRunner) FinalizeResultsQueryRunner(QueryRunner<T> baseRunner, QueryToolChest<T, Query<T>> toolChest) FluentQueryRunner(QueryRunner<T> runner, QueryToolChest<T, Query<T>> toolChest) MetricsEmittingQueryRunner(ServiceEmitter emitter, QueryToolChest<T, ? extends Query<T>> queryToolChest, QueryRunner<T> queryRunner, ObjLongConsumer<? super QueryMetrics<?>> reportMetric, Consumer<QueryMetrics<?>> applyCustomDimensions) PerSegmentOptimizingQueryRunner(QueryRunner<T> base, PerSegmentQueryOptimizationContext optimizationContext) ResultMergeQueryRunner(QueryRunner<T> baseRunner, Function<Query<T>, Comparator<T>> comparatorGenerator, Function<Query<T>, BinaryOperator<T>> mergeFnGenerator) SubqueryQueryRunner(QueryRunner<T> baseRunner) UnionDataSourceQueryRunner(QueryRunner<T> baseRunner) Constructor parameters in org.apache.druid.query with type arguments of type QueryRunnerModifierConstructorDescriptionChainedExecutionQueryRunner(QueryProcessingPool queryProcessingPool, QueryWatcher queryWatcher, Iterable<QueryRunner<T>> queryables) SinkQueryRunners(Iterable<Pair<org.joda.time.Interval, QueryRunner<T>>> runners) -
Uses of QueryRunner in org.apache.druid.query.datasourcemetadata
Methods in org.apache.druid.query.datasourcemetadata that return QueryRunnerModifier and TypeMethodDescriptionDataSourceMetadataQueryRunnerFactory.createRunner(Segment segment) DataSourceQueryQueryToolChest.mergeResults(QueryRunner<Result<DataSourceMetadataResultValue>> runner) DataSourceMetadataQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<DataSourceMetadataResultValue>>> queryRunners) Methods in org.apache.druid.query.datasourcemetadata with parameters of type QueryRunnerModifier and TypeMethodDescriptionDataSourceQueryQueryToolChest.mergeResults(QueryRunner<Result<DataSourceMetadataResultValue>> runner) Method parameters in org.apache.druid.query.datasourcemetadata with type arguments of type QueryRunnerModifier and TypeMethodDescriptionDataSourceMetadataQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<DataSourceMetadataResultValue>>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.groupby
Methods in org.apache.druid.query.groupby that return QueryRunnerModifier and TypeMethodDescriptionGroupByQueryRunnerFactory.createRunner(Segment segment) GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner) GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner, boolean willMergeRunner) GroupByQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners) GroupingEngine.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners) Merges a variety of single-segment query runners into a combined runner.GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ResultRow> runner) Methods in org.apache.druid.query.groupby with parameters of type QueryRunnerModifier and TypeMethodDescriptionGroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner) GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner, boolean willMergeRunner) GroupingEngine.mergeResults(QueryRunner<ResultRow> baseRunner, GroupByQuery query, ResponseContext responseContext) Runs a providedQueryRunneron a providedGroupByQuery, which is assumed to return rows that are properly sorted (by timestamp and dimensions) but not necessarily fully merged (that is, there may be adjacent rows with the same timestamp and dimensions) and without PostAggregators computed.GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ResultRow> runner) Method parameters in org.apache.druid.query.groupby with type arguments of type QueryRunnerModifier and TypeMethodDescriptionGroupByQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners) GroupingEngine.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners) Merges a variety of single-segment query runners into a combined runner. -
Uses of QueryRunner in org.apache.druid.query.groupby.epinephelinae
Classes in org.apache.druid.query.groupby.epinephelinae that implement QueryRunnerModifier and TypeClassDescriptionclassClass that knows how to merge a collection of groupByQueryRunnerobjects, calledqueryables, using a buffer provided bymergeBufferPooland a parallel executor provided byexec.Constructor parameters in org.apache.druid.query.groupby.epinephelinae with type arguments of type QueryRunnerModifierConstructorDescriptionGroupByMergingQueryRunner(GroupByQueryConfig config, DruidProcessingConfig processingConfig, QueryProcessingPool queryProcessingPool, QueryWatcher queryWatcher, Iterable<QueryRunner<ResultRow>> queryables, GroupByResourcesReservationPool groupByResourcesReservationPool, int concurrencyHint, int mergeBufferSize, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, GroupByStatsProvider groupByStatsProvider) -
Uses of QueryRunner in org.apache.druid.query.metadata
Methods in org.apache.druid.query.metadata that return QueryRunnerModifier and TypeMethodDescriptionSegmentMetadataQueryRunnerFactory.createRunner(Segment segment) SegmentMetadataQueryQueryToolChest.mergeResults(QueryRunner<SegmentAnalysis> runner) SegmentMetadataQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<SegmentAnalysis>> queryRunners) Methods in org.apache.druid.query.metadata with parameters of type QueryRunnerModifier and TypeMethodDescriptionSegmentMetadataQueryQueryToolChest.mergeResults(QueryRunner<SegmentAnalysis> runner) Method parameters in org.apache.druid.query.metadata with type arguments of type QueryRunnerModifier and TypeMethodDescriptionSegmentMetadataQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<SegmentAnalysis>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.operator
Methods in org.apache.druid.query.operator that return QueryRunnerModifier and TypeMethodDescriptionWindowOperatorQueryQueryRunnerFactory.createRunner(Segment segment) WindowOperatorQueryQueryToolChest.mergeResults(QueryRunner<RowsAndColumns> runner) WindowOperatorQueryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<RowsAndColumns>> queryRunners) Methods in org.apache.druid.query.operator with parameters of type QueryRunnerModifier and TypeMethodDescriptionWindowOperatorQueryQueryToolChest.mergeResults(QueryRunner<RowsAndColumns> runner) Method parameters in org.apache.druid.query.operator with type arguments of type QueryRunnerModifier and TypeMethodDescriptionWindowOperatorQueryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<RowsAndColumns>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.scan
Methods in org.apache.druid.query.scan that return QueryRunnerModifier and TypeMethodDescriptionScanQueryRunnerFactory.createRunner(Segment segment) ScanQueryQueryToolChest.mergeResults(QueryRunner<ScanResultValue> runner) ScanQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ScanResultValue>> queryRunners) ScanQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ScanResultValue> runner) Methods in org.apache.druid.query.scan with parameters of type QueryRunnerModifier and TypeMethodDescriptionScanQueryQueryToolChest.mergeResults(QueryRunner<ScanResultValue> runner) ScanQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ScanResultValue> runner) Method parameters in org.apache.druid.query.scan with type arguments of type QueryRunnerModifier and TypeMethodDescriptionScanQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ScanResultValue>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.search
Classes in org.apache.druid.query.search that implement QueryRunnerMethods in org.apache.druid.query.search that return QueryRunnerModifier and TypeMethodDescriptionSearchQueryRunnerFactory.createRunner(Segment segment) SearchQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners) SearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner) Methods in org.apache.druid.query.search with parameters of type QueryRunnerModifier and TypeMethodDescriptionSearchQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<SearchResultValue>> runner) Method parameters in org.apache.druid.query.search with type arguments of type QueryRunnerModifier and TypeMethodDescriptionSearchQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<SearchResultValue>>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.select
Methods in org.apache.druid.query.select that return QueryRunner -
Uses of QueryRunner in org.apache.druid.query.spec
Classes in org.apache.druid.query.spec that implement QueryRunnerMethods in org.apache.druid.query.spec that return QueryRunnerModifier and TypeMethodDescription<T> QueryRunner<T> MultipleIntervalSegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker) <T> QueryRunner<T> MultipleSpecificSegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker) <T> QueryRunner<T> QuerySegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker) <T> QueryRunner<T> SpecificSegmentSpec.lookup(Query<T> query, QuerySegmentWalker walker) Constructors in org.apache.druid.query.spec with parameters of type QueryRunnerModifierConstructorDescriptionSpecificSegmentQueryRunner(QueryRunner<T> base, SpecificSegmentSpec specificSpec) -
Uses of QueryRunner in org.apache.druid.query.timeboundary
Methods in org.apache.druid.query.timeboundary that return QueryRunnerModifier and TypeMethodDescriptionTimeBoundaryQueryRunnerFactory.createRunner(Segment segment) TimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner) TimeBoundaryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners) Methods in org.apache.druid.query.timeboundary with parameters of type QueryRunnerModifier and TypeMethodDescriptionTimeBoundaryQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner) Method parameters in org.apache.druid.query.timeboundary with type arguments of type QueryRunnerModifier and TypeMethodDescriptionTimeBoundaryQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TimeBoundaryResultValue>>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.timeseries
Methods in org.apache.druid.query.timeseries that return QueryRunnerModifier and TypeMethodDescriptionTimeseriesQueryRunnerFactory.createRunner(Segment segment) TimeseriesQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeseriesResultValue>> queryRunner) TimeseriesQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TimeseriesResultValue>>> queryRunners) TimeseriesQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TimeseriesResultValue>> runner) Methods in org.apache.druid.query.timeseries with parameters of type QueryRunnerModifier and TypeMethodDescriptionTimeseriesQueryQueryToolChest.mergeResults(QueryRunner<Result<TimeseriesResultValue>> queryRunner) TimeseriesQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TimeseriesResultValue>> runner) Method parameters in org.apache.druid.query.timeseries with type arguments of type QueryRunnerModifier and TypeMethodDescriptionTimeseriesQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TimeseriesResultValue>>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.topn
Methods in org.apache.druid.query.topn that return QueryRunnerModifier and TypeMethodDescriptionTopNQueryRunnerFactory.createRunner(Segment segment) TopNQueryQueryToolChest.mergeResults(QueryRunner<Result<TopNResultValue>> runner) TopNQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners) TopNQueryQueryToolChest.postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) TopNQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) Methods in org.apache.druid.query.topn with parameters of type QueryRunnerModifier and TypeMethodDescriptionTopNQueryQueryToolChest.mergeResults(QueryRunner<Result<TopNResultValue>> runner) TopNQueryQueryToolChest.postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) TopNQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner) Method parameters in org.apache.druid.query.topn with type arguments of type QueryRunnerModifier and TypeMethodDescriptionTopNQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<Result<TopNResultValue>>> queryRunners) -
Uses of QueryRunner in org.apache.druid.query.union
Methods in org.apache.druid.query.union that return QueryRunnerModifier and TypeMethodDescription<T> QueryRunner<Object> UnionQueryLogic.entryPoint(Query<T> query, QuerySegmentWalker walker) UnionQuery.getRunner(QuerySegmentWalker walker)
QueryRunnerFactory.mergeRunners(QueryProcessingPool, Iterable)instead.