Uses of Interface
org.apache.druid.query.Query
Packages that use Query
Package
Description
-
Uses of Query in org.apache.druid.java.util.common.granularity
Methods in org.apache.druid.java.util.common.granularity with parameters of type QueryModifier and TypeMethodDescriptionstatic CursorBuildSpecGranularities.decorateCursorBuildSpec(Query<?> query, CursorBuildSpec buildSpec) DecoratesCursorBuildSpecwith a grouping column and virtual column equivalent to theGranularityfor aQuery, if that query has granularity other thanGranularities.ALL. -
Uses of Query in org.apache.druid.query
Classes in org.apache.druid.query with type parameters of type QueryModifier and TypeInterfaceDescriptioninterfaceCacheStrategy<T,CacheType, QueryType extends Query<T>> Handles caching-related tasks for a particular query type.classDefaultQueryMetrics<QueryType extends Query<?>>DefaultQueryMetrics is unsafe for use from multiple threads.interfaceQueryMetrics<QueryType extends Query<?>>Abstraction wrappingServiceMetricEvent.Builderand allowing to control what metrics are actually emitted, what dimensions do they have, etc.interfaceQueryRunnerFactory<T,QueryType extends Query<T>> An interface that defines the nitty gritty implementation details of a Query on a SegmentclassQueryToolChest<ResultType,QueryType extends Query<ResultType>> The broker-side (also used by server in some cases) API for a specific Query type.Classes in org.apache.druid.query that implement QueryMethods in org.apache.druid.query with type parameters of type QueryModifier and TypeMethodDescriptionstatic <K,J extends Query<K>>
FluentQueryRunner<K>FluentQueryRunner.create(QueryRunner<K> runner, QueryToolChest<K, J> toolchest) <T,QueryType extends Query<T>>
QueryRunnerFactory<T,QueryType> DefaultQueryRunnerFactoryConglomerate.findFactory(QueryType query) <T,QueryType extends Query<T>>
QueryRunnerFactory<T,QueryType> QueryRunnerFactoryConglomerate.findFactory(QueryType query) <T,QueryType extends Query<T>>
QueryLogicDefaultQueryRunnerFactoryConglomerate.getQueryLogic(QueryType query) <T,QueryType extends Query<T>>
QueryLogicQueryRunnerFactoryConglomerate.getQueryLogic(QueryType query) <T,QueryType extends Query<T>>
QueryToolChest<T,QueryType> DefaultQueryRunnerFactoryConglomerate.getToolChest(QueryType query) <T,QueryType extends Query<T>>
QueryToolChest<T,QueryType> MapQueryToolChestWarehouse.getToolChest(QueryType query) <T,QueryType extends Query<T>>
QueryToolChest<T,QueryType> QueryRunnerFactoryConglomerate.getToolChest(QueryType query) <T,QueryType extends Query<T>>
QueryToolChest<T,QueryType> QueryToolChestWarehouse.getToolChest(QueryType query) QueryPlus.unwrapQuery(Class<C> clazz) Methods in org.apache.druid.query that return QueryModifier and TypeMethodDescriptionQueryDataSource.getQuery()QueryPlus.getQuery()Query.optimizeForSegment(PerSegmentQueryOptimizationContext optimizationContext) static QueryQueries.withBaseDataSource(Query query, DataSource newBaseDataSource) Rewrite "query" to refer to some specific base datasource, instead of the one it currently refers to.Query.withDataSource(DataSource dataSource) Query.withDefaultSubQueryId()static <T> Query<T>Queries.withDefaultTimeout(Query<T> query, long defaultTimeout) static <T> Query<T>Queries.withMaxScatterGatherBytes(Query<T> query, long maxScatterGatherBytesLimit) Query.withOverriddenContext(Map<String, Object> contextOverride) Query.withPriority(int priority) Query.withQuerySegmentSpec(QuerySegmentSpec spec) Returns a new query, identical to this one, but with a different associatedQuerySegmentSpec.static <T> Query<T>Queries.withSpecificSegments(Query<T> query, List<SegmentDescriptor> descriptors) Rewrite "query" to refer to some specific segment descriptors.BaseQuery.withSqlQueryId(String sqlQueryId) Query.withSqlQueryId(String sqlQueryId) BaseQuery.withSubQueryId(String subQueryId) Query.withSubQueryId(String subQueryId) Returns a copy of this query with a new subQueryId (seegetSubQueryId().static <T> Query<T>Queries.withTimeout(Query<T> query, long timeout) Methods in org.apache.druid.query that return types with arguments of type QueryModifier and TypeMethodDescriptionQueryMetrics<Query<?>>DefaultGenericQueryMetricsFactory.makeMetrics()QueryMetrics<Query<?>>DefaultGenericQueryMetricsFactory.makeMetrics(Query<?> query) QueryMetrics<Query<?>>GenericQueryMetricsFactory.makeMetrics()Creates aQueryMetricswhich doesn't have predefined QueryMetrics subclass.QueryMetrics<Query<?>>GenericQueryMetricsFactory.makeMetrics(Query<?> query) Creates aQueryMetricsfor query, which doesn't have predefined QueryMetrics subclass.QueryMetrics<? super Query<Object>>QueryLogicCompatToolChest.makeMetrics(Query<Object> query) Methods in org.apache.druid.query with parameters of type QueryModifier and TypeMethodDescription<T> booleanQueryToolChest.canExecuteFully(Query<T> query) booleanQueryToolChest.canPerformSubquery(Query<?> subquery) Returns whether this toolchest is able to handle the provided subquery.QueryToolChest.createMergeFn(Query<ResultType> query) Creates a merge function that is used to merge intermediate aggregates from historicals in broker.QueryToolChest.createResultComparator(Query<ResultType> query) Creates an ordering comparator that is used to order results.DataSource.createSegmentMapFunction(Query query) Returns a segment function on to how to segment should be modified.FilteredDataSource.createSegmentMapFunction(Query query) JoinDataSource.createSegmentMapFunction(Query query) Creates a Function that maps base segments toHashJoinSegmentif needed (i.e.LeafDataSource.createSegmentMapFunction(Query query) QueryDataSource.createSegmentMapFunction(Query query) RestrictedDataSource.createSegmentMapFunction(Query query) UnionDataSource.createSegmentMapFunction(Query query) UnnestDataSource.createSegmentMapFunction(Query query) Druids.ScanQueryBuilder.dataSource(Query<?> q) <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.QueryMetrics<Query<?>>DefaultGenericQueryMetricsFactory.makeMetrics(Query<?> query) QueryMetrics<Query<?>>GenericQueryMetricsFactory.makeMetrics(Query<?> query) Creates aQueryMetricsfor query, which doesn't have predefined QueryMetrics subclass.QueryMetrics<? super Query<Object>>QueryLogicCompatToolChest.makeMetrics(Query<Object> query) QueryLogicCompatToolChest.makePreComputeManipulatorFn(Query<Object> query, MetricManipulationFn fn) static <T> QueryMetrics<?>DruidMetrics.makeRequestMetrics(GenericQueryMetricsFactory queryMetricsFactory, QueryToolChest<T, Query<T>> toolChest, Query<T> query, String remoteAddr) voidQueryWatcher.registerQueryFuture(Query<?> query, com.google.common.util.concurrent.ListenableFuture<?> future) QueryRunners must use this method to register any pending queries.QueryLogicCompatToolChest.resultArraySignature(Query<Object> query) QueryLogicCompatToolChest.resultsAsArrays(Query<Object> query, Sequence<Object> resultSequence) QueryLogicCompatToolChest.resultsAsFrames(Query<Object> query, Sequence<Object> resultSequence, MemoryAllocatorFactory memoryAllocatorFactory, boolean useNestedForUnknownTypes) static QueryQueries.withBaseDataSource(Query query, DataSource newBaseDataSource) Rewrite "query" to refer to some specific base datasource, instead of the one it currently refers to.static <T> Query<T>Queries.withDefaultTimeout(Query<T> query, long defaultTimeout) static <T> Query<T>Queries.withMaxScatterGatherBytes(Query<T> query, long maxScatterGatherBytesLimit) <U> QueryPlus<U>Returns a QueryPlus object withQueryMetricsfrom this QueryPlus object, and the providedQuery.static <T> Query<T>Queries.withSpecificSegments(Query<T> query, List<SegmentDescriptor> descriptors) Rewrite "query" to refer to some specific segment descriptors.static <T> Query<T>Queries.withTimeout(Query<T> query, long timeout) static <T> QueryPlus<T>Returns the minimum bare QueryPlus object with the given query.Method parameters in org.apache.druid.query with type arguments of type QueryModifier and TypeMethodDescriptionDefaultQueryRunnerFactoryConglomerate.buildFromQueryRunnerFactories(Map<Class<? extends Query>, QueryRunnerFactory> factories) static <T> QueryMetrics<?>DruidMetrics.makeRequestMetrics(GenericQueryMetricsFactory queryMetricsFactory, QueryToolChest<T, Query<T>> toolChest, Query<T> query, String remoteAddr) static <T> QueryRunner<T>CPUTimeMetricQueryRunner.safeBuild(QueryRunner<T> delegate, QueryToolChest<T, ? extends Query<T>> queryToolChest, ServiceEmitter emitter, AtomicLong accumulator, boolean report) QueryPlus.withQueryMetrics(QueryToolChest<T, ? extends Query<T>> queryToolChest) Returns the same QueryPlus object, if it already hasQueryMetrics(QueryPlus.getQueryMetrics()returns not null), or returns a new QueryPlus object withQueryfrom this QueryPlus and QueryMetrics created using the givenQueryToolChest, viaQueryToolChest.makeMetrics(Query)method.Constructors in org.apache.druid.query with parameters of type QueryModifierConstructorDescriptionQueryDataSource(Query query) ToolChestBasedResultSerializedRunner(Query<T> query, QuerySegmentWalker walker, QueryToolChest<T, Query<T>> toolChest) Constructor parameters in org.apache.druid.query with type arguments of type QueryModifierConstructorDescriptionDefaultQueryRunnerFactoryConglomerate(Map<Class<? extends Query>, QueryRunnerFactory> factories, Map<Class<? extends Query>, QueryToolChest> toolchests, Map<Class<? extends Query>, QueryLogic> querylogics) FinalizeResultsQueryRunner(QueryRunner<T> baseRunner, QueryToolChest<T, Query<T>> toolChest) FluentQueryRunner(QueryRunner<T> runner, QueryToolChest<T, Query<T>> toolChest) MapQueryToolChestWarehouse(Map<Class<? extends Query>, QueryToolChest> toolchests) MetricsEmittingQueryRunner(ServiceEmitter emitter, QueryToolChest<T, ? extends Query<T>> queryToolChest, QueryRunner<T> queryRunner, ObjLongConsumer<? super QueryMetrics<?>> reportMetric, Consumer<QueryMetrics<?>> applyCustomDimensions) ResultMergeQueryRunner(QueryRunner<T> baseRunner, Function<Query<T>, Comparator<T>> comparatorGenerator, Function<Query<T>, BinaryOperator<T>> mergeFnGenerator) ToolChestBasedResultSerializedRunner(Query<T> query, QuerySegmentWalker walker, QueryToolChest<T, Query<T>> toolChest) -
Uses of Query in org.apache.druid.query.datasourcemetadata
Classes in org.apache.druid.query.datasourcemetadata that implement QueryMethods in org.apache.druid.query.datasourcemetadata that return QueryMethods in org.apache.druid.query.datasourcemetadata that return types with arguments of type QueryModifier and TypeMethodDescriptionQueryMetrics<Query<?>>DataSourceQueryQueryToolChest.makeMetrics(DataSourceMetadataQuery query) -
Uses of Query in org.apache.druid.query.groupby
Classes in org.apache.druid.query.groupby that implement QueryMethods in org.apache.druid.query.groupby that return QueryMethods in org.apache.druid.query.groupby with parameters of type QueryModifier and TypeMethodDescriptionbooleanGroupByQueryQueryToolChest.canPerformSubquery(Query<?> subquery) GroupByQueryQueryToolChest.createMergeFn(Query<ResultRow> query) GroupingEngine.createMergeFn(Query<ResultRow> queryParam) SeeQueryToolChest.createMergeFn(Query)for details, allowsGroupByQueryQueryToolChestto delegate implementation to the strategyGroupByQueryQueryToolChest.createResultComparator(Query<ResultRow> query) GroupingEngine.createResultComparator(Query<ResultRow> queryParam) SeeQueryToolChest.createResultComparator(Query), allowsGroupByQueryQueryToolChestto delegate implementation to the strategyGroupByQuery.Builder.setDataSource(Query query) -
Uses of Query in org.apache.druid.query.metadata
Methods in org.apache.druid.query.metadata that return types with arguments of type QueryModifier and TypeMethodDescriptionQueryMetrics<Query<?>>SegmentMetadataQueryQueryToolChest.makeMetrics(SegmentMetadataQuery query) Methods in org.apache.druid.query.metadata with parameters of type QueryModifier and TypeMethodDescriptionSegmentMetadataQueryQueryToolChest.createMergeFn(Query<SegmentAnalysis> query) SegmentMetadataQueryQueryToolChest.createResultComparator(Query<SegmentAnalysis> query) -
Uses of Query in org.apache.druid.query.metadata.metadata
Classes in org.apache.druid.query.metadata.metadata that implement QueryMethods in org.apache.druid.query.metadata.metadata that return QueryModifier and TypeMethodDescriptionSegmentMetadataQuery.withColumns(ColumnIncluderator includerator) SegmentMetadataQuery.withDataSource(DataSource dataSource) SegmentMetadataQuery.withOverriddenContext(Map<String, Object> contextOverride) SegmentMetadataQuery.withQuerySegmentSpec(QuerySegmentSpec spec) -
Uses of Query in org.apache.druid.query.operator
Classes in org.apache.druid.query.operator that implement QueryModifier and TypeClassDescriptionclassA query that can compute window functions on top of a completely in-memory inline datasource or query results.Methods in org.apache.druid.query.operator that return QueryModifier and TypeMethodDescriptionWindowOperatorQuery.withDataSource(DataSource dataSource) WindowOperatorQuery.withOperators(List<OperatorFactory> operators) WindowOperatorQuery.withOverriddenContext(Map<String, Object> contextOverride) WindowOperatorQuery.withQuerySegmentSpec(QuerySegmentSpec spec) -
Uses of Query in org.apache.druid.query.planning
Fields in org.apache.druid.query.planning declared as QueryModifier and TypeFieldDescriptionprotected final Query<?>ExecutionVertex.topQueryThe top level query this vertex is describing.Methods in org.apache.druid.query.planning that return QueryModifier and TypeMethodDescriptionExecutionVertex.buildQueryWithBaseDataSource(DataSource newBaseDataSource) Methods in org.apache.druid.query.planning with parameters of type QueryModifier and TypeMethodDescriptionstatic ExecutionVertexIdentifies the vertex for the given query.Constructors in org.apache.druid.query.planning with parameters of type QueryModifierConstructorDescriptionJoinDataSourceAnalysis(DataSource baseDataSource, Query<?> baseQuery, DimFilter joinBaseTableFilter, List<PreJoinableClause> preJoinableClauses, QuerySegmentSpec querySegmentSpec) -
Uses of Query in org.apache.druid.query.scan
Classes in org.apache.druid.query.scan that implement QueryMethods in org.apache.druid.query.scan that return types with arguments of type QueryModifier and TypeMethodDescriptionQueryMetrics<Query<?>>ScanQueryQueryToolChest.makeMetrics(ScanQuery query) -
Uses of Query in org.apache.druid.query.search
Classes in org.apache.druid.query.search that implement QueryMethods in org.apache.druid.query.search that return QueryMethods in org.apache.druid.query.search with parameters of type QueryModifier and TypeMethodDescriptionSearchQueryQueryToolChest.createMergeFn(Query<Result<SearchResultValue>> query) SearchQueryQueryToolChest.createResultComparator(Query<Result<SearchResultValue>> query) Constructor parameters in org.apache.druid.query.search with type arguments of type Query -
Uses of Query in org.apache.druid.query.select
Classes in org.apache.druid.query.select that implement QueryMethods in org.apache.druid.query.select that return QueryModifier and TypeMethodDescriptionSelectQuery.withDataSource(DataSource dataSource) Deprecated.Deprecated.SelectQuery.withOverriddenContext(Map<String, Object> contextOverride) Deprecated.SelectQuery.withQuerySegmentSpec(QuerySegmentSpec spec) Deprecated.SelectQuery.withSubQueryId(String subQueryId) Deprecated. -
Uses of Query in org.apache.druid.query.spec
Methods in org.apache.druid.query.spec with parameters of type QueryModifier 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) -
Uses of Query in org.apache.druid.query.timeboundary
Classes in org.apache.druid.query.timeboundary that implement QueryMethods in org.apache.druid.query.timeboundary that return QueryMethods in org.apache.druid.query.timeboundary that return types with arguments of type QueryModifier and TypeMethodDescriptionQueryMetrics<Query<?>>TimeBoundaryQueryQueryToolChest.makeMetrics(TimeBoundaryQuery query) Methods in org.apache.druid.query.timeboundary with parameters of type QueryModifier and TypeMethodDescriptionTimeBoundaryQueryQueryToolChest.createMergeFn(Query<Result<TimeBoundaryResultValue>> query) TimeBoundaryQueryQueryToolChest.createResultComparator(Query<Result<TimeBoundaryResultValue>> query) -
Uses of Query in org.apache.druid.query.timeseries
Classes in org.apache.druid.query.timeseries that implement QueryMethods in org.apache.druid.query.timeseries that return QueryModifier and TypeMethodDescriptionTimeseriesQuery.optimizeForSegment(PerSegmentQueryOptimizationContext optimizationContext) TimeseriesQuery.withDataSource(DataSource dataSource) Methods in org.apache.druid.query.timeseries with parameters of type QueryModifier and TypeMethodDescriptionTimeseriesQueryQueryToolChest.createMergeFn(Query<Result<TimeseriesResultValue>> query) TimeseriesQueryQueryToolChest.createResultComparator(Query<Result<TimeseriesResultValue>> query) -
Uses of Query in org.apache.druid.query.topn
Classes in org.apache.druid.query.topn that implement QueryMethods in org.apache.druid.query.topn that return QueryModifier and TypeMethodDescriptionTopNQuery.optimizeForSegment(PerSegmentQueryOptimizationContext optimizationContext) TopNQuery.withDataSource(DataSource dataSource) -
Uses of Query in org.apache.druid.query.union
Classes in org.apache.druid.query.union that implement QueryFields in org.apache.druid.query.union with type parameters of type QueryMethods in org.apache.druid.query.union that return QueryModifier and TypeMethodDescriptionUnionQuery.withDataSource(DataSource dataSource) UnionQuery.withDataSources(List<DataSource> children) UnionQuery.withOverriddenContext(Map<String, Object> contextOverrides) UnionQuery.withQuerySegmentSpec(QuerySegmentSpec spec) UnionQuery.withSubQueryId(String subQueryId) Methods in org.apache.druid.query.union with parameters of type QueryModifier and TypeMethodDescription<T> QueryRunner<Object>UnionQueryLogic.entryPoint(Query<T> query, QuerySegmentWalker walker) Constructor parameters in org.apache.druid.query.union with type arguments of type Query -
Uses of Query in org.apache.druid.segment.filter
Methods in org.apache.druid.segment.filter with parameters of type QueryModifier and TypeMethodDescriptionstatic FilterFilters.convertToCNFFromQueryContext(Query query, Filter filter) -
Uses of Query in org.apache.druid.segment.join.filter.rewrite
Methods in org.apache.druid.segment.join.filter.rewrite with parameters of type Query