com.espertech.esper.epl.property

Class PropertyEvaluatorAccumulative

java.lang.Object

com.espertech.esper.epl.property.PropertyEvaluatorAccumulative

public class PropertyEvaluatorAccumulative
extends java.lang.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(ContainedEventEval[] containedEventEvals, FragmentEventType[] fragmentEventType, ExprEvaluator[] whereClauses, java.util.List<java.lang.String> propertyNames) Ctor.

Method Summary

Modifier and Type	Method and Description
java.util.ArrayDeque<EventBean[]>	getAccumulative(EventBean theEvent, ExprEvaluatorContext exprEvaluatorContext) Returns the accumulative events for the input event.

Methods inherited from class java.lang.Object

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

Constructor Detail

PropertyEvaluatorAccumulative

public PropertyEvaluatorAccumulative(ContainedEventEval[] containedEventEvals,
                                     FragmentEventType[] fragmentEventType,
                                     ExprEvaluator[] whereClauses,
                                     java.util.List<java.lang.String> propertyNames)

Ctor.

Parameters:

containedEventEvals - property getters or other evaluators

fragmentEventType - property fragment types

whereClauses - filters, if any

propertyNames - the property names that are staggered

Method Detail

getAccumulative

public java.util.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