Package org.apache.storm.sql
Class AbstractStreamsProcessor
java.lang.Object
org.apache.storm.sql.AbstractStreamsProcessor
- 
Field SummaryFieldsModifier and TypeFieldDescriptionprotected List<CompilingClassLoader>protected org.apache.calcite.DataContext
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionabstract StormTopologybuild()Construct the Storm topology based on the SQL.Return the list of Classloaders which need to be compiled and included to the jar.org.apache.calcite.DataContextReturn DataContext instance which is used with execution of query.Return final output stream of SQL topology structure.
- 
Field Details- 
outputStream
- 
dataContextprotected org.apache.calcite.DataContext dataContext
- 
classLoaders
 
- 
- 
Constructor Details- 
AbstractStreamsProcessorpublic AbstractStreamsProcessor()
 
- 
- 
Method Details- 
outputStreamReturn final output stream of SQL topology structure.- Returns:
- the output stream of the SQL
 
- 
buildConstruct the Storm topology based on the SQL.
- 
getDataContextpublic org.apache.calcite.DataContext getDataContext()Return DataContext instance which is used with execution of query.- Returns:
- DataContext instance which is used with execution of query
 
- 
getClassLoadersReturn the list of Classloaders which need to be compiled and included to the jar. They're all chaining so the last classloader can access all classes.- Returns:
- Classloaders to compile.
 
 
-