org.apache.druid.sql.calcite.expression

Class OperatorConversions

java.lang.Object

org.apache.druid.sql.calcite.expression.OperatorConversions

public class OperatorConversions
extends Object

Utilities for assisting in writing SqlOperatorConversion implementations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	OperatorConversions.OperatorBuilder

Constructor Summary

Constructors

Constructor and Description
OperatorConversions()

Method Summary

Modifier and Type	Method and Description
static DruidExpression	convertCall(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, DruidExpression.DruidExpressionCreator expressionFunction)
static DruidExpression	convertCall(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, String functionName) Deprecated.
static DruidExpression	convertCall(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, String functionName, Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction) Deprecated.
static DruidExpression	convertCallBuilder(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, DruidExpression.ExpressionGenerator expressionGenerator)
static DruidExpression	convertCallWithPostAggOperands(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, DruidExpression.DruidExpressionCreator expressionFunction, PostAggregatorVisitor postAggregatorVisitor)
static DruidExpression	convertDirectCall(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, String functionName)
static DruidExpression	convertDirectCallWithExtraction(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, String functionName, Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction)
static DirectOperatorConversion	druidBinaryLongFn(String sqlOperator, String druidFunctionName)
static DirectOperatorConversion	druidUnaryDoubleFn(String sqlOperator, String druidFunctionName)
static DirectOperatorConversion	druidUnaryLongFn(String sqlOperator, String druidFunctionName)
static <T> T	getOperandWithDefault(List<org.apache.calcite.rex.RexNode> operands, int i, Function<org.apache.calcite.rex.RexNode,T> f, T defaultReturnValue) Gets operand "i" from "operands", or returns a default value if it doesn't exist (operands is too short) or is null.
static OperatorConversions.OperatorBuilder	operatorBuilder(String name) Returns a builder that helps SqlOperatorConversion implementations create the SqlFunction objects they need to return from SqlOperatorConversion.calciteOperator().
static PostAggregator	toPostAggregator(PlannerContext plannerContext, RowSignature rowSignature, org.apache.calcite.rex.RexNode rexNode, PostAggregatorVisitor postAggregatorVisitor) Translate a Calcite RexNode to a Druid PostAggregator

Methods inherited from class java.lang.Object

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

Constructor Detail

OperatorConversions

public OperatorConversions()

Method Detail

convertDirectCall

@Nullable
public static DruidExpression convertDirectCall(PlannerContext plannerContext,
                                                          RowSignature rowSignature,
                                                          org.apache.calcite.rex.RexNode rexNode,
                                                          String functionName)

convertDirectCallWithExtraction

@Nullable
public static DruidExpression convertDirectCallWithExtraction(PlannerContext plannerContext,
                                                                        RowSignature rowSignature,
                                                                        org.apache.calcite.rex.RexNode rexNode,
                                                                        String functionName,
                                                                        Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction)

convertCallBuilder

@Nullable
public static DruidExpression convertCallBuilder(PlannerContext plannerContext,
                                                           RowSignature rowSignature,
                                                           org.apache.calcite.rex.RexNode rexNode,
                                                           DruidExpression.ExpressionGenerator expressionGenerator)

convertCall

@Nullable
public static DruidExpression convertCall(PlannerContext plannerContext,
                                                    RowSignature rowSignature,
                                                    org.apache.calcite.rex.RexNode rexNode,
                                                    DruidExpression.DruidExpressionCreator expressionFunction)

convertCall

@Deprecated
 @Nullable
public static DruidExpression convertCall(PlannerContext plannerContext,
                                                                 RowSignature rowSignature,
                                                                 org.apache.calcite.rex.RexNode rexNode,
                                                                 String functionName)

Deprecated.

convertCall

@Deprecated
 @Nullable
public static DruidExpression convertCall(PlannerContext plannerContext,
                                                                 RowSignature rowSignature,
                                                                 org.apache.calcite.rex.RexNode rexNode,
                                                                 String functionName,
                                                                 Function<List<DruidExpression>,SimpleExtraction> simpleExtractionFunction)

Deprecated.

getOperandWithDefault

public static <T> T getOperandWithDefault(List<org.apache.calcite.rex.RexNode> operands,
                                          int i,
                                          Function<org.apache.calcite.rex.RexNode,T> f,
                                          T defaultReturnValue)

Gets operand "i" from "operands", or returns a default value if it doesn't exist (operands is too short) or is null.

convertCallWithPostAggOperands

@Nullable
public static DruidExpression convertCallWithPostAggOperands(PlannerContext plannerContext,
                                                                       RowSignature rowSignature,
                                                                       org.apache.calcite.rex.RexNode rexNode,
                                                                       DruidExpression.DruidExpressionCreator expressionFunction,
                                                                       PostAggregatorVisitor postAggregatorVisitor)

toPostAggregator

@Nullable
public static PostAggregator toPostAggregator(PlannerContext plannerContext,
                                                        RowSignature rowSignature,
                                                        org.apache.calcite.rex.RexNode rexNode,
                                                        PostAggregatorVisitor postAggregatorVisitor)

Translate a Calcite RexNode to a Druid PostAggregator

Parameters:

plannerContext - SQL planner context

rowSignature - signature of the rows to be extracted from

rexNode - expression meant to be applied on top of the rows

postAggregatorVisitor - visitor that manages postagg names and tracks postaggs that were created by the translation

Returns:

rexNode referring to fields in rowOrder, or null if not possible

operatorBuilder

public static OperatorConversions.OperatorBuilder operatorBuilder(String name)

Returns a builder that helps SqlOperatorConversion implementations create the SqlFunction objects they need to return from SqlOperatorConversion.calciteOperator().

druidUnaryLongFn

public static DirectOperatorConversion druidUnaryLongFn(String sqlOperator,
                                                        String druidFunctionName)

druidBinaryLongFn

public static DirectOperatorConversion druidBinaryLongFn(String sqlOperator,
                                                         String druidFunctionName)

druidUnaryDoubleFn

public static DirectOperatorConversion druidUnaryDoubleFn(String sqlOperator,
                                                          String druidFunctionName)