com.espertech.esper.epl.core.resultset.rowpergroup

Class ResultSetProcessorRowPerGroupUnbound

java.lang.Object

com.espertech.esper.epl.core.resultset.rowpergroup.ResultSetProcessorRowPerGroupImpl

com.espertech.esper.epl.core.resultset.rowpergroup.ResultSetProcessorRowPerGroupUnbound

All Implemented Interfaces:

AggregationRowRemovedCallback, ResultSetProcessor, ResultSetProcessorRowPerGroup, StopCallback

public class ResultSetProcessorRowPerGroupUnbound
extends ResultSetProcessorRowPerGroupImpl

Field Summary

Fields inherited from class com.espertech.esper.epl.core.resultset.rowpergroup.ResultSetProcessorRowPerGroupImpl

agentInstanceContext, aggregationService, orderByProcessor, prototype, selectExprProcessor

Method Summary

Modifier and Type	Method and Description
void	applyViewResult(EventBean[] newData, EventBean[] oldData)
static void	applyViewResultCodegen(ResultSetProcessorRowPerGroupForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
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.
static void	getIteratorViewUnboundedCodegen(ResultSetProcessorRowPerGroupForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
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	stop() Stops the underlying resources.
static void	stopMethodCodegenUnbound(ResultSetProcessorRowPerGroupForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)

Methods inherited from class com.espertech.esper.epl.core.resultset.rowpergroup.ResultSetProcessorRowPerGroupImpl

acceptHelperVisitor, acceptHelperVisitorCodegen, applyJoinResult, applyJoinResultCodegen, clear, clearMethodCodegen, continueOutputLimitedLastAllNonBufferedJoin, continueOutputLimitedLastAllNonBufferedJoinCodegen, continueOutputLimitedLastAllNonBufferedView, continueOutputLimitedLastAllNonBufferedViewCodegen, evaluateHavingClause, generateGroupKeySingle, generateOutputBatchedArrFromIterator, generateOutputBatchedNoSortWMap, getAgentInstanceContext, getAggregationService, getIterator, getIteratorJoinCodegen, getIteratorViewCodegen, getOptionalHavingNode, getResultEventType, getSelectExprProcessor, hasHavingClause, isSelectRStream, processJoinResult, processJoinResultCodegen, processOutputLimitedJoin, processOutputLimitedJoinCodegen, processOutputLimitedLastAllNonBufferedJoin, processOutputLimitedLastAllNonBufferedJoinCodegen, processOutputLimitedLastAllNonBufferedView, processOutputLimitedLastAllNonBufferedViewCodegen, processOutputLimitedView, processOutputLimitedViewCodegen, processViewResultCodegen, removedAggregationGroupKey, setAgentInstanceContext, stopMethodCodegenBound

Methods inherited from class java.lang.Object

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

Method Detail

applyViewResult

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

Specified by:

applyViewResult in interface ResultSetProcessor

Overrides:

applyViewResult in class ResultSetProcessorRowPerGroupImpl

applyViewResultCodegen

public static void applyViewResultCodegen(ResultSetProcessorRowPerGroupForge forge,
                                          CodegenClassScope classScope,
                                          CodegenMethodNode method,
                                          CodegenInstanceAux instance)

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 ResultSetProcessorRowPerGroupImpl

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 ResultSetProcessorRowPerGroupImpl

Parameters:

parent - is the parent view iterator

Returns:

event iterator

getIteratorViewUnboundedCodegen

public static void getIteratorViewUnboundedCodegen(ResultSetProcessorRowPerGroupForge forge,
                                                   CodegenClassScope classScope,
                                                   CodegenMethodNode method,
                                                   CodegenInstanceAux instance)

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

Overrides:

stop in class ResultSetProcessorRowPerGroupImpl

stopMethodCodegenUnbound

public static void stopMethodCodegenUnbound(ResultSetProcessorRowPerGroupForge forge,
                                            CodegenClassScope classScope,
                                            CodegenMethodNode method,
                                            CodegenInstanceAux instance)