com.espertech.esper.epl.core
Class ResultSetProcessorRowPerGroupUnbound

java.lang.Object
  com.espertech.esper.epl.core.ResultSetProcessorRowPerGroup
      com.espertech.esper.epl.core.ResultSetProcessorRowPerGroupUnbound

All Implemented Interfaces:

AggregationRowRemovedCallback, ResultSetProcessor

public class ResultSetProcessorRowPerGroupUnbound
extends ResultSetProcessorRowPerGroup
implements AggregationRowRemovedCallback

Field Summary

protected java.util.Map<java.lang.Object,EventBean>

groupReps

Fields inherited from class com.espertech.esper.epl.core.ResultSetProcessorRowPerGroup

agentInstanceContext, aggregationService, groupRepsView, orderByProcessor, prototype, selectExprProcessor

Constructor Summary

ResultSetProcessorRowPerGroupUnbound(ResultSetProcessorRowPerGroupFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

Method Summary

void	applyViewResult(EventBean[] newData, EventBean[] oldData)
java.util.Iterator<EventBean>	getIterator(Viewable parent) Returns the iterator implementing the group-by and aggregation and order-by logic specific to each case of use of these construct.
UniformPair<EventBean[]>	processViewResult(EventBean[] newData, EventBean[] oldData, boolean isSynthesize) For use by views posting their result, process the event rows that are entered and removed (new and old events).
void	removed(java.lang.Object optionalGroupKeyPerRow)

Methods inherited from class com.espertech.esper.epl.core.ResultSetProcessorRowPerGroup

applyJoinResult, clear, generateGroupKey, generateGroupKeys, generateOutputEventsView, getIterator, getIteratorSorted, getOptionalHavingNode, getResultEventType, getSelectExprProcessor, hasAggregation, obtainIterator, processJoinResult, processOutputLimitedJoin, processOutputLimitedView, setAgentInstanceContext

Methods inherited from class java.lang.Object

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

Field Detail

groupReps

protected final java.util.Map<java.lang.Object,EventBean> groupReps

Constructor Detail

ResultSetProcessorRowPerGroupUnbound

public ResultSetProcessorRowPerGroupUnbound(ResultSetProcessorRowPerGroupFactory prototype,
                                            SelectExprProcessor selectExprProcessor,
                                            OrderByProcessor orderByProcessor,
                                            AggregationService aggregationService,
                                            AgentInstanceContext agentInstanceContext)

Method Detail

applyViewResult

public void applyViewResult(EventBean[] newData,
                            EventBean[] oldData)

Specified by:

applyViewResult in interface ResultSetProcessor

Overrides:

applyViewResult in class ResultSetProcessorRowPerGroup

processViewResult

public UniformPair<EventBean[]> processViewResult(EventBean[] newData,
                                                  EventBean[] oldData,
                                                  boolean isSynthesize)

Description copied from interface: ResultSetProcessor

For use by views posting their result, process the event rows that are entered and removed (new and old events). Processes according to select-clauses, group-by clauses and having-clauses and returns new events and old events as specified.

Specified by:

processViewResult in interface ResultSetProcessor

Overrides:

processViewResult in class ResultSetProcessorRowPerGroup

Parameters:

newData - - new events posted by view

oldData - - old events posted by view

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

Returns:

pair of new events and old events

getIterator

public java.util.Iterator<EventBean> getIterator(Viewable parent)

Description copied from interface: ResultSetProcessor

Returns the iterator implementing the group-by and aggregation and order-by logic specific to each case of use of these construct.

Specified by:

getIterator in interface ResultSetProcessor

Overrides:

getIterator in class ResultSetProcessorRowPerGroup

Parameters:

parent - is the parent view iterator

Returns:

event iterator

removed

public void removed(java.lang.Object optionalGroupKeyPerRow)

Specified by:

removed in interface AggregationRowRemovedCallback

Overrides:

removed in class ResultSetProcessorRowPerGroup