com.espertech.esper.epl.core
Class ResultSetProcessorRowPerGroupSpecial

java.lang.Object
  extended by com.espertech.esper.epl.core.ResultSetProcessorRowPerGroup
      extended by com.espertech.esper.epl.core.ResultSetProcessorRowPerGroupSpecial
All Implemented Interfaces:
AggregationRowRemovedCallback, ResultSetProcessor

public class ResultSetProcessorRowPerGroupSpecial
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
ResultSetProcessorRowPerGroupSpecial(ResultSetProcessorRowPerGroupFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)
           
 
Method Summary
 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
clear, generateGroupKey, generateGroupKeys, generateOutputEventsView, getIterator, getIteratorSorted, getOptionalHavingNode, getResultEventType, getSelectExprProcessor, hasAggregation, 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

ResultSetProcessorRowPerGroupSpecial

public ResultSetProcessorRowPerGroupSpecial(ResultSetProcessorRowPerGroupFactory prototype,
                                            SelectExprProcessor selectExprProcessor,
                                            OrderByProcessor orderByProcessor,
                                            AggregationService aggregationService,
                                            AgentInstanceContext agentInstanceContext)
Method Detail

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

© 2006-2014 EsperTech Inc.
All rights reserved.
Visit us at espertech.com