public abstract class AbstractStreamsProcessor extends Object
Modifier and Type | Field and Description |
---|---|
protected List<CompilingClassLoader> |
classLoaders |
protected org.apache.calcite.DataContext |
dataContext |
protected Stream<Values> |
outputStream |
Constructor and Description |
---|
AbstractStreamsProcessor() |
Modifier and Type | Method and Description |
---|---|
abstract StormTopology |
build()
Construct the Storm topology based on the SQL.
|
List<CompilingClassLoader> |
getClassLoaders()
Return the list of Classloaders which need to be compiled and included to the jar.
|
org.apache.calcite.DataContext |
getDataContext()
Return DataContext instance which is used with execution of query.
|
Stream<Values> |
outputStream()
Return final output stream of SQL topology structure.
|
protected org.apache.calcite.DataContext dataContext
protected List<CompilingClassLoader> classLoaders
public Stream<Values> outputStream()
Return final output stream of SQL topology structure.
public abstract StormTopology build()
Construct the Storm topology based on the SQL.
public org.apache.calcite.DataContext getDataContext()
Return DataContext instance which is used with execution of query.
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.
Copyright © 2022 The Apache Software Foundation. All rights reserved.