Package org.apache.storm.sql
Class StormSqlContext
java.lang.Object
org.apache.storm.sql.StormSqlContext
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.calcite.tools.FrameworkConfigcompileSql(String query) org.apache.calcite.schema.SchemaPlusorg.apache.calcite.adapter.java.JavaTypeFactoryvoidinterpretCreateFunction(SqlCreateFunction sqlCreateFunction) void
- 
Constructor Details- 
StormSqlContextpublic StormSqlContext()
 
- 
- 
Method Details- 
interpretCreateTable
- 
interpretCreateFunctionpublic void interpretCreateFunction(SqlCreateFunction sqlCreateFunction) throws ClassNotFoundException - Throws:
- ClassNotFoundException
 
- 
compileSql- Throws:
- Exception
 
- 
explainpublic String explain(String query) throws org.apache.calcite.sql.parser.SqlParseException, org.apache.calcite.tools.ValidationException, org.apache.calcite.tools.RelConversionException - Throws:
- org.apache.calcite.sql.parser.SqlParseException
- org.apache.calcite.tools.ValidationException
- org.apache.calcite.tools.RelConversionException
 
- 
buildFrameWorkConfigpublic org.apache.calcite.tools.FrameworkConfig buildFrameWorkConfig()
- 
getTypeFactorypublic org.apache.calcite.adapter.java.JavaTypeFactory getTypeFactory()
- 
getSchemapublic org.apache.calcite.schema.SchemaPlus getSchema()
- 
getDataSources
 
-