Package com.espertech.esper.common.internal.epl.resultset.agggrouped

Interface ResultSetProcessorAggregateGrouped

All Superinterfaces:

AggregationRowRemovedCallback, ResultSetProcessor, StopCallback

public interface ResultSetProcessorAggregateGrouped
extends ResultSetProcessor, AggregationRowRemovedCallback

Field Summary

Fields

Modifier and Type	Field	Description
static final EPTypeClass	EPTYPE

Fields inherited from interface com.espertech.esper.common.internal.epl.resultset.core.ResultSetProcessor

EPTYPE_PROCESSORTYPE

Method Summary

Modifier and Type	Method	Description
boolean	evaluateHavingClause(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
Object[]	generateGroupKeyArrayJoin(Set<MultiKeyArrayOfKeys<EventBean>> newData, boolean isNewData)
Object[]	generateGroupKeyArrayView(EventBean[] oldData, boolean isNewData)
Object	generateGroupKeySingle(EventBean[] eventsPerStream, boolean isNewData)
void	generateOutputBatchedJoinPerKey(Set<MultiKeyArrayOfKeys<EventBean>> outputEvents, Object[] groupByKeys, boolean isNewData, boolean isSynthesize, Map<Object,EventBean> resultEvents, Map<Object,Object> optSortKeys)
void	generateOutputBatchedJoinUnkeyed(Set<MultiKeyArrayOfKeys<EventBean>> outputEvents, Object[] groupByKeys, boolean isNewData, boolean isSynthesize, Collection<EventBean> resultEvents, List<Object> optSortKeys)
EventBean	generateOutputBatchedSingle(Object key, EventBean[] event, boolean isNewData, boolean isSynthesize)
void	generateOutputBatchedViewPerKey(EventBean[] oldData, Object[] oldDataMultiKey, boolean isNewData, boolean isGenerateSynthetic, Map<Object,EventBean> outputLastUnordGroupOld, Map<Object,Object> optSortKeys, EventBean[] eventsPerStream)
void	generateOutputBatchedViewUnkeyed(EventBean[] outputEvents, Object[] groupByKeys, boolean isNewData, boolean isSynthesize, Collection<EventBean> resultEvents, List<Object> optSortKeys, EventBean[] eventsPerStream)
AggregationService	getAggregationService()
ExprEvaluatorContext	getExprEvaluatorContext()
SelectExprProcessor	getSelectExprProcessor()
boolean	hasHavingClause()
boolean	isSelectRStream()

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

removedAggregationGroupKey

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

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

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

stop

Field Details

EPTYPE

static final EPTypeClass EPTYPE

Method Details

hasHavingClause

boolean hasHavingClause()

evaluateHavingClause

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

getSelectExprProcessor

SelectExprProcessor getSelectExprProcessor()

getAggregationService

AggregationService getAggregationService()

getExprEvaluatorContext

ExprEvaluatorContext getExprEvaluatorContext()

isSelectRStream

boolean isSelectRStream()

generateGroupKeySingle

Object generateGroupKeySingle(EventBean[] eventsPerStream,
 boolean isNewData)

generateGroupKeyArrayJoin

Object[] generateGroupKeyArrayJoin(Set<MultiKeyArrayOfKeys<EventBean>> newData,
 boolean isNewData)

generateGroupKeyArrayView

Object[] generateGroupKeyArrayView(EventBean[] oldData,
 boolean isNewData)

generateOutputBatchedSingle

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

generateOutputBatchedViewUnkeyed

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

generateOutputBatchedJoinUnkeyed

void generateOutputBatchedJoinUnkeyed(Set<MultiKeyArrayOfKeys<EventBean>> outputEvents,
 Object[] groupByKeys,
 boolean isNewData,
 boolean isSynthesize,
 Collection<EventBean> resultEvents,
 List<Object> optSortKeys)

generateOutputBatchedViewPerKey

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

generateOutputBatchedJoinPerKey

void generateOutputBatchedJoinPerKey(Set<MultiKeyArrayOfKeys<EventBean>> outputEvents,
 Object[] groupByKeys,
 boolean isNewData,
 boolean isSynthesize,
 Map<Object,EventBean> resultEvents,
 Map<Object,Object> optSortKeys)