com.espertech.esper.epl.core
Class RowLimitProcessor

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

public class RowLimitProcessor
extends java.lang.Object

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

Constructor Summary

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

Method Summary

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)