com.espertech.esper.epl.named

Class NamedWindowProcessor

java.lang.Object

com.espertech.esper.epl.named.NamedWindowProcessor

public class NamedWindowProcessor
extends 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

Constructors

Constructor and Description

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

Method Summary

Modifier and Type	Method and Description
NamedWindowConsumerView	addConsumer(NamedWindowConsumerDesc consumerDesc, boolean isSubselect)
NamedWindowProcessorInstance	addInstance(AgentInstanceContext agentInstanceContext)
void	clearProcessorInstances()
void	destroy() Deletes a named window and removes any associated resources.
String	getContextName()
StatementMetricHandle	getCreateNamedWindowMetricsHandle()
String	getEplExpression() Returns the EPL expression.
EventTableIndexMetadata	getEventTableIndexMetadataRepo()
String	getEventTypeAsName()
String	getNamedWindowName()
EventType	getNamedWindowType() Returns the event type of the named window.
Set<String>	getOptionalUniqueKeyProps()
NamedWindowProcessorInstance	getProcessorInstance(AgentInstanceContext agentInstanceContext)
NamedWindowProcessorInstance	getProcessorInstance(int agentInstanceId)
NamedWindowProcessorInstance	getProcessorInstanceAllowUnpartitioned(int agentInstanceId)
NamedWindowProcessorInstance	getProcessorInstanceNoContext()
Collection<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()
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.
String[][]	getUniqueIndexes()
boolean	isEnableSubqueryIndexShare()
boolean	isVirtualDataWindow()
void	removeAllInstanceIndexes(IndexMultiKey index)
void	removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey imk, String finalStatementName)
void	validateAddIndex(String statementName, String explicitIndexName, QueryPlanIndexItem explicitIndexDesc, 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(String namedWindowName,
                            NamedWindowMgmtService namedWindowMgmtService,
                            NamedWindowDispatchService namedWindowDispatchService,
                            String contextName,
                            EventType eventType,
                            StatementResultService statementResultService,
                            ValueAddEventProcessor revisionProcessor,
                            String eplExpression,
                            String statementName,
                            boolean isPrioritized,
                            boolean isEnableSubqueryIndexShare,
                            boolean enableQueryPlanLog,
                            MetricReportingService metricReportingService,
                            boolean isBatchingDataWindow,
                            boolean isVirtualDataWindow,
                            Set<String> optionalUniqueKeyProps,
                            String eventTypeAsName,
                            StatementContext statementContextCreateWindow)

Method Detail

getEventTypeAsName

public 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 Collection<Integer> getProcessorInstancesAll()

getProcessorInstance

public NamedWindowProcessorInstance getProcessorInstance(AgentInstanceContext agentInstanceContext)

getContextName

public 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 String getEplExpression()

Returns the EPL expression.

Returns:

epl

getStatementName

public 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 String getNamedWindowName()

getUniqueIndexes

public String[][] getUniqueIndexes()

getOptionalUniqueKeyProps

public Set<String> getOptionalUniqueKeyProps()

getEventTableIndexMetadataRepo

public EventTableIndexMetadata getEventTableIndexMetadataRepo()

getStatementContextCreateWindow

public StatementContext getStatementContextCreateWindow()

removeAllInstanceIndexes

public void removeAllInstanceIndexes(IndexMultiKey index)

validateAddIndex

public void validateAddIndex(String statementName,
                             String explicitIndexName,
                             QueryPlanIndexItem explicitIndexDesc,
                             IndexMultiKey imk)
                      throws ExprValidationException

Throws:

ExprValidationException

removeIndexReferencesStmtMayRemoveIndex

public void removeIndexReferencesStmtMayRemoveIndex(IndexMultiKey imk,
                                                    String finalStatementName)

clearProcessorInstances

public void clearProcessorInstances()