Package com.espertech.esper.common.internal.epl.contained

Class PropertyEvaluatorAccumulative

java.lang.Object

com.espertech.esper.common.internal.epl.contained.PropertyEvaluatorAccumulative

public class PropertyEvaluatorAccumulative
extends Object

A property evaluator that returns a full row of events for each stream, i.e. flattened inner-join results for property-upon-property.

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Constructor Summary

Constructors

Constructor	Description
PropertyEvaluatorAccumulative()

Method Summary

Modifier and Type	Method	Description
ArrayDeque<EventBean[]>	getAccumulative(EventBean theEvent, ExprEvaluatorContext exprEvaluatorContext)	Returns the accumulative events for the input event.
void	setContainedEventEvals(ContainedEventEval[] containedEventEvals)
void	setFragmentEventTypeIsIndexed(boolean[] fragmentEventTypeIsIndexed)
void	setPropertyNames(String[] propertyNames)
void	setWhereClauses(ExprEvaluator[] whereClauses)

Methods inherited from class java.lang.Object

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

Field Details

EPTYPE

public static final EPTypeClass EPTYPE

Constructor Details

PropertyEvaluatorAccumulative

public PropertyEvaluatorAccumulative()

Method Details

setPropertyNames

public void setPropertyNames(String[] propertyNames)

setContainedEventEvals

public void setContainedEventEvals(ContainedEventEval[] containedEventEvals)

setFragmentEventTypeIsIndexed

public void setFragmentEventTypeIsIndexed(boolean[] fragmentEventTypeIsIndexed)

setWhereClauses

public void setWhereClauses(ExprEvaluator[] whereClauses)

getAccumulative

public ArrayDeque<EventBean[]> getAccumulative(EventBean theEvent,
 ExprEvaluatorContext exprEvaluatorContext)

Returns the accumulative events for the input event.

Parameters:

theEvent - is the input event

exprEvaluatorContext - expression evaluation context

Returns:

events per stream for each row