org.apache.flink.table.planner.calcite

Class FlinkOperatorBinding

java.lang.Object

org.apache.calcite.sql.SqlOperatorBinding

org.apache.flink.table.planner.calcite.FlinkOperatorBinding

public class FlinkOperatorBinding
extends org.apache.calcite.sql.SqlOperatorBinding

The proxy implementation of SqlOperatorBinding can be used to correct the operator type when using named parameter.

Field Summary

Fields inherited from class org.apache.calcite.sql.SqlOperatorBinding

typeFactory

Constructor Summary

Constructors

Constructor and Description
FlinkOperatorBinding(org.apache.calcite.sql.SqlOperatorBinding sqlOperatorBinding)

Method Summary

Modifier and Type	Method and Description
List<org.apache.calcite.rel.type.RelDataType>	collectOperandTypes()
@Nullable String	getColumnListParamInfo(int ordinal, String paramName, List<String> columnList)
@Nullable org.apache.calcite.rel.type.RelDataType	getCursorOperand(int ordinal)
int	getGroupCount()
int	getIntLiteralOperand(int ordinal)
int	getOperandCount()
@Nullable Comparable	getOperandLiteralValue(int ordinal)
<T> T	getOperandLiteralValue(int ordinal, Class<T> clazz)
@Nullable Object	getOperandLiteralValue(int ordinal, org.apache.calcite.rel.type.RelDataType type)
org.apache.calcite.sql.validate.SqlMonotonicity	getOperandMonotonicity(int ordinal)
org.apache.calcite.rel.type.RelDataType	getOperandType(int ordinal)
org.apache.calcite.sql.SqlOperator	getOperator()
@Nullable String	getStringLiteralOperand(int ordinal)
org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()
boolean	hasFilter()
boolean	isOperandLiteral(int ordinal, boolean allowCast)
boolean	isOperandNull(int ordinal, boolean allowCast)
org.apache.calcite.runtime.CalciteException	newError(org.apache.calcite.runtime.Resources.ExInst<org.apache.calcite.sql.validate.SqlValidatorException> e)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkOperatorBinding

public FlinkOperatorBinding(org.apache.calcite.sql.SqlOperatorBinding sqlOperatorBinding)

Method Detail

getOperandCount

public int getOperandCount()

Specified by:

getOperandCount in class org.apache.calcite.sql.SqlOperatorBinding

getOperandType

public org.apache.calcite.rel.type.RelDataType getOperandType(int ordinal)

Specified by:

getOperandType in class org.apache.calcite.sql.SqlOperatorBinding

newError

public org.apache.calcite.runtime.CalciteException newError(org.apache.calcite.runtime.Resources.ExInst<org.apache.calcite.sql.validate.SqlValidatorException> e)

Specified by:

newError in class org.apache.calcite.sql.SqlOperatorBinding

getGroupCount

public int getGroupCount()

Overrides:

getGroupCount in class org.apache.calcite.sql.SqlOperatorBinding

hasFilter

public boolean hasFilter()

Overrides:

hasFilter in class org.apache.calcite.sql.SqlOperatorBinding

getOperator

public org.apache.calcite.sql.SqlOperator getOperator()

Overrides:

getOperator in class org.apache.calcite.sql.SqlOperatorBinding

getTypeFactory

public org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()

Overrides:

getTypeFactory in class org.apache.calcite.sql.SqlOperatorBinding

getStringLiteralOperand

public @Nullable String getStringLiteralOperand(int ordinal)

Overrides:

getStringLiteralOperand in class org.apache.calcite.sql.SqlOperatorBinding

getIntLiteralOperand

public int getIntLiteralOperand(int ordinal)

Overrides:

getIntLiteralOperand in class org.apache.calcite.sql.SqlOperatorBinding

isOperandNull

public boolean isOperandNull(int ordinal,
                             boolean allowCast)

Overrides:

isOperandNull in class org.apache.calcite.sql.SqlOperatorBinding

isOperandLiteral

public boolean isOperandLiteral(int ordinal,
                                boolean allowCast)

Overrides:

isOperandLiteral in class org.apache.calcite.sql.SqlOperatorBinding

getOperandLiteralValue

public @Nullable Object getOperandLiteralValue(int ordinal,
                                               org.apache.calcite.rel.type.RelDataType type)

Overrides:

getOperandLiteralValue in class org.apache.calcite.sql.SqlOperatorBinding

getOperandLiteralValue

public @Nullable Comparable getOperandLiteralValue(int ordinal)

Overrides:

getOperandLiteralValue in class org.apache.calcite.sql.SqlOperatorBinding

getOperandMonotonicity

public org.apache.calcite.sql.validate.SqlMonotonicity getOperandMonotonicity(int ordinal)

Overrides:

getOperandMonotonicity in class org.apache.calcite.sql.SqlOperatorBinding

collectOperandTypes

public List<org.apache.calcite.rel.type.RelDataType> collectOperandTypes()

Overrides:

collectOperandTypes in class org.apache.calcite.sql.SqlOperatorBinding

getCursorOperand

public @Nullable org.apache.calcite.rel.type.RelDataType getCursorOperand(int ordinal)

Overrides:

getCursorOperand in class org.apache.calcite.sql.SqlOperatorBinding

getColumnListParamInfo

public @Nullable String getColumnListParamInfo(int ordinal,
                                               String paramName,
                                               List<String> columnList)

Overrides:

getColumnListParamInfo in class org.apache.calcite.sql.SqlOperatorBinding

getOperandLiteralValue

public <T> T getOperandLiteralValue(int ordinal,
                                    Class<T> clazz)

Overrides:

getOperandLiteralValue in class org.apache.calcite.sql.SqlOperatorBinding