net.esper.eql.spec
Class DBStatementStreamSpec
java.lang.Object
net.esper.eql.spec.StreamSpecBase
net.esper.eql.spec.DBStatementStreamSpec
- All Implemented Interfaces:
- StreamSpec, StreamSpecCompiled, StreamSpecRaw, MetaDefItem
public class DBStatementStreamSpec
- extends StreamSpecBase
- implements StreamSpecRaw, StreamSpecCompiled, MetaDefItem
Specification object for historical data poll via database SQL statement.
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DBStatementStreamSpec
public DBStatementStreamSpec(String optionalStreamName,
List<ViewSpec> viewSpecs,
String databaseName,
String sqlWithSubsParams)
- Ctor.
- Parameters:
optionalStreamName
- is a stream name optionally given to streamviewSpecs
- is a list of views onto the streamdatabaseName
- is the database name to pollsqlWithSubsParams
- is the SQL with placeholder parameters
getDatabaseName
public String getDatabaseName()
- Returns the database name.
- Returns:
- name of database.
getSqlWithSubsParams
public String getSqlWithSubsParams()
- Returns the SQL with substitution parameters.
- Returns:
- SQL with parameters embedded as ${stream.param}
compile
public StreamSpecCompiled compile(EventAdapterService eventAdapterService,
AutoImportService autoImportService)
- Description copied from interface:
StreamSpecRaw
- Compiles a raw stream specification consisting event type information and filter expressions
to an validated, optimized form for use with filter service
- Specified by:
compile
in interface StreamSpecRaw
- Parameters:
eventAdapterService
- supplies type informationautoImportService
- for resolving imports
- Returns:
- compiled stream