|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface NamedWindowService
Service to manage named window dispatches, locks and processors on an engine level.
Field Summary | |
---|---|
static String |
ERROR_MSG_DATAWINDOWS
Error message for data windows required. |
static String |
ERROR_MSG_NO_DATAWINDOW_ALLOWED
Error message for no data window allowed. |
Method Summary | |
---|---|
void |
addDispatch(NamedWindowDeltaData delta,
Map<EPStatementHandle,List<NamedWindowConsumerView>> consumers)
For use to add a result of a named window that must be dispatched to consuming views. |
void |
addNamedWindowLock(String windowName,
ManagedLock statementResourceLock)
Sets the lock to use for a named window. |
NamedWindowProcessor |
addProcessor(String name,
EventType eventType,
EPStatementHandle createWindowStmtHandle,
StatementResultService statementResultService)
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. |
ManagedLock |
getNamedWindowLock(String windowName)
Returns the statement lock for the named window, to be shared with on-delete statements for the same named window. |
NamedWindowProcessor |
getProcessor(String name)
Returns the processing instance for a given named window. |
boolean |
isNamedWindow(String name)
Returns true to indicate that the name is a named window. |
void |
removeProcessor(String name)
Upon destroy of the named window creation statement, the named window processor must be removed. |
Field Detail |
---|
static final String ERROR_MSG_DATAWINDOWS
static final String ERROR_MSG_NO_DATAWINDOW_ALLOWED
Method Detail |
---|
boolean isNamedWindow(String name)
name
- is the window name
NamedWindowProcessor addProcessor(String name, EventType eventType, EPStatementHandle createWindowStmtHandle, StatementResultService statementResultService) throws ViewProcessingException
name
- window nameeventType
- the event type of the windowcreateWindowStmtHandle
- is the handle and lock of the create-named-window statementstatementResultService
- for coordinating on whether insert and remove stream events should be posted
ViewProcessingException
- if the named window already existsNamedWindowProcessor getProcessor(String name)
name
- window name
void removeProcessor(String name)
name
- is the named window nameboolean dispatch()
void addDispatch(NamedWindowDeltaData delta, Map<EPStatementHandle,List<NamedWindowConsumerView>> consumers)
delta
- is the result to dispatchconsumers
- is the destination of the dispatch, a map of statements to one or more consuming viewsManagedLock getNamedWindowLock(String windowName)
windowName
- is the window name
void addNamedWindowLock(String windowName, ManagedLock statementResourceLock)
windowName
- is the named window namestatementResourceLock
- is the statement lock for the create window statementvoid destroy()
|
© 2007 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 |