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".
  • Field Details

  • Constructor Details

    • RowLimitProcessor

      public RowLimitProcessor(VariableReader numRowsVariableReader, VariableReader offsetVariableReader, int currentRowLimit, int currentOffset)
  • Method Details

    • 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)