| Package | Description |
|---|---|
| com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
| com.espertech.esper.epl.agg.factory |
Aggregator factories
|
| 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.expression.accessagg |
Access-aggregation expressions.
|
| com.espertech.esper.epl.expression.core |
Core expression classes.
|
| com.espertech.esper.epl.property |
Classes for handling events-within-events.
|
| com.espertech.esper.epl.variable |
Variable service and variable collections
|
| com.espertech.esper.filter |
Main switchboard filtering and routing of incoming events to interested statements is performed in this package.
|
| 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.view |
View infrastructure concerned with view creation and destroy, cloning and hooking views trees into filtering.
|
| Modifier and Type | Method and Description |
|---|---|
StatementExtensionSvcContext |
StatementContext.getStatementExtensionServicesContext()
Returns extension context for statements.
|
| Constructor and Description |
|---|
StatementContext(StatementContextEngineServices stmtEngineServices,
SchedulingService schedulingService,
ScheduleBucket scheduleBucket,
EPStatementHandle epStatementHandle,
ViewResolutionService viewResultionService,
PatternObjectResolutionService patternResolutionService,
StatementExtensionSvcContext statementExtensionSvcContext,
StatementStopService statementStopService,
PatternContextFactory patternContextFactory,
FilterService filterService,
StatementResultService statementResultService,
InternalEventRouteDest internalEventEngineRouteDest,
Annotation[] annotations,
StatementAIResourceRegistry statementAgentInstanceRegistry,
StatementAgentInstanceLock defaultAgentInstanceLock,
ContextDescriptor contextDescriptor,
PatternSubexpressionPoolStmtSvc patternSubexpressionPoolSvc,
MatchRecognizeStatePoolStmtSvc matchRecognizeStatePoolStmtSvc,
boolean statelessSelect,
ContextControllerFactoryService contextControllerFactoryService,
AgentInstanceScriptContext defaultAgentInstanceScriptContext,
AggregationServiceFactoryService aggregationServiceFactoryService,
boolean writesToTables,
Object statementUserObject,
StatementSemiAnonymousTypeRegistry statementSemiAnonymousTypeRegistry,
int priority) |
| Modifier and Type | Method and Description |
|---|---|
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvedev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvedevNode exprAvedevNode,
Class childType,
ExprNode[] positionalParams) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeAvg(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvgNode exprAvgNode,
Class childType,
MathContext optionalMathContext) |
AggregationMethodFactory |
AggregationFactoryFactory.makeAvg(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAvgNode exprAvgNode,
Class childType,
MathContext optionalMathContext) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeCount(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountNode exprCountNode,
boolean ignoreNulls,
Class countedValueType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeCount(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountNode exprCountNode,
boolean ignoreNulls,
Class countedValueType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeCountEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountEverNode exprCountEverNode,
boolean ignoreNulls) |
AggregationMethodFactory |
AggregationFactoryFactory.makeCountEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprCountEverNode exprCountEverNode,
boolean ignoreNulls) |
AggregationStateFactoryCountMinSketch |
AggregationFactoryFactoryDefault.makeCountMinSketch(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggCountMinSketchNode expr,
CountMinSketchSpec specification) |
AggregationStateFactoryCountMinSketch |
AggregationFactoryFactory.makeCountMinSketch(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggCountMinSketchNode expr,
CountMinSketchSpec specification) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeFirstEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprFirstEverNode exprFirstEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactory.makeFirstEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprFirstEverNode exprFirstEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeLastEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLastEverNode exprLastEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLastEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLastEverNode exprLastEverNode,
Class type) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeLeaving(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLeavingAggNode exprLeavingAggNode) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLeaving(StatementExtensionSvcContext statementExtensionSvcContext,
ExprLeavingAggNode exprLeavingAggNode) |
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeLinear(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode expr,
int streamNum,
ExprEvaluator optionalFilter) |
AggregationStateFactory |
AggregationFactoryFactory.makeLinear(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode expr,
int streamNum,
ExprEvaluator optionalFilter) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeLinearUnbounded(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode parent,
EventType containedType,
Class accessorResultType,
int streamNum,
boolean hasFilter) |
AggregationMethodFactory |
AggregationFactoryFactory.makeLinearUnbounded(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionLinearAccessNode exprAggMultiFunctionLinearAccessNode,
EventType containedType,
Class accessorResultType,
int streamNum,
boolean hasFilter) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeMedian(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMedianNode exprMedianNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeMedian(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMedianNode exprMedianNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeMinMax(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMinMaxAggrNode exprMinMaxAggrNode,
Class type,
boolean hasDataWindows) |
AggregationMethodFactory |
AggregationFactoryFactory.makeMinMax(StatementExtensionSvcContext statementExtensionSvcContext,
ExprMinMaxAggrNode exprMinMaxAggrNode,
Class type,
boolean hasDataWindows) |
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeMinMaxEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateMinMaxByEverSpec spec) |
AggregationStateFactory |
AggregationFactoryFactory.makeMinMaxEver(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateMinMaxByEverSpec spec) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeNth(StatementExtensionSvcContext statementExtensionSvcContext,
ExprNthAggNode exprNthAggNode,
Class type,
int size) |
AggregationMethodFactory |
AggregationFactoryFactory.makeNth(StatementExtensionSvcContext statementExtensionSvcContext,
ExprNthAggNode exprNthAggNode,
Class type,
int size) |
AggregationStateFactory |
AggregationFactoryFactoryDefault.makePlugInAccess(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggMultiFunctionNodeFactory factory) |
AggregationStateFactory |
AggregationFactoryFactory.makePlugInAccess(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggMultiFunctionNodeFactory factory) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makePlugInMethod(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggNode expr,
AggregationFunctionFactory factory,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makePlugInMethod(StatementExtensionSvcContext statementExtensionSvcContext,
ExprPlugInAggNode expr,
AggregationFunctionFactory factory,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeRate(StatementExtensionSvcContext statementExtensionSvcContext,
ExprRateAggNode exprRateAggNode,
boolean isEver,
long intervalTime,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
AggregationMethodFactory |
AggregationFactoryFactory.makeRate(StatementExtensionSvcContext statementExtensionSvcContext,
ExprRateAggNode exprRateAggNode,
boolean isEver,
long intervalMsec,
TimeProvider timeProvider,
TimeAbacus timeAbacus) |
AggregationStateFactory |
AggregationFactoryFactoryDefault.makeSorted(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateSortedSpec spec) |
AggregationStateFactory |
AggregationFactoryFactory.makeSorted(StatementExtensionSvcContext statementExtensionSvcContext,
ExprAggMultiFunctionSortedMinMaxByNode expr,
AggregationStateSortedSpec spec) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeStddev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprStddevNode exprStddevNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeStddev(StatementExtensionSvcContext statementExtensionSvcContext,
ExprStddevNode exprStddevNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactoryDefault.makeSum(StatementExtensionSvcContext statementExtensionSvcContext,
ExprSumNode exprSumNode,
Class childType) |
AggregationMethodFactory |
AggregationFactoryFactory.makeSum(StatementExtensionSvcContext statementExtensionSvcContext,
ExprSumNode exprSumNode,
Class childType) |
| Modifier and Type | Method and Description |
|---|---|
static SelectExprProcessor |
SelectExprProcessorFactory.getProcessor(Collection<Integer> assignedTypeNumberStack,
SelectClauseElementCompiled[] selectionList,
boolean isUsingWildcard,
InsertIntoDesc insertIntoDesc,
EventType optionalInsertIntoEventType,
ForClauseSpec forClauseSpec,
StreamTypeService typeService,
EventAdapterService eventAdapterService,
StatementResultService statementResultService,
ValueAddEventService valueAddEventService,
SelectExprEventTypeRegistry selectExprEventTypeRegistry,
EngineImportService engineImportService,
ExprEvaluatorContext exprEvaluatorContext,
VariableService variableService,
TableService tableService,
TimeProvider timeProvider,
String engineURI,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configuration,
SelectExprProcessorDeliveryCallback selectExprProcessorCallback,
NamedWindowMgmtService namedWindowMgmtService,
IntoTableSpec intoTableClause,
com.espertech.esper.epl.core.GroupByRollupInfo groupByRollupInfo,
StatementExtensionSvcContext statementExtensionSvcContext) |
| Constructor and Description |
|---|
ExprPlugInAggMultiFunctionNodeFactory(ExprPlugInAggMultiFunctionNode parent,
PlugInAggregationMultiFunctionHandler handlerPlugin,
AggregationFactoryFactory aggregationFactoryFactory,
StatementExtensionSvcContext statementExtensionSvcContext) |
SortedAggregationStateFactoryFactory(EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ExprEvaluator[] evaluators,
boolean[] sortDescending,
boolean ever,
int streamNum,
ExprAggMultiFunctionSortedMinMaxByNode parent,
ExprEvaluator optionalFilter) |
| Modifier and Type | Method and Description |
|---|---|
StatementExtensionSvcContext |
ExprValidationContext.getStatementExtensionSvcContext() |
| Constructor and Description |
|---|
ExprValidationContext(StreamTypeService streamTypeService,
EngineImportService engineImportService,
StatementExtensionSvcContext statementExtensionSvcContext,
ViewResourceDelegateUnverified viewResourceDelegate,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ExprEvaluatorContext exprEvaluatorContext,
EventAdapterService eventAdapterService,
String statementName,
int statementId,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
boolean disablePropertyExpressionEventCollCache,
boolean allowRollupFunctions,
boolean allowBindingConsumption,
boolean isUnidirectionalJoin,
String intoTableName,
boolean isFilterExpression) |
| Modifier and Type | Method and Description |
|---|---|
static PropertyEvaluator |
PropertyEvaluatorFactory.makeEvaluator(PropertyEvalSpec spec,
EventType sourceEventType,
String optionalSourceStreamName,
EventAdapterService eventAdapterService,
EngineImportService engineImportService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
String engineURI,
int statementId,
String statementName,
Annotation[] annotations,
Collection<Integer> assignedTypeNumberStack,
ConfigurationInformation configuration,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext) |
| Modifier and Type | Method and Description |
|---|---|
void |
VariableServiceImpl.allocateVariableState(String variableName,
int agentInstanceId,
StatementExtensionSvcContext extensionServicesContext,
boolean isRecoveringResilient) |
void |
VariableService.allocateVariableState(String variableName,
int agentInstanceId,
StatementExtensionSvcContext extensionServicesContext,
boolean isRecoveringResilient) |
Pair<Boolean,Object> |
VariableStateHandler.getHasState(String variableName,
int variableNumber,
int agentInstanceId,
Class type,
EventType eventType,
StatementExtensionSvcContext statementExtContext,
boolean isConstant)
Returns the current variable state plus Boolean.TRUE if there is a current state since the variable
may have the value of null; returns Boolean.FALSE and null if there is no current state
|
| Modifier and Type | Field and Description |
|---|---|
StatementExtensionSvcContext |
FilterSpecCompilerArgs.statementExtensionSvcContext |
| Modifier and Type | Method and Description |
|---|---|
static FilterSpecCompiled |
FilterSpecCompiler.buildNoStmtCtx(List<ExprNode> validatedFilterNodes,
EventType eventType,
String eventTypeName,
PropertyEvalSpec optionalPropertyEvalSpec,
LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
StreamTypeService streamTypeService,
String optionalStreamName,
Collection<Integer> assignedTypeNumberStack,
ExprEvaluatorContext exprEvaluatorContext,
int statementId,
String statementName,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
EngineImportService engineImportService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
ConfigurationInformation configurationInformation,
NamedWindowMgmtService namedWindowMgmtService,
StatementExtensionSvcContext statementExtensionSvcContext) |
| Constructor and Description |
|---|
FilterSpecCompilerArgs(LinkedHashMap<String,Pair<EventType,String>> taggedEventTypes,
LinkedHashMap<String,Pair<EventType,String>> arrayEventTypes,
ExprEvaluatorContext exprEvaluatorContext,
String statementName,
int statementId,
StreamTypeService streamTypeService,
EngineImportService engineImportService,
TimeProvider timeProvider,
VariableService variableService,
TableService tableService,
EventAdapterService eventAdapterService,
FilterBooleanExpressionFactory filterBooleanExpressionFactory,
Annotation[] annotations,
ContextDescriptor contextDescriptor,
ConfigurationInformation configurationInformation,
StatementExtensionSvcContext statementExtensionSvcContext) |
| Modifier and Type | Method and Description |
|---|---|
StatementExtensionSvcContext |
PatternContext.getStatementExtensionServicesContext()
Returns extension services context for statement (statement-specific).
|
| Modifier and Type | Method and Description |
|---|---|
StatementExtensionSvcContext |
ViewFactoryContext.getStatementExtensionServicesContext()
Returns extension svc.
|