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

Interface ResultSetProcessorRowPerGroupRollup

All Superinterfaces:

AggregationRowRemovedCallback, ResultSetProcessor, StopCallback

public interface ResultSetProcessorRowPerGroupRollup
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
Object	generateGroupKeySingle(EventBean[] eventsPerStream, boolean isNewData)
void	generateOutputBatched(Object mk, AggregationGroupByRollupLevel level, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize, List<EventBean> resultEvents, List<Object> optSortKeys)
void	generateOutputBatchedMapUnsorted(boolean join, Object mk, AggregationGroupByRollupLevel level, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize, Map<Object,EventBean> resultEvents)
AggregationService	getAggregationService()
ExprEvaluatorContext	getExprEvaluatorContext()
AggregationGroupByRollupDesc	getGroupByRollupDesc()
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

getAggregationService

AggregationService getAggregationService()

getExprEvaluatorContext

ExprEvaluatorContext getExprEvaluatorContext()

isSelectRStream

boolean isSelectRStream()

getGroupByRollupDesc

AggregationGroupByRollupDesc getGroupByRollupDesc()

generateGroupKeySingle

Object generateGroupKeySingle(EventBean[] eventsPerStream,
 boolean isNewData)

generateOutputBatchedMapUnsorted

void generateOutputBatchedMapUnsorted(boolean join,
 Object mk,
 AggregationGroupByRollupLevel level,
 EventBean[] eventsPerStream,
 boolean isNewData,
 boolean isSynthesize,
 Map<Object,EventBean> resultEvents)

generateOutputBatched

void generateOutputBatched(Object mk,
 AggregationGroupByRollupLevel level,
 EventBean[] eventsPerStream,
 boolean isNewData,
 boolean isSynthesize,
 List<EventBean> resultEvents,
 List<Object> optSortKeys)