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

Class DictionaryBuildingGroupByVectorColumnSelector<T>

java.lang.Object

org.apache.druid.query.groupby.epinephelinae.vector.DictionaryBuildingGroupByVectorColumnSelector<T>

All Implemented Interfaces:

GroupingSelector, GroupByVectorColumnSelector

Direct Known Subclasses:

DictionaryBuildingComplexGroupByVectorColumnSelector, DictionaryBuildingSingleValueStringGroupByVectorColumnSelector

public abstract class DictionaryBuildingGroupByVectorColumnSelector<T>
extends Object
implements GroupByVectorColumnSelector

Base class for GroupByVectorColumnSelector that build dictionaries for values that are not natively dictionary-encoded.

See Also:

• the nonvectorized version

Field Summary

Fields

Modifier and Type	Field	Description
protected final DimensionIdCodec<T>	dimensionIdCodec
protected final VectorObjectSelector	selector

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DictionaryBuildingGroupByVectorColumnSelector(VectorObjectSelector selector, DimensionIdCodec<T> dimensionIdCodec)

Method Summary

Modifier and Type	Method	Description
protected abstract T	convertValue(Object rawValue)	Convert raw value from the vector to the appropriate type for this selector.
final int	getGroupingKeySize()	Get the size in bytes of the key parts generated by this column.
final void	reset()	Reset any internal state held by this selector.
final int	writeKeys(org.apache.datasketches.memory.WritableMemory keySpace, int keySize, int keyOffset, int startRow, int endRow)	Write key parts for this column, from startRow (inclusive) to endRow (exclusive), into keySpace starting at keyOffset.
final void	writeKeyToResultRow(MemoryPointer keyMemory, int keyOffset, ResultRow resultRow, int resultRowPosition)	Write key parts for this column into a particular result row.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.query.groupby.epinephelinae.GroupingSelector

getValueCardinality

Field Details

selector

protected final VectorObjectSelector selector

dimensionIdCodec

protected final DimensionIdCodec<T> dimensionIdCodec

Constructor Details

DictionaryBuildingGroupByVectorColumnSelector

protected DictionaryBuildingGroupByVectorColumnSelector(VectorObjectSelector selector,
 DimensionIdCodec<T> dimensionIdCodec)

Method Details

getGroupingKeySize

public final int getGroupingKeySize()

Description copied from interface: GroupByVectorColumnSelector

Get the size in bytes of the key parts generated by this column.

Specified by:

getGroupingKeySize in interface GroupByVectorColumnSelector

writeKeys

public final int writeKeys(org.apache.datasketches.memory.WritableMemory keySpace,
 int keySize,
 int keyOffset,
 int startRow,
 int endRow)

Description copied from interface: GroupByVectorColumnSelector

Write key parts for this column, from startRow (inclusive) to endRow (exclusive), into keySpace starting at keyOffset.

Specified by:

writeKeys in interface GroupByVectorColumnSelector

Parameters:

keySpace - key memory

keySize - size of the overall key (not just the part for this column)

keyOffset - starting position for the first key part within keySpace

startRow - starting row (inclusive) within the current vector

endRow - ending row (exclusive) within the current vector

Returns:

estimated increase in internal state footprint, in bytes, as a result of this operation. May be zero if memory did not increase as a result of this operation. Will not be negative.

writeKeyToResultRow

public final void writeKeyToResultRow(MemoryPointer keyMemory,
 int keyOffset,
 ResultRow resultRow,
 int resultRowPosition)

Description copied from interface: GroupByVectorColumnSelector

Write key parts for this column into a particular result row.

Specified by:

writeKeyToResultRow in interface GroupByVectorColumnSelector

Parameters:

keyMemory - key memory

keyOffset - starting position for this key part within keyMemory (starting from MemoryPointer.position)

resultRow - result row to receive key parts

resultRowPosition - position within the result row for this key part

reset

public final void reset()

Description copied from interface: GroupByVectorColumnSelector

Reset any internal state held by this selector. After this method is called, any memory previously written by GroupByVectorColumnSelector.writeKeys(org.apache.datasketches.memory.WritableMemory, int, int, int, int) must be considered unreadable. Calling GroupByVectorColumnSelector.writeKeyToResultRow(org.apache.druid.query.groupby.epinephelinae.collection.MemoryPointer, int, org.apache.druid.query.groupby.ResultRow, int) on that memory has undefined behavior.

Specified by:

reset in interface GroupByVectorColumnSelector

convertValue

protected abstract T convertValue(Object rawValue)

Convert raw value from the vector to the appropriate type for this selector.