Class QueryPlanner
java.lang.Object
org.apache.storm.sql.planner.streams.QueryPlanner
-
Field Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptioncompile
(Map<String, ISqlStreamsDataSource> sources, String query)
-
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
-