Package org.apache.storm.sql
Class AbstractStreamsProcessor
java.lang.Object
org.apache.storm.sql.AbstractStreamsProcessor
-
Field Summary
Modifier and TypeFieldDescriptionprotected List<CompilingClassLoader>
protected org.apache.calcite.DataContext
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionabstract StormTopology
build()
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.DataContext
Return DataContext instance which is used with execution of query.Return final output stream of SQL topology structure.
-
Field Details
-
outputStream
-
dataContext
protected org.apache.calcite.DataContext dataContext -
classLoaders
-
-
Constructor Details
-
AbstractStreamsProcessor
public AbstractStreamsProcessor()
-
-
Method Details
-
outputStream
Return final output stream of SQL topology structure.- Returns:
- the output stream of the SQL
-
build
Construct the Storm topology based on the SQL. -
getDataContext
public 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
-
getClassLoaders
Return 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.
-