|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.espertech.esper.core.context.util.EPStatementAgentInstanceHandle
public class EPStatementAgentInstanceHandle
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 |
---|
public EPStatementAgentInstanceHandle(EPStatementHandle statementHandle, StatementAgentInstanceLock statementAgentInstanceLock, int agentInstanceId, StatementAgentInstanceFilterVersion statementFilterVersion)
Method Detail |
---|
public EPStatementHandle getStatementHandle()
public StatementAgentInstanceLock getStatementAgentInstanceLock()
public int getAgentInstanceId()
public int getPriority()
public boolean isPreemptive()
public boolean isHasVariables()
public boolean isCanSelfJoin()
public void setStatementAgentInstanceLock(StatementAgentInstanceLock statementAgentInstanceLock)
public StatementAgentInstanceFilterVersion getStatementFilterVersion()
public boolean isCurrentFilter(long filterVersion)
filterVersion
- to test
public boolean equals(java.lang.Object otherObj)
equals
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public void setOptionalDispatchable(EPStatementDispatch optionalDispatchable)
optionalDispatchable
- is the instance for calling onto after statement callback processingpublic EPStatementDispatch getOptionalDispatchable()
public void internalDispatch(ExprEvaluatorContext exprEvaluatorContext)
EPRuntime
to indicate that a statements's
filer and schedule processing is done, and now it's time to process join results.
exprEvaluatorContext
- context for expression evaluationpublic boolean isDestroyed()
public void setDestroyed(boolean destroyed)
public java.lang.String toString()
toString
in class java.lang.Object
public FilterFaultHandler getFilterFaultHandler()
public void setFilterFaultHandler(FilterFaultHandler filterFaultHandler)
public java.lang.String getStatementId()
|
© 2006-2011 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 |