Uses of Class
org.apache.druid.query.groupby.GroupByQueryResources
Packages that use GroupByQueryResources
-
Uses of GroupByQueryResources in org.apache.druid.query.groupby
Methods in org.apache.druid.query.groupby that return GroupByQueryResourcesModifier and TypeMethodDescriptionGroupByResourcesReservationPool.fetch(QueryResourceId queryResourceId) Fetches resources corresponding to the given resource idstatic GroupByQueryResourcesGroupingEngine.prepareResource(GroupByQuery query, BlockingPool<ByteBuffer> mergeBufferPool, boolean usesGroupByMergingQueryRunner, GroupByQueryConfig groupByQueryConfig) Initializes resources required to runGroupByQueryQueryToolChest.mergeResults(QueryRunner)andGroupByMergingQueryRunnerfor a particular query.Methods in org.apache.druid.query.groupby with parameters of type GroupByQueryResourcesModifier and TypeMethodDescriptionGroupingEngine.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> subqueryResult, boolean wasQueryPushedDown, GroupByStatsProvider.PerQueryStats perQueryStats) Called byGroupByQueryQueryToolChest.mergeResults(QueryRunner)when it needs to process a subquery.GroupingEngine.processSubtotalsSpec(GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> queryResult, GroupByStatsProvider.PerQueryStats perQueryStats) Called byGroupByQueryQueryToolChest.mergeResults(QueryRunner)when it needs to generate subtotals. -
Uses of GroupByQueryResources in org.apache.druid.query.groupby.epinephelinae
Methods in org.apache.druid.query.groupby.epinephelinae with parameters of type GroupByQueryResourcesModifier and TypeMethodDescriptionGroupByRowProcessor.process(GroupByQuery query, GroupByQuery subquery, Sequence<ResultRow> rows, GroupByQueryConfig config, DruidProcessingConfig processingConfig, GroupByQueryResources resource, com.fasterxml.jackson.databind.ObjectMapper spillMapper, String processingTmpDir, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats) Process the input of sequence "rows" (output by "subquery") based on "query" and returns aGroupByRowProcessor.ResultSupplier.