Package org.apache.druid.query.groupby.epinephelinae.vector

Class VectorGroupByEngine

java.lang.Object

org.apache.druid.query.groupby.epinephelinae.vector.VectorGroupByEngine

public class VectorGroupByEngine
extends Object

Contains logic to process a groupBy query on a single CursorFactory in a vectorized manner. This code runs on anything that processes CursorFactory directly, typically data servers like Historicals.

Used for vectorized processing by GroupingEngine.process(org.apache.druid.query.groupby.GroupByQuery, org.apache.druid.segment.CursorFactory, org.apache.druid.segment.TimeBoundaryInspector, org.apache.druid.collections.NonBlockingPool<java.nio.ByteBuffer>, org.apache.druid.query.groupby.GroupByQueryMetrics).

See Also:

• for non-vectorized version of this logic

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

process

public static Sequence<ResultRow> process(GroupByQuery query,
 @Nullable
 TimeBoundaryInspector timeBoundaryInspector,
 CursorHolder cursorHolder,
 ByteBuffer processingBuffer,
 @Nullable
 org.joda.time.DateTime fudgeTimestamp,
 org.joda.time.Interval interval,
 GroupByQueryConfig config,
 DruidProcessingConfig processingConfig)

canVectorizeDimensions

public static boolean canVectorizeDimensions(ColumnInspector inspector,
 List<DimensionSpec> dimensions)