| Package | Description |
|---|---|
| com.espertech.esper.client.hook |
Callback interfaces for use with statement annotations.
|
| com.espertech.esper.collection |
Internal collection classes
|
| com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
| com.espertech.esper.core.context.stmt |
Registries for context partitions to handle aggregations, prev/prior and subselects.
|
| com.espertech.esper.core.context.util |
Context partition utility or reference classes.
|
| com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
| com.espertech.esper.core.start |
Classes related to start and stop of statements
|
| com.espertech.esper.core.support |
Internal-use-only services for unit and regression testing
|
| com.espertech.esper.epl.agg.access |
State multifunction aggregation methods
|
| com.espertech.esper.epl.agg.service |
Aggregation services.
|
| com.espertech.esper.epl.approx |
Approximation algos.
|
| com.espertech.esper.epl.core |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
| com.espertech.esper.epl.core.eval |
Select expression evaluators.
|
| com.espertech.esper.epl.datetime.calop |
Date-Time calendar operations.
|
| com.espertech.esper.epl.datetime.dtlocal | |
| 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.interval.deltaexpr | |
| com.espertech.esper.epl.datetime.reformatop |
Date-Time re-formatting operations.
|
| com.espertech.esper.epl.db |
Database SQL polling views and caches
|
| com.espertech.esper.epl.declexpr |
Declared expression handling.
|
| com.espertech.esper.epl.enummethod.dot |
Enumeration method utility classes and input data sources.
|
| com.espertech.esper.epl.enummethod.eval |
Enumeration method implementations.
|
| com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
| com.espertech.esper.epl.expression.baseagg |
Base aggregation expressions.
|
| com.espertech.esper.epl.expression.core |
Core expression classes.
|
| com.espertech.esper.epl.expression.dot |
Chained expression functionality.
|
| com.espertech.esper.epl.expression.dot.inner |
Expression dot-method innerForge evaluators.
|
| com.espertech.esper.epl.expression.funcs |
Function expressions.
|
| com.espertech.esper.epl.expression.ops |
Operator expressions.
|
| com.espertech.esper.epl.expression.prev |
'Previous'-group expressions.
|
| com.espertech.esper.epl.expression.prior |
'Prior'-group expressions.
|
| com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
| com.espertech.esper.epl.expression.table |
Table access and identifiers expressions.
|
| com.espertech.esper.epl.expression.time |
Time-related expressions.
|
| com.espertech.esper.epl.index.quadtree |
Quad-tree indexes
|
| com.espertech.esper.epl.index.service |
Advanced index provisioning
|
| 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.join.table |
Indexes for views
|
| com.espertech.esper.epl.lookup |
Subquery execution strategies and lookup indexes
|
| com.espertech.esper.epl.named |
Named window classes are in this package
|
| com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
| com.espertech.esper.epl.property |
Classes for handling events-within-events.
|
| com.espertech.esper.epl.script |
Script expression evaluation.
|
| com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
| com.espertech.esper.epl.subquery |
Subquery helper classes are found here.
|
| com.espertech.esper.epl.table.merge |
Table on-merge handlers.
|
| com.espertech.esper.epl.table.mgmt |
Table-related services and metadata.
|
| com.espertech.esper.epl.table.onaction |
Table on-action handlers.
|
| com.espertech.esper.epl.table.strategy |
Table access evaluators.
|
| com.espertech.esper.epl.table.upd |
Table update strategies.
|
| com.espertech.esper.epl.updatehelper |
Helpers for EPL update functionality.
|
| com.espertech.esper.epl.variable |
Variable service and variable collections
|
| com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
| com.espertech.esper.epl.virtualdw |
Virtual data window.
|
| com.espertech.esper.event |
This package defines the internal event APIs.
|
| com.espertech.esper.event.bean |
JavaBean and legacy Java underlying event classes are here.
|
| com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
| com.espertech.esper.metrics.instrumentation |
EPL instrumentation helpers.
|
| com.espertech.esper.pattern |
Pattern expression tree and pattern state objects, the later resembles pattern expression state for each active
pattern instance
|
| com.espertech.esper.rowregex |
Match-recognize expression tree and state objects.
|
| com.espertech.esper.type |
Internal primitive, enum and other type representations
|
| com.espertech.esper.util.support |
Internal-use-only unit and regression test support classes.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
VirtualDataWindowEventConsumerAdd.getExprEvaluatorContext()
Returns the expression evaluator context for evaluating filter expressions.
|
| Constructor and Description |
|---|
VirtualDataWindowEventConsumerAdd(String namedWindowName,
Object consumerObject,
String statementName,
int agentInstanceId,
ExprNode[] filterExpressions,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
| Constructor and Description |
|---|
FilteredEventIterator(ExprEvaluator[] filters,
Iterator<EventBean> parent,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StatementAgentInstancePreload.executePreload(ExprEvaluatorContext exprEvaluatorContext) |
| Constructor and Description |
|---|
StatementAgentInstancePostLoadSelect(Viewable[] streamViews,
JoinSetComposerDesc joinSetComposer,
NamedWindowTailViewInstance[] namedWindowTailViews,
QueryGraph[] namedWindowPostloadFilters,
List<ExprNode>[] namedWindowFilters,
Annotation[] annotations,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
AIRegistryAggregationSingle.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationMultiPerm.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationMap.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationSingle.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationMultiPerm.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationMap.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationSingle.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationMultiPerm.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AIRegistryAggregationMap.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryTableAccessSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryTableAccessMultiPerm.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
AIRegistryTableAccessMap.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
AIRegistryPriorSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber) |
Object |
AIRegistryPriorMultiPerm.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber) |
Object |
AIRegistryPriorMap.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber) |
Object |
AIRegistryPreviousSingle.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryPreviousMultiPerm.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryPreviousMap.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AIRegistryPreviousSingle.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryPreviousMultiPerm.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryPreviousMap.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
AIRegistryPreviousSingle.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
AIRegistryPreviousMultiPerm.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
AIRegistryPreviousMap.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
AIRegistryTableAccessSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AIRegistryTableAccessMultiPerm.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AIRegistryTableAccessMap.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AIRegistryPreviousSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
AIRegistryPreviousMultiPerm.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
AIRegistryPreviousMap.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryTableAccessSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryTableAccessMultiPerm.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryTableAccessMap.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
AIRegistryTableAccessSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
AIRegistryTableAccessMultiPerm.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
AIRegistryTableAccessMap.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistrySubselectSingle.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AIRegistrySubselectMultiPerm.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AIRegistrySubselectMap.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
AIRegistryTableAccessSingle.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
AIRegistryTableAccessMultiPerm.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
AIRegistryTableAccessMap.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousSingle.getAccess(ExprEvaluatorContext exprEvaluatorContext) |
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousMultiPerm.getAccess(ExprEvaluatorContext exprEvaluatorContext) |
RegexPartitionStateRandomAccess |
AIRegistryMatchRecognizePreviousMap.getAccess(ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AIRegistryAggregationSingle.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryAggregationMultiPerm.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AIRegistryAggregationMap.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AIRegistryAggregationSingle.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AIRegistryAggregationMultiPerm.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AIRegistryAggregationMap.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AIRegistryAggregationSingle.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AIRegistryAggregationMultiPerm.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AIRegistryAggregationMap.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AIRegistryAggregationSingle.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AIRegistryAggregationMultiPerm.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AIRegistryAggregationMap.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryAggregationSingle.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryAggregationMultiPerm.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AIRegistryAggregationMap.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Class and Description |
|---|---|
class |
AgentInstanceContext |
class |
AgentInstanceViewFactoryChainContext |
| Modifier and Type | Class and Description |
|---|---|
class |
ExprEvaluatorContextStatement
Represents a statement-level-only context for expression evaluation, not allowing for agents instances and result cache.
|
class |
ExprEvaluatorContextWTableAccess |
| Modifier and Type | Field and Description |
|---|---|
protected ExprEvaluatorContext |
EPRuntimeImpl.engineFilterAndDispatchTimeContext |
| Modifier and Type | Method and Description |
|---|---|
EventBean |
InternalEventRouterImpl.preprocess(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Pre-process the event.
|
EventBean |
InternalEventRouter.preprocess(EventBean theEvent,
ExprEvaluatorContext engineFilterAndDispatchTimeContext) |
EventBean |
InternalEventRouterPreprocessor.process(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Pre-proces the event.
|
void |
InternalEventRouterImpl.route(EventBean theEvent,
EPStatementHandle statementHandle,
InternalEventRouteDest routeDest,
ExprEvaluatorContext exprEvaluatorContext,
boolean addToFront) |
void |
InternalEventRouter.route(EventBean theEvent,
EPStatementHandle statementHandle,
InternalEventRouteDest routeDest,
ExprEvaluatorContext exprEvaluatorContext,
boolean addToFront)
Route the event such that the event is processed as required.
|
void |
StatementResultServiceImpl.setSelectClause(Class[] selectClauseTypes,
String[] selectClauseColumnNames,
boolean forClauseDelivery,
ExprEvaluator[] groupDeliveryExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
void |
StatementResultService.setSelectClause(Class[] selectClauseTypes,
String[] selectClauseColumnNames,
boolean forClauseDelivery,
ExprEvaluator[] groupDeliveryExpressions,
ExprEvaluatorContext exprEvaluatorContext)
For initialize of the service providing select clause column types and names.
|
| Constructor and Description |
|---|
ExprEvaluatorContextWTableAccess(ExprEvaluatorContext context,
TableService tableService) |
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
EPPreparedExecuteIUDSingleStreamExecInsert.getExprEvaluatorContext() |
| Modifier and Type | Method and Description |
|---|---|
protected static ExprNode |
EPStatementStartMethodHelperValidate.validateExprNoAgg(ExprNodeOrigin exprNodeOrigin,
ExprNode exprNode,
StreamTypeService streamTypeService,
StatementContext statementContext,
ExprEvaluatorContext exprEvaluatorContext,
String errorMsg,
boolean allowTableConsumption) |
| Constructor and Description |
|---|
EPPreparedExecuteIUDSingleStreamExecInsert(ExprEvaluatorContext exprEvaluatorContext,
SelectExprProcessor insertHelper,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
| Modifier and Type | Method and Description |
|---|---|
static ExprEvaluatorContext |
SupportStatementContextFactory.makeEvaluatorContext() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
AggregationStateMinMaxByEver.addEvent(EventBean theEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateSortedWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateSortedJoinWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateSortedImpl.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateMinMaxByEverWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateMinMaxByEver.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearJoinWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearJoinImpl.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearImpl.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationState.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Enter an event.
|
void |
AggregationAgentRewriteStreamWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgentRewriteStream.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgentDefaultWFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgentDefault.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgent.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationStateSortedWFilter.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateSortedJoinWFilter.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateSortedImpl.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateMinMaxByEver.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearWFilter.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearJoinWFilter.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearJoinImpl.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationStateLinearImpl.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationState.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Remove an event.
|
void |
AggregationAgentRewriteStreamWFilter.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgentRewriteStream.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgentDefaultWFilter.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgentDefault.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
AggregationAgent.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
protected void |
AggregationStateSortedImpl.dereferenceRemove(EventBean theEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
static Object |
AggregationStateSortedImpl.getComparable(ExprEvaluator[] criteria,
EventBean[] eventsPerStream,
boolean istream,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorWindowWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorWindowNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorSortedTable.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorSortedNonTable.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorMinMaxByBase.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorLastWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorLastNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorFirstWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorFirstNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorFirstLastIndexWEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessorFirstLastIndexNoEval.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
AggregationAccessor.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a single event.
|
Collection<EventBean> |
AggregationAccessorWindowWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorWindowNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorSortedTable.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorSortedNonTable.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorMinMaxByBase.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggregationAccessorLastWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorLastNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorFirstWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorFirstNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorFirstLastIndexWEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessorFirstLastIndexNoEval.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggregationAccessor.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of events.
|
Collection<Object> |
AggregationAccessorWindowWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorWindowNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorSortedTable.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorSortedNonTable.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorMinMaxByBase.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorLastWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorLastNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorFirstWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorFirstNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorFirstLastIndexWEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessorFirstLastIndexNoEval.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationAccessor.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value consisting of a collection of scalar values.
|
Object |
AggregationAccessorWindowWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorWindowNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorSortedTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorSortedNonTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorMinMaxByTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
AggregationAccessorMinMaxByNonTable.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
AggregationAccessorLastWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorLastNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorFirstWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorFirstNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorFirstLastIndexWEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessorFirstLastIndexNoEval.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationAccessor.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Return the aggregation state value either as a scalar value or any other object.
|
protected void |
AggregationStateSortedImpl.referenceAdd(EventBean theEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
static void |
AggSvcGroupLocalGroupByBase.aggregateIntoEnter(AggregationLocalGroupByLevel level,
AggregationMethod[] methods,
AggregationState[] states,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
static void |
AggSvcGroupLocalGroupByBase.aggregateIntoLeave(AggregationLocalGroupByLevel level,
AggregationMethod[] methods,
AggregationState[] states,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceMatchRecognizeImpl.applyEnter(EventBean[] eventsPerStream,
int streamId,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceMatchRecognize.applyEnter(EventBean[] eventsPerStream,
int streamId,
ExprEvaluatorContext exprEvaluatorContext)
Enter a single event row consisting of one or more events per stream (each stream representing a variable).
|
void |
AggSvcGroupLocalGroupByBase.applyEnter(EventBean[] eventsPerStream,
Object groupByKeyProvided,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableBase.applyEnter(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedWAccessRollupImpl.applyEnter(EventBean[] eventsPerStream,
Object compositeGroupKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedWAccessImpl.applyEnter(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedNoAccessImpl.applyEnter(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByReclaimAgedImpl.applyEnter(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByNoAccessImpl.applyEnter(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByMixedAccessImpl.applyEnter(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByAccessOnlyImpl.applyEnter(EventBean[] eventsPerStream,
Object groupKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllNoAccessImpl.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllMixedAccessWTableImpl.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllMixedAccessImpl.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllAccessOnlyImpl.applyEnter(EventBean[] eventsPerStream,
Object groupKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceTable.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceNull.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationService.applyEnter(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as entering a window (new events).
|
protected void |
AggSvcGroupByWTableBase.applyEnterGroupKey(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableRollupSingleKeyImpl.applyEnterInternal(EventBean[] eventsPerStream,
Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableRollupMultiKeyImpl.applyEnterInternal(EventBean[] eventsPerStream,
Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableImpl.applyEnterInternal(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
AggSvcGroupByWTableBase.applyEnterInternal(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupLocalGroupByBase.applyLeave(EventBean[] eventsPerStream,
Object groupByKeyProvided,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableBase.applyLeave(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedWAccessRollupImpl.applyLeave(EventBean[] eventsPerStream,
Object compositeGroupKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedWAccessImpl.applyLeave(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedNoAccessImpl.applyLeave(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByReclaimAgedImpl.applyLeave(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByNoAccessImpl.applyLeave(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByMixedAccessImpl.applyLeave(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByAccessOnlyImpl.applyLeave(EventBean[] eventsPerStream,
Object groupKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllNoAccessImpl.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllMixedAccessWTableImpl.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllMixedAccessImpl.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllAccessOnlyImpl.applyLeave(EventBean[] eventsPerStream,
Object groupKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceTable.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceNull.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationService.applyLeave(EventBean[] eventsPerStream,
Object optionalGroupKeyPerRow,
ExprEvaluatorContext exprEvaluatorContext)
Apply events as leaving a window (old events).
|
protected void |
AggSvcGroupByWTableBase.applyLeaveGroupKey(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableRollupSingleKeyImpl.applyLeaveInternal(EventBean[] eventsPerStream,
Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableRollupMultiKeyImpl.applyLeaveInternal(EventBean[] eventsPerStream,
Object compositeGroupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableImpl.applyLeaveInternal(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
AggSvcGroupByWTableBase.applyLeaveInternal(EventBean[] eventsPerStream,
Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupLocalGroupByBase.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByWTableBase.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedWAccessRollupImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedWAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByRefcountedNoAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByReclaimAgedImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByNoAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByMixedAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupByAccessOnlyImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllNoAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllMixedAccessWTableImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllMixedAccessImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggSvcGroupAllAccessOnlyImpl.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceTable.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationServiceNull.clearResults(ExprEvaluatorContext exprEvaluatorContext) |
void |
AggregationService.clearResults(ExprEvaluatorContext exprEvaluatorContext)
Clear current aggregation state.
|
protected abstract Object |
AggSvcGroupLocalGroupByBase.computeGroupKey(AggregationLocalGroupByLevel level,
Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
protected Object |
AggSvcGroupByLocalGroupBy.computeGroupKey(AggregationLocalGroupByLevel level,
Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
protected Object |
AggSvcGroupAllLocalGroupBy.computeGroupKey(AggregationLocalGroupByLevel level,
Object groupKey,
ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
static Object |
AggSvcGroupLocalGroupByBase.computeGroupKey(ExprEvaluator[] partitionEval,
EventBean[] eventsPerStream,
boolean b,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
AggSvcGroupLocalGroupByBase.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByWTableBase.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByRefcountedWAccessRollupImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByRefcountedWAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByRefcountedNoAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByReclaimAgedImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByNoAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByMixedAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupByAccessOnlyImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupAllNoAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupAllMixedAccessWTableImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupAllMixedAccessImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggSvcGroupAllAccessOnlyImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggregationServiceTable.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggregationServiceNull.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggregationServiceMatchRecognizeImpl.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
AggregationResultFuture.getCollectionOfEvents(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupLocalGroupByBase.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByWTableBase.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByRefcountedWAccessRollupImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByRefcountedWAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByRefcountedNoAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByReclaimAgedImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByNoAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByMixedAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupByAccessOnlyImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupAllNoAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupAllMixedAccessWTableImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupAllMixedAccessImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupAllAccessOnlyImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggregationServiceTable.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggregationServiceNull.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggregationServiceMatchRecognizeImpl.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggregationResultFuture.getCollectionScalar(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupLocalGroupByBase.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByWTableBase.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByRefcountedWAccessRollupImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByRefcountedWAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByRefcountedNoAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByReclaimAgedImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByNoAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByMixedAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupByAccessOnlyImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupAllNoAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupAllMixedAccessWTableImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupAllMixedAccessImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggSvcGroupAllAccessOnlyImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggregationServiceTable.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggregationServiceNull.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggregationServiceMatchRecognizeImpl.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
AggregationResultFuture.getEventBean(int column,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<Object> |
AggSvcGroupLocalGroupByBase.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByWTableBase.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByRefcountedWAccessRollupImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByRefcountedWAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByRefcountedNoAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByReclaimAgedImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByNoAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByMixedAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupByAccessOnlyImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupAllNoAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupAllMixedAccessWTableImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupAllMixedAccessImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggSvcGroupAllAccessOnlyImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationServiceTable.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationServiceNull.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationServiceMatchRecognizeImpl.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
AggregationResultFuture.getGroupKeys(ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByWTableBase.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByRefcountedWAccessRollupImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByRefcountedWAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByRefcountedNoAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByReclaimAgedImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByNoAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByMixedAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByLocalGroupBy.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupByAccessOnlyImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupAllNoAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupAllMixedAccessWTableImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupAllMixedAccessImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupAllLocalGroupBy.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggSvcGroupAllAccessOnlyImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationServiceTable.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationServiceNull.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationServiceMatchRecognizeImpl.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
AggregationResultFuture.getValue(int column,
int agentInstanceId,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Returns current aggregation state, for use by expression node representing an aggregation function.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CountMinSketchAggState.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
CountMinSketchAggAgentAddFilter.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
CountMinSketchAggAgentAdd.applyEnter(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
void |
CountMinSketchAggState.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
CountMinSketchAggAgentAdd.applyLeave(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
AggregationState aggregationState) |
EventBean |
CountMinSketchAggAccessorTopk.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
CountMinSketchAggAccessorFrequency.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
CountMinSketchAggAccessorDefault.getEnumerableEvent(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
CountMinSketchAggAccessorTopk.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
CountMinSketchAggAccessorFrequency.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
CountMinSketchAggAccessorDefault.getEnumerableEvents(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
CountMinSketchAggAccessorTopk.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
CountMinSketchAggAccessorFrequency.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<Object> |
CountMinSketchAggAccessorDefault.getEnumerableScalar(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
CountMinSketchAggAccessorTopk.getValue(AggregationState aggregationState,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
CountMinSketchAggAccessorFrequency.getValue(AggregationState aggregationState,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
CountMinSketchAggAccessorDefault.getValue(AggregationState state,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Field and Description |
|---|---|
protected ExprEvaluatorContext |
ResultSetProcessorSimple.exprEvaluatorContext |
protected ExprEvaluatorContext |
ResultSetProcessorRowForAll.exprEvaluatorContext |
| Modifier and Type | Method and Description |
|---|---|
static void |
ResultSetProcessorUtil.applyAggJoinResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents) |
static void |
ResultSetProcessorUtil.applyAggViewResult(AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext,
EventBean[] newData,
EventBean[] oldData,
EventBean[] eventsPerStream) |
static void |
ResultSetProcessorUtil.clearAndAggregateUngrouped(ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService,
Viewable parent) |
static EventBean |
SelectExprProcessorEvalStreamInsertTable.convertToTableEvent(int streamNum,
TableMetadataInternalEventToPublic eventToPublic,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static EventBean[] |
SelectExprProcessorEnumerationAtBeanCollTableEval.convertToTableType(Object result,
TableMetadataInternalEventToPublic eventToPublic,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static HistoricalEventViewable |
MethodPollingViewableFactory.createPollMethodView(int streamNumber,
MethodStreamSpec methodStreamSpec,
EventAdapterService eventAdapterService,
EPStatementAgentInstanceHandle epStatementAgentInstanceHandle,
EngineImportService engineImportService,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
String contextName,
DataCacheFactory dataCacheFactory,
StatementContext statementContext)
Creates a method-invocation polling view for use as a stream that calls a method, or pulls results from cache.
|
EventBean |
OrderByProcessorImpl.determineLocalMinMax(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorTypableSingleEvalSingleRow.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorTypableSingleEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorTypableMultiEvalFirstRow.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorTypableMultiEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorTypableMapEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEvalStreamInsertUnd.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEvalStreamInsertTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEvalStreamInsertNamedWindow.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEvalByGetterFragment.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEvalByGetter.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEnumerationSingleToCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEnumerationCollEvalFirstRow.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEnumerationCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEnumerationAtBeanSingleEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
SelectExprProcessorEnumerationAtBeanCollTableEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SelectExprProcessorEnumerationAtBeanCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
SelectExprInsertEventBeanFactory.ExprForgeJoinWildcard.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
BindProcessorStream.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
BindProcessorEvaluatorStreamTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
static Object[] |
BindProcessorEvaluatorStreamTable.evaluateConvertTableEventToUnd(int streamNum,
TableMetadataInternalEventToPublic eventToPublic,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static SelectExprProcessor |
SelectExprProcessorFactory.getProcessor(Collection<Integer> assignedTypeNumberStack,
SelectClauseElementCompiled[] selectionList,
boolean isUsingWildcard,
InsertIntoDesc insertIntoDesc,
EventType optionalInsertIntoEventType,
ForClauseSpec forClauseSpec,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
StatementResultService statementResultService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
TableService tableService,
TimeProvider timeProvider,
String engineURI,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configuration,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
NamedWindowMgmtService namedWindowMgmtService,
IntoTableSpec intoTableClause,
com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo,
StatementExtensionSvcContext statementExtensionSvcContext) |
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,
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,
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,
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,
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,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Applies the select-clause to the given events returning the selected events.
|
Object |
OrderByProcessorRowLimitOnly.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
OrderByProcessorOrderedLimit.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
OrderByProcessorImpl.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
OrderByProcessor.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Returns the sort key for a given row.
|
Object |
OrderByProcessorRowLimitOnly.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel) |
Object |
OrderByProcessorOrderedLimit.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel) |
Object |
OrderByProcessorImpl.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel) |
Object |
OrderByProcessor.getSortKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
OrderByElement[] elementsForLevel) |
Object[] |
OrderByProcessorRowLimitOnly.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
OrderByProcessorOrderedLimit.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
OrderByProcessorImpl.getSortKeyPerRow(EventBean[] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
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) |
List<EventBean> |
MethodPollingExecStrategyScript.poll(Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext) |
List<EventBean> |
MethodPollingExecStrategyBase.poll(Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectEventsHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectEventsNoHaving(SelectExprProcessor exprProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
Collection<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
EventBean[] events,
boolean isNewData,
boolean isSynthesize,
Collection<EventBean> result,
List<Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
ExprEvaluator havingNode,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> sortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHaving(SelectExprProcessor exprProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
ResultSetProcessorUtil.populateSelectJoinEventsNoHavingWithOrderBy(SelectExprProcessor exprProcessor,
OrderByProcessor orderByProcessor,
Set<MultiKey<EventBean>> events,
boolean isNewData,
boolean isSynthesize,
List<EventBean> result,
List<Object> optSortKeys,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprWildcardTableProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprWildcardProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprResultProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprProcessorWDeliveryCallback.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext)
Computes the select-clause results and returns an event of the result event type that contains, in it's
properties, the selected items.
|
EventBean |
SelectExprJoinWildcardProcessorTableRows.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprJoinWildcardProcessorObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprJoinWildcardProcessorMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceAvro.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) |
EventBean |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeNoEval.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
BindProcessor.process(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Process select expressions into columns for native dispatch.
|
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Sort the output events.
|
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
EventBean[][] generatingEvents,
Object[] groupByKeys,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Sort the output events, using the provided group-by keys for
evaluating grouped aggregation functions, and avoiding the cost of
recomputing the keys.
|
EventBean[] |
OrderByProcessorRowLimitOnly.sort(EventBean[] outgoingEvents,
Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessorOrderedLimit.sort(EventBean[] outgoingEvents,
Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessorImpl.sort(EventBean[] outgoingEvents,
Object[] orderKeys,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
OrderByProcessor.sort(EventBean[] outgoingEvents,
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,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
String engineURI,
Map<Integer,List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext) |
| Constructor and Description |
|---|
MethodPollingViewable(MethodStreamSpec methodStreamSpec,
DataCache dataCache,
EventType eventType,
ExprEvaluatorContext exprEvaluatorContext,
MethodPollingViewableMeta metadata) |
ResultSetAggregateAllIterator(Iterator<EventBean> sourceIterator,
ResultSetProcessorAggregateAll resultSetProcessor,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
ResultSetAggregateGroupedIterator(Iterator<EventBean> sourceIterator,
ResultSetProcessorAggregateGrouped resultSetProcessor,
AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
ResultSetRowPerGroupIterator(Iterator<EventBean> sourceIterator,
ResultSetProcessorRowPerGroup resultSetProcessor,
AggregationService aggregationService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
EventBean |
EvalSelectStreamNoUnderlyingObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamBaseObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamBaseMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectNoWildcardObjectArray.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectNoWildcardMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectNoWildcardEmptyProps.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardRevision.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardJoinRevision.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardBean.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertNoWildcardObjectArrayRemapWWiden.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertNoWildcardObjectArrayRemap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertNoWildcardObjectArray.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 |
EvalInsertCoercionAvro.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 |
EvalBaseMap.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalBaseFirstProp.process(EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectWildcardSSWrapper.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectWildcardJoin.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectWildcard.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardWrapper.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardSSWrapperRevision.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardSSWrapper.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardRevisionWrapper.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertWildcardJoin.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertNoWildcardRevision.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalInsertNoWildcardMap.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
abstract EventBean |
EvalBaseMap.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
boolean isSynthesize,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamWUnderlying.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamNoUndWEventBeanToObj.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamNoUnderlyingMap.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
abstract EventBean |
EvalSelectStreamBaseMap.processSpecific(Map<String,Object> props,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamNoUndWEventBeanToObjObjArray.processSpecific(Object[] props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EvalSelectStreamNoUnderlyingObjectArray.processSpecific(Object[] props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
abstract EventBean |
EvalSelectStreamBaseObjectArray.processSpecific(Object[] props,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
CalendarWithTimeForgeOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarWithMinForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarWithMaxForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarWithDateForgeOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarSetForgeOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarPlusMinusForgeOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
void |
CalendarForgeRound.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarWithTimeForgeOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarWithMinForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarWithMaxForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarWithDateForgeOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarSetForgeOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarPlusMinusForgeOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
LocalDateTime |
CalendarForgeRound.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarWithTimeForgeOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarWithMinForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarWithMaxForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarWithDateForgeOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarSetForgeOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarPlusMinusForgeOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ZonedDateTime |
CalendarForgeRound.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
static Object |
CalendarOpUtil.getFormatter(EPType inputType,
String methodName,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext) |
protected static Integer |
CalendarWithDateForgeOp.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected static Integer |
CalendarOpUtil.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
DTLocalZonedDateTimeReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalZonedDateTimeOpsReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalZonedDateTimeOpsIntervalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLongReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLongOpsReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLongOpsIntervalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLongIntervalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLocalDateTimeReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLocalDateTimeOpsReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLocalDateTimeOpsIntervalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalEvaluator.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalDateReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalDateOpsReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsZonedDateTimeEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsReformatEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsLongEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsLocalDateTimeEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsIntervalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsDateEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsCalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalIntervalEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalBeanIntervalWithEndEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalBeanIntervalNoEndTSEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalBeanCalOpsEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalZonedDateTimeOpsIntervalEval.evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLongOpsIntervalEval.evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLongIntervalEval.evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalLocalDateTimeOpsIntervalEval.evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalOpsIntervalEval.evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
DTLocalCalIntervalEval.evaluate(Object startTimestamp,
Object endTimestamp,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected static void |
DTLocalUtil.evaluateCalOpsCalendar(List<CalendarOp> calendarOps,
Calendar cal,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected static LocalDateTime |
DTLocalUtil.evaluateCalOpsLDT(List<CalendarOp> calendarOps,
LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected static ZonedDateTime |
DTLocalUtil.evaluateCalOpsZDT(List<CalendarOp> calendarOps,
ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
static ExprDotDTMethodDesc |
ExprDotDTFactory.validateMake(StreamTypeService streamTypeService,
Deque<ExprChainedSpec> chainSpecStack,
DatetimeMethodEnum dtMethod,
String dtMethodName,
EPType inputType,
List<ExprNode> parameters,
ExprDotNodeFilterAnalyzerInput inputDesc,
TimeZone timeZone,
TimeAbacus timeAbacus,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
Boolean |
IntervalComputerForgeFactory.IntervalComputerConstantAfter.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerAfterWithDeltaExprEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerAfterNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerConstantBefore.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerBeforeWithDeltaExprEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerBeforeNoParamForge.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerConstantCoincides.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerCoincidesWithDeltaExprEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerCoincidesNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerDuringNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerIncludesNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerDuringAndIncludesThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerDuringAndIncludesMinMaxEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerDuringMinMaxStartEndEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerFinishesNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerFinishesThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerFinishedByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerFinishedByThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerMeetsNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerMeetsThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerMetByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerMetByThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerOverlapsNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerOverlapsAndByThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerOverlapsAndByMinMaxEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerOverlappedByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerStartsNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerStartsThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerStartedByNoParam.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerForgeFactory.IntervalComputerStartedByThresholdEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Boolean |
IntervalComputerEval.compute(long leftStart,
long leftEnd,
long rightStart,
long rightEnd,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
Object |
ExprEvaluatorStreamDTPropFragment.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprEvaluatorStreamDTProp.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
IntervalDeltaExprEvaluator.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprOptionalConstantForge.IntervalDeltaExprMaxEval.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprOptionalConstantEval.IntervalDeltaExprEvaluatorMax.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalOp.evaluate(long startTs,
long endTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeOp.evaluate(long startTs,
long endTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpEval.evaluate(long startTs,
long endTs,
Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpDateEval.evaluate(long startTs,
long endTs,
Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpEvalLong.evaluate(long startTs,
long endTs,
Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpCalEval.evaluate(long startTs,
long endTs,
Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpLocalDateTimeEval.evaluate(long startTs,
long endTs,
Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpZonedDateTimeEval.evaluate(long startTs,
long endTs,
Object parameter,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpEvalDateWithEndBase.evaluate(long startTs,
long endTs,
Object parameterStartTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
abstract Object |
IntervalForgeImpl.IntervalOpEvalDateWithEndBase.evaluate(long startTs,
long endTs,
Object parameterStartTs,
Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpDateWithEndEval.evaluate(long startTs,
long endTs,
Object parameterStartTs,
Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpLongWithEndEval.evaluate(long startTs,
long endTs,
Object parameterStartTs,
Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpCalWithEndEval.evaluate(long startTs,
long endTs,
Object parameterStartTs,
Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpLocalDateTimeWithEndEval.evaluate(long startTs,
long endTs,
Object parameterStartTs,
Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
IntervalForgeImpl.IntervalOpZonedDateTimeWithEndEval.evaluate(long startTs,
long endTs,
Object parameterStartTs,
Object parameterEndTs,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
long |
IntervalDeltaExprTimePeriodNonConstForge.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
IntervalDeltaExprTimePeriodConstForge.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
IntervalDeltaExprMSecConstForge.evaluate(long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ReformatToMillisecForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToCalendarForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatStringFormatForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatGetFieldForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatToDateForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatEvalForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenNonConstantParamsForgeOp.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenConstantParamsForge.evaluate(Calendar cal,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToMillisecForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToCalendarForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatStringFormatForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatOp.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatGetFieldForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatToDateForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatEvalForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenNonConstantParamsForgeOp.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenConstantParamsForge.evaluate(Date d,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToMillisecForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToCalendarForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatStringFormatForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatGetFieldForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatToDateForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatEvalForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenNonConstantParamsForgeOp.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenConstantParamsForge.evaluate(LocalDateTime ldt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToMillisecForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToCalendarForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatStringFormatForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatOp.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatGetFieldForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatToDateForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatEvalForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenNonConstantParamsForgeOp.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenConstantParamsForge.evaluate(Long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToMillisecForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatToCalendarForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatStringFormatForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatGetFieldForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatToDateForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatFormatForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatEvalForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenNonConstantParamsForgeOp.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenConstantParamsForge.evaluate(ZonedDateTime zdt,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ReformatBetweenNonConstantParamsForgeOp.evaluateInternal(long ts,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
ReformatForge |
ReformatForgeFactory.getForge(EPType inputType,
TimeZone timeZone,
TimeAbacus timeAbacus,
DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
EventTable[][] |
DatabasePollingViewable.poll(EventBean[][] lookupEventsPerStream,
PollResultIndexingStrategy indexingStrategy,
ExprEvaluatorContext exprEvaluatorContext) |
List<EventBean> |
PollExecStrategyDBQuery.poll(Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext) |
List<EventBean> |
PollExecStrategy.poll(Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext)
Poll events using the keys provided.
|
void |
DatabasePollingViewable.validate(EngineImportService engineImportService,
StreamTypeService streamTypeService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
String engineURI,
Map<Integer,List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprDeclaredForgeConstant.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprDeclaredForgeBase.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprDeclaredForgeBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprDeclaredForgeBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprDeclaredForgeBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[][] |
ExprDeclaredForgeBase.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprDeclaredForgeBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprDeclaredNodeImpl.getConstantValue(ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
static Collection<Object[]> |
ExprDotForgeUnpackCollEventBeanTable.convertToTableUnderling(Object target,
TableMetadataInternalEventToPublic eventToPublic,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Object |
PropertyDotNonLambdaMappedForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
PropertyDotNonLambdaIndexedForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
PropertyDotNonLambdaFragmentForge.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
PropertyDotNonLambdaForge.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprLambdaGoesNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeUnpackCollEventBeanTable.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeUnpackCollEventBean.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeUnpackBeanTable.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeUnpackBean.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeProperty.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeEnumMethodEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
PropertyDotScalarIterable.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context) |
EventBean |
PropertyDotScalarCollection.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context) |
EventBean |
PropertyDotScalarArrayForge.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context) |
EventBean |
PropertyDotEventSingleForge.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context) |
EventBean |
PropertyDotEventCollectionForge.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotScalarIterable.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotScalarCollection.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotScalarArrayForge.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotEventSingleForge.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotEventCollectionForge.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context) |
Collection |
PropertyDotScalarIterable.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context) |
Collection |
PropertyDotScalarCollection.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context) |
Collection |
PropertyDotScalarArrayForge.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context) |
Collection |
PropertyDotEventSingleForge.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context) |
Collection |
PropertyDotEventCollectionForge.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context) |
EventBean |
PropertyDotScalarIterable.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
PropertyDotScalarCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
PropertyDotScalarArrayForge.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
PropertyDotEventSingleForge.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
PropertyDotEventCollectionForge.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotScalarIterable.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotScalarCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotScalarArrayForge.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotEventSingleForge.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
PropertyDotEventCollectionForge.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
PropertyDotScalarIterable.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
PropertyDotScalarCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
PropertyDotScalarArrayForge.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
PropertyDotEventSingleForge.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
PropertyDotEventCollectionForge.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
EnumWhereScalarIndexForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumWhereScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumWhereIndexEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumWhereEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumUnionForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumToMapScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumToMapEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileLastScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileLastIndexScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileLastIndexEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileLastEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileIndexScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileIndexEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeWhileEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeLastForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumTakeForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumSumScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumSumScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumSumEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumSequenceEqualForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumSelectFromScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumSelectFromEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumReverseForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumOrderByAscDescScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumOrderByAscDescScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumOrderByAscDescEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMostLeastFrequentScalarLamdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMostLeastFrequentScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMostLeastFrequentEventForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMinMaxScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMinMaxScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMinMaxEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMinMaxByScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumMinMaxByEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumLastOfPredicateScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumLastOfPredicateEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumLastOfNoPredicateForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumIntersectForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumGroupByKeyValueSelectorScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumGroupByKeyValueSelectorEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumGroupByKeySelectorScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumGroupByKeySelectorEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumForgeNoOp.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumFirstOfPredicateScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumFirstOfPredicateEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumFirstOfNoPredicateForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumExceptForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumDistinctScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumDistinctScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumDistinctEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumCountOfSelectorScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumCountOfSelectorEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumCountOfForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAverageScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAverageScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAverageEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAverageBigDecimalScalarLambdaForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAverageBigDecimalScalarForge.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAverageBigDecimalEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAnyOfScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAnyOfEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAllOfScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAllOfEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAggregateScalarForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EnumAggregateEventsForgeEval.evaluateEnumMethod(EventBean[] eventsLambda,
Collection enumcoll,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
EventBean |
ExprPlugInAggMultiFunctionNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprAggMultiFunctionSortedMinMaxByNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprAggMultiFunctionLinearAccessNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprAggCountMinSketchNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprPlugInAggMultiFunctionNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprAggMultiFunctionSortedMinMaxByNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprAggMultiFunctionLinearAccessNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprAggCountMinSketchNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprPlugInAggMultiFunctionNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprAggMultiFunctionSortedMinMaxByNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprAggMultiFunctionLinearAccessNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprAggCountMinSketchNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprAggregateNodeGroupKey.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprAggregateNodeBase.evaluate(EventBean[] events,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Class and Description |
|---|---|
class |
ExprEvaluatorContextTimeOnly
Represents a minimal engine-level context for expression evaluation, not allowing for agents instances and result cache.
|
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
ExprValidationContext.getExprEvaluatorContext() |
| Modifier and Type | Method and Description |
|---|---|
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(Iterator<EventBean> iterator,
ExprEvaluator filterExpression,
ExprEvaluatorContext exprEvaluatorContext,
Collection<EventBean> eventsInWindow) |
static void |
ExprNodeUtility.applyFilterExpressionsIterable(Iterable<EventBean> iterable,
List<ExprNode> filterExpressions,
ExprEvaluatorContext exprEvaluatorContext,
Collection<EventBean> eventsInWindow) |
static ScheduleSpec |
ExprNodeUtility.crontabScheduleBuild(ExprEvaluator[] scheduleSpecEvaluators,
ExprEvaluatorContext context) |
Object |
ExprWildcardImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprVariableNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTypedNoEvalNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprSubstitutionNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprStreamUnderlyingNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprOrderedExpr.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNumberSetRange.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNumberSetList.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNumberSetFrequency.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNumberSetCronParam.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNodeValidated.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNodeUtilUnderlyingEvaluatorTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilUnderlyingEvaluator.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilExprStreamNumUnd.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilExprStreamNumEventTable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilExprStreamNumEvent.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilExprStreamNumEnumSingleEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilExprStreamNumEnumCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeUtilExprMethodContext.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNamedParameterNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprIdentNodeEvaluatorLogging.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprIdentNodeEvaluatorImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprIdentNodeEvaluatorContext.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprGroupingNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprGroupingIdNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprEvaluator.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
Evaluate event tuple and return result.
|
Object |
ExprCurrentEvaluationContextNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprContextPropertyNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprConstantNodeImpl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
static EventBean |
ExprNodeUtilExprStreamNumEventTable.evaluateConvertTableEvent(int streamNum,
TableMetadataInternalEventToPublic eventToPublic,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
EventBean |
ExprEnumerationGivenEvent.evaluateEventGetEventBean(EventBean event,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprEnumerationGivenEvent.evaluateEventGetROCollectionEvents(EventBean event,
ExprEvaluatorContext context) |
Collection |
ExprEnumerationGivenEvent.evaluateEventGetROCollectionScalar(EventBean event,
ExprEvaluatorContext context) |
static Object[] |
ExprNodeUtility.evaluateExpressions(ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprEnumerationEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprEnumerationEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprEnumerationEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[][] |
ExprTypableReturnEval.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTypableReturnEval.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
static Object |
ExprNodeUtility.evaluateValidationTimeNoStreams(ExprEvaluator evaluator,
ExprEvaluatorContext context,
String expressionName) |
static EPLExpressionEvaluationContext |
ExprCurrentEvaluationContextNode.exprCurrentEvaluationContextMake(ExprEvaluatorContext exprEvaluatorContext)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
Object |
ExprVariableNodeImpl.getConstantValue(ExprEvaluatorContext context) |
Object |
ExprConstantNodeImpl.getConstantValue(ExprEvaluatorContext context)
Returns the constant's value.
|
Object |
ExprConstantNode.getConstantValue(ExprEvaluatorContext context) |
| Constructor and Description |
|---|
ExprValidationContext(StreamTypeService streamTypeService,
EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ViewResourceDelegateUnverified viewResourceDelegate,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
EventAdapterService eventAdapterService,
String statementName,
int statementId,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
boolean disablePropertyExpressionEventCollCache,
boolean allowRollupFunctions,
boolean allowBindingConsumption,
boolean isUnidirectionalJoin,
String intoTableName,
boolean isFilterExpression) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprDotNodeForgeVariableEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotNodeForgeTransposeAsStreamEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprDotNodeForgeStreamEvalMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotNodeForgeStreamEvalEventBean.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotNodeForgeStaticMethodEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotNodeForgeRootChildEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprDotNodeForgePropertyExprEvalMapped.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprDotNodeForgePropertyExprEvalIndexed.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprDotEvalRootChildInnerEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotMethodForgeNoDuckEvalWrapArray.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotMethodForgeNoDuckEvalUnderlying.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotMethodForgeNoDuckEvalPlain.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotMethodForgeDuckEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeArraySize.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotForgeArrayGetEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprDotEval.evaluate(Object target,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
static Object |
ExprDotNodeUtility.evaluateChain(ExprDotForge[] forges,
ExprDotEval[] evaluators,
Object inner,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
static Object |
ExprDotNodeUtility.evaluateChainWithWrap(ExprDotStaticMethodWrap resultWrapLambda,
Object result,
EventType optionalResultSingleEventType,
Class resultType,
ExprDotEval[] chainEval,
ExprDotForge[] chainForges,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprDotNodeForgeRootChildEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprDotEvalRootChildInnerEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprDotNodeForgeRootChildEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprDotEvalRootChildInnerEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprDotNodeForgeRootChildEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprDotEvalRootChildInnerEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
InnerEvaluatorScalarUnpackEvent.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerEvaluatorScalar.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerEvaluatorEnumerableScalarCollection.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerEvaluatorEnumerableEventCollection.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerEvaluatorEnumerableEventBean.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
InnerEvaluatorColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerEvaluatorArrPrimitiveToColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerEvaluatorArrObjectToColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotScalarUnpackEventEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotScalarEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotEnumerableScalarCollectionEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotEnumerableEventCollectionEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotEnumerableEventBeanEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
InnerDotCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotArrPrimitiveToCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InnerDotArrObjectToCollEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
InnerEvaluatorScalarUnpackEvent.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorScalar.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorEnumerableScalarCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorEnumerableEventCollection.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorEnumerableEventBean.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorColl.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorArrPrimitiveToColl.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerEvaluatorArrObjectToColl.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotScalarUnpackEventEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotScalarEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotEnumerableScalarCollectionEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotEnumerableEventCollectionEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotEnumerableEventBeanEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotCollEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotArrPrimitiveToCollEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
InnerDotArrObjectToCollEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorScalarUnpackEvent.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorScalar.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorEnumerableScalarCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorEnumerableEventCollection.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorEnumerableEventBean.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorColl.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorArrPrimitiveToColl.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerEvaluatorArrObjectToColl.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotScalarUnpackEventEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotScalarEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotEnumerableScalarCollectionEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotEnumerableEventCollectionEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotEnumerableEventBeanEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotCollEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotArrPrimitiveToCollEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
InnerDotArrObjectToCollEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorScalarUnpackEvent.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorScalar.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorEnumerableScalarCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorEnumerableEventCollection.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorEnumerableEventBean.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorColl.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorArrPrimitiveToColl.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerEvaluatorArrObjectToColl.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotScalarUnpackEventEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotScalarEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotEnumerableScalarCollectionEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotEnumerableEventCollectionEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotEnumerableEventBeanEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotCollEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotArrPrimitiveToCollEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
InnerDotArrObjectToCollEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprCastNode.CasterParserComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext)
Compute an result performing casting and parsing.
|
Object |
ExprCastNode.StringXFormComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.NumberCasterComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringParserComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.NonnumericCasterComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToDateWStaticFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToJava8WStaticFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToLocalDateTimeWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
LocalDate |
ExprCastNode.StringToLocalDateWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
LocalTime |
ExprCastNode.StringToLocalTimeWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
ZonedDateTime |
ExprCastNode.StringToZonedDateTimeWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToDateWStaticISOFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToLongWStaticFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToLongWStaticISOFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToCalendarWStaticFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNode.StringToCalendarWStaticISOFormatComputer.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Date |
ExprCastNode.StringToDateWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Long |
ExprCastNode.StringToLongWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Calendar |
ExprCastNode.StringToCalendarWDynamicFormatComputerEval.compute(Object input,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTypeofNodeForgeStreamEvent.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTypeofNodeForgeFragmentType.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTypeofNode.StreamEventTypeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTypeofNode.FragmentTypeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprPropertyExistsNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPlugInSingleRowNodeForgeConst.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprMinMaxRowNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprIStreamNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprInstanceofNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCoalesceNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCastNodeNonConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprCastNodeForgeNonConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprCastNodeForgeConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprCastNodeConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprCaseNodeForgeEvalTypable.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprCaseNodeForgeEvalSyntax2.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprCaseNodeForgeEvalSyntax1.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object[][] |
ExprCaseNodeForgeEvalTypable.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprCaseNodeForgeEvalTypable.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprRelationalOpNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprRelationalOpAllAnyNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprRegexpNodeForgeNonconstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprRegexpNodeForgeConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprOrNodeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNotNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNewStructNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNewInstanceNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprMathNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprLikeNodeFormNonconstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprLikeNodeForgeConstEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprInNodeForgeEvalWColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprInNodeForgeEvalNoColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprEqualsNodeForgeNCEvalIs.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprEqualsNodeForgeNCEvalEquals.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprEqualsNodeForgeCoercionEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprEqualsAllAnyNodeForgeEvalAnyWColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprEqualsAllAnyNodeForgeEvalAnyNoColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprEqualsAllAnyNodeForgeEvalAllWColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprEqualsAllAnyNodeForgeEvalAllNoColl.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprConcatNodeForgeEvalWNew.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprConcatNodeForgeEvalThreadLocal.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprConcatNodeEvalWNew.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprConcatNodeEvalThreadLocal.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprBitWiseNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprBetweenNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprArrayNodeForgeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprAndNodeEval.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected static String |
ExprConcatNodeEvalWNew.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context,
StringBuffer buffer,
ExprEvaluator[] evaluators,
ExprConcatNode parent) |
protected static String |
ExprConcatNodeForgeEvalWNew.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context,
StringBuffer buffer,
ExprEvaluator[] evaluators,
ExprConcatNodeForge form) |
EventBean |
ExprArrayNodeForgeEval.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprArrayNodeForgeEval.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprArrayNodeForgeEval.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[][] |
ExprNewStructNodeForgeEval.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[][] |
ExprNewStructNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprNewStructNodeForgeEval.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprPreviousNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPreviousMatchRecognizeNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPreviousMatchRecognizeEvalStrategy.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPreviousEvalStrategyWindow.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPreviousEvalStrategyPrev.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPreviousEvalStrategyCount.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPreviousEvalStrategy.evaluate(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
ExprPreviousEvalStrategyWindow.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprPreviousEvalStrategyPrev.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprPreviousEvalStrategyCount.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprPreviousEvalStrategy.evaluateGetCollEvents(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
ExprPreviousEvalStrategyWindow.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
ExprPreviousEvalStrategyPrev.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
ExprPreviousEvalStrategyCount.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection |
ExprPreviousEvalStrategy.evaluateGetCollScalar(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
ExprPreviousNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprPreviousEvalStrategyWindow.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
ExprPreviousEvalStrategyPrev.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
ExprPreviousEvalStrategyCount.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean |
ExprPreviousEvalStrategy.evaluateGetEventBean(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprPreviousNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprPreviousNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprPriorNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprPriorEvalStrategyBase.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber) |
Object |
ExprPriorEvalStrategy.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext,
int streamNumber,
ExprEvaluator evaluator,
int constantIndexNumber) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprSubselectRowNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
abstract Object |
ExprSubselectNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate the lookup expression returning an evaluation result object.
|
Object |
ExprSubselectInNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprSubselectExistsNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprSubselectAllSomeAnyNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
SubselectEvalStrategyNRExistsWGroupByWHaving.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationServiceAnyPartition) |
Object |
SubselectEvalStrategyNRExistsWGroupBy.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
Object |
SubselectEvalStrategyNRExistsDefault.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
Object |
SubselectEvalStrategyNRExistsAlwaysTrue.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
Object |
SubselectEvalStrategyNRExistsAggregated.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
Object |
SubselectEvalStrategyNRBase.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
Object |
SubselectEvalStrategyNR.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService)
Evaluate.
|
Object |
SubselectEvalStrategyRowUnfilteredUnselectedTable.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowUnfilteredUnselected.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowUnfilteredSelectedGroupedWHaving.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowUnfilteredSelectedGroupedNoHaving.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowUnfilteredSelected.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowHavingSelected.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowFilteredUnselectedTable.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowFilteredUnselected.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRowFilteredSelected.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object |
SubselectEvalStrategyRow.evaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode exprSubselectRowNode) |
Object |
ExprSubselectNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
static EventBean |
ExprSubselectRowNodeUtility.evaluateFilterExpectSingleMatch(EventBean[] eventsZeroSubselect,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Collection<EventBean> |
ExprSubselectRowNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context) |
abstract Collection<EventBean> |
ExprSubselectNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
ExprSubselectInNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprSubselectExistsNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprSubselectAllSomeAnyNode.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubselectEvalStrategyRowUnfilteredUnselected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRowUnfilteredSelectedGroupedWHaving.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRowUnfilteredSelectedGroupedNoHaving.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRowUnfilteredSelected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRowHavingSelected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRowFilteredUnselected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRowFilteredSelected.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection<EventBean> |
SubselectEvalStrategyRow.evaluateGetCollEvents(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
ExprSubselectRowNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context) |
abstract Collection |
ExprSubselectNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Collection |
ExprSubselectInNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Collection |
ExprSubselectExistsNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Collection |
ExprSubselectAllSomeAnyNode.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Collection |
SubselectEvalStrategyRowUnfilteredUnselected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRowUnfilteredSelectedGroupedWHaving.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRowUnfilteredSelectedGroupedNoHaving.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRowUnfilteredSelected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRowHavingSelected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRowFilteredUnselected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRowFilteredSelected.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
Collection |
SubselectEvalStrategyRow.evaluateGetCollScalar(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
ExprSubselectRowNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
abstract EventBean |
ExprSubselectNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprSubselectInNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprSubselectExistsNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprSubselectAllSomeAnyNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
SubselectEvalStrategyRowUnfilteredUnselected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRowUnfilteredSelectedGroupedWHaving.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRowUnfilteredSelectedGroupedNoHaving.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRowUnfilteredSelected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRowHavingSelected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRowFilteredUnselected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRowFilteredSelected.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext context,
ExprSubselectRowNode parent) |
EventBean |
SubselectEvalStrategyRow.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode exprSubselectRowNode) |
EventBean |
ExprSubselectNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprSubselectInNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprSubselectExistsNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprSubselectAllSomeAnyNode.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprSubselectNode.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection |
ExprSubselectNode.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected Object |
SubselectEvalStrategyNRRelOpAnyWGroupBy.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationServiceAnyPartition) |
protected Object |
SubselectEvalStrategyNRRelOpAnyDefault.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNRRelOpAllWGroupBy.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationServiceAnyPartition) |
protected Object |
SubselectEvalStrategyNRRelOpAllDefault.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNRRelOpAllAnyAggregated.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNREqualsInWGroupBy.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationServiceAnyPartition) |
protected Object |
SubselectEvalStrategyNREqualsInUnfiltered.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNREqualsInFiltered.evaluateInternal(Object leftResult,
EventBean[] eventsZeroOffset,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNREqualsInAggregated.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNREqualsAnyWGroupBy.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationServiceAnyPartition) |
protected Object |
SubselectEvalStrategyNREqualsAnyDefault.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNREqualsAllWGroupBy.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationServiceAnyPartition) |
protected Object |
SubselectEvalStrategyNREqualsAllDefault.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected Object |
SubselectEvalStrategyNREqualsAllAnyAggregated.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
protected abstract Object |
SubselectEvalStrategyNRBase.evaluateInternal(Object leftResult,
EventBean[] events,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
AggregationService aggregationService) |
Collection<EventBean> |
ExprSubselectStrategy.evaluateMatching(EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
protected Map<String,Object> |
ExprSubselectRowNode.evaluateRow(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[][] |
ExprSubselectRowNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
abstract Object[][] |
ExprSubselectNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[][] |
ExprSubselectInNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[][] |
ExprSubselectExistsNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[][] |
ExprSubselectAllSomeAnyNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[][] |
ExprSubselectNode.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprSubselectRowNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
abstract Object[] |
ExprSubselectNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
ExprSubselectInNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
ExprSubselectExistsNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
ExprSubselectAllSomeAnyNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object[] |
ExprSubselectNode.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
SubselectEvalStrategyRowUnfilteredUnselected.typableEvaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[] |
SubselectEvalStrategyRowUnfilteredSelected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[] |
SubselectEvalStrategyRowHavingSelected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[] |
SubselectEvalStrategyRowFilteredUnselected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[] |
SubselectEvalStrategyRowFilteredSelected.typableEvaluate(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[] |
SubselectEvalStrategyRow.typableEvaluate(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[][] |
SubselectEvalStrategyRowUnfilteredUnselected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[][] |
SubselectEvalStrategyRowUnfilteredSelected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean isNewData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[][] |
SubselectEvalStrategyRowHavingSelected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[][] |
SubselectEvalStrategyRowFilteredUnselected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[][] |
SubselectEvalStrategyRowFilteredSelected.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
Object[][] |
SubselectEvalStrategyRow.typableEvaluateMultirow(EventBean[] eventsPerStream,
boolean newData,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext,
ExprSubselectRowNode parent) |
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprTableIdentNodeSubpropAccessor.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableAccessNodeTopLevel.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableAccessNodeSubpropAccessor.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableAccessNodeSubprop.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableAccessNodeKeys.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableAccessEvalStrategy.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprTableIdentNodeSubpropAccessor.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableAccessNodeSubpropAccessor.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableAccessNodeSubprop.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableAccessEvalStrategy.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableIdentNodeSubpropAccessor.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableAccessNodeSubpropAccessor.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableAccessNodeSubprop.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableAccessEvalStrategy.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableIdentNodeSubpropAccessor.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableAccessNodeSubpropAccessor.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableAccessNodeSubprop.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableAccessEvalStrategy.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[][] |
ExprTableAccessNodeTopLevel.evaluateTypableMulti(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableAccessNodeTopLevel.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableAccessEvalStrategy.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
ExprTimePeriodEvalDeltaConst |
ExprTimePeriodImpl.constEvaluator(ExprEvaluatorContext context) |
ExprTimePeriodEvalDeltaConst |
ExprTimePeriodForge.constEvaluator(ExprEvaluatorContext context) |
ExprTimePeriodEvalDeltaConst |
ExprTimePeriod.constEvaluator(ExprEvaluatorContext context) |
long |
ExprTimePeriodEvalDeltaNonConstMsec.deltaAdd(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprTimePeriodEvalDeltaNonConstCalAdd.deltaAdd(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprTimePeriodEvalDeltaNonConst.deltaAdd(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ExprTimePeriodEvalDeltaResult |
ExprTimePeriodEvalDeltaNonConstMsec.deltaAddWReference(long current,
long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ExprTimePeriodEvalDeltaResult |
ExprTimePeriodEvalDeltaNonConstCalAdd.deltaAddWReference(long current,
long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ExprTimePeriodEvalDeltaResult |
ExprTimePeriodEvalDeltaNonConst.deltaAddWReference(long current,
long reference,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprTimePeriodEvalDeltaNonConstMsec.deltaSubtract(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprTimePeriodEvalDeltaNonConstCalAdd.deltaSubtract(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
long |
ExprTimePeriodEvalDeltaNonConst.deltaSubtract(long currentTime,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTimestampNode.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
long |
ExprTimePeriodEvalMillis.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
double |
ExprTimePeriodImpl.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
double |
ExprTimePeriodForge.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
double |
ExprTimePeriod.evaluateAsSeconds(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
TimePeriod |
ExprTimePeriodImpl.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
TimePeriod |
ExprTimePeriodForge.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
TimePeriod |
ExprTimePeriod.evaluateGetTimePeriod(EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
void |
EventTableQuadTreePointRegionImpl.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreeMXCIFImpl.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreePointRegionImpl.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreeMXCIFImpl.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreePointRegionImpl.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreeMXCIFImpl.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
AdvancedIndexConfigContextPartition |
EventAdvancedIndexFactoryQuadTree.configureContextPartition(EventType eventType,
AdvancedIndexDesc indexDesc,
ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext,
EventTableOrganization organization,
EventAdvancedIndexConfigStatement advancedIndexConfigStatement) |
protected static AdvancedIndexConfigContextPartition |
AdvancedIndexFactoryProviderQuadTree.configureQuadTree(String indexName,
ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.RectangleIntersectsRectangleEvaluator.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
EngineImportApplicationDotMethodPointInsideRectange.PointIntersectsRectangleEvaluator.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordTableLookupStrategyQuadTreeSubq.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordTableLookupStrategyQuadTreeNW.lookup(EventBean[] events,
ExprEvaluatorContext context) |
protected Collection<EventBean> |
SubordTableLookupStrategyQuadTreeBase.lookupInternal(EventBean[] events,
ExprEvaluatorContext context) |
void |
EventTableQuadTreePointRegionImpl.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreeMXCIFImpl.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreePointRegionImpl.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTableQuadTreeMXCIFImpl.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
static double |
AdvancedIndexEvaluationHelper.evalDoubleColumn(ExprEvaluator col,
String indexName,
String colName,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext exprEvaluatorContext) |
static double |
AdvancedIndexEvaluationHelper.evalDoubleParameter(ExprEvaluator param,
String indexName,
String parameterName,
ExprEvaluatorContext exprEvaluatorContext) |
static int |
AdvancedIndexEvaluationHelper.evalIntParameter(ExprEvaluator param,
String indexName,
String parameterName,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
EventTableFactoryCustomIndex.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
protected static void |
JoinSetFilter.filter(ExprEvaluator filterExprNode,
Set<MultiKey<EventBean>> events,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Filter event by applying the filter nodes evaluation method.
|
void |
JoinSetComposerStreamToWinImpl.init(EventBean[][] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetComposerImpl.init(EventBean[][] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetComposerHistoricalImpl.init(EventBean[][] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetComposerFAFImpl.init(EventBean[][] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetComposerAllUnidirectionalOuter.init(EventBean[][] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinSetComposer.init(EventBean[][] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext)
Provides initialization events per stream to composer to populate join indexes, if required
|
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerStreamToWinImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerHistoricalImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerFAFImpl.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<Set<MultiKey<EventBean>>> |
JoinSetComposerAllUnidirectionalOuter.join(EventBean[][] newDataPerStream,
EventBean[][] oldDataPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
UniformPair<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,
Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext)
Look up events returning tuples of joined events.
|
void |
HistoricalDataQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext) |
void |
ExecNodeQueryStrategy.lookup(EventBean[] lookupEvents,
Set<MultiKey<EventBean>> joinSet,
ExprEvaluatorContext exprEvaluatorContext) |
Iterator<EventBean> |
HistoricalIndexLookupStrategySorted.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext context) |
Iterator<EventBean> |
HistoricalIndexLookupStrategyNoIndex.lookup(EventBean lookupEvent,
EventTable[] index,
ExprEvaluatorContext context) |
Iterator<EventBean> |
HistoricalIndexLookupStrategyInKeywordSingle.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext) |
Iterator<EventBean> |
HistoricalIndexLookupStrategyInKeywordMulti.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext) |
Iterator<EventBean> |
HistoricalIndexLookupStrategyIndexSingle.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext) |
Iterator<EventBean> |
HistoricalIndexLookupStrategyIndex.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext exprEvaluatorContext) |
Iterator<EventBean> |
HistoricalIndexLookupStrategyComposite.lookup(EventBean lookupEvent,
EventTable[] indexTable,
ExprEvaluatorContext context) |
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(String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean queryPlanLogging,
StatementContext statementContext,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
boolean selectsRemoveStream,
boolean hasAggregations,
TableService tableService,
boolean isOnDemandQuery,
boolean allowIndexInit) |
void |
JoinPreloadMethodNull.preloadFromBuffer(int stream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinPreloadMethodImpl.preloadFromBuffer(int stream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
JoinPreloadMethod.preloadFromBuffer(int stream,
ExprEvaluatorContext exprEvaluatorContext)
Initialize a stream from the stream buffers data.
|
void |
JoinSetProcessor.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
Process join result set.
|
void |
JoinSetFilter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext) |
| Constructor and Description |
|---|
JoinExecutionStrategyImpl(JoinSetComposer composer,
JoinSetProcessor filter,
JoinSetProcessor indicator,
ExprEvaluatorContext staticExprEvaluatorContext)
Ctor.
|
JoinSetComposerFAFImpl(Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
boolean isPureSelfJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean joinRemoveStream,
boolean outerJoins) |
JoinSetComposerHistoricalImpl(boolean allowInitIndex,
Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
Viewable[] streamViews,
ExprEvaluatorContext staticEvalExprEvaluatorContext) |
JoinSetComposerImpl(boolean allowInitIndex,
Map<TableLookupIndexReqKey,EventTable>[] repositories,
QueryStrategy[] queryStrategies,
boolean isPureSelfJoin,
ExprEvaluatorContext exprEvaluatorContext,
boolean joinRemoveStream) |
JoinSetComposerPrototypeHistorical2StreamImpl(ExprEvaluator optionalFilterEval,
EventType[] streamTypes,
ExprEvaluatorContext exprEvaluatorContext,
int polledViewNum,
int streamViewNum,
boolean outerJoin,
ExprEvaluator outerJoinEqualsEval,
Pair<HistoricalIndexLookupStrategy,PollResultIndexingStrategy> indexStrategies,
boolean allHistoricalNoSubordinate,
OuterJoinDesc[] outerJoinDescList,
boolean allowIndexInit) |
JoinSetComposerPrototypeImpl(String statementName,
int statementId,
OuterJoinDesc[] outerJoinDescList,
ExprNode optionalFilterNode,
EventType[] streamTypes,
String[] streamNames,
StreamJoinAnalysisResult streamJoinAnalysisResult,
Annotation[] annotations,
HistoricalViewableDesc historicalViewableDesc,
ExprEvaluatorContext exprEvaluatorContext,
QueryPlanIndex[] indexSpecs,
QueryPlan queryPlan,
HistoricalStreamIndexList[] historicalStreamIndexLists,
boolean joinRemoveStream,
boolean isOuterJoins,
TableService tableService,
EventTableIndexService eventTableIndexService,
EngineImportService engineImportService,
boolean isFireAndForget) |
| Modifier and Type | Method and Description |
|---|---|
Set<EventBean> |
SortedTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
JoinExecTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext)
Returns matched events for a event to look up for.
|
Set<EventBean> |
InKeywordSingleTableLookupStrategyExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
InKeywordMultiTableLookupStrategyExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
IndexedTableLookupStrategySingleExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
IndexedTableLookupStrategySingle.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
IndexedTableLookupStrategyExpr.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
IndexedTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
HistoricalTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
FullTableScanUniqueValueLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
FullTableScanLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext exprEvaluatorContext) |
Set<EventBean> |
CompositeTableLookupStrategy.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext context) |
void |
TableOuterLookupExecNodeTableLocking.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableOuterLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableLookupExecNodeTableLocking.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableLookupExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
NestedIterationExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
LookupInstructionExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> resultFinalRows,
ExprEvaluatorContext exprEvaluatorContext) |
void |
HistoricalDataExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
ExecNodeNoOp.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
void |
ExecNodeAllUnidirectionalOuter.process(EventBean lookupEvent,
EventBean[] prefillPath,
Collection<EventBean[]> result,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
ExecNode.process(EventBean lookupEvent,
EventBean[] prefillPath,
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,
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.
|
| Modifier and Type | Method and Description |
|---|---|
protected static QueryPlan |
NStreamOuterQueryPlanBuilder.build(QueryGraph queryGraph,
OuterJoinDesc[] outerJoinDescList,
String[] streamNames,
EventType[] typesPerStream,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
ExprEvaluatorContext exprEvaluatorContext,
String[][][] indexedStreamsUniqueProps,
TableMetadata[] tablesPerStream,
EngineImportService engineImportService,
boolean isFireAndForget)
Build a query plan based on the stream property relationships indicated in queryGraph.
|
static QueryPlan |
QueryPlanBuilder.getPlan(EventType[] typesPerStream,
OuterJoinDesc[] outerJoinDescList,
QueryGraph queryGraph,
String[] streamNames,
HistoricalViewableDesc historicalViewableDesc,
DependencyGraph dependencyGraph,
HistoricalStreamIndexList[] historicalStreamIndexLists,
StreamJoinAnalysisResult streamJoinAnalysisResult,
boolean isQueryPlanLogging,
Annotation[] annotations,
ExprEvaluatorContext exprEvaluatorContext,
EngineImportService engineImportService,
boolean isFireAndForget)
Build query plan using the filter.
|
static Set<EventBean> |
InKeywordTableLookupUtil.multiIndexLookup(ExprEvaluator evaluator,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
EventTable[] indexes) |
static Set<EventBean> |
InKeywordTableLookupUtil.singleIndexLookup(ExprEvaluator[] evaluators,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext,
PropertyIndexedEventTableSingle index) |
| Modifier and Type | Method and Description |
|---|---|
void |
UnindexedEventTableList.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
UnindexedEventTableImpl.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SingleReferenceEventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertySortedEventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Add an array of events.
|
void |
PropertyIndexedEventTableSingle.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Add an array of events.
|
void |
PropertyIndexedEventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Add an array of events.
|
void |
PropertyCompositeEventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Add an array of events.
|
void |
MultiIndexEventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Add events to table.
|
void |
UnindexedEventTableList.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
UnindexedEventTableImpl.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SingleReferenceEventTable.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertySortedEventTableImpl.add(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableUnique.add(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableUnadorned.add(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableSingleUnique.add(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableSingleUnadorned.add(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyCompositeEventTableImpl.add(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
MultiIndexEventTable.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTable.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext)
Add event to table.
|
void |
UnindexedEventTableList.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
UnindexedEventTableImpl.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SingleReferenceEventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertySortedEventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableUnique.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext)
Remove then add events.
|
void |
PropertyIndexedEventTableSingleUnique.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext)
Remove then add events.
|
void |
PropertyIndexedEventTableSingle.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyCompositeEventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
MultiIndexEventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext)
Add and remove events from table.
|
EventTable[] |
UnindexedEventTableFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertySortedEventTableFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertySortedEventTableCoercedFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableSingleFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableSingleCoerceAllFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableSingleCoerceAddFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableSingleArrayFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableCoerceAllFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyIndexedEventTableCoerceAddFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
PropertyCompositeEventTableFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
EventTable[] |
EventTableFactory.makeEventTables(EventTableFactoryTableIdent tableIdent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
UnindexedEventTableList.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
UnindexedEventTableImpl.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SingleReferenceEventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertySortedEventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Remove events.
|
void |
PropertyIndexedEventTableSingle.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Remove events.
|
void |
PropertyIndexedEventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Remove events.
|
void |
PropertyCompositeEventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Remove events.
|
void |
MultiIndexEventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext)
Remove events from table.
|
void |
UnindexedEventTableList.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
UnindexedEventTableImpl.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SingleReferenceEventTable.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertySortedEventTableImpl.remove(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableUnique.remove(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableUnadorned.remove(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableSingleUnique.remove(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyIndexedEventTableSingleUnadorned.remove(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
PropertyCompositeEventTableImpl.remove(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
void |
MultiIndexEventTable.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
EventTable.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext)
Remove event from table.
|
| Modifier and Type | Method and Description |
|---|---|
AdvancedIndexConfigContextPartition |
EventAdvancedIndexFactory.configureContextPartition(EventType eventType,
AdvancedIndexDesc indexDesc,
ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext,
EventTableOrganization organization,
EventAdvancedIndexConfigStatement advancedIndexConfigStatement) |
protected Object |
SubordIndexedTableLookupStrategySingleExprNW.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys.
|
protected Object |
SubordIndexedTableLookupStrategySingleExpr.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys.
|
protected Object |
SubordIndexedTableLookupStrategySingleCoercingNW.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
protected Object |
SubordIndexedTableLookupStrategySingleCoercing.getKey(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
protected Object[] |
SubordIndexedTableLookupStrategyExprNW.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys.
|
protected Object[] |
SubordIndexedTableLookupStrategyExpr.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context)
Get the index lookup keys.
|
protected Object[] |
SubordIndexedTableLookupStrategyCoercingNW.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
protected Object[] |
SubordIndexedTableLookupStrategyCoercing.getKeys(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
EventBean[] |
SubordWMatchExprLookupStrategyIndexedUnfiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
SubordWMatchExprLookupStrategyIndexedFiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
SubordWMatchExprLookupStrategyAllUnfiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
SubordWMatchExprLookupStrategyAllFiltered.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean[] |
SubordWMatchExprLookupStrategy.lookup(EventBean[] newData,
ExprEvaluatorContext exprEvaluatorContext)
Determines the events.
|
Set<EventBean> |
SubordTableLookupStrategyNullRow.lookup(EventBean[] events,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordTableLookupStrategy.lookup(EventBean[] events,
ExprEvaluatorContext context)
Returns matched events for a set of events to look up for.
|
Collection<EventBean> |
SubordSortedTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordInKeywordSingleTableLookupStrategyNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordInKeywordSingleTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordInKeywordMultiTableLookupStrategyNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordInKeywordMultiTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupTableStrategy.lookup(EventBean[] events,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategySinglePropUnique.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategySingleProp.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategySingleExprNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategySingleExpr.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategyProp.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategyLocking.lookup(EventBean[] events,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategyExprNW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordIndexedTableLookupStrategyExpr.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordFullTableScanTableLookupStrategy.lookup(EventBean[] events,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordFullTableScanLookupStrategyLocking.lookup(EventBean[] events,
ExprEvaluatorContext context) |
Set<EventBean> |
SubordFullTableScanLookupStrategy.lookup(EventBean[] eventPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
SubordCompositeTableLookupStrategy.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
NamedWindowOnExprBaseView.getExprEvaluatorContext()
returns expr context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NamedWindowOnMergeMatch.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext context) |
void |
NamedWindowOnMergeActionUpd.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
NamedWindowOnMergeActionIns.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext) |
void |
NamedWindowOnMergeActionDel.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
NamedWindowOnMergeAction.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
OneEventCollection newData,
OneEventCollection oldData,
ExprEvaluatorContext exprEvaluatorContext) |
boolean |
NamedWindowOnMergeMatch.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
boolean |
NamedWindowOnMergeAction.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Collection<EventBean> |
NamedWindowTailViewInstance.snapshotNoLockWithFilter(QueryGraph queryGraph,
Annotation[] annotations,
ExprNode filterExpr,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
static OutputLimitSpec |
ASTOutputLimitHelper.buildOutputLimitSpec(org.antlr.v4.runtime.CommonTokenStream tokenStream,
EsperEPL2GrammarParser.OutputLimitContext ctx,
Map<org.antlr.v4.runtime.tree.Tree,ExprNode> astExprNodeMap,
VariableService variableService,
String engineURI,
TimeProvider timeProvider,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
ArrayDeque<EventBean[]> |
PropertyEvaluatorAccumulative.getAccumulative(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Returns the accumulative events for the input event.
|
Object |
ContainedEventEvalGetter.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ContainedEventEvalExprNode.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ContainedEventEvalEventBeanArray.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ContainedEventEvalArrayToEvent.getFragment(EventBean eventBean,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
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.
|
| Modifier and Type | Method and Description |
|---|---|
Object |
ExprNodeScriptEvalMVEL.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeScriptEvalJSR223.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprNodeScriptEvaluator.evaluate(Object[] lookupValues,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprNodeScriptEvalMVEL.evaluate(Object[] lookupValues,
ExprEvaluatorContext context) |
Object |
ExprNodeScriptEvalJSR223.evaluate(Object[] lookupValues,
ExprEvaluatorContext context) |
EventBean |
ExprNodeScriptEvalBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprNodeScriptEvalBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprNodeScriptEvalBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Bindings |
ExprNodeScriptEvalJSR223.getBindings(ExprEvaluatorContext context)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
static Map<String,Object> |
ExprNodeScriptEvalMVEL.getMVELScriptParamsList(ExprEvaluatorContext context)
NOTE: Code-generation-invoked method, method name and parameter order matters
|
| Modifier and Type | Method and Description |
|---|---|
ExprNode |
OuterJoinDesc.makeExprNode(ExprEvaluatorContext exprEvaluatorContext)
Make an expression node that represents the outer join criteria as specified in the on-clause.
|
| Modifier and Type | Field and Description |
|---|---|
protected ExprEvaluatorContext |
SubselectAggregatorViewBase.exprEvaluatorContext |
| Modifier and Type | Method and Description |
|---|---|
void |
SubselectAggregationPreprocessorUnfilteredUngrouped.evaluate(EventBean[] eventsPerStream,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SubselectAggregationPreprocessorUnfilteredGrouped.evaluate(EventBean[] eventsPerStream,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SubselectAggregationPreprocessorFilteredUngrouped.evaluate(EventBean[] eventsPerStream,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
void |
SubselectAggregationPreprocessorFilteredGrouped.evaluate(EventBean[] eventsPerStream,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
SubselectAggregationPreprocessorBase.evaluate(EventBean[] eventsPerStream,
Collection<EventBean> matchingEvents,
ExprEvaluatorContext exprEvaluatorContext) |
protected Object |
SubselectAggregationPreprocessorBase.generateGroupKey(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
TableOnMergeMatch.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance stateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext context) |
void |
TableOnMergeActionUpd.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableOnMergeActionIns.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableOnMergeActionDel.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
abstract void |
TableOnMergeAction.apply(EventBean matchingEvent,
EventBean[] eventsPerStream,
TableStateInstance tableStateInstance,
TableOnMergeViewChangeHandler changeHandlerAdded,
TableOnMergeViewChangeHandler changeHandlerRemoved,
ExprEvaluatorContext exprEvaluatorContext) |
boolean |
TableOnMergeMatch.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
boolean |
TableOnMergeAction.isApplies(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
EventBean |
TableMetadataInternalEventToPublic.convert(EventBean event,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
TableMetadataInternalEventToPublic.convertToUnd(EventBean event,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
ObjectArrayBackedEventBean |
TableStateInstanceUngroupedImpl.getCreateRowIntoTable(Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
ObjectArrayBackedEventBean |
TableStateInstanceUngrouped.getCreateRowIntoTable(Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
ObjectArrayBackedEventBean |
TableStateInstanceGroupedImpl.getCreateRowIntoTable(Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
ObjectArrayBackedEventBean |
TableStateInstanceGrouped.getCreateRowIntoTable(Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
abstract ObjectArrayBackedEventBean |
TableStateInstance.getCreateRowIntoTable(Object groupByKey,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
TableMetadata.getPublicEventBean(EventBean event,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Field and Description |
|---|---|
protected ExprEvaluatorContext |
TableOnViewBase.exprEvaluatorContext |
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
TableOnViewBase.getExprEvaluatorContext()
returns expr context.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TableOnMergeViewChangeHandler.add(EventBean theEvent,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
static EventBean[] |
TableOnViewUtil.toPublic(EventBean[] matching,
TableMetadata tableMetadata,
EventBean[] triggers,
boolean isNewData,
ExprEvaluatorContext context) |
| Modifier and Type | Method and Description |
|---|---|
protected static Object |
ExprTableEvalStrategyUtil.evalAccessorGetValue(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static EventBean |
ExprTableEvalStrategyUtil.evalGetEventBean(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Collection<EventBean> |
ExprTableEvalStrategyUtil.evalGetROCollectionEvents(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Collection |
ExprTableEvalStrategyUtil.evalGetROCollectionScalar(AggregationRowPair row,
AggregationAccessorSlotPair pair,
EventBean[] eventsPerStream,
boolean newData,
ExprEvaluatorContext context) |
protected static Map<String,Object> |
ExprTableEvalStrategyUtil.evalMap(ObjectArrayBackedEventBean event,
AggregationRowPair row,
Map<String,TableMetadataColumn> items,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
protected static Object[] |
ExprTableEvalStrategyUtil.evalTypable(ObjectArrayBackedEventBean event,
AggregationRowPair row,
Map<String,TableMetadataColumn> items,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableExprEvaluatorMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableExprEvaluatorAccess.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyUngroupedTopLevel.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyUngroupedProp.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyUngroupedMethod.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyUngroupedAccess.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyGroupByTopLevelSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByTopLevelMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByPropSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByPropMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByMethodSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByMethodMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByKeys.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyGroupByAccessSingle.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
ExprTableEvalStrategyGroupByAccessMulti.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
ExprTableExprEvaluatorAccess.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyUngroupedTopLevel.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyUngroupedProp.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyUngroupedMethod.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyUngroupedAccess.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByPropSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByPropMulti.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByMethodBase.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByKeys.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByAccessSingle.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByAccessMulti.evaluateGetEventBean(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected EventBean |
ExprTableEvalStrategyGroupByAccessBase.evaluateGetEventBeanInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
EventBean |
ExprTableEvalStrategyGroupByPropBase.evaluateGetEventBeanInternal(Object groupKey,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableExprEvaluatorAccess.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyUngroupedTopLevel.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyUngroupedProp.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyUngroupedMethod.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyUngroupedAccess.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByPropSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByPropMulti.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByMethodBase.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByKeys.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByAccessSingle.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByAccessMulti.evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Collection<EventBean> |
ExprTableEvalStrategyGroupByAccessBase.evaluateGetROCollectionEventsInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection<EventBean> |
ExprTableEvalStrategyGroupByPropBase.evaluateGetROCollectionEventsInternal(Object groupKey,
ExprEvaluatorContext context) |
Collection |
ExprTableExprEvaluatorAccess.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyUngroupedTopLevel.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyUngroupedProp.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyUngroupedMethod.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyUngroupedAccess.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByPropSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByPropMulti.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByMethodBase.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByKeys.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByAccessSingle.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByAccessMulti.evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Collection |
ExprTableEvalStrategyGroupByAccessBase.evaluateGetROCollectionScalarInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Collection |
ExprTableEvalStrategyGroupByPropBase.evaluateGetROCollectionScalarInternal(Object groupKey,
ExprEvaluatorContext context) |
protected Object |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateInternal(Object groupKey,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Object |
ExprTableEvalStrategyGroupByAccessBase.evaluateInternal(Object group,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object |
ExprTableEvalStrategyGroupByPropBase.evaluateInternal(Object groupKey,
ExprEvaluatorContext context) |
protected Object |
ExprTableEvalStrategyGroupByMethodBase.evaluateInternal(Object groupKey,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyUngroupedTopLevel.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyUngroupedProp.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyUngroupedMethod.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyUngroupedAccess.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyGroupByTopLevelSingle.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyGroupByTopLevelMulti.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyGroupByPropBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyGroupByMethodBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyGroupByKeys.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Object[] |
ExprTableEvalStrategyGroupByAccessBase.evaluateTypableSingle(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected Object[] |
ExprTableEvalStrategyGroupByTopLevelBase.evaluateTypableSingleInternal(Object groupKey,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected static MultiKeyUntyped |
ExprTableEvalStrategyGroupByAccessMulti.getKey(ExprEvaluator[] evaluators,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected TableStateInstanceGrouped |
ExprTableEvalStrategyGroupByBase.lockTableRead(ExprEvaluatorContext context) |
protected ObjectArrayBackedEventBean |
ExprTableEvalStrategyUngroupedBase.lockTableReadAndGet(ExprEvaluatorContext context) |
protected ObjectArrayBackedEventBean |
ExprTableEvalStrategyGroupByBase.lockTableReadAndGet(Object group,
ExprEvaluatorContext context) |
static void |
ExprTableEvalLockUtil.obtainLockUnless(Lock lock,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
TableUpdateStrategyWUniqueConstraint.updateTable(Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableUpdateStrategyNonIndex.updateTable(Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableUpdateStrategyIndexNonUnique.updateTable(Collection<EventBean> eventsUnsafeIter,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
void |
TableUpdateStrategy.updateTable(Collection<EventBean> events,
TableStateInstance instance,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
EventBeanUpdateHelper.updateNoCopy(EventBean matchingEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
EventBean |
EventBeanUpdateHelper.updateWCopy(EventBean matchingEvent,
EventBean[] eventsPerStream,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
OnSetVariableView |
OnSetVariableViewFactory.instantiate(ExprEvaluatorContext exprEvaluatorContext) |
void |
VariableReadWritePackage.writeVariables(VariableService variableService,
EventBean[] eventsPerStream,
Map<String,Object> valuesWritten,
ExprEvaluatorContext exprEvaluatorContext)
Write new variable values and commit, evaluating assignment expressions using the given
events per stream.
|
| Constructor and Description |
|---|
OnSetVariableView(OnSetVariableViewFactory factory,
ExprEvaluatorContext exprEvaluatorContext) |
OnSetVariableViewFactory(int statementId,
OnTriggerSetDesc desc,
EventAdapterService eventAdapterService,
VariableService variableService,
StatementResultService statementResultService,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
OutputProcessViewDirectDistinctOrAfter.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewDirect.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionSnapshot.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionLastAllUnord.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionFirst.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewConditionDefault.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext)
This process (update) method is for participation in a join.
|
void |
OutputProcessViewBaseCallback.process(Set<MultiKey<EventBean>> newEvents,
Set<MultiKey<EventBean>> oldEvents,
ExprEvaluatorContext exprEvaluatorContext) |
| Constructor and Description |
|---|
FilterExprView(ExprNode exprNode,
ExprEvaluator exprEvaluator,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
FilterExprViewIterator(Iterator<EventBean> sourceIterator,
ExprEvaluator filter,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
VirtualDWEventTable.add(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
VirtualDWEventTable.add(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
void |
VirtualDWEventTable.addRemove(EventBean[] newData,
EventBean[] oldData,
ExprEvaluatorContext exprEvaluatorContext) |
Collection<EventBean> |
SubordTableLookupStrategyVirtualDW.lookup(EventBean[] eventsPerStream,
ExprEvaluatorContext context) |
Set<EventBean> |
JoinExecTableLookupStrategyVirtualDW.lookup(EventBean theEvent,
Cursor cursor,
ExprEvaluatorContext context) |
void |
VirtualDWEventTable.remove(EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext) |
void |
VirtualDWEventTable.remove(EventBean event,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
static MultiKeyUntyped |
EventBeanUtility.getMultiKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
ExprEvaluatorContext context,
Class[] coercionTypes) |
| Modifier and Type | Method and Description |
|---|---|
Object |
InstanceManufacturerFastCtor.make(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
InstanceManufacturer.make(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Field and Description |
|---|---|
protected ExprEvaluatorContext |
ExprNodeAdapterBase.evaluatorContext |
ExprEvaluatorContext |
FilterSpecCompilerArgs.exprEvaluatorContext |
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
ExprNodeAdapterBase.getEvaluatorContext() |
| Modifier and Type | Method and Description |
|---|---|
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(List<ExprNode> validatedFilterNodes,
EventType eventType,
String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
Collection<Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ConfigurationInformation configurationInformation,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext) |
Object |
FilterSpecParamFilterForEval.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext)
Returns the filter value representing the endpoint.
|
Object |
FilterForEvalEventPropMayCoerce.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext) |
Object |
FilterForEvalEventPropIndexedMayCoerce.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext) |
Double |
FilterForEvalEventPropIndexedDouble.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Double |
FilterForEvalEventPropDouble.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
FilterForEvalContextPropString.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
FilterForEvalContextPropMayCoerce.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext) |
Double |
FilterForEvalContextPropDouble.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
String |
FilterForEvalConstantString.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Double |
FilterForEvalConstantDouble.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Object |
FilterForEvalConstantAnyType.getFilterValue(MatchedEventMap matchedEvents,
ExprEvaluatorContext evaluatorContext) |
Double |
FilterSpecParamFilterForEvalDouble.getFilterValueDouble(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Double |
FilterForEvalEventPropIndexedDouble.getFilterValueDouble(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Double |
FilterForEvalEventPropDouble.getFilterValueDouble(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Double |
FilterForEvalContextPropDouble.getFilterValueDouble(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
Double |
FilterForEvalConstantDouble.getFilterValueDouble(MatchedEventMap matchedEvents,
ExprEvaluatorContext exprEvaluatorContext) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableMultiStream(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableServiceToUse,
EngineImportService engineImportService,
EventBean[] events,
Annotation[] annotations) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableMultiStreamNoTL(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableServiceToUse,
EngineImportService engineImportService,
EventBean[] events,
Annotation[] annotations) |
protected ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.getLockableSingle(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
StatementContext statementContext,
int agentInstanceId) |
ExprNodeAdapterBase |
FilterBooleanExpressionFactoryImpl.make(FilterSpecParamExprNode node,
EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext,
StatementContext statementContext,
int agentInstanceId) |
ExprNodeAdapterBase |
FilterBooleanExpressionFactory.make(FilterSpecParamExprNode filterSpecParamExprNode,
EventBean[] events,
ExprEvaluatorContext exprEvaluatorContext,
StatementContext statementContext,
int agentInstanceId) |
protected static FilterSpecParam |
FilterSpecCompilerMakeParamUtil.makeFilterParam(ExprNode constituent,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
String statementName)
For a given expression determine if this is optimizable and create the filter parameter
representing the expression, or null if not optimizable.
|
| Constructor and Description |
|---|
ExprNodeAdapterBase(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
EngineImportService engineImportService,
Annotation[] annotations) |
ExprNodeAdapterBaseStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
Annotation[] annotations) |
ExprNodeAdapterBaseVariables(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
Annotation[] annotations) |
ExprNodeAdapterBaseWTableAccess(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
ExprNodeAdapterBase evalBase,
TableService tableService,
EngineImportService engineImportService,
Annotation[] annotations) |
ExprNodeAdapterMultiStream(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
Annotation[] annotations) |
ExprNodeAdapterMultiStreamNoTL(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
Annotation[] annotations) |
ExprNodeAdapterMultiStreamNoTLStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
Annotation[] annotations) |
ExprNodeAdapterMultiStreamStmtLock(int filterSpecId,
int filterSpecParamPathNum,
ExprNode exprNode,
ExprEvaluatorContext evaluatorContext,
VariableService variableService,
EngineImportService engineImportService,
EventBean[] prototype,
Annotation[] annotations) |
FilterSpecCompilerArgs(LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
String statementName,
int statementId,
StreamTypeService streamTypeService,
EngineImportService engineImportService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configurationInformation,
StatementExtensionSvcContext statementExtensionSvcContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
InstrumentationDefault.qSelectClause(EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
ExprEvaluatorContext exprEvaluatorContext) |
void |
Instrumentation.qSelectClause(EventBean[] eventsPerStream,
boolean newData,
boolean synthesize,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
static Object |
PatternExpressionUtil.evaluate(String objectName,
MatchedEventMap beginState,
ExprNode parameter,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext) |
static List<Object> |
PatternExpressionUtil.evaluate(String objectName,
MatchedEventMap beginState,
List<ExprNode> parameters,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
static Object |
PatternExpressionUtil.evaluateTimePeriod(String objectName,
MatchedEventMap beginState,
ExprTimePeriod timePeriod,
MatchedEventConvertor convertor,
ExprEvaluatorContext exprEvaluatorContext)
Evaluate the pattern expression.
|
| Modifier and Type | Method and Description |
|---|---|
ExprEvaluatorContext |
RegexPartitionStateRepoGroupMeta.getExprEvaluatorContext() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Constructor and Description |
|---|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Method and Description |
|---|---|
Number |
MinMaxTypeEnum.Computer.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext)
Executes child expression nodes and compares results, returning the min/max.
|
Number |
MinMaxTypeEnum.MinComputerDoubleCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Number |
MinMaxTypeEnum.MaxComputerDoubleCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Number |
MinMaxTypeEnum.ComputerBigIntCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
Number |
MinMaxTypeEnum.ComputerBigDecCoerce.execute(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext exprEvaluatorContext) |
| Modifier and Type | Class and Description |
|---|---|
class |
SupportExprEvaluatorContext |
| Modifier and Type | Method and Description |
|---|---|
static Object |
ViewFactorySupport.evaluateAssertNoProperties(String viewName,
ExprNode expression,
int index,
ExprEvaluatorContext exprEvaluatorContext) |
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,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
ConfigurationInformation configSnapshot,
SchedulingService schedulingService,
String engineURI,
Map<Integer,List<ExprNode>> sqlParameters,
EventAdapterService eventAdapterService,
StatementContext statementContext)
Validate the view.
|
| Modifier and Type | Method and Description |
|---|---|
static Object |
RankWindowView.getCriteriaKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
EventBean theEvent,
ExprEvaluatorContext evalContext) |
static MultiKeyUntyped |
RankWindowView.getCriteriaMultiKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
ExprEvaluatorContext evalContext) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
RouteResultViewHandlerFirst.handle(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
boolean |
RouteResultViewHandlerAll.handle(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext) |
boolean |
RouteResultViewHandler.handle(EventBean theEvent,
ExprEvaluatorContext exprEvaluatorContext)
Handle event.
|