com.espertech.esper.epl.core
Class ResultSetProcessorRowPerGroup

java.lang.Object
  com.espertech.esper.epl.core.ResultSetProcessorRowPerGroup

All Implemented Interfaces:

AggregationRowRemovedCallback, ResultSetProcessor

Direct Known Subclasses:

ResultSetProcessorRowPerGroupUnbound

public class ResultSetProcessorRowPerGroup
extends java.lang.Object
implements ResultSetProcessor, AggregationRowRemovedCallback

Result set processor for the fully-grouped case: there is a group-by and all non-aggregation event properties in the select clause are listed in the group by, and there are aggregation functions.

Produces one row for each group that changed (and not one row per event). Computes MultiKey group-by keys for each event and uses a set of the group-by keys to generate the result rows, using the first (old or new, anyone) event for each distinct group-by key.

Field Summary

protected AgentInstanceContext	agentInstanceContext
protected AggregationService	aggregationService
protected java.util.Map<java.lang.Object,EventBean[]>	groupRepsView
protected OrderByProcessor	orderByProcessor
protected ResultSetProcessorRowPerGroupFactory	prototype
protected SelectExprProcessor	selectExprProcessor

Constructor Summary

ResultSetProcessorRowPerGroup(ResultSetProcessorRowPerGroupFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

Method Summary

void	applyJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents)
void	applyViewResult(EventBean[] newData, EventBean[] oldData)
void	clear() Clear out current state.
protected java.lang.Object	generateGroupKey(EventBean[] eventsPerStream, boolean isNewData)
protected java.lang.Object[]	generateGroupKeys(EventBean[] events, java.util.Map<java.lang.Object,EventBean> eventPerKey, boolean isNewData)
protected EventBean[]	generateOutputEventsView(java.util.Map<java.lang.Object,EventBean> keysAndEvents, boolean isNewData, boolean isSynthesize)
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.
protected java.util.Iterator<EventBean>	getIteratorSorted(java.util.Iterator<EventBean> parentIter)
ExprEvaluator	getOptionalHavingNode() Returns the optional having expression.
EventType	getResultEventType() Returns the event type of processed results.
SelectExprProcessor	getSelectExprProcessor() Returns the select expression processor
boolean	hasAggregation()
java.util.Iterator<EventBean>	obtainIterator(Viewable parent)
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).
UniformPair<EventBean[]>	processOutputLimitedJoin(java.util.List<UniformPair<java.util.Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.
UniformPair<EventBean[]>	processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.
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).
void	removed(java.lang.Object key)
void	setAgentInstanceContext(AgentInstanceContext agentInstanceContext)

Methods inherited from class java.lang.Object

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

Field Detail

prototype

protected final ResultSetProcessorRowPerGroupFactory prototype

selectExprProcessor

protected final SelectExprProcessor selectExprProcessor

orderByProcessor

protected final OrderByProcessor orderByProcessor

aggregationService

protected final AggregationService aggregationService

agentInstanceContext

protected AgentInstanceContext agentInstanceContext

groupRepsView

protected final java.util.Map<java.lang.Object,EventBean[]> groupRepsView

Constructor Detail

ResultSetProcessorRowPerGroup

public ResultSetProcessorRowPerGroup(ResultSetProcessorRowPerGroupFactory prototype,
                                     SelectExprProcessor selectExprProcessor,
                                     OrderByProcessor orderByProcessor,
                                     AggregationService aggregationService,
                                     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.

applyViewResult

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

Specified by:

applyViewResult in interface ResultSetProcessor

applyJoinResult

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

Specified by:

applyJoinResult in interface ResultSetProcessor

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

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

generateOutputEventsView

protected EventBean[] generateOutputEventsView(java.util.Map<java.lang.Object,EventBean> keysAndEvents,
                                               boolean isNewData,
                                               boolean isSynthesize)

generateGroupKeys

protected java.lang.Object[] generateGroupKeys(EventBean[] events,
                                               java.util.Map<java.lang.Object,EventBean> eventPerKey,
                                               boolean isNewData)

getOptionalHavingNode

public ExprEvaluator getOptionalHavingNode()

Returns the optional having expression.

Returns:

having expression node

getSelectExprProcessor

public SelectExprProcessor getSelectExprProcessor()

Returns the select expression processor

Returns:

select processor.

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

obtainIterator

public java.util.Iterator<EventBean> obtainIterator(Viewable parent)

getIteratorSorted

protected java.util.Iterator<EventBean> getIteratorSorted(java.util.Iterator<EventBean> parentIter)

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

clear

public void clear()

Description copied from interface: ResultSetProcessor

Clear out current state.

Specified by:

clear in interface ResultSetProcessor

processOutputLimitedJoin

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

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

outputLimitLimitType - the type of output rate limiting

Returns:

results for dispatch

processOutputLimitedView

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

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

outputLimitLimitType - the type of output rate limiting

Returns:

results for dispatch

hasAggregation

public boolean hasAggregation()

Specified by:

hasAggregation in interface ResultSetProcessor

removed

public void removed(java.lang.Object key)

Specified by:

removed in interface AggregationRowRemovedCallback

generateGroupKey

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