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.context.subselect |
Subselect implementation.
|
com.espertech.esper.core.service |
Implementation of client package interfaces, glue code
|
com.espertech.esper.core.service.resource |
Core service statement resource holders.
|
com.espertech.esper.core.start |
Classes related to start and stop of statements
|
com.espertech.esper.epl.expression.subquery |
Subselect expressions.
|
com.espertech.esper.epl.expression.visitor |
Expression visitors.
|
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.metrics.instrumentation |
EPL instrumentation helpers.
|
Modifier and Type | Method and Description |
---|---|
Map<ExprSubselectNode,SubSelectStrategyHolder> |
StatementAgentInstanceFactoryResult.getSubselectStrategies() |
Modifier and Type | Method and Description |
---|---|
Map<ExprSubselectNode,SubSelectStrategyFactoryDesc> |
SubSelectStrategyCollection.getSubqueries() |
Map<ExprSubselectNode,SubSelectActivationHolder> |
SubSelectActivationCollection.getSubqueries() |
Modifier and Type | Method and Description |
---|---|
void |
SubSelectActivationCollection.add(ExprSubselectNode subselectNode,
SubSelectActivationHolder holder)
Add lookup.
|
void |
SubSelectStrategyCollection.add(ExprSubselectNode subselectNode,
SubSelectStrategyFactoryDesc prototypeHolder)
Add lookup.
|
EventType |
SubSelectActivationCollection.getRootViewableType(ExprSubselectNode subqueryNode)
Returns the lookup viewable, child-most view.
|
int |
SubSelectActivationCollection.getStreamNumber(ExprSubselectNode subqueryNode)
Returns stream number.
|
SubSelectActivationHolder |
SubSelectActivationCollection.getSubSelectHolder(ExprSubselectNode subselectNode) |
ViewFactoryChain |
SubSelectActivationCollection.getViewFactoryChain(ExprSubselectNode subqueryNode)
Returns the lookup's view factory chain.
|
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.
|
static boolean |
StatementContextFactoryUtil.determineHasTableAccess(List<ExprSubselectNode> subselectNodes,
StatementSpecRaw statementSpecRaw,
EPServicesContext engineServices) |
StatementContext |
StatementContextFactoryDefault.makeContext(int statementId,
String statementName,
String expression,
StatementType statementType,
EPServicesContext engineServices,
Map<String,Object> optAdditionalContext,
boolean isFireAndForget,
Annotation[] annotations,
EPIsolationUnitServices isolationUnitServices,
boolean stateless,
StatementSpecRaw statementSpecRaw,
List<ExprSubselectNode> subselectNodes,
boolean writesToTables,
Object statementUserObject) |
StatementContext |
StatementContextFactory.makeContext(int statementId,
String statementName,
String expression,
StatementType statementType,
EPServicesContext engineServices,
Map<String,Object> optAdditionalContext,
boolean isFireAndForget,
Annotation[] annotations,
EPIsolationUnitServices isolationUnitServices,
boolean stateless,
StatementSpecRaw statementSpecRaw,
List<ExprSubselectNode> subselectNodes,
boolean writesToTables,
Object statementUserObject) |
Modifier and Type | Method and Description |
---|---|
Map<ExprSubselectNode,SubSelectStrategyHolder> |
StatementResourceHolder.getSubselectStrategies() |
Modifier and Type | Method and Description |
---|---|
protected void |
StatementResourceHolder.setSubselectStrategies(Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategies) |
Modifier and Type | Method and Description |
---|---|
static Map<ExprSubselectNode,SubSelectStrategyHolder> |
EPStatementStartMethodHelperSubselect.startSubselects(EPServicesContext services,
SubSelectStrategyCollection subSelectStrategyCollection,
AgentInstanceContext agentInstanceContext,
List<StopCallback> stopCallbackList,
boolean isRecoveringResilient) |
Modifier and Type | Method and Description |
---|---|
static String |
EPStatementStartMethodHelperSubselect.getSubqueryInfoText(int subqueryNum,
ExprSubselectNode subselect) |
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.assignSubqueryStrategies(SubSelectStrategyCollection subSelectStrategyCollection,
Map<ExprSubselectNode,SubSelectStrategyHolder> subselectStrategyInstances) |
static void |
EPStatementStartMethodHelperAssignExpr.unassignSubqueryStrategies(Collection<ExprSubselectNode> subselects) |
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 |
ExprSubselectRowNode
Represents a subselect in an expression tree.
|
Modifier and Type | Field and Description |
---|---|
static ExprSubselectNode[] |
ExprSubselectNode.EMPTY_SUBSELECT_ARRAY |
Modifier and Type | Method and Description |
---|---|
static ExprSubselectNode[] |
ExprSubselectNode.toArray(List<ExprSubselectNode> subselectNodes) |
Modifier and Type | Method and Description |
---|---|
static SubselectEvalStrategyNR |
SubselectEvalStrategyNRFactory.createStrategyAnyAllIn(ExprSubselectNode subselectExpression,
boolean isNot,
boolean isAll,
boolean isAny,
RelationalOpEnum relationalOp,
EngineImportService engineImportService,
String statementName) |
Modifier and Type | Method and Description |
---|---|
static ExprSubselectNode[] |
ExprSubselectNode.toArray(List<ExprSubselectNode> subselectNodes) |
Modifier and Type | Method and Description |
---|---|
List<ExprSubselectNode> |
ExprNodeSubselectDeclaredNoTraverseVisitor.getSubselects()
Returns a list of lookup expression nodes.
|
List<ExprSubselectNode> |
ExprNodeSubselectDeclaredDotVisitor.getSubselects()
Returns a list of lookup expression nodes.
|
Modifier and Type | Method and Description |
---|---|
ExprSubselectNode[] |
StatementSpecCompiled.getSubSelectExpressions()
Returns the list of lookup expression nodes.
|
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 |
---|---|
void |
InstrumentationDefault.qExprSubselect(ExprSubselectNode exprSubselectNode) |
void |
Instrumentation.qExprSubselect(ExprSubselectNode exprSubselectNode) |
void |
InstrumentationDefault.qFilterActivationSubselect(String eventTypeName,
ExprSubselectNode subselectNode) |
void |
Instrumentation.qFilterActivationSubselect(String eventTypeName,
ExprSubselectNode subselectNode) |