Class StreamsPlanCreator
java.lang.Object
org.apache.storm.sql.planner.streams.StreamsPlanCreator
- 
Constructor SummaryConstructorsConstructorDescriptionStreamsPlanCreator(Map<String, ISqlStreamsDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder) 
- 
Method SummaryModifier and TypeMethodDescriptionvoidaddClassLoader(CompilingClassLoader compilingClassLoader) voidcreateScalarInstance(List<org.apache.calcite.rex.RexNode> nodes, org.apache.calcite.rel.type.RelDataType inputRowType, String className) createScalarInstance(org.apache.calcite.rex.RexProgram program, String className) org.apache.calcite.DataContextorg.apache.calcite.adapter.java.JavaTypeFactorypop()
- 
Constructor Details- 
StreamsPlanCreatorpublic StreamsPlanCreator(Map<String, ISqlStreamsDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder) 
 
- 
- 
Method Details- 
addStream- Throws:
- Exception
 
- 
pop
- 
getSources
- 
getDataContextpublic org.apache.calcite.DataContext getDataContext()
- 
getTypeFactorypublic org.apache.calcite.adapter.java.JavaTypeFactory getTypeFactory()
- 
getStreamBuilder
- 
createScalarInstancepublic ExecutableExpression createScalarInstance(List<org.apache.calcite.rex.RexNode> nodes, org.apache.calcite.rel.type.RelDataType inputRowType, String className) throws CompilingClassLoader.CompilerException, ClassNotFoundException, IllegalAccessException, InstantiationException 
- 
createScalarInstancepublic ExecutableExpression createScalarInstance(org.apache.calcite.rex.RexProgram program, String className) throws CompilingClassLoader.CompilerException, ClassNotFoundException, IllegalAccessException, InstantiationException 
- 
addClassLoader
- 
getLastClassLoader
- 
getClassLoaders
 
-