com.espertech.esper.epl.core
Class ResultSetProcessorBaseSimple

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

All Implemented Interfaces:

ResultSetProcessor

Direct Known Subclasses:

ResultSetProcessorHandThrough, ResultSetProcessorSimple

public abstract class ResultSetProcessorBaseSimple
extends java.lang.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

ResultSetProcessorBaseSimple()

Method Summary

void	clear() Clear out current state.
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.

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

applyJoinResult, applyViewResult, getIterator, getIterator, getResultEventType, hasAggregation, processJoinResult, processViewResult, setAgentInstanceContext

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