Package | Description |
---|---|
com.espertech.esper.core.context.factory |
Statement agent instance factories.
|
com.espertech.esper.core.context.stmt |
Registries for context partitions to handle aggregations, prev/prior and subselects.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.expression.table |
Table access and identifiers expressions.
|
com.espertech.esper.epl.expression.visitor |
Expression visitors.
|
com.espertech.esper.epl.parse |
Parsers and AST tree walkers and helper classes transforming AST into business objects
|
com.espertech.esper.epl.spec |
Contains EPL statement specification classes define the constructs that make up an EPL statement,
such as the list of items in the select clause, the insert-into stream name and property names etc.
|
com.espertech.esper.epl.table.strategy |
Table access evaluators.
|
Modifier and Type | Method and Description |
---|---|
Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> |
StatementAgentInstanceFactoryResult.getTableAccessEvalStrategies() |
Modifier and Type | Method and Description |
---|---|
AIRegistryTableAccess |
AIRegistryExprBase.allocateTableAccess(ExprTableAccessNode tableNode) |
AIRegistryTableAccess |
AIRegistryExpr.allocateTableAccess(ExprTableAccessNode tableNode) |
AIRegistryTableAccess |
AIRegistryExprBase.getTableAccessServices(ExprTableAccessNode key) |
AIRegistryTableAccess |
AIRegistryExpr.getTableAccessServices(ExprTableAccessNode key) |
Modifier and Type | Method and Description |
---|---|
void |
StatementVariableRefImpl.addReferences(String statementName,
Set<String> variablesReferenced,
ExprTableAccessNode[] tableNodes) |
void |
StatementVariableRef.addReferences(String statementName,
Set<String> variablesReferenced,
ExprTableAccessNode[] tableNodes)
Add a reference from a statement name to a set of variables.
|
Modifier and Type | Method and Description |
---|---|
protected static StatementSpecCompiled |
StatementLifecycleSvcImpl.compile(StatementSpecRaw spec,
String eplStatement,
StatementContext statementContext,
boolean isSubquery,
boolean isOnDemandQuery,
Annotation[] annotations,
List<ExprSubselectNode> subselectNodes,
List<ExprDeclaredNode> declaredNodes,
Set<ExprTableAccessNode> tableAccessNodes,
EPServicesContext servicesContext)
Compiles a statement returning the compile (verified, non-serializable) form of a statement.
|
Modifier and Type | Method and Description |
---|---|
ExprTableAccessNode[] |
EPPreparedExecuteIUDSingleStreamExecUpdate.getOptionalTableNodes() |
ExprTableAccessNode[] |
EPPreparedExecuteIUDSingleStreamExecInsert.getOptionalTableNodes() |
ExprTableAccessNode[] |
EPPreparedExecuteIUDSingleStreamExecDelete.getOptionalTableNodes() |
ExprTableAccessNode[] |
EPPreparedExecuteMethodQuery.getTableNodes() |
Modifier and Type | Method and Description |
---|---|
static Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> |
EPStatementStartMethodHelperTableAccess.attachTableAccess(EPServicesContext services,
AgentInstanceContext agentInstanceContext,
ExprTableAccessNode[] tableNodes) |
Modifier and Type | Method and Description |
---|---|
static void |
EPPreparedExecuteTableHelper.assignTableAccessStrategies(EPServicesContext services,
ExprTableAccessNode[] optionalTableNodes,
AgentInstanceContext agentInstanceContext) |
static Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> |
EPStatementStartMethodHelperTableAccess.attachTableAccess(EPServicesContext services,
AgentInstanceContext agentInstanceContext,
ExprTableAccessNode[] tableNodes) |
Modifier and Type | Method and Description |
---|---|
static void |
EPStatementStartMethodHelperAssignExpr.assignExpressionStrategies(EPStatementStartMethodSelectDesc selectDesc,
AggregationService aggregationService,
Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategyInstances,
Map<ExprPriorNode,ExprPriorEvalStrategy> priorStrategyInstances,
Map<ExprPreviousNode,ExprPreviousEvalStrategy> previousStrategyInstances,
Set<ExprPreviousMatchRecognizeNode> matchRecognizeNodes,
RegexExprPreviousEvalStrategy matchRecognizePrevEvalStrategy,
Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategyInstances) |
static void |
EPStatementStartMethodHelperAssignExpr.assignTableAccessStrategies(Map<ExprTableAccessNode,ExprTableAccessEvalStrategy> tableAccessStrategies) |
Constructor and Description |
---|
EPPreparedExecuteIUDSingleStreamExecDelete(QueryGraph queryGraph,
ExprNode optionalWhereClause,
Annotation[] annotations,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
EPPreparedExecuteIUDSingleStreamExecInsert(ExprEvaluatorContext exprEvaluatorContext,
SelectExprProcessor insertHelper,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
EPPreparedExecuteIUDSingleStreamExecUpdate(QueryGraph queryGraph,
ExprNode optionalWhereClause,
Annotation[] annotations,
EventBeanUpdateHelper updateHelper,
TableUpdateStrategy tableUpdateStrategy,
ExprTableAccessNode[] optionalTableNodes,
EPServicesContext services) |
Modifier and Type | Class and Description |
---|---|
class |
ExprTableAccessNodeKeys |
class |
ExprTableAccessNodeSubprop |
class |
ExprTableAccessNodeSubpropAccessor |
class |
ExprTableAccessNodeTopLevel |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ExprTableAccessNodeTopLevel.equalsNodeInternal(ExprTableAccessNode other) |
protected boolean |
ExprTableAccessNodeSubpropAccessor.equalsNodeInternal(ExprTableAccessNode other) |
protected boolean |
ExprTableAccessNodeSubprop.equalsNodeInternal(ExprTableAccessNode other) |
protected boolean |
ExprTableAccessNodeKeys.equalsNodeInternal(ExprTableAccessNode other) |
protected abstract boolean |
ExprTableAccessNode.equalsNodeInternal(ExprTableAccessNode other) |
Constructor and Description |
---|
ExprNodeTableAccessVisitor(Set<ExprTableAccessNode> nodesToAddTo) |
Modifier and Type | Method and Description |
---|---|
static ExprTableAccessNode |
ASTTableExprHelper.checkTableNameGetExprForProperty(TableService tableService,
String propertyName)
Resolve "table" and "table.property" when nested-property, not chainable
|
Modifier and Type | Method and Description |
---|---|
static Pair<ExprTableAccessNode,ExprDotNode> |
ASTTableExprHelper.checkTableNameGetExprForSubproperty(TableService tableService,
String tableName,
String subproperty) |
static Pair<ExprTableAccessNode,List<ExprChainedSpec>> |
ASTTableExprHelper.checkTableNameGetLibFunc(TableService tableService,
EngineImportService engineImportService,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
String engineURI,
String classIdent,
List<ExprChainedSpec> chain) |
static Pair<ExprTableAccessNode,List<ExprChainedSpec>> |
ASTTableExprHelper.getTableExprChainable(EngineImportService engineImportService,
LazyAllocatedMap<ConfigurationPlugInAggregationMultiFunction,PlugInAggregationMultiFunctionFactory> plugInAggregations,
String engineURI,
String tableName,
List<ExprChainedSpec> chain) |
Modifier and Type | Method and Description |
---|---|
static void |
ASTTableExprHelper.addTableExpressionReference(StatementSpecRaw statementSpec,
ExprTableAccessNode tableNode) |
Modifier and Type | Method and Description |
---|---|
static void |
ASTTableExprHelper.addTableExpressionReference(StatementSpecRaw statementSpec,
Set<ExprTableAccessNode> tableNodes) |
Modifier and Type | Method and Description |
---|---|
ExprTableAccessNode[] |
StatementSpecCompiled.getTableNodes() |
Modifier and Type | Method and Description |
---|---|
Set<ExprTableAccessNode> |
StatementSpecRaw.getTableExpressions() |
Set<ExprTableAccessNode> |
StatementSpecMapContext.getTableExpressions() |
Modifier and Type | Method and Description |
---|---|
void |
StatementSpecRaw.setTableExpressions(Set<ExprTableAccessNode> tableExpressions) |
Constructor and Description |
---|
StatementSpecCompiled(OnTriggerDesc onTriggerDesc,
CreateWindowDesc createWindowDesc,
CreateIndexDesc createIndexDesc,
CreateVariableDesc createVariableDesc,
CreateTableDesc createTableDesc,
CreateSchemaDesc createSchemaDesc,
InsertIntoDesc insertIntoDesc,
SelectClauseStreamSelectorEnum selectClauseStreamSelectorEnum,
SelectClauseSpecCompiled selectClauseSpec,
StreamSpecCompiled[] streamSpecs,
OuterJoinDesc[] outerJoinDescList,
ExprNode filterExprRootNode,
ExprNode havingExprRootNode,
OutputLimitSpec outputLimitSpec,
OrderByItem[] orderByList,
ExprSubselectNode[] subSelectExpressions,
ExprDeclaredNode[] declaredExpressions,
ExpressionScriptProvided[] scripts,
Set<String> variableReferences,
RowLimitSpec rowLimitSpec,
String[] eventTypeReferences,
Annotation[] annotations,
UpdateDesc updateSpec,
MatchRecognizeSpec matchRecognizeSpec,
ForClauseSpec forClauseSpec,
Map<Integer,List<ExprNode>> sqlParameters,
CreateContextDesc contextDesc,
String optionalContextName,
CreateDataFlowDesc createGraphDesc,
CreateExpressionDesc createExpressionDesc,
FireAndForgetSpec fireAndForgetSpec,
GroupByClauseExpressions groupByExpressions,
IntoTableSpec intoTableSpec,
ExprTableAccessNode[] tableNodes) |
Modifier and Type | Method and Description |
---|---|
static ExprTableAccessEvalStrategy |
ExprTableEvalStrategyFactory.getTableAccessEvalStrategy(ExprTableAccessNode tableNode,
TableAndLockProvider provider,
TableMetadata tableMetadata) |