org.apache.calcite.sql.validate.SqlValidatorImpl.Permute Class Reference

Collaboration diagram for org.apache.calcite.sql.validate.SqlValidatorImpl.Permute:

Public Member Functions
void	permute (List< SqlNode > selectItems, List< Map.Entry< String, RelDataType >> fields)

Package Functions
	Permute (SqlNode from, int offset)

Package Attributes
final List< ImmutableIntList >	sources
final RelDataType	rowType
final boolean	trivial

Private Member Functions
RelDataTypeField	field (String name)

Detailed Description

Permutation of fields in NATURAL JOIN or USING.

Definition at line 6576 of file SqlValidatorImpl.java.

Constructor & Destructor Documentation

org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.Permute ( SqlNode  from, int  offset  )

inlinepackage

Definition at line 6581 of file SqlValidatorImpl.java.

References f(), org.apache.calcite.sql.validate.SqlValidatorImpl.getValidatedNodeType(), join(), setup.name, org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.rowType, org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.sources, and org.apache.calcite.sql.validate.SqlValidatorImpl.usingNames().

                                      {
      switch (from.getKind()) {
      case JOIN:
        final SqlJoin join = (SqlJoin) from;
        final Permute left = new Permute(join.getLeft(), offset);
        final int fieldCount =
            getValidatedNodeType(join.getLeft()).getFieldList().size();
        final Permute right =
            new Permute(join.getRight(), offset + fieldCount);
        final List<String> names = usingNames(join);
        final List<ImmutableIntList> sources = new ArrayList<>();
        final Set<ImmutableIntList> sourceSet = new HashSet<>();
        final RelDataTypeFactory.Builder b = typeFactory.builder();
        if (names != null) {
          for (String name : names) {
            final RelDataTypeField f = left.field(name);
            final ImmutableIntList source = left.sources.get(f.getIndex());
            sourceSet.add(source);
            final RelDataTypeField f2 = right.field(name);
            final ImmutableIntList source2 = right.sources.get(f2.getIndex());
            sourceSet.add(source2);
            sources.add(source.appendAll(source2));
            final boolean nullable =
                (f.getType().isNullable()
                    || join.getJoinType().generatesNullsOnLeft())
                && (f2.getType().isNullable()
                    || join.getJoinType().generatesNullsOnRight());
            b.add(f).nullable(nullable);
          }
        }
        for (RelDataTypeField f : left.rowType.getFieldList()) {
          final ImmutableIntList source = left.sources.get(f.getIndex());
          if (sourceSet.add(source)) {
            sources.add(source);
            b.add(f);
          }
        }
        for (RelDataTypeField f : right.rowType.getFieldList()) {
          final ImmutableIntList source = right.sources.get(f.getIndex());
          if (sourceSet.add(source)) {
            sources.add(source);
            b.add(f);
          }
        }
        rowType = b.build();
        this.sources = ImmutableList.copyOf(sources);
        this.trivial = left.trivial
            && right.trivial
            && (names == null || names.isEmpty());
        break;

      default:
        rowType = getValidatedNodeType(from);
        this.sources = Functions.generate(rowType.getFieldCount(),
            i -> ImmutableIntList.of(offset + i));
        this.trivial = true;
      }
    }

Here is the call graph for this function:

Member Function Documentation

RelDataTypeField org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.field ( String  name )

inlineprivate

Definition at line 6640 of file SqlValidatorImpl.java.

References org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.rowType.

Referenced by org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.permute().

                                                {
      return catalogReader.nameMatcher().field(rowType, name);
    }

Here is the caller graph for this function:

void org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.permute ( List< SqlNode >  selectItems, List< Map.Entry< String, RelDataType >>  fields  )

inline

Moves fields according to the permutation.

Definition at line 6645 of file SqlValidatorImpl.java.

References org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.field(), org.apache.calcite.sql.validate.SqlValidatorImpl.maybeCast(), setup.name, org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.sources, org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.trivial, run_benchmark_import.type, and org.apache.calcite.sql.validate.SqlValidatorImpl.typeFactory.

                                                     {
      if (trivial) {
        return;
      }

      final List<SqlNode> oldSelectItems = ImmutableList.copyOf(selectItems);
      selectItems.clear();
      final List<Map.Entry<String, RelDataType>> oldFields =
          ImmutableList.copyOf(fields);
      fields.clear();
      for (ImmutableIntList source : sources) {
        final int p0 = source.get(0);
        Map.Entry<String, RelDataType> field = oldFields.get(p0);
        final String name = field.getKey();
        RelDataType type = field.getValue();
        SqlNode selectItem = oldSelectItems.get(p0);
        for (int p1 : Util.skip(source)) {
          final Map.Entry<String, RelDataType> field1 = oldFields.get(p1);
          final SqlNode selectItem1 = oldSelectItems.get(p1);
          final RelDataType type1 = field1.getValue();
          // output is nullable only if both inputs are
          final boolean nullable = type.isNullable() && type1.isNullable();
          final RelDataType type2 =
              SqlTypeUtil.leastRestrictiveForComparison(typeFactory, type,
                  type1);
          selectItem =
              SqlStdOperatorTable.AS.createCall(SqlParserPos.ZERO,
                  SqlStdOperatorTable.COALESCE.createCall(SqlParserPos.ZERO,
                      maybeCast(selectItem, type, type2),
                      maybeCast(selectItem1, type1, type2)),
                  new SqlIdentifier(name, SqlParserPos.ZERO));
          type = typeFactory.createTypeWithNullability(type2, nullable);
        }
        fields.add(Pair.of(name, type));
        selectItems.add(selectItem);
      }
    }

Here is the call graph for this function:

Member Data Documentation

final RelDataType org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.rowType

package

Definition at line 6578 of file SqlValidatorImpl.java.

Referenced by org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.field(), and org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.Permute().

final List<ImmutableIntList> org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.sources

package

Definition at line 6577 of file SqlValidatorImpl.java.

Referenced by org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.Permute(), and org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.permute().

final boolean org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.trivial

package

Definition at line 6579 of file SqlValidatorImpl.java.

Referenced by org.apache.calcite.sql.validate.SqlValidatorImpl.Permute.permute().

---

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/sql/validate/SqlValidatorImpl.java