com.espertech.esper.core.context.util
Class EPStatementAgentInstanceHandle

java.lang.Object
  extended by com.espertech.esper.core.context.util.EPStatementAgentInstanceHandle

public class EPStatementAgentInstanceHandle
extends java.lang.Object


Constructor Summary
EPStatementAgentInstanceHandle(EPStatementHandle statementHandle, StatementAgentInstanceLock statementAgentInstanceLock, int agentInstanceId, StatementAgentInstanceFilterVersion statementFilterVersion)
           
 
Method Summary
 boolean equals(java.lang.Object otherObj)
           
 int getAgentInstanceId()
           
 FilterFaultHandler getFilterFaultHandler()
           
 EPStatementDispatch getOptionalDispatchable()
           
 int getPriority()
           
 StatementAgentInstanceLock getStatementAgentInstanceLock()
           
 StatementAgentInstanceFilterVersion getStatementFilterVersion()
           
 EPStatementHandle getStatementHandle()
           
 java.lang.String getStatementId()
           
 int hashCode()
           
 void internalDispatch(ExprEvaluatorContext exprEvaluatorContext)
          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()
           
 boolean isCurrentFilter(long filterVersion)
          Tests filter version.
 boolean isDestroyed()
           
 boolean isHasVariables()
           
 boolean isPreemptive()
           
 void setDestroyed(boolean destroyed)
           
 void setFilterFaultHandler(FilterFaultHandler filterFaultHandler)
           
 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 setStatementAgentInstanceLock(StatementAgentInstanceLock statementAgentInstanceLock)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

EPStatementAgentInstanceHandle

public EPStatementAgentInstanceHandle(EPStatementHandle statementHandle,
                                      StatementAgentInstanceLock statementAgentInstanceLock,
                                      int agentInstanceId,
                                      StatementAgentInstanceFilterVersion statementFilterVersion)
Method Detail

getStatementHandle

public EPStatementHandle getStatementHandle()

getStatementAgentInstanceLock

public StatementAgentInstanceLock getStatementAgentInstanceLock()

getAgentInstanceId

public int getAgentInstanceId()

getPriority

public int getPriority()

isPreemptive

public boolean isPreemptive()

isHasVariables

public boolean isHasVariables()

isCanSelfJoin

public boolean isCanSelfJoin()

setStatementAgentInstanceLock

public void setStatementAgentInstanceLock(StatementAgentInstanceLock statementAgentInstanceLock)

getStatementFilterVersion

public StatementAgentInstanceFilterVersion getStatementFilterVersion()

isCurrentFilter

public boolean isCurrentFilter(long filterVersion)
Tests filter version.

Parameters:
filterVersion - to test
Returns:
indicator whether version is up-to-date

equals

public boolean equals(java.lang.Object otherObj)
Overrides:
equals in class java.lang.Object

hashCode

public int hashCode()
Overrides:
hashCode in class java.lang.Object

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

getOptionalDispatchable

public EPStatementDispatch getOptionalDispatchable()

internalDispatch

public void internalDispatch(ExprEvaluatorContext exprEvaluatorContext)
Invoked by EPRuntime to indicate that a statements's filer and schedule processing is done, and now it's time to process join results.

Parameters:
exprEvaluatorContext - context for expression evaluation

isDestroyed

public boolean isDestroyed()

setDestroyed

public void setDestroyed(boolean destroyed)

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object

getFilterFaultHandler

public FilterFaultHandler getFilterFaultHandler()

setFilterFaultHandler

public void setFilterFaultHandler(FilterFaultHandler filterFaultHandler)

getStatementId

public java.lang.String getStatementId()

© 2006-2014 EsperTech Inc.
All rights reserved.
Visit us at espertech.com