com.espertech.esper.epl.core

Class ResultSetProcessorBaseSimple

java.lang.Object

com.espertech.esper.epl.core.ResultSetProcessorBaseSimple

All Implemented Interfaces:

ResultSetProcessor, StopCallback

Direct Known Subclasses:

ResultSetProcessorHandThrough, ResultSetProcessorSimple

public abstract class ResultSetProcessorBaseSimple
extends Object
implements ResultSetProcessor

Result set processor for the simplest case: no aggregation functions used in the select clause, and no group-by.

The processor generates one row for each event entering (new event) and one row for each event leaving (old event).

Constructor Summary

Constructors

Constructor and Description
ResultSetProcessorBaseSimple()

Method Summary

Modifier and Type	Method and Description
void	clear() Clear out current state.
UniformPair<EventBean[]>	processOutputLimitedJoin(List<UniformPair<Set<MultiKey<EventBean>>>> joinEventsSet, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.
UniformPair<EventBean[]>	processOutputLimitedView(List<UniformPair<EventBean[]>> viewEventsList, boolean generateSynthetic, OutputLimitLimitType outputLimitLimitType) Processes batched events in case of output-rate limiting.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.espertech.esper.epl.core.ResultSetProcessor

acceptHelperVisitor, applyJoinResult, applyViewResult, continueOutputLimitedLastAllNonBufferedJoin, continueOutputLimitedLastAllNonBufferedView, getIterator, getIterator, getResultEventType, hasAggregation, processJoinResult, processOutputLimitedLastAllNonBufferedJoin, processOutputLimitedLastAllNonBufferedView, processViewResult, setAgentInstanceContext

Methods inherited from interface com.espertech.esper.util.StopCallback

stop

Constructor Detail

ResultSetProcessorBaseSimple

public ResultSetProcessorBaseSimple()

Method Detail

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