public class FlinkCalciteSqlValidator
extends org.apache.calcite.sql.validate.SqlValidatorImpl
FlinkPlannerImpl
.org.apache.calcite.sql.validate.SqlValidatorImpl.DmlNamespace, org.apache.calcite.sql.validate.SqlValidatorImpl.FunctionParamInfo, org.apache.calcite.sql.validate.SqlValidatorImpl.IdInfo, org.apache.calcite.sql.validate.SqlValidatorImpl.Status
Constructor and Description |
---|
FlinkCalciteSqlValidator(org.apache.calcite.sql.SqlOperatorTable opTab,
org.apache.calcite.prepare.CalciteCatalogReader catalogReader,
org.apache.calcite.adapter.java.JavaTypeFactory typeFactory) |
Modifier and Type | Method and Description |
---|---|
org.apache.calcite.rel.type.RelDataType |
getLogicalSourceRowType(org.apache.calcite.rel.type.RelDataType sourceRowType,
org.apache.calcite.sql.SqlInsert insert) |
org.apache.calcite.rel.type.RelDataType |
getLogicalTargetRowType(org.apache.calcite.rel.type.RelDataType targetRowType,
org.apache.calcite.sql.SqlInsert insert) |
addToSelectList, checkTypeAssignment, createSelectNamespace, createSetopNamespace, createSourceSelectForDelete, createSourceSelectForUpdate, createTargetRowType, declareCursor, deriveAlias, deriveConstructorType, deriveType, expand, expandOrderExpr, expandStar, getAggregate, getCatalogReader, getColumnReferenceExpansion, getConformance, getCursorScope, getDefaultNullCollation, getEmptyScope, getFieldOrigins, getFromScope, getGroupScope, getHavingScope, getJoinScope, getNamespace, getOperatorTable, getOrderScope, getOriginal, getOverScope, getParameterRowType, getParentCursor, getRawSelectScope, getSelectScope, getSelfJoinExprForUpdate, getTypeFactory, getUnknownType, getValidatedNodeType, getValidatedNodeTypeIfKnown, getWhereScope, getWindowByName, getWithScope, handleUnresolvedFunction, inferUnknownTypes, isAggregate, isAggregate, isNestedAggregateWindow, isSystemField, lookupHints, lookupNameCompletionHints, lookupQualifiedName, newValidationError, performUnconditionalRewrites, popFunctionCall, pushFunctionCall, registerNamespace, removeValidatedNodeType, resolveWindow, setCallRewrite, setColumnReferenceExpansion, setDefaultNullCollation, setIdentifierExpansion, setOriginal, setValidatedNodeType, shouldAllowIntermediateOrderBy, shouldAllowOverRelation, shouldExpandIdentifiers, validate, validateAggregateParams, validateCall, validateColumnListParams, validateDataType, validateDelete, validateDynamicParam, validateFeature, validateFrom, validateGroupClause, validateHavingClause, validateIdentifier, validateInsert, validateIntervalQualifier, validateJoin, validateLiteral, validateMerge, validateModality, validateNamespace, validateOrderList, validateOver, validateParameterizedExpression, validateQuery, validateSelect, validateSelectList, validateSequenceValue, validateUpdate, validateValues, validateWhereClause, validateWhereOrOn, validateWindow, validateWindowClause, validateWith, validateWithItem
public FlinkCalciteSqlValidator(org.apache.calcite.sql.SqlOperatorTable opTab, org.apache.calcite.prepare.CalciteCatalogReader catalogReader, org.apache.calcite.adapter.java.JavaTypeFactory typeFactory)
public org.apache.calcite.rel.type.RelDataType getLogicalSourceRowType(org.apache.calcite.rel.type.RelDataType sourceRowType, org.apache.calcite.sql.SqlInsert insert)
getLogicalSourceRowType
in class org.apache.calcite.sql.validate.SqlValidatorImpl
public org.apache.calcite.rel.type.RelDataType getLogicalTargetRowType(org.apache.calcite.rel.type.RelDataType targetRowType, org.apache.calcite.sql.SqlInsert insert)
getLogicalTargetRowType
in class org.apache.calcite.sql.validate.SqlValidatorImpl
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.