com.espertech.esper.epl.core

Class RowLimitProcessor

java.lang.Object

com.espertech.esper.epl.core.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
protected EventBean[]	applyLimit(EventBean[] outgoingEvents)
protected void	determineCurrentLimit()
protected 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()

determineLimitAndApply

protected EventBean[] determineLimitAndApply(EventBean[] outgoingEvents)

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

Parameters:

outgoingEvents - unlimited

Returns:

limited

determineCurrentLimit

protected void determineCurrentLimit()

applyLimit

protected EventBean[] applyLimit(EventBean[] outgoingEvents)