public class StormSqlContext extends Object
| Constructor and Description |
|---|
StormSqlContext() |
| Modifier and Type | Method and Description |
|---|---|
org.apache.calcite.tools.FrameworkConfig |
buildFrameWorkConfig() |
AbstractStreamsProcessor |
compileSql(String query) |
String |
explain(String query) |
Map<String,ISqlStreamsDataSource> |
getDataSources() |
org.apache.calcite.schema.SchemaPlus |
getSchema() |
org.apache.calcite.adapter.java.JavaTypeFactory |
getTypeFactory() |
void |
interpretCreateFunction(SqlCreateFunction sqlCreateFunction) |
void |
interpretCreateTable(SqlCreateTable n) |
public void interpretCreateTable(SqlCreateTable n)
public void interpretCreateFunction(SqlCreateFunction sqlCreateFunction) throws ClassNotFoundException
ClassNotFoundExceptionpublic AbstractStreamsProcessor compileSql(String query) throws Exception
Exceptionpublic String explain(String query) throws org.apache.calcite.sql.parser.SqlParseException, org.apache.calcite.tools.ValidationException, org.apache.calcite.tools.RelConversionException
org.apache.calcite.sql.parser.SqlParseExceptionorg.apache.calcite.tools.ValidationExceptionorg.apache.calcite.tools.RelConversionExceptionpublic org.apache.calcite.tools.FrameworkConfig buildFrameWorkConfig()
public org.apache.calcite.adapter.java.JavaTypeFactory getTypeFactory()
public org.apache.calcite.schema.SchemaPlus getSchema()
public Map<String,ISqlStreamsDataSource> getDataSources()
Copyright © 2021 The Apache Software Foundation. All rights reserved.