com.espertech.esper.epl.core

Class ResultSetProcessorRowForAll

java.lang.Object

com.espertech.esper.epl.core.ResultSetProcessorRowForAll

All Implemented Interfaces:

ResultSetProcessor, StopCallback

public class ResultSetProcessorRowForAll
extends Object
implements ResultSetProcessor

Result set processor for the case: aggregation functions used in the select clause, and no group-by, and all properties in the select clause are under an aggregation function.

This processor does not perform grouping, every event entering and leaving is in the same group. Produces one old event and one new event row every time either at least one old or new event is received. Aggregation state is simply one row holding all the state.

Field Summary

Fields

Modifier and Type	Field and Description
protected AggregationService	aggregationService
protected ExprEvaluatorContext	exprEvaluatorContext
protected ResultSetProcessorRowForAllFactory	prototype

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorRowForAll(ResultSetProcessorRowForAllFactory prototype, SelectExprProcessor selectExprProcessor, OrderByProcessor orderByProcessor, AggregationService aggregationService, AgentInstanceContext agentInstanceContext)

Method Summary

Modifier and Type	Method and Description
void	acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor)
void	applyJoinResult(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents)
void	applyViewResult(EventBean[] newData, EventBean[] oldData)
void	clear() Clear out current state.
UniformPair<EventBean[]>	continueOutputLimitedLastAllNonBufferedJoin(boolean isSynthesize, boolean isAll)
UniformPair<EventBean[]>	continueOutputLimitedLastAllNonBufferedView(boolean isSynthesize, boolean isAll)
AggregationService	getAggregationService()
Iterator<EventBean>	getIterator(Set<MultiKey<EventBean>> joinSet) Returns the iterator for iterating over a join-result.
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.
EventBean[]	getSelectListEvents(boolean isNewData, boolean isSynthesize, boolean join)
boolean	hasAggregation()
UniformPair<EventBean[]>	processJoinResult(Set<MultiKey<EventBean>> newEvents, 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(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.
void	processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents, Set<MultiKey<EventBean>> oldEvents, boolean isGenerateSynthetic, boolean isAll)
void	processOutputLimitedLastAllNonBufferedView(EventBean[] newData, EventBean[] oldData, boolean isGenerateSynthetic, boolean isAll)
UniformPair<EventBean[]>	processOutputLimitedView(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	setAgentInstanceContext(AgentInstanceContext context)
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 ResultSetProcessorRowForAllFactory prototype

aggregationService

protected final AggregationService aggregationService

exprEvaluatorContext

protected ExprEvaluatorContext exprEvaluatorContext

Constructor Detail

ResultSetProcessorRowForAll

public ResultSetProcessorRowForAll(ResultSetProcessorRowForAllFactory prototype,
                                   SelectExprProcessor selectExprProcessor,
                                   OrderByProcessor orderByProcessor,
                                   AggregationService aggregationService,
                                   AgentInstanceContext agentInstanceContext)

Method Detail

setAgentInstanceContext

public void setAgentInstanceContext(AgentInstanceContext context)

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.

processJoinResult

public UniformPair<EventBean[]> processJoinResult(Set<MultiKey<EventBean>> newEvents,
                                                  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

getSelectListEvents

public EventBean[] getSelectListEvents(boolean isNewData,
                                       boolean isSynthesize,
                                       boolean join)

getIterator

public 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 Iterator<EventBean> getIterator(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(List<UniformPair<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(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

applyViewResult

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

Specified by:

applyViewResult in interface ResultSetProcessor

applyJoinResult

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

Specified by:

applyJoinResult in interface ResultSetProcessor

getAggregationService

public AggregationService getAggregationService()

stop

public void stop()

Description copied from interface: StopCallback

Stops the underlying resources.

Specified by:

stop in interface StopCallback

processOutputLimitedLastAllNonBufferedView

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

Specified by:

processOutputLimitedLastAllNonBufferedView in interface ResultSetProcessor

processOutputLimitedLastAllNonBufferedJoin

public void processOutputLimitedLastAllNonBufferedJoin(Set<MultiKey<EventBean>> newEvents,
                                                       Set<MultiKey<EventBean>> oldEvents,
                                                       boolean isGenerateSynthetic,
                                                       boolean isAll)

Specified by:

processOutputLimitedLastAllNonBufferedJoin in interface ResultSetProcessor

continueOutputLimitedLastAllNonBufferedView

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

Specified by:

continueOutputLimitedLastAllNonBufferedView in interface ResultSetProcessor

continueOutputLimitedLastAllNonBufferedJoin

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

Specified by:

continueOutputLimitedLastAllNonBufferedJoin in interface ResultSetProcessor

acceptHelperVisitor

public void acceptHelperVisitor(ResultSetProcessorOutputHelperVisitor visitor)

Specified by:

acceptHelperVisitor in interface ResultSetProcessor