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

Class ResultSetProcessorAggregateGroupedImpl

java.lang.Object

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

All Implemented Interfaces:

AggregationRowRemovedCallback, ResultSetProcessorAggregateGrouped, ResultSetProcessor, StopCallback

public class ResultSetProcessorAggregateGroupedImpl
extends java.lang.Object
implements ResultSetProcessorAggregateGrouped

Result-set processor for the aggregate-grouped case: there is a group-by and one or more non-aggregation event properties in the select clause are not listed in the group by, and there are aggregation functions.

This processor does perform grouping by computing MultiKey group-by keys for each row. The processor generates one row for each event entering (new event) and one row for each event leaving (old event).

Aggregation state is a table of rows held by AggregationService where the row key is the group-by MultiKey.

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentInstanceContext	agentInstanceContext
protected AggregationService	aggregationService
protected ResultSetProcessorAggregateGroupedFactory	prototype

Method Summary

Modifier and Type	Method and Description
void	acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor)
static void	acceptHelperVisitorCodegen(CodegenMethodNode method, CodegenInstanceAux instance)
void	applyJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents)
static void	applyJoinResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	applyViewResult(EventBean[] newData, EventBean[] oldData)
static void	applyViewResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	clear() Clear out current state.
static void	clearMethodCodegen(CodegenMethodNode method)
UniformPair<EventBean[]>	continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize)
static void	continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenMethodNode method)
UniformPair<EventBean[]>	continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize)
static void	continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenMethodNode method)
boolean	evaluateHavingClause(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext)
java.lang.Object[]	generateGroupKeyArrayJoin(java.util.Set<MultiKey<EventBean>> resultSet, boolean isNewData)
java.lang.Object[]	generateGroupKeyArrayView(EventBean[] events, boolean isNewData)
java.lang.Object	generateGroupKeySingle(EventBean[] eventsPerStream, boolean isNewData) Generates the group-by key for the row
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 groupByKey, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize)
void	generateOutputBatchedViewPerKey(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, 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()
java.util.Iterator<EventBean>	getIterator(java.util.Set<MultiKey<EventBean>> joinSet) Returns the iterator for iterating over a join-result.
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	getIteratorJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
static void	getIteratorViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
ExprEvaluator	getOptionalHavingNode() Returns the having node.
EventType	getResultEventType() Returns the event type of processed results.
SelectExprProcessor	getSelectExprProcessor() Returns the select expression processor
boolean	hasHavingClause()
boolean	isSelectRStream()
UniformPair<EventBean[]>	processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isSynthesize) For use by joins posting their result, process the event rows that are entered and removed (new and old events).
static void	processJoinResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
UniformPair<EventBean[]>	processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic) Processes batched events in case of output-rate limiting.
static void	processOutputLimitedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	processOutputLimitedLastAllNonBufferedJoin(java.util.Set<MultiKey<EventBean>> newData, java.util.Set<MultiKey<EventBean>> oldData, boolean isGenerateSynthetic)
static void	processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	processOutputLimitedLastAllNonBufferedView(EventBean[] newData, EventBean[] oldData, boolean isGenerateSynthetic)
static void	processOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
UniformPair<EventBean[]>	processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic) Processes batched events in case of output-rate limiting.
static void	processOutputLimitedViewCodegen(ResultSetProcessorAggregateGroupedForge 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).
static void	processViewResultCodegen(ResultSetProcessorAggregateGroupedForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	removedAggregationGroupKey(java.lang.Object key)
void	setAgentInstanceContext(AgentInstanceContext agentInstanceContext)
void	stop() Stops the underlying resources.
static void	stopMethodCodegen(CodegenMethodNode method, CodegenInstanceAux instance)

Methods inherited from class java.lang.Object

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

Field Detail

prototype

protected final ResultSetProcessorAggregateGroupedFactory prototype

aggregationService

protected final AggregationService aggregationService

agentInstanceContext

protected AgentInstanceContext agentInstanceContext

Method Detail

setAgentInstanceContext

public void setAgentInstanceContext(AgentInstanceContext agentInstanceContext)

Specified by:

setAgentInstanceContext in interface ResultSetProcessor

getResultEventType

public EventType getResultEventType()

Description copied from interface: ResultSetProcessor

Returns the event type of processed results.

Specified by:

getResultEventType in interface ResultSetProcessor

Returns:

event type of the resulting events posted by the processor.

getAggregationService

public AggregationService getAggregationService()

Specified by:

getAggregationService in interface ResultSetProcessorAggregateGrouped

applyViewResult

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

Specified by:

applyViewResult in interface ResultSetProcessor

applyViewResultCodegen

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

applyJoinResult

public void applyJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
                            java.util.Set<MultiKey<EventBean>> oldEvents)

Specified by:

applyJoinResult in interface ResultSetProcessor

applyJoinResultCodegen

public static void applyJoinResultCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                          CodegenClassScope classScope,
                                          CodegenMethodNode method,
                                          CodegenInstanceAux instance)

processJoinResult

public UniformPair<EventBean[]> processJoinResult(java.util.Set<MultiKey<EventBean>> newEvents,
                                                  java.util.Set<MultiKey<EventBean>> oldEvents,
                                                  boolean isSynthesize)

Description copied from interface: ResultSetProcessor

For use by joins 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:

processJoinResult in interface ResultSetProcessor

Parameters:

newEvents - - new events posted by join

oldEvents - - old events posted by join

isSynthesize - - set to true to indicate that synthetic events are required for an iterator result set

Returns:

pair of new events and old events

processJoinResultCodegen

public static void processJoinResultCodegen(ResultSetProcessorAggregateGroupedForge 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

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

processViewResultCodegen

public static void processViewResultCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                            CodegenClassScope classScope,
                                            CodegenMethodNode method,
                                            CodegenInstanceAux instance)

generateGroupKeyArrayJoin

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

Specified by:

generateGroupKeyArrayJoin in interface ResultSetProcessorAggregateGrouped

generateGroupKeyArrayView

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

Specified by:

generateGroupKeyArrayView in interface ResultSetProcessorAggregateGrouped

acceptHelperVisitor

public void acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor)

Specified by:

acceptHelperVisitor in interface ResultSetProcessor

acceptHelperVisitorCodegen

public static void acceptHelperVisitorCodegen(CodegenMethodNode method,
                                              CodegenInstanceAux instance)

generateGroupKeySingle

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

Generates the group-by key for the row

Specified by:

generateGroupKeySingle in interface ResultSetProcessorAggregateGrouped

Parameters:

eventsPerStream - is the row of events

isNewData - is true for new data

Returns:

grouping keys

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

Parameters:

parent - is the parent view iterator

Returns:

event iterator

getIteratorViewCodegen

public static void getIteratorViewCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                          CodegenClassScope classScope,
                                          CodegenMethodNode method,
                                          CodegenInstanceAux instance)

getSelectExprProcessor

public SelectExprProcessor getSelectExprProcessor()

Returns the select expression processor

Specified by:

getSelectExprProcessor in interface ResultSetProcessorAggregateGrouped

Returns:

select processor.

getOptionalHavingNode

public ExprEvaluator getOptionalHavingNode()

Returns the having node.

Returns:

having expression

getIterator

public java.util.Iterator<EventBean> getIterator(java.util.Set<MultiKey<EventBean>> joinSet)

Description copied from interface: ResultSetProcessor

Returns the iterator for iterating over a join-result.

Specified by:

getIterator in interface ResultSetProcessor

Parameters:

joinSet - is the join result set

Returns:

iterator over join results

getIteratorJoinCodegen

public static void getIteratorJoinCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                          CodegenClassScope classScope,
                                          CodegenMethodNode method,
                                          CodegenInstanceAux instance)

clear

public void clear()

Description copied from interface: ResultSetProcessor

Clear out current state.

Specified by:

clear in interface ResultSetProcessor

clearMethodCodegen

public static void clearMethodCodegen(CodegenMethodNode method)

processOutputLimitedJoin

public UniformPair<EventBean[]> processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet,
                                                         boolean generateSynthetic)

Description copied from interface: ResultSetProcessor

Processes batched events in case of output-rate limiting.

Specified by:

processOutputLimitedJoin in interface ResultSetProcessor

Parameters:

joinEventsSet - the join results

generateSynthetic - flag to indicate whether synthetic events must be generated

Returns:

results for dispatch

processOutputLimitedJoinCodegen

public static void processOutputLimitedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                                   CodegenClassScope classScope,
                                                   CodegenMethodNode method,
                                                   CodegenInstanceAux instance)

processOutputLimitedView

public UniformPair<EventBean[]> processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList,
                                                         boolean generateSynthetic)

Description copied from interface: ResultSetProcessor

Processes batched events in case of output-rate limiting.

Specified by:

processOutputLimitedView in interface ResultSetProcessor

Parameters:

viewEventsList - the view results

generateSynthetic - flag to indicate whether synthetic events must be generated

Returns:

results for dispatch

processOutputLimitedViewCodegen

public static void processOutputLimitedViewCodegen(ResultSetProcessorAggregateGroupedForge 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

stopMethodCodegen

public static void stopMethodCodegen(CodegenMethodNode method,
                                     CodegenInstanceAux instance)

generateOutputBatchedJoinUnkeyed

public 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)

Specified by:

generateOutputBatchedJoinUnkeyed in interface ResultSetProcessorAggregateGrouped

generateOutputBatchedSingle

public EventBean generateOutputBatchedSingle(java.lang.Object groupByKey,
                                             EventBean[] eventsPerStream,
                                             boolean isNewData,
                                             boolean isSynthesize)

Specified by:

generateOutputBatchedSingle in interface ResultSetProcessorAggregateGrouped

generateOutputBatchedViewPerKey

public void generateOutputBatchedViewPerKey(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,
                                            EventBean[] eventsPerStream)

Specified by:

generateOutputBatchedViewPerKey in interface ResultSetProcessorAggregateGrouped

generateOutputBatchedJoinPerKey

public 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)

Specified by:

generateOutputBatchedJoinPerKey in interface ResultSetProcessorAggregateGrouped

removedAggregationGroupKey

public void removedAggregationGroupKey(java.lang.Object key)

Specified by:

removedAggregationGroupKey in interface AggregationRowRemovedCallback

processOutputLimitedLastAllNonBufferedView

public void processOutputLimitedLastAllNonBufferedView(EventBean[] newData,
                                                       EventBean[] oldData,
                                                       boolean isGenerateSynthetic)

Specified by:

processOutputLimitedLastAllNonBufferedView in interface ResultSetProcessor

processOutputLimitedLastAllNonBufferedViewCodegen

public static void processOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                                                     CodegenClassScope classScope,
                                                                     CodegenMethodNode method,
                                                                     CodegenInstanceAux instance)

processOutputLimitedLastAllNonBufferedJoin

public void processOutputLimitedLastAllNonBufferedJoin(java.util.Set<MultiKey<EventBean>> newData,
                                                       java.util.Set<MultiKey<EventBean>> oldData,
                                                       boolean isGenerateSynthetic)

Specified by:

processOutputLimitedLastAllNonBufferedJoin in interface ResultSetProcessor

processOutputLimitedLastAllNonBufferedJoinCodegen

public static void processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                                                     CodegenClassScope classScope,
                                                                     CodegenMethodNode method,
                                                                     CodegenInstanceAux instance)

continueOutputLimitedLastAllNonBufferedView

public UniformPair<EventBean[]> continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize)

Specified by:

continueOutputLimitedLastAllNonBufferedView in interface ResultSetProcessor

continueOutputLimitedLastAllNonBufferedViewCodegen

public static void continueOutputLimitedLastAllNonBufferedViewCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                                                      CodegenMethodNode method)

continueOutputLimitedLastAllNonBufferedJoin

public UniformPair<EventBean[]> continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize)

Specified by:

continueOutputLimitedLastAllNonBufferedJoin in interface ResultSetProcessor

continueOutputLimitedLastAllNonBufferedJoinCodegen

public static void continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorAggregateGroupedForge forge,
                                                                      CodegenMethodNode method)

generateOutputBatchedViewUnkeyed

public 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)

Specified by:

generateOutputBatchedViewUnkeyed in interface ResultSetProcessorAggregateGrouped

hasHavingClause

public boolean hasHavingClause()

Specified by:

hasHavingClause in interface ResultSetProcessorAggregateGrouped

evaluateHavingClause

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

Specified by:

evaluateHavingClause in interface ResultSetProcessorAggregateGrouped

isSelectRStream

public boolean isSelectRStream()

Specified by:

isSelectRStream in interface ResultSetProcessorAggregateGrouped

getAgentInstanceContext

public ExprEvaluatorContext getAgentInstanceContext()

Specified by:

getAgentInstanceContext in interface ResultSetProcessorAggregateGrouped