Package com.espertech.esper.common.internal.epl.expression.subquery

Class ExprSubselectNode

java.lang.Object

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

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

All Implemented Interfaces:

ExprEnumerationForge, ExprEvaluator, ExprForge, ExprForgeInstrumentable, ExprNode, ExprNodeRenderable, ExprTypableReturnForge, ExprValidator

Direct Known Subclasses:

ExprSubselectAllSomeAnyNode, ExprSubselectExistsNode, ExprSubselectInNode, ExprSubselectRowNode

public abstract class ExprSubselectNode
extends ExprNodeBase
implements ExprEvaluator, ExprEnumerationForge, ExprTypableReturnForge, ExprForgeInstrumentable

Represents a subselect in an expression tree.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ExprSubselectNode.SubqueryAggregationType

Field Summary

Fields

Modifier and Type	Field	Description
static final ExprSubselectNode[]	EMPTY_SUBSELECT_ARRAY
protected ExprForge	filterExpr
protected ExprForge	havingExpr
protected EventType	rawEventType
protected String[]	selectAsNames
protected ExprNode[]	selectClause

Fields inherited from interface com.espertech.esper.common.internal.epl.expression.core.ExprEvaluator

EPTYPE, EPTYPEARRAY

Constructor Summary

Constructors

Constructor	Description
ExprSubselectNode(StatementSpecRaw statementSpec)	Ctor.

Method Summary

Modifier and Type	Method	Description
boolean	equalsNode(ExprNode node, boolean ignoreStreamPrefix)	Return true if a expression node semantically equals the current node, or false if not.
protected abstract CodegenExpression	evalMatchesGetCollEventsCodegen(CodegenMethodScope parent, ExprSubselectEvalMatchSymbol symbols, CodegenClassScope classScope)
protected abstract CodegenExpression	evalMatchesGetCollScalarCodegen(CodegenMethodScope parent, ExprSubselectEvalMatchSymbol symbols, CodegenClassScope classScope)
protected abstract CodegenExpression	evalMatchesGetEventBeanCodegen(CodegenMethodScope parent, ExprSubselectEvalMatchSymbol symbols, CodegenClassScope classScope)
protected abstract CodegenExpression	evalMatchesPlainCodegen(CodegenMethodScope parent, ExprSubselectEvalMatchSymbol symbols, CodegenClassScope classScope)
protected abstract CodegenExpression	evalMatchesTypableMultiCodegen(CodegenMethodScope parent, ExprSubselectEvalMatchSymbol symbols, CodegenClassScope classScope)
protected abstract CodegenExpression	evalMatchesTypableSingleCodegen(CodegenMethodScope parent, ExprSubselectEvalMatchSymbol symbols, CodegenClassScope classScope)
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)	Evaluate event tuple and return result.
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
CodegenExpression	evaluateCodegen(EPTypeClass requiredType, CodegenMethodScope parent, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
CodegenExpression	evaluateCodegenUninstrumented(EPTypeClass requiredType, CodegenMethodScope codegenMethodScope, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
CodegenExpression	evaluateGetEventBeanCodegen(CodegenMethodScope parent, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
CodegenExpression	evaluateGetROCollectionEventsCodegen(CodegenMethodScope parent, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
CodegenExpression	evaluateGetROCollectionScalarCodegen(CodegenMethodScope parent, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
CodegenExpression	evaluateTypableMultiCodegen(CodegenMethodScope parent, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
CodegenExpression	evaluateTypableSingleCodegen(CodegenMethodScope codegenMethodScope, ExprForgeCodegenSymbol exprSymbol, CodegenClassScope codegenClassScope)
ExprEvaluator	getExprEvaluator()
ExprEnumerationEval	getExprEvaluatorEnumeration()
ExprValidationContext	getFilterStreamExprValidationContext()
StreamTypeService	getFilterSubqueryStreamTypes()	Return stream types.
ExprForge	getForge()
ExprForgeConstantType	getForgeConstantType()
ExprNodeRenderable	getForgeRenderable()
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.
ExprSubselectNode.SubqueryAggregationType	getSubselectAggregationType()
int	getSubselectNumber()
abstract boolean	isAllowMultiColumnSelect()
boolean	isConstantResult()
boolean	isFilterStreamSubselect()
Boolean	isMultirow()	Return true for multi-row return, return false for return of single row only
void	setFilterExpr(ExprForge 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(ExprForge 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)	Sets the validates select clause
void	setStatementSpecCompiled(StatementSpecCompiled statementSpecCompiled, int subselectNumber)	Supplies a compiled statement spec.
void	setSubselectAggregationType(ExprSubselectNode.SubqueryAggregationType subselectAggregationType)
static ExprSubselectNode[]	toArray(List<ExprSubselectNode> subselectNodes)
void	toPrecedenceFreeEPL(StringWriter writer, ExprNodeRenderableFlags flags)
abstract LinkedHashMap<String,Object>	typableGetRowProperties()
ExprNode	validate(ExprValidationContext validationContext)
abstract void	validateSubquery(ExprValidationContext validationContext)

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

accept, accept, acceptChildnodes, addChildNode, addChildNodes, addChildNodeToFront, checkValidated, checkValidatedException, 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.common.internal.epl.expression.core.ExprEnumerationForge

getComponentTypeCollection, getEventTypeCollection, getEventTypeSingle

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

getEvaluationType

Field Details

EMPTY_SUBSELECT_ARRAY

public static final ExprSubselectNode[] EMPTY_SUBSELECT_ARRAY

selectClause

protected ExprNode[] selectClause

selectAsNames

protected String[] selectAsNames

filterExpr

protected ExprForge filterExpr

havingExpr

protected ExprForge havingExpr

rawEventType

protected EventType rawEventType

Constructor Details

ExprSubselectNode

public ExprSubselectNode(StatementSpecRaw statementSpec)

Ctor.

Parameters:

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

Method Details

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

evalMatchesPlainCodegen

protected abstract CodegenExpression evalMatchesPlainCodegen(CodegenMethodScope parent,
 ExprSubselectEvalMatchSymbol symbols,
 CodegenClassScope classScope)

evalMatchesGetCollEventsCodegen

protected abstract CodegenExpression evalMatchesGetCollEventsCodegen(CodegenMethodScope parent,
 ExprSubselectEvalMatchSymbol symbols,
 CodegenClassScope classScope)

evalMatchesGetCollScalarCodegen

protected abstract CodegenExpression evalMatchesGetCollScalarCodegen(CodegenMethodScope parent,
 ExprSubselectEvalMatchSymbol symbols,
 CodegenClassScope classScope)

evalMatchesGetEventBeanCodegen

protected abstract CodegenExpression evalMatchesGetEventBeanCodegen(CodegenMethodScope parent,
 ExprSubselectEvalMatchSymbol symbols,
 CodegenClassScope classScope)

evalMatchesTypableSingleCodegen

protected abstract CodegenExpression evalMatchesTypableSingleCodegen(CodegenMethodScope parent,
 ExprSubselectEvalMatchSymbol symbols,
 CodegenClassScope classScope)

evalMatchesTypableMultiCodegen

protected abstract CodegenExpression evalMatchesTypableMultiCodegen(CodegenMethodScope parent,
 ExprSubselectEvalMatchSymbol symbols,
 CodegenClassScope classScope)

getExprEvaluator

public ExprEvaluator getExprEvaluator()

Specified by:

getExprEvaluator in interface ExprForge

isConstantResult

public boolean isConstantResult()

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)

Sets the validates select clause

Parameters:

selectClause - is the expression representing the select clause

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.

evaluate

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

evaluateCodegenUninstrumented

public CodegenExpression evaluateCodegenUninstrumented(EPTypeClass requiredType,
 CodegenMethodScope codegenMethodScope,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateCodegenUninstrumented in interface ExprForgeInstrumentable

evaluateCodegen

public CodegenExpression evaluateCodegen(EPTypeClass requiredType,
 CodegenMethodScope parent,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateCodegen in interface ExprForge

evaluateGetROCollectionEventsCodegen

public CodegenExpression evaluateGetROCollectionEventsCodegen(CodegenMethodScope parent,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateGetROCollectionEventsCodegen in interface ExprEnumerationForge

evaluateGetROCollectionScalarCodegen

public CodegenExpression evaluateGetROCollectionScalarCodegen(CodegenMethodScope parent,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateGetROCollectionScalarCodegen in interface ExprEnumerationForge

evaluateGetEventBeanCodegen

public CodegenExpression evaluateGetEventBeanCodegen(CodegenMethodScope parent,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateGetEventBeanCodegen in interface ExprEnumerationForge

evaluateTypableSingleCodegen

public CodegenExpression evaluateTypableSingleCodegen(CodegenMethodScope codegenMethodScope,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateTypableSingleCodegen in interface ExprTypableReturnForge

evaluateTypableMultiCodegen

public CodegenExpression evaluateTypableMultiCodegen(CodegenMethodScope parent,
 ExprForgeCodegenSymbol exprSymbol,
 CodegenClassScope codegenClassScope)

Specified by:

evaluateTypableMultiCodegen in interface ExprTypableReturnForge

getForgeConstantType

public ExprForgeConstantType getForgeConstantType()

Specified by:

getForgeConstantType in interface ExprForge

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

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(ExprForge filterExpr)

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

Parameters:

filterExpr - is the filter

setHavingExpr

public void setHavingExpr(ExprForge havingExpr)

toPrecedenceFreeEPL

public void toPrecedenceFreeEPL(StringWriter writer,
 ExprNodeRenderableFlags flags)

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

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

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()

getExprEvaluatorEnumeration

public ExprEnumerationEval getExprEvaluatorEnumeration()

Specified by:

getExprEvaluatorEnumeration in interface ExprEnumerationForge

getFilterStreamExprValidationContext

public ExprValidationContext getFilterStreamExprValidationContext()

toArray

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