Package | Description |
---|---|
com.espertech.esper.codegen.compile |
Code-Generation Compiler
|
com.espertech.esper.codegen.model.blocks |
Code-Generation Reusable Code Blocks
|
com.espertech.esper.collection |
Internal collection classes
|
com.espertech.esper.core.context.activator |
Activation of streams for statement start.
|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
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.datetime.reformatop |
Date-Time re-formatting operations.
|
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.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
|
Modifier and Type | Method and Description |
---|---|
static ExprEvaluator |
CodegenExprEvaluator.compile(String engineURI,
EngineImportService engineImportService,
CodegenExpression expression,
CodegenContext codegenContext,
Class returnType,
Supplier<String> debugInformationProvider) |
Modifier and Type | Method and Description |
---|---|
static CodegenExpression |
CodegenLegoEvaluateSelf.evaluateSelfPlainWithCast(ExprEvaluator provider,
Class returnType,
CodegenParamSetExprPremade params,
CodegenContext context) |
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) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
StatementAgentInstanceFactoryCreateWindow.createWindowInsertFilter |
protected ExprEvaluator |
StatementAgentInstanceFactorySelect.filterRootNodeEvaluator |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
ContextControllerInitTermFactoryImpl.getDistinctEvaluators() |
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
|
ExprEvaluator |
InternalEventRouterDesc.getOptionalWhereClauseEval() |
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.
|
Constructor and Description |
---|
InternalEventRouterEntry(int priority,
boolean drop,
ExprEvaluator optionalWhereClause,
ExprNode[] assignments,
EventBeanWriter writer,
TypeWidener[] wideners,
InternalRoutePreprocessView outputView,
StatementAgentInstanceLock agentInstanceLock,
boolean hasSubselect)
Ctor.
|
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) |
Constructor and Description |
---|
AggregationAccessorFirstLastIndexNoEval(ExprEvaluator indexNode,
int constant,
boolean first) |
AggregationAccessorFirstLastIndexWEval(int streamNum,
ExprEvaluator childNode,
ExprEvaluator indexNode,
int constant,
boolean isFirst)
Ctor.
|
AggregationAccessorFirstWEval(int streamNum,
ExprEvaluator childNode)
Ctor.
|
AggregationAccessorLastWEval(int streamNum,
ExprEvaluator childNode)
Ctor.
|
AggregationAccessorWindowWEval(int streamNum,
ExprEvaluator childNode,
Class componentType)
Ctor.
|
AggregationAgentDefaultWFilter(ExprEvaluator filterEval) |
AggregationAgentRewriteStreamWFilter(int streamNum,
ExprEvaluator filterEval) |
AggregationStateLinearJoinWFilter(int streamId,
ExprEvaluator filterEval) |
AggregationStateLinearWFilter(int streamId,
ExprEvaluator filter) |
AggregationStateMinMaxByEverSpec(int streamId,
ExprEvaluator[] criteria,
Class[] criteriaTypes,
boolean max,
Comparator<Object> comparator,
Object criteriaKeyBinding,
ExprEvaluator optionalFilter) |
AggregationStateMinMaxByEverSpec(int streamId,
ExprEvaluator[] criteria,
Class[] criteriaTypes,
boolean max,
Comparator<Object> comparator,
Object criteriaKeyBinding,
ExprEvaluator optionalFilter) |
AggregationStateSortedSpec(int streamId,
ExprEvaluator[] criteria,
Class[] criteriaTypes,
Comparator<Object> comparator,
Object criteriaKeyBinding,
ExprEvaluator optionalFilter) |
AggregationStateSortedSpec(int streamId,
ExprEvaluator[] criteria,
Class[] criteriaTypes,
Comparator<Object> comparator,
Object criteriaKeyBinding,
ExprEvaluator optionalFilter) |
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,
EngineImportService engineImportService,
boolean fireAndForget,
String statementName) |
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,
Class[] partitionEvaluatorsTypes,
boolean defaultLevel) |
AggregationLocalGroupByLevel(ExprEvaluator[] methodEvaluators,
AggregationMethodFactory[] methodFactories,
AggregationStateFactory[] stateFactories,
ExprEvaluator[] partitionEvaluators,
Class[] partitionEvaluatorsTypes,
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 | Field and Description |
---|---|
protected ExprEvaluator |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeExpressionCoerceBase.exprEvaluator |
protected ExprEvaluator[] |
SelectExprInsertEventBeanFactory.SelectExprInsertNativeBase.exprEvaluators |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
OrderByElement.getExpr() |
ExprEvaluator |
SelectExprProcessorTypableSingleForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorTypableMultiForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorTypableMapForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEvalStreamInsertUnd.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEvalStreamInsertTable.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEvalStreamInsertNamedWindow.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEvalByGetterFragment.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEvalByGetter.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEnumerationSingleToCollForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEnumerationCollForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEnumerationAtBeanSingleForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEnumerationAtBeanCollTableForge.getExprEvaluator() |
ExprEvaluator |
SelectExprProcessorEnumerationAtBeanCollForge.getExprEvaluator() |
ExprEvaluator |
SelectExprInsertEventBeanFactory.ExprForgeJoinWildcard.getExprEvaluator() |
ExprEvaluator |
BindProcessorStream.getExprEvaluator() |
ExprEvaluator |
BindProcessorEvaluatorStreamTable.getExprEvaluator() |
ExprEvaluator[] |
OrderByProcessorFactoryImpl.getGroupByNodes() |
ExprEvaluator |
ResultSetProcessorRowPerGroupRollupFactory.getGroupKeyNode() |
ExprEvaluator |
ResultSetProcessorRowPerGroupFactory.getGroupKeyNode() |
ExprEvaluator |
ResultSetProcessorAggregateGroupedFactory.getGroupKeyNode() |
ExprEvaluator[] |
ResultSetProcessorRowPerGroupRollupFactory.getGroupKeyNodes() |
ExprEvaluator[] |
ResultSetProcessorRowPerGroupFactory.getGroupKeyNodes() |
ExprEvaluator[] |
ResultSetProcessorAggregateGroupedFactory.getGroupKeyNodes() |
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,
ExprForge[] forges,
String[] columnNames,
Object[] expressionReturnTypes,
EngineImportService engineImportService,
InsertIntoDesc insertIntoDesc,
String[] columnNamesAsProvided,
boolean allowNestableTargetFragmentTypes,
String statementName) |
static OrderByProcessorFactory |
OrderByProcessorFactoryFactory.getProcessor(List<SelectClauseExprCompiledSpec> selectionList,
ExprEvaluator[] groupByNodeEvals,
List<OrderByItem> orderByList,
RowLimitSpec rowLimitSpec,
VariableService variableService,
boolean isSortUsingCollator,
String optionalContextName,
EngineImportService engineImportService,
boolean onDemandQuery,
String statementName)
Returns processor for order-by clauses.
|
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.
|
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactoryImpl.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
ExprNode[] groupKeyNodeExpressions,
OutputConditionPolledFactory optionalOutputFirstConditionFactory,
AggregationGroupByRollupDesc optionalGroupByRollupDesc,
int optionalRollupLevel) |
ResultSetProcessorGroupedOutputFirstHelper |
ResultSetProcessorHelperFactory.makeRSGroupedOutputFirst(AgentInstanceContext agentInstanceContext,
ExprEvaluator[] groupKeyNodes,
ExprNode[] groupKeyNodeExpressions,
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) |
OrderByProcessorFactoryImpl(List<OrderByItem> orderByList,
ExprEvaluator[] groupByEvals,
boolean needsGroupByKeys,
boolean isSortUsingCollator,
EngineImportService engineImportService,
boolean onDemandQuery,
String statementName)
Ctor.
|
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) |
SelectExprProcessorTypableMapEval(SelectExprProcessorTypableMapForge forge,
ExprEvaluator innerEvaluator) |
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 |
CalendarWithDateForgeOp.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
protected static Integer |
CalendarOpUtil.getInt(ExprEvaluator expr,
EventBean[] eventsPerStream,
boolean isNewData,
ExprEvaluatorContext context) |
Constructor and Description |
---|
CalendarPlusMinusForgeOp(ExprEvaluator param,
int factor) |
CalendarSetForgeOp(CalendarFieldEnum fieldName,
ExprEvaluator valueExpr) |
CalendarWithDateForgeOp(ExprEvaluator year,
ExprEvaluator month,
ExprEvaluator day) |
CalendarWithTimeForgeOp(ExprEvaluator hour,
ExprEvaluator min,
ExprEvaluator sec,
ExprEvaluator msec) |
Modifier and Type | Class and Description |
---|---|
class |
ExprEvaluatorStreamDTProp |
class |
ExprEvaluatorStreamDTPropFragment |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprEvaluatorStreamDTPropFragment.getExprEvaluator() |
ExprEvaluator |
ExprEvaluatorStreamDTProp.getExprEvaluator() |
Constructor and Description |
---|
IntervalForgeOp(ExprEvaluator evaluatorTimestamp,
IntervalForgeImpl.IntervalOpEval intervalOpEval) |
IntervalOpCalWithEndEval(IntervalComputerEval intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpDateWithEndEval(IntervalComputerEval intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpEvalDateWithEndBase(IntervalComputerEval intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpLocalDateTimeWithEndEval(IntervalComputerEval intervalComputer,
ExprEvaluator evaluatorEndTimestamp,
TimeZone timeZone) |
IntervalOpLongWithEndEval(IntervalComputerEval intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
IntervalOpZonedDateTimeWithEndEval(IntervalComputerEval intervalComputer,
ExprEvaluator evaluatorEndTimestamp) |
Constructor and Description |
---|
ReformatBetweenNonConstantParamsForgeOp(ReformatBetweenNonConstantParamsForge forge,
ExprEvaluator startEval,
ExprEvaluator endEval,
ExprEvaluator evalIncludeLow,
ExprEvaluator evalIncludeHigh) |
Modifier and Type | Class and Description |
---|---|
class |
ExprDeclaredForgeBase |
class |
ExprDeclaredForgeConstant |
class |
ExprDeclaredForgeNoRewrite |
class |
ExprDeclaredForgeRewrite |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprDeclaredNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprDeclaredForgeConstant.getExprEvaluator() |
ExprEvaluator |
ExprDeclaredForgeBase.getExprEvaluator() |
Modifier and Type | Class and Description |
---|---|
class |
ExprLambdaGoesNode
Represents the case-when-then-else control flow function is an expression tree.
|
class |
PropertyDotNonLambdaForge |
class |
PropertyDotNonLambdaFragmentForge |
class |
PropertyDotNonLambdaIndexedForgeEval |
class |
PropertyDotNonLambdaMappedForgeEval |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
PropertyDotNonLambdaMappedForge.getExprEvaluator() |
ExprEvaluator |
PropertyDotNonLambdaIndexedForge.getExprEvaluator() |
ExprEvaluator |
PropertyDotNonLambdaFragmentForge.getExprEvaluator() |
ExprEvaluator |
PropertyDotNonLambdaForge.getExprEvaluator() |
ExprEvaluator |
ExprLambdaGoesNode.getExprEvaluator() |
Constructor and Description |
---|
PropertyDotNonLambdaIndexedForgeEval(PropertyDotNonLambdaIndexedForge forge,
ExprEvaluator paramEval) |
PropertyDotNonLambdaMappedForgeEval(PropertyDotNonLambdaMappedForge forge,
ExprEvaluator paramEval) |
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 |
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,
Class addOrFrequencyEvaluatorReturnType) |
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprNode[] expressions,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprEvaluator optionalFilter) |
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprNode[] expressions,
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 | Interface and Description |
---|---|
interface |
ExprIdentNodeEvaluator |
interface |
ExprTypableReturnEval
Interface for evaluators that select possible multi-valued results in a single select column,
such as subqueries and "new" and case+new combined.
|
Modifier and Type | Class and Description |
---|---|
class |
ExprConstantNodeImpl
Represents a constant in an expressiun tree.
|
class |
ExprContextPropertyNodeImpl
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 |
ExprNodeUtilExprMethodContext |
class |
ExprNodeUtilExprStreamNumEnumCollEval |
class |
ExprNodeUtilExprStreamNumEnumSingleEval |
class |
ExprNodeUtilExprStreamNumEvent |
class |
ExprNodeUtilExprStreamNumEventTable |
class |
ExprNodeUtilExprStreamNumUnd |
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 ExprEvaluator |
ExprNodeCompiler.allocateEvaluator(ExprForge forge,
EngineImportService engineImportService,
Class compiledByClass,
boolean onDemandQuery,
String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.crontabScheduleValidate(ExprNodeOrigin origin,
List<ExprNode> scheduleSpecExpressionList,
StatementContext context,
boolean allowBindingConsumption) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(ExprForge[] forges,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(ExprNode[] exprNodes,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsMayCompile(List<ExprNode> exprNodes,
EngineImportService engineImportService,
Class requestor,
boolean isFireAndForget,
String statementName) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(ExprForge[] forges) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(ExprNode[] exprNodes) |
static ExprEvaluator[] |
ExprNodeUtility.getEvaluatorsNoCompile(List<ExprNode> childNodes) |
ExprEvaluator |
ExprWildcardImpl.getExprEvaluator() |
ExprEvaluator |
ExprVariableNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprTypedNoEvalNode.getExprEvaluator() |
ExprEvaluator |
ExprSubstitutionNode.getExprEvaluator() |
ExprEvaluator |
ExprStreamUnderlyingNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprOrderedExpr.getExprEvaluator() |
ExprEvaluator |
ExprNumberSetRange.getExprEvaluator() |
ExprEvaluator |
ExprNumberSetList.getExprEvaluator() |
ExprEvaluator |
ExprNumberSetFrequency.getExprEvaluator() |
ExprEvaluator |
ExprNumberSetCronParam.getExprEvaluator() |
ExprEvaluator |
ExprNodeValidated.getExprEvaluator() |
ExprEvaluator |
ExprNodeUtilExprStreamNumUnd.getExprEvaluator() |
ExprEvaluator |
ExprNodeUtilExprStreamNumEventTable.getExprEvaluator() |
ExprEvaluator |
ExprNodeUtilExprStreamNumEvent.getExprEvaluator() |
ExprEvaluator |
ExprNodeUtilExprStreamNumEnumSingleForge.getExprEvaluator() |
ExprEvaluator |
ExprNodeUtilExprStreamNumEnumCollForge.getExprEvaluator() |
ExprEvaluator |
ExprNodeUtilExprMethodContext.getExprEvaluator() |
ExprEvaluator |
ExprNamedParameterNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprIdentNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprGroupingNode.getExprEvaluator() |
ExprEvaluator |
ExprGroupingIdNode.getExprEvaluator() |
ExprEvaluator |
ExprForge.getExprEvaluator() |
ExprEvaluator |
ExprCurrentEvaluationContextNode.getExprEvaluator() |
ExprEvaluator |
ExprContextPropertyNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprConstantNodeImpl.getExprEvaluator() |
static ExprEvaluator |
ExprNodeUtility.makeUnderlyingEvaluator(int streamNum,
Class resultType,
TableMetadata tableMetadata) |
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 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) |
Modifier and Type | Class and Description |
---|---|
class |
ExprDotNodeForgePropertyExprEvalIndexed |
class |
ExprDotNodeForgePropertyExprEvalMapped |
class |
ExprDotNodeForgeRootChildEval |
class |
ExprDotNodeForgeStaticMethodEval |
class |
ExprDotNodeForgeStreamEvalEventBean |
class |
ExprDotNodeForgeStreamEvalMethod |
class |
ExprDotNodeForgeTransposeAsStreamEval |
class |
ExprDotNodeForgeVariableEval |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
ExprDotNodeImpl.getExprEvaluator() |
ExprEvaluator |
ExprDotNodeForgeVariable.getExprEvaluator() |
ExprEvaluator |
ExprDotNodeForgeTransposeAsStream.getExprEvaluator() |
ExprEvaluator |
ExprDotNodeForgeStream.getExprEvaluator() |
ExprEvaluator |
ExprDotNodeForgeStaticMethod.getExprEvaluator() |
ExprEvaluator |
ExprDotNodeForgePropertyExpr.getExprEvaluator() |
ExprEvaluator |
ExprAppDotMethodImpl.getExprEvaluator() |
Constructor and Description |
---|
ExprDotForgeArrayGetEval(ExprDotForgeArrayGet forge,
ExprEvaluator indexExpression) |
ExprDotMethodForgeNoDuckEvalUnderlying(ExprDotMethodForgeNoDuck forge,
ExprEvaluator[] parameters) |
ExprDotMethodForgeNoDuckEvalWrapArray(ExprDotMethodForgeNoDuck forge,
ExprEvaluator[] parameters) |
ExprDotNodeForgePropertyExprEvalIndexed(ExprDotNodeForgePropertyExpr forge,
ExprEvaluator exprEvaluator) |
ExprDotNodeForgePropertyExprEvalMapped(ExprDotNodeForgePropertyExpr forge,
ExprEvaluator exprEvaluator) |
ExprDotNodeForgeStaticMethodEval(ExprDotNodeForgeStaticMethod forge,
ExprEvaluator[] childEvals,
ExprDotEval[] chainEval) |
ExprDotNodeForgeTransposeAsStreamEval(ExprDotNodeForgeTransposeAsStream forge,
ExprEvaluator inner) |
Constructor and Description |
---|
InnerDotArrObjectToCollEval(ExprEvaluator rootEvaluator) |
InnerDotArrPrimitiveToCollEval(ExprEvaluator rootEvaluator) |
InnerDotCollEval(ExprEvaluator rootEvaluator) |
InnerDotScalarEval(ExprEvaluator rootEvaluator) |
InnerDotScalarUnpackEventEval(ExprEvaluator rootEvaluator) |
InnerEvaluatorArrObjectToColl(ExprEvaluator rootEvaluator) |
InnerEvaluatorArrPrimitiveToColl(ExprEvaluator rootEvaluator) |
InnerEvaluatorColl(ExprEvaluator rootEvaluator) |
InnerEvaluatorScalar(ExprEvaluator rootEvaluator) |
InnerEvaluatorScalarUnpackEvent(ExprEvaluator rootEvaluator) |
Modifier and Type | Class and Description |
---|---|
class |
ExprCaseNodeForgeEvalSyntax1 |
class |
ExprCaseNodeForgeEvalSyntax2 |
class |
ExprCaseNodeForgeEvalTypable |
class |
ExprCastNodeConstEval |
class |
ExprCastNodeForgeConstEval |
class |
ExprCastNodeForgeNonConstEval |
class |
ExprCastNodeNonConstEval |
class |
ExprCoalesceNodeForgeEval |
class |
ExprInstanceofNodeForgeEval |
class |
ExprIStreamNode
Represents the RSTREAM() function in an expression tree.
|
class |
ExprMinMaxRowNodeForgeEval
Represents the MAX(a,b) and MIN(a,b) functions is an expression tree.
|
class |
ExprPlugInSingleRowNodeForgeConst |
class |
ExprPropertyExistsNode
Represents the EXISTS(property) function in an expression tree.
|
static class |
ExprTypeofNode.FragmentTypeEval |
static class |
ExprTypeofNode.StreamEventTypeEval |
class |
ExprTypeofNodeForgeFragmentType |
class |
ExprTypeofNodeForgeStreamEvent
Represents the TYPEOF(a) function is an expression tree.
|
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator |
ExprCastNode.StringToDateLongWDynamicFormatEval.dateFormatEval |
protected ExprEvaluator |
ExprCastNode.StringToJava8WDynamicFormatComputerEval.dateFormatEval |
Constructor and Description |
---|
ExprCaseNodeForgeEvalSyntax1(ExprCaseNodeForge forge,
List<UniformPair<ExprEvaluator>> whenThenNodeList,
ExprEvaluator optionalElseExprNode) |
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 | Method and Description |
---|---|
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) |
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 | Class and Description |
---|---|
class |
ExprTimestampNode
Represents the CURRENT_TIMESTAMP() function or reserved keyword in an expression tree.
|
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
ExprTimePeriodForge.getEvaluators() |
ExprEvaluator |
ExprTimestampNode.getExprEvaluator() |
ExprEvaluator |
ExprTimePeriodImpl.getExprEvaluator() |
ExprEvaluator |
ExprTimePeriodForge.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 |
EngineImportApplicationDotMethodRectangeIntersectsRectangle.RectangleIntersectsRectangleForge.getExprEvaluator() |
ExprEvaluator |
EngineImportApplicationDotMethodPointInsideRectange.PointIntersectsRectangleForge.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() |
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) |
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) |
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) |
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) |
Constructor and Description |
---|
HistoricalDataPlanNode(int streamNum,
int rootStreamNum,
int lookupStreamNum,
int numStreams,
ExprEvaluator outerJoinExprEval)
Ctor.
|
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) |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
NamedWindowConsumerDesc.getFilterEvaluators() |
Constructor and Description |
---|
NamedWindowConsumerDesc(ExprNode[] filterExpressions,
ExprEvaluator[] filterEvaluators,
PropertyEvaluator optPropertyEvaluator,
AgentInstanceContext agentInstanceContext) |
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 | Method and Description |
---|---|
ExprEvaluator |
ExprNodeScriptEvalMVEL.getExprEvaluator() |
ExprEvaluator |
ExprNodeScriptEvalJSR223.getExprEvaluator() |
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 |
ExprTableExprEvaluatorBase |
class |
ExprTableExprEvaluatorMethod |
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 |
---|---|
ExprEvaluator |
InstanceManufacturerUtil.InstanceManufacturerForgeNonArray.getExprEvaluator() |
ExprEvaluator |
InstanceManufacturerUtil.InstanceManufacturerForgeArray.getExprEvaluator() |
Constructor and Description |
---|
InstanceManufacturerFastCtor(InstanceManufacturerFactoryFastCtor factory,
ExprEvaluator[] evaluators) |
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 | Field and Description |
---|---|
protected ExprEvaluator[] |
EventRowRegexNFAViewFactory.columnEvaluators |
protected ExprEvaluator[] |
EventRowRegexNFAViewFactory.partitionByEvals |
Modifier and Type | Field and Description |
---|---|
protected HashMap<String,Pair<ExprNode,ExprEvaluator>> |
EventRowRegexNFAViewFactory.variableDefinitions |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
RegexPartitionStateRepoGroupMeta.getPartitionExpressions() |
Modifier and Type | Method and Description |
---|---|
protected static RegexNFAStrandResult |
EventRowRegexHelper.recursiveBuildStartStates(RowRegexExprNode parent,
Map<String,Pair<ExprNode,ExprEvaluator>> variableDefinitions,
Map<String,Pair<Integer,Boolean>> variableStreams,
boolean[] exprRequiresMultimatchState)
Build a list of start states from the parent node.
|
Constructor and Description |
---|
RegexNFAStateOneOptional(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
boolean isGreedy,
ExprEvaluator exprEvaluator,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexNFAStateOneToMany(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
boolean isGreedy,
ExprEvaluator exprEvaluator,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexNFAStateZeroToMany(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
boolean isGreedy,
ExprEvaluator exprEvaluator,
boolean exprRequiresMultimatchState)
Ctor.
|
RegexPartitionStateRepoGroupMeta(boolean hasInterval,
ExprNode[] partitionExpressionNodes,
ExprEvaluator[] partitionExpressions,
ExprEvaluatorContext exprEvaluatorContext) |
Constructor and Description |
---|
RegexNFAStateFilter(String nodeNum,
String variableName,
int streamNum,
boolean multiple,
Pair<ExprNode,ExprEvaluator> expression,
boolean exprRequiresMultimatchState)
Ctor.
|
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(ExprNode[] sortCriteria,
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[] |
RankWindowViewFactory.sortEvals |
protected ExprEvaluator |
TimeToLiveViewFactory.timestampExpressionEvaluator |
protected ExprEvaluator |
TimeOrderViewFactory.timestampExpressionEvaluator |
protected ExprEvaluator[] |
RankWindowViewFactory.uniqueEvals |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator |
SortWindowViewFactory.getSizeEvaluator() |
ExprEvaluator |
RankWindowViewFactory.getSizeEvaluator() |
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 |
---|
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 | Field and Description |
---|---|
protected ExprEvaluator |
RegressionLinestViewFactory.expressionXEval |
protected ExprEvaluator |
CorrelationViewFactory.expressionXEval |
protected ExprEvaluator |
RegressionLinestViewFactory.expressionYEval |
protected ExprEvaluator |
CorrelationViewFactory.expressionYEval |
protected ExprEvaluator |
UnivariateStatisticsViewFactory.fieldExpressionEvaluator |
protected ExprEvaluator |
WeightedAverageViewFactory.fieldNameWeightEvaluator |
protected ExprEvaluator |
WeightedAverageViewFactory.fieldNameXEvaluator |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
StatViewAdditionalProps.getAdditionalEvals() |
ExprEvaluator |
BaseBivariateStatisticsView.getExpressionXEval() |
ExprEvaluator |
BaseBivariateStatisticsView.getExpressionYEval() |
Constructor and Description |
---|
BaseBivariateStatisticsView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode expressionX,
ExprEvaluator expressionXEval,
ExprNode expressionY,
ExprEvaluator expressionYEval,
EventType eventType,
StatViewAdditionalProps additionalProps)
Constructor requires the name of the two fields to use in the parent view to compute the statistics.
|
CorrelationView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xExpression,
ExprEvaluator xExpressionEval,
ExprNode yExpression,
ExprEvaluator yExpressionEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
RegressionLinestView(ViewFactory viewFactory,
AgentInstanceContext agentInstanceContext,
ExprNode xFieldName,
ExprEvaluator xEval,
ExprNode yFieldName,
ExprEvaluator yEval,
EventType eventType,
StatViewAdditionalProps additionalProps) |
Modifier and Type | Field and Description |
---|---|
protected ExprEvaluator[] |
GroupByViewFactory.criteriaExpressionEvals |
protected ExprEvaluator[] |
FirstUniqueByPropertyViewFactory.criteriaExpressionEvals |
protected ExprEvaluator[] |
UniqueByPropertyViewFactory.criteriaExpressionsEvals |
Modifier and Type | Method and Description |
---|---|
ExprEvaluator[] |
GroupByViewFactory.getCriteriaExpressionEvals() |
ExprEvaluator[] |
FirstUniqueByPropertyViewFactory.getCriteriaExpressionEvals() |
ExprEvaluator[] |
UniqueByPropertyViewFactory.getCriteriaExpressionsEvals() |
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.
|