com.espertech.esper.core.start
Class EPPreparedExecuteSingleStream

java.lang.Object
  extended by com.espertech.esper.core.start.EPPreparedExecuteSingleStream
All Implemented Interfaces:
EPPreparedExecuteMethod
Direct Known Subclasses:
EPPreparedExecuteSingleStreamDelete, EPPreparedExecuteSingleStreamUpdate

public abstract class EPPreparedExecuteSingleStream
extends java.lang.Object
implements EPPreparedExecuteMethod

Starts and provides the stop method for EPL statements.


Field Summary
protected  EPPreparedExecuteSingleStreamExec executor
           
protected  NamedWindowProcessor processor
           
protected  EPServicesContext services
           
protected  StatementContext statementContext
           
protected  StatementSpecCompiled statementSpec
           
 
Constructor Summary
EPPreparedExecuteSingleStream(StatementSpecCompiled statementSpec, EPServicesContext services, StatementContext statementContext)
          Ctor.
 
Method Summary
protected  void dispatch()
           
 EPPreparedQueryResult execute(ContextPartitionSelector[] contextPartitionSelectors)
          Executes the prepared query.
 EventType getEventType()
          Returns the event type of the prepared statement.
abstract  EPPreparedExecuteSingleStreamExec getExecutor(FilterSpecCompiled filter, java.lang.String aliasName)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

statementSpec

protected final StatementSpecCompiled statementSpec

processor

protected final NamedWindowProcessor processor

services

protected final EPServicesContext services

executor

protected final EPPreparedExecuteSingleStreamExec executor

statementContext

protected final StatementContext statementContext
Constructor Detail

EPPreparedExecuteSingleStream

public EPPreparedExecuteSingleStream(StatementSpecCompiled statementSpec,
                                     EPServicesContext services,
                                     StatementContext statementContext)
                              throws ExprValidationException
Ctor.

Parameters:
statementSpec - is a container for the definition of all statement constructs that may have been used in the statement, i.e. if defines the select clauses, insert into, outer joins etc.
services - is the service instances for dependency injection
statementContext - is statement-level information and statement services
Throws:
ExprValidationException - if the preparation failed
Method Detail

getExecutor

public abstract EPPreparedExecuteSingleStreamExec getExecutor(FilterSpecCompiled filter,
                                                              java.lang.String aliasName)

getEventType

public EventType getEventType()
Returns the event type of the prepared statement.

Specified by:
getEventType in interface EPPreparedExecuteMethod
Returns:
event type

execute

public EPPreparedQueryResult execute(ContextPartitionSelector[] contextPartitionSelectors)
Executes the prepared query.

Specified by:
execute in interface EPPreparedExecuteMethod
Returns:
query results

dispatch

protected void dispatch()

© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com