Class RowLimitProcessor
java.lang.Object
com.espertech.esper.common.internal.epl.resultset.order.RowLimitProcessor
An limit-processor for use with "limit" and "offset".
-
Field Summary
-
Constructor Summary
ConstructorDescriptionRowLimitProcessor
(VariableReader numRowsVariableReader, VariableReader offsetVariableReader, int currentRowLimit, int currentOffset) -
Method Summary
Modifier and TypeMethodDescriptionapplyLimit
(EventBean[] outgoingEvents) determineApplyLimit2Events
(EventBean first, EventBean second) void
determineLimitAndApply
(EventBean[] outgoingEvents) Determine the current limit and applies the limiting function to outgoing events.int
int
-
Field Details
-
EPTYPE
-
-
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
-
determineLimitAndApply
Determine the current limit and applies the limiting function to outgoing events.- Parameters:
outgoingEvents
- unlimited- Returns:
- limited
-
determineApplyLimit2Events
-