com.espertech.esper.epl.expression.subquery

Class ExprSubselectRowNode

java.lang.Object

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

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

com.espertech.esper.epl.expression.subquery.ExprSubselectRowNode

All Implemented Interfaces:

ExprEvaluator, ExprEvaluatorEnumeration, ExprEvaluatorTypableReturn, ExprNode, ExprValidator, MetaDefItem, Serializable

public class ExprSubselectRowNode
extends ExprSubselectNode

Represents a subselect in an expression tree.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	ExprSubselectRowNode.SubselectMultirowType

Nested classes/interfaces inherited from class com.espertech.esper.epl.expression.subquery.ExprSubselectNode

ExprSubselectNode.SubqueryAggregationType

Field Summary

Fields

Modifier and Type	Field and Description
static SubselectEvalStrategyRow	FILTERED_SELECTED
static SubselectEvalStrategyRow	FILTERED_UNSELECTED
static SubselectEvalStrategyRow	HAVING_SELECTED
protected ExprSubselectRowNode.SubselectMultirowType	subselectMultirowType
static SubselectEvalStrategyRow	UNFILTERED_SELECTED
static SubselectEvalStrategyRow	UNFILTERED_SELECTED_GROUPED

Fields inherited from class com.espertech.esper.epl.expression.subquery.ExprSubselectNode

EMPTY_SUBSELECT_ARRAY, filterExpr, havingExpr, rawEventType, selectAsNames, selectClause, selectClauseEvaluator, statementName, subselectAggregationService, subselectNumber

Constructor Summary

Constructors

Constructor and Description
ExprSubselectRowNode(StatementSpecRaw statementSpec) Ctor.

Method Summary

Modifier and Type	Method and Description
Object	evaluate(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext) Evaluate the lookup expression returning an evaluation result object.
Collection<EventBean>	evaluateGetCollEvents(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext context)
Collection	evaluateGetCollScalar(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext context)
EventBean	evaluateGetEventBean(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
protected Map<String,Object>	evaluateRow(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext context)
Object[][]	evaluateTypableMulti(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
Object[]	evaluateTypableSingle(EventBean[] eventsPerStream, boolean isNewData, Collection<EventBean> matchingEvents, ExprEvaluatorContext exprEvaluatorContext)
Class	getComponentTypeCollection()
EventType	getEventTypeCollection(EventAdapterService eventAdapterService, int statementId)
EventType	getEventTypeSingle(EventAdapterService eventAdapterService, int statementId)
String	getMultirowMessage()
Class	getType() Returns the type that the node's evaluate method returns an instance of.
boolean	isAllowMultiColumnSelect()
LinkedHashMap<String,Object>	typableGetRowProperties()
void	validateSubquery(ExprValidationContext validationContext)

Methods inherited from class com.espertech.esper.epl.expression.subquery.ExprSubselectNode

equalsNode, evaluate, evaluateGetEventBean, evaluateGetROCollectionEvents, evaluateGetROCollectionScalar, evaluateTypableMulti, evaluateTypableSingle, getExprEvaluator, getFilterExpr, getFilterSubqueryStreamTypes, getHavingExpr, getPrecedence, getRawEventType, getRowProperties, getSelectClause, getStatementSpecCompiled, getStatementSpecRaw, getSubselectAggregationService, getSubselectAggregationType, getSubselectNumber, isConstantResult, isFilterStreamSubselect, isMultirow, setFilterExpr, setFilterStreamSubselect, setFilterSubqueryStreamTypes, setHavingExpr, setRawEventType, setSelectAsNames, setSelectClause, setStatementSpecCompiled, setStrategy, setSubselectAggregationService, setSubselectAggregationType, toArray, toPrecedenceFreeEPL, validate

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

Field Detail

UNFILTERED_SELECTED

public static final SubselectEvalStrategyRow UNFILTERED_SELECTED

FILTERED_UNSELECTED

public static final SubselectEvalStrategyRow FILTERED_UNSELECTED

FILTERED_SELECTED

public static final SubselectEvalStrategyRow FILTERED_SELECTED

HAVING_SELECTED

public static final SubselectEvalStrategyRow HAVING_SELECTED

UNFILTERED_SELECTED_GROUPED

public static final SubselectEvalStrategyRow UNFILTERED_SELECTED_GROUPED

subselectMultirowType

protected transient ExprSubselectRowNode.SubselectMultirowType subselectMultirowType

Constructor Detail

ExprSubselectRowNode

public ExprSubselectRowNode(StatementSpecRaw statementSpec)

Ctor.

Parameters:

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

Method Detail

getType

public Class getType()

Description copied from interface: ExprEvaluator

Returns the type that the node's evaluate method returns an instance of.

Returns:

type returned when evaluated

validateSubquery

public void validateSubquery(ExprValidationContext validationContext)
                      throws ExprValidationException

Specified by:

validateSubquery in class ExprSubselectNode

Throws:

ExprValidationException

evaluate

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

Description copied from class: ExprSubselectNode

Evaluate the lookup expression returning an evaluation result object.

Specified by:

evaluate in class ExprSubselectNode

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 Collection<EventBean> evaluateGetCollEvents(EventBean[] eventsPerStream,
                                                   boolean isNewData,
                                                   Collection<EventBean> matchingEvents,
                                                   ExprEvaluatorContext context)

Specified by:

evaluateGetCollEvents in class ExprSubselectNode

evaluateGetCollScalar

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

Specified by:

evaluateGetCollScalar in class ExprSubselectNode

evaluateGetEventBean

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

Specified by:

evaluateGetEventBean in class ExprSubselectNode

evaluateTypableSingle

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

Specified by:

evaluateTypableSingle in class ExprSubselectNode

evaluateTypableMulti

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

Specified by:

evaluateTypableMulti in class ExprSubselectNode

typableGetRowProperties

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

Specified by:

typableGetRowProperties in class ExprSubselectNode

Throws:

ExprValidationException

getEventTypeSingle

public EventType getEventTypeSingle(EventAdapterService eventAdapterService,
                                    int statementId)
                             throws ExprValidationException

Throws:

ExprValidationException

getEventTypeCollection

public EventType getEventTypeCollection(EventAdapterService eventAdapterService,
                                        int statementId)
                                 throws ExprValidationException

Throws:

ExprValidationException

getComponentTypeCollection

public Class getComponentTypeCollection()
                                 throws ExprValidationException

Throws:

ExprValidationException

isAllowMultiColumnSelect

public boolean isAllowMultiColumnSelect()

Specified by:

isAllowMultiColumnSelect in class ExprSubselectNode

getMultirowMessage

public String getMultirowMessage()

evaluateRow

protected Map<String,Object> evaluateRow(EventBean[] eventsPerStream,
                                         boolean isNewData,
                                         ExprEvaluatorContext context)