com.espertech.esper.epl.core.resultset.rowpergrouprollup

Class ResultSetProcessorRowPerGroupRollupImpl

java.lang.Object

com.espertech.esper.epl.core.resultset.rowpergrouprollup.ResultSetProcessorRowPerGroupRollupImpl

All Implemented Interfaces:

AggregationRowRemovedCallback, ResultSetProcessor, ResultSetProcessorRowPerGroupRollup, StopCallback

Direct Known Subclasses:

ResultSetProcessorRowPerGroupRollupUnbound

public class ResultSetProcessorRowPerGroupRollupImpl
extends java.lang.Object
implements ResultSetProcessorRowPerGroupRollup

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentInstanceContext	agentInstanceContext
protected AggregationService	aggregationService
protected OrderByProcessor	orderByProcessor
protected ResultSetProcessorRowPerGroupRollupFactory	prototype

Method Summary

Modifier and Type	Method and Description
void	acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor)
void	applyJoinResult(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents)
static void	applyJoinResultCodegen(ResultSetProcessorRowPerGroupRollupForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	applyViewResult(EventBean[] newData, EventBean[] oldData)
void	clear() Clear out current state.
UniformPair<EventBean[]>	continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize)
static void	continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerGroupRollupForge forge, CodegenMethodNode method)
UniformPair<EventBean[]>	continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize)
java.lang.Object	generateGroupKeySingle(EventBean[] eventsPerStream, boolean isNewData)
void	generateOutputBatched(java.lang.Object mk, AggregationGroupByRollupLevel level, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize, java.util.List<EventBean> resultEvents, java.util.List<java.lang.Object> optSortKeys)
void	generateOutputBatchedMapUnsorted(boolean join, java.lang.Object mk, AggregationGroupByRollupLevel level, EventBean[] eventsPerStream, boolean isNewData, boolean isSynthesize, java.util.Map<java.lang.Object,EventBean> resultEvents)
ExprEvaluatorContext	getAgentInstanceContext()
AggregationService	getAggregationService()
AggregationGroupByRollupDesc	getGroupByRollupDesc()
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.
EventType	getResultEventType() Returns the event type of processed results.
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).
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(ResultSetProcessorRowPerGroupRollupForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	processOutputLimitedLastAllNonBufferedJoin(java.util.Set<MultiKey<EventBean>> newEvents, java.util.Set<MultiKey<EventBean>> oldEvents, boolean isGenerateSynthetic)
static void	processOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerGroupRollupForge forge, CodegenClassScope classScope, CodegenMethodNode method, CodegenInstanceAux instance)
void	processOutputLimitedLastAllNonBufferedView(EventBean[] newData, EventBean[] oldData, boolean isGenerateSynthetic)
UniformPair<EventBean[]>	processOutputLimitedView(java.util.List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic) 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	removedAggregationGroupKey(java.lang.Object key)
void	setAgentInstanceContext(AgentInstanceContext agentInstanceContext)
void	stop() Stops the underlying resources.

Methods inherited from class java.lang.Object

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

Field Detail

prototype

protected final ResultSetProcessorRowPerGroupRollupFactory prototype

orderByProcessor

protected final OrderByProcessor orderByProcessor

aggregationService

protected final AggregationService aggregationService

agentInstanceContext

protected AgentInstanceContext agentInstanceContext

Method Detail

setAgentInstanceContext

public void setAgentInstanceContext(AgentInstanceContext agentInstanceContext)

Specified by:

setAgentInstanceContext in interface ResultSetProcessor

getAggregationService

public AggregationService getAggregationService()

Specified by:

getAggregationService in interface ResultSetProcessorRowPerGroupRollup

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.

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

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

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)

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(ResultSetProcessorRowPerGroupRollupForge 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

acceptHelperVisitor

public void acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor)

Specified by:

acceptHelperVisitor in interface ResultSetProcessor

removedAggregationGroupKey

public void removedAggregationGroupKey(java.lang.Object key)

Specified by:

removedAggregationGroupKey in interface AggregationRowRemovedCallback

generateGroupKeySingle

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

Specified by:

generateGroupKeySingle in interface ResultSetProcessorRowPerGroupRollup

generateOutputBatched

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

Specified by:

generateOutputBatched in interface ResultSetProcessorRowPerGroupRollup

generateOutputBatchedMapUnsorted

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

Specified by:

generateOutputBatchedMapUnsorted in interface ResultSetProcessorRowPerGroupRollup

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

applyJoinResultCodegen

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

processOutputLimitedLastAllNonBufferedView

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

Specified by:

processOutputLimitedLastAllNonBufferedView in interface ResultSetProcessor

processOutputLimitedLastAllNonBufferedJoin

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

Specified by:

processOutputLimitedLastAllNonBufferedJoin in interface ResultSetProcessor

processOutputLimitedLastAllNonBufferedJoinCodegen

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

continueOutputLimitedLastAllNonBufferedView

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

Specified by:

continueOutputLimitedLastAllNonBufferedView in interface ResultSetProcessor

continueOutputLimitedLastAllNonBufferedJoin

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

Specified by:

continueOutputLimitedLastAllNonBufferedJoin in interface ResultSetProcessor

continueOutputLimitedLastAllNonBufferedJoinCodegen

public static void continueOutputLimitedLastAllNonBufferedJoinCodegen(ResultSetProcessorRowPerGroupRollupForge forge,
                                                                      CodegenMethodNode method)

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

getAgentInstanceContext

public ExprEvaluatorContext getAgentInstanceContext()

Specified by:

getAgentInstanceContext in interface ResultSetProcessorRowPerGroupRollup

isSelectRStream

public boolean isSelectRStream()

Specified by:

isSelectRStream in interface ResultSetProcessorRowPerGroupRollup

getGroupByRollupDesc

public AggregationGroupByRollupDesc getGroupByRollupDesc()

Specified by:

getGroupByRollupDesc in interface ResultSetProcessorRowPerGroupRollup