org.apache.beam.sdk.extensions.sql.impl

Interface QueryPlanner

All Known Implementing Classes:

CalciteQueryPlanner, ZetaSQLQueryPlanner

public interface QueryPlanner

An interface that planners should implement to convert sql statement to BeamRelNode or SqlNode.

Method Summary

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.sql.SqlNode	parse(java.lang.String sqlStatement) Parse input SQL query, and return a SqlNode as grammar tree.

Method Detail

convertToBeamRel

BeamRelNode convertToBeamRel(java.lang.String sqlStatement)
                      throws ParseException,
                             SqlConversionException

It parses and validate the input query, then convert into a BeamRelNode tree.

Throws:

ParseException

SqlConversionException

parse

org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.sql.SqlNode parse(java.lang.String sqlStatement)
                                                                     throws ParseException

Parse input SQL query, and return a SqlNode as grammar tree.

Throws:

ParseException