com.espertech.esper.epl.core.orderby

Class OrderByProcessorOrderedLimit

java.lang.Object

com.espertech.esper.epl.core.orderby.OrderByProcessorOrderedLimit

All Implemented Interfaces:

OrderByProcessor

public class OrderByProcessorOrderedLimit
extends java.lang.Object
implements OrderByProcessor

Sorter and row limiter in one: sorts using a sorter and row limits

Constructor Summary

Constructors

Constructor and Description
OrderByProcessorOrderedLimit(OrderByProcessorImpl orderByProcessor, RowLimitProcessor rowLimitProcessor) Ctor.

Method Summary

Modifier and Type	Method and Description
java.lang.Object	getSortKey(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext) Returns the sort key for a given row.
java.lang.Object	getSortKeyRollup(EventBean[] eventsPerStream, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext, AggregationGroupByRollupLevel level) Returns the sort key for a given row for rollup.
EventBean[]	sortPlain(EventBean[] outgoingEvents, EventBean[][] generatingEvents, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService) Sort the output events.
EventBean[]	sortRollup(EventBean[] outgoingEvents, java.util.List<GroupByRollupKey> currentGenerators, boolean newData, AgentInstanceContext agentInstanceContext, AggregationService aggregationService) Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys.
static void	sortRollupCodegen(OrderByProcessorOrderedLimitForge forge, CodegenMethodNode method, CodegenClassScope classScope, CodegenNamedMethods namedMethods)
EventBean[]	sortTwoKeys(EventBean first, java.lang.Object sortKeyFirst, EventBean second, java.lang.Object sortKeySecond) Sort two keys and events
EventBean[]	sortWGroupKeys(EventBean[] outgoingEvents, EventBean[][] generatingEvents, java.lang.Object[] groupByKeys, boolean isNewData, ExprEvaluatorContext exprEvaluatorContext, AggregationService aggregationService) Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys.
EventBean[]	sortWOrderKeys(EventBean[] outgoingEvents, java.lang.Object[] orderKeys, ExprEvaluatorContext exprEvaluatorContext) Sort a given array of outgoing events using the sort keys returning a sorted outgoing event array.

Methods inherited from class java.lang.Object

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

Constructor Detail

OrderByProcessorOrderedLimit

public OrderByProcessorOrderedLimit(OrderByProcessorImpl orderByProcessor,
                                    RowLimitProcessor rowLimitProcessor)

Ctor.

Parameters:

orderByProcessor - the sorter

rowLimitProcessor - the row limiter

Method Detail

sortPlain

public EventBean[] sortPlain(EventBean[] outgoingEvents,
                             EventBean[][] generatingEvents,
                             boolean isNewData,
                             ExprEvaluatorContext exprEvaluatorContext,
                             AggregationService aggregationService)

Description copied from interface: OrderByProcessor

Sort the output events. If the order-by processor needs group-by keys to evaluate the expressions in the order-by clause, these will be computed from the generating events.

Specified by:

sortPlain in interface OrderByProcessor

Parameters:

outgoingEvents - - the events to be sorted

generatingEvents - - the events that generated the output events (each event has a corresponding array of generating events per different event streams)

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

exprEvaluatorContext - context for expression evalauation

aggregationService - aggregation svc

Returns:

an array containing the output events in sorted order

sortRollup

public EventBean[] sortRollup(EventBean[] outgoingEvents,
                              java.util.List<GroupByRollupKey> currentGenerators,
                              boolean newData,
                              AgentInstanceContext agentInstanceContext,
                              AggregationService aggregationService)

Description copied from interface: OrderByProcessor

Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys.

Specified by:

sortRollup in interface OrderByProcessor

Parameters:

outgoingEvents - - the events to sort

currentGenerators - - the events that generated the output events (each event has a corresponding array of generating events per different event streams)

newData - - indicates whether we are dealing with new data (istream) or old data (rstream)

agentInstanceContext - context for expression evaluation

aggregationService - aggregation svc

Returns:

an array containing the output events in sorted order

sortRollupCodegen

public static void sortRollupCodegen(OrderByProcessorOrderedLimitForge forge,
                                     CodegenMethodNode method,
                                     CodegenClassScope classScope,
                                     CodegenNamedMethods namedMethods)

sortWGroupKeys

public EventBean[] sortWGroupKeys(EventBean[] outgoingEvents,
                                  EventBean[][] generatingEvents,
                                  java.lang.Object[] groupByKeys,
                                  boolean isNewData,
                                  ExprEvaluatorContext exprEvaluatorContext,
                                  AggregationService aggregationService)

Description copied from interface: OrderByProcessor

Sort the output events, using the provided group-by keys for evaluating grouped aggregation functions, and avoiding the cost of recomputing the keys.

Specified by:

sortWGroupKeys in interface OrderByProcessor

Parameters:

outgoingEvents - - the events to sort

generatingEvents - - the events that generated the output events (each event has a corresponding array of generating events per different event streams)

groupByKeys - - the keys to use for determining the group-by group of output events

isNewData - - indicates whether we are dealing with new data (istream) or old data (rstream)

exprEvaluatorContext - context for expression evaluation

aggregationService - aggregation svc

Returns:

an array containing the output events in sorted order

getSortKey

public java.lang.Object getSortKey(EventBean[] eventsPerStream,
                                   boolean isNewData,
                                   ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: OrderByProcessor

Returns the sort key for a given row.

Specified by:

getSortKey in interface OrderByProcessor

Parameters:

eventsPerStream - is the row consisting of one event per stream

isNewData - is true for new data

exprEvaluatorContext - context for expression evalauation

Returns:

sort key

getSortKeyRollup

public java.lang.Object getSortKeyRollup(EventBean[] eventsPerStream,
                                         boolean isNewData,
                                         ExprEvaluatorContext exprEvaluatorContext,
                                         AggregationGroupByRollupLevel level)

Description copied from interface: OrderByProcessor

Returns the sort key for a given row for rollup.

Specified by:

getSortKeyRollup in interface OrderByProcessor

Parameters:

eventsPerStream - is the row consisting of one event per stream

isNewData - is true for new data

exprEvaluatorContext - context for expression evalauation

level - rollup level

Returns:

sort key

sortWOrderKeys

public EventBean[] sortWOrderKeys(EventBean[] outgoingEvents,
                                  java.lang.Object[] orderKeys,
                                  ExprEvaluatorContext exprEvaluatorContext)

Description copied from interface: OrderByProcessor

Sort a given array of outgoing events using the sort keys returning a sorted outgoing event array.

Specified by:

sortWOrderKeys in interface OrderByProcessor

Parameters:

outgoingEvents - is the events to sort

orderKeys - is the keys to sort by

exprEvaluatorContext - context for expression evalauation

Returns:

sorted events

sortTwoKeys

public EventBean[] sortTwoKeys(EventBean first,
                               java.lang.Object sortKeyFirst,
                               EventBean second,
                               java.lang.Object sortKeySecond)

Description copied from interface: OrderByProcessor

Sort two keys and events

Specified by:

sortTwoKeys in interface OrderByProcessor

Parameters:

first - first

sortKeyFirst - sort key first

second - second

sortKeySecond - sort key seconds

Returns:

sorted