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.

Constructor Summary

Constructors

Constructor and Description
PropertyEvaluatorAccumulative()

Method Summary

Modifier and Type	Method and 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

Constructor Detail

PropertyEvaluatorAccumulative

public PropertyEvaluatorAccumulative()

Method Detail

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