Package org.apache.druid.segment.vector

Class RemapVectorColumnSelectorFactory

java.lang.Object

org.apache.druid.segment.vector.RemapVectorColumnSelectorFactory

All Implemented Interfaces:

Expr.InputBindingInspector, ColumnInspector, VectorColumnSelectorFactory

public class RemapVectorColumnSelectorFactory
extends Object
implements VectorColumnSelectorFactory

Constructor Summary

Constructors

Constructor	Description
RemapVectorColumnSelectorFactory(VectorColumnSelectorFactory delegate, Map<String,String> remap)

Method Summary

Modifier and Type	Method	Description
ColumnCapabilities	getColumnCapabilities(String column)	Returns capabilities of a particular column, or null if the column doesn't exist.
int	getMaxVectorSize()	Returns the maximum vector size for the VectorCursor that generated this object.
ReadableVectorInspector	getReadableVectorInspector()	Returns a ReadableVectorInspector for the VectorCursor that generated this object.
ExpressionType	getType(String name)	Get the ExpressionType from the backing store for a given identifier (this is likely a column, but could be other things depending on the backing adapter)
GroupByVectorColumnSelector	makeGroupByVectorColumnSelector(String column, DeferExpressionDimensions deferExpressionDimensions)	Returns a group-by selector.
MultiValueDimensionVectorSelector	makeMultiValueDimensionSelector(DimensionSpec dimensionSpec)	Returns a dictionary encoded, string-typed, multi-value-per-row column selector.
VectorObjectSelector	makeObjectSelector(String column)	Returns an object selector.
SingleValueDimensionVectorSelector	makeSingleValueDimensionSelector(DimensionSpec dimensionSpec)	Returns a dictionary encoded, string-typed, single-value-per-row column selector.
VectorValueSelector	makeValueSelector(String column)	Returns a primitive column selector.

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.math.expr.Expr.InputBindingInspector

areNumeric, areNumeric, areSameTypes, areSameTypes, areScalar, areScalar, canVectorize, canVectorize

Constructor Details

RemapVectorColumnSelectorFactory

public RemapVectorColumnSelectorFactory(VectorColumnSelectorFactory delegate,
 Map<String,String> remap)

Method Details

getReadableVectorInspector

public ReadableVectorInspector getReadableVectorInspector()

Description copied from interface: VectorColumnSelectorFactory

Returns a ReadableVectorInspector for the VectorCursor that generated this object.

Specified by:

getReadableVectorInspector in interface VectorColumnSelectorFactory

getMaxVectorSize

public int getMaxVectorSize()

Description copied from interface: VectorColumnSelectorFactory

Returns the maximum vector size for the VectorCursor that generated this object.

Specified by:

getMaxVectorSize in interface VectorColumnSelectorFactory

See Also:

• VectorSizeInspector.getMaxVectorSize()

makeSingleValueDimensionSelector

public SingleValueDimensionVectorSelector makeSingleValueDimensionSelector(DimensionSpec dimensionSpec)

Description copied from interface: VectorColumnSelectorFactory

Returns a dictionary encoded, string-typed, single-value-per-row column selector. Should only be called on columns where VectorColumnSelectorFactory.getColumnCapabilities(java.lang.String) indicates they return STRING, or on nonexistent columns. Since the selector created with this method operates directly on the dictionary encoded input, STRING values must be translated from the dictionary id for a given row value using DimensionDictionarySelector.lookupName(int), but this selector can prove optimal for operations which can be done directly on the underlying dictionary ids, such as grouping within a segment. If you need to write code that adapts to different input types, you should write a VectorColumnProcessorFactory and use one of the ColumnProcessors.makeVectorProcessor(java.lang.String, org.apache.druid.segment.VectorColumnProcessorFactory<T>, org.apache.druid.segment.vector.VectorColumnSelectorFactory) functions instead of using this method.

Specified by:

makeSingleValueDimensionSelector in interface VectorColumnSelectorFactory

makeMultiValueDimensionSelector

public MultiValueDimensionVectorSelector makeMultiValueDimensionSelector(DimensionSpec dimensionSpec)

Description copied from interface: VectorColumnSelectorFactory

Returns a dictionary encoded, string-typed, multi-value-per-row column selector. Should only be called on columns where VectorColumnSelectorFactory.getColumnCapabilities(java.lang.String) indicates they return STRING. Unlike VectorColumnSelectorFactory.makeSingleValueDimensionSelector(org.apache.druid.query.dimension.DimensionSpec), this should not be called on nonexistent columns. If you need to write code that adapts to different input types, you should write a VectorColumnProcessorFactory and use one of the ColumnProcessors.makeVectorProcessor(java.lang.String, org.apache.druid.segment.VectorColumnProcessorFactory<T>, org.apache.druid.segment.vector.VectorColumnSelectorFactory) functions instead of using this method.

Specified by:

makeMultiValueDimensionSelector in interface VectorColumnSelectorFactory

makeValueSelector

public VectorValueSelector makeValueSelector(String column)

Description copied from interface: VectorColumnSelectorFactory

Returns a primitive column selector. Should only be called on columns where VectorColumnSelectorFactory.getColumnCapabilities(java.lang.String) indicates they return DOUBLE, FLOAT, or LONG, or on nonexistent columns. If you need to write code that adapts to different input types, you should write a VectorColumnProcessorFactory and use one of the ColumnProcessors.makeVectorProcessor(java.lang.String, org.apache.druid.segment.VectorColumnProcessorFactory<T>, org.apache.druid.segment.vector.VectorColumnSelectorFactory) functions instead of using this method.

Specified by:

makeValueSelector in interface VectorColumnSelectorFactory

makeObjectSelector

public VectorObjectSelector makeObjectSelector(String column)

Description copied from interface: VectorColumnSelectorFactory

Returns an object selector. Should only be called on columns where VectorColumnSelectorFactory.getColumnCapabilities(java.lang.String) indicates that they return STRING, ARRAY, or COMPLEX, or on nonexistent columns. For STRING, this is needed if values are not dictionary encoded, such as computed virtual columns, or can optionally be used in place of SingleValueDimensionVectorSelector when using the dictionary isn't helpful. Currently, this should only be called on single valued STRING inputs (multi-value STRING vector object selector is not yet implemented). If you need to write code that adapts to different input types, you should write a VectorColumnProcessorFactory and use one of the ColumnProcessors.makeVectorProcessor(java.lang.String, org.apache.druid.segment.VectorColumnProcessorFactory<T>, org.apache.druid.segment.vector.VectorColumnSelectorFactory) functions instead of using this method.

Specified by:

makeObjectSelector in interface VectorColumnSelectorFactory

getColumnCapabilities

@Nullable
public ColumnCapabilities getColumnCapabilities(String column)

Description copied from interface: VectorColumnSelectorFactory

Returns capabilities of a particular column, or null if the column doesn't exist. Unlike ColumnSelectorFactory, null does not potentially indicate a dynamically discovered column.

Specified by:

getColumnCapabilities in interface ColumnInspector

Specified by:

getColumnCapabilities in interface VectorColumnSelectorFactory

Parameters:

column - column name

Returns:

capabilities, or null if the column doesn't exist.

getType

@Nullable
public ExpressionType getType(String name)

Description copied from interface: Expr.InputBindingInspector

Get the ExpressionType from the backing store for a given identifier (this is likely a column, but could be other things depending on the backing adapter)

Specified by:

getType in interface ColumnInspector

Specified by:

getType in interface Expr.InputBindingInspector

makeGroupByVectorColumnSelector

public GroupByVectorColumnSelector makeGroupByVectorColumnSelector(String column,
 DeferExpressionDimensions deferExpressionDimensions)

Description copied from interface: VectorColumnSelectorFactory

Returns a group-by selector. Allows columns to control their own grouping behavior.

Specified by:

makeGroupByVectorColumnSelector in interface VectorColumnSelectorFactory

Parameters:

column - column name

deferExpressionDimensions - active value of GroupByQueryConfig.CTX_KEY_DEFER_EXPRESSION_DIMENSIONS