Package | Description |
---|---|
com.espertech.esper.collection |
Internal collection classes
|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.mgr |
Context management.
|
com.espertech.esper.core.context.stmt |
Registries for context partitions to handle aggregations, prev/prior and subselects.
|
com.espertech.esper.core.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.epl.agg.access |
State multifunction aggregation methods
|
com.espertech.esper.epl.agg.factory |
Aggregator factories
|
com.espertech.esper.epl.agg.rollup |
Aggregation roll-up services.
|
com.espertech.esper.epl.agg.service |
Aggregation services.
|
com.espertech.esper.epl.agg.util |
Aggregation utility classes centered around local group-by parameters.
|
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.interval |
Interval algebra.
|
com.espertech.esper.epl.declexpr |
Declared expression handling.
|
com.espertech.esper.epl.enummethod.dot |
Enumeration method utility classes and input data sources.
|
com.espertech.esper.epl.enummethod.eval |
Enumeration method implementations.
|
com.espertech.esper.epl.expression.accessagg |
Access-aggregation expressions.
|
com.espertech.esper.epl.expression.baseagg |
Base aggregation expressions.
|
com.espertech.esper.epl.expression.core |
Core expression classes.
|
com.espertech.esper.epl.expression.dot |
Chained expression functionality.
|
com.espertech.esper.epl.expression.dot.inner |
Expression dot-method inner evaluators.
|
com.espertech.esper.epl.expression.funcs |
Function expressions.
|
com.espertech.esper.epl.expression.methodagg |
Method-aggregation 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.hint |
Hints related to joins.
|
com.espertech.esper.epl.join.plan |
Inner join and outer join query planning
|
com.espertech.esper.epl.lookup |
Subquery execution strategies and lookup indexes
|
com.espertech.esper.epl.named |
Named window classes are in this package
|
com.espertech.esper.epl.property |
Classes for handling events-within-events.
|
com.espertech.esper.epl.script |
Script expression evaluation.
|
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.strategy |
Table access evaluators.
|
com.espertech.esper.epl.updatehelper |
Helpers for EPL update functionality.
|
com.espertech.esper.epl.view |
Internal processing views for output rate limiting, filtering and internal event routing
|
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.pattern.guard |
Pattern guards that can define the lifetime of a pattern
|
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 |
Utility classes that center around Java type handling, printing, reflection, debugging
|
com.espertech.esper.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
com.espertech.esper.view.ext |
Extension views that providing services such as sorting, which don't fit much into other categories.
|
com.espertech.esper.view.internal |
Internal management views for buffering view results and providing these to joins.
|
com.espertech.esper.view.stat |
Views computing statistical values.
|
com.espertech.esper.view.std |
Base service views that perform typical SQL-like functions such as unique, grouping, size, last etc.
|
com.espertech.esper.view.window |
Window views are in this package
|
Constructor and Description |
---|
FilteredEventIterator(ExprEvaluator[] filters,
Iterator<EventBean> parent,
ExprEvaluatorContext exprEvaluatorContext)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
ViewableActivator |
ViewableActivatorFactoryDefault.createTable(TableMetadata metadata,
ExprEvaluator[] optionalTableFilters) |
ViewableActivator |
ViewableActivatorFactory.createTable(TableMetadata metadata,
ExprEvaluator[] optionalTableFilters) |
Constructor and Description |
---|
ViewableActivatorTable(TableMetadata tableMetadata,
ExprEvaluator[] optionalTableFilters) |
Constructor and Description |
---|
ContextControllerHashedGetterCRC32Single(ExprEvaluator eval,
int granularity) |
ContextControllerHashedGetterHashSingle(ExprEvaluator eval,
int granularity) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
SubSelectStrategyFactoryIndexShare(String statementName,
int statementId,
int subqueryNum,
EventType[] outerEventTypesSelect,
NamedWindowProcessor optionalNamedWindowProcessor,
TableMetadata optionalTableMetadata,
boolean fullTableScan,
IndexHint optionalIndexHint,
SubordPropPlan joinedPropPlan,
ExprEvaluator filterExprEval,
AggregationServiceFactoryDesc aggregationServiceFactory,
ExprEvaluator[] groupByKeys,
TableService tableService,
Annotation[] annotations,
StatementStopService statementStopService,
EngineImportService engineImportService) |
SubSelectStrategyFactoryIndexShare(String statementName,
int statementId,
int subqueryNum,
EventType[] outerEventTypesSelect,
NamedWindowProcessor optionalNamedWindowProcessor,
TableMetadata optionalTableMetadata,
boolean fullTableScan,
IndexHint optionalIndexHint,
SubordPropPlan joinedPropPlan,
ExprEvaluator filterExprEval,
AggregationServiceFactoryDesc aggregationServiceFactory,
ExprEvaluator[] groupByKeys,
TableService tableService,
Annotation[] annotations,
StatementStopService statementStopService,
EngineImportService engineImportService) |
SubSelectStrategyFactoryLocalViewPreloaded(int subqueryNumber,
SubSelectActivationHolder subSelectHolder,
Pair<EventTableFactory,SubordTableLookupStrategyFactory> pair,
ExprNode filterExprNode,
ExprEvaluator filterExprEval,
boolean correlatedSubquery,
AggregationServiceFactoryDesc aggregationServiceFactory,
ViewResourceDelegateVerified viewResourceDelegate,
ExprEvaluator[] groupKeys) |
SubSelectStrategyFactoryLocalViewPreloaded(int subqueryNumber,
SubSelectActivationHolder subSelectHolder,
Pair<EventTableFactory,SubordTableLookupStrategyFactory> pair,
ExprNode filterExprNode,
ExprEvaluator filterExprEval,
boolean correlatedSubquery,
AggregationServiceFactoryDesc aggregationServiceFactory,
ViewResourceDelegateVerified viewResourceDelegate,
ExprEvaluator[] groupKeys) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
InternalEventRouterEntry.getAssignments()
Returns the expressions providing values for assignment.
|
ExprEvaluator |
InternalEventRouterEntry.getOptionalWhereClause()
Returns the where-clause or null if none defined
|
Modifier and Type | Method and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
AggregationStateSortedSpec.getCriteria() |
ExprEvaluator[] |
AggregationStateMinMaxByEverSpec.getCriteria() |
ExprEvaluator |
AggregationStateSortedSpec.getOptionalFilter() |
ExprEvaluator |
AggregationStateMinMaxByEverSpec.getOptionalFilter() |
Modifier and Type | Method and Description |
---|---|
static Object |
AggregationStateSortedImpl.getComparable(ExprEvaluator[] criteria,
EventBean[] eventsPerStream,
boolean istream,
ExprEvaluatorContext exprEvaluatorContext) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
AggregationStateFactoryLinear.optionalFilter |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
AggregationMethodFactorySum.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryStddev.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryRate.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryPlugIn.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryNth.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryMinMax.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryMedian.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryLeaving.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryLastEver.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryFirstEver.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryCountEver.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryCount.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryAvg.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryAvedev.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
static ExprEvaluator |
AggregationMethodFactoryCount.getMethodAggregationEvaluatorCountBy(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
Modifier and Type | Method and Description |
---|---|
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeLinear(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode expr,
int streamNum,
ExprEvaluator optionalFilter) |
AggregationStateFactory |
AggregationFactoryFactory.makeLinear(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode expr,
int streamNum,
ExprEvaluator optionalFilter) |
Constructor and Description |
---|
AggregationStateFactoryLinear(ExprAggMultiFunctionLinearAccessNode expr,
int streamNum,
ExprEvaluator optionalFilter) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
GroupByRollupPerLevelExpression.getOptionalHavingNodes() |
Constructor and Description |
---|
GroupByRollupPerLevelExpression(SelectExprProcessor[] selectExprProcessor,
ExprEvaluator[] optionalHavingNodes,
OrderByElement[][] optionalOrderByElements) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
AggregationServiceFactoryBase.evaluators
Evaluation nodes under.
|
protected ExprEvaluator[] |
AggregationServiceBaseUngrouped.evaluators
Evaluation nodes under.
|
protected ExprEvaluator[] |
AggregationServiceBaseGrouped.evaluators
Evaluation nodes under.
|
protected ExprEvaluator[] |
AggregationServiceBase.evaluators
Evaluation nodes under.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
AggregationServiceBase.getEvaluators() |
ExprEvaluator |
AggregationMethodFactory.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
Modifier and Type | Method and Description |
---|---|
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) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupedNoReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupNoReclaimMixed(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimAged(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
Hint reclaimGroupAged,
Hint reclaimGroupFrequency,
VariableService variableService,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
String optionalContextName,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixable(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimMixableRollup(ExprNode[] groupByNodes,
AggregationGroupByRollupDesc byRollupDesc,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getGroupReclaimNoAccess(ExprNode[] groupByNodes,
ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupAccessMixed(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
AggregationAccessorSlotPair[] pairs,
AggregationStateFactory[] accessAggregations,
boolean join,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryServiceImpl.getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
AggregationServiceFactory |
AggregationServiceFactoryService.getNoGroupNoAccess(ExprEvaluator[] evaluatorsArr,
AggregationMethodFactory[] aggregatorsArr,
boolean isUnidirectional,
boolean isFireAndForget,
boolean isOnSelect) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
AggregationLocalGroupByLevel.getMethodEvaluators() |
ExprEvaluator[] |
AggregationLocalGroupByLevel.getPartitionEvaluators() |
ExprEvaluator[] |
AggregationLocalGroupByColumn.getPartitionEvaluators() |
Modifier and Type | Method and Description |
---|---|
static AggregationLocalGroupByPlan |
AggregationGroupByLocalGroupByAnalyzer.analyze(ExprEvaluator[] evaluators,
AggregationMethodFactory[] prototypes,
AggregationStateFactory[] accessAggregations,
AggregationGroupByLocalGroupDesc localGroupDesc,
ExprNode[] groupByExpressions,
AggregationAccessorSlotPair[] accessors) |
Constructor and Description |
---|
AggregationLocalGroupByColumn(boolean defaultGroupLevel,
ExprEvaluator[] partitionEvaluators,
int methodOffset,
boolean methodAgg,
AggregationAccessorSlotPair pair,
int levelNum) |
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
boolean defaultLevel) |
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
boolean defaultLevel) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
CountMinSketchAggAgentAdd.stringEvaluator |
Constructor and Description |
---|
CountMinSketchAggAccessorFrequency(ExprEvaluator evaluator) |
CountMinSketchAggAgentAdd(ExprEvaluator stringEvaluator) |
CountMinSketchAggAgentAddFilter(ExprEvaluator stringEvaluator,
ExprEvaluator filter) |
Modifier and Type | Class and Description |
---|---|
class |
BindProcessorEvaluatorStream |
class |
BindProcessorEvaluatorStreamTable |
static class |
SelectExprInsertEventBeanFactory.ExprEvaluatorJoinWildcard |
class |
SelectExprProcessorEvalByGetter |
class |
SelectExprProcessorEvalByGetterFragment |
class |
SelectExprProcessorEvalStreamInsertNamedWindow |
class |
SelectExprProcessorEvalStreamInsertTable |
class |
SelectExprProcessorEvalStreamInsertUnd |
class |
SelectExprProcessorEvalTypableMap |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceBase.exprEvaluator |
protected ExprEvaluator[] |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeBase.exprEvaluators |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
OrderByElement.getExpr() |
ExprEvaluator |
EngineImportApplicationDotMethod.getExprEvaluator() |
ExprEvaluator[] |
OrderByProcessorFactoryImpl.getGroupByNodes() |
ExprEvaluator |
ResultSetProcessorRowPerGroupRollupFactory.getGroupKeyNode() |
ExprEvaluator |
ResultSetProcessorRowPerGroupFactory.getGroupKeyNode() |
ExprEvaluator |
ResultSetProcessorAggregateGroupedFactory.getGroupKeyNode() |
ExprEvaluator[] |
ResultSetProcessorRowPerGroupRollupFactory.getGroupKeyNodes() |
ExprEvaluator[] |
ResultSetProcessorRowPerGroupFactory.getGroupKeyNodes() |
ExprEvaluator[] |
ResultSetProcessorAggregateGroupedFactory.getGroupKeyNodes() |
ExprEvaluator |
SelectExprProcessorEvalTypableMap.getInnerEvaluator() |
ExprEvaluator |
ResultSetProcessorSimpleFactory.getOptionalHavingExpr() |
ExprEvaluator |
ResultSetProcessorRowPerGroupFactory.getOptionalHavingNode() |
ExprEvaluator |
ResultSetProcessorRowPerGroup.getOptionalHavingNode()
Returns the optional having expression.
|
ExprEvaluator |
ResultSetProcessorRowForAllFactory.getOptionalHavingNode() |
ExprEvaluator |
ResultSetProcessorAggregateGroupedFactory.getOptionalHavingNode() |
ExprEvaluator |
ResultSetProcessorAggregateGrouped.getOptionalHavingNode()
Returns the having node.
|
ExprEvaluator |
ResultSetProcessorAggregateAllFactory.getOptionalHavingNode() |
ExprEvaluator |
ResultSetProcessorAggregateAll.getOptionalHavingNode()
Returns the optional having expression.
|
Modifier and Type | Method and Description |
---|---|
static SelectExprProcessor |
SelectExprInsertEventBeanFactory.getInsertUnderlyingNonJoin(EventAdapterService eventAdapterService,
EventType eventType,
boolean isUsingWildcard,
StreamTypeService typeService,
ExprEvaluator[] expressionNodes,
String[] columnNames,
Object[] expressionReturnTypes,
EngineImportService engineImportService,
InsertIntoDesc insertIntoDesc,
String[] columnNamesAsProvided,
boolean allowNestableTargetFragmentTypes,
String statementName) |
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.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.
|
ResultSetProcessorGroupedOutputAllGroupReps |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyExpressions,
int numStreams) |
ResultSetProcessorGroupedOutputAllGroupReps |
ResultSetProcessorHelperFactory.makeRSGroupedOutputAllNoOpt(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyExpressions,
int numStreams) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactory.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
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.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) |
Constructor and Description |
---|
OrderByElement(ExprNode exprNode,
ExprEvaluator expr,
boolean descending) |
ResultSetProcessorAggregateAllFactory(SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
boolean enableOutputLimitOpt,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
ResultSetProcessorAggregateGroupedFactory(SelectExprProcessor selectExprProcessor,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
boolean enableOutputLimitOpt,
int numStreams) |
ResultSetProcessorAggregateGroupedFactory(SelectExprProcessor selectExprProcessor,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean isHistoricalOnly,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
boolean enableOutputLimitOpt,
int numStreams) |
ResultSetProcessorRowForAllFactory(SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
boolean isHistoricalOnly,
OutputLimitSpec outputLimitSpec,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory) |
ResultSetProcessorRowPerGroupFactory(SelectExprProcessor selectExprProcessor,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean enableOutputLimitOpt,
int numStreams,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
ResultSetProcessorRowPerGroupFactory(SelectExprProcessor selectExprProcessor,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
boolean isHistoricalOnly,
boolean iterateUnbounded,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean enableOutputLimitOpt,
int numStreams,
OutputConditionPolledFactory optionalOutputFirstConditionFactory) |
ResultSetProcessorRowPerGroupRollupFactory(GroupByRollupPerLevelExpression perLevelExpression,
ExprNode[] groupKeyNodeExpressions,
ExprEvaluator[] groupKeyNodes,
boolean isSelectRStream,
boolean isUnidirectional,
OutputLimitSpec outputLimitSpec,
boolean isSorting,
boolean noDataWindowSingleStream,
AggregationGroupByRollupDesc groupByRollupDesc,
boolean isJoin,
boolean isHistoricalOnly,
boolean iterateUnbounded,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
boolean enableOutputLimitOpt,
int numStreams) |
ResultSetProcessorSimpleFactory(SelectExprProcessor selectExprProcessor,
ExprEvaluator optionalHavingNode,
boolean isSelectRStream,
OutputLimitSpec outputLimitSpec,
boolean enableOutputLimitOpt,
ResultSetProcessorHelperFactory resultSetProcessorHelperFactory,
int numStreams) |
SelectExprInsertNativeBase(EventType eventType,
EventBeanManufacturer eventManufacturer,
ExprEvaluator[] exprEvaluators) |
SelectExprInsertNativeExpressionCoerceAvro(EventType eventType,
ExprEvaluator exprEvaluator,
EventAdapterService eventAdapterService) |
SelectExprInsertNativeExpressionCoerceBase(EventType eventType,
ExprEvaluator exprEvaluator,
EventAdapterService eventAdapterService) |
SelectExprInsertNativeExpressionCoerceMap(EventType eventType,
ExprEvaluator exprEvaluator,
EventAdapterService eventAdapterService) |
SelectExprInsertNativeExpressionCoerceNative(EventType eventType,
ExprEvaluator exprEvaluator,
EventAdapterService eventAdapterService) |
SelectExprInsertNativeExpressionCoerceObjectArray(EventType eventType,
ExprEvaluator exprEvaluator,
EventAdapterService eventAdapterService) |
SelectExprInsertNativeNoWiden(EventType eventType,
EventBeanManufacturer eventManufacturer,
ExprEvaluator[] exprEvaluators) |
SelectExprInsertNativeWidening(EventType eventType,
EventBeanManufacturer eventManufacturer,
ExprEvaluator[] exprEvaluators,
TypeWidener[] wideners) |
SelectExprProcessorEvalTypableMap(EventType mapType,
ExprEvaluator innerEvaluator,
EventAdapterService eventAdapterService) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
SelectExprContext.getExpressionNodes() |
ExprEvaluator[] |
EvalBase.getExprNodes() |
Modifier and Type | Method and Description |
---|---|
void |
SelectExprContext.setExpressionNodes(ExprEvaluator[] expressionNodes) |
Constructor and Description |
---|
EvalSelectStreamWUnderlying(SelectExprContext selectExprContext,
EventType resultEventType,
List<SelectClauseStreamCompiledSpec> namedStreams,
boolean usingWildcard,
List<SelectExprStreamDesc> unnamedStreams,
boolean singleStreamWrapper,
boolean underlyingIsFragmentEvent,
int underlyingStreamNumber,
EventPropertyGetter underlyingPropertyEventGetter,
ExprEvaluator underlyingExprEvaluator,
TableMetadata tableMetadata) |
SelectExprContext(ExprEvaluator[] expressionNodes,
String[] columnNames,
EventAdapterService eventAdapterService) |
Modifier and Type | Method and Description |
---|---|
protected static Integer |
CalendarOpWithDate.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected static Integer |
CalendarOpUtil.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
CalendarOp |
CalendarOpFactory.getOp(DatetimeMethodEnum method,
String methodNameUsed,
List<ExprNode> parameters,
ExprEvaluator[] evaluators) |
Constructor and Description |
---|
CalendarOpPlusMinus(ExprEvaluator param,
int factor) |
CalendarOpSet(CalendarFieldEnum fieldName,
ExprEvaluator valueExpr) |
CalendarOpWithDate(ExprEvaluator year,
ExprEvaluator month,
ExprEvaluator day) |
CalendarOpWithTime(ExprEvaluator hour,
ExprEvaluator min,
ExprEvaluator sec,
ExprEvaluator msec) |
Modifier and Type | Class and Description |
---|---|
class |
ExprEvaluatorStreamLongProp |
class |
ExprEvaluatorStreamLongPropFragment |
Constructor and Description |
---|
IntervalOpEvalCalWithEnd(IntervalComputer intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpEvalDateWithEnd(IntervalComputer intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpEvalDateWithEndBase(IntervalComputer intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpEvalLocalDateTimeWithEnd(IntervalComputer intervalComputer,
ExprEvaluator evaluatorEndTimestamp,
TimeZone timeZone) |
IntervalOpEvalLongWithEnd(IntervalComputer intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpEvalZonedDateTimeWithEnd(IntervalComputer intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
Modifier and Type | Class and Description |
---|---|
class |
ExprDeclaredEvalBase |
class |
ExprDeclaredEvalConstant |
class |
ExprDeclaredEvalNoRewrite |
class |
ExprDeclaredEvalRewrite |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprDeclaredNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprDeclaredEvalBase.getInnerEvaluator() |
Constructor and Description |
---|
ExprDeclaredEvalBase(ExprEvaluator innerEvaluator,
ExpressionDeclItem prototype,
boolean isCache) |
ExprDeclaredEvalNoRewrite(ExprEvaluator innerEvaluator,
ExpressionDeclItem prototype,
boolean isCache) |
ExprDeclaredEvalRewrite(ExprEvaluator innerEvaluator,
ExpressionDeclItem prototype,
boolean isCache,
int[] streamAssignments) |
Modifier and Type | Class and Description |
---|---|
class |
ExprLambdaGoesNode
Represents the case-when-then-else control flow function is an expression tree.
|
class |
PropertyExprEvaluatorNonLambda |
class |
PropertyExprEvaluatorNonLambdaFragment |
class |
PropertyExprEvaluatorNonLambdaIndexed |
class |
PropertyExprEvaluatorNonLambdaMapped |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprDotEvalParam.getBodyEvaluator() |
ExprEvaluator |
ExprLambdaGoesNode.getExprEvaluator() |
Constructor and Description |
---|
ExprDotEvalParam(int parameterNum,
ExprNode body,
ExprEvaluator bodyEvaluator) |
ExprDotEvalParamExpr(int parameterNum,
ExprNode body,
ExprEvaluator bodyEvaluator) |
ExprDotEvalParamLambda(int parameterNum,
ExprNode body,
ExprEvaluator bodyEvaluator,
int streamCountIncoming,
List<String> goesToNames,
EventType[] goesToTypes) |
PropertyExprEvaluatorNonLambdaIndexed(int streamId,
EventPropertyGetterIndexed indexedGetter,
ExprEvaluator paramEval,
Class returnType) |
PropertyExprEvaluatorNonLambdaMapped(int streamId,
EventPropertyGetterMapped mappedGetter,
ExprEvaluator paramEval,
Class returnType) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
EnumEvalAggregateBase.initialization |
protected ExprEvaluator |
EnumEvalBaseScalarIndex.innerExpression |
protected ExprEvaluator |
EnumEvalBaseIndex.innerExpression |
protected ExprEvaluator |
EnumEvalBase.innerExpression |
protected ExprEvaluator |
EnumEvalAggregateBase.innerExpression |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
EnumEvalBase.getInnerExpression() |
Constructor and Description |
---|
EnumEvalAggregateBase(ExprEvaluator initialization,
ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType resultEventType) |
EnumEvalAggregateEvents(ExprEvaluator initialization,
ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType resultEventType) |
EnumEvalAggregateScalar(ExprEvaluator initialization,
ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType resultEventType,
ObjectArrayEventType evalEventType) |
EnumEvalAllOfEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalAllOfScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalAnyOfEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalAnyOfScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalAverageBigDecimalEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
MathContext optionalMathContext) |
EnumEvalAverageBigDecimalScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType resultEventType,
MathContext optionalMathContext) |
EnumEvalAverageEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalAverageScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType resultEventType) |
EnumEvalBase(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalBaseIndex(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType indexEventType) |
EnumEvalBaseScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalBaseScalarIndex(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType evalEventType,
ObjectArrayEventType indexEventType) |
EnumEvalCountOfSelectorEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalCountOfSelectorScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalDistinctEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalDistinctScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType resultEventType) |
EnumEvalFirstOfPredicateEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalFirstOfPredicateScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalGroupByKeySelectorEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalGroupByKeySelectorScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType resultEventType) |
EnumEvalGroupByKeyValueSelectorEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
ExprEvaluator secondExpression) |
EnumEvalGroupByKeyValueSelectorScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ExprEvaluator secondExpression,
ObjectArrayEventType resultEventType) |
EnumEvalLastOfPredicateEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalLastOfPredicateScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalMinMaxByEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean max) |
EnumEvalMinMaxByScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean max,
ObjectArrayEventType resultEventType) |
EnumEvalMinMaxEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean max) |
EnumEvalMinMaxScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean max,
ObjectArrayEventType resultEventType) |
EnumEvalMostLeastFrequentEvent(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean mostFrequent) |
EnumEvalMostLeastFrequentScalarLamda(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean mostFrequent,
ObjectArrayEventType resultEventType) |
EnumEvalOrderByAscDescEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean descending) |
EnumEvalOrderByAscDescScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
boolean descending,
ObjectArrayEventType resultEventType) |
EnumEvalSelectFromEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalSelectFromScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType resultEventType) |
EnumEvalSequenceEqual(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalSumEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
ExprDotEvalSumMethodFactory sumMethodFactory) |
EnumEvalSumScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ExprDotEvalSumMethodFactory sumMethodFactory,
ObjectArrayEventType resultEventType) |
EnumEvalTake(ExprEvaluator sizeEval,
int numStreams) |
EnumEvalTakeLast(ExprEvaluator sizeEval,
int numStreams) |
EnumEvalTakeWhileEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalTakeWhileIndexEvents(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType indexEventType) |
EnumEvalTakeWhileIndexScalar(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType evalEventType,
ObjectArrayEventType indexEventType) |
EnumEvalTakeWhileLastEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalTakeWhileLastIndexEvents(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType indexEventType) |
EnumEvalTakeWhileLastIndexScalar(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType evalEventType,
ObjectArrayEventType indexEventType) |
EnumEvalTakeWhileLastScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalTakeWhileScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalToMapEvents(ExprEvaluator innerExpression,
int streamCountIncoming,
ExprEvaluator secondExpression) |
EnumEvalToMapScalarLambda(ExprEvaluator innerExpression,
int streamCountIncoming,
ExprEvaluator secondExpression,
ObjectArrayEventType resultEventType) |
EnumEvalWhereEvents(ExprEvaluator innerExpression,
int streamCountIncoming) |
EnumEvalWhereIndexEvents(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType indexEventType) |
EnumEvalWhereScalar(ExprEvaluator innerExpression,
int streamCountIncoming,
ObjectArrayEventType type) |
EnumEvalWhereScalarIndex(ExprEvaluator innerExpression,
int streamNumLambda,
ObjectArrayEventType evalEventType,
ObjectArrayEventType indexEventType) |
Modifier and Type | Class and Description |
---|---|
class |
ExprAggCountMinSketchNode
Represents the Count-min sketch aggregate function.
|
class |
ExprAggMultiFunctionLinearAccessNode |
class |
ExprAggMultiFunctionSortedMinMaxByNode |
class |
ExprPlugInAggMultiFunctionNode
Represents a custom aggregation function in an expresson tree.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprAggCountMinSketchNodeFactoryUse.getAddOrFrequencyEvaluator() |
ExprEvaluator |
ExprPlugInAggMultiFunctionNodeFactory.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
ExprAggMultiFunctionSortedMinMaxByNodeFactory.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
ExprAggMultiFunctionLinearAccessNodeFactoryAccess.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
ExprAggCountMinSketchNodeFactoryUse.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
ExprAggCountMinSketchNodeFactoryState.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
ExprEvaluator |
AggregationMethodFactoryFirstLastUnbound.getMethodAggregationEvaluator(boolean join,
EventType[] typesPerStream) |
Constructor and Description |
---|
ExprAggCountMinSketchNodeFactoryUse(ExprAggCountMinSketchNode parent,
ExprEvaluator addOrFrequencyEvaluator) |
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprEvaluator optionalFilter) |
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprEvaluator optionalFilter) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprAggregateNode
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAggregateNodeBase
Base expression node that represents an aggregation function such as 'sum' or 'count'.
|
class |
ExprAggregateNodeGroupKey |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprAggregateNodeGroupKey.getExprEvaluator() |
ExprEvaluator |
ExprAggregateNodeBase.getExprEvaluator() |
Modifier and Type | Method and Description |
---|---|
void |
ExprAggregateNodeBase.validateFilter(ExprEvaluator filterEvaluator) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprEvaluatorTypableReturn
Interface for evaluators that select possible multi-valued results in a single select column,
such as subqueries and "new" and case+new combined.
|
interface |
ExprIdentNodeEvaluator |
Modifier and Type | Class and Description |
---|---|
class |
ExprConstantNodeImpl
Represents a constant in an expressiun tree.
|
class |
ExprContextPropertyNode
Represents an stream property identifier in a filter expressiun tree.
|
class |
ExprCurrentEvaluationContextNode
Represents the "current_evaluation_context" function in an expression tree.
|
class |
ExprGroupingIdNode |
class |
ExprGroupingNode |
class |
ExprIdentNodeEvaluatorContext |
class |
ExprIdentNodeEvaluatorImpl |
class |
ExprIdentNodeEvaluatorLogging |
class |
ExprNamedParameterNodeImpl |
class |
ExprNodeUtilExprEvalMethodContext |
class |
ExprNodeUtilExprEvalStreamNumEnumColl |
class |
ExprNodeUtilExprEvalStreamNumEnumSingle |
class |
ExprNodeUtilExprEvalStreamNumEvent |
class |
ExprNodeUtilExprEvalStreamNumEventTable |
class |
ExprNodeUtilExprEvalStreamNumUnd |
class |
ExprNodeUtilUnderlyingEvaluator |
class |
ExprNodeUtilUnderlyingEvaluatorTable |
class |
ExprNodeValidated
A placeholder for another expression node that has been validated already.
|
class |
ExprNumberSetCronParam
Expression for a parameter within a crontab.
|
class |
ExprNumberSetFrequency
Expression for use within crontab to specify a frequency.
|
class |
ExprNumberSetList
Expression for use within crontab to specify a list of values.
|
class |
ExprNumberSetRange
Expression for use within crontab to specify a range.
|
class |
ExprOrderedExpr
A placeholder expression for view/pattern object parameters that allow
sorting expression values ascending or descending.
|
class |
ExprStreamUnderlyingNodeImpl
Represents an stream selector that returns the streams underlying event, or null if undefined.
|
class |
ExprTypedNoEvalNode
Represents an expression node that returns the predefined type and
that cannot be evaluated.
|
class |
ExprVariableNodeImpl
Represents a variable in an expression tree.
|
class |
ExprWildcardImpl
Expression for use within crontab to specify a wildcard.
|
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 ScheduleSpec |
ExprNodeUtility.crontabScheduleBuild(ExprEvaluator[] scheduleSpecEvaluators,
ExprEvaluatorContext context) |
static Object[] |
ExprNodeUtility.evaluateExpressions(ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext) |
static Object |
ExprNodeUtility.evaluateValidationTimeNoStreams(ExprEvaluator evaluator,
ExprEvaluatorContext context,
String expressionName) |
static Class[] |
ExprNodeUtility.getExprResultTypes(ExprEvaluator[] evaluators) |
static Object |
ExprEvaluatorProxy.newInstance(String engineURI,
String statementName,
String expressionToString,
ExprEvaluator evaluator) |
static String |
ExprNodeUtility.printEvaluators(ExprEvaluator[] evaluators) |
Constructor and Description |
---|
ExprEvaluatorProxy(String engineURI,
String statementName,
String expressionToString,
ExprEvaluator evaluator) |
ExprNodeUtilMethodDesc(boolean allConstants,
Class[] paramTypes,
ExprEvaluator[] childEvals,
Method reflectionMethod,
net.sf.cglib.reflect.FastMethod fastMethod,
EventType optionalEventType) |
Modifier and Type | Class and Description |
---|---|
class |
ExprDotEvalPropertyExprBase |
class |
ExprDotEvalPropertyExprIndexed |
class |
ExprDotEvalPropertyExprMapped |
class |
ExprDotEvalRootChild |
class |
ExprDotEvalStaticMethod |
class |
ExprDotEvalStreamEventBean |
class |
ExprDotEvalStreamMethod |
class |
ExprDotEvalTransposeAsStream |
class |
ExprDotEvalVariable |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
ExprDotEvalPropertyExprBase.exprEvaluator |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprDotNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprAppDotMethodImpl.getExprEvaluator() |
Constructor and Description |
---|
ExprDotEvalArrayGet(ExprEvaluator index,
Class componentType) |
ExprDotEvalPropertyExprBase(String statementName,
String propertyName,
int streamNum,
ExprEvaluator exprEvaluator,
Class propertyType) |
ExprDotEvalPropertyExprIndexed(String statementName,
String propertyName,
int streamNum,
ExprEvaluator exprEvaluator,
Class propertyType,
EventPropertyGetterIndexed indexedGetter) |
ExprDotEvalPropertyExprMapped(String statementName,
String propertyName,
int streamNum,
ExprEvaluator exprEvaluator,
Class propertyType,
EventPropertyGetterMapped mappedGetter) |
ExprDotEvalRootChild(boolean hasEnumerationMethod,
ExprDotNode dotNode,
ExprEvaluator rootNodeEvaluator,
ExprEvaluatorEnumeration rootLambdaEvaluator,
EPType typeInfo,
ExprDotEval[] evalIteratorEventBean,
ExprDotEval[] evalUnpacking,
boolean checkedUnpackEvent) |
ExprDotEvalStaticMethod(String statementName,
String classOrPropertyName,
net.sf.cglib.reflect.FastMethod staticMethod,
ExprEvaluator[] childEvals,
boolean constantParameters,
ExprDotStaticMethodWrap resultWrapLambda,
ExprDotEval[] chainEval,
boolean rethrowExceptions,
Object targetObject) |
ExprDotEvalTransposeAsStream(ExprEvaluator inner) |
ExprDotMethodEvalDuck(String statementName,
EngineImportService engineImportService,
String methodName,
Class[] parameterTypes,
ExprEvaluator[] parameters) |
ExprDotMethodEvalNoDuck(String statementName,
net.sf.cglib.reflect.FastMethod method,
ExprEvaluator[] parameters) |
ExprDotMethodEvalNoDuckUnderlying(String statementName,
net.sf.cglib.reflect.FastMethod method,
ExprEvaluator[] parameters) |
ExprDotMethodEvalNoDuckWrapArray(String statementName,
net.sf.cglib.reflect.FastMethod method,
ExprEvaluator[] parameters) |
Constructor and Description |
---|
InnerEvaluatorArrObjectToColl(ExprEvaluator rootEvaluator) |
InnerEvaluatorArrPrimitiveToColl(ExprEvaluator rootEvaluator) |
InnerEvaluatorColl(ExprEvaluator rootEvaluator) |
InnerEvaluatorScalar(ExprEvaluator rootEvaluator) |
InnerEvaluatorScalarUnpackEvent(ExprEvaluator rootEvaluator) |
Modifier and Type | Class and Description |
---|---|
class |
ExprCaseNode
Represents the case-when-then-else control flow function is an expression tree.
|
class |
ExprCastNodeConstEval |
class |
ExprCastNodeNonConstEval |
class |
ExprCoalesceNode
Represents the COALESCE(a,b,...) function is an expression tree.
|
class |
ExprInstanceofNode
Represents the INSTANCEOF(a,b,...) function is an expression tree.
|
class |
ExprIStreamNode
Represents the RSTREAM() function in an expression tree.
|
class |
ExprMinMaxRowNode
Represents the MAX(a,b) and MIN(a,b) functions is an expression tree.
|
class |
ExprPropertyExistsNode
Represents the EXISTS(property) function in an expression tree.
|
static class |
ExprTypeofNode.FragmentTypeEval |
static class |
ExprTypeofNode.StreamEventTypeEval |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprCastNodeDateDesc.getDynamicDateFormat() |
ExprEvaluator |
ExprTypeofNode.getExprEvaluator() |
ExprEvaluator |
ExprPropertyExistsNode.getExprEvaluator() |
ExprEvaluator |
ExprPlugInSingleRowNode.getExprEvaluator() |
ExprEvaluator |
ExprMinMaxRowNode.getExprEvaluator() |
ExprEvaluator |
ExprIStreamNode.getExprEvaluator() |
ExprEvaluator |
ExprInstanceofNode.getExprEvaluator() |
ExprEvaluator |
ExprCoalesceNode.getExprEvaluator() |
ExprEvaluator |
ExprCastNode.getExprEvaluator() |
ExprEvaluator |
ExprCaseNode.getExprEvaluator() |
Modifier and Type | Class and Description |
---|---|
class |
ExprAvedevNode
Represents the avedev(...) aggregate function is an expression tree.
|
class |
ExprAvgNode
Represents the avg(...) aggregate function is an expression tree.
|
class |
ExprCountEverNode
Represents the "countever" aggregate function is an expression tree.
|
class |
ExprCountNode
Represents the count(...) and count(*) and count(distinct ...) aggregate function is an expression tree.
|
class |
ExprFirstEverNode
Represents the "firstever" aggregate function is an expression tree.
|
class |
ExprLastEverNode
Represents the "lastever" aggregate function is an expression tree.
|
class |
ExprLeavingAggNode
Represents the leaving() aggregate function is an expression tree.
|
class |
ExprMedianNode
Represents the median(...) aggregate function is an expression tree.
|
class |
ExprMinMaxAggrNode
Represents the min/max(distinct? ...) aggregate function is an expression tree.
|
class |
ExprNthAggNode
Represents the nth(...) and aggregate function is an expression tree.
|
class |
ExprPlugInAggNode
Represents a custom aggregation function in an expresson tree.
|
class |
ExprRateAggNode
Represents the rate(...) and aggregate function is an expression tree.
|
class |
ExprStddevNode
Represents the stddev(...) aggregate function is an expression tree.
|
class |
ExprSumNode
Represents the sum(...) aggregate function is an expression tree.
|
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
ExprMethodAggUtil.getDefaultEvaluator(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
static ExprEvaluator |
ExprMethodAggUtil.getMultiNodeEvaluator(ExprNode[] childNodes,
boolean join,
EventType[] typesPerStream) |
Modifier and Type | Interface and Description |
---|---|
interface |
ExprAndNode
Represents an And-condition.
|
interface |
ExprBetweenNode
Represents the between-clause function in an expression tree.
|
interface |
ExprInNode
Represents the in-clause (set check) function in an expression tree.
|
interface |
ExprRelationalOpNode
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprAndNodeImpl
Represents an And-condition.
|
class |
ExprArrayNode
Represents an array in a filter expressiun tree.
|
class |
ExprBetweenNodeImpl
Represents the between-clause function in an expression tree.
|
class |
ExprBitWiseNode
Represents the bit-wise operators in an expression tree.
|
class |
ExprConcatNodeEvalThreadLocal |
class |
ExprConcatNodeEvalWNew |
class |
ExprEqualsAllAnyNode
Represents an equals-for-group (= ANY/ALL/SOME (expression list)) comparator in a expression tree.
|
static class |
ExprEqualsNodeImpl.ExprEqualsEvaluatorCoercing |
static class |
ExprEqualsNodeImpl.ExprEqualsEvaluatorEquals |
static class |
ExprEqualsNodeImpl.ExprEqualsEvaluatorIs |
class |
ExprInNodeImpl
Represents the in-clause (set check) function in an expression tree.
|
class |
ExprLikeNode
Represents the like-clause in an expression tree.
|
class |
ExprMathNode
Represents a simple Math (+/-/divide/*) in a filter expression tree.
|
class |
ExprNewInstanceNode
Represents the "new Class(...)" operator in an expression tree.
|
class |
ExprNewStructNode
Represents the "new {...}" operator in an expression tree.
|
class |
ExprNotNode
Represents a NOT expression in an expression tree.
|
class |
ExprOrNode
Represents an OR expression in a filter expression tree.
|
class |
ExprRegexpNode
Represents the regexp-clause in an expression tree.
|
class |
ExprRelationalOpAllAnyNode
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
class |
ExprRelationalOpNodeImpl
Represents a lesser or greater then (</<=/>/>=) expression in a filter expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprRelationalOpNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprRelationalOpAllAnyNode.getExprEvaluator() |
ExprEvaluator |
ExprRegexpNode.getExprEvaluator() |
ExprEvaluator |
ExprOrNode.getExprEvaluator() |
ExprEvaluator |
ExprNotNode.getExprEvaluator() |
ExprEvaluator |
ExprNewStructNode.getExprEvaluator() |
ExprEvaluator |
ExprNewInstanceNode.getExprEvaluator() |
ExprEvaluator |
ExprMathNode.getExprEvaluator() |
ExprEvaluator |
ExprLikeNode.getExprEvaluator() |
ExprEvaluator |
ExprInNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprEqualsNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprEqualsAllAnyNode.getExprEvaluator() |
ExprEvaluator |
ExprConcatNode.getExprEvaluator() |
ExprEvaluator |
ExprBitWiseNode.getExprEvaluator() |
ExprEvaluator |
ExprBetweenNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprArrayNode.getExprEvaluator() |
ExprEvaluator |
ExprAndNodeImpl.getExprEvaluator() |
Modifier and Type | Method and Description |
---|---|
protected static String |
ExprConcatNodeEvalWNew.evaluate(EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context,
StringBuffer buffer,
ExprEvaluator[] evaluators,
ExprConcatNode parent) |
Constructor and Description |
---|
ExprConcatNodeEvalThreadLocal(ExprConcatNode parent,
ExprEvaluator[] evaluators) |
ExprConcatNodeEvalWNew(ExprConcatNode parent,
ExprEvaluator[] evaluators) |
ExprEqualsEvaluatorCoercing(ExprEqualsNodeImpl parent,
ExprEvaluator lhs,
ExprEvaluator rhs,
SimpleNumberCoercer numberCoercerLHS,
SimpleNumberCoercer numberCoercerRHS) |
ExprEqualsEvaluatorEquals(ExprEqualsNodeImpl parent,
ExprEvaluator lhs,
ExprEvaluator rhs) |
ExprEqualsEvaluatorIs(ExprEqualsNodeImpl parent,
ExprEvaluator lhs,
ExprEvaluator rhs) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPreviousMatchRecognizeNode
Represents the 'prev' previous event function in match-recognize "define" item.
|
class |
ExprPreviousNode
Represents the 'prev' previous event function in an expression node tree.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprPreviousNode.getExprEvaluator() |
ExprEvaluator |
ExprPreviousMatchRecognizeNode.getExprEvaluator() |
Constructor and Description |
---|
ExprPreviousEvalStrategyPrev(int streamNumber,
ExprEvaluator indexNode,
ExprEvaluator evalNode,
RandomAccessByIndexGetter randomAccessGetter,
RelativeAccessByEventNIndexGetter relativeAccessGetter,
boolean constantIndex,
Integer constantIndexNumber,
boolean tail) |
ExprPreviousEvalStrategyWindow(int streamNumber,
ExprEvaluator evalNode,
Class componentType,
RandomAccessByIndexGetter randomAccessGetter,
RelativeAccessByEventNIndexGetter relativeAccessGetter) |
Modifier and Type | Class and Description |
---|---|
class |
ExprPriorNode
Represents the 'prior' prior event function in an expression node tree.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprPriorNode.getExprEvaluator() |
ExprEvaluator |
ExprPriorNode.getInnerEvaluator() |
Modifier and Type | Method and Description |
---|---|
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 | Class and Description |
---|---|
class |
ExprSubselectAllSomeAnyNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectExistsNode
Represents an exists-subselect in an expression tree.
|
class |
ExprSubselectInNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectNode
Represents a subselect in an expression tree.
|
class |
ExprSubselectRowNode
Represents a subselect in an expression tree.
|
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
ExprSubselectNode.filterExpr
The validate filter expression.
|
protected ExprEvaluator |
ExprSubselectNode.havingExpr
The validated having expression.
|
protected ExprEvaluator[] |
ExprSubselectNode.selectClauseEvaluator |
protected ExprEvaluator |
SubselectEvalStrategyNRBase.selectEval |
protected ExprEvaluator |
SubselectEvalStrategyNRBase.valueEval |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprSubselectNode.getExprEvaluator() |
ExprEvaluator |
ExprSubselectNode.getFilterExpr()
Returns filter expr or null if none.
|
ExprEvaluator |
ExprSubselectNode.getHavingExpr() |
Modifier and Type | Method and Description |
---|---|
void |
ExprSubselectNode.setFilterExpr(ExprEvaluator filterExpr)
Sets the validated filter expression, or null if there is none.
|
void |
ExprSubselectNode.setHavingExpr(ExprEvaluator havingExpr) |
Modifier and Type | Class and Description |
---|---|
class |
ExprTableAccessNodeKeys |
class |
ExprTableAccessNodeSubprop |
class |
ExprTableAccessNodeSubpropAccessor |
class |
ExprTableAccessNodeTopLevel |
class |
ExprTableIdentNodeSubpropAccessor |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
ExprTableAccessNode.groupKeyEvaluators |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprTableIdentNodeSubpropAccessor.getExprEvaluator() |
ExprEvaluator |
ExprTableIdentNode.getExprEvaluator() |
ExprEvaluator |
ExprTableAccessNodeTopLevel.getExprEvaluator() |
ExprEvaluator |
ExprTableAccessNodeSubpropAccessor.getExprEvaluator() |
ExprEvaluator |
ExprTableAccessNodeSubprop.getExprEvaluator() |
ExprEvaluator |
ExprTableAccessNodeKeys.getExprEvaluator() |
ExprEvaluator[] |
ExprTableAccessNode.getGroupKeyEvaluators() |
Modifier and Type | Method and Description |
---|---|
void |
ExprTableIdentNode.setEval(ExprEvaluator eval) |
Modifier and Type | Class and Description |
---|---|
class |
ExprTimePeriodImpl
Expression representing a time period.
|
class |
ExprTimestampNode
Represents the CURRENT_TIMESTAMP() function or reserved keyword in an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
ExprTimePeriodImpl.getEvaluators() |
ExprEvaluator |
ExprTimestampNode.getExprEvaluator() |
ExprEvaluator |
ExprTimePeriodImpl.getExprEvaluator() |
Constructor and Description |
---|
ExprTimePeriodEvalDeltaConstFactoryMsec(ExprEvaluator secondsEvaluator,
TimeAbacus timeAbacus) |
Modifier and Type | Class and Description |
---|---|
static class |
EngineImportApplicationDotMethodPointInsideRectange.PointIntersectsRectangleEvaluator |
static class |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.RectangleIntersectsRectangleEvaluator |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
EngineImportApplicationDotMethodBase.getExprEvaluator() |
ExprEvaluator |
SubordTableLookupStrategyFactoryQuadTree.getHeight() |
ExprEvaluator |
AdvancedIndexConfigStatementMXCIFQuadtree.getHeightEval() |
ExprEvaluator |
SubordTableLookupStrategyFactoryQuadTree.getWidth() |
ExprEvaluator |
AdvancedIndexConfigStatementMXCIFQuadtree.getWidthEval() |
ExprEvaluator |
SubordTableLookupStrategyFactoryQuadTree.getX() |
ExprEvaluator |
AdvancedIndexConfigStatementPointRegionQuadtree.getxEval() |
ExprEvaluator |
AdvancedIndexConfigStatementMXCIFQuadtree.getxEval() |
ExprEvaluator |
SubordTableLookupStrategyFactoryQuadTree.getY() |
ExprEvaluator |
AdvancedIndexConfigStatementPointRegionQuadtree.getyEval() |
ExprEvaluator |
AdvancedIndexConfigStatementMXCIFQuadtree.getyEval() |
protected ExprEvaluator |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected ExprEvaluator |
EngineImportApplicationDotMethodPointInsideRectange.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
protected abstract ExprEvaluator |
EngineImportApplicationDotMethodBase.validateAll(String lhsName,
ExprNode[] lhs,
String rhsName,
ExprNode[] rhs,
ExprValidationContext validationContext) |
Modifier and Type | Method and Description |
---|---|
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) |
Constructor and Description |
---|
AdvancedIndexConfigStatementMXCIFQuadtree(ExprEvaluator xEval,
ExprEvaluator yEval,
ExprEvaluator widthEval,
ExprEvaluator heightEval) |
AdvancedIndexConfigStatementPointRegionQuadtree(ExprEvaluator xEval,
ExprEvaluator yEval) |
RectangleIntersectsRectangleEvaluator(ExprEvaluator meXEval,
ExprEvaluator meYEval,
ExprEvaluator meWidthEval,
ExprEvaluator meHeightEval,
ExprEvaluator otherXEval,
ExprEvaluator otherYEval,
ExprEvaluator otherWidthEval,
ExprEvaluator otherHeightEval) |
SubordTableLookupStrategyFactoryQuadTree(ExprEvaluator x,
ExprEvaluator y,
ExprEvaluator width,
ExprEvaluator height,
boolean isNWOnTrigger,
int streamCountOuter,
LookupStrategyDesc lookupStrategyDesc) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
EventAdvancedIndexProvisionDesc.getParameters() |
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) |
Constructor and Description |
---|
EventAdvancedIndexProvisionDesc(AdvancedIndexDesc indexDesc,
ExprEvaluator[] parameters,
EventAdvancedIndexFactory factory,
EventAdvancedIndexConfigStatement configStatement) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
JoinSetComposerDesc.getPostJoinFilterEvaluator() |
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.
|
Constructor and Description |
---|
HistoricalDataQueryStrategy(int myStreamNumber,
int historicalStreamNumber,
HistoricalEventViewable historicalEventViewable,
boolean isOuterJoin,
ExprEvaluator outerJoinCompareNode,
HistoricalIndexLookupStrategy indexLookupStrategy,
PollResultIndexingStrategy pollResultIndexingStrategy)
Ctor.
|
JoinSetComposerDesc(JoinSetComposer joinSetComposer,
ExprEvaluator postJoinFilterEvaluator) |
JoinSetFilter(ExprEvaluator filterExprNode)
Ctor.
|
Constructor and Description |
---|
HistoricalTableLookupStrategy(HistoricalEventViewable viewable,
PollResultIndexingStrategy indexingStrategy,
HistoricalIndexLookupStrategy lookupStrategy,
int numStreams,
int streamNum,
int rootStreamNum,
ExprEvaluator outerJoinExprNode)
Ctor.
|
IndexedTableLookupStrategyExpr(ExprEvaluator[] evaluators,
int streamNum,
PropertyIndexedEventTable index,
LookupStrategyDesc lookupStrategyDesc) |
InKeywordMultiTableLookupStrategyExpr(ExprEvaluator evaluator,
int streamNum,
PropertyIndexedEventTableSingle[] indexes,
LookupStrategyDesc lookupStrategyDesc) |
InKeywordSingleTableLookupStrategyExpr(ExprEvaluator[] evaluators,
int streamNum,
PropertyIndexedEventTableSingle index,
LookupStrategyDesc lookupStrategyDesc) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
CompositeAccessStrategyRangeBase.end |
protected ExprEvaluator |
CompositeAccessStrategyRelOpBase.key |
protected ExprEvaluator |
CompositeAccessStrategyRangeBase.start |
Constructor and Description |
---|
CompositeAccessStrategyGE(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator key,
Class coercionType) |
CompositeAccessStrategyGT(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator key,
Class coercionType) |
CompositeAccessStrategyLE(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator key,
Class coercionType) |
CompositeAccessStrategyLT(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator key,
Class coercionType) |
CompositeAccessStrategyRangeBase(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator start,
boolean includeStart,
ExprEvaluator end,
boolean includeEnd,
Class coercionType) |
CompositeAccessStrategyRangeInverted(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator start,
boolean includeStart,
ExprEvaluator end,
boolean includeEnd,
Class coercionType) |
CompositeAccessStrategyRangeNormal(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator start,
boolean includeStart,
ExprEvaluator end,
boolean includeEnd,
Class coercionType,
boolean allowReverseRange) |
CompositeAccessStrategyRelOpBase(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator key,
Class coercionType) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
SortedAccessStrategyRangeBase.end |
protected ExprEvaluator |
SortedAccessStrategyRangeBase.start |
Constructor and Description |
---|
SortedAccessStrategyGE(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator keyEval) |
SortedAccessStrategyGT(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator keyEval) |
SortedAccessStrategyLE(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator keyEval) |
SortedAccessStrategyLT(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator keyEval) |
SortedAccessStrategyRange(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator start,
boolean includeStart,
ExprEvaluator end,
boolean includeEnd,
boolean allowRangeReversal) |
SortedAccessStrategyRangeBase(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator start,
boolean includeStart,
ExprEvaluator end,
boolean includeEnd) |
SortedAccessStrategyRangeInverted(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator start,
boolean includeStart,
ExprEvaluator end,
boolean includeEnd) |
SortedAccessStrategyRelOpBase(boolean isNWOnTrigger,
int lookupStream,
int numStreams,
ExprEvaluator keyEval) |
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
ExcludePlanHintExprUtil.toExpression(String hint,
StatementContext statementContext) |
Constructor and Description |
---|
ExcludePlanHint(String[] streamNames,
List<ExprEvaluator> evaluators,
StatementContext statementContext) |
Modifier and Type | Method and Description |
---|---|
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 | Field and Description |
---|---|
protected ExprEvaluator |
SubordInKeywordMultiTableLookupStrategyNW.evaluator |
protected ExprEvaluator |
SubordInKeywordMultiTableLookupStrategyFactory.evaluator |
protected ExprEvaluator |
SubordInKeywordMultiTableLookupStrategy.evaluator |
protected ExprEvaluator |
SubordIndexedTableLookupStrategySingleExprNW.evaluator
Stream numbers to get key values from.
|
protected ExprEvaluator |
SubordIndexedTableLookupStrategySingleExprFactory.evaluator |
protected ExprEvaluator |
SubordIndexedTableLookupStrategySingleExpr.evaluator
Stream numbers to get key values from.
|
protected ExprEvaluator[] |
SubordInKeywordSingleTableLookupStrategyNW.evaluators |
protected ExprEvaluator[] |
SubordInKeywordSingleTableLookupStrategyFactory.evaluators |
protected ExprEvaluator[] |
SubordInKeywordSingleTableLookupStrategy.evaluators
Stream numbers to get key values from.
|
protected ExprEvaluator[] |
SubordIndexedTableLookupStrategyExprNW.evaluators |
protected ExprEvaluator[] |
SubordIndexedTableLookupStrategyExprFactory.evaluators |
protected ExprEvaluator[] |
SubordIndexedTableLookupStrategyExpr.evaluators |
Modifier and Type | Method and Description |
---|---|
AdvancedIndexConfigContextPartition |
EventAdvancedIndexFactory.configureContextPartition(EventType eventType,
AdvancedIndexDesc indexDesc,
ExprEvaluator[] parameters,
ExprEvaluatorContext exprEvaluatorContext,
EventTableOrganization organization,
EventAdvancedIndexConfigStatement advancedIndexConfigStatement) |
Constructor and Description |
---|
NamedWindowConsumerView(ExprEvaluator[] filterList,
PropertyEvaluator optPropertyEvaluator,
EventType eventType,
NamedWindowConsumerCallback consumerCallback,
ExprEvaluatorContext exprEvaluatorContext,
boolean audit) |
NamedWindowOnMergeAction(ExprEvaluator optionalFilter) |
NamedWindowOnMergeActionDel(ExprEvaluator optionalFilter) |
NamedWindowOnMergeActionIns(ExprEvaluator optionalFilter,
SelectExprProcessor insertHelper,
InternalEventRouter internalEventRouter,
String insertIntoTableName,
TableService tableService,
EPStatementHandle statementHandle,
InternalEventRouteDest internalEventRouteDest,
boolean audit) |
NamedWindowOnMergeActionUpd(ExprEvaluator optionalFilter,
EventBeanUpdateHelper updateHelper) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
PropertyEvaluatorSimple.getFilter()
Returns the filter.
|
Constructor and Description |
---|
ContainedEventEvalArrayToEvent(ExprEvaluator evaluator,
EventBeanManufacturer manufacturer) |
ContainedEventEvalEventBeanArray(ExprEvaluator evaluator) |
ContainedEventEvalExprNode(ExprEvaluator evaluator,
EventBeanFactory eventBeanFactory) |
PropertyEvaluatorAccumulative(ContainedEventEval[] containedEventEvals,
FragmentEventType[] fragmentEventType,
ExprEvaluator[] whereClauses,
List<String> propertyNames)
Ctor.
|
PropertyEvaluatorNested(ContainedEventEval[] containedEventEvals,
FragmentEventType[] fragmentEventType,
ExprEvaluator[] whereClauses,
List<String> expressionTexts)
Ctor.
|
PropertyEvaluatorSimple(ContainedEventEval containedEventEval,
FragmentEventType fragmentEventType,
ExprEvaluator filter,
String expressionText)
Ctor.
|
Modifier and Type | Interface and Description |
---|---|
interface |
ExprNodeScriptEvaluator |
Modifier and Type | Class and Description |
---|---|
class |
ExprNodeScriptEvalBase |
class |
ExprNodeScriptEvalJSR223 |
class |
ExprNodeScriptEvalMVEL |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
ExprNodeScriptEvalBase.parameters |
Constructor and Description |
---|
ExprNodeScriptEvalBase(String scriptName,
String statementName,
String[] names,
ExprEvaluator[] parameters,
Class returnType,
EventType eventTypeCollection) |
ExprNodeScriptEvalJSR223(String scriptName,
String statementName,
String[] names,
ExprEvaluator[] parameters,
Class returnType,
EventType eventTypeCollection,
CompiledScript executable) |
ExprNodeScriptEvalMVEL(String scriptName,
String statementName,
String[] names,
ExprEvaluator[] parameters,
Class returnType,
EventType eventTypeCollection,
Object executable) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
SubselectAggregationPreprocessorBase.filterEval |
protected ExprEvaluator[] |
SubselectAggregatorViewBase.groupKeys |
protected ExprEvaluator[] |
SubselectAggregationPreprocessorBase.groupKeys |
protected ExprEvaluator |
SubselectAggregatorViewBase.optionalFilterExpr |
Constructor and Description |
---|
TableOnMergeAction(ExprEvaluator optionalFilter) |
TableOnMergeActionDel(ExprEvaluator optionalFilter) |
TableOnMergeActionIns(ExprEvaluator optionalFilter,
SelectExprProcessor insertHelper,
InternalEventRouter internalEventRouter,
EPStatementHandle statementHandle,
InternalEventRouteDest internalEventRouteDest,
boolean audit,
TableStateRowFactory tableStateRowFactory) |
TableOnMergeActionUpd(ExprEvaluator optionalFilter,
TableUpdateStrategy tableUpdateStrategy) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
TableColumnMethodPair.getEvaluator() |
Constructor and Description |
---|
TableColumnMethodPair(ExprEvaluator evaluator,
int targetIndex,
ExprNode aggregationNode) |
TableStateViewableInternal(TableMetadata tableMetadata,
TableStateInstance tableStateInstance,
ExprEvaluator[] optionalTableFilters) |
Modifier and Type | Class and Description |
---|---|
class |
ExprTableExprEvaluatorAccess |
class |
ExprTableExprEvaluatorMethod |
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
ExprTableEvalStrategyFactory.getTableAccessEvalStrategy(ExprNode exprNode,
String tableName,
Integer streamNum,
TableMetadataColumnAggregation agg) |
Modifier and Type | Method and Description |
---|---|
protected static MultiKeyUntyped |
ExprTableEvalStrategyGroupByAccessMulti.getKey(ExprEvaluator[] evaluators,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
EventBeanUpdateItem.getExpression() |
Constructor and Description |
---|
EventBeanUpdateItem(ExprEvaluator expression,
String optinalPropertyName,
EventPropertyWriter optionalWriter,
boolean notNullableField,
TypeWidener optionalWidener) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
OutputConditionCrontabFactory.scheduleSpecEvaluators |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
OutputConditionExpressionFactory.getAndWhenTerminatedExpressionNodeEval() |
ExprEvaluator |
OutputConditionPolledExpressionFactory.getWhenExpressionNode() |
ExprEvaluator |
OutputConditionExpressionFactory.getWhenExpressionNodeEval() |
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 |
---|---|
static MultiKeyUntyped |
EventBeanUtility.getMultiKey(EventBean[] eventsPerStream,
ExprEvaluator[] evaluators,
ExprEvaluatorContext context,
Class[] coercionTypes) |
Modifier and Type | Method and Description |
---|---|
static Pair<net.sf.cglib.reflect.FastConstructor,ExprEvaluator[]> |
InstanceManufacturerUtil.getManufacturer(Class targetClass,
EngineImportService engineImportService,
ExprEvaluator[] exprEvaluators,
Object[] expressionReturnTypes) |
Constructor and Description |
---|
InstanceManufacturerFastCtor(Class targetClass,
net.sf.cglib.reflect.FastConstructor ctor,
ExprEvaluator[] expr) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
ExprNodeAdapterBase.exprNodeEval |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentationDefault.qSplitStream(boolean all,
EventBean theEvent,
ExprEvaluator[] whereClauses) |
void |
Instrumentation.qSplitStream(boolean all,
EventBean theEvent,
ExprEvaluator[] whereClauses) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
EvalEveryDistinctFactoryNode.distinctExpressionsArray |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
EvalEveryDistinctFactoryNode.getDistinctExpressionsArray() |
Modifier and Type | Method and Description |
---|---|
static Object |
PatternExpressionUtil.getKeys(MatchedEventMap matchEvent,
MatchedEventConvertor convertor,
ExprEvaluator[] expressions,
AgentInstanceContext agentInstanceContext) |
Constructor and Description |
---|
ExpressionGuard(MatchedEventConvertor convertor,
ExprEvaluator expression,
Quitable quitable) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
RegexPartitionStateRepoGroupMeta.getPartitionExpressions() |
Constructor and Description |
---|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
ComputerBigDecCoerce(ExprEvaluator[] childNodes,
SimpleNumberBigDecimalCoercer[] convertors,
boolean isMax)
Ctor.
|
ComputerBigIntCoerce(ExprEvaluator[] childNodes,
SimpleNumberBigIntegerCoercer[] convertors,
boolean isMax)
Ctor.
|
MaxComputerDoubleCoerce(ExprEvaluator[] childNodes)
Ctor.
|
MinComputerDoubleCoerce(ExprEvaluator[] childNodes)
Ctor.
|
Modifier and Type | Method and Description |
---|---|
static Comparator<Object> |
CollectionUtil.getComparator(ExprEvaluator[] sortCriteriaEvaluators,
boolean isSortUsingCollator,
boolean[] isDescendingValues) |
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
ViewFactorySupport.validateSizeParam(String viewName,
StatementContext statementContext,
ExprNode sizeNode,
int expressionNumber) |
static ExprEvaluator |
ViewFactorySupport.validateSizeSingleParam(String viewName,
ViewFactoryContext viewFactoryContext,
List<ExprNode> expressionParameters) |
Modifier and Type | Method and Description |
---|---|
static Object |
ViewFactorySupport.evaluate(ExprEvaluator evaluator,
int expressionNumber,
String viewName,
StatementContext statementContext) |
static int |
ViewFactorySupport.evaluateSizeParam(String viewName,
ExprEvaluator sizeEvaluator,
AgentInstanceContext context) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
SortWindowViewFactory.sizeEvaluator
The sort window size.
|
protected ExprEvaluator |
RankWindowViewFactory.sizeEvaluator
The sort window size.
|
protected ExprEvaluator[] |
SortWindowViewFactory.sortCriteriaEvaluators |
protected ExprEvaluator[] |
SortWindowView.sortCriteriaEvaluators |
protected ExprEvaluator[] |
RankWindowView.sortCriteriaEvaluators |
protected ExprEvaluator[] |
RankWindowViewFactory.sortEvals |
protected ExprEvaluator |
TimeToLiveViewFactory.timestampExpressionEvaluator |
protected ExprEvaluator |
TimeOrderViewFactory.timestampExpressionEvaluator |
protected ExprEvaluator[] |
RankWindowView.uniqueCriteriaEvaluators |
protected ExprEvaluator[] |
RankWindowViewFactory.uniqueEvals |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
SortWindowViewFactory.getSortCriteriaEvaluators() |
ExprEvaluator[] |
RankWindowViewFactory.getSortEvals() |
ExprEvaluator |
TimeToLiveViewFactory.getTimestampExpressionEvaluator() |
ExprEvaluator |
TimeOrderViewFactory.getTimestampExpressionEvaluator() |
ExprEvaluator[] |
RankWindowViewFactory.getUniqueEvals() |
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) |
Constructor and Description |
---|
RankWindowView(RankWindowViewFactory rankWindowViewFactory,
ExprNode[] uniqueCriteriaExpressions,
ExprEvaluator[] uniqueCriteriaEvaluators,
ExprNode[] sortCriteriaExpressions,
ExprEvaluator[] sortCriteriaEvaluators,
boolean[] descendingValues,
int sortWindowSize,
IStreamSortRankRandomAccess optionalRankedRandomAccess,
boolean isSortUsingCollator,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
RankWindowView(RankWindowViewFactory rankWindowViewFactory,
ExprNode[] uniqueCriteriaExpressions,
ExprEvaluator[] uniqueCriteriaEvaluators,
ExprNode[] sortCriteriaExpressions,
ExprEvaluator[] sortCriteriaEvaluators,
boolean[] descendingValues,
int sortWindowSize,
IStreamSortRankRandomAccess optionalRankedRandomAccess,
boolean isSortUsingCollator,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
SortWindowView(SortWindowViewFactory sortWindowViewFactory,
ExprNode[] sortCriteriaExpressions,
ExprEvaluator[] sortCriteriaEvaluators,
boolean[] descendingValues,
int sortWindowSize,
IStreamSortRankRandomAccess optionalSortedRandomAccess,
boolean isSortUsingCollator,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext) |
TimeOrderView(AgentInstanceViewFactoryChainContext agentInstanceContext,
ViewFactory viewFactory,
ExprNode timestampExpr,
ExprEvaluator timestampEvaluator,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
IStreamSortRankRandomAccess optionalSortedRandomAccess) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
RouteResultViewHandlerBase.whereClauses |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
StatViewAdditionalProps.getAdditionalExpr() |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
UniqueByPropertyView.criteriaExpressionsEvals |
protected ExprEvaluator[] |
FirstUniqueByPropertyView.uniqueCriteriaEval |
Constructor and Description |
---|
GroupByViewImpl(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] criteriaExpressions,
ExprEvaluator[] criteriaEvaluators)
Constructor.
|
GroupByViewReclaimAged(AgentInstanceViewFactoryChainContext agentInstanceContext,
ExprNode[] criteriaExpressions,
ExprEvaluator[] criteriaEvaluators,
double reclaimMaxAgeSeconds,
double reclaimFrequencySeconds)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
ExpressionViewBase.expiryExpression |
protected ExprEvaluator |
ExpressionViewFactoryBase.expiryExpressionEvaluator |
protected ExprEvaluator |
TimeLengthBatchViewFactory.sizeEvaluator
Number of events to collect before batch fires.
|
protected ExprEvaluator |
LengthWindowViewFactory.sizeEvaluator
Size of length window.
|
protected ExprEvaluator |
LengthBatchViewFactory.sizeEvaluator
The length window size.
|
protected ExprEvaluator |
FirstLengthWindowViewFactory.sizeEvaluator
Size of length first window.
|
protected ExprEvaluator |
ExternallyTimedWindowViewFactory.timestampExpressionEval |
protected ExprEvaluator |
ExternallyTimedBatchViewFactory.timestampExpressionEval |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExpressionViewFactoryBase.getExpiryExpressionEvaluator() |
ExprEvaluator |
ExternallyTimedWindowViewFactory.getTimestampExpressionEval() |
ExprEvaluator |
ExternallyTimedBatchViewFactory.getTimestampExpressionEval() |
Constructor and Description |
---|
ExpressionBatchView(ExpressionBatchViewFactory dataWindowViewFactory,
ViewUpdatedCollection viewUpdatedCollection,
ExprEvaluator expiryExpression,
AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
ObjectArrayEventBean builtinEventProps,
Set<String> variableNames,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
ExpressionViewBase(ViewUpdatedCollection viewUpdatedCollection,
ExprEvaluator expiryExpression,
AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
ObjectArrayEventBean builtinEventProps,
Set<String> variableNames,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
ExpressionWindowView(ExpressionWindowViewFactory dataWindowViewFactory,
ViewUpdatedCollection viewUpdatedCollection,
ExprEvaluator expiryExpression,
AggregationServiceFactoryDesc aggregationServiceFactoryDesc,
ObjectArrayEventBean builtinEventProps,
Set<String> variableNames,
AgentInstanceViewFactoryChainContext agentInstanceContext) |
ExternallyTimedBatchView(ExternallyTimedBatchViewFactory factory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
Long optionalReferencePoint,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|
ExternallyTimedWindowView(ExternallyTimedWindowViewFactory externallyTimedWindowViewFactory,
ExprNode timestampExpression,
ExprEvaluator timestampExpressionEval,
ExprTimePeriodEvalDeltaConst timeDeltaComputation,
ViewUpdatedCollection viewUpdatedCollection,
AgentInstanceViewFactoryChainContext agentInstanceViewFactoryContext)
Constructor.
|