Class QueryPlanner

java.lang.Object
org.apache.storm.sql.planner.streams.QueryPlanner

public class QueryPlanner extends Object
  • Field Details

    • STORM_REL_CONVERSION_RULES

      public static final int STORM_REL_CONVERSION_RULES
      See Also:
  • Constructor Details

    • QueryPlanner

      public QueryPlanner(org.apache.calcite.schema.SchemaPlus schema)
  • Method Details

    • compile

      public AbstractStreamsProcessor compile(Map<String,ISqlStreamsDataSource> sources, String query) throws Exception
      Throws:
      Exception
    • getPlan

      public StreamsRel getPlan(String query) throws org.apache.calcite.tools.ValidationException, org.apache.calcite.tools.RelConversionException, org.apache.calcite.sql.parser.SqlParseException
      Throws:
      org.apache.calcite.tools.ValidationException
      org.apache.calcite.tools.RelConversionException
      org.apache.calcite.sql.parser.SqlParseException