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, NamedWindowService namedWindowService, java.lang.String contextName, boolean singleInstanceContext, 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, StatementMetricHandle statementMetricHandle, java.util.Set<java.lang.String> optionalUniqueKeyProps, java.lang.String eventTypeAsName)
Ctor.

Method Summary

NamedWindowConsumerView	addConsumer(NamedWindowConsumerDesc consumerDesc, boolean isSubselect)
NamedWindowProcessorInstance	addInstance(AgentInstanceContext agentInstanceContext)
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	getProcessorInstanceNoContext()
java.util.Collection<java.lang.Integer>	getProcessorInstancesAll()
long	getProcessorRowCountDefaultInstance()
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.
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(NamedWindowProcessorInstance processorInstance)
boolean	isEnableSubqueryIndexShare()
boolean	isVirtualDataWindow()
void	removeAllInstanceIndexes(IndexMultiKey index)
void	removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey imk, java.lang.String finalStatementName)
void	removeProcessorInstance(NamedWindowProcessorInstance instance)
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,
                            NamedWindowService namedWindowService,
                            java.lang.String contextName,
                            boolean singleInstanceContext,
                            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,
                            StatementMetricHandle statementMetricHandle,
                            java.util.Set<java.lang.String> optionalUniqueKeyProps,
                            java.lang.String eventTypeAsName)

Ctor.

Parameters:

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

removeProcessorInstance

public void removeProcessorInstance(NamedWindowProcessorInstance instance)

getProcessorInstanceNoContext

public NamedWindowProcessorInstance getProcessorInstanceNoContext()

getProcessorInstancesAll

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

getProcessorInstance

public NamedWindowProcessorInstance getProcessorInstance(int agentInstanceId)

getProcessorRowCountDefaultInstance

public long getProcessorRowCountDefaultInstance()

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

getOptionalUniqueKeyProps

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

getEventTableIndexMetadataRepo

public EventTableIndexMetadata getEventTableIndexMetadataRepo()

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)