org.apache.calcite.sql.validate

Class ProcedureNamespace

java.lang.Object

org.apache.calcite.sql.validate.ProcedureNamespace

All Implemented Interfaces:

org.apache.calcite.sql.validate.SqlValidatorNamespace

@Internal
public final class ProcedureNamespace
extends Object

Namespace whose contents are defined by the result of a call to a user-defined procedure.

Note: Compared to Calcite, this class implements custom logic for dealing with collection tables like TABLE(function(...)) procedures. Compared to the SQL standard, Flink's table functions can return arbitrary types that are wrapped into a ROW type if necessary. We don't interpret ARRAY or MULTISET types as it would be standard.

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.calcite.sql.SqlNode	enclosingNode
protected org.apache.calcite.rel.type.RelDataType	rowType
protected org.apache.calcite.rel.type.RelDataType	type
protected SqlValidatorImpl	validator

Method Summary

Modifier and Type	Method and Description
protected org.apache.calcite.rel.type.RelDataType	convertToStruct(org.apache.calcite.rel.type.RelDataType arg0)
boolean	fieldExists(String arg0)
org.apache.calcite.sql.SqlNode	getEnclosingNode()
List<org.apache.calcite.util.Pair<org.apache.calcite.sql.SqlNode,org.apache.calcite.sql.validate.SqlMonotonicity>>	getMonotonicExprs()
org.apache.calcite.sql.validate.SqlMonotonicity	getMonotonicity(String arg0)
org.apache.calcite.sql.SqlNode	getNode()
org.apache.calcite.rel.type.RelDataType	getRowType()
org.apache.calcite.rel.type.RelDataType	getRowTypeSansSystemColumns()
org.apache.calcite.sql.validate.SqlValidatorTable	getTable()
org.apache.calcite.rel.type.RelDataType	getType()
org.apache.calcite.sql.validate.SqlValidator	getValidator()
boolean	isWrapperFor(Class<?> arg0)
org.apache.calcite.sql.validate.SqlValidatorNamespace	lookupChild(String arg0)
void	makeNullable()
org.apache.calcite.sql.validate.SqlValidatorNamespace	resolve()
void	setType(org.apache.calcite.rel.type.RelDataType arg0)
boolean	supportsModality(org.apache.calcite.sql.validate.SqlModality arg0)
protected org.apache.calcite.rel.type.RelDataType	toStruct(org.apache.calcite.rel.type.RelDataType type, org.apache.calcite.sql.SqlNode unnest) Converts a type to a struct if it is not already.
String	translate(String arg0)
<T> T	unwrap(Class<T> arg0)
void	validate(org.apache.calcite.rel.type.RelDataType arg0)
org.apache.calcite.rel.type.RelDataType	validateImpl(org.apache.calcite.rel.type.RelDataType targetRowType)

Methods inherited from class java.lang.Object

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

Field Detail

validator

protected final SqlValidatorImpl validator

rowType

protected org.apache.calcite.rel.type.RelDataType rowType

type

protected org.apache.calcite.rel.type.RelDataType type

enclosingNode

protected final org.apache.calcite.sql.SqlNode enclosingNode

Method Detail

validateImpl

public org.apache.calcite.rel.type.RelDataType validateImpl(org.apache.calcite.rel.type.RelDataType targetRowType)

toStruct

protected org.apache.calcite.rel.type.RelDataType toStruct(org.apache.calcite.rel.type.RelDataType type,
                                                           org.apache.calcite.sql.SqlNode unnest)

Converts a type to a struct if it is not already.

getNode

public org.apache.calcite.sql.SqlNode getNode()

getValidator

public org.apache.calcite.sql.validate.SqlValidator getValidator()

Specified by:

getValidator in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

validate

public final void validate(org.apache.calcite.rel.type.RelDataType arg0)

Specified by:

validate in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getRowType

public org.apache.calcite.rel.type.RelDataType getRowType()

Specified by:

getRowType in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getRowTypeSansSystemColumns

public org.apache.calcite.rel.type.RelDataType getRowTypeSansSystemColumns()

Specified by:

getRowTypeSansSystemColumns in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getType

public org.apache.calcite.rel.type.RelDataType getType()

Specified by:

getType in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

setType

public void setType(org.apache.calcite.rel.type.RelDataType arg0)

Specified by:

setType in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getEnclosingNode

public org.apache.calcite.sql.SqlNode getEnclosingNode()

Specified by:

getEnclosingNode in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getTable

public org.apache.calcite.sql.validate.SqlValidatorTable getTable()

Specified by:

getTable in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

lookupChild

public org.apache.calcite.sql.validate.SqlValidatorNamespace lookupChild(String arg0)

Specified by:

lookupChild in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

fieldExists

public boolean fieldExists(String arg0)

Specified by:

fieldExists in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getMonotonicExprs

public List<org.apache.calcite.util.Pair<org.apache.calcite.sql.SqlNode,org.apache.calcite.sql.validate.SqlMonotonicity>> getMonotonicExprs()

Specified by:

getMonotonicExprs in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

getMonotonicity

public org.apache.calcite.sql.validate.SqlMonotonicity getMonotonicity(String arg0)

Specified by:

getMonotonicity in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

makeNullable

public void makeNullable()

Specified by:

makeNullable in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

translate

public String translate(String arg0)

resolve

public org.apache.calcite.sql.validate.SqlValidatorNamespace resolve()

Specified by:

resolve in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

supportsModality

public boolean supportsModality(org.apache.calcite.sql.validate.SqlModality arg0)

Specified by:

supportsModality in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

unwrap

public <T> T unwrap(Class<T> arg0)

Specified by:

unwrap in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

isWrapperFor

public boolean isWrapperFor(Class<?> arg0)

Specified by:

isWrapperFor in interface org.apache.calcite.sql.validate.SqlValidatorNamespace

convertToStruct

protected org.apache.calcite.rel.type.RelDataType convertToStruct(org.apache.calcite.rel.type.RelDataType arg0)