Package com.espertech.esper.common.internal.context.util

Class EPStatementHandle

java.lang.Object

com.espertech.esper.common.internal.context.util.EPStatementHandle

public class EPStatementHandle
extends Object

Class exists once per statement and hold statement resource lock(s).

The statement's self-join flag indicates 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.

Constructor Summary

Constructors

Constructor	Description
EPStatementHandle(String statementName, String deploymentId, int statementId, String optionalStatementEPL, int priority, boolean preemptive, boolean canSelfJoin, MultiMatchHandler multiMatchHandler, boolean hasVariables, boolean hasTableAccess, StatementMetricHandle metricsHandle, InsertIntoLatchFactory insertIntoFrontLatchFactory, InsertIntoLatchFactory insertIntoBackLatchFactory)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object otherObj)
String	getDeploymentId()
InsertIntoLatchFactory	getInsertIntoBackLatchFactory()
InsertIntoLatchFactory	getInsertIntoFrontLatchFactory()
StatementMetricHandle	getMetricsHandle()	Returns handle for metrics reporting.
MultiMatchHandler	getMultiMatchHandler()
String	getOptionalStatementEPL()
int	getPriority()	Returns the statement priority.
int	getStatementId()	Returns the statement id.
String	getStatementName()
int	hashCode()
boolean	isCanSelfJoin()	Returns true if the statement potentially self-joins amojng the events it processes.
boolean	isHasTableAccess()
boolean	isHasVariables()	Returns true if the statement uses variables, false if not.
boolean	isPreemptive()	True for preemptive (drop) statements.

Methods inherited from class java.lang.Object

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

Constructor Details

EPStatementHandle

public EPStatementHandle(String statementName,
 String deploymentId,
 int statementId,
 String optionalStatementEPL,
 int priority,
 boolean preemptive,
 boolean canSelfJoin,
 MultiMatchHandler multiMatchHandler,
 boolean hasVariables,
 boolean hasTableAccess,
 StatementMetricHandle metricsHandle,
 InsertIntoLatchFactory insertIntoFrontLatchFactory,
 InsertIntoLatchFactory insertIntoBackLatchFactory)

Method Details

getStatementId

public int getStatementId()

Returns the statement id.

Returns:

statement id

isHasVariables

public boolean isHasVariables()

Returns true if the statement uses variables, false if not.

Returns:

indicator if variables are used by statement

getPriority

public int getPriority()

Returns the statement priority.

Returns:

priority, default 0

isPreemptive

public boolean isPreemptive()

True for preemptive (drop) statements.

Returns:

preemptive indicator

equals

public boolean equals(Object otherObj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

isCanSelfJoin

public boolean isCanSelfJoin()

Returns true if the statement potentially self-joins amojng the events it processes.

Returns:

true for self-joins possible, false for not possible (most statements)

getMetricsHandle

public StatementMetricHandle getMetricsHandle()

Returns handle for metrics reporting.

Returns:

handle for metrics reporting

isHasTableAccess

public boolean isHasTableAccess()

getMultiMatchHandler

public MultiMatchHandler getMultiMatchHandler()

getStatementName

public String getStatementName()

getDeploymentId

public String getDeploymentId()

getOptionalStatementEPL

public String getOptionalStatementEPL()

getInsertIntoFrontLatchFactory

public InsertIntoLatchFactory getInsertIntoFrontLatchFactory()

getInsertIntoBackLatchFactory

public InsertIntoLatchFactory getInsertIntoBackLatchFactory()