com.espertech.esper.epl.named
Class NamedWindowProcessor

java.lang.Object
  extended by 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.
 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 removeProcessorInstance(NamedWindowProcessorInstance instance)
           
 java.lang.String validateContextAssociation(java.lang.String optionalProvidedContextName)
           
 void validateOnExpressionContext(java.lang.String onExprContextName)
           
 
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)

validateOnExpressionContext

public void validateOnExpressionContext(java.lang.String onExprContextName)
                                 throws ExprValidationException
Throws:
ExprValidationException

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

validateContextAssociation

public java.lang.String validateContextAssociation(java.lang.String optionalProvidedContextName)

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