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	ready ()
CompletionResult	getCompletionHints (final String sql, final int cursor, final List< String > visibleTables)
RelRoot	rel (SqlNode sql) throws RelConversionException
void	setFilterPushDownInfo (final List< MapDParserOptions.FilterPushDownInfo > filterPushDownInfo)

Package Attributes
FrameworkConfig	config

Private Member Functions
CalciteCatalogReader	createCatalogReader ()
RelRoot	applyFilterPushdown (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 53 of file MapDPlanner.java.

Constructor & Destructor Documentation

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

inline

Definition at line 58 of file MapDPlanner.java.

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

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

Member Function Documentation

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

inlineprivate

Definition at line 143 of file MapDPlanner.java.

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

Referenced by 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:

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

inlineprivate

Definition at line 82 of file MapDPlanner.java.

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

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

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

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

                                                                                {
    ready();
    MapDSqlAdvisorValidator advisor_validator = new MapDSqlAdvisorValidator(visibleTables,
            config.getOperatorTable(),
            createCatalogReader(),
            getTypeFactory(),
            SqlConformanceEnum.LENIENT);
    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:

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

inline

Definition at line 102 of file MapDPlanner.java.

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

                      {
    // 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 ) throws RelConversionException

inline

Definition at line 137 of file MapDPlanner.java.

References org.apache.calcite.prepare.MapDPlanner.applyFilterPushdown().

                                                                {
    RelRoot root = super.rel(sql);
    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 63 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 160 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 54 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 55 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