|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.esper.core.EPStatementHandle
public class EPStatementHandle
Class exists once per statement and hold statement resource lock(s).
Use by EPRuntimeImpl
for determining callback-statement affinity and locking of statement
resources.
Constructor Summary | |
---|---|
EPStatementHandle(String statementId,
ManagedLock statementLock,
String expressionText,
boolean hasVariables)
Ctor. |
Method Summary | |
---|---|
boolean |
equals(Object otherObj)
|
InsertIntoLatchFactory |
getInsertIntoLatchFactory()
Returns the factory for latches in insert-into guaranteed order of delivery. |
ManagedLock |
getStatementLock()
Returns statement resource lock. |
int |
hashCode()
|
void |
internalDispatch()
Invoked by EPRuntime to indicate that a statements's
filer and schedule processing is done, and now it's time to process join results. |
boolean |
isCanSelfJoin()
Returns true if the statement potentially self-joins amojng the events it processes. |
boolean |
isHasVariables()
Returns true if the statement uses variables, false if not. |
void |
setCanSelfJoin(boolean canSelfJoin)
Set the statement's self-join flag to indicate the the statement may join to itself, that is a single event may dispatch into multiple streams or patterns for the same statement, requiring internal dispatch logic to not shortcut evaluation of all filters for the statement within one lock, requiring the callback handle to be sorted. |
void |
setInsertIntoLatchFactory(InsertIntoLatchFactory insertIntoLatchFactory)
Sets the factory for latches in insert-into guaranteed order of delivery. |
void |
setOptionalDispatchable(EPStatementDispatch optionalDispatchable)
Provides a callback for use when statement processing for filters and schedules is done, for use by join statements that require an explicit indicator that all joined streams results have been processed. |
void |
setStatementLock(ManagedLock statementLock)
Sets the lock to use for the statement. |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public EPStatementHandle(String statementId, ManagedLock statementLock, String expressionText, boolean hasVariables)
statementId
- is the statement id uniquely indentifying the handlestatementLock
- is the statement resource lockexpressionText
- is the expressionhasVariables
- indicator whether the statement uses variablesMethod Detail |
---|
public void setCanSelfJoin(boolean canSelfJoin)
canSelfJoin
- is true if the statement potentially self-joins, false if notpublic void setInsertIntoLatchFactory(InsertIntoLatchFactory insertIntoLatchFactory)
insertIntoLatchFactory
- latch factory for the statement if it performs insert-into (route) of eventspublic InsertIntoLatchFactory getInsertIntoLatchFactory()
public ManagedLock getStatementLock()
public boolean isHasVariables()
public void setStatementLock(ManagedLock statementLock)
statementLock
- statement lockpublic void setOptionalDispatchable(EPStatementDispatch optionalDispatchable)
optionalDispatchable
- is the instance for calling onto after statement callback processingpublic void internalDispatch()
EPRuntime
to indicate that a statements's
filer and schedule processing is done, and now it's time to process join results.
public boolean equals(Object otherObj)
equals
in class Object
public int hashCode()
hashCode
in class Object
public boolean isCanSelfJoin()
|
© 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 |