|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ExprEvaluatorContext | |
---|---|
com.espertech.esper.client.hook | Callback interfaces for use with statement annotations. |
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.core.thread | This package contains classes to advanced threading options. |
com.espertech.esper.epl.agg.access | State multifunction aggregation methods |
com.espertech.esper.epl.agg.service | Aggregation services. |
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 | This package contains the EPL expression nodes that represent all expressions such as used in select clauses, group-by and having clauses, or order-by clauses |
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.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.filter | Main switchboard filtering and routing of incoming events to interested statements is performed in this package. |
com.espertech.esper.metrics.instrumentation | |
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.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 |
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 |
AIRegistryPreviousSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryPreviousMultiPerm.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryPreviousMap.evaluateGetEventBean(EventBean[] eventsPerStream,
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)
|
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousSingle.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousMultiPerm.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousMap.getAccess(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
AIRegistryAggregationSingle.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryAggregationMultiPerm.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AIRegistryAggregationMap.getCollection(int column,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryAggregationSingle.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryAggregationMultiPerm.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AIRegistryAggregationMap.getEventBean(int column,
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)
|
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
|
Methods in com.espertech.esper.core.context.util with parameters of type ExprEvaluatorContext | |
---|---|
void |
EPStatementAgentInstanceHandle.internalDispatch(ExprEvaluatorContext exprEvaluatorContext)
Invoked by EPRuntime to indicate that a statements's
filer and schedule processing is done, and now it's time to process join results. |
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. |
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. |
static void |
EPRuntimeImpl.processStatementScheduleMultiple(EPStatementAgentInstanceHandle handle,
java.lang.Object callbackObject,
EPServicesContext services,
ExprEvaluatorContext exprEvaluatorContext)
Processing multiple schedule matches for a statement. |
static void |
EPRuntimeImpl.processStatementScheduleSingle(EPStatementHandleCallback handle,
EPServicesContext services,
ExprEvaluatorContext exprEvaluatorContext)
Processing single schedule matche for a statement. |
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. |
Uses of ExprEvaluatorContext in com.espertech.esper.core.start |
---|
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)
|
Constructors in com.espertech.esper.core.start with parameters of type ExprEvaluatorContext | |
---|---|
EPPreparedExecuteSingleStreamExecInsert(ExprEvaluatorContext exprEvaluatorContext,
SelectExprProcessor insertHelper)
|
Uses of ExprEvaluatorContext in com.espertech.esper.core.thread |
---|
Constructors in com.espertech.esper.core.thread with parameters of type ExprEvaluatorContext | |
---|---|
TimerUnitMultiple(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementAgentInstanceHandle handle,
java.lang.Object callbackObject,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
|
TimerUnitSingle(EPServicesContext services,
EPRuntimeImpl runtime,
EPStatementHandleCallback handleCallback,
ExprEvaluatorContext exprEvaluatorContext)
Ctor. |
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 |
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. |
protected static java.lang.Object |
AggregationStateSortedImpl.getComparable(ExprEvaluator[] criteria,
EventBean[] eventsPerStream,
boolean istream,
ExprEvaluatorContext exprEvaluatorContext)
|
Uses of ExprEvaluatorContext in com.espertech.esper.epl.agg.service |
---|
Methods in com.espertech.esper.epl.agg.service with parameters of type 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 |
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 |
AggSvcGroupAllMixedAccessImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllAccessOnlyImpl.applyEnter(EventBean[] eventsPerStream,
java.lang.Object groupKey,
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). |
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 |
AggSvcGroupAllMixedAccessImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllAccessOnlyImpl.applyLeave(EventBean[] eventsPerStream,
java.lang.Object groupKey,
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). |
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 |
AggSvcGroupAllMixedAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggSvcGroupAllAccessOnlyImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationServiceNull.clearResults(ExprEvaluatorContext exprEvaluatorContext)
|
void |
AggregationService.clearResults(ExprEvaluatorContext exprEvaluatorContext)
Clear current aggregation state. |
java.util.Collection<EventBean> |
AggSvcGroupByRefcountedWAccessRollupImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByRefcountedWAccessImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByRefcountedNoAccessImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByReclaimAgedImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByNoAccessImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByMixedAccessImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupByAccessOnlyImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllNoAccessImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllMixedAccessImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggSvcGroupAllAccessOnlyImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationServiceNull.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationServiceMatchRecognizeImpl.getCollection(int column,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
AggregationResultFuture.getCollection(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByRefcountedWAccessRollupImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByRefcountedWAccessImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByRefcountedNoAccessImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByReclaimAgedImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByNoAccessImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByMixedAccessImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupByAccessOnlyImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllNoAccessImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllMixedAccessImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggSvcGroupAllAccessOnlyImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggregationServiceNull.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggregationServiceMatchRecognizeImpl.getEventBean(int column,
ExprEvaluatorContext context)
|
EventBean |
AggregationResultFuture.getEventBean(int column,
ExprEvaluatorContext context)
|
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> |
AggSvcGroupAllMixedAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<java.lang.Object> |
AggSvcGroupAllAccessOnlyImpl.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)
|
static AggregationServiceFactoryDesc |
AggregationServiceFactoryFactory.getService(java.util.List<ExprAggregateNode> selectAggregateExprNodes,
ExprNode[] groupByNodes,
java.util.List<ExprAggregateNode> havingAggregateExprNodes,
java.util.List<ExprAggregateNode> orderByAggregateExprNodes,
java.util.List<ExprAggregateNodeGroupKey> groupKeyExpressions,
boolean hasGroupByClause,
ExprEvaluatorContext exprEvaluatorContext,
java.lang.annotation.Annotation[] annotations,
VariableService variableService,
boolean isJoin,
boolean isDisallowNoReclaim,
ExprNode whereClause,
ExprNode havingClause,
AggregationServiceFactoryService factoryService,
EventType[] typesPerStream,
MethodResolutionService methodResolutionService,
AggregationGroupByRollupDesc groupByRollupDesc,
java.lang.String optionalContextName)
Returns an instance to handle the aggregation required by the aggregation expression nodes, depending on whether there are any group-by nodes. |
static AggregationServiceMatchRecognizeFactoryDesc |
AggregationServiceFactoryFactory.getServiceMatchRecognize(int numStreams,
java.util.Map<java.lang.Integer,java.util.List<ExprAggregateNode>> measureExprNodesPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Produces an aggregation service for use with match-recognice. |
Uses of ExprEvaluatorContext in com.espertech.esper.epl.core |
---|
Methods in com.espertech.esper.epl.core with parameters of type ExprEvaluatorContext | |
---|---|
static HistoricalEventViewable |
MethodPollingViewableFactory.createPollMethodView(int streamNumber,
MethodStreamSpec methodStreamSpec,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
MethodResolutionService methodResolutionService,
EngineImportService engineImportService,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
ExprEvaluatorContext exprEvaluatorContext)
Creates a method-invocation polling view for use as a stream that calls a method, or pulls results from cache. |
java.lang.Object |
SelectExprInsertEventBeanFactory.ExprEvaluatorJoinWildcard.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
static SelectExprProcessor |
SelectExprProcessorFactory.getProcessor(java.util.Collection<java.lang.Integer> assignedTypeNumberStack,
SelectClauseElementCompiled[] selectionList,
boolean isUsingWildcard,
InsertIntoDesc insertIntoDesc,
ForClauseSpec forClauseSpec,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
StatementResultService statementResultService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
MethodResolutionService methodResolutionService,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
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)
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 |
OrderByProcessorRowLimit.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 |
OrderByProcessorRowLimit.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[] |
OrderByProcessorRowLimit.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)
|
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 |
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 |
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[] |
OrderByProcessorRowLimit.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[] |
OrderByProcessorRowLimit.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[] |
OrderByProcessorRowLimit.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,
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 |
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,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamNoUndWEventBeanToObj.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
EvalSelectStreamNoUnderlyingMap.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
|
abstract EventBean |
EvalSelectStreamBaseMap.processSpecific(java.util.Map<java.lang.String,java.lang.Object> props,
EventBean[] eventsPerStream,
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)
|
void |
DatabasePollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
TimeProvider timeProvider,
VariableService variableService,
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)
|
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 |
ExprDotEvalUnpackCollEventBean.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.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 |
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> |
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 |
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 |
---|
Classes in com.espertech.esper.epl.expression 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 that return ExprEvaluatorContext | |
---|---|
ExprEvaluatorContext |
ExprValidationContext.getExprEvaluatorContext()
|
Methods in com.espertech.esper.epl.expression 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.lang.Iterable<EventBean> iterable,
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)
|
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 |
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 |
ExprVariableNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
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 |
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)
|
java.lang.Object |
ExprSubstitutionNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprSubselectNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprStreamUnderlyingNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext 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 |
ExprPropertyExistsNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprPriorNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext 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 |
ExprOrNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprOrderedExpr.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNumberSetWildcard.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 |
ExprNotNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNodeValidated.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprNodeUtilExprEvalStreamNumUnd.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 |
ExprNewNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprMinMaxRowNode.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 |
ExprIStreamNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprInstanceofNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprInNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
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 |
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 |
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 |
ExprContextPropertyNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprConstantNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprConcatNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCoalesceNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCastNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.lang.Object |
ExprCaseNode.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)
|
java.lang.Object |
ExprAggregateNodeGroupKey.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object |
ExprAggregateNodeBase.evaluate(EventBean[] events,
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)
|
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.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)
|
double |
ExprTimePeriodImpl.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
double |
ExprTimePeriod.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
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)
|
static java.lang.Object[] |
ExprNodeUtility.evaluateExpressions(ExprEvaluator[] parameters,
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> |
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 |
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 |
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 |
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 |
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)
|
EventBean |
ExprPreviousNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprPlugInAggMultiFunctionNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprEvaluatorEnumeration.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprDotEvalRootChildInnerEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprDotEvalRootChild.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
EventBean |
ExprArrayNode.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 |
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> |
ExprSubselectNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection<EventBean> |
ExprPreviousNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprPlugInAggMultiFunctionNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection<EventBean> |
ExprEvaluatorEnumeration.evaluateGetROCollectionEvents(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<EventBean> |
ExprArrayNode.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 |
ExprSubselectNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Collection |
ExprPreviousNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprPlugInAggMultiFunctionNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.util.Collection |
ExprEvaluatorEnumeration.evaluateGetROCollectionScalar(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)
|
java.util.Collection |
ExprArrayNode.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)
|
TimePeriod |
ExprTimePeriodImpl.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
TimePeriod |
ExprTimePeriod.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context)
|
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[][] |
ExprNewNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprEvaluatorTypableReturn.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[][] |
ExprCaseNode.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[] |
ExprNewNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprEvaluatorTypableReturn.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
java.lang.Object[] |
ExprCaseNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
|
Constructors in com.espertech.esper.epl.expression with parameters of type ExprEvaluatorContext | |
---|---|
ExprValidationContext(StreamTypeService streamTypeService,
MethodResolutionService methodResolutionService,
ViewResourceDelegateUnverified viewResourceDelegate,
TimeProvider timeProvider,
VariableService variableService,
ExprEvaluatorContext exprEvaluatorContext,
EventAdapterService eventAdapterService,
java.lang.String statementName,
java.lang.String statementId,
java.lang.annotation.Annotation[] annotations,
ContextDescriptor contextDescriptor,
boolean disablePropertyExpressionEventCollCache,
boolean allowRollupFunctions)
|
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)
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<java.lang.String,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
boolean isPureSelfJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean joinRemoveStream,
boolean outerJoins)
|
|
JoinSetComposerHistoricalImpl(java.util.Map<java.lang.String,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
Viewable[] streamViews,
ExprEvaluatorContext staticEvalExprEvaluatorContext)
Ctor. |
|
JoinSetComposerImpl(java.util.Map<java.lang.String,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)
|
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> |
FullTableScanLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
|
java.util.Set<EventBean> |
CompositeTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext context)
|
void |
TableOuterLookupExecNode.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)
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)
|
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> |
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> |
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 |
NamedWindowServiceImpl.dispatch(ExprEvaluatorContext exprEvaluatorContext)
|
boolean |
NamedWindowService.dispatch(ExprEvaluatorContext exprEvaluatorContext)
Dispatch events of the insert and remove stream of named windows to consumers, as part of the main event processing or dispatch loop. |
boolean |
NamedWindowOnMergeMatch.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
boolean |
NamedWindowOnMergeAction.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
|
EventBean[] |
NamedWindowLookupStrategyTableScan.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
NamedWindowLookupStrategyIndexedUnfiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
NamedWindowLookupStrategyIndexed.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
NamedWindowLookupStrategyAllRows.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean[] |
NamedWindowLookupStrategy.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
Determines the events to be deleted from a named window. |
java.util.Collection<EventBean> |
NamedWindowTailViewInstance.snapshotNoLockWithFilter(FilterSpecCompiled filter,
java.lang.annotation.Annotation[] annotations,
ExprNode filterExpr,
ExprEvaluatorContext exprEvaluatorContext)
|
EventBean |
NamedWindowUpdateHelper.update(EventBean matchingEvent,
EventBean[] eventsPerStream,
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 |
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.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.filter |
---|
Fields in com.espertech.esper.filter declared as ExprEvaluatorContext | |
---|---|
protected ExprEvaluatorContext |
ExprNodeAdapterBase.evaluatorContext
|
Methods in com.espertech.esper.filter with parameters of type ExprEvaluatorContext | |
---|---|
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(java.util.List<ExprNode> validatedNodes,
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,
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 |
FilterSpecCompiler.makeFilterParam(ExprNode constituent,
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)
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)
|
|
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)
|
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)
Evaluate the pattern expression. |
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. |
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,
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-2014 EsperTech Inc. All rights reserved. Visit us at espertech.com |
|||||||||
PREV NEXT | FRAMES NO FRAMES |