com.espertech.esper.filter
Class ExprNodeAdapterMultiStreamStmtLock

java.lang.Object
  com.espertech.esper.filter.ExprNodeAdapterBase
      com.espertech.esper.filter.ExprNodeAdapterBaseVariables
          com.espertech.esper.filter.ExprNodeAdapterMultiStream
              com.espertech.esper.filter.ExprNodeAdapterMultiStreamStmtLock

public class ExprNodeAdapterMultiStreamStmtLock
extends ExprNodeAdapterMultiStream

Field Summary

static long

LOCK_BACKOFF_MSEC

Fields inherited from class com.espertech.esper.filter.ExprNodeAdapterMultiStream

prototypeArray

Fields inherited from class com.espertech.esper.filter.ExprNodeAdapterBaseVariables

variableService

Fields inherited from class com.espertech.esper.filter.ExprNodeAdapterBase

evaluatorContext, exprNode, exprNodeEval, statementName

Constructor Summary

ExprNodeAdapterMultiStreamStmtLock(java.lang.String statementName, ExprNode exprNode, ExprEvaluatorContext evaluatorContext, VariableService variableService, EventBean[] prototype)

Method Summary

protected boolean

evaluatePerStream(EventBean[] eventsPerStream)

Methods inherited from class com.espertech.esper.filter.ExprNodeAdapterMultiStream

evaluate

Methods inherited from class com.espertech.esper.filter.ExprNodeAdapterBase

getExprNode, getStatementName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOCK_BACKOFF_MSEC

public static final long LOCK_BACKOFF_MSEC

See Also:

Constant Field Values

Constructor Detail

ExprNodeAdapterMultiStreamStmtLock

public ExprNodeAdapterMultiStreamStmtLock(java.lang.String statementName,
                                          ExprNode exprNode,
                                          ExprEvaluatorContext evaluatorContext,
                                          VariableService variableService,
                                          EventBean[] prototype)

Method Detail

evaluatePerStream

protected boolean evaluatePerStream(EventBean[] eventsPerStream)

Overrides:

evaluatePerStream in class ExprNodeAdapterBase