com.espertech.esper.epl.expression.subquery

Class ExprSubselectNode

java.lang.Object

com.espertech.esper.epl.expression.core.ExprNodeBase

com.espertech.esper.epl.expression.subquery.ExprSubselectNode

All Implemented Interfaces:

ExprEnumerationEval, ExprEnumerationForge, ExprEvaluator, ExprForge, ExprNode, ExprNodeRenderable, ExprTypableReturnEval, ExprTypableReturnForge, ExprValidator, MetaDefItem, Serializable

Direct Known Subclasses:

ExprSubselectAllSomeAnyNode, ExprSubselectExistsNode, ExprSubselectInNode, ExprSubselectRowNode

public abstract class ExprSubselectNode
extends ExprNodeBase
implements ExprEvaluator, ExprEnumerationForge, ExprEnumerationEval, ExprTypableReturnForge, ExprTypableReturnEval, ExprForge

Represents a subselect in an expression tree.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExprSubselectNode.SubqueryAggregationType

Field Summary

Fields

Modifier and Type	Field and Description
static ExprSubselectNode[]	EMPTY_SUBSELECT_ARRAY
protected ExprEvaluator	filterExpr The validate filter expression.
protected ExprEvaluator	havingExpr The validated having expression.
protected EventType	rawEventType The event type generated for wildcard selects.
protected String[]	selectAsNames
protected ExprNode[]	selectClause The validated select clause.
protected ExprEvaluator[]	selectClauseEvaluator
protected String	statementName
protected AggregationService	subselectAggregationService
protected int	subselectNumber

Constructor Summary

Constructors

Constructor and Description
ExprSubselectNode(StatementSpecRaw statementSpec) Ctor.

Method Summary

Modifier and Type	Method and Description
boolean	equalsNode(ExprNode node, boolean ignoreStreamPrefix) Return true if a expression node semantically equals the current node, or false if not.
abstract Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext) Evaluate the lookup expression returning an evaluation result object.
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Evaluate event tuple and return result.
CodegenExpression	evaluateCodegen(CodegenParamSetExprPremade params, CodegenContext context)
abstract Collection<EventBean>	evaluateGetCollEvents(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
abstract Collection	evaluateGetCollScalar(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
abstract EventBean	evaluateGetEventBean(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
EventBean	evaluateGetEventBean(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
CodegenExpression	evaluateGetEventBeanCodegen(CodegenParamSetExprPremade params, CodegenContext context)
Collection<EventBean>	evaluateGetROCollectionEvents(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
CodegenExpression	evaluateGetROCollectionEventsCodegen(CodegenParamSetExprPremade params, CodegenContext context)
Collection	evaluateGetROCollectionScalar(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
CodegenExpression	evaluateGetROCollectionScalarCodegen(CodegenParamSetExprPremade params, CodegenContext context)
abstract Object[][]	evaluateTypableMulti(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
Object[][]	evaluateTypableMulti(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
CodegenExpression	evaluateTypableMultiCodegen(CodegenParamSetExprPremade params, CodegenContext context)
abstract Object[]	evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
Object[]	evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
CodegenExpression	evaluateTypableSingleCodegen(CodegenParamSetExprPremade params, CodegenContext context)
ExprForgeComplexityEnum	getComplexity()
ExprEvaluator	getExprEvaluator()
ExprEnumerationEval	getExprEvaluatorEnumeration()
ExprEvaluator	getFilterExpr() Returns filter expr or null if none.
StreamTypeService	getFilterSubqueryStreamTypes() Return stream types.
ExprForge	getForge()
ExprNodeRenderable	getForgeRenderable()
ExprEvaluator	getHavingExpr()
ExprPrecedenceEnum	getPrecedence() Returns precedence.
EventType	getRawEventType() Returns the event type.
LinkedHashMap<String,Object>	getRowProperties() Return null to indicate no row-type result available, or a map of property names and types to indicate a row-type result is available.
ExprNode[]	getSelectClause() Returns the select clause or null if none.
StatementSpecCompiled	getStatementSpecCompiled() Returns the compiled statement spec.
StatementSpecRaw	getStatementSpecRaw() Returns the uncompiled statement spec.
AggregationService	getSubselectAggregationService()
ExprSubselectNode.SubqueryAggregationType	getSubselectAggregationType()
int	getSubselectNumber()
ExprTypableReturnEval	getTypableReturnEvaluator()
abstract boolean	isAllowMultiColumnSelect()
boolean	isConstantResult() Returns true if the expression node's evaluation value doesn't depend on any events data, as must be determined at validation time, which is bottom-up and therefore reliably allows each node to determine constant value.
boolean	isFilterStreamSubselect()
Boolean	isMultirow() Return true for multi-row return, return false for return of single row only
void	setFilterExpr(ExprEvaluator filterExpr) Sets the validated filter expression, or null if there is none.
void	setFilterStreamSubselect(boolean filterStreamSubselect)
void	setFilterSubqueryStreamTypes(StreamTypeService filterSubqueryStreamTypes) Set stream types.
void	setHavingExpr(ExprEvaluator havingExpr)
void	setRawEventType(EventType rawEventType) Sets the event type generated for wildcard selects.
void	setSelectAsNames(String[] selectAsNames) Supplies the name of the select expression as-tag
void	setSelectClause(ExprNode[] selectClause, EngineImportService engineImportService, String statementName) Sets the validates select clause
void	setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled, int subselectNumber) Supplies a compiled statement spec.
void	setStrategy(ExprSubselectStrategy strategy) Sets the strategy for boiling down the table of lookup events into a subset against which to run the filter.
void	setSubselectAggregationService(AggregationService subselectAggregationService)
void	setSubselectAggregationType(ExprSubselectNode.SubqueryAggregationType subselectAggregationType)
static ExprSubselectNode[]	toArray(List<ExprSubselectNode> subselectNodes)
void	toPrecedenceFreeEPL(StringWriter writer)
abstract LinkedHashMap<String,Object>	typableGetRowProperties()
ExprNode	validate(ExprValidationContext validationContext)
abstract void	validateSubquery(ExprValidationContext validationContext)

Methods inherited from class com.espertech.esper.epl.expression.core.ExprNodeBase

accept, accept, acceptChildnodes, addChildNode, addChildNodes, addChildNodeToFront, getChildNodes, replaceUnlistedChildNode, setChildNode, setChildNodes, toEPL

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.espertech.esper.epl.expression.core.ExprEnumerationForge

getComponentTypeCollection, getEventTypeCollection, getEventTypeSingle

Methods inherited from interface com.espertech.esper.epl.expression.core.ExprForge

getEvaluationType

Field Detail

EMPTY_SUBSELECT_ARRAY

public static final ExprSubselectNode[] EMPTY_SUBSELECT_ARRAY

selectClause

protected ExprNode[] selectClause

The validated select clause.

selectClauseEvaluator

protected transient ExprEvaluator[] selectClauseEvaluator

selectAsNames

protected String[] selectAsNames

filterExpr

protected transient ExprEvaluator filterExpr

The validate filter expression.

havingExpr

protected transient ExprEvaluator havingExpr

The validated having expression.

rawEventType

protected transient EventType rawEventType

The event type generated for wildcard selects.

statementName

protected String statementName

subselectNumber

protected int subselectNumber

subselectAggregationService

protected transient AggregationService subselectAggregationService

Constructor Detail

ExprSubselectNode

public ExprSubselectNode(StatementSpecRaw statementSpec)

Ctor.

Parameters:

statementSpec - is the lookup statement spec from the parser, unvalidated

Method Detail

evaluate

public abstract Object evaluate(EventBean[] eventsPerStream,
                                boolean isNewData,
                                Collection<EventBean> matchingEvents,
                                ExprEvaluatorContext exprEvaluatorContext)

Evaluate the lookup expression returning an evaluation result object.

Parameters:

eventsPerStream - is the events for each stream in a join

isNewData - is true for new data, or false for old data

matchingEvents - is filtered results from the table of stored lookup events

exprEvaluatorContext - context for expression evalauation

Returns:

evaluation result

evaluateGetCollEvents

public abstract Collection<EventBean> evaluateGetCollEvents(EventBean[] eventsPerStream,
                                                            boolean isNewData,
                                                            Collection<EventBean> matchingEvents,
                                                            ExprEvaluatorContext exprEvaluatorContext)

evaluateGetCollScalar

public abstract Collection evaluateGetCollScalar(EventBean[] eventsPerStream,
                                                 boolean isNewData,
                                                 Collection<EventBean> matchingEvents,
                                                 ExprEvaluatorContext exprEvaluatorContext)

evaluateGetEventBean

public abstract EventBean evaluateGetEventBean(EventBean[] eventsPerStream,
                                               boolean isNewData,
                                               Collection<EventBean> matchingEvents,
                                               ExprEvaluatorContext exprEvaluatorContext)

isAllowMultiColumnSelect

public abstract boolean isAllowMultiColumnSelect()

validateSubquery

public abstract void validateSubquery(ExprValidationContext validationContext)
                               throws ExprValidationException

Throws:

ExprValidationException

typableGetRowProperties

public abstract LinkedHashMap<String,Object> typableGetRowProperties()
                                                              throws ExprValidationException

Throws:

ExprValidationException

evaluateTypableSingle

public abstract Object[] evaluateTypableSingle(EventBean[] eventsPerStream,
                                               boolean isNewData,
                                               Collection<EventBean> matchingEvents,
                                               ExprEvaluatorContext exprEvaluatorContext)

evaluateTypableMulti

public abstract Object[][] evaluateTypableMulti(EventBean[] eventsPerStream,
                                                boolean isNewData,
                                                Collection<EventBean> matchingEvents,
                                                ExprEvaluatorContext exprEvaluatorContext)

getExprEvaluator

public ExprEvaluator getExprEvaluator()

Specified by:

getExprEvaluator in interface ExprForge

isConstantResult

public boolean isConstantResult()

Description copied from interface: ExprNode

Returns true if the expression node's evaluation value doesn't depend on any events data, as must be determined at validation time, which is bottom-up and therefore reliably allows each node to determine constant value.

Specified by:

isConstantResult in interface ExprNode

Returns:

true for constant evaluation value, false for non-constant evaluation value

getForge

public ExprForge getForge()

Specified by:

getForge in interface ExprNode

getForgeRenderable

public ExprNodeRenderable getForgeRenderable()

Specified by:

getForgeRenderable in interface ExprEnumerationForge

Specified by:

getForgeRenderable in interface ExprForge

validate

public ExprNode validate(ExprValidationContext validationContext)
                  throws ExprValidationException

Specified by:

validate in interface ExprValidator

Throws:

ExprValidationException

setStatementSpecCompiled

public void setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled,
                                     int subselectNumber)

Supplies a compiled statement spec.

Parameters:

statementSpecCompiled - compiled validated filters

subselectNumber - subselect assigned number

getStatementSpecCompiled

public StatementSpecCompiled getStatementSpecCompiled()

Returns the compiled statement spec.

Returns:

compiled statement

setSelectClause

public void setSelectClause(ExprNode[] selectClause,
                            EngineImportService engineImportService,
                            String statementName)

Sets the validates select clause

Parameters:

selectClause - is the expression representing the select clause

engineImportService - engine import service

statementName - name

evaluate

public Object evaluate(EventBean[] eventsPerStream,
                       boolean isNewData,
                       ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: ExprEvaluator

Evaluate event tuple and return result.

Specified by:

evaluate in interface ExprEvaluator

Parameters:

eventsPerStream - - event tuple

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

exprEvaluatorContext - context for expression evaluation

Returns:

evaluation result, a boolean value for OR/AND-type evalution nodes.

evaluateCodegen

public CodegenExpression evaluateCodegen(CodegenParamSetExprPremade params,
                                         CodegenContext context)

Specified by:

evaluateCodegen in interface ExprForge

getComplexity

public ExprForgeComplexityEnum getComplexity()

Specified by:

getComplexity in interface ExprForge

evaluateGetROCollectionEvents

public Collection<EventBean> evaluateGetROCollectionEvents(EventBean[] eventsPerStream,
                                                           boolean isNewData,
                                                           ExprEvaluatorContext exprEvaluatorContext)

Specified by:

evaluateGetROCollectionEvents in interface ExprEnumerationEval

evaluateGetROCollectionEventsCodegen

public CodegenExpression evaluateGetROCollectionEventsCodegen(CodegenParamSetExprPremade params,
                                                              CodegenContext context)

Specified by:

evaluateGetROCollectionEventsCodegen in interface ExprEnumerationForge

evaluateGetROCollectionScalar

public Collection evaluateGetROCollectionScalar(EventBean[] eventsPerStream,
                                                boolean isNewData,
                                                ExprEvaluatorContext exprEvaluatorContext)

Specified by:

evaluateGetROCollectionScalar in interface ExprEnumerationEval

evaluateGetROCollectionScalarCodegen

public CodegenExpression evaluateGetROCollectionScalarCodegen(CodegenParamSetExprPremade params,
                                                              CodegenContext context)

Specified by:

evaluateGetROCollectionScalarCodegen in interface ExprEnumerationForge

evaluateGetEventBean

public EventBean evaluateGetEventBean(EventBean[] eventsPerStream,
                                      boolean isNewData,
                                      ExprEvaluatorContext context)

Specified by:

evaluateGetEventBean in interface ExprEnumerationEval

getRowProperties

public LinkedHashMap<String,Object> getRowProperties()
                                              throws ExprValidationException

Description copied from interface: ExprTypableReturnForge

Return null to indicate no row-type result available, or a map of property names and types to indicate a row-type result is available.

Specified by:

getRowProperties in interface ExprTypableReturnForge

Returns:

map of property names and types or null

Throws:

ExprValidationException - if the expression is invalid

isMultirow

public Boolean isMultirow()

Description copied from interface: ExprTypableReturnForge

Return true for multi-row return, return false for return of single row only

Specified by:

isMultirow in interface ExprTypableReturnForge

Returns:

multi-row flag

evaluateTypableSingle

public Object[] evaluateTypableSingle(EventBean[] eventsPerStream,
                                      boolean isNewData,
                                      ExprEvaluatorContext context)

Specified by:

evaluateTypableSingle in interface ExprTypableReturnEval

evaluateTypableSingleCodegen

public CodegenExpression evaluateTypableSingleCodegen(CodegenParamSetExprPremade params,
                                                      CodegenContext context)

Specified by:

evaluateTypableSingleCodegen in interface ExprTypableReturnForge

evaluateTypableMulti

public Object[][] evaluateTypableMulti(EventBean[] eventsPerStream,
                                       boolean isNewData,
                                       ExprEvaluatorContext context)

Specified by:

evaluateTypableMulti in interface ExprTypableReturnEval

evaluateTypableMultiCodegen

public CodegenExpression evaluateTypableMultiCodegen(CodegenParamSetExprPremade params,
                                                     CodegenContext context)

Specified by:

evaluateTypableMultiCodegen in interface ExprTypableReturnForge

getExprEvaluatorEnumeration

public ExprEnumerationEval getExprEvaluatorEnumeration()

Specified by:

getExprEvaluatorEnumeration in interface ExprEnumerationForge

evaluateGetEventBeanCodegen

public CodegenExpression evaluateGetEventBeanCodegen(CodegenParamSetExprPremade params,
                                                     CodegenContext context)

Specified by:

evaluateGetEventBeanCodegen in interface ExprEnumerationForge

getStatementSpecRaw

public StatementSpecRaw getStatementSpecRaw()

Returns the uncompiled statement spec.

Returns:

statement spec uncompiled

setSelectAsNames

public void setSelectAsNames(String[] selectAsNames)

Supplies the name of the select expression as-tag

Parameters:

selectAsNames - is the as-name(s)

setFilterExpr

public void setFilterExpr(ExprEvaluator filterExpr)

Sets the validated filter expression, or null if there is none.

Parameters:

filterExpr - is the filter

setHavingExpr

public void setHavingExpr(ExprEvaluator havingExpr)

toPrecedenceFreeEPL

public void toPrecedenceFreeEPL(StringWriter writer)

Specified by:

toPrecedenceFreeEPL in class ExprNodeBase

getPrecedence

public ExprPrecedenceEnum getPrecedence()

Description copied from interface: ExprNode

Returns precedence.

Specified by:

getPrecedence in interface ExprNode

Returns:

precedence

equalsNode

public boolean equalsNode(ExprNode node,
                          boolean ignoreStreamPrefix)

Description copied from interface: ExprNode

Return true if a expression node semantically equals the current node, or false if not.

Concrete implementations should compare the type and any additional information that impact the evaluation of a node.

Specified by:

equalsNode in interface ExprNode

Parameters:

node - to compare to

ignoreStreamPrefix - when the equals-comparison can ignore prefix of event properties

Returns:

true if semantically equal, or false if not equals

setStrategy

public void setStrategy(ExprSubselectStrategy strategy)

Sets the strategy for boiling down the table of lookup events into a subset against which to run the filter.

Parameters:

strategy - is the looking strategy (full table scan or indexed)

setRawEventType

public void setRawEventType(EventType rawEventType)

Sets the event type generated for wildcard selects.

Parameters:

rawEventType - is the wildcard type (parent view)

getSelectClause

public ExprNode[] getSelectClause()

Returns the select clause or null if none.

Returns:

clause

getFilterExpr

public ExprEvaluator getFilterExpr()

Returns filter expr or null if none.

Returns:

filter

getHavingExpr

public ExprEvaluator getHavingExpr()

getRawEventType

public EventType getRawEventType()

Returns the event type.

Returns:

type

getFilterSubqueryStreamTypes

public StreamTypeService getFilterSubqueryStreamTypes()

Return stream types.

Returns:

types

setFilterSubqueryStreamTypes

public void setFilterSubqueryStreamTypes(StreamTypeService filterSubqueryStreamTypes)

Set stream types.

Parameters:

filterSubqueryStreamTypes - types

getSubselectAggregationType

public ExprSubselectNode.SubqueryAggregationType getSubselectAggregationType()

setSubselectAggregationType

public void setSubselectAggregationType(ExprSubselectNode.SubqueryAggregationType subselectAggregationType)

getSubselectNumber

public int getSubselectNumber()

setFilterStreamSubselect

public void setFilterStreamSubselect(boolean filterStreamSubselect)

isFilterStreamSubselect

public boolean isFilterStreamSubselect()

toArray

public static ExprSubselectNode[] toArray(List<ExprSubselectNode> subselectNodes)

setSubselectAggregationService

public void setSubselectAggregationService(AggregationService subselectAggregationService)

getSubselectAggregationService

public AggregationService getSubselectAggregationService()

getTypableReturnEvaluator

public ExprTypableReturnEval getTypableReturnEvaluator()

Specified by:

getTypableReturnEvaluator in interface ExprTypableReturnForge