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

Interface ResultSetProcessorRowPerGroup

All Superinterfaces:

AggregationRowRemovedCallback, ResultSetProcessor, StopCallback

All Known Implementing Classes:

ResultSetProcessorRowPerGroupImpl, ResultSetProcessorRowPerGroupUnbound

public interface ResultSetProcessorRowPerGroup
extends ResultSetProcessor, AggregationRowRemovedCallback

Method Summary

Modifier and Type	Method and Description
boolean	evaluateHavingClause(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object	generateGroupKeySingle(EventBean[] eventsPerStream, boolean isNewData)
void	generateOutputBatchedArrFromIterator(boolean join, java.util.Iterator<java.util.Map.Entry<java.lang.Object,EventBean[]>> keysAndEvents, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> resultEvents, java.util.List<java.lang.Object> optSortKeys)
EventBean	generateOutputBatchedNoSortWMap(boolean join, java.lang.Object mk, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize)
ExprEvaluatorContext	getAgentInstanceContext()
AggregationService	getAggregationService()
SelectExprProcessor	getSelectExprProcessor()
boolean	hasHavingClause()
boolean	isSelectRStream()

Methods inherited from interface com.espertech.esper.epl.core.resultset.core.ResultSetProcessor

acceptHelperVisitor, applyJoinResult, applyViewResult, clear, continueOutputLimitedLastAllNonBufferedJoin, continueOutputLimitedLastAllNonBufferedView, getIterator, getIterator, getResultEventType, processJoinResult, processOutputLimitedJoin, processOutputLimitedLastAllNonBufferedJoin, processOutputLimitedLastAllNonBufferedView, processOutputLimitedView, processViewResult, setAgentInstanceContext

Methods inherited from interface com.espertech.esper.util.StopCallback

stop

Methods inherited from interface com.espertech.esper.epl.agg.service.common.AggregationRowRemovedCallback

removedAggregationGroupKey

Method Detail

generateGroupKeySingle

java.lang.Object generateGroupKeySingle(EventBean[] eventsPerStream,
                                        boolean isNewData)

hasHavingClause

boolean hasHavingClause()

evaluateHavingClause

boolean evaluateHavingClause(EventBean[] eventsPerStream,
                             boolean isNewData,
                             ExprEvaluatorContext exprEvaluatorContext)

isSelectRStream

boolean isSelectRStream()

getAggregationService

AggregationService getAggregationService()

getAgentInstanceContext

ExprEvaluatorContext getAgentInstanceContext()

getSelectExprProcessor

SelectExprProcessor getSelectExprProcessor()

generateOutputBatchedNoSortWMap

EventBean generateOutputBatchedNoSortWMap(boolean join,
                                          java.lang.Object mk,
                                          EventBean[] eventsPerStream,
                                          boolean isNewData,
                                          boolean isSynthesize)

generateOutputBatchedArrFromIterator

void generateOutputBatchedArrFromIterator(boolean join,
                                          java.util.Iterator<java.util.Map.Entry<java.lang.Object,EventBean[]>> keysAndEvents,
                                          boolean isNewData,
                                          boolean isSynthesize,
                                          java.util.List<EventBean> resultEvents,
                                          java.util.List<java.lang.Object> optSortKeys)