net.esper.core
Class EPStatementHandle

java.lang.Object
  extended by net.esper.core.EPStatementHandle

public class EPStatementHandle
extends Object

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(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.
 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

EPStatementHandle

public EPStatementHandle(ManagedLock statementLock,
                         String expressionText)
Ctor.

Parameters:
statementLock - is the statement resource lock
expressionText - is the expression
Method Detail

getStatementLock

public ManagedLock getStatementLock()
Returns statement resource lock.

Returns:
lock

setOptionalDispatchable

public 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.

Parameters:
optionalDispatchable - is the instance for calling onto after statement callback processing

internalDispatch

public 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.


equals

public boolean equals(Object otherObj)
Overrides:
equals in class Object

hashCode

public int hashCode()
Overrides:
hashCode in class Object