Package org.apache.druid.sql.calcite.rel

Class VirtualColumnRegistry

java.lang.Object

org.apache.druid.sql.calcite.rel.VirtualColumnRegistry

public class VirtualColumnRegistry
extends Object

Provides facilities to create and re-use VirtualColumn definitions for dimensions, filters, and filtered aggregators while constructing a DruidQuery.

Method Summary

Modifier and Type	Method	Description
VirtualColumns	build(Set<String> exclude)
static VirtualColumnRegistry	create(RowSignature rowSignature, ExpressionParser expressionParser, boolean forceExpressionVirtualColumns)
List<DruidExpression>	findVirtualColumnExpressions(List<String> allColumns)	Given a list of column names, find any corresponding VirtualColumn with the same name
Collection<? extends VirtualColumn>	getAllVirtualColumns(List<String> requiredColumns)
RowSignature	getFullRowSignature()	Get a signature representing the base signature plus all registered virtual columns.
String	getOrCreateVirtualColumnForExpression(DruidExpression expression, org.apache.calcite.rel.type.RelDataType typeHint)	Get existing or create new VirtualColumn for a given DruidExpression and RelDataType
String	getOrCreateVirtualColumnForExpression(DruidExpression expression, ColumnType typeHint)	Get existing or create new VirtualColumn for a given DruidExpression and hinted ColumnType.
VirtualColumn	getOrCreateVirtualColumnForExpression(PlannerContext plannerContext, DruidExpression expression, ColumnType valueType)	Deprecated. use getOrCreateVirtualColumnForExpression(DruidExpression, ColumnType) instead
VirtualColumn	getVirtualColumn(String virtualColumnName)	Get existing virtual column by column name.
boolean	isEmpty()
boolean	isVirtualColumnDefined(String virtualColumnName)	Check if a VirtualColumn is defined by column name

Methods inherited from class java.lang.Object

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

Method Details

create

public static VirtualColumnRegistry create(RowSignature rowSignature,
 ExpressionParser expressionParser,
 boolean forceExpressionVirtualColumns)

isEmpty

public boolean isEmpty()

isVirtualColumnDefined

public boolean isVirtualColumnDefined(String virtualColumnName)

Check if a VirtualColumn is defined by column name

getOrCreateVirtualColumnForExpression

public String getOrCreateVirtualColumnForExpression(DruidExpression expression,
 ColumnType typeHint)

Get existing or create new VirtualColumn for a given DruidExpression and hinted ColumnType.

getOrCreateVirtualColumnForExpression

public String getOrCreateVirtualColumnForExpression(DruidExpression expression,
 org.apache.calcite.rel.type.RelDataType typeHint)

Get existing or create new VirtualColumn for a given DruidExpression and RelDataType

getVirtualColumn

@Nullable
public VirtualColumn getVirtualColumn(String virtualColumnName)

Get existing virtual column by column name.

Returns:

null if a virtual column for the given name does not exist.

getFullRowSignature

public RowSignature getFullRowSignature()

Get a signature representing the base signature plus all registered virtual columns.

findVirtualColumnExpressions

public List<DruidExpression> findVirtualColumnExpressions(List<String> allColumns)

Given a list of column names, find any corresponding VirtualColumn with the same name

getAllVirtualColumns

public Collection<? extends VirtualColumn> getAllVirtualColumns(List<String> requiredColumns)

getOrCreateVirtualColumnForExpression

@Deprecated
public VirtualColumn getOrCreateVirtualColumnForExpression(PlannerContext plannerContext,
 DruidExpression expression,
 ColumnType valueType)

Deprecated.

use getOrCreateVirtualColumnForExpression(DruidExpression, ColumnType) instead

build

public VirtualColumns build(Set<String> exclude)