|
||||||||||
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 |
getRoutedInsertStreamLock()
Returns the insert-into stream lock to use for reserving order in generated streams. |
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. |
void |
setRoutedInsertStreamLock(ManagedLock routedInsertStreamLock)
Set a insert-into stream lock to use for reserving order in generated streams. |
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)
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 void setRoutedInsertStreamLock(ManagedLock routedInsertStreamLock)
routedInsertStreamLock
- is a lock to use to lock the stream when routing events into itpublic ManagedLock getRoutedInsertStreamLock()
public ManagedLock getStatementLock()
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()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |