org.apache.calcite.prepare.CalciteSqlValidator Class Reference

Inheritance diagram for org.apache.calcite.prepare.CalciteSqlValidator:

Collaboration diagram for org.apache.calcite.prepare.CalciteSqlValidator:

Protected Member Functions
RelDataType	getLogicalSourceRowType (RelDataType sourceRowType, SqlInsert insert)
RelDataType	getLogicalTargetRowType (RelDataType targetRowType, SqlInsert insert)
void	addToSelectList (List< SqlNode > list, Set< String > aliases, List< Map.Entry< String, RelDataType >> fieldList, SqlNode exp, SelectScope scope, boolean includeSystemVars)
void	checkTypeAssignment (SqlValidatorScope sourceScope, SqlValidatorTable table, RelDataType sourceRowType, RelDataType targetRowType, SqlNode query)

Package Functions
	CalciteSqlValidator (SqlOperatorTable opTab, CalciteCatalogReader catalogReader, JavaTypeFactory typeFactory, Config config)

Private Member Functions
boolean	isSystemColumn (final SqlNode exp, final SelectScope scope)

Detailed Description

Based on CalciteSqlValidator in calcite-core with the addition of an addToSelectList() method override, which fixes the omission of system column checks when adding columns from an expanded star selection into the select list.

Definition at line 44 of file CalciteSqlValidator.java.

Constructor & Destructor Documentation

org.apache.calcite.prepare.CalciteSqlValidator.CalciteSqlValidator ( SqlOperatorTable  opTab, CalciteCatalogReader  catalogReader, JavaTypeFactory  typeFactory, Config  config  )

inlinepackage

Definition at line 45 of file CalciteSqlValidator.java.

                         {
    super(opTab, catalogReader, typeFactory, config);
  }

Member Function Documentation

void org.apache.calcite.prepare.CalciteSqlValidator.addToSelectList ( List< SqlNode >  list, Set< String >  aliases, List< Map.Entry< String, RelDataType >>  fieldList, SqlNode  exp, SelectScope  scope, boolean  includeSystemVars  )

inlineprotected

Definition at line 67 of file CalciteSqlValidator.java.

References org.apache.calcite.prepare.CalciteSqlValidator.isSystemColumn().

                                     {
    if (includeSystemVars || !isSystemColumn(exp, scope)) {
      super.addToSelectList(list, aliases, fieldList, exp, scope, includeSystemVars);
    }
  }

Here is the call graph for this function:

void org.apache.calcite.prepare.CalciteSqlValidator.checkTypeAssignment ( SqlValidatorScope  sourceScope, SqlValidatorTable  table, RelDataType  sourceRowType, RelDataType  targetRowType, SqlNode  query  )

inlineprotected

Definition at line 96 of file CalciteSqlValidator.java.

                         {
    // disabling assignment checking in calcite and instead letting omni-sci server
    // handle
  }

RelDataType org.apache.calcite.prepare.CalciteSqlValidator.getLogicalSourceRowType ( RelDataType  sourceRowType, SqlInsert  insert  )

inlineprotected

Definition at line 53 of file CalciteSqlValidator.java.

                                                       {
    final RelDataType superType = super.getLogicalSourceRowType(sourceRowType, insert);
    return ((JavaTypeFactory) typeFactory).toSql(superType);
  }

RelDataType org.apache.calcite.prepare.CalciteSqlValidator.getLogicalTargetRowType ( RelDataType  targetRowType, SqlInsert  insert  )

inlineprotected

Definition at line 60 of file CalciteSqlValidator.java.

                                                       {
    final RelDataType superType = super.getLogicalTargetRowType(targetRowType, insert);
    return ((JavaTypeFactory) typeFactory).toSql(superType);
  }

boolean org.apache.calcite.prepare.CalciteSqlValidator.isSystemColumn ( final SqlNode  exp, final SelectScope  scope  )

inlineprivate

Definition at line 78 of file CalciteSqlValidator.java.

References test_readcsv.table.

Referenced by org.apache.calcite.prepare.CalciteSqlValidator.addToSelectList().

                                                                             {
    if (exp instanceof SqlIdentifier) {
      SqlIdentifier columnId = (SqlIdentifier) exp;
      // Expects columnId.names[0] to be table name and columnId.names[1] to be column
      // name
      if (columnId.names != null && columnId.names.size() == 2) {
        SqlValidatorTable sqlValidatorTable =
                scope.fullyQualify(columnId).namespace.getTable();
        if (sqlValidatorTable != null) {
          MapDTable table = (MapDTable) sqlValidatorTable.unwrap(MapDTable.class);
          return table.isSystemColumn(columnId.names.get(1));
        }
      }
    }
    return false;
  }

Here is the caller graph for this function:

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/main/java/org/apache/calcite/prepare/CalciteSqlValidator.java