com.espertech.esper.common.internal.epl.resultset.order

Class RowLimitProcessor

java.lang.Object

com.espertech.esper.common.internal.epl.resultset.order.RowLimitProcessor

public class RowLimitProcessor
extends Object

An limit-processor for use with "limit" and "offset".

Constructor Summary

Constructors

Constructor and Description
RowLimitProcessor(VariableReader numRowsVariableReader, VariableReader offsetVariableReader, int currentRowLimit, int currentOffset)

Method Summary

Modifier and Type	Method and Description
EventBean[]	applyLimit(EventBean[] outgoingEvents)
EventBean[]	determineApplyLimit2Events(EventBean first, EventBean second)
void	determineCurrentLimit()
EventBean[]	determineLimitAndApply(EventBean[] outgoingEvents) Determine the current limit and applies the limiting function to outgoing events.
int	getCurrentOffset()
int	getCurrentRowLimit()

Methods inherited from class java.lang.Object

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

Constructor Detail

RowLimitProcessor

public RowLimitProcessor(VariableReader numRowsVariableReader,
                         VariableReader offsetVariableReader,
                         int currentRowLimit,
                         int currentOffset)

Method Detail

getCurrentRowLimit

public int getCurrentRowLimit()

getCurrentOffset

public int getCurrentOffset()

determineCurrentLimit

public void determineCurrentLimit()

applyLimit

public EventBean[] applyLimit(EventBean[] outgoingEvents)

determineLimitAndApply

public EventBean[] determineLimitAndApply(EventBean[] outgoingEvents)

Determine the current limit and applies the limiting function to outgoing events.

Parameters:

outgoingEvents - unlimited

Returns:

limited

determineApplyLimit2Events

public EventBean[] determineApplyLimit2Events(EventBean first,
                                              EventBean second)