org.apache.calcite.rel.rules.InjectFilterRule Class Reference

Inheritance diagram for org.apache.calcite.rel.rules.InjectFilterRule:

Collaboration diagram for org.apache.calcite.rel.rules.InjectFilterRule:

Classes
interface	Config

Public Member Functions
	InjectFilterRule (Config config, Restriction restriction)
void	onMatch (RelOptRuleCall call)

Static Public Attributes
static Set< String >	visitedMemo = new HashSet<>()

Package Functions
void	clearMemo ()

Package Attributes
final Restriction	restriction

Static Package Attributes
static final Logger	MAPDLOGGER = LoggerFactory.getLogger(InjectFilterRule.class)

Detailed Description

Definition at line 38 of file InjectFilterRule.java.

Constructor & Destructor Documentation

org.apache.calcite.rel.rules.InjectFilterRule.InjectFilterRule ( Config  config, Restriction  restriction  )

inline

Definition at line 45 of file InjectFilterRule.java.

References org.apache.calcite.rel.rules.InjectFilterRule.clearMemo(), and org.apache.calcite.rel.rules.InjectFilterRule.restriction.

Referenced by org.apache.calcite.rel.rules.InjectFilterRule.Config.toRule().

                                                                  {
    super(config);
    this.restriction = restriction;
    clearMemo();
  }

Here is the call graph for this function:

Here is the caller graph for this function:

Member Function Documentation

void org.apache.calcite.rel.rules.InjectFilterRule.clearMemo ( )

inlinepackage

Definition at line 51 of file InjectFilterRule.java.

Referenced by org.apache.calcite.rel.rules.InjectFilterRule.InjectFilterRule().

                   {
    visitedMemo.clear();
  }

Here is the caller graph for this function:

void org.apache.calcite.rel.rules.InjectFilterRule.onMatch ( RelOptRuleCall  call )

inline

Definition at line 56 of file InjectFilterRule.java.

References field(), org.apache.calcite.rel.rules.Restriction.getRestrictionColumn(), org.apache.calcite.rel.rules.Restriction.getRestrictionValues(), OR, org.apache.calcite.rel.rules.InjectFilterRule.restriction, test_readcsv.table, and org.apache.calcite.rel.rules.InjectFilterRule.visitedMemo.

                                           {
    LogicalTableScan parentNode = call.rel(0);
    if (visitedMemo.contains(parentNode.toString())) {
      return;
    } else {
      visitedMemo.add(parentNode.toString());
    }
    RelOptTable table = parentNode.getTable();

    RelDataTypeField field =
            table.getRowType().getField(restriction.getRestrictionColumn(), false, false);
    if (field != null) {
      MAPDLOGGER.debug(
              " Scan is " + parentNode.toString() + " TABLE is " + table.toString());
      MAPDLOGGER.debug("Column " + restriction.getRestrictionColumn()
              + " exists in table " + table.getQualifiedName());
      RelBuilder builder = call.builder();
      RexBuilder rBuilder = builder.getRexBuilder();
      builder = builder.push(parentNode);

      ArrayList<RexNode> orList = new ArrayList<RexNode>();
      for (String val : restriction.getRestrictionValues()) {
        MAPDLOGGER.debug(" Column is " + restriction.getRestrictionColumn()
                + " literal is '" + val + "'");
        RexNode lit;
        if (SqlTypeName.NUMERIC_TYPES.indexOf(field.getType().getSqlTypeName()) == -1) {
          lit = rBuilder.makeLiteral(val, field.getType(), false);
        } else {
          lit = rBuilder.makeLiteral(Integer.parseInt(val), field.getType(), false);
        }
        RexNode rn = builder.call(SqlStdOperatorTable.EQUALS,
                builder.field(restriction.getRestrictionColumn()),
                lit);
        orList.add(rn);
      }

      RexNode relOr = builder.call(SqlStdOperatorTable.OR, orList);

      final RelNode newNode = builder.filter(relOr).build();
      call.transformTo(newNode);
    }
  };

Here is the call graph for this function:

Member Data Documentation

final Logger org.apache.calcite.rel.rules.InjectFilterRule.MAPDLOGGER = LoggerFactory.getLogger(InjectFilterRule.class)

staticpackage

Definition at line 42 of file InjectFilterRule.java.

final Restriction org.apache.calcite.rel.rules.InjectFilterRule.restriction

package

Definition at line 43 of file InjectFilterRule.java.

Referenced by org.apache.calcite.rel.rules.InjectFilterRule.InjectFilterRule(), and org.apache.calcite.rel.rules.InjectFilterRule.onMatch().

Set<String> org.apache.calcite.rel.rules.InjectFilterRule.visitedMemo = new HashSet<>()

static

Definition at line 41 of file InjectFilterRule.java.

Referenced by org.apache.calcite.rel.rules.InjectFilterRule.onMatch().

---

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/rel/rules/InjectFilterRule.java