|
||||||||||
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)
Ctor. |
Method Summary | |
---|---|
boolean |
equals(Object otherObj)
|
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. |
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 |
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. |
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)
statementId
- is the statement id uniquely indentifying the handlestatementLock
- is the statement resource lockexpressionText
- is the expressionMethod Detail |
---|
public void setCanSelfJoin(boolean canSelfJoin)
canSelfJoin
- is true if the statement potentially self-joins, false if notpublic ManagedLock getStatementLock()
public 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()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |