com.espertech.esper.core.start
Class EPPreparedExecuteIUDSingleStream

java.lang.Object
  com.espertech.esper.core.start.EPPreparedExecuteIUDSingleStream

All Implemented Interfaces:

EPPreparedExecuteMethod

Direct Known Subclasses:

EPPreparedExecuteIUDInsertInto, EPPreparedExecuteIUDSingleStreamDelete, EPPreparedExecuteIUDSingleStreamUpdate

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

Starts and provides the stop method for EPL statements.

Field Summary

protected EPPreparedExecuteIUDSingleStreamExec	executor
protected boolean	hasTableAccess
protected FireAndForgetProcessor	processor
protected EPServicesContext	services
protected StatementContext	statementContext
protected StatementSpecCompiled	statementSpec

Constructor Summary

EPPreparedExecuteIUDSingleStream(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 EPPreparedExecuteIUDSingleStreamExec	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 FireAndForgetProcessor processor

services

protected final EPServicesContext services

executor

protected final EPPreparedExecuteIUDSingleStreamExec executor

statementContext

protected final StatementContext statementContext

hasTableAccess

protected boolean hasTableAccess

Constructor Detail

EPPreparedExecuteIUDSingleStream

public EPPreparedExecuteIUDSingleStream(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 EPPreparedExecuteIUDSingleStreamExec getExecutor(FilterSpecCompiled filter,
                                                                 java.lang.String aliasName)
                                                          throws ExprValidationException

Throws:

ExprValidationException

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()