com.espertech.esper.epl.named
Class NamedWindowServiceImpl

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

All Implemented Interfaces:

NamedWindowService

public class NamedWindowServiceImpl
extends java.lang.Object
implements NamedWindowService

This service hold for each named window a dedicated processor and a lock to the named window. This lock is shrared between the named window and on-delete statements.

Field Summary

Fields inherited from interface com.espertech.esper.epl.named.NamedWindowService

ERROR_MSG_DATAWINDOWS, ERROR_MSG_NO_DATAWINDOW_ALLOWED

Constructor Summary

NamedWindowServiceImpl(SchedulingService schedulingService, VariableService variableService, TableService tableService, boolean isPrioritized, ManagedReadWriteLock eventProcessingRWLock, ExceptionHandlingService exceptionHandlingService, boolean enableQueryPlanLog, MetricReportingService metricReportingService)
Ctor.

Method Summary

void	addDispatch(NamedWindowDeltaData delta, java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers) For use to add a result of a named window that must be dispatched to consuming views.
void	addNamedWindowLock(java.lang.String windowName, StatementAgentInstanceLock statementResourceLock, java.lang.String statementName) Sets the lock to use for a named window.
void	addObserver(NamedWindowLifecycleObserver observer) Add an observer to be called back when named window state changes occur.
NamedWindowProcessor	addProcessor(java.lang.String name, 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 isBatchingDataWindow, boolean isVirtualDataWindow, StatementMetricHandle statementMetricHandle, java.util.Set<java.lang.String> optionalUniqueKeyProps, java.lang.String eventTypeAsName) Create a new named window.
void	destroy() Clear out the service.
boolean	dispatch() Dispatch events of the insert and remove stream of named windows to consumers, as part of the main event processing or dispatch loop.
java.util.LinkedHashMap<NamedWindowConsumerView,NamedWindowDeltaData>	getDeltaPerConsumer(java.lang.Object perStmtObj, EPStatementAgentInstanceHandle handle)
IndexMultiKey[]	getNamedWindowIndexes(java.lang.String windowName) Returns an index descriptor array describing all available indexes for the named window.
StatementAgentInstanceLock	getNamedWindowLock(java.lang.String windowName) Returns the statement lock for the named window, to be shared with on-delete statements for the same named window.
java.lang.String[]	getNamedWindows() Returns the names of all named windows known.
NamedWindowProcessor	getProcessor(java.lang.String name) Returns the processing instance for a given named window.
boolean	isNamedWindow(java.lang.String name) Returns true to indicate that the name is a named window.
void	removeNamedWindowLock(java.lang.String statementName) Remove the lock associated to the named window.
void	removeObserver(NamedWindowLifecycleObserver observer) Remove an observer to be called back when named window state changes occur.
void	removeProcessor(java.lang.String name) Upon destroy of the named window creation statement, the named window processor must be removed.

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedWindowServiceImpl

public NamedWindowServiceImpl(SchedulingService schedulingService,
                              VariableService variableService,
                              TableService tableService,
                              boolean isPrioritized,
                              ManagedReadWriteLock eventProcessingRWLock,
                              ExceptionHandlingService exceptionHandlingService,
                              boolean enableQueryPlanLog,
                              MetricReportingService metricReportingService)

Ctor.

Parameters:

variableService - is for variable access

isPrioritized - if the engine is running with prioritized execution

Method Detail

destroy

public void destroy()

Description copied from interface: NamedWindowService

Clear out the service.

Specified by:

destroy in interface NamedWindowService

getNamedWindows

public java.lang.String[] getNamedWindows()

Description copied from interface: NamedWindowService

Returns the names of all named windows known.

Specified by:

getNamedWindows in interface NamedWindowService

Returns:

named window names

getNamedWindowLock

public StatementAgentInstanceLock getNamedWindowLock(java.lang.String windowName)

Description copied from interface: NamedWindowService

Returns the statement lock for the named window, to be shared with on-delete statements for the same named window.

Specified by:

getNamedWindowLock in interface NamedWindowService

Parameters:

windowName - is the window name

Returns:

the lock for the named window, or null if the window dos not yet exists

addNamedWindowLock

public void addNamedWindowLock(java.lang.String windowName,
                               StatementAgentInstanceLock statementResourceLock,
                               java.lang.String statementName)

Description copied from interface: NamedWindowService

Sets the lock to use for a named window.

Specified by:

addNamedWindowLock in interface NamedWindowService

Parameters:

windowName - is the named window name

statementResourceLock - is the statement lock for the create window statement

statementName - the name of the statement that is the "create window"

removeNamedWindowLock

public void removeNamedWindowLock(java.lang.String statementName)

Description copied from interface: NamedWindowService

Remove the lock associated to the named window.

Specified by:

removeNamedWindowLock in interface NamedWindowService

Parameters:

statementName - the name of the statement that is the "create window"

isNamedWindow

public boolean isNamedWindow(java.lang.String name)

Description copied from interface: NamedWindowService

Returns true to indicate that the name is a named window.

Specified by:

isNamedWindow in interface NamedWindowService

Parameters:

name - is the window name

Returns:

true if a named window, false if not a named window

getProcessor

public NamedWindowProcessor getProcessor(java.lang.String name)

Description copied from interface: NamedWindowService

Returns the processing instance for a given named window.

Specified by:

getProcessor in interface NamedWindowService

Parameters:

name - window name

Returns:

processor for the named window

getNamedWindowIndexes

public IndexMultiKey[] getNamedWindowIndexes(java.lang.String windowName)

Description copied from interface: NamedWindowService

Returns an index descriptor array describing all available indexes for the named window.

Specified by:

getNamedWindowIndexes in interface NamedWindowService

Parameters:

windowName - window name

Returns:

indexes

addProcessor

public NamedWindowProcessor addProcessor(java.lang.String name,
                                         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 isBatchingDataWindow,
                                         boolean isVirtualDataWindow,
                                         StatementMetricHandle statementMetricHandle,
                                         java.util.Set<java.lang.String> optionalUniqueKeyProps,
                                         java.lang.String eventTypeAsName)
                                  throws ViewProcessingException

Description copied from interface: NamedWindowService

Create a new named window.

Specified by:

addProcessor in interface NamedWindowService

Parameters:

name - window name

eventType - the event type of the window

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

revisionProcessor - handles update events

eplExpression - is the expression

statementName - the name of the statement

isPrioritized - if the engine is running with prioritized execution

Returns:

processor for the named window

Throws:

ViewProcessingException - if the named window already exists

removeProcessor

public void removeProcessor(java.lang.String name)

Description copied from interface: NamedWindowService

Upon destroy of the named window creation statement, the named window processor must be removed.

Specified by:

removeProcessor in interface NamedWindowService

Parameters:

name - is the named window name

addDispatch

public void addDispatch(NamedWindowDeltaData delta,
                        java.util.Map<EPStatementAgentInstanceHandle,java.util.List<NamedWindowConsumerView>> consumers)

Description copied from interface: NamedWindowService

For use to add a result of a named window that must be dispatched to consuming views.

Specified by:

addDispatch in interface NamedWindowService

Parameters:

delta - is the result to dispatch

consumers - is the destination of the dispatch, a map of statements to one or more consuming views

dispatch

public boolean dispatch()

Description copied from interface: NamedWindowService

Dispatch events of the insert and remove stream of named windows to consumers, as part of the main event processing or dispatch loop.

Specified by:

dispatch in interface NamedWindowService

Returns:

send events to consuming statements

addObserver

public void addObserver(NamedWindowLifecycleObserver observer)

Description copied from interface: NamedWindowService

Add an observer to be called back when named window state changes occur.

Observers have set-semantics: the same Observer cannot be added twice

Specified by:

addObserver in interface NamedWindowService

Parameters:

observer - to add

removeObserver

public void removeObserver(NamedWindowLifecycleObserver observer)

Description copied from interface: NamedWindowService

Remove an observer to be called back when named window state changes occur.

Specified by:

removeObserver in interface NamedWindowService

Parameters:

observer - to remove

getDeltaPerConsumer

public java.util.LinkedHashMap<NamedWindowConsumerView,NamedWindowDeltaData> getDeltaPerConsumer(java.lang.Object perStmtObj,
                                                                                                 EPStatementAgentInstanceHandle handle)