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.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	QueryPlanner.Factory
static class	QueryPlanner.QueryParameters

Method Summary

Modifier and Type	Method and Description
BeamRelNode	convertToBeamRel(java.lang.String sqlStatement, QueryPlanner.QueryParameters queryParameters) It parses and validate the input query, then convert into a BeamRelNode tree.
org.apache.beam.vendor.calcite.v1_28_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,
                             QueryPlanner.QueryParameters queryParameters)
                      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_28_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