org.apache.flink.table.planner.calcite

Class FlinkCalciteSqlValidator

java.lang.Object

org.apache.calcite.sql.validate.SqlValidatorImpl

org.apache.flink.table.planner.calcite.FlinkCalciteSqlValidator

All Implemented Interfaces:

org.apache.calcite.sql.validate.SqlValidator, org.apache.calcite.sql.validate.SqlValidatorWithHints

@Internal
public final class FlinkCalciteSqlValidator
extends SqlValidatorImpl

Extends Calcite's SqlValidator by Flink-specific behavior.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.calcite.sql.validate.SqlValidatorImpl

SqlValidatorImpl.DmlNamespace, SqlValidatorImpl.FunctionParamInfo, SqlValidatorImpl.IdInfo, SqlValidatorImpl.Status

Nested classes/interfaces inherited from interface org.apache.calcite.sql.validate.SqlValidator

org.apache.calcite.sql.validate.SqlValidator.Config

Field Summary

Fields inherited from class org.apache.calcite.sql.validate.SqlValidatorImpl

callToOperandTypesMap, functionCallStack, idPositions, namespaces, scopes, TRACER, typeFactory, unknownType, UPDATE_ANON_PREFIX, UPDATE_SRC_ALIAS, UPDATE_TGT_ALIAS

Constructor Summary

Constructors

Constructor and Description
FlinkCalciteSqlValidator(org.apache.calcite.sql.SqlOperatorTable opTab, org.apache.calcite.sql.validate.SqlValidatorCatalogReader catalogReader, org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.sql.validate.SqlValidator.Config config)

Method Summary

Modifier and Type	Method and Description
Optional<org.apache.calcite.rel.type.RelDataType>	getExpectedOutputType(org.apache.calcite.sql.SqlNode sqlNode)
void	setExpectedOutputType(org.apache.calcite.sql.SqlNode sqlNode, org.apache.calcite.rel.type.RelDataType expectedOutputType)
void	validateColumnListParams(org.apache.calcite.sql.SqlFunction function, List<org.apache.calcite.rel.type.RelDataType> argTypes, List<org.apache.calcite.sql.SqlNode> operands)
protected void	validateJoin(org.apache.calcite.sql.SqlJoin join, org.apache.calcite.sql.validate.SqlValidatorScope scope)
void	validateLiteral(org.apache.calcite.sql.SqlLiteral literal)

Methods inherited from class org.apache.calcite.sql.validate.SqlValidatorImpl

addToSelectList, checkTypeAssignment, config, createMatchRecognizeNameSpace, createPivotNameSpace, createSelectNamespace, createSetopNamespace, createSourceSelectForDelete, createSourceSelectForUpdate, createTargetRowType, createUnpivotNameSpace, declareCursor, deriveAlias, deriveConstructorType, deriveType, expand, expandGroupByOrHavingExpr, expandOrderExpr, expandSelectExpr, expandStar, getAggregate, getCatalogReader, getConformance, getCursorScope, getEmptyScope, getFieldOrigins, getFromScope, getGroupScope, getHavingScope, getJoinScope, getLogicalSourceRowType, getLogicalTargetRowType, getMatchRecognizeScope, getNamespace, getOperatorTable, getOrderScope, getOriginal, getOverScope, getParameterRowType, getParentCursor, getRawSelectScope, getSelectScope, getSelfJoinExprForUpdate, getTypeCoercion, getTypeFactory, getUnknownType, getValidatedNodeType, getValidatedNodeTypeIfKnown, getValidatedOperandTypes, getValidationErrorFunction, getWhereScope, getWindowByName, getWithScope, handleUnresolvedFunction, inferUnknownTypes, isAggregate, isAggregate, isNestedAggregateWindow, isOverAggregateWindow, isSystemField, lookupHints, lookupNameCompletionHints, lookupQualifiedName, makeNullaryCall, newValidationError, performUnconditionalRewrites, popFunctionCall, pushFunctionCall, registerNamespace, removeValidatedNodeType, resolveWindow, setOriginal, setValidatedNodeType, shouldAllowIntermediateOrderBy, shouldAllowOverRelation, transform, usingNames, validate, validateAggregateParams, validateCall, validateDataType, validateDelete, validateDynamicParam, validateFeature, validateFrom, validateGroupClause, validateHavingClause, validateIdentifier, validateInsert, validateIntervalQualifier, validateMatchRecognize, validateMerge, validateModality, validateNamespace, validateOrderList, validateOver, validateParameterizedExpression, validatePivot, validateQuery, validateSelect, validateSelectList, validateSequenceValue, validateUnnest, validateUnpivot, validateUpdate, validateValues, validateWhereClause, validateWhereOrOn, validateWindow, validateWindowClause, validateWith, validateWithItem

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.calcite.sql.validate.SqlValidator

resolveWindow

Constructor Detail

FlinkCalciteSqlValidator

public FlinkCalciteSqlValidator(org.apache.calcite.sql.SqlOperatorTable opTab,
                                org.apache.calcite.sql.validate.SqlValidatorCatalogReader catalogReader,
                                org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
                                org.apache.calcite.sql.validate.SqlValidator.Config config)

Method Detail

setExpectedOutputType

public void setExpectedOutputType(org.apache.calcite.sql.SqlNode sqlNode,
                                  org.apache.calcite.rel.type.RelDataType expectedOutputType)

getExpectedOutputType

public Optional<org.apache.calcite.rel.type.RelDataType> getExpectedOutputType(org.apache.calcite.sql.SqlNode sqlNode)

validateLiteral

public void validateLiteral(org.apache.calcite.sql.SqlLiteral literal)

Specified by:

validateLiteral in interface org.apache.calcite.sql.validate.SqlValidator

Overrides:

validateLiteral in class SqlValidatorImpl

validateJoin

protected void validateJoin(org.apache.calcite.sql.SqlJoin join,
                            org.apache.calcite.sql.validate.SqlValidatorScope scope)

Overrides:

validateJoin in class SqlValidatorImpl

validateColumnListParams

public void validateColumnListParams(org.apache.calcite.sql.SqlFunction function,
                                     List<org.apache.calcite.rel.type.RelDataType> argTypes,
                                     List<org.apache.calcite.sql.SqlNode> operands)

Specified by:

validateColumnListParams in interface org.apache.calcite.sql.validate.SqlValidator

Overrides:

validateColumnListParams in class SqlValidatorImpl