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

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

Method Summary

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