Package org.apache.storm.sql

Class AbstractStreamsProcessor

java.lang.Object
org.apache.storm.sql.AbstractStreamsProcessor
public abstract class AbstractStreamsProcessor extends Object

  • Field Details

    • outputStream

      protected Stream<Values> outputStream

    • dataContext

      protected org.apache.calcite.DataContext dataContext

    • classLoaders

      protected List<CompilingClassLoader> classLoaders

  • Constructor Details

    • AbstractStreamsProcessor

      public AbstractStreamsProcessor()

  • Method Details

    • outputStream

      public Stream<Values> outputStream()
      Return final output stream of SQL topology structure.
      Returns:
      the output stream of the SQL

    • build

      public abstract StormTopology 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

      public List<CompilingClassLoader> 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.