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)

Package Attributes
FrameworkConfig	config

Private Member Functions
CalciteCatalogReader	createCatalogReader ()
RelRoot	applyFilterPushdown (RelRoot root)
RelRoot	applyQueryOptimizationRules (RelRoot root)

Static Private Member Functions
static SchemaPlus	rootSchema (SchemaPlus schema)

Private Attributes
List < MapDParserOptions.FilterPushDownInfo >	filterPushDownInfo

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 79 of file MapDPlanner.java.

Constructor & Destructor Documentation

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

inline

Definition at line 84 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 128 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 183 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.applyQueryOptimizationRules ( RelRoot  root )

inlineprivate

Definition at line 200 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 108 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 155 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);
    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 213 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);

    ProjectMergeRule projectMergeRule =
            new ProjectMergeRule(true, RelFactories.LOGICAL_BUILDER);
    final Program program =
            Programs.hep(ImmutableList.of(FilterProjectTransposeRule.INSTANCE,
                                 projectMergeRule,
                                 ProjectProjectRemoveRule.INSTANCE,
                                 FilterMergeRule.INSTANCE),
                    true,
                    DefaultRelMetadataProvider.INSTANCE);
    RelNode oldRel;
    RelNode newRel = relR.project();

    do {
      oldRel = newRel;
      newRel = program.run(null,
              oldRel,
              null,
              ImmutableList.<RelOptMaterialization>of(),
              ImmutableList.<RelOptLattice>of());
      // there must be a better way to compare these
    } while (!RelOptUtil.toString(oldRel).equals(RelOptUtil.toString(newRel)));

    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 137 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 176 of file MapDPlanner.java.

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

                                  {
    RelRoot root = super.rel(sql);
    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 89 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 249 of file MapDPlanner.java.

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

                                                                               {
    this.filterPushDownInfo = filterPushDownInfo;
  }

Member Data Documentation

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

package

Definition at line 80 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 81 of file MapDPlanner.java.

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

---

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