|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ExprEvaluatorContext | |
---|---|
com.espertech.esper.client.hook | Callback interfaces for use with statement annotations. |
com.espertech.esper.collection | Internal collection classes |
com.espertech.esper.core.context.factory | Statement agent instance factories. |
com.espertech.esper.core.context.stmt | Registries for context partitions to handle aggregations, prev/prior and subselects. |
com.espertech.esper.core.context.util | Context partition utility or reference classes. |
com.espertech.esper.core.service | Implementation of client package interfaces, glue code |
com.espertech.esper.core.start | Classes related to start and stop of statements |
com.espertech.esper.epl.agg.access | State multifunction aggregation methods |
com.espertech.esper.epl.agg.service | Aggregation services. |
com.espertech.esper.epl.approx | Approximation algos. |
com.espertech.esper.epl.core | Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc. |
com.espertech.esper.epl.core.eval | Select expression evaluators. |
com.espertech.esper.epl.datetime.calop | Date-Time calendar operations. |
com.espertech.esper.epl.datetime.eval | Date-Time methods and related utility classes. |
com.espertech.esper.epl.datetime.interval | Interval algebra. |
com.espertech.esper.epl.datetime.reformatop | Date-Time re-formatting operations. |
com.espertech.esper.epl.db | Database SQL polling views and caches |
com.espertech.esper.epl.declexpr | Declared expression handling. |
com.espertech.esper.epl.enummethod.dot | Enumeration method utility classes and input data sources. |
com.espertech.esper.epl.enummethod.eval | Enumeration method implementations. |
com.espertech.esper.epl.expression.accessagg | Access-aggregation expressions. |
com.espertech.esper.epl.expression.baseagg | Base aggregation expressions. |
com.espertech.esper.epl.expression.core | Core expression classes. |
com.espertech.esper.epl.expression.dot | Chained expression functionality. |
com.espertech.esper.epl.expression.dot.inner | Expression dot-method inner evaluators. |
com.espertech.esper.epl.expression.funcs | Function expressions. |
com.espertech.esper.epl.expression.ops | Operator expressions. |
com.espertech.esper.epl.expression.prev | 'Previous'-group expressions. |
com.espertech.esper.epl.expression.prior | 'Prior'-group expressions. |
com.espertech.esper.epl.expression.subquery | Subselect expressions. |
com.espertech.esper.epl.expression.table | Table access and identifiers expressions. |
com.espertech.esper.epl.expression.time | Time-related expressions. |
com.espertech.esper.epl.join.base | Join process interfaces and glue code |
com.espertech.esper.epl.join.exec.base | Inner join execution |
com.espertech.esper.epl.join.exec.composite | Composite query execution for hash+btree combined lookup. |
com.espertech.esper.epl.join.exec.sorted | Btree lookup for query execution. |
com.espertech.esper.epl.join.plan | Inner join and outer join query planning |
com.espertech.esper.epl.lookup | Subquery execution strategies and lookup indexes |
com.espertech.esper.epl.named | Named window classes are in this package |
com.espertech.esper.epl.parse | Parsers and AST tree walkers and helper classes transforming AST into business objects |
com.espertech.esper.epl.property | Classes for handling events-within-events. |
com.espertech.esper.epl.script | Script expression evaluation. |
com.espertech.esper.epl.spec | Contains EPL statement specification classes define the constructs that make up an EPL statement, such as the list of items in the select clause, the insert-into stream name and property names etc. |
com.espertech.esper.epl.subquery | Subquery helper classes are found here. |
com.espertech.esper.epl.table.merge | Table on-merge handlers. |
com.espertech.esper.epl.table.mgmt | Table-related services and metadata. |
com.espertech.esper.epl.table.onaction | Table on-action handlers. |
com.espertech.esper.epl.table.strategy | Table access evaluators. |
com.espertech.esper.epl.table.upd | Table update strategies. |
com.espertech.esper.epl.updatehelper | Helpers for EPL update functionality. |
com.espertech.esper.epl.variable | Variable service and variable collections |
com.espertech.esper.epl.view | Internal processing views for output rate limiting, filtering and internal event routing |
com.espertech.esper.epl.virtualdw | Virtual data window. |
com.espertech.esper.event | This package defines the internal event APIs. |
com.espertech.esper.event.bean | JavaBean and legacy Java underlying event classes are here. |
com.espertech.esper.filter | Main switchboard filtering and routing of incoming events to interested statements is performed in this package. |
com.espertech.esper.metrics.instrumentation | EPL instrumentation helpers. |
com.espertech.esper.pattern | Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active pattern instance |
com.espertech.esper.rowregex | Match-recognize expression tree and state objects. |
com.espertech.esper.type | Internal primitive, enum and other type representations |
com.espertech.esper.view | View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering. |
com.espertech.esper.view.ext | Extension views that providing services such as sorting, which don't fit much into other categories. |
com.espertech.esper.view.internal | Internal management views for buffering view results and providing these to joins. |
com.espertech.esper.view.stream | View to event stream relationship service |
Uses of ExprEvaluatorContext in com.espertech.esper.client.hook |
---|
Methods in com.espertech.esper.client.hook that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
VirtualDataWindowEventConsumerAdd.getExprEvaluatorContext()
Returns the expression evaluator context for evaluating filter expressions. |
Constructors in com.espertech.esper.client.hook with parameters of type ExprEvaluatorContext | |
---|---|
VirtualDataWindowEventConsumerAdd(java.lang.String namedWindowName,
java.lang.Object consumerObject,
java.lang.String statementName,
int agentInstanceId,
ExprNode[] filterExpressions,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
Uses of ExprEvaluatorContext in com.espertech.esper.collection |
---|
Constructors in com.espertech.esper.collection with parameters of type ExprEvaluatorContext | |
---|---|
FilteredEventIterator(ExprEvaluator[] filters,
java.util.Iterator<EventBean> parent,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
Uses of ExprEvaluatorContext in com.espertech.esper.core.context.factory |
---|
Constructors in com.espertech.esper.core.context.factory with parameters of type ExprEvaluatorContext | |
---|---|
StatementAgentInstancePostLoadSelect(Viewable[] streamViews,
JoinSetComposerDesc joinSetComposer,
NamedWindowTailViewInstance[] namedWindowTailViews,
FilterSpecCompiled[] namedWindowPostloadFilters,
java.util.List<ExprNode>[] namedWindowFilters,
java.lang.annotation.Annotation[] annotations,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.core.context.stmt |
---|
Methods in com.espertech.esper.core.context.stmt with parameters of type ExprEvaluatorContext | |
---|---|
void |
AIRegistryAggregationSingle.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationMultiPerm.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationMap.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationSingle.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationMultiPerm.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationMap.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationSingle.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationMultiPerm.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AIRegistryAggregationMap.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryTableAccessSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryTableAccessMultiPerm.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
AIRegistryTableAccessMap.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
AIRegistryPriorSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber)
|
java.lang.Object |
AIRegistryPriorMultiPerm.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber)
|
java.lang.Object |
AIRegistryPriorMap.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber)
|
java.lang.Object |
AIRegistryPreviousSingle.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryPreviousMultiPerm.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryPreviousMap.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AIRegistryPreviousSingle.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryPreviousMultiPerm.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryPreviousMap.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
AIRegistryPreviousSingle.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
AIRegistryPreviousMultiPerm.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
AIRegistryPreviousMap.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryTableAccessSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryTableAccessMultiPerm.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryTableAccessMap.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryPreviousSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryPreviousMultiPerm.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryPreviousMap.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryTableAccessSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryTableAccessMultiPerm.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryTableAccessMap.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
AIRegistryTableAccessSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
AIRegistryTableAccessMultiPerm.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
AIRegistryTableAccessMap.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistrySubselectSingle.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AIRegistrySubselectMultiPerm.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AIRegistrySubselectMap.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
AIRegistryTableAccessSingle.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
AIRegistryTableAccessMultiPerm.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
AIRegistryTableAccessMap.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousSingle.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousMultiPerm.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousMap.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AIRegistryAggregationSingle.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryAggregationMultiPerm.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryAggregationMap.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AIRegistryAggregationSingle.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AIRegistryAggregationMultiPerm.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AIRegistryAggregationMap.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryAggregationSingle.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryAggregationMultiPerm.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryAggregationMap.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AIRegistryAggregationSingle.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AIRegistryAggregationMultiPerm.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AIRegistryAggregationMap.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryAggregationSingle.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryAggregationMultiPerm.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AIRegistryAggregationMap.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.core.context.util |
---|
Classes in com.espertech.esper.core.context.util that implement ExprEvaluatorContext | |
---|---|
class |
AgentInstanceContext
|
class |
AgentInstanceViewFactoryChainContext
|
Uses of ExprEvaluatorContext in com.espertech.esper.core.service |
---|
Classes in com.espertech.esper.core.service that implement ExprEvaluatorContext | |
---|---|
class |
ExprEvaluatorContextStatement
Represents a statement-level-only context for expression evaluation, not allowing for agents instances and result cache. |
class |
ExprEvaluatorContextWTableAccess
|
Methods in com.espertech.esper.core.service with parameters of type ExprEvaluatorContext | |
---|---|
EventBean |
InternalEventRouterImpl.preprocess(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Pre-process the event. |
EventBean |
InternalEventRouter.preprocess(EventBean theEvent,
ExprEvaluatorContext engineFilterAndDispatchTimeContext)
|
EventBean |
InternalEventRouterPreprocessor.process(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Pre-proces the event. |
void |
InternalEventRouterImpl.route(EventBean theEvent,
EPStatementHandle statementHandle,
InternalEventRouteDest routeDest,
ExprEvaluatorContext exprEvaluatorContext,
boolean addToFront)
|
void |
InternalEventRouter.route(EventBean theEvent,
EPStatementHandle statementHandle,
InternalEventRouteDest routeDest,
ExprEvaluatorContext exprEvaluatorContext,
boolean addToFront)
Route the event such that the event is processed as required. |
void |
StatementResultServiceImpl.setSelectClause(java.lang.Class[] selectClauseTypes,
java.lang.String[] selectClauseColumnNames,
boolean forClauseDelivery,
ExprEvaluator[] groupDeliveryExpressions,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
StatementResultService.setSelectClause(java.lang.Class[] selectClauseTypes,
java.lang.String[] selectClauseColumnNames,
boolean forClauseDelivery,
ExprEvaluator[] groupDeliveryExpressions,
ExprEvaluatorContext exprEvaluatorContext)
For initialize of the service providing select clause column types and names. |
Constructors in com.espertech.esper.core.service with parameters of type ExprEvaluatorContext | |
---|---|
ExprEvaluatorContextWTableAccess(ExprEvaluatorContext context,
TableService tableService)
|
Uses of ExprEvaluatorContext in com.espertech.esper.core.start |
---|
Methods in com.espertech.esper.core.start that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
EPPreparedExecuteIUDSingleStreamExecInsert.getExprEvaluatorContext()
|
Methods in com.espertech.esper.core.start with parameters of type ExprEvaluatorContext | |
---|---|
protected static ExprNode |
EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNodeOrigin exprNodeOrigin,
ExprNode exprNode,
StreamTypeService streamTypeService,
StatementContext statementContext,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String errorMsg,
boolean allowTableConsumption)
|
Constructors in com.espertech.esper.core.start with parameters of type ExprEvaluatorContext | |
---|---|
EPPreparedExecuteIUDSingleStreamExecInsert(ExprEvaluatorContext exprEvaluatorContext,
SelectExprProcessor insertHelper,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.agg.access |
---|
Methods in com.espertech.esper.epl.agg.access with parameters of type ExprEvaluatorContext | |
---|---|
void |
AggregationStateSortedImpl.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationStateMinMaxByEver.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationStateJoinImpl.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationStateImpl.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationState.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Enter an event. |
void |
AggregationAgentRewriteStream.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
void |
AggregationAgentDefault.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
void |
AggregationAgent.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
void |
AggregationStateSortedImpl.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationStateMinMaxByEver.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationStateJoinImpl.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationStateImpl.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationState.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Remove an event. |
void |
AggregationAgentRewriteStream.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
void |
AggregationAgentDefault.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
void |
AggregationAgent.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
protected static java.lang.Object |
AggregationStateSortedImpl.getComparable(ExprEvaluator[] criteria,
EventBean[] eventsPerStream,
boolean istream,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorWindowWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorWindowNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorSortedTable.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorSortedNonTable.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorMinMaxByBase.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorLastWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorLastNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorFirstWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorFirstNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorFirstLastIndexWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessorFirstLastIndexNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
AggregationAccessor.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a single event. |
java.util.Collection<EventBean> |
AggregationAccessorWindowWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorWindowNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorSortedTable.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorSortedNonTable.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorMinMaxByBase.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationAccessorLastWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorLastNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorFirstWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorFirstNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorFirstLastIndexWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessorFirstLastIndexNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggregationAccessor.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of events. |
java.util.Collection<java.lang.Object> |
AggregationAccessorWindowWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorWindowNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorSortedTable.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorSortedNonTable.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorMinMaxByBase.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorLastWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorLastNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorFirstWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorFirstNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorFirstLastIndexWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessorFirstLastIndexNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationAccessor.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of scalar values. |
java.lang.Object |
AggregationAccessorWindowWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorWindowNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorSortedTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorSortedNonTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorMinMaxByTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
AggregationAccessorMinMaxByNonTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
AggregationAccessorLastWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorLastNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorFirstWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorFirstNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorFirstLastIndexWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessorFirstLastIndexNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationAccessor.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value either as a scalar value or any other object. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.agg.service |
---|
Methods in com.espertech.esper.epl.agg.service with parameters of type ExprEvaluatorContext | |
---|---|
protected static void |
AggSvcGroupLocalGroupByBase.aggregateIntoEnter(AggregationLocalGroupByLevel level,
AggregationMethod[] methods,
AggregationState[] states,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
AggSvcGroupLocalGroupByBase.aggregateIntoLeave(AggregationLocalGroupByLevel level,
AggregationMethod[] methods,
AggregationState[] states,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceMatchRecognizeImpl.applyEnter(EventBean[] eventsPerStream,
int streamId,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceMatchRecognize.applyEnter(EventBean[] eventsPerStream,
int streamId,
ExprEvaluatorContext exprEvaluatorContext)
Enter a single event row consisting of one or more events per stream (each stream representing a variable). |
void |
AggSvcGroupLocalGroupByBase.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKeyProvided,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableBase.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedWAccessRollupImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object compositeGroupKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedWAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedNoAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByReclaimAgedImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByNoAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByMixedAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByAccessOnlyImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllNoAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllMixedAccessWTableImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllMixedAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllAccessOnlyImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceTable.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceNull.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationService.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as entering a window (new events). |
protected void |
AggSvcGroupByWTableBase.applyEnterGroupKey(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableRollupSingleKeyImpl.applyEnterInternal(EventBean[] eventsPerStream,
java.lang.Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableRollupMultiKeyImpl.applyEnterInternal(EventBean[] eventsPerStream,
java.lang.Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableImpl.applyEnterInternal(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract void |
AggSvcGroupByWTableBase.applyEnterInternal(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupLocalGroupByBase.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKeyProvided,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableBase.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedWAccessRollupImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object compositeGroupKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedWAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedNoAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByReclaimAgedImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByNoAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByMixedAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByAccessOnlyImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllNoAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllMixedAccessWTableImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllMixedAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllAccessOnlyImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceTable.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceNull.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationService.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as leaving a window (old events). |
protected void |
AggSvcGroupByWTableBase.applyLeaveGroupKey(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableRollupSingleKeyImpl.applyLeaveInternal(EventBean[] eventsPerStream,
java.lang.Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableRollupMultiKeyImpl.applyLeaveInternal(EventBean[] eventsPerStream,
java.lang.Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableImpl.applyLeaveInternal(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract void |
AggSvcGroupByWTableBase.applyLeaveInternal(EventBean[] eventsPerStream,
java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupLocalGroupByBase.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByWTableBase.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedWAccessRollupImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedWAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByRefcountedNoAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByReclaimAgedImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByNoAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByMixedAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupByAccessOnlyImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllNoAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllMixedAccessWTableImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllMixedAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllAccessOnlyImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceTable.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceNull.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationService.clearResults(ExprEvaluatorContext exprEvaluatorContext)
Clear current aggregation state. |
protected abstract java.lang.Object |
AggSvcGroupLocalGroupByBase.computeGroupKey(AggregationLocalGroupByLevel level,
java.lang.Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
protected java.lang.Object |
AggSvcGroupByLocalGroupBy.computeGroupKey(AggregationLocalGroupByLevel level,
java.lang.Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
protected java.lang.Object |
AggSvcGroupAllLocalGroupBy.computeGroupKey(AggregationLocalGroupByLevel level,
java.lang.Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static java.lang.Object |
AggSvcGroupLocalGroupByBase.computeGroupKey(ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean b,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AggSvcGroupLocalGroupByBase.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByWTableBase.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByRefcountedWAccessRollupImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByRefcountedWAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByRefcountedNoAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByReclaimAgedImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByNoAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByMixedAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByAccessOnlyImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllNoAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllMixedAccessWTableImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllMixedAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllAccessOnlyImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationServiceTable.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationServiceNull.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationServiceMatchRecognizeImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationResultFuture.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupLocalGroupByBase.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByWTableBase.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByRefcountedWAccessRollupImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByRefcountedWAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByRefcountedNoAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByReclaimAgedImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByNoAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByMixedAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByAccessOnlyImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllNoAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllMixedAccessWTableImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllMixedAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllAccessOnlyImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggregationServiceTable.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggregationServiceNull.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggregationServiceMatchRecognizeImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggregationResultFuture.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupLocalGroupByBase.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByWTableBase.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByRefcountedWAccessRollupImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByRefcountedWAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByRefcountedNoAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByReclaimAgedImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByNoAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByMixedAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByAccessOnlyImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllNoAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllMixedAccessWTableImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllMixedAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllAccessOnlyImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggregationServiceTable.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggregationServiceNull.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggregationServiceMatchRecognizeImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
AggregationResultFuture.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupLocalGroupByBase.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByWTableBase.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByRefcountedWAccessRollupImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByRefcountedWAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByRefcountedNoAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByReclaimAgedImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByNoAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByMixedAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupByAccessOnlyImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllNoAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllMixedAccessWTableImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllMixedAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllAccessOnlyImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationServiceTable.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationServiceNull.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationServiceMatchRecognizeImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggregationResultFuture.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByWTableBase.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByRefcountedWAccessRollupImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByRefcountedWAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByRefcountedNoAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByReclaimAgedImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByNoAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByMixedAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByLocalGroupBy.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupByAccessOnlyImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupAllNoAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupAllMixedAccessWTableImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupAllMixedAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupAllLocalGroupBy.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggSvcGroupAllAccessOnlyImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationServiceTable.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationServiceNull.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationServiceMatchRecognizeImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
AggregationResultFuture.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Returns current aggregation state, for use by expression node representing an aggregation function. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.approx |
---|
Methods in com.espertech.esper.epl.approx with parameters of type ExprEvaluatorContext | |
---|---|
void |
CountMinSketchAggState.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
CountMinSketchAggAgentAdd.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
void |
CountMinSketchAggState.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
CountMinSketchAggAgentAdd.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState)
|
EventBean |
CountMinSketchAggAccessorTopk.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
CountMinSketchAggAccessorFrequency.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
CountMinSketchAggAccessorDefault.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
CountMinSketchAggAccessorTopk.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
CountMinSketchAggAccessorFrequency.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
CountMinSketchAggAccessorDefault.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
CountMinSketchAggAccessorTopk.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
CountMinSketchAggAccessorFrequency.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
CountMinSketchAggAccessorDefault.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
CountMinSketchAggAccessorTopk.getValue(AggregationState aggregationState,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
CountMinSketchAggAccessorFrequency.getValue(AggregationState aggregationState,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
CountMinSketchAggAccessorDefault.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.core |
---|
Methods in com.espertech.esper.epl.core with parameters of type ExprEvaluatorContext | |
---|---|
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents)
|
static void |
ResultSetProcessorUtil.applyAggViewResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
EventBean[] newData,
EventBean[] oldData,
EventBean[] eventsPerStream)
|
static void |
ResultSetProcessorUtil.clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService,
Viewable parent)
|
static HistoricalEventViewable |
MethodPollingViewableFactory.createPollMethodView(int streamNumber,
MethodStreamSpec methodStreamSpec,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
MethodResolutionService methodResolutionService,
EngineImportService engineImportService,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
java.lang.String contextName)
Creates a method-invocation polling view for use as a stream that calls a method, or pulls results from cache. |
EventBean |
OrderByProcessorImpl.determineLocalMinMax(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
SelectExprInsertEventBeanFactory.ExprEvaluatorJoinWildcard.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
BindProcessorEvaluatorStreamTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
BindProcessorEvaluatorStream.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
static SelectExprProcessor |
SelectExprProcessorFactory.getProcessor(java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
SelectClauseElementCompiled[] selectionList,
boolean isUsingWildcard,
InsertIntoDesc insertIntoDesc,
EventType optionalInsertIntoEventType,
ForClauseSpec forClauseSpec,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
StatementResultService statementResultService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
MethodResolutionService methodResolutionService,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
TableService tableService,
TimeProvider timeProvider,
java.lang.String engineURI,
java.lang.String statementId,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configuration,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
NamedWindowService namedWindowService,
IntoTableSpec intoTableClause)
Returns the processor to use for a given select-clause. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectEventsHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorHandThrough.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext agentInstanceContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorHandThrough.getSelectEventsNoHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext agentInstanceContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
protected static EventBean[] |
ResultSetProcessorUtil.getSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events. |
java.lang.Object |
OrderByProcessorRowLimitOnly.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
OrderByProcessorOrderedLimit.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
OrderByProcessorImpl.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
OrderByProcessor.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Returns the sort key for a given row. |
java.lang.Object |
OrderByProcessorRowLimitOnly.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel)
|
java.lang.Object |
OrderByProcessorOrderedLimit.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel)
|
java.lang.Object |
OrderByProcessorImpl.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel)
|
java.lang.Object |
OrderByProcessor.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel)
|
java.lang.Object[] |
OrderByProcessorRowLimitOnly.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
OrderByProcessorOrderedLimit.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
OrderByProcessorImpl.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
OrderByProcessor.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Returns the sort key for a each row where a row is a single event (no join, single stream). |
EventTable[][] |
MethodPollingViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.List<EventBean> |
MethodPollingExecStrategyBase.poll(java.lang.Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectEventsHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
java.util.List<java.lang.Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
java.util.Collection<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
java.util.Collection<EventBean> result,
java.util.List<java.lang.Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
java.util.List<java.lang.Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
java.util.List<EventBean> result,
java.util.List<java.lang.Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprWildcardTableProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprWildcardProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprResultProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprProcessorWDeliveryCallback.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Computes the select-clause results and returns an event of the result event type that contains, in it's properties, the selected items. |
EventBean |
SelectExprJoinWildcardProcessorTableRows.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprJoinWildcardProcessorObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprJoinWildcardProcessorMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceNative.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeWidening.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeNoWiden.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
BindProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Process select expressions into columns for native dispatch. |
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Sort the output events. |
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
java.lang.Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
java.lang.Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
java.lang.Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
java.lang.Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys. |
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
java.lang.Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
java.lang.Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
java.lang.Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
java.lang.Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext)
Sort a given array of outgoing events using the sort keys returning a sorted outgoing event array. |
void |
MethodPollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
java.lang.String statementName,
java.lang.String statementId,
java.lang.annotation.Annotation[] annotations)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.core.eval |
---|
Methods in com.espertech.esper.epl.core.eval with parameters of type ExprEvaluatorContext | |
---|---|
EventBean |
EvalSelectStreamNoUnderlyingObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamBaseObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamBaseMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectNoWildcardObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectNoWildcardMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectNoWildcardEmptyProps.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardRevision.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardJoinRevision.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardBean.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertNoWildcardObjectArrayRemapWWiden.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertNoWildcardObjectArrayRemap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertCoercionObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertCoercionMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertBeanWrapRecast.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertBeanRecast.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalBaseObjectArr.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalBaseMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalBaseFirstProp.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectWildcardSSWrapper.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectWildcardJoin.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectWildcard.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardWrapper.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardSSWrapperRevision.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardSSWrapper.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardRevisionWrapper.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertWildcardJoin.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertNoWildcardRevision.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertNoWildcardMap.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract EventBean |
EvalBaseMap.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamWUnderlying.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamNoUndWEventBeanToObj.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamNoUnderlyingMap.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract EventBean |
EvalSelectStreamBaseMap.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalInsertNoWildcardObjectArray.processSpecific(java.lang.Object[] props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract EventBean |
EvalBaseObjectArr.processSpecific(java.lang.Object[] props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamNoUndWEventBeanToObjObjArray.processSpecific(java.lang.Object[] props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamNoUnderlyingObjectArray.processSpecific(java.lang.Object[] props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract EventBean |
EvalSelectStreamBaseObjectArray.processSpecific(java.lang.Object[] props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.datetime.calop |
---|
Methods in com.espertech.esper.epl.datetime.calop with parameters of type ExprEvaluatorContext | |
---|---|
void |
CalendarOpWithTime.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOpWithMin.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOpWithMax.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOpWithDate.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOpSet.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOpRound.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOpPlusMinus.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
void |
CalendarOp.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected static java.lang.Integer |
CalendarOpWithDate.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected static java.lang.Integer |
CalendarOpUtil.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.datetime.eval |
---|
Methods in com.espertech.esper.epl.datetime.eval with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprDotEvalDT.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static void |
ExprDotEvalDT.evaluateCalOps(java.util.List<CalendarOp> calendarOps,
java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.datetime.interval |
---|
Methods in com.espertech.esper.epl.datetime.interval with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerConstantAfter.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerAfterWithDeltaExpr.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerAfterNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerConstantBefore.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerBeforeWithDeltaExpr.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerBeforeNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerConstantCoincides.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerCoincidesWithDeltaExpr.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerCoincidesNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerDuringNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerIncludesNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerDuringAndIncludesThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerDuringAndIncludesMinMax.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerDuringMinMaxStartEnd.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerFinishesNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerFinishesThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerFinishedByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerFinishedByThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerMeetsNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerMeetsThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerMetByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerMetByThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerOverlapsNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerOverlapsAndByThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerOverlapsAndByMinMax.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerOverlappedByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerStartsNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerStartsThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerStartedByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputerFactory.IntervalComputerStartedByThreshold.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Boolean |
IntervalComputer.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprEvaluatorStreamLongPropFragment.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprEvaluatorStreamLongProp.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
IntervalDeltaExprEvaluator.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprOptionalConstant.IntervalDeltaExprEvaluatorMax.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.evaluate(long startTs,
long endTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOp.evaluate(long startTs,
long endTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEval.evaluate(long startTs,
long endTs,
java.lang.Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalDate.evaluate(long startTs,
long endTs,
java.lang.Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalLong.evaluate(long startTs,
long endTs,
java.lang.Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalCal.evaluate(long startTs,
long endTs,
java.lang.Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalDateWithEndBase.evaluate(long startTs,
long endTs,
java.lang.Object parameterStartTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
abstract java.lang.Object |
IntervalOpImpl.IntervalOpEvalDateWithEndBase.evaluate(long startTs,
long endTs,
java.lang.Object parameterStartTs,
java.lang.Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalDateWithEnd.evaluate(long startTs,
long endTs,
java.lang.Object parameterStartTs,
java.lang.Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalLongWithEnd.evaluate(long startTs,
long endTs,
java.lang.Object parameterStartTs,
java.lang.Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
IntervalOpImpl.IntervalOpEvalCalWithEnd.evaluate(long startTs,
long endTs,
java.lang.Object parameterStartTs,
java.lang.Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.datetime.reformatop |
---|
Methods in com.espertech.esper.epl.datetime.reformatop with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ReformatOpToMillisec.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToDate.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToCalendar.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpStringFormat.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpGetField.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpCalendarEval.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenNonConstantParams.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenConstantParams.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOp.evaluate(java.util.Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToMillisec.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToDate.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToCalendar.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpStringFormat.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpGetField.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpCalendarEval.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenNonConstantParams.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenConstantParams.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOp.evaluate(java.util.Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToMillisec.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToDate.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpToCalendar.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpStringFormat.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpGetField.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpCalendarEval.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenNonConstantParams.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenConstantParams.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOp.evaluate(java.lang.Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ReformatOpBetweenNonConstantParams.evaluateInternal(long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.db |
---|
Methods in com.espertech.esper.epl.db with parameters of type ExprEvaluatorContext | |
---|---|
EventTable[][] |
DatabasePollingViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.List<EventBean> |
PollExecStrategyDBQuery.poll(java.lang.Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.List<EventBean> |
PollExecStrategy.poll(java.lang.Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext)
Poll events using the keys provided. |
void |
DatabasePollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
java.lang.String statementName,
java.lang.String statementId,
java.lang.annotation.Annotation[] annotations)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.declexpr |
---|
Methods in com.espertech.esper.epl.declexpr with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprDeclaredEvalConstant.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprDeclaredEvalBase.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprDeclaredEvalBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprDeclaredEvalBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprDeclaredEvalBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprDeclaredEvalBase.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprDeclaredEvalBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprDeclaredNodeImpl.getConstantValue(ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.enummethod.dot |
---|
Methods in com.espertech.esper.epl.enummethod.dot with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
PropertyExprEvaluatorNonLambdaMapped.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
PropertyExprEvaluatorNonLambdaIndexed.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
PropertyExprEvaluatorNonLambdaFragment.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
PropertyExprEvaluatorNonLambda.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprLambdaGoesNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalUnpackCollEventBeanTable.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalUnpackCollEventBean.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalUnpackBeanTable.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalUnpackBean.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalProperty.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalEnumMethodBase.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
PropertyExprEvaluatorScalarIterable.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorScalarCollection.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorScalarArray.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorEventSingle.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorEventCollection.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorScalarIterable.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorScalarCollection.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorScalarArray.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorEventSingle.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorEventCollection.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorScalarIterable.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorScalarCollection.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorScalarArray.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorEventSingle.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorEventCollection.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorScalarIterable.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorScalarCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorScalarArray.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorEventSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
PropertyExprEvaluatorEventCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorScalarIterable.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorScalarCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorScalarArray.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorEventSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
PropertyExprEvaluatorEventCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorScalarIterable.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorScalarCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorScalarArray.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorEventSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
PropertyExprEvaluatorEventCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.enummethod.eval |
---|
Methods in com.espertech.esper.epl.enummethod.eval with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
EnumEvalWhereScalarIndex.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalWhereScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalWhereIndexEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalWhereEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalUnion.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalToMapScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalToMapEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileLastScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileLastIndexScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileLastIndexEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileLastEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileIndexScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileIndexEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeWhileEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTakeLast.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalTake.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalSumScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalSumScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalSumEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalSequenceEqual.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalSelectFromScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalSelectFromEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalReverse.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalOrderByAscDescScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalOrderByAscDescScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalOrderByAscDescEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalNoOp.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMostLeastFrequentScalarLamda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMostLeastFrequentScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMostLeastFrequentEvent.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMinMaxScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMinMaxScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMinMaxEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMinMaxByScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalMinMaxByEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalLastOfPredicateScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalLastOfPredicateEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalLastOfNoPredicate.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalIntersect.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalGroupByKeyValueSelectorScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalGroupByKeyValueSelectorEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalGroupByKeySelectorScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalGroupByKeySelectorEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalFirstOfPredicateScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalFirstOfPredicateEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalFirstOfNoPredicate.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalExcept.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalDistinctScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalDistinctScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalDistinctEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalCountOfSelectorScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalCountOfSelectorEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalCountOf.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAverageScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAverageScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAverageEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAverageBigDecimalScalarLambda.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAverageBigDecimalScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAverageBigDecimalEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAnyOfScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAnyOfEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAllOfScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAllOfEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAggregateScalar.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEvalAggregateEvents.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
EnumEval.evaluateEnumMethod(EventBean[] eventsLambda,
java.util.Collection target,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.accessagg |
---|
Methods in com.espertech.esper.epl.expression.accessagg with parameters of type ExprEvaluatorContext | |
---|---|
EventBean |
ExprPlugInAggMultiFunctionNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprAggMultiFunctionSortedMinMaxByNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprAggMultiFunctionLinearAccessNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprAggCountMinSketchNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprPlugInAggMultiFunctionNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprAggMultiFunctionSortedMinMaxByNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprAggMultiFunctionLinearAccessNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprAggCountMinSketchNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPlugInAggMultiFunctionNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprAggMultiFunctionSortedMinMaxByNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprAggMultiFunctionLinearAccessNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprAggCountMinSketchNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.baseagg |
---|
Methods in com.espertech.esper.epl.expression.baseagg with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprAggregateNodeGroupKey.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprAggregateNodeBase.evaluate(EventBean[] events,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.core |
---|
Classes in com.espertech.esper.epl.expression.core that implement ExprEvaluatorContext | |
---|---|
class |
ExprEvaluatorContextTimeOnly
Represents a minimal enginel-level context for expression evaluation, not allowing for agents instances and result cache. |
Methods in com.espertech.esper.epl.expression.core that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
ExprValidationContext.getExprEvaluatorContext()
|
Methods in com.espertech.esper.epl.expression.core with parameters of type ExprEvaluatorContext | |
---|---|
static boolean |
ExprNodeUtility.applyFilterExpression(ExprEvaluator filter,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Apply a filter expression returning a pass indicator. |
static EventBean[] |
ExprNodeUtility.applyFilterExpression(ExprEvaluator filter,
EventBean streamZeroEvent,
EventBean[] streamOneEvents,
ExprEvaluatorContext exprEvaluatorContext)
Apply a filter expression. |
static void |
ExprNodeUtility.applyFilterExpressionIterable(java.util.Iterator<EventBean> iterator,
ExprEvaluator filterExpression,
ExprEvaluatorContext exprEvaluatorContext,
java.util.Collection<EventBean> eventsInWindow)
|
static void |
ExprNodeUtility.applyFilterExpressionsIterable(java.lang.Iterable<EventBean> iterable,
java.util.List<ExprNode> filterExpressions,
ExprEvaluatorContext exprEvaluatorContext,
java.util.Collection<EventBean> eventsInWindow)
|
java.lang.Object |
ExprWildcardImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprVariableNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTypedNoEvalNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprSubstitutionNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprStreamUnderlyingNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprOrderedExpr.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNumberSetRange.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNumberSetList.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNumberSetFrequency.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNumberSetCronParam.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNodeValidated.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNodeUtilUnderlyingEvaluatorTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilUnderlyingEvaluator.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilExprEvalStreamNumUnd.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilExprEvalStreamNumEventTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilExprEvalStreamNumEvent.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilExprEvalStreamNumEnumSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilExprEvalStreamNumEnumColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeUtilExprEvalMethodContext.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNamedParameterNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprIdentNodeEvaluatorLogging.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprIdentNodeEvaluatorImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprIdentNodeEvaluatorContext.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprGroupingNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprGroupingIdNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprEvaluator.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
Evaluate event tuple and return result. |
java.lang.Object |
ExprCurrentEvaluationContextNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprContextPropertyNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprConstantNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprEvaluatorEnumerationGivenEvent.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprEvaluatorEnumerationGivenEvent.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprEvaluatorEnumerationGivenEvent.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context)
|
static java.lang.Object[] |
ExprNodeUtility.evaluateExpressions(ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprEvaluatorEnumeration.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprEvaluatorEnumeration.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprEvaluatorEnumeration.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprEvaluatorTypableReturn.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprEvaluatorTypableReturn.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprVariableNodeImpl.getConstantValue(ExprEvaluatorContext context)
|
java.lang.Object |
ExprConstantNodeImpl.getConstantValue(ExprEvaluatorContext context)
Returns the constant's value. |
java.lang.Object |
ExprConstantNode.getConstantValue(ExprEvaluatorContext context)
|
Constructors in com.espertech.esper.epl.expression.core with parameters of type ExprEvaluatorContext | |
---|---|
ExprValidationContext(StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
ViewResourceDelegateUnverified viewResourceDelegate,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
EventAdapterService eventAdapterService,
java.lang.String statementName,
java.lang.String statementId,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
boolean disablePropertyExpressionEventCollCache,
boolean allowRollupFunctions,
boolean allowBindingConsumption,
boolean isUnidirectionalJoin,
java.lang.String intoTableName)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.dot |
---|
Methods in com.espertech.esper.epl.expression.dot with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprDotEvalVariable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalTransposeAsStream.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprDotEvalStreamMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalStreamEventBean.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalStaticMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalRootChildInnerEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalRootChild.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprDotEvalPropertyExprMapped.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprDotEvalPropertyExprIndexed.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprDotMethodEvalNoDuckWrapArray.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotMethodEvalNoDuckUnderlying.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotMethodEvalNoDuck.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotMethodEvalDuck.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalArraySize.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEvalArrayGet.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprDotEval.evaluate(java.lang.Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
static java.lang.Object |
ExprDotNodeUtility.evaluateChain(ExprDotEval[] evaluators,
java.lang.Object inner,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
static java.lang.Object |
ExprDotNodeUtility.evaluateChainWithWrap(ExprDotStaticMethodWrap resultWrapLambda,
java.lang.Object result,
EventType optionalResultSingleEventType,
java.lang.Class resultType,
ExprDotEval[] chainEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprDotEvalRootChildInnerEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprDotEvalRootChild.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprDotEvalRootChildInnerEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprDotEvalRootChild.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprDotEvalRootChildInnerEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprDotEvalRootChild.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.dot.inner |
---|
Methods in com.espertech.esper.epl.expression.dot.inner with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
InnerEvaluatorScalarUnpackEvent.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InnerEvaluatorScalar.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InnerEvaluatorEnumerableScalarCollection.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InnerEvaluatorEnumerableEventCollection.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InnerEvaluatorEnumerableEventBean.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
InnerEvaluatorColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InnerEvaluatorArrPrimitiveToColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InnerEvaluatorArrObjectToColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
InnerEvaluatorScalarUnpackEvent.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorScalar.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorEnumerableScalarCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorEnumerableEventCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorEnumerableEventBean.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorColl.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorArrPrimitiveToColl.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
InnerEvaluatorArrObjectToColl.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorScalarUnpackEvent.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorScalar.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorEnumerableScalarCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorEnumerableEventCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorEnumerableEventBean.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorColl.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorArrPrimitiveToColl.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
InnerEvaluatorArrObjectToColl.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorScalarUnpackEvent.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorScalar.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorEnumerableScalarCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorEnumerableEventCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorEnumerableEventBean.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorColl.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorArrPrimitiveToColl.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
InnerEvaluatorArrObjectToColl.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.funcs |
---|
Methods in com.espertech.esper.epl.expression.funcs with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprCastNode.CasterParserComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
Compute an result performing casting and parsing. |
java.lang.Object |
ExprCastNode.StringXFormComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.NumberCasterComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringParserComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.NonnumericCasterComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToDateLongWDynamicFormat.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToDateWStaticFormatComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToDateWStaticISOFormatComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToLongWStaticFormatComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToLongWStaticISOFormatComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToCalendarWStaticFormatComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.StringToCalendarWStaticISOFormatComputer.compute(java.lang.Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTypeofNode.StreamEventTypeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTypeofNode.FragmentTypeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprPropertyExistsNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprMinMaxRowNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprIStreamNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprInstanceofNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCoalesceNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNodeNonConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprCastNodeConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprCaseNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[][] |
ExprCaseNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprCaseNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.ops |
---|
Methods in com.espertech.esper.epl.expression.ops with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprRelationalOpNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprRelationalOpAllAnyNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprRegexpNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprOrNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNotNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNewStructNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNewInstanceNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprMathNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprLikeNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprInNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprEqualsNodeImpl.ExprEqualsEvaluatorCoercing.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprEqualsNodeImpl.ExprEqualsEvaluatorEquals.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprEqualsNodeImpl.ExprEqualsEvaluatorIs.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprEqualsAllAnyNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprConcatNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprBitWiseNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprBetweenNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprArrayNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprAndNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprArrayNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprArrayNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprArrayNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprNewStructNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprNewStructNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.prev |
---|
Methods in com.espertech.esper.epl.expression.prev with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprPreviousNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPreviousMatchRecognizeNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPreviousMatchRecognizeEvalStrategy.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPreviousEvalStrategyWindow.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPreviousEvalStrategyPrev.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPreviousEvalStrategyCount.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPreviousEvalStrategy.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
ExprPreviousEvalStrategyWindow.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprPreviousEvalStrategyPrev.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprPreviousEvalStrategyCount.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprPreviousEvalStrategy.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPreviousEvalStrategyWindow.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPreviousEvalStrategyPrev.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPreviousEvalStrategyCount.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPreviousEvalStrategy.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
ExprPreviousNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprPreviousEvalStrategyWindow.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
ExprPreviousEvalStrategyPrev.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
ExprPreviousEvalStrategyCount.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
ExprPreviousEvalStrategy.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprPreviousNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPreviousNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.prior |
---|
Methods in com.espertech.esper.epl.expression.prior with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprPriorNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPriorEvalStrategyBase.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber)
|
java.lang.Object |
ExprPriorEvalStrategy.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.subquery |
---|
Methods in com.espertech.esper.epl.expression.subquery with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
SubselectEvalStrategyRelOpAny.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
SubselectEvalStrategyRelOpAll.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
SubselectEvalStrategyEqualsIn.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
SubselectEvalStrategyEqualsAny.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
SubselectEvalStrategyEqualsAll.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
SubselectEvalStrategy.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate. |
java.lang.Object |
ExprSubselectRowNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract java.lang.Object |
ExprSubselectNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate the lookup expression returning an evaluation result object. |
java.lang.Object |
ExprSubselectInNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprSubselectExistsNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprSubselectAllSomeAnyNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprSubselectRowEvalStrategyUnfilteredUnselectedTable.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategyUnfilteredUnselected.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategyUnfilteredSelectedGroupedAgg.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategyUnfilteredSelected.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategyFilteredUnselectedTable.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategyFilteredUnselected.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategyFilteredSelected.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object |
ExprSubselectRowEvalStrategy.evaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode exprSubselectRowNode)
|
java.lang.Object |
ExprSubselectNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
static EventBean |
ExprSubselectRowNodeUtility.evaluateFilterExpectSingleMatch(EventBean[] eventsZeroSubselect,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.util.Collection<EventBean> |
ExprSubselectRowNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context)
|
abstract java.util.Collection<EventBean> |
ExprSubselectNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
ExprSubselectInNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprSubselectExistsNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprSubselectAllSomeAnyNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprSubselectRowEvalStrategyUnfilteredUnselected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection<EventBean> |
ExprSubselectRowEvalStrategyUnfilteredSelectedGroupedAgg.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection<EventBean> |
ExprSubselectRowEvalStrategyUnfilteredSelected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection<EventBean> |
ExprSubselectRowEvalStrategyFilteredUnselected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection<EventBean> |
ExprSubselectRowEvalStrategyFilteredSelected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection<EventBean> |
ExprSubselectRowEvalStrategy.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection |
ExprSubselectRowNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context)
|
abstract java.util.Collection |
ExprSubselectNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection |
ExprSubselectInNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection |
ExprSubselectExistsNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection |
ExprSubselectAllSomeAnyNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection |
ExprSubselectRowEvalStrategyUnfilteredUnselected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection |
ExprSubselectRowEvalStrategyUnfilteredSelectedGroupedAgg.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection |
ExprSubselectRowEvalStrategyUnfilteredSelected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection |
ExprSubselectRowEvalStrategyFilteredUnselected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection |
ExprSubselectRowEvalStrategyFilteredSelected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
java.util.Collection |
ExprSubselectRowEvalStrategy.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
EventBean |
ExprSubselectRowNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract EventBean |
ExprSubselectNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprSubselectInNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprSubselectExistsNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprSubselectAllSomeAnyNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprSubselectRowEvalStrategyUnfilteredUnselected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
EventBean |
ExprSubselectRowEvalStrategyUnfilteredSelectedGroupedAgg.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
EventBean |
ExprSubselectRowEvalStrategyUnfilteredSelected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
EventBean |
ExprSubselectRowEvalStrategyFilteredUnselected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
EventBean |
ExprSubselectRowEvalStrategyFilteredSelected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent)
|
EventBean |
ExprSubselectRowEvalStrategy.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode exprSubselectRowNode)
|
EventBean |
ExprSubselectNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprSubselectInNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprSubselectExistsNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprSubselectAllSomeAnyNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprSubselectNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection |
ExprSubselectNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
ExprSubselectStrategy.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
protected java.util.Map<java.lang.String,java.lang.Object> |
ExprSubselectRowNode.evaluateRow(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprSubselectRowNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract java.lang.Object[][] |
ExprSubselectNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[][] |
ExprSubselectInNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[][] |
ExprSubselectExistsNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[][] |
ExprSubselectAllSomeAnyNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[][] |
ExprSubselectNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprSubselectRowNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract java.lang.Object[] |
ExprSubselectNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
ExprSubselectInNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
ExprSubselectExistsNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
ExprSubselectAllSomeAnyNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object[] |
ExprSubselectNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprSubselectRowEvalStrategyUnfilteredUnselected.typableEvaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[] |
ExprSubselectRowEvalStrategyUnfilteredSelected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[] |
ExprSubselectRowEvalStrategyFilteredUnselected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[] |
ExprSubselectRowEvalStrategyFilteredSelected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[] |
ExprSubselectRowEvalStrategy.typableEvaluate(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[][] |
ExprSubselectRowEvalStrategyUnfilteredUnselected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[][] |
ExprSubselectRowEvalStrategyUnfilteredSelected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean isNewData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[][] |
ExprSubselectRowEvalStrategyFilteredUnselected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[][] |
ExprSubselectRowEvalStrategyFilteredSelected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
java.lang.Object[][] |
ExprSubselectRowEvalStrategy.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.table |
---|
Methods in com.espertech.esper.epl.expression.table with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprTableIdentNodeSubpropAccessor.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableAccessNodeTopLevel.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableAccessNodeSubpropAccessor.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableAccessNodeSubprop.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableAccessNodeKeys.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableAccessEvalStrategy.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprTableIdentNodeSubpropAccessor.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableAccessNodeSubpropAccessor.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableAccessNodeSubprop.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableAccessEvalStrategy.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableIdentNodeSubpropAccessor.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableAccessNodeSubpropAccessor.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableAccessNodeSubprop.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableAccessEvalStrategy.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableIdentNodeSubpropAccessor.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableAccessNodeSubpropAccessor.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableAccessNodeSubprop.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableAccessEvalStrategy.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprTableAccessNodeTopLevel.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableAccessNodeTopLevel.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableAccessEvalStrategy.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.expression.time |
---|
Methods in com.espertech.esper.epl.expression.time with parameters of type ExprEvaluatorContext | |
---|---|
ExprTimePeriodEvalDeltaConst |
ExprTimePeriodImpl.constEvaluator(ExprEvaluatorContext context)
|
ExprTimePeriodEvalDeltaConst |
ExprTimePeriod.constEvaluator(ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalDeltaNonConstMsec.deltaMillisecondsAdd(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalDeltaNonConstCalAdd.deltaMillisecondsAdd(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalDeltaNonConst.deltaMillisecondsAdd(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
ExprTimePeriodEvalDeltaResult |
ExprTimePeriodEvalDeltaNonConstMsec.deltaMillisecondsAddWReference(long current,
long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
ExprTimePeriodEvalDeltaResult |
ExprTimePeriodEvalDeltaNonConstCalAdd.deltaMillisecondsAddWReference(long current,
long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
ExprTimePeriodEvalDeltaResult |
ExprTimePeriodEvalDeltaNonConst.deltaMillisecondsAddWReference(long current,
long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalDeltaNonConstMsec.deltaMillisecondsSubtract(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalDeltaNonConstCalAdd.deltaMillisecondsSubtract(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalDeltaNonConst.deltaMillisecondsSubtract(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTimestampNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTimePeriodImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
long |
ExprTimePeriodEvalMillis.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
double |
ExprTimePeriodImpl.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
double |
ExprTimePeriod.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
TimePeriod |
ExprTimePeriodImpl.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
TimePeriod |
ExprTimePeriod.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.join.base |
---|
Methods in com.espertech.esper.epl.join.base with parameters of type ExprEvaluatorContext | |
---|---|
protected static void |
JoinSetFilter.filter(ExprEvaluator filterExprNode,
java.util.Set<MultiKey<EventBean>> events,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Filter event by applying the filter nodes evaluation method. |
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposerStreamToWinImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposerHistoricalImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposerFAFImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
UniformPair<java.util.Set<MultiKey<EventBean>>> |
JoinSetComposer.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Return join tuple result set from new data and old data for each stream. |
void |
QueryStrategy.lookup(EventBean[] lookupEvents,
java.util.Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext)
Look up events returning tuples of joined events. |
void |
HistoricalDataQueryStrategy.lookup(EventBean[] lookupEvents,
java.util.Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
java.util.Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategySorted.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext context)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategyNoIndex.lookup(EventBean lookupEvent,
EventTable[] index,
ExprEvaluatorContext context)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategyInKeywordSingle.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategyInKeywordMulti.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategyIndexSingle.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategyIndex.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategyComposite.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext context)
|
java.util.Iterator<EventBean> |
HistoricalIndexLookupStrategy.lookup(EventBean lookupEvent,
EventTable[] index,
ExprEvaluatorContext context)
Look up into the index, potentially using some of the properties in the lookup event, returning a partial or full result in respect to the index. |
static JoinSetComposerPrototype |
JoinSetComposerPrototypeFactory.makeComposerPrototype(java.lang.String statementName,
java.lang.String statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
java.lang.String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean queryPlanLogging,
StatementContext statementContext,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
boolean selectsRemoveStream,
boolean hasAggregations,
TableService tableService,
boolean isOnDemandQuery)
Builds join tuple composer. |
void |
JoinSetProcessor.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
Process join result set. |
void |
JoinSetFilter.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
Constructors in com.espertech.esper.epl.join.base with parameters of type ExprEvaluatorContext | |
---|---|
JoinExecutionStrategyImpl(JoinSetComposer composer,
JoinSetProcessor filter,
JoinSetProcessor indicator,
ExprEvaluatorContext staticExprEvaluatorContext)
Ctor. |
|
JoinSetComposerFAFImpl(java.util.Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
boolean isPureSelfJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean joinRemoveStream,
boolean outerJoins)
|
|
JoinSetComposerHistoricalImpl(java.util.Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
Viewable[] streamViews,
ExprEvaluatorContext staticEvalExprEvaluatorContext)
Ctor. |
|
JoinSetComposerImpl(java.util.Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
boolean isPureSelfJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean joinRemoveStream)
Ctor. |
|
JoinSetComposerPrototypeHistorical2StreamImpl(ExprNode optionalFilterNode,
EventType[] streamTypes,
ExprEvaluatorContext exprEvaluatorContext,
int polledViewNum,
int streamViewNum,
boolean outerJoin,
ExprNode outerJoinEqualsNode,
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> indexStrategies,
boolean allHistoricalNoSubordinate,
OuterJoinDesc[] outerJoinDescList)
|
|
JoinSetComposerPrototypeImpl(java.lang.String statementName,
java.lang.String statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
java.lang.String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
java.lang.annotation.Annotation[] annotations,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
QueryPlanIndex[] indexSpecs,
QueryPlan queryPlan,
HistoricalStreamIndexList[] historicalStreamIndexLists,
boolean joinRemoveStream,
boolean isOuterJoins,
TableService tableService)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.join.exec.base |
---|
Methods in com.espertech.esper.epl.join.exec.base with parameters of type ExprEvaluatorContext | |
---|---|
java.util.Set<EventBean> |
SortedTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
JoinExecTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
Returns matched events for a event to look up for. |
java.util.Set<EventBean> |
InKeywordSingleTableLookupStrategyExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
InKeywordMultiTableLookupStrategyExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
IndexedTableLookupStrategySingleExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
IndexedTableLookupStrategySingle.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
IndexedTableLookupStrategyExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
IndexedTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
HistoricalTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
FullTableScanUniqueValueLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
FullTableScanLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
CompositeTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext context)
|
void |
TableOuterLookupExecNodeTableLocking.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableOuterLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableLookupExecNodeTableLocking.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
NestedIterationExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
LookupInstructionExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> resultFinalRows,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
HistoricalDataExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
ExecNodeNoOp.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract void |
ExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
Process single event using the prefill events to compile lookup results. |
boolean |
LookupInstructionExec.process(Repository repository,
ExprEvaluatorContext exprEvaluatorContext)
Execute the instruction adding results to the repository and obtaining events for lookup from the repository. |
protected void |
NestedIterationExecNode.recursiveNestedJoin(EventBean lookupEvent,
int nestingOrderIndex,
EventBean[] currentPath,
java.util.Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext)
Recursive method to run through all child nodes and, for each result set tuple returned by a child node, execute the inner child of the child node until there are no inner child nodes. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.join.exec.composite |
---|
Methods in com.espertech.esper.epl.join.exec.composite with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
CompositeAccessStrategyRelOpBase.evaluateLookup(EventBean theEvent,
ExprEvaluatorContext context)
|
java.lang.Object |
CompositeAccessStrategyRangeBase.evaluateLookupEnd(EventBean theEvent,
ExprEvaluatorContext context)
|
java.lang.Object |
CompositeAccessStrategyRangeBase.evaluateLookupStart(EventBean theEvent,
ExprEvaluatorContext context)
|
java.lang.Object |
CompositeAccessStrategyRelOpBase.evaluatePerStream(EventBean[] eventPerStream,
ExprEvaluatorContext context)
|
java.lang.Object |
CompositeAccessStrategyRangeBase.evaluatePerStreamEnd(EventBean[] eventPerStream,
ExprEvaluatorContext context)
|
java.lang.Object |
CompositeAccessStrategyRangeBase.evaluatePerStreamStart(EventBean[] eventPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
CompositeIndexQueryRange.get(EventBean[] eventsPerStream,
java.util.Map parent,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
CompositeIndexQueryKeyed.get(EventBean[] eventsPerStream,
java.util.Map parent,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
CompositeIndexQuery.get(EventBean[] eventsPerStream,
java.util.Map parent,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
CompositeIndexQueryRange.get(EventBean theEvent,
java.util.Map parent,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
CompositeIndexQueryKeyed.get(EventBean theEvent,
java.util.Map parent,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
CompositeIndexQuery.get(EventBean theEvent,
java.util.Map parent,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
CompositeIndexQueryRange.getCollectKeys(EventBean[] eventsPerStream,
java.util.Map parent,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
CompositeIndexQueryKeyed.getCollectKeys(EventBean[] eventsPerStream,
java.util.Map parent,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
CompositeIndexQuery.getCollectKeys(EventBean[] eventsPerStream,
java.util.Map parent,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
CompositeIndexQueryRange.getCollectKeys(EventBean theEvent,
java.util.Map parent,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
CompositeIndexQueryKeyed.getCollectKeys(EventBean theEvent,
java.util.Map parent,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
CompositeIndexQuery.getCollectKeys(EventBean theEvent,
java.util.Map parent,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
CompositeAccessStrategyRangeNormal.lookup(EventBean[] eventPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Collection<EventBean> |
CompositeAccessStrategyRangeInverted.lookup(EventBean[] eventPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Collection<EventBean> |
CompositeAccessStrategyLT.lookup(EventBean[] eventsPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Collection<EventBean> |
CompositeAccessStrategyLE.lookup(EventBean[] eventPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Collection<EventBean> |
CompositeAccessStrategyGT.lookup(EventBean[] eventPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Collection<EventBean> |
CompositeAccessStrategyGE.lookup(EventBean[] eventPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Collection<EventBean> |
CompositeAccessStrategy.lookup(EventBean[] eventPerStream,
java.util.Map parent,
java.util.Collection<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategyRangeNormal.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategyRangeInverted.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategyLT.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategyLE.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategyGT.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategyGE.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
java.util.Set<EventBean> |
CompositeAccessStrategy.lookup(EventBean theEvent,
java.util.Map parent,
java.util.Set<EventBean> result,
CompositeIndexQuery next,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> optionalKeyCollector)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.join.exec.sorted |
---|
Methods in com.espertech.esper.epl.join.exec.sorted with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
SortedAccessStrategyRelOpBase.evaluateLookup(EventBean theEvent,
ExprEvaluatorContext context)
|
java.lang.Object |
SortedAccessStrategyRangeBase.evaluateLookupEnd(EventBean theEvent,
ExprEvaluatorContext context)
|
java.lang.Object |
SortedAccessStrategyRangeBase.evaluateLookupStart(EventBean theEvent,
ExprEvaluatorContext context)
|
java.lang.Object |
SortedAccessStrategyRelOpBase.evaluatePerStream(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.lang.Object |
SortedAccessStrategyRangeBase.evaluatePerStreamEnd(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.lang.Object |
SortedAccessStrategyRangeBase.evaluatePerStreamStart(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyRangeInverted.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyRange.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyLT.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyLE.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyGT.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyGE.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategy.lookup(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategyRangeInverted.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategyRange.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategyLT.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategyLE.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategyGT.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategyGE.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SortedAccessStrategy.lookup(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SortedAccessStrategyRangeInverted.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
SortedAccessStrategyRange.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
SortedAccessStrategyLT.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
SortedAccessStrategyLE.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
SortedAccessStrategyGT.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
SortedAccessStrategyGE.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Collection<EventBean> |
SortedAccessStrategy.lookupCollectKeys(EventBean[] eventsPerStream,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategyRangeInverted.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategyRange.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategyLT.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategyLE.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategyGT.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategyGE.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
java.util.Set<EventBean> |
SortedAccessStrategy.lookupCollectKeys(EventBean theEvent,
PropertySortedEventTable index,
ExprEvaluatorContext context,
java.util.ArrayList<java.lang.Object> keys)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.join.plan |
---|
Methods in com.espertech.esper.epl.join.plan with parameters of type ExprEvaluatorContext | |
---|---|
protected static QueryPlan |
NStreamOuterQueryPlanBuilder.build(QueryGraph queryGraph,
OuterJoinDesc[] outerJoinDescList,
java.lang.String[] streamNames,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String[][][] indexedStreamsUniqueProps,
TableMetadata[] tablesPerStream)
Build a query plan based on the stream property relationships indicated in queryGraph. |
static QueryPlan |
QueryPlanBuilder.getPlan(EventType[] typesPerStream,
OuterJoinDesc[] outerJoinDescList,
QueryGraph queryGraph,
java.lang.String[] streamNames,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean isQueryPlanLogging,
java.lang.annotation.Annotation[] annotations,
ExprEvaluatorContext exprEvaluatorContext)
Build query plan using the filter. |
static java.util.Set<EventBean> |
InKeywordTableLookupUtil.multiIndexLookup(ExprEvaluator evaluator,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
EventTable[] indexes)
|
static java.util.Set<EventBean> |
InKeywordTableLookupUtil.singleIndexLookup(ExprEvaluator[] evaluators,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
PropertyIndexedEventTableSingle index)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.lookup |
---|
Methods in com.espertech.esper.epl.lookup with parameters of type ExprEvaluatorContext | |
---|---|
protected java.lang.Object |
SubordIndexedTableLookupStrategySingleExprNW.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys. |
protected java.lang.Object |
SubordIndexedTableLookupStrategySingleExpr.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys. |
protected java.lang.Object |
SubordIndexedTableLookupStrategySingleCoercingNW.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
protected java.lang.Object |
SubordIndexedTableLookupStrategySingleCoercing.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
protected java.lang.Object[] |
SubordIndexedTableLookupStrategyExprNW.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys. |
protected java.lang.Object[] |
SubordIndexedTableLookupStrategyExpr.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys. |
protected java.lang.Object[] |
SubordIndexedTableLookupStrategyCoercingNW.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
protected java.lang.Object[] |
SubordIndexedTableLookupStrategyCoercing.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean[] |
SubordWMatchExprLookupStrategyIndexedUnfiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
SubordWMatchExprLookupStrategyIndexedFiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
SubordWMatchExprLookupStrategyAllUnfiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
SubordWMatchExprLookupStrategyAllFiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
SubordWMatchExprLookupStrategy.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
Determines the events. |
java.util.Set<EventBean> |
SubordTableLookupStrategyNullRow.lookup(EventBean[] events,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordTableLookupStrategy.lookup(EventBean[] events,
ExprEvaluatorContext context)
Returns matched events for a set of events to look up for. |
java.util.Collection<EventBean> |
SubordSortedTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordInKeywordSingleTableLookupStrategyNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordInKeywordSingleTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordInKeywordMultiTableLookupStrategyNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordInKeywordMultiTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupTableStrategy.lookup(EventBean[] events,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategySinglePropUnique.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategySingleProp.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategySingleExprNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategySingleExpr.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategyProp.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategyLocking.lookup(EventBean[] events,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategyExprNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordIndexedTableLookupStrategyExpr.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordFullTableScanTableLookupStrategy.lookup(EventBean[] events,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordFullTableScanLookupStrategyLocking.lookup(EventBean[] events,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
SubordFullTableScanLookupStrategy.lookup(EventBean[] eventPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
SubordCompositeTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.named |
---|
Methods in com.espertech.esper.epl.named that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
NamedWindowOnExprBaseView.getExprEvaluatorContext()
returns expr context. |
Methods in com.espertech.esper.epl.named with parameters of type ExprEvaluatorContext | |
---|---|
void |
NamedWindowOnMergeMatch.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext context)
|
void |
NamedWindowOnMergeActionUpd.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
NamedWindowOnMergeActionIns.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
NamedWindowOnMergeActionDel.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract void |
NamedWindowOnMergeAction.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
NamedWindowOnMergeMatch.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
boolean |
NamedWindowOnMergeAction.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
NamedWindowTailViewInstance.snapshotNoLockWithFilter(FilterSpecCompiled filter,
java.lang.annotation.Annotation[] annotations,
ExprNode filterExpr,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.parse |
---|
Methods in com.espertech.esper.epl.parse with parameters of type ExprEvaluatorContext | |
---|---|
static OutputLimitSpec |
ASTOutputLimitHelper.buildOutputLimitSpec(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EsperEPL2GrammarParser.OutputLimitContext ctx,
java.util.Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
java.lang.String engineURI,
TimeProvider timeProvider,
ExprEvaluatorContext exprEvaluatorContext)
Build an output limit spec from the AST node supplied. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.property |
---|
Methods in com.espertech.esper.epl.property with parameters of type ExprEvaluatorContext | |
---|---|
java.util.ArrayDeque<EventBean[]> |
PropertyEvaluatorAccumulative.getAccumulative(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Returns the accumulative events for the input event. |
java.lang.Object |
ContainedEventEvalGetter.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ContainedEventEvalExprNode.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ContainedEventEvalArrayToEvent.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ContainedEventEval.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
PropertyEvaluatorSimple.getProperty(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
PropertyEvaluatorSelect.getProperty(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
PropertyEvaluatorNested.getProperty(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
PropertyEvaluator.getProperty(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Returns the result events based on property values, or null if none found. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.script |
---|
Methods in com.espertech.esper.epl.script with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
ExprNodeScriptEvalMVEL.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprNodeScriptEvalJSR223.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprNodeScriptEvalBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprNodeScriptEvalBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprNodeScriptEvalBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.spec |
---|
Methods in com.espertech.esper.epl.spec with parameters of type ExprEvaluatorContext | |
---|---|
ExprNode |
OuterJoinDesc.makeExprNode(ExprEvaluatorContext exprEvaluatorContext)
Make an expression node that represents the outer join criteria as specified in the on-clause. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.subquery |
---|
Fields in com.espertech.esper.epl.subquery declared as ExprEvaluatorContext | |
---|---|
protected ExprEvaluatorContext |
SubselectAggregatorViewBase.exprEvaluatorContext
|
Methods in com.espertech.esper.epl.subquery with parameters of type ExprEvaluatorContext | |
---|---|
void |
SubselectAggregationPreprocessorUnfilteredUngrouped.evaluate(EventBean[] eventsPerStream,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
SubselectAggregationPreprocessorUnfilteredGrouped.evaluate(EventBean[] eventsPerStream,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
SubselectAggregationPreprocessorFilteredUngrouped.evaluate(EventBean[] eventsPerStream,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
SubselectAggregationPreprocessorFilteredGrouped.evaluate(EventBean[] eventsPerStream,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract void |
SubselectAggregationPreprocessorBase.evaluate(EventBean[] eventsPerStream,
java.util.Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
protected java.lang.Object |
SubselectAggregationPreprocessorBase.generateGroupKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.table.merge |
---|
Methods in com.espertech.esper.epl.table.merge with parameters of type ExprEvaluatorContext | |
---|---|
void |
TableOnMergeMatch.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance stateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext context)
|
void |
TableOnMergeActionUpd.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableOnMergeActionIns.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableOnMergeActionDel.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract void |
TableOnMergeAction.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
TableOnMergeMatch.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
boolean |
TableOnMergeAction.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.table.mgmt |
---|
Methods in com.espertech.esper.epl.table.mgmt with parameters of type ExprEvaluatorContext | |
---|---|
EventBean |
TableMetadataInternalEventToPublic.convert(EventBean event,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
TableMetadataInternalEventToPublic.convertToUnd(EventBean event,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
ObjectArrayBackedEventBean |
TableStateInstanceUngrouped.getCreateRowIntoTable(java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
ObjectArrayBackedEventBean |
TableStateInstanceGroupBy.getCreateRowIntoTable(java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract ObjectArrayBackedEventBean |
TableStateInstance.getCreateRowIntoTable(java.lang.Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
TableMetadata.getPublicEventBean(EventBean event,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.table.onaction |
---|
Fields in com.espertech.esper.epl.table.onaction declared as ExprEvaluatorContext | |
---|---|
protected ExprEvaluatorContext |
TableOnViewBase.exprEvaluatorContext
|
Methods in com.espertech.esper.epl.table.onaction that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
TableOnViewBase.getExprEvaluatorContext()
returns expr context. |
Methods in com.espertech.esper.epl.table.onaction with parameters of type ExprEvaluatorContext | |
---|---|
void |
TableOnMergeViewChangeHandler.add(EventBean theEvent,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
static EventBean[] |
TableOnViewUtil.toPublic(EventBean[] matching,
TableMetadata tableMetadata,
EventBean[] triggers,
boolean isNewData,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.table.strategy |
---|
Methods in com.espertech.esper.epl.table.strategy with parameters of type ExprEvaluatorContext | |
---|---|
protected static java.lang.Object |
ExprTableEvalStrategyUtil.evalAccessorGetValue(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
protected static EventBean |
ExprTableEvalStrategyUtil.evalGetEventBean(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
protected static java.util.Collection<EventBean> |
ExprTableEvalStrategyUtil.evalGetROCollectionEvents(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
protected static java.util.Collection |
ExprTableEvalStrategyUtil.evalGetROCollectionScalar(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
protected static java.util.Map<java.lang.String,java.lang.Object> |
ExprTableEvalStrategyUtil.evalMap(ObjectArrayBackedEventBean event,
AggregationRowPair row,
java.util.Map<java.lang.String,TableMetadataColumn> items,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
protected static java.lang.Object[] |
ExprTableEvalStrategyUtil.evalTypable(ObjectArrayBackedEventBean event,
AggregationRowPair row,
java.util.Map<java.lang.String,TableMetadataColumn> items,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableExprEvaluatorMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableExprEvaluatorAccess.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyUngroupedTopLevel.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyUngroupedProp.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyUngroupedMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyUngroupedAccess.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyGroupByTopLevelSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByTopLevelMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByPropSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByPropMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByMethodSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByMethodMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByKeys.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyGroupByAccessSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprTableEvalStrategyGroupByAccessMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
ExprTableExprEvaluatorAccess.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyUngroupedTopLevel.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyUngroupedProp.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyUngroupedMethod.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyUngroupedAccess.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByPropSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByPropMulti.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByMethodBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByKeys.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByAccessSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByAccessMulti.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected EventBean |
ExprTableEvalStrategyGroupByAccessBase.evaluateGetEventBeanInternal(java.lang.Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprTableEvalStrategyGroupByPropBase.evaluateGetEventBeanInternal(java.lang.Object groupKey,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableExprEvaluatorAccess.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyUngroupedTopLevel.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyUngroupedProp.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyUngroupedMethod.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyUngroupedAccess.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByPropSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByPropMulti.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByMethodBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByKeys.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByAccessSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByAccessMulti.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByAccessBase.evaluateGetROCollectionEventsInternal(java.lang.Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprTableEvalStrategyGroupByPropBase.evaluateGetROCollectionEventsInternal(java.lang.Object groupKey,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableExprEvaluatorAccess.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyUngroupedTopLevel.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyUngroupedProp.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyUngroupedMethod.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyUngroupedAccess.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByPropSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByPropMulti.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByMethodBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByKeys.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByAccessSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByAccessMulti.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected java.util.Collection |
ExprTableEvalStrategyGroupByAccessBase.evaluateGetROCollectionScalarInternal(java.lang.Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprTableEvalStrategyGroupByPropBase.evaluateGetROCollectionScalarInternal(java.lang.Object groupKey,
ExprEvaluatorContext context)
|
protected java.lang.Object |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateInternal(java.lang.Object groupKey,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected java.lang.Object |
ExprTableEvalStrategyGroupByAccessBase.evaluateInternal(java.lang.Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprTableEvalStrategyGroupByPropBase.evaluateInternal(java.lang.Object groupKey,
ExprEvaluatorContext context)
|
protected java.lang.Object |
ExprTableEvalStrategyGroupByMethodBase.evaluateInternal(java.lang.Object groupKey,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyUngroupedTopLevel.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyUngroupedProp.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyUngroupedMethod.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyUngroupedAccess.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyGroupByTopLevelSingle.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyGroupByTopLevelMulti.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyGroupByPropBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyGroupByMethodBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyGroupByKeys.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprTableEvalStrategyGroupByAccessBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected java.lang.Object[] |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateTypableSingleInternal(java.lang.Object groupKey,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected static MultiKeyUntyped |
ExprTableEvalStrategyGroupByAccessMulti.getKey(ExprEvaluator[] evaluators,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
protected void |
ExprTableEvalStrategyGroupByBase.lockTableRead(ExprEvaluatorContext context)
|
protected ObjectArrayBackedEventBean |
ExprTableEvalStrategyUngroupedBase.lockTableReadAndGet(ExprEvaluatorContext context)
|
protected ObjectArrayBackedEventBean |
ExprTableEvalStrategyGroupByBase.lockTableReadAndGet(java.lang.Object group,
ExprEvaluatorContext context)
|
static void |
ExprTableEvalLockUtil.obtainLockUnless(java.util.concurrent.locks.Lock lock,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.table.upd |
---|
Methods in com.espertech.esper.epl.table.upd with parameters of type ExprEvaluatorContext | |
---|---|
void |
TableUpdateStrategyWUniqueConstraint.updateTable(java.util.Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableUpdateStrategyNonIndex.updateTable(java.util.Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableUpdateStrategyIndexNonUnique.updateTable(java.util.Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
TableUpdateStrategy.updateTable(java.util.Collection<EventBean> events,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.updatehelper |
---|
Methods in com.espertech.esper.epl.updatehelper with parameters of type ExprEvaluatorContext | |
---|---|
void |
EventBeanUpdateHelper.updateNoCopy(EventBean matchingEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EventBeanUpdateHelper.updateWCopy(EventBean matchingEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.variable |
---|
Methods in com.espertech.esper.epl.variable with parameters of type ExprEvaluatorContext | |
---|---|
OnSetVariableView |
OnSetVariableViewFactory.instantiate(ExprEvaluatorContext exprEvaluatorContext)
|
void |
VariableReadWritePackage.writeVariables(VariableService variableService,
EventBean[] eventsPerStream,
java.util.Map<java.lang.String,java.lang.Object> valuesWritten,
ExprEvaluatorContext exprEvaluatorContext)
Write new variable values and commit, evaluating assignment expressions using the given events per stream. |
Constructors in com.espertech.esper.epl.variable with parameters of type ExprEvaluatorContext | |
---|---|
OnSetVariableView(OnSetVariableViewFactory factory,
ExprEvaluatorContext exprEvaluatorContext)
|
|
OnSetVariableViewFactory(java.lang.String statementId,
OnTriggerSetDesc desc,
EventAdapterService eventAdapterService,
VariableService variableService,
StatementResultService statementResultService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.view |
---|
Methods in com.espertech.esper.epl.view with parameters of type ExprEvaluatorContext | |
---|---|
void |
OutputProcessViewDirectDistinctOrAfter.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join. |
void |
OutputProcessViewDirect.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join. |
void |
OutputProcessViewConditionSnapshot.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join. |
void |
OutputProcessViewConditionFirst.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join. |
void |
OutputProcessViewConditionDefault.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join. |
void |
OutputProcessViewBaseCallback.process(java.util.Set<MultiKey<EventBean>> newEvents,
java.util.Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
Constructors in com.espertech.esper.epl.view with parameters of type ExprEvaluatorContext | |
---|---|
FilterExprView(ExprNode exprNode,
ExprEvaluator exprEvaluator,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
|
FilterExprViewIterator(java.util.Iterator<EventBean> sourceIterator,
ExprEvaluator filter,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.virtualdw |
---|
Methods in com.espertech.esper.epl.virtualdw with parameters of type ExprEvaluatorContext | |
---|---|
java.util.Collection<EventBean> |
SubordTableLookupStrategyVirtualDW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
java.util.Set<EventBean> |
JoinExecTableLookupStrategyVirtualDW.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext context)
|
Uses of ExprEvaluatorContext in com.espertech.esper.event |
---|
Methods in com.espertech.esper.event with parameters of type ExprEvaluatorContext | |
---|---|
static MultiKeyUntyped |
EventBeanUtility.getMultiKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
ExprEvaluatorContext context,
java.lang.Class[] coercionTypes)
|
Uses of ExprEvaluatorContext in com.espertech.esper.event.bean |
---|
Methods in com.espertech.esper.event.bean with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Object |
InstanceManufacturerFastCtor.make(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InstanceManufacturer.make(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.filter |
---|
Fields in com.espertech.esper.filter declared as ExprEvaluatorContext | |
---|---|
protected ExprEvaluatorContext |
ExprNodeAdapterBase.evaluatorContext
|
ExprEvaluatorContext |
FilterSpecCompilerArgs.exprEvaluatorContext
|
Methods in com.espertech.esper.filter with parameters of type ExprEvaluatorContext | |
---|---|
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(java.util.List<ExprNode> validatedFilterNodes,
EventType eventType,
java.lang.String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
StreamTypeService streamTypeService,
java.lang.String optionalStreamName,
java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String statementId,
java.lang.String statementName,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
MethodResolutionService methodResolutionService,
EventAdapterService eventAdapterService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ConfigurationInformation configurationInformation,
NamedWindowService namedWindowService)
|
java.lang.String |
RangeValueString.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Double |
RangeValueEventPropIndexed.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
RangeValueEventProp.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Double |
RangeValueDouble.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
RangeValueContextProp.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
InSetOfValuesEventPropIndexed.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
InSetOfValuesEventProp.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
InSetOfValuesContextProp.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
InSetOfValuesConstant.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
FilterSpecParamRangeValue.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
Returns the filter value representing the endpoint. |
java.lang.Object |
FilterSpecParamRange.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
FilterSpecParamInValue.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
Returns the actual value to filter for from prior matching events |
java.lang.Object |
FilterSpecParamIn.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
ExprNodeAdapterBase |
FilterSpecParamExprNode.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
FilterSpecParamEventPropIndexed.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
FilterSpecParamEventProp.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
FilterSpecParamContextProp.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
java.lang.Object |
FilterSpecParamConstant.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
|
abstract java.lang.Object |
FilterSpecParam.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext)
Return the filter parameter constant to filter for. |
FilterValueSet |
FilterSpecCompiled.getValueSet(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext,
FilterValueSetParam[][] addendum)
Returns the values for the filter, using the supplied result events to ask filter parameters for the value to filter for. |
protected static FilterSpecParam |
FilterSpecCompilerMakeParamUtil.makeFilterParam(ExprNode constituent,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String statementName)
For a given expression determine if this is optimizable and create the filter parameter representing the expression, or null if not optimizable. |
Constructors in com.espertech.esper.filter with parameters of type ExprEvaluatorContext | |
---|---|
ExprNodeAdapterBase(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext)
Ctor. |
|
ExprNodeAdapterBaseStmtLock(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService)
|
|
ExprNodeAdapterBaseVariables(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService)
|
|
ExprNodeAdapterBaseWTableAccess(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
ExprNodeAdapterBase evalBase,
TableService tableService)
|
|
ExprNodeAdapterMultiStream(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype)
|
|
ExprNodeAdapterMultiStreamNoTL(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype)
|
|
ExprNodeAdapterMultiStreamNoTLStmtLock(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype)
|
|
ExprNodeAdapterMultiStreamStmtLock(java.lang.String statementName,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EventBean[] prototype)
|
|
FilterSpecCompilerArgs(java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> taggedEventTypes,
java.util.LinkedHashMap<java.lang.String,Pair<EventType,java.lang.String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.String statementName,
java.lang.String statementId,
StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
EventAdapterService eventAdapterService,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configurationInformation)
|
Uses of ExprEvaluatorContext in com.espertech.esper.metrics.instrumentation |
---|
Methods in com.espertech.esper.metrics.instrumentation with parameters of type ExprEvaluatorContext | |
---|---|
void |
InstrumentationDefault.qSelectClause(EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
Instrumentation.qSelectClause(EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.pattern |
---|
Methods in com.espertech.esper.pattern with parameters of type ExprEvaluatorContext | |
---|---|
static java.lang.Object |
PatternExpressionUtil.evaluate(java.lang.String objectName,
MatchedEventMap beginState,
ExprNode parameter,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
|
static java.util.List<java.lang.Object> |
PatternExpressionUtil.evaluate(java.lang.String objectName,
MatchedEventMap beginState,
java.util.List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
static java.lang.Object |
PatternExpressionUtil.evaluateTimePeriod(java.lang.String objectName,
MatchedEventMap beginState,
ExprTimePeriod timePeriod,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate the pattern expression. |
Uses of ExprEvaluatorContext in com.espertech.esper.rowregex |
---|
Methods in com.espertech.esper.rowregex that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
RegexPartitionStateRepoGroupMeta.getExprEvaluatorContext()
|
Methods in com.espertech.esper.rowregex with parameters of type ExprEvaluatorContext | |
---|---|
RegexPartitionStateRandomAccess |
RegexPartitionStateRandomAccessGetter.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
RegexPartitionStateRandomAccess |
RegexExprPreviousEvalStrategy.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAStateZeroToMany.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAStateOneToMany.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAStateOneOptional.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAStateFilter.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAStateEnd.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAStateAnyOne.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RegexNFAState.matches(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate a match. |
Constructors in com.espertech.esper.rowregex with parameters of type ExprEvaluatorContext | |
---|---|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.type |
---|
Methods in com.espertech.esper.type with parameters of type ExprEvaluatorContext | |
---|---|
java.lang.Number |
MinMaxTypeEnum.Computer.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Executes child expression nodes and compares results, returning the min/max. |
java.lang.Number |
MinMaxTypeEnum.MinComputerDoubleCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Number |
MinMaxTypeEnum.MaxComputerDoubleCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Number |
MinMaxTypeEnum.ComputerBigIntCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Number |
MinMaxTypeEnum.ComputerBigDecCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.view |
---|
Methods in com.espertech.esper.view with parameters of type ExprEvaluatorContext | |
---|---|
static java.lang.Object |
ViewFactorySupport.evaluateAssertNoProperties(java.lang.String viewName,
ExprNode expression,
int index,
ExprEvaluatorContext exprEvaluatorContext)
Assert and throws an exception if the expression uses event property values. |
EventTable[][] |
HistoricalEventViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext)
Poll for stored historical or reference data using events per stream and returing for each event-per-stream row a separate list with events representing the poll result. |
void |
ValidatedView.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
java.lang.String engineURI,
java.util.Map<java.lang.Integer,java.util.List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
java.lang.String statementName,
java.lang.String statementId,
java.lang.annotation.Annotation[] annotations)
Validate the view. |
Uses of ExprEvaluatorContext in com.espertech.esper.view.ext |
---|
Methods in com.espertech.esper.view.ext with parameters of type ExprEvaluatorContext | |
---|---|
static java.lang.Object |
RankWindowView.getCriteriaKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
EventBean theEvent,
ExprEvaluatorContext evalContext)
|
static MultiKeyUntyped |
RankWindowView.getCriteriaMultiKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
ExprEvaluatorContext evalContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.view.internal |
---|
Methods in com.espertech.esper.view.internal with parameters of type ExprEvaluatorContext | |
---|---|
boolean |
RouteResultViewHandlerFirst.handle(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RouteResultViewHandlerAll.handle(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
RouteResultViewHandler.handle(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Handle event. |
Uses of ExprEvaluatorContext in com.espertech.esper.view.stream |
---|
Methods in com.espertech.esper.view.stream with parameters of type ExprEvaluatorContext | |
---|---|
Pair<EventStream,StatementAgentInstanceLock> |
StreamFactorySvcImpl.createStream(java.lang.String statementId,
FilterSpecCompiled filterSpec,
FilterService filterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
boolean isJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
java.lang.annotation.Annotation[] annotations,
boolean stateless,
int streamNum,
boolean isCanIterateUnbound)
See the method of the same name in StreamFactoryService . |
Pair<EventStream,StatementAgentInstanceLock> |
StreamFactoryService.createStream(java.lang.String statementId,
FilterSpecCompiled filterSpec,
FilterService filterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
boolean isJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean hasOrderBy,
boolean filterWithSameTypeSubselect,
java.lang.annotation.Annotation[] annotations,
boolean stateless,
int streamNum,
boolean isCanIterateUnbound)
Create or reuse existing EventStream instance representing that event filter. |
|
© 2006-2015 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV NEXT | FRAMES NO FRAMES |