public class CalciteQueryPlanner extends java.lang.Object implements QueryPlanner
Modifier and Type | Class and Description |
---|---|
static class |
CalciteQueryPlanner.NonCumulativeCostImpl |
Constructor and Description |
---|
CalciteQueryPlanner(JdbcConnection connection,
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets) |
Modifier and Type | Method and Description |
---|---|
BeamRelNode |
convertToBeamRel(java.lang.String sqlStatement)
It parses and validate the input query, then convert into a
BeamRelNode tree. |
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig |
defaultConfig(JdbcConnection connection,
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets) |
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode |
parse(java.lang.String sqlStatement)
Parse input SQL query, and return a
SqlNode as grammar tree. |
public CalciteQueryPlanner(JdbcConnection connection, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets)
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.FrameworkConfig defaultConfig(JdbcConnection connection, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.tools.RuleSet[] ruleSets)
public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode parse(java.lang.String sqlStatement) throws ParseException
SqlNode
as grammar tree.parse
in interface QueryPlanner
ParseException
public BeamRelNode convertToBeamRel(java.lang.String sqlStatement) throws ParseException, SqlConversionException
BeamRelNode
tree.convertToBeamRel
in interface QueryPlanner
ParseException
SqlConversionException