org.apache.storm.sql

Class AbstractTridentProcessor

java.lang.Object

org.apache.storm.sql.AbstractTridentProcessor

public abstract class AbstractTridentProcessor
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected List<CompilingClassLoader>	classLoaders
protected org.apache.calcite.DataContext	dataContext
protected Stream	outputStream

Constructor Summary

Constructors

Constructor and Description
AbstractTridentProcessor()

Method Summary

Modifier and Type	Method and Description
abstract TridentTopology	build() Construct the trident topology based on the SQL.
List<CompilingClassLoader>	getClassLoaders()
org.apache.calcite.DataContext	getDataContext()
Stream	outputStream()

Methods inherited from class java.lang.Object

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

Field Detail

outputStream

protected Stream outputStream

dataContext

protected org.apache.calcite.DataContext dataContext

classLoaders

protected List<CompilingClassLoader> classLoaders

Constructor Detail

AbstractTridentProcessor

public AbstractTridentProcessor()

Method Detail

outputStream

public Stream outputStream()

Returns:

the output stream of the SQL

build

public abstract TridentTopology build()

Construct the trident topology based on the SQL.

getDataContext

public org.apache.calcite.DataContext getDataContext()

Returns:

DataContext instance which is used with execution of query

getClassLoaders

public List<CompilingClassLoader> getClassLoaders()

Returns:

Classloaders to compile. They’re all chaining so the last classloader can access all classes.