Uses of Class
org.apache.druid.query.groupby.ResultRow

Packages that use ResultRow

Package	Description
org.apache.druid.query.groupby
org.apache.druid.query.groupby.epinephelinae
org.apache.druid.query.groupby.epinephelinae.column
org.apache.druid.query.groupby.epinephelinae.vector
org.apache.druid.query.groupby.having
org.apache.druid.query.groupby.orderby
org.apache.druid.query.rowsandcols
org.apache.druid.segment.virtual

Uses of ResultRow in org.apache.druid.query.groupby

Methods in org.apache.druid.query.groupby that return ResultRow

Modifier and Type	Method	Description
ResultRow	ResultRow.copy()	Returns a copy of this row.
static ResultRow	ResultRow.create(int size)	Create a row of a certain size, initialized to all nulls.
static ResultRow	ResultRow.fromLegacyRow(Row row, GroupByQuery query)	Create a row based on a legacy Row that was generated by a given GroupByQuery.
static ResultRow	ResultRow.of(Object... row)	Create a row from an array of objects.

Methods in org.apache.druid.query.groupby that return types with arguments of type ResultRow

Modifier and Type	Method	Description
Sequence<ResultRow>	GroupingEngine.applyPostProcessing(Sequence<ResultRow> results, GroupByQuery query)	Apply the GroupByQuery "postProcessingFn", which is responsible for HavingSpec and LimitSpec.
BinaryOperator<ResultRow>	GroupByQueryQueryToolChest.createMergeFn(Query<ResultRow> query)
BinaryOperator<ResultRow>	GroupingEngine.createMergeFn(Query<ResultRow> queryParam)	See QueryToolChest.createMergeFn(Query) for details, allows GroupByQueryQueryToolChest to delegate implementation to the strategy
Comparator<ResultRow>	GroupByQueryQueryToolChest.createResultComparator(Query<ResultRow> query)
Comparator<ResultRow>	GroupingEngine.createResultComparator(Query<ResultRow> queryParam)	See QueryToolChest.createResultComparator(Query), allows GroupByQueryQueryToolChest to delegate implementation to the strategy
QueryRunner<ResultRow>	GroupByQueryRunnerFactory.createRunner(Segment segment)
CacheStrategy<ResultRow,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query)
CacheStrategy<ResultRow,Object,GroupByQuery>	GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query, com.fasterxml.jackson.databind.ObjectMapper mapper)
com.fasterxml.jackson.core.type.TypeReference<ResultRow>	GroupByQueryQueryToolChest.getResultTypeReference()
com.google.common.collect.Ordering<ResultRow>	GroupByQuery.getRowOrdering(boolean granular)
com.google.common.collect.Ordering<ResultRow>	GroupByQuery.OrderingAndDimensions.getRowOrdering()
QueryToolChest<ResultRow,GroupByQuery>	GroupByQueryRunnerFactory.getToolchest()
com.google.common.base.Function<ResultRow,ResultRow>	GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<ResultRow,ResultRow>	GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<ResultRow,ResultRow>	GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
com.google.common.base.Function<ResultRow,ResultRow>	GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query, MetricManipulationFn fn)
QueryRunner<ResultRow>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner)
QueryRunner<ResultRow>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner, boolean willMergeRunner)
Sequence<ResultRow>	GroupingEngine.mergeResults(QueryRunner<ResultRow> baseRunner, GroupByQuery query, ResponseContext responseContext)	Runs a provided QueryRunner on a provided GroupByQuery, 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.
QueryRunner<ResultRow>	GroupByQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)
QueryRunner<ResultRow>	GroupingEngine.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)	Merges a variety of single-segment query runners into a combined runner.
Sequence<ResultRow>	GroupByQuery.postProcess(Sequence<ResultRow> results)	Apply the havingSpec and limitSpec.
QueryRunner<ResultRow>	GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ResultRow> runner)
Sequence<ResultRow>	GroupingEngine.process(GroupByQuery query, CursorFactory cursorFactory, TimeBoundaryInspector timeBoundaryInspector, NonBlockingPool<ByteBuffer> bufferPool, GroupByQueryMetrics groupByQueryMetrics)	Process a groupBy query on a single CursorFactory.
Sequence<ResultRow>	GroupingEngine.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> subqueryResult, boolean wasQueryPushedDown, GroupByStatsProvider.PerQueryStats perQueryStats)	Called by GroupByQueryQueryToolChest.mergeResults(QueryRunner) when it needs to process a subquery.
Sequence<ResultRow>	GroupingEngine.processSubtotalsSpec(GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> queryResult, GroupByStatsProvider.PerQueryStats perQueryStats)	Called by GroupByQueryQueryToolChest.mergeResults(QueryRunner) when it needs to generate subtotals.
Query<ResultRow>	GroupByQuery.withDataSource(DataSource dataSource)
static Sequence<ResultRow>	GroupingEngine.wrapSummaryRowIfNeeded(GroupByQuery query, Sequence<ResultRow> process)	Wraps the sequence around if for this query a summary row might be needed in case the input becomes empty.

Methods in org.apache.druid.query.groupby with parameters of type ResultRow

Modifier and Type	Method	Description
static void	GroupingEngine.convertRowTypesToOutputTypes(List<DimensionSpec> dimensionSpecs, ResultRow resultRow, int resultRowDimensionStart)

Method parameters in org.apache.druid.query.groupby with type arguments of type ResultRow

Modifier and Type	Method	Description
Sequence<ResultRow>	GroupingEngine.applyPostProcessing(Sequence<ResultRow> results, GroupByQuery query)	Apply the GroupByQuery "postProcessingFn", which is responsible for HavingSpec and LimitSpec.
BinaryOperator<ResultRow>	GroupByQueryQueryToolChest.createMergeFn(Query<ResultRow> query)
BinaryOperator<ResultRow>	GroupingEngine.createMergeFn(Query<ResultRow> queryParam)	See QueryToolChest.createMergeFn(Query) for details, allows GroupByQueryQueryToolChest to delegate implementation to the strategy
Comparator<ResultRow>	GroupByQueryQueryToolChest.createResultComparator(Query<ResultRow> query)
Comparator<ResultRow>	GroupingEngine.createResultComparator(Query<ResultRow> queryParam)	See QueryToolChest.createResultComparator(Query), allows GroupByQueryQueryToolChest to delegate implementation to the strategy
QueryRunner<ResultRow>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner)
QueryRunner<ResultRow>	GroupByQueryQueryToolChest.mergeResults(QueryRunner<ResultRow> runner, boolean willMergeRunner)
Sequence<ResultRow>	GroupingEngine.mergeResults(QueryRunner<ResultRow> baseRunner, GroupByQuery query, ResponseContext responseContext)	Runs a provided QueryRunner on a provided GroupByQuery, 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.
QueryRunner<ResultRow>	GroupByQueryRunnerFactory.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)
QueryRunner<ResultRow>	GroupingEngine.mergeRunners(QueryProcessingPool queryProcessingPool, Iterable<QueryRunner<ResultRow>> queryRunners)	Merges a variety of single-segment query runners into a combined runner.
Sequence<ResultRow>	GroupByQuery.postProcess(Sequence<ResultRow> results)	Apply the havingSpec and limitSpec.
QueryRunner<ResultRow>	GroupByQueryQueryToolChest.preMergeQueryDecoration(QueryRunner<ResultRow> runner)
Sequence<ResultRow>	GroupingEngine.processSubqueryResult(GroupByQuery subquery, GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> subqueryResult, boolean wasQueryPushedDown, GroupByStatsProvider.PerQueryStats perQueryStats)	Called by GroupByQueryQueryToolChest.mergeResults(QueryRunner) when it needs to process a subquery.
Sequence<ResultRow>	GroupingEngine.processSubtotalsSpec(GroupByQuery query, GroupByQueryResources resource, Sequence<ResultRow> queryResult, GroupByStatsProvider.PerQueryStats perQueryStats)	Called by GroupByQueryQueryToolChest.mergeResults(QueryRunner) when it needs to generate subtotals.
Sequence<Object[]>	GroupByQueryQueryToolChest.resultsAsArrays(GroupByQuery query, Sequence<ResultRow> resultSequence)
Optional<Sequence<FrameSignaturePair>>	GroupByQueryQueryToolChest.resultsAsFrames(GroupByQuery query, Sequence<ResultRow> resultSequence, MemoryAllocatorFactory memoryAllocatorFactory, boolean useNestedForUnknownTypes)	This returns a single frame containing the results of the group by query.
static Sequence<ResultRow>	GroupingEngine.wrapSummaryRowIfNeeded(GroupByQuery query, Sequence<ResultRow> process)	Wraps the sequence around if for this query a summary row might be needed in case the input becomes empty.

Constructor parameters in org.apache.druid.query.groupby with type arguments of type ResultRow

Modifier	Constructor	Description
	OrderingAndDimensions(com.google.common.collect.Ordering<ResultRow> rowOrdering, List<DimensionSpec> dimensions)

Uses of ResultRow in org.apache.druid.query.groupby.epinephelinae

Methods in org.apache.druid.query.groupby.epinephelinae that return ResultRow

Modifier and Type	Method	Description
ResultRow	GroupByResultMergeFn.apply(ResultRow arg1, ResultRow arg2)

Methods in org.apache.druid.query.groupby.epinephelinae that return types with arguments of type ResultRow

Modifier and Type	Method	Description
static Pair<Grouper<RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,ResultRow>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, GroupByQuery subquery, GroupByQueryConfig config, DruidProcessingConfig processingConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, ReferenceCountingResourceHolder<ByteBuffer> combineBufferHolder, int concurrencyHint, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, com.google.common.util.concurrent.ListeningExecutorService grouperSorter, int priority, boolean hasQueryTimeout, long queryTimeoutAt, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats)	Create a Grouper that groups according to the dimensions and aggregators in "query", along with an Accumulator that accepts ResultRows and forwards them to the grouper.
static Pair<Grouper<RowBasedGrouperHelper.RowBasedKey>,Accumulator<AggregateResult,ResultRow>>	RowBasedGrouperHelper.createGrouperAccumulatorPair(GroupByQuery query, GroupByQuery subquery, GroupByQueryConfig config, DruidProcessingConfig processingConfig, com.google.common.base.Supplier<ByteBuffer> bufferSupplier, LimitedTemporaryStorage temporaryStorage, com.fasterxml.jackson.databind.ObjectMapper spillMapper, int mergeBufferSize, GroupByStatsProvider.PerQueryStats perQueryStats)	Create a single-threaded grouper and accumulator.
static CloseableGrouperIterator<RowBasedGrouperHelper.RowBasedKey,ResultRow>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, Closeable closeable)
static CloseableGrouperIterator<RowBasedGrouperHelper.RowBasedKey,ResultRow>	RowBasedGrouperHelper.makeGrouperIterator(Grouper<RowBasedGrouperHelper.RowBasedKey> grouper, GroupByQuery query, List<DimensionSpec> dimsToInclude, Closeable closeable)
static Sequence<ResultRow>	GroupByQueryEngine.process(GroupByQuery query, TimeBoundaryInspector timeBoundaryInspector, CursorHolder cursorHolder, CursorBuildSpec buildSpec, ByteBuffer processingBuffer, org.joda.time.DateTime fudgeTimestamp, GroupByQueryConfig querySpecificConfig, DruidProcessingConfig processingConfig)
Sequence<ResultRow>	GroupByRowProcessor.ResultSupplier.results(List<DimensionSpec> dimensionsToInclude)	Return a result sequence.
Sequence<ResultRow>	GroupByMergingQueryRunner.run(QueryPlus<ResultRow> queryPlus, ResponseContext responseContext)

Methods in org.apache.druid.query.groupby.epinephelinae with parameters of type ResultRow

Modifier and Type	Method	Description
ResultRow	GroupByResultMergeFn.apply(ResultRow arg1, ResultRow arg2)

Method parameters in org.apache.druid.query.groupby.epinephelinae with type arguments of type ResultRow

Modifier and Type	Method	Description
static ColumnSelectorFactory	RowBasedGrouperHelper.createResultRowBasedColumnSelectorFactory(GroupByQuery query, com.google.common.base.Supplier<ResultRow> supplier, RowSignature.Finalization finalization)	Creates a ColumnSelectorFactory that can read rows which originate as results of the provided "query".
static GroupByRowProcessor.ResultSupplier	GroupByRowProcessor.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 a GroupByRowProcessor.ResultSupplier.
Sequence<ResultRow>	GroupByMergingQueryRunner.run(QueryPlus<ResultRow> queryPlus, ResponseContext responseContext)

Constructor parameters in org.apache.druid.query.groupby.epinephelinae with type arguments of type ResultRow

Modifier	Constructor	Description
	GroupByMergingQueryRunner(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 ResultRow in org.apache.druid.query.groupby.epinephelinae.column

Methods in org.apache.druid.query.groupby.epinephelinae.column with parameters of type ResultRow

Modifier and Type	Method	Description
void	FixedWidthGroupByColumnSelectorStrategy.processValueFromGroupingKey(GroupByColumnSelectorPlus selectorPlus, ByteBuffer key, ResultRow resultRow, int keyBufferPosition)
void	GroupByColumnSelectorStrategy.processValueFromGroupingKey(GroupByColumnSelectorPlus selectorPlus, ByteBuffer key, ResultRow resultRow, int keyBufferPosition)	Read a value from a grouping key and add it to the group by query result row, using the output name specified in a DimensionSpec.
void	KeyMappingMultiValueGroupByColumnSelectorStrategy.DictionaryBuilding.processValueFromGroupingKey(GroupByColumnSelectorPlus selectorPlus, ByteBuffer key, ResultRow resultRow, int keyBufferPosition)
void	KeyMappingMultiValueGroupByColumnSelectorStrategy.PrebuiltDictionary.processValueFromGroupingKey(GroupByColumnSelectorPlus selectorPlus, ByteBuffer key, ResultRow resultRow, int keyBufferPosition)

Uses of ResultRow in org.apache.druid.query.groupby.epinephelinae.vector

Methods in org.apache.druid.query.groupby.epinephelinae.vector that return types with arguments of type ResultRow

Modifier and Type	Method	Description
static Sequence<ResultRow>	VectorGroupByEngine.process(GroupByQuery query, TimeBoundaryInspector timeBoundaryInspector, CursorHolder cursorHolder, ByteBuffer processingBuffer, org.joda.time.DateTime fudgeTimestamp, org.joda.time.Interval interval, GroupByQueryConfig config, DruidProcessingConfig processingConfig)

Methods in org.apache.druid.query.groupby.epinephelinae.vector with parameters of type ResultRow

Modifier and Type	Method	Description
final void	DictionaryBuildingGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	DoubleGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	FloatGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	GroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)	Write key parts for this column into a particular result row.
void	LongGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	NilGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	NullableDoubleGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	NullableFloatGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	NullableLongGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)
void	SingleValueStringGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)

Uses of ResultRow in org.apache.druid.query.groupby.having

Methods in org.apache.druid.query.groupby.having with parameters of type ResultRow

Modifier and Type	Method	Description
boolean	AlwaysHavingSpec.eval(ResultRow row)
boolean	AndHavingSpec.eval(ResultRow row)
boolean	DimensionSelectorHavingSpec.eval(ResultRow row)
boolean	DimFilterHavingSpec.eval(ResultRow row)
boolean	EqualToHavingSpec.eval(ResultRow row)
boolean	GreaterThanHavingSpec.eval(ResultRow row)
boolean	HavingSpec.eval(ResultRow row)	Evaluates if a given row satisfies the having spec.
boolean	LessThanHavingSpec.eval(ResultRow row)
boolean	NeverHavingSpec.eval(ResultRow row)
boolean	NotHavingSpec.eval(ResultRow row)
boolean	OrHavingSpec.eval(ResultRow row)

Uses of ResultRow in org.apache.druid.query.groupby.orderby

Methods in org.apache.druid.query.groupby.orderby that return types with arguments of type ResultRow

Modifier and Type	Method	Description
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	DefaultLimitSpec.build(GroupByQuery query)
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	DefaultLimitSpec.build(GroupByQuery query)
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	LimitSpec.build(GroupByQuery query)	Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	LimitSpec.build(GroupByQuery query)	Returns a function that applies a limit to an input sequence that is assumed to be sorted on dimensions.
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	NoopLimitSpec.build(GroupByQuery query)
com.google.common.base.Function<Sequence<ResultRow>,Sequence<ResultRow>>	NoopLimitSpec.build(GroupByQuery query)

Uses of ResultRow in org.apache.druid.query.rowsandcols

Method parameters in org.apache.druid.query.rowsandcols with type arguments of type ResultRow

Modifier and Type	Method	Description
static MapOfColumnsRowsAndColumns	MapOfColumnsRowsAndColumns.fromResultRow(ArrayList<ResultRow> objs, RowSignature signature)
static MapOfColumnsRowsAndColumns	MapOfColumnsRowsAndColumns.fromResultRowTillIndex(ArrayList<ResultRow> objs, RowSignature signature, int index)

Uses of ResultRow in org.apache.druid.segment.virtual

Methods in org.apache.druid.segment.virtual with parameters of type ResultRow

Modifier and Type	Method	Description
void	ExpressionDeferredGroupByVectorColumnSelector.writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)