Package org.apache.storm.sql.planner.streams

# Class QueryPlanner

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

public class QueryPlanner extends Object

- ## Field Summary

  Fields
  Modifier and Type
  Field
  Description
  `static final int`
  `STORM_REL_CONVERSION_RULES`

- ## Constructor Summary

  Constructors
  Constructor
  Description
  `QueryPlanner(org.apache.calcite.schema.SchemaPlus schema)`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `AbstractStreamsProcessor`
  `compile(Map<String,ISqlStreamsDataSource> sources, String query)`
  `StreamsRel`
  `getPlan(String query)`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

- ## Field Details

  - ### STORM_REL_CONVERSION_RULES

    public static final int STORM_REL_CONVERSION_RULES
    See Also:
      - Constant Field Values

- ## 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`