Class StreamsPlanCreator
java.lang.Object
org.apache.storm.sql.planner.streams.StreamsPlanCreator
-
Constructor Summary
ConstructorDescriptionStreamsPlanCreator
(Map<String, ISqlStreamsDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder) -
Method Summary
Modifier and TypeMethodDescriptionvoid
addClassLoader
(CompilingClassLoader compilingClassLoader) void
createScalarInstance
(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.DataContext
org.apache.calcite.adapter.java.JavaTypeFactory
pop()
-
Constructor Details
-
StreamsPlanCreator
public StreamsPlanCreator(Map<String, ISqlStreamsDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder)
-
-
Method Details
-
addStream
- Throws:
Exception
-
pop
-
getSources
-
getDataContext
public org.apache.calcite.DataContext getDataContext() -
getTypeFactory
public org.apache.calcite.adapter.java.JavaTypeFactory getTypeFactory() -
getStreamBuilder
-
createScalarInstance
public ExecutableExpression createScalarInstance(List<org.apache.calcite.rex.RexNode> nodes, org.apache.calcite.rel.type.RelDataType inputRowType, String className) throws CompilingClassLoader.CompilerException, ClassNotFoundException, IllegalAccessException, InstantiationException -
createScalarInstance
public ExecutableExpression createScalarInstance(org.apache.calcite.rex.RexProgram program, String className) throws CompilingClassLoader.CompilerException, ClassNotFoundException, IllegalAccessException, InstantiationException -
addClassLoader
-
getLastClassLoader
-
getClassLoaders
-