|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.epl.named.NamedWindowProcessor
public class NamedWindowProcessor
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)
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 |
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)
|
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 |
---|
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)
namedWindowService
- service for dispatching resultseventType
- the type of event held by the named windowstatementResultService
- for coordinating on whether insert and remove stream events should be postedrevisionProcessor
- for revision processingeplExpression
- epl expressionstatementName
- statement nameisPrioritized
- if the engine is running with prioritized executionMethod Detail |
---|
public NamedWindowProcessorInstance addInstance(AgentInstanceContext agentInstanceContext)
public void removeProcessorInstance(NamedWindowProcessorInstance instance)
public NamedWindowProcessorInstance getProcessorInstanceNoContext()
public java.util.Collection<java.lang.Integer> getProcessorInstancesAll()
public NamedWindowProcessorInstance getProcessorInstance(int agentInstanceId)
public long getProcessorRowCountDefaultInstance()
public NamedWindowProcessorInstance getProcessorInstance(AgentInstanceContext agentInstanceContext)
public void validateOnExpressionContext(java.lang.String onExprContextName) throws ExprValidationException
ExprValidationException
public java.lang.String getContextName()
public NamedWindowConsumerView addConsumer(NamedWindowConsumerDesc consumerDesc, boolean isSubselect)
public boolean isVirtualDataWindow()
public NamedWindowTailView getTailView()
public NamedWindowRootView getRootView()
public EventType getNamedWindowType()
public java.lang.String getEplExpression()
public java.lang.String getStatementName()
public void destroy()
public boolean isEnableSubqueryIndexShare()
public StatementMetricHandle getCreateNamedWindowMetricsHandle()
public java.lang.String getNamedWindowName()
public java.lang.String[][] getUniqueIndexes(NamedWindowProcessorInstance processorInstance)
public java.util.Set<java.lang.String> getOptionalUniqueKeyProps()
|
© 2006-2011 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |