com.espertech.esper.epl.named
Class NamedWindowProcessor

java.lang.Object
  com.espertech.esper.epl.named.NamedWindowProcessor

public class NamedWindowProcessor
extends java.lang.Object

An instance of this class is associated with a specific named window. The processor provides the views to create-window, on-delete statements and statements selecting from a named window.

Constructor Summary

NamedWindowProcessor(java.lang.String namedWindowName, NamedWindowMgmtService namedWindowMgmtService, NamedWindowDispatchService namedWindowDispatchService, java.lang.String contextName, EventType eventType, StatementResultService statementResultService, ValueAddEventProcessor revisionProcessor, java.lang.String eplExpression, java.lang.String statementName, boolean isPrioritized, boolean isEnableSubqueryIndexShare, boolean enableQueryPlanLog, MetricReportingService metricReportingService, boolean isBatchingDataWindow, boolean isVirtualDataWindow, java.util.Set<java.lang.String> optionalUniqueKeyProps, java.lang.String eventTypeAsName, StatementContext statementContextCreateWindow)
Ctor.

Method Summary

NamedWindowConsumerView	addConsumer(NamedWindowConsumerDesc consumerDesc, boolean isSubselect)
NamedWindowProcessorInstance	addInstance(AgentInstanceContext agentInstanceContext)
void	clearProcessorInstances()
void	destroy() Deletes a named window and removes any associated resources.
java.lang.String	getContextName()
StatementMetricHandle	getCreateNamedWindowMetricsHandle()
java.lang.String	getEplExpression() Returns the EPL expression.
EventTableIndexMetadata	getEventTableIndexMetadataRepo()
java.lang.String	getEventTypeAsName()
java.lang.String	getNamedWindowName()
EventType	getNamedWindowType() Returns the event type of the named window.
java.util.Set<java.lang.String>	getOptionalUniqueKeyProps()
NamedWindowProcessorInstance	getProcessorInstance(AgentInstanceContext agentInstanceContext)
NamedWindowProcessorInstance	getProcessorInstance(int agentInstanceId)
NamedWindowProcessorInstance	getProcessorInstanceAllowUnpartitioned(int agentInstanceId)
NamedWindowProcessorInstance	getProcessorInstanceNoContext()
java.util.Collection<java.lang.Integer>	getProcessorInstancesAll()
NamedWindowRootView	getRootView() Returns the root view of the named window, hooked into the view chain before the named window's data window views, right after the filter stream that filters for insert-into events.
StatementContext	getStatementContextCreateWindow()
java.lang.String	getStatementName() Returns the statement name.
NamedWindowTailView	getTailView() Returns the tail view of the named window, hooked into the view chain after the named window's data window views, as the last view.
java.lang.String[][]	getUniqueIndexes()
boolean	isEnableSubqueryIndexShare()
boolean	isVirtualDataWindow()
void	removeAllInstanceIndexes(IndexMultiKey index)
void	removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey imk, java.lang.String finalStatementName)
void	validateAddIndex(java.lang.String statementName, java.lang.String indexName, IndexMultiKey imk)

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedWindowProcessor

public NamedWindowProcessor(java.lang.String namedWindowName,
                            NamedWindowMgmtService namedWindowMgmtService,
                            NamedWindowDispatchService namedWindowDispatchService,
                            java.lang.String contextName,
                            EventType eventType,
                            StatementResultService statementResultService,
                            ValueAddEventProcessor revisionProcessor,
                            java.lang.String eplExpression,
                            java.lang.String statementName,
                            boolean isPrioritized,
                            boolean isEnableSubqueryIndexShare,
                            boolean enableQueryPlanLog,
                            MetricReportingService metricReportingService,
                            boolean isBatchingDataWindow,
                            boolean isVirtualDataWindow,
                            java.util.Set<java.lang.String> optionalUniqueKeyProps,
                            java.lang.String eventTypeAsName,
                            StatementContext statementContextCreateWindow)

Ctor.

Parameters:

namedWindowMgmtService - service for dispatching results

eventType - the type of event held by the named window

statementResultService - for coordinating on whether insert and remove stream events should be posted

revisionProcessor - for revision processing

eplExpression - epl expression

statementName - statement name

isPrioritized - if the engine is running with prioritized execution

Method Detail

getEventTypeAsName

public java.lang.String getEventTypeAsName()

addInstance

public NamedWindowProcessorInstance addInstance(AgentInstanceContext agentInstanceContext)

getProcessorInstanceNoContext

public NamedWindowProcessorInstance getProcessorInstanceNoContext()

getProcessorInstance

public NamedWindowProcessorInstance getProcessorInstance(int agentInstanceId)

getProcessorInstanceAllowUnpartitioned

public NamedWindowProcessorInstance getProcessorInstanceAllowUnpartitioned(int agentInstanceId)

getProcessorInstancesAll

public java.util.Collection<java.lang.Integer> getProcessorInstancesAll()

getProcessorInstance

public NamedWindowProcessorInstance getProcessorInstance(AgentInstanceContext agentInstanceContext)

getContextName

public java.lang.String getContextName()

addConsumer

public NamedWindowConsumerView addConsumer(NamedWindowConsumerDesc consumerDesc,
                                           boolean isSubselect)

isVirtualDataWindow

public boolean isVirtualDataWindow()

getTailView

public NamedWindowTailView getTailView()

Returns the tail view of the named window, hooked into the view chain after the named window's data window views, as the last view.

Returns:

tail view

getRootView

public NamedWindowRootView getRootView()

Returns the root view of the named window, hooked into the view chain before the named window's data window views, right after the filter stream that filters for insert-into events.

Returns:

tail view

getNamedWindowType

public EventType getNamedWindowType()

Returns the event type of the named window.

Returns:

event type

getEplExpression

public java.lang.String getEplExpression()

Returns the EPL expression.

Returns:

epl

getStatementName

public java.lang.String getStatementName()

Returns the statement name.

Returns:

name

destroy

public void destroy()

Deletes a named window and removes any associated resources.

isEnableSubqueryIndexShare

public boolean isEnableSubqueryIndexShare()

getCreateNamedWindowMetricsHandle

public StatementMetricHandle getCreateNamedWindowMetricsHandle()

getNamedWindowName

public java.lang.String getNamedWindowName()

getUniqueIndexes

public java.lang.String[][] getUniqueIndexes()

getOptionalUniqueKeyProps

public java.util.Set<java.lang.String> getOptionalUniqueKeyProps()

getEventTableIndexMetadataRepo

public EventTableIndexMetadata getEventTableIndexMetadataRepo()

getStatementContextCreateWindow

public StatementContext getStatementContextCreateWindow()

removeAllInstanceIndexes

public void removeAllInstanceIndexes(IndexMultiKey index)

validateAddIndex

public void validateAddIndex(java.lang.String statementName,
                             java.lang.String indexName,
                             IndexMultiKey imk)
                      throws ExprValidationException

Throws:

ExprValidationException

removeIndexReferencesStmtMayRemoveIndex

public void removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey imk,
                                                    java.lang.String finalStatementName)

clearProcessorInstances

public void clearProcessorInstances()