com.espertech.esper.epl.core.resultset.agggrouped

Interface ResultSetProcessorAggregateGrouped

All Superinterfaces:

AggregationRowRemovedCallback, ResultSetProcessor, StopCallback

All Known Implementing Classes:

ResultSetProcessorAggregateGroupedImpl

public interface ResultSetProcessorAggregateGrouped
extends ResultSetProcessor, AggregationRowRemovedCallback

Method Summary

Modifier and Type	Method and Description
boolean	evaluateHavingClause(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object[]	generateGroupKeyArrayJoin(java.util.Set<MultiKey<EventBean>> newData, boolean isNewData)
java.lang.Object[]	generateGroupKeyArrayView(EventBean[] oldData, boolean isNewData)
java.lang.Object	generateGroupKeySingle(EventBean[] eventsPerStream, boolean isNewData)
void	generateOutputBatchedJoinPerKey(java.util.Set<MultiKey<EventBean>> outputEvents, java.lang.Object[] groupByKeys, boolean isNewData, boolean isSynthesize, java.util.Map<java.lang.Object,EventBean> resultEvents, java.util.Map<java.lang.Object,java.lang.Object> optSortKeys)
void	generateOutputBatchedJoinUnkeyed(java.util.Set<MultiKey<EventBean>> outputEvents, java.lang.Object[] groupByKeys, boolean isNewData, boolean isSynthesize, java.util.Collection<EventBean> resultEvents, java.util.List<java.lang.Object> optSortKeys)
EventBean	generateOutputBatchedSingle(java.lang.Object key, EventBean[] event, boolean isNewData, boolean isSynthesize)
void	generateOutputBatchedViewPerKey(EventBean[] oldData, java.lang.Object[] oldDataMultiKey, boolean isNewData, boolean isGenerateSynthetic, java.util.Map<java.lang.Object,EventBean> outputLastUnordGroupOld, java.util.Map<java.lang.Object,java.lang.Object> optSortKeys, EventBean[] eventsPerStream)
void	generateOutputBatchedViewUnkeyed(EventBean[] outputEvents, java.lang.Object[] groupByKeys, boolean isNewData, boolean isSynthesize, java.util.Collection<EventBean> resultEvents, java.util.List<java.lang.Object> optSortKeys, EventBean[] eventsPerStream)
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

hasHavingClause

boolean hasHavingClause()

evaluateHavingClause

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

getSelectExprProcessor

SelectExprProcessor getSelectExprProcessor()

getAggregationService

AggregationService getAggregationService()

getAgentInstanceContext

ExprEvaluatorContext getAgentInstanceContext()

isSelectRStream

boolean isSelectRStream()

generateGroupKeySingle

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

generateGroupKeyArrayJoin

java.lang.Object[] generateGroupKeyArrayJoin(java.util.Set<MultiKey<EventBean>> newData,
                                             boolean isNewData)

generateGroupKeyArrayView

java.lang.Object[] generateGroupKeyArrayView(EventBean[] oldData,
                                             boolean isNewData)

generateOutputBatchedSingle

EventBean generateOutputBatchedSingle(java.lang.Object key,
                                      EventBean[] event,
                                      boolean isNewData,
                                      boolean isSynthesize)

generateOutputBatchedViewUnkeyed

void generateOutputBatchedViewUnkeyed(EventBean[] outputEvents,
                                      java.lang.Object[] groupByKeys,
                                      boolean isNewData,
                                      boolean isSynthesize,
                                      java.util.Collection<EventBean> resultEvents,
                                      java.util.List<java.lang.Object> optSortKeys,
                                      EventBean[] eventsPerStream)

generateOutputBatchedJoinUnkeyed

void generateOutputBatchedJoinUnkeyed(java.util.Set<MultiKey<EventBean>> outputEvents,
                                      java.lang.Object[] groupByKeys,
                                      boolean isNewData,
                                      boolean isSynthesize,
                                      java.util.Collection<EventBean> resultEvents,
                                      java.util.List<java.lang.Object> optSortKeys)

generateOutputBatchedViewPerKey

void generateOutputBatchedViewPerKey(EventBean[] oldData,
                                     java.lang.Object[] oldDataMultiKey,
                                     boolean isNewData,
                                     boolean isGenerateSynthetic,
                                     java.util.Map<java.lang.Object,EventBean> outputLastUnordGroupOld,
                                     java.util.Map<java.lang.Object,java.lang.Object> optSortKeys,
                                     EventBean[] eventsPerStream)

generateOutputBatchedJoinPerKey

void generateOutputBatchedJoinPerKey(java.util.Set<MultiKey<EventBean>> outputEvents,
                                     java.lang.Object[] groupByKeys,
                                     boolean isNewData,
                                     boolean isSynthesize,
                                     java.util.Map<java.lang.Object,EventBean> resultEvents,
                                     java.util.Map<java.lang.Object,java.lang.Object> optSortKeys)