org.apache.calcite.prepare.MapDPlanner Class Reference

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

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

Classes
class	CompletionResult

Public Member Functions
	MapDPlanner (FrameworkConfig config)
void	advanceToValidate ()
void	ready ()
CompletionResult	getCompletionHints (final String sql, final int cursor, final List< String > visibleTables)
RelRoot	rel (SqlNode sql)
RelRoot	optimizeRaQuery (String query, MapDSchema schema) throws IOException
void	setFilterPushDownInfo (final List< MapDParserOptions.FilterPushDownInfo > filterPushDownInfo)
void	setRestriction (Restriction restriction)

Package Attributes
FrameworkConfig	config

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

Private Member Functions
CalciteCatalogReader	createCatalogReader ()
RelRoot	applyInjectFilterRule (RelRoot root, Restriction restriction)
RelRoot	applyFilterPushdown (RelRoot root)
RelRoot	applyQueryOptimizationRules (RelRoot root)

Static Private Member Functions
static SchemaPlus	rootSchema (SchemaPlus schema)

Private Attributes
List < MapDParserOptions.FilterPushDownInfo >	filterPushDownInfo
Restriction	restriction = null

Detailed Description

Customised version of the PlannerImpl for MapD. Used to be a copy of PlannerImpl, refactored now to use inheritance to minimize maintenance efforts. Implementation of org.apache.calcite.tools.Planner.

Definition at line 72 of file MapDPlanner.java.

Constructor & Destructor Documentation

org.apache.calcite.prepare.MapDPlanner.MapDPlanner ( FrameworkConfig  config )

inline

Definition at line 79 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.config.

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

Member Function Documentation

void org.apache.calcite.prepare.MapDPlanner.advanceToValidate ( )

inline

Definition at line 123 of file MapDPlanner.java.

                                  {
    try {
      String dummySql = "SELECT 1";
      super.parse(dummySql);
    } catch (SqlParseException e) {
      throw new RuntimeException(e);
    }
  }

RelRoot org.apache.calcite.prepare.MapDPlanner.applyFilterPushdown ( RelRoot  root )

inlineprivate

Definition at line 195 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.filterPushDownInfo.

Referenced by org.apache.calcite.prepare.MapDPlanner.optimizeRaQuery(), and org.apache.calcite.prepare.MapDPlanner.rel().

                                                    {
    if (filterPushDownInfo.isEmpty()) {
      return root;
    }
    final DynamicFilterJoinRule dynamicFilterJoinRule = new DynamicFilterJoinRule(true,
            RelFactories.LOGICAL_BUILDER,
            FilterJoinRule.TRUE_PREDICATE,
            filterPushDownInfo);
    final HepProgram program =
            HepProgram.builder().addRuleInstance(dynamicFilterJoinRule).build();
    HepPlanner prePlanner = new HepPlanner(program);
    prePlanner.setRoot(root.rel);
    final RelNode rootRelNode = prePlanner.findBestExp();
    filterPushDownInfo.clear();
    return root.withRel(rootRelNode);
  }

Here is the caller graph for this function:

RelRoot org.apache.calcite.prepare.MapDPlanner.applyInjectFilterRule ( RelRoot  root, Restriction  restriction  )

inlineprivate

Definition at line 181 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.restriction.

Referenced by org.apache.calcite.prepare.MapDPlanner.rel().

                                                                               {
    // TODO consider doing these rules in one preplan pass

    final InjectFilterRule injectFilterRule =
            InjectFilterRule.Config.DEFAULT.toRule(restriction);

    final HepProgram program =
            HepProgram.builder().addRuleInstance(injectFilterRule).build();
    HepPlanner prePlanner = new HepPlanner(program);
    prePlanner.setRoot(root.rel);
    final RelNode rootRelNode = prePlanner.findBestExp();
    return root.withRel(rootRelNode);
  }

Here is the caller graph for this function:

RelRoot org.apache.calcite.prepare.MapDPlanner.applyQueryOptimizationRules ( RelRoot  root )

inlineprivate

Definition at line 212 of file MapDPlanner.java.

Referenced by org.apache.calcite.prepare.MapDPlanner.optimizeRaQuery(), and org.apache.calcite.prepare.MapDPlanner.rel().

                                                            {
    QueryOptimizationRules outerJoinOptRule =
            new OuterJoinOptViaNullRejectionRule(RelFactories.LOGICAL_BUILDER);

    HepProgram opt_program =
            HepProgram.builder().addRuleInstance(outerJoinOptRule).build();
    HepPlanner prePlanner = new HepPlanner(
            opt_program, null, true, Functions.ignore2(), RelOptCostImpl.FACTORY);
    prePlanner.setRoot(root.rel);
    final RelNode rootRelNode = prePlanner.findBestExp();
    return root.withRel(rootRelNode);
  }

Here is the caller graph for this function:

CalciteCatalogReader org.apache.calcite.prepare.MapDPlanner.createCatalogReader ( )

inlineprivate

Definition at line 103 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.config, and org.apache.calcite.prepare.MapDPlanner.rootSchema().

Referenced by org.apache.calcite.prepare.MapDPlanner.getCompletionHints(), and org.apache.calcite.prepare.MapDPlanner.optimizeRaQuery().

                                                     {
    final SchemaPlus rootSchema = rootSchema(config.getDefaultSchema());
    final Context context = config.getContext();
    final CalciteConnectionConfig connectionConfig;

    if (context != null) {
      connectionConfig = context.unwrap(CalciteConnectionConfig.class);
    } else {
      Properties properties = new Properties();
      properties.setProperty(CalciteConnectionProperty.CASE_SENSITIVE.camelName(),
              String.valueOf(config.getParserConfig().caseSensitive()));
      connectionConfig = new CalciteConnectionConfigImpl(properties);
    }

    return new CalciteCatalogReader(CalciteSchema.from(rootSchema),
            CalciteSchema.from(config.getDefaultSchema()).path(null),
            getTypeFactory(),
            connectionConfig);
  }

Here is the call graph for this function:

Here is the caller graph for this function:

CompletionResult org.apache.calcite.prepare.MapDPlanner.getCompletionHints ( final String  sql, final int  cursor, final List< String >  visibleTables  )

inline

Definition at line 150 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.config, org.apache.calcite.prepare.MapDPlanner.createCatalogReader(), and org.apache.calcite.prepare.MapDPlanner.ready().

                                                                                {
    ready();

    SqlValidator.Config validatorConfig = SqlValidator.Config.DEFAULT;
    validatorConfig = validatorConfig.withSqlConformance(SqlConformanceEnum.LENIENT);

    MapDSqlAdvisorValidator advisor_validator = new MapDSqlAdvisorValidator(visibleTables,
            config.getOperatorTable(),
            createCatalogReader(),
            getTypeFactory(),
            validatorConfig);
    SqlAdvisor advisor = new MapDSqlAdvisor(advisor_validator, config.getParserConfig());
    String[] replaced = new String[1];
    int adjusted_cursor = cursor < 0 ? sql.length() : cursor;
    java.util.List<SqlMoniker> hints =
            advisor.getCompletionHints(sql, adjusted_cursor, replaced);
    return new CompletionResult(hints, replaced[0]);
  }

Here is the call graph for this function:

RelRoot org.apache.calcite.prepare.MapDPlanner.optimizeRaQuery ( String  query, MapDSchema  schema  ) throws IOException

inline

Definition at line 225 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.applyFilterPushdown(), org.apache.calcite.prepare.MapDPlanner.applyQueryOptimizationRules(), org.apache.calcite.prepare.MapDPlanner.createCatalogReader(), com.mapd.calcite.parser.ProjectProjectRemoveRule.INSTANCE, and org.apache.calcite.prepare.MapDPlanner.ready().

                                                                                     {
    ready();
    RexBuilder builder = new RexBuilder(getTypeFactory());
    RelOptCluster cluster = RelOptCluster.create(new VolcanoPlanner(), builder);
    CalciteCatalogReader catalogReader = createCatalogReader();
    MapDRelJsonReader reader = new MapDRelJsonReader(cluster, catalogReader, schema);

    RelRoot relR = RelRoot.of(reader.read(query), SqlKind.SELECT);
    applyQueryOptimizationRules(relR);
    applyFilterPushdown(relR);

    HepProgramBuilder hepBuilder = new HepProgramBuilder();
    hepBuilder.addRuleInstance(CoreRules.JOIN_PROJECT_BOTH_TRANSPOSE_INCLUDE_OUTER);
    hepBuilder.addRuleInstance(CoreRules.FILTER_MERGE);
    hepBuilder.addRuleInstance(CoreRules.FILTER_PROJECT_TRANSPOSE);
    hepBuilder.addRuleInstance(CoreRules.PROJECT_MERGE);
    hepBuilder.addRuleInstance(ProjectProjectRemoveRule.INSTANCE);

    HepPlanner hepPlanner = new HepPlanner(hepBuilder.build());
    final RelNode root = relR.project();
    hepPlanner.setRoot(root);
    final RelNode newRel = hepPlanner.findBestExp();

    return RelRoot.of(newRel, relR.kind);
  }

Here is the call graph for this function:

void org.apache.calcite.prepare.MapDPlanner.ready ( )

inline

Definition at line 132 of file MapDPlanner.java.

Referenced by org.apache.calcite.prepare.MapDPlanner.getCompletionHints(), and org.apache.calcite.prepare.MapDPlanner.optimizeRaQuery().

                      {
    // need to call ready on the super class, but that method is marked private
    // circumventing via reflection for now
    try {
      Method readyMethod = getClass().getSuperclass().getDeclaredMethod("ready");
      readyMethod.setAccessible(true);
      readyMethod.invoke(this);
    } catch (InvocationTargetException e) {
      if (e.getCause() instanceof RuntimeException) {
        throw(RuntimeException) e.getCause();
      } else {
        throw new RuntimeException(e.getCause());
      }
    } catch (Exception e) {
      throw new RuntimeException(e);
    }
  }

Here is the caller graph for this function:

RelRoot org.apache.calcite.prepare.MapDPlanner.rel ( SqlNode  sql )

inline

Definition at line 171 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.applyFilterPushdown(), org.apache.calcite.prepare.MapDPlanner.applyInjectFilterRule(), org.apache.calcite.prepare.MapDPlanner.applyQueryOptimizationRules(), and org.apache.calcite.prepare.MapDPlanner.restriction.

                                  {
    RelRoot root = super.rel(sql);
    if (restriction != null) {
      root = applyInjectFilterRule(root, restriction);
    }
    root = applyQueryOptimizationRules(root);
    root = applyFilterPushdown(root);
    return root;
  }

Here is the call graph for this function:

static SchemaPlus org.apache.calcite.prepare.MapDPlanner.rootSchema ( SchemaPlus  schema )

inlinestaticprivate

Definition at line 84 of file MapDPlanner.java.

Referenced by org.apache.calcite.prepare.MapDPlanner.createCatalogReader().

                                                          {
    for (;;) {
      if (schema.getParentSchema() == null) {
        return schema;
      }
      schema = schema.getParentSchema();
    }
  }

Here is the caller graph for this function:

void org.apache.calcite.prepare.MapDPlanner.setFilterPushDownInfo ( final List< MapDParserOptions.FilterPushDownInfo >  filterPushDownInfo )

inline

Definition at line 251 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.filterPushDownInfo.

                                                                               {
    this.filterPushDownInfo = filterPushDownInfo;
  }

void org.apache.calcite.prepare.MapDPlanner.setRestriction ( Restriction  restriction )

inline

Definition at line 256 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.restriction.

                                                      {
    this.restriction = restriction;
  }

Member Data Documentation

FrameworkConfig org.apache.calcite.prepare.MapDPlanner.config

package

Definition at line 73 of file MapDPlanner.java.

Referenced by org.apache.calcite.prepare.MapDPlanner.createCatalogReader(), org.apache.calcite.prepare.MapDPlanner.getCompletionHints(), and org.apache.calcite.prepare.MapDPlanner.MapDPlanner().

List<MapDParserOptions.FilterPushDownInfo> org.apache.calcite.prepare.MapDPlanner.filterPushDownInfo

private

Initial value:

=
          new ArrayList<>()

Definition at line 74 of file MapDPlanner.java.

Referenced by org.apache.calcite.prepare.MapDPlanner.applyFilterPushdown(), and org.apache.calcite.prepare.MapDPlanner.setFilterPushDownInfo().

final Logger org.apache.calcite.prepare.MapDPlanner.MAPDLOGGER = LoggerFactory.getLogger(MapDPlanner.class)

staticpackage

Definition at line 77 of file MapDPlanner.java.

Restriction org.apache.calcite.prepare.MapDPlanner.restriction = null

private

Definition at line 76 of file MapDPlanner.java.

Referenced by org.apache.calcite.prepare.MapDPlanner.applyInjectFilterRule(), org.apache.calcite.prepare.MapDPlanner.rel(), and org.apache.calcite.prepare.MapDPlanner.setRestriction().

---

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/MapDPlanner.java