Class StormSqlContext

java.lang.Object
org.apache.storm.sql.StormSqlContext

public class StormSqlContext extends Object
  • Constructor Details

    • StormSqlContext

      public StormSqlContext()
  • Method Details

    • interpretCreateTable

      public void interpretCreateTable(SqlCreateTable n)
    • interpretCreateFunction

      public void interpretCreateFunction(SqlCreateFunction sqlCreateFunction) throws ClassNotFoundException
      Throws:
      ClassNotFoundException
    • compileSql

      public AbstractStreamsProcessor compileSql(String query) throws Exception
      Throws:
      Exception
    • explain

      public 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
    • buildFrameWorkConfig

      public org.apache.calcite.tools.FrameworkConfig buildFrameWorkConfig()
    • getTypeFactory

      public org.apache.calcite.adapter.java.JavaTypeFactory getTypeFactory()
    • getSchema

      public org.apache.calcite.schema.SchemaPlus getSchema()
    • getDataSources

      public Map<String,ISqlStreamsDataSource> getDataSources()