org.apache.storm.sql.planner.trident

Class TridentPlanCreator

java.lang.Object

org.apache.storm.sql.planner.trident.TridentPlanCreator

public class TridentPlanCreator
extends Object

Constructor Summary

Constructors

Constructor and Description
TridentPlanCreator(Map<String,ISqlTridentDataSource> sources, org.apache.calcite.rex.RexBuilder rexBuilder)

Method Summary

Modifier and Type	Method and Description
void	addClassLoader(CompilingClassLoader compilingClassLoader)
void	addStream(IAggregatableStream stream)
ExecutableExpression	createScalarInstance(List<org.apache.calcite.rex.RexNode> nodes, org.apache.calcite.rel.type.RelDataType inputRowType, String className)
ExecutableExpression	createScalarInstance(org.apache.calcite.rex.RexProgram program, String className)
List<CompilingClassLoader>	getClassLoaders()
org.apache.calcite.DataContext	getDataContext()
ClassLoader	getLastClassLoader()
Map<String,ISqlTridentDataSource>	getSources()
TridentTopology	getTopology()
org.apache.calcite.adapter.java.JavaTypeFactory	getTypeFactory()
IAggregatableStream	pop()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TridentPlanCreator

public TridentPlanCreator(Map<String,ISqlTridentDataSource> sources,
                          org.apache.calcite.rex.RexBuilder rexBuilder)

Method Detail

addStream

public void addStream(IAggregatableStream stream)
               throws Exception

Throws:

Exception

pop

public IAggregatableStream pop()

getSources

public Map<String,ISqlTridentDataSource> getSources()

getDataContext

public org.apache.calcite.DataContext getDataContext()

getTypeFactory

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

getTopology

public TridentTopology getTopology()

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

Throws:

CompilingClassLoader.CompilerException

ClassNotFoundException

IllegalAccessException

InstantiationException

createScalarInstance

public ExecutableExpression createScalarInstance(org.apache.calcite.rex.RexProgram program,
                                                 String className)
                                          throws CompilingClassLoader.CompilerException,
                                                 ClassNotFoundException,
                                                 IllegalAccessException,
                                                 InstantiationException

Throws:

CompilingClassLoader.CompilerException

ClassNotFoundException

IllegalAccessException

InstantiationException

addClassLoader

public void addClassLoader(CompilingClassLoader compilingClassLoader)

getLastClassLoader

public ClassLoader getLastClassLoader()

getClassLoaders

public List<CompilingClassLoader> getClassLoaders()